init.c

 
#include <winpr/config.h>
 
#include <winpr/synch.h>
#include <winpr/interlocked.h>
 
#include "../log.h"
#define TAG WINPR_TAG("sync")
 
#if (!defined(_WIN32)) || (defined(_WIN32) && (_WIN32_WINNT < 0x0600))
 
BOOL winpr_InitOnceBeginInitialize(WINPR_ATTR_UNUSED LPINIT_ONCE lpInitOnce,
                                   WINPR_ATTR_UNUSED DWORD dwFlags,
                                   WINPR_ATTR_UNUSED PBOOL fPending,
                                   WINPR_ATTR_UNUSED LPVOID* lpContext)
{
  WLog_ERR(TAG, "not implemented");
  return FALSE;
}
 
BOOL winpr_InitOnceComplete(WINPR_ATTR_UNUSED LPINIT_ONCE lpInitOnce,
                            WINPR_ATTR_UNUSED DWORD dwFlags, WINPR_ATTR_UNUSED LPVOID lpContext)
{
  WLog_ERR(TAG, "not implemented");
  return FALSE;
}
 
VOID winpr_InitOnceInitialize(WINPR_ATTR_UNUSED PINIT_ONCE InitOnce)
{
  WLog_ERR(TAG, "not implemented");
}
 
BOOL winpr_InitOnceExecuteOnce(PINIT_ONCE InitOnce, PINIT_ONCE_FN InitFn, PVOID Parameter,
                               LPVOID* Context)
{
  for (;;)
  {
    switch ((ULONG_PTR)InitOnce->Ptr & 3)
    {
      case 2:
        /* already completed successfully */
        return TRUE;
 
      case 0:
 
        /* first time */
        if (InterlockedCompareExchangePointer(&InitOnce->Ptr, (PVOID)1, (PVOID)0) !=
            (PVOID)0)
        {
          /* some other thread was faster */
          break;
        }
 
        /* it's our job to call the init function */
        if (InitFn(InitOnce, Parameter, Context))
        {
          /* success */
          InitOnce->Ptr = (PVOID)2;
          return TRUE;
        }
 
        /* the init function returned an error,  reset the status */
        InitOnce->Ptr = (PVOID)0;
        return FALSE;
 
      case 1:
        /* in progress */
        break;
 
      default:
        WLog_ERR(TAG, "internal error");
        return FALSE;
    }
 
    Sleep(5);
  }
}
 
#endif