sal/osl/w32/conditn.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "system.h"
  21
  22 #include <osl/conditn.h>
  23 #include <osl/diagnose.h>
  24 #include <osl/time.h>
  25
  26 /*
  27     under WIN32, we use the void* oslCondition
  28     as a WIN32 HANDLE (which is also a 32-bit value)
  29 */
  30
  31 oslCondition SAL_CALL osl_createCondition(void)
  32 {
  33     oslCondition Condition;
  34
  35     Condition= reinterpret_cast<oslCondition>(CreateEventW(nullptr,   /* no security */
  36                                                            true,      /* manual reset */
  37                                                            false,     /* initial state not signaled */
  38                                                            nullptr)); /* automatic name */
  39
  40     return Condition;
  41
  42 }
  43
  44 void SAL_CALL osl_destroyCondition(oslCondition Condition)
  45 {
  46     if(Condition)
  47         OSL_VERIFY(CloseHandle(Condition));
  48 }
  49
  50 sal_Bool SAL_CALL osl_setCondition(oslCondition Condition)
  51 {
  52     OSL_ASSERT(Condition);
  53
  54     return SetEvent(reinterpret_cast<HANDLE>(Condition)) != FALSE;
  55 }
  56
  57 sal_Bool SAL_CALL osl_resetCondition(oslCondition Condition)
  58 {
  59     OSL_ASSERT(Condition);
  60
  61     return ResetEvent(reinterpret_cast<HANDLE>(Condition)) != FALSE;
  62 }
  63
  64 oslConditionResult SAL_CALL osl_waitCondition(oslCondition Condition,
  65                                      const TimeValue* pTimeout)
  66 {
  67     DWORD timeout;
  68
  69     OSL_ASSERT(Condition);
  70
  71     if (pTimeout)
  72         timeout = pTimeout->Seconds * 1000 + pTimeout->Nanosec / 1000000L;
  73     else
  74         timeout = INFINITE;
  75
  76     /* It's necessary to process SendMessage calls to the current thread to give other threads
  77         access to COM objects instantiated in this thread */
  78
  79     while ( true )
  80     {
  81         /* Only wake up if a SendMessage call to the threads message loop is detected */
  82         switch( MsgWaitForMultipleObjects( 1, reinterpret_cast<HANDLE *>(&Condition), FALSE, timeout, QS_SENDMESSAGE ) )
  83         {
  84             case WAIT_OBJECT_0 + 1:
  85                 {
  86                 MSG msg;
  87
  88                 /* We Must not dispatch the message. PM_NOREMOVE leaves the message queue untouched
  89                  but dispatches SendMessage calls automatically */
  90
  91                 PeekMessageW( &msg, nullptr, 0, 0, PM_NOREMOVE );
  92                 }
  93                 break;
  94
  95             case WAIT_OBJECT_0:
  96                 return osl_cond_result_ok;
  97
  98             case WAIT_TIMEOUT:
  99                 return osl_cond_result_timeout;
 100
 101             default:
 102                 return osl_cond_result_error;
 103         }
 104     }
 105 }
 106
 107 sal_Bool SAL_CALL osl_checkCondition(oslCondition Condition)
 108 {
 109     OSL_ASSERT(Condition);
 110
 111     return WaitForSingleObject(reinterpret_cast<HANDLE>(Condition), 0) == WAIT_OBJECT_0;
 112 }
 113
 114 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */