git.oblomov.eu Git - wine/blob - dlls/kernel/sync.c

   1 /*
   2  * Kernel synchronization objects
   3  *
   4  * Copyright 1998 Alexandre Julliard
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2.1 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  */
  20
  21 #include "config.h"
  22 #include "wine/port.h"
  23
  24 #include <string.h>
  25 #ifdef HAVE_UNISTD_H
  26 # include <unistd.h>
  27 #endif
  28 #include <errno.h>
  29 #ifdef HAVE_SYS_IOCTL_H
  30 #include <sys/ioctl.h>
  31 #endif
  32 #ifdef HAVE_SYS_POLL_H
  33 #include <sys/poll.h>
  34 #endif
  35 #include <stdio.h>
  36
  37 #include "winbase.h"
  38 #include "winerror.h"
  39 #include "winnls.h"
  40
  41 #include "wine/server.h"
  42 #include "wine/unicode.h"
  43 #include "file.h"
  44
  45 #include "wine/debug.h"
  46
  47 WINE_DEFAULT_DEBUG_CHANNEL(win32);
  48
  49 /* check if current version is NT or Win95 */
  50 inline static int is_version_nt(void)
  51 {
  52     return !(GetVersion() & 0x80000000);
  53 }
  54
  55
  56 /***********************************************************************
  57  *           InitializeCriticalSection   (KERNEL32.@)
  58  */
  59 void WINAPI InitializeCriticalSection( CRITICAL_SECTION *crit )
  60 {
  61     NTSTATUS ret = RtlInitializeCriticalSection( crit );
  62     if (ret) RtlRaiseStatus( ret );
  63 }
  64
  65 /***********************************************************************
  66  *           InitializeCriticalSectionAndSpinCount   (KERNEL32.@)
  67  */
  68 BOOL WINAPI InitializeCriticalSectionAndSpinCount( CRITICAL_SECTION *crit, DWORD spincount )
  69 {
  70     NTSTATUS ret = RtlInitializeCriticalSectionAndSpinCount( crit, spincount );
  71     if (ret) RtlRaiseStatus( ret );
  72     return !ret;
  73 }
  74
  75 /***********************************************************************
  76  *           SetCriticalSectionSpinCount   (KERNEL32.@)
  77  * This function is available on NT4SP3 or later, but not Win98
  78  * It is SMP related
  79  */
  80 DWORD WINAPI SetCriticalSectionSpinCount( CRITICAL_SECTION *crit, DWORD spincount )
  81 {
  82     ULONG_PTR oldspincount = crit->SpinCount;
  83     if(spincount) FIXME("critsection=%p: spincount=%ld not supported\n", crit, spincount);
  84     crit->SpinCount = spincount;
  85     return oldspincount;
  86 }
  87
  88 /***********************************************************************
  89  *           MakeCriticalSectionGlobal   (KERNEL32.@)
  90  */
  91 void WINAPI MakeCriticalSectionGlobal( CRITICAL_SECTION *crit )
  92 {
  93     /* let's assume that only one thread at a time will try to do this */
  94     HANDLE sem = crit->LockSemaphore;
  95     if (!sem) NtCreateSemaphore( &sem, SEMAPHORE_ALL_ACCESS, NULL, 0, 1 );
  96     crit->LockSemaphore = ConvertToGlobalHandle( sem );
  97 }
  98
  99
 100 /***********************************************************************
 101  *           ReinitializeCriticalSection   (KERNEL32.@)
 102  */
 103 void WINAPI ReinitializeCriticalSection( CRITICAL_SECTION *crit )
 104 {
 105     if ( !crit->LockSemaphore )
 106         RtlInitializeCriticalSection( crit );
 107 }
 108
 109
 110 /***********************************************************************
 111  *           UninitializeCriticalSection   (KERNEL32.@)
 112  */
 113 void WINAPI UninitializeCriticalSection( CRITICAL_SECTION *crit )
 114 {
 115     RtlDeleteCriticalSection( crit );
 116 }
 117
 118
 119 /***********************************************************************
 120  *           CreateEventA    (KERNEL32.@)
 121  */
 122 HANDLE WINAPI CreateEventA( SECURITY_ATTRIBUTES *sa, BOOL manual_reset,
 123                             BOOL initial_state, LPCSTR name )
 124 {
 125     WCHAR buffer[MAX_PATH];
 126
 127     if (!name) return CreateEventW( sa, manual_reset, initial_state, NULL );
 128
 129     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 130     {
 131         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 132         return 0;
 133     }
 134     return CreateEventW( sa, manual_reset, initial_state, buffer );
 135 }
 136
 137
 138 /***********************************************************************
 139  *           CreateEventW    (KERNEL32.@)
 140  */
 141 HANDLE WINAPI CreateEventW( SECURITY_ATTRIBUTES *sa, BOOL manual_reset,
 142                             BOOL initial_state, LPCWSTR name )
 143 {
 144     HANDLE ret;
 145     DWORD len = name ? strlenW(name) : 0;
 146     if (len >= MAX_PATH)
 147     {
 148         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 149         return 0;
 150     }
 151     /* one buggy program needs this
 152      * ("Van Dale Groot woordenboek der Nederlandse taal")
 153      */
 154     if (sa && IsBadReadPtr(sa,sizeof(SECURITY_ATTRIBUTES)))
 155     {
 156         ERR("Bad security attributes pointer %p\n",sa);
 157         SetLastError( ERROR_INVALID_PARAMETER);
 158         return 0;
 159     }
 160     SERVER_START_REQ( create_event )
 161     {
 162         req->manual_reset = manual_reset;
 163         req->initial_state = initial_state;
 164         req->inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
 165         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 166         SetLastError(0);
 167         wine_server_call_err( req );
 168         ret = reply->handle;
 169     }
 170     SERVER_END_REQ;
 171     return ret;
 172 }
 173
 174
 175 /***********************************************************************
 176  *           CreateW32Event    (KERNEL.457)
 177  */
 178 HANDLE WINAPI WIN16_CreateEvent( BOOL manual_reset, BOOL initial_state )
 179 {
 180     return CreateEventA( NULL, manual_reset, initial_state, NULL );
 181 }
 182
 183
 184 /***********************************************************************
 185  *           OpenEventA    (KERNEL32.@)
 186  */
 187 HANDLE WINAPI OpenEventA( DWORD access, BOOL inherit, LPCSTR name )
 188 {
 189     WCHAR buffer[MAX_PATH];
 190
 191     if (!name) return OpenEventW( access, inherit, NULL );
 192
 193     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 194     {
 195         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 196         return 0;
 197     }
 198     return OpenEventW( access, inherit, buffer );
 199 }
 200
 201
 202 /***********************************************************************
 203  *           OpenEventW    (KERNEL32.@)
 204  */
 205 HANDLE WINAPI OpenEventW( DWORD access, BOOL inherit, LPCWSTR name )
 206 {
 207     HANDLE ret;
 208     DWORD len = name ? strlenW(name) : 0;
 209     if (len >= MAX_PATH)
 210     {
 211         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 212         return 0;
 213     }
 214     if (!is_version_nt()) access = EVENT_ALL_ACCESS;
 215
 216     SERVER_START_REQ( open_event )
 217     {
 218         req->access  = access;
 219         req->inherit = inherit;
 220         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 221         wine_server_call_err( req );
 222         ret = reply->handle;
 223     }
 224     SERVER_END_REQ;
 225     return ret;
 226 }
 227
 228
 229 /***********************************************************************
 230  *           EVENT_Operation
 231  *
 232  * Execute an event operation (set,reset,pulse).
 233  */
 234 static BOOL EVENT_Operation( HANDLE handle, enum event_op op )
 235 {
 236     BOOL ret;
 237     SERVER_START_REQ( event_op )
 238     {
 239         req->handle = handle;
 240         req->op     = op;
 241         ret = !wine_server_call_err( req );
 242     }
 243     SERVER_END_REQ;
 244     return ret;
 245 }
 246
 247
 248 /***********************************************************************
 249  *           PulseEvent    (KERNEL32.@)
 250  */
 251 BOOL WINAPI PulseEvent( HANDLE handle )
 252 {
 253     return EVENT_Operation( handle, PULSE_EVENT );
 254 }
 255
 256
 257 /***********************************************************************
 258  *           SetW32Event (KERNEL.458)
 259  *           SetEvent    (KERNEL32.@)
 260  */
 261 BOOL WINAPI SetEvent( HANDLE handle )
 262 {
 263     return EVENT_Operation( handle, SET_EVENT );
 264 }
 265
 266
 267 /***********************************************************************
 268  *           ResetW32Event (KERNEL.459)
 269  *           ResetEvent    (KERNEL32.@)
 270  */
 271 BOOL WINAPI ResetEvent( HANDLE handle )
 272 {
 273     return EVENT_Operation( handle, RESET_EVENT );
 274 }
 275
 276
 277 /***********************************************************************
 278  * NOTE: The Win95 VWin32_Event routines given below are really low-level
 279  *       routines implemented directly by VWin32. The user-mode libraries
 280  *       implement Win32 synchronisation routines on top of these low-level
 281  *       primitives. We do it the other way around here :-)
 282  */
 283
 284 /***********************************************************************
 285  *       VWin32_EventCreate     (KERNEL.442)
 286  */
 287 HANDLE WINAPI VWin32_EventCreate(VOID)
 288 {
 289     HANDLE hEvent = CreateEventA( NULL, FALSE, 0, NULL );
 290     return ConvertToGlobalHandle( hEvent );
 291 }
 292
 293 /***********************************************************************
 294  *       VWin32_EventDestroy    (KERNEL.443)
 295  */
 296 VOID WINAPI VWin32_EventDestroy(HANDLE event)
 297 {
 298     CloseHandle( event );
 299 }
 300
 301 /***********************************************************************
 302  *       VWin32_EventWait       (KERNEL.450)
 303  */
 304 VOID WINAPI VWin32_EventWait(HANDLE event)
 305 {
 306     DWORD mutex_count;
 307
 308     ReleaseThunkLock( &mutex_count );
 309     WaitForSingleObject( event, INFINITE );
 310     RestoreThunkLock( mutex_count );
 311 }
 312
 313 /***********************************************************************
 314  *       VWin32_EventSet        (KERNEL.451)
 315  *       KERNEL_479             (KERNEL.479)
 316  */
 317 VOID WINAPI VWin32_EventSet(HANDLE event)
 318 {
 319     SetEvent( event );
 320 }
 321
 322
 323
 324 /***********************************************************************
 325  *           CreateMutexA   (KERNEL32.@)
 326  */
 327 HANDLE WINAPI CreateMutexA( SECURITY_ATTRIBUTES *sa, BOOL owner, LPCSTR name )
 328 {
 329     WCHAR buffer[MAX_PATH];
 330
 331     if (!name) return CreateMutexW( sa, owner, NULL );
 332
 333     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 334     {
 335         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 336         return 0;
 337     }
 338     return CreateMutexW( sa, owner, buffer );
 339 }
 340
 341
 342 /***********************************************************************
 343  *           CreateMutexW   (KERNEL32.@)
 344  */
 345 HANDLE WINAPI CreateMutexW( SECURITY_ATTRIBUTES *sa, BOOL owner, LPCWSTR name )
 346 {
 347     HANDLE ret;
 348     DWORD len = name ? strlenW(name) : 0;
 349     if (len >= MAX_PATH)
 350     {
 351         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 352         return 0;
 353     }
 354     SERVER_START_REQ( create_mutex )
 355     {
 356         req->owned   = owner;
 357         req->inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
 358         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 359         SetLastError(0);
 360         wine_server_call_err( req );
 361         ret = reply->handle;
 362     }
 363     SERVER_END_REQ;
 364     return ret;
 365 }
 366
 367
 368 /***********************************************************************
 369  *           OpenMutexA   (KERNEL32.@)
 370  */
 371 HANDLE WINAPI OpenMutexA( DWORD access, BOOL inherit, LPCSTR name )
 372 {
 373     WCHAR buffer[MAX_PATH];
 374
 375     if (!name) return OpenMutexW( access, inherit, NULL );
 376
 377     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 378     {
 379         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 380         return 0;
 381     }
 382     return OpenMutexW( access, inherit, buffer );
 383 }
 384
 385
 386 /***********************************************************************
 387  *           OpenMutexW   (KERNEL32.@)
 388  */
 389 HANDLE WINAPI OpenMutexW( DWORD access, BOOL inherit, LPCWSTR name )
 390 {
 391     HANDLE ret;
 392     DWORD len = name ? strlenW(name) : 0;
 393     if (len >= MAX_PATH)
 394     {
 395         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 396         return 0;
 397     }
 398     if (!is_version_nt()) access = MUTEX_ALL_ACCESS;
 399
 400     SERVER_START_REQ( open_mutex )
 401     {
 402         req->access  = access;
 403         req->inherit = inherit;
 404         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 405         wine_server_call_err( req );
 406         ret = reply->handle;
 407     }
 408     SERVER_END_REQ;
 409     return ret;
 410 }
 411
 412
 413 /***********************************************************************
 414  *           ReleaseMutex   (KERNEL32.@)
 415  */
 416 BOOL WINAPI ReleaseMutex( HANDLE handle )
 417 {
 418     BOOL ret;
 419     SERVER_START_REQ( release_mutex )
 420     {
 421         req->handle = handle;
 422         ret = !wine_server_call_err( req );
 423     }
 424     SERVER_END_REQ;
 425     return ret;
 426 }
 427
 428
 429 /*
 430  * Semaphores
 431  */
 432
 433
 434 /***********************************************************************
 435  *           CreateSemaphoreA   (KERNEL32.@)
 436  */
 437 HANDLE WINAPI CreateSemaphoreA( SECURITY_ATTRIBUTES *sa, LONG initial, LONG max, LPCSTR name )
 438 {
 439     WCHAR buffer[MAX_PATH];
 440
 441     if (!name) return CreateSemaphoreW( sa, initial, max, NULL );
 442
 443     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 444     {
 445         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 446         return 0;
 447     }
 448     return CreateSemaphoreW( sa, initial, max, buffer );
 449 }
 450
 451
 452 /***********************************************************************
 453  *           CreateSemaphoreW   (KERNEL32.@)
 454  */
 455 HANDLE WINAPI CreateSemaphoreW( SECURITY_ATTRIBUTES *sa, LONG initial,
 456                                     LONG max, LPCWSTR name )
 457 {
 458     HANDLE ret;
 459     DWORD len = name ? strlenW(name) : 0;
 460
 461     /* Check parameters */
 462
 463     if ((max <= 0) || (initial < 0) || (initial > max))
 464     {
 465         SetLastError( ERROR_INVALID_PARAMETER );
 466         return 0;
 467     }
 468     if (len >= MAX_PATH)
 469     {
 470         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 471         return 0;
 472     }
 473
 474     SERVER_START_REQ( create_semaphore )
 475     {
 476         req->initial = (unsigned int)initial;
 477         req->max     = (unsigned int)max;
 478         req->inherit = (sa && (sa->nLength>=sizeof(*sa)) && sa->bInheritHandle);
 479         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 480         SetLastError(0);
 481         wine_server_call_err( req );
 482         ret = reply->handle;
 483     }
 484     SERVER_END_REQ;
 485     return ret;
 486 }
 487
 488
 489 /***********************************************************************
 490  *           OpenSemaphoreA   (KERNEL32.@)
 491  */
 492 HANDLE WINAPI OpenSemaphoreA( DWORD access, BOOL inherit, LPCSTR name )
 493 {
 494     WCHAR buffer[MAX_PATH];
 495
 496     if (!name) return OpenSemaphoreW( access, inherit, NULL );
 497
 498     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 499     {
 500         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 501         return 0;
 502     }
 503     return OpenSemaphoreW( access, inherit, buffer );
 504 }
 505
 506
 507 /***********************************************************************
 508  *           OpenSemaphoreW   (KERNEL32.@)
 509  */
 510 HANDLE WINAPI OpenSemaphoreW( DWORD access, BOOL inherit, LPCWSTR name )
 511 {
 512     HANDLE ret;
 513     DWORD len = name ? strlenW(name) : 0;
 514     if (len >= MAX_PATH)
 515     {
 516         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 517         return 0;
 518     }
 519     if (!is_version_nt()) access = SEMAPHORE_ALL_ACCESS;
 520
 521     SERVER_START_REQ( open_semaphore )
 522     {
 523         req->access  = access;
 524         req->inherit = inherit;
 525         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 526         wine_server_call_err( req );
 527         ret = reply->handle;
 528     }
 529     SERVER_END_REQ;
 530     return ret;
 531 }
 532
 533
 534 /***********************************************************************
 535  *           ReleaseSemaphore   (KERNEL32.@)
 536  */
 537 BOOL WINAPI ReleaseSemaphore( HANDLE handle, LONG count, LONG *previous )
 538 {
 539     NTSTATUS status = NtReleaseSemaphore( handle, count, previous );
 540     if (status) SetLastError( RtlNtStatusToDosError(status) );
 541     return !status;
 542 }
 543
 544
 545 /*
 546  * Timers
 547  */
 548
 549
 550 /***********************************************************************
 551  *           CreateWaitableTimerA    (KERNEL32.@)
 552  */
 553 HANDLE WINAPI CreateWaitableTimerA( SECURITY_ATTRIBUTES *sa, BOOL manual, LPCSTR name )
 554 {
 555     WCHAR buffer[MAX_PATH];
 556
 557     if (!name) return CreateWaitableTimerW( sa, manual, NULL );
 558
 559     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 560     {
 561         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 562         return 0;
 563     }
 564     return CreateWaitableTimerW( sa, manual, buffer );
 565 }
 566
 567
 568 /***********************************************************************
 569  *           CreateWaitableTimerW    (KERNEL32.@)
 570  */
 571 HANDLE WINAPI CreateWaitableTimerW( SECURITY_ATTRIBUTES *sa, BOOL manual, LPCWSTR name )
 572 {
 573     HANDLE              handle;
 574     NTSTATUS            status;
 575     UNICODE_STRING      us;
 576     DWORD               attr = 0;
 577     OBJECT_ATTRIBUTES   oa;
 578
 579     if (name) RtlInitUnicodeString(&us, name);
 580     if (sa && (sa->nLength >= sizeof(*sa)) && sa->bInheritHandle)
 581         attr |= OBJ_INHERIT;
 582     InitializeObjectAttributes(&oa, name ? &us : NULL, attr,
 583                                NULL /* FIXME */, NULL /* FIXME */);
 584     status = NtCreateTimer(&handle, TIMER_ALL_ACCESS, &oa,
 585                            manual ? NotificationTimer : SynchronizationTimer);
 586
 587     if (status != STATUS_SUCCESS)
 588     {
 589         SetLastError( RtlNtStatusToDosError(status) );
 590         return 0;
 591     }
 592     return handle;
 593 }
 594
 595
 596 /***********************************************************************
 597  *           OpenWaitableTimerA    (KERNEL32.@)
 598  */
 599 HANDLE WINAPI OpenWaitableTimerA( DWORD access, BOOL inherit, LPCSTR name )
 600 {
 601     WCHAR buffer[MAX_PATH];
 602
 603     if (!name) return OpenWaitableTimerW( access, inherit, NULL );
 604
 605     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 606     {
 607         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 608         return 0;
 609     }
 610     return OpenWaitableTimerW( access, inherit, buffer );
 611 }
 612
 613
 614 /***********************************************************************
 615  *           OpenWaitableTimerW    (KERNEL32.@)
 616  */
 617 HANDLE WINAPI OpenWaitableTimerW( DWORD access, BOOL inherit, LPCWSTR name )
 618 {
 619     NTSTATUS            status;
 620     ULONG               attr = 0;
 621     UNICODE_STRING      us;
 622     HANDLE              handle;
 623     OBJECT_ATTRIBUTES   oa;
 624
 625     if (inherit) attr |= OBJ_INHERIT;
 626
 627     if (name) RtlInitUnicodeString(&us, name);
 628     InitializeObjectAttributes(&oa, name ? &us : NULL, attr, NULL /* FIXME */, NULL /* FIXME */);
 629     status = NtOpenTimer(&handle, access, &oa);
 630     if (status != STATUS_SUCCESS)
 631     {
 632         SetLastError( RtlNtStatusToDosError(status) );
 633         return 0;
 634     }
 635     return handle;
 636 }
 637
 638
 639 /***********************************************************************
 640  *           SetWaitableTimer    (KERNEL32.@)
 641  */
 642 BOOL WINAPI SetWaitableTimer( HANDLE handle, const LARGE_INTEGER *when, LONG period,
 643                               PTIMERAPCROUTINE callback, LPVOID arg, BOOL resume )
 644 {
 645     NTSTATUS status = NtSetTimer(handle, when, callback, arg, resume, period, NULL);
 646
 647     if (status != STATUS_SUCCESS)
 648     {
 649         SetLastError( RtlNtStatusToDosError(status) );
 650         if (status != STATUS_TIMER_RESUME_IGNORED) return FALSE;
 651     }
 652     return TRUE;
 653 }
 654
 655
 656 /***********************************************************************
 657  *           CancelWaitableTimer    (KERNEL32.@)
 658  */
 659 BOOL WINAPI CancelWaitableTimer( HANDLE handle )
 660 {
 661     NTSTATUS status;
 662
 663     status = NtCancelTimer(handle, NULL);
 664     if (status != STATUS_SUCCESS)
 665     {
 666         SetLastError( RtlNtStatusToDosError(status) );
 667         return FALSE;
 668     }
 669     return TRUE;
 670 }
 671
 672
 673 /***********************************************************************
 674  *           CreateTimerQueue  (KERNEL32.@)
 675  */
 676 HANDLE WINAPI CreateTimerQueue(void)
 677 {
 678     FIXME("stub\n");
 679     SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
 680     return NULL;
 681 }
 682
 683
 684 /***********************************************************************
 685  *           DeleteTimerQueueEx  (KERNEL32.@)
 686  */
 687 BOOL WINAPI DeleteTimerQueueEx(HANDLE TimerQueue, HANDLE CompletionEvent)
 688 {
 689     FIXME("(%p, %p): stub\n", TimerQueue, CompletionEvent);
 690     SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
 691     return 0;
 692 }
 693
 694 /***********************************************************************
 695  *           CreateTimerQueueTimer  (KERNEL32.@)
 696  *
 697  * Creates a timer-queue timer. This timer expires at the specified due
 698  * time (in ms), then after every specified period (in ms). When the timer
 699  * expires, the callback function is called.
 700  *
 701  * RETURNS
 702  *   nonzero on success or zero on faillure
 703  *
 704  * BUGS
 705  *   Unimplemented
 706  */
 707 BOOL WINAPI CreateTimerQueueTimer( PHANDLE phNewTimer, HANDLE TimerQueue,
 708                                    WAITORTIMERCALLBACK Callback, PVOID Parameter,
 709                                    DWORD DueTime, DWORD Period, ULONG Flags )
 710 {
 711     FIXME("stub\n");
 712     SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
 713     return TRUE;
 714 }
 715
 716 /***********************************************************************
 717  *           DeleteTimerQueueTimer  (KERNEL32.@)
 718  *
 719  * Cancels a timer-queue timer.
 720  *
 721  * RETURNS
 722  *   nonzero on success or zero on faillure
 723  *
 724  * BUGS
 725  *   Unimplemented
 726  */
 727 BOOL WINAPI DeleteTimerQueueTimer( HANDLE TimerQueue, HANDLE Timer,
 728                                    HANDLE CompletionEvent )
 729 {
 730     FIXME("stub\n");
 731     SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
 732     return TRUE;
 733 }
 734
 735
 736 /*
 737  * Pipes
 738  */
 739
 740
 741 /***********************************************************************
 742  *           CreateNamedPipeA   (KERNEL32.@)
 743  */
 744 HANDLE WINAPI CreateNamedPipeA( LPCSTR name, DWORD dwOpenMode,
 745                                 DWORD dwPipeMode, DWORD nMaxInstances,
 746                                 DWORD nOutBufferSize, DWORD nInBufferSize,
 747                                 DWORD nDefaultTimeOut, LPSECURITY_ATTRIBUTES attr )
 748 {
 749     WCHAR buffer[MAX_PATH];
 750
 751     if (!name) return CreateNamedPipeW( NULL, dwOpenMode, dwPipeMode, nMaxInstances,
 752                                         nOutBufferSize, nInBufferSize, nDefaultTimeOut, attr );
 753
 754     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 755     {
 756         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 757         return INVALID_HANDLE_VALUE;
 758     }
 759     return CreateNamedPipeW( buffer, dwOpenMode, dwPipeMode, nMaxInstances,
 760                              nOutBufferSize, nInBufferSize, nDefaultTimeOut, attr );
 761 }
 762
 763
 764 /***********************************************************************
 765  *           CreateNamedPipeW   (KERNEL32.@)
 766  */
 767 HANDLE WINAPI CreateNamedPipeW( LPCWSTR name, DWORD dwOpenMode,
 768                                 DWORD dwPipeMode, DWORD nMaxInstances,
 769                                 DWORD nOutBufferSize, DWORD nInBufferSize,
 770                                 DWORD nDefaultTimeOut, LPSECURITY_ATTRIBUTES attr )
 771 {
 772     HANDLE ret;
 773     DWORD len;
 774     static const WCHAR leadin[] = {'\\','\\','.','\\','P','I','P','E','\\'};
 775
 776     TRACE("(%s, %#08lx, %#08lx, %ld, %ld, %ld, %ld, %p)\n",
 777           debugstr_w(name), dwOpenMode, dwPipeMode, nMaxInstances,
 778           nOutBufferSize, nInBufferSize, nDefaultTimeOut, attr );
 779
 780     if (!name)
 781     {
 782         SetLastError( ERROR_PATH_NOT_FOUND );
 783         return INVALID_HANDLE_VALUE;
 784     }
 785     len = strlenW(name);
 786     if (len >= MAX_PATH)
 787     {
 788         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 789         return INVALID_HANDLE_VALUE;
 790     }
 791     if (strncmpiW(name, leadin, sizeof(leadin)/sizeof(leadin[0])))
 792     {
 793         SetLastError( ERROR_INVALID_NAME );
 794         return INVALID_HANDLE_VALUE;
 795     }
 796     SERVER_START_REQ( create_named_pipe )
 797     {
 798         req->openmode = dwOpenMode;
 799         req->pipemode = dwPipeMode;
 800         req->maxinstances = nMaxInstances;
 801         req->outsize = nOutBufferSize;
 802         req->insize = nInBufferSize;
 803         req->timeout = nDefaultTimeOut;
 804         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 805         SetLastError(0);
 806         if (!wine_server_call_err( req )) ret = reply->handle;
 807         else ret = INVALID_HANDLE_VALUE;
 808     }
 809     SERVER_END_REQ;
 810     return ret;
 811 }
 812
 813
 814 /***********************************************************************
 815  *           PeekNamedPipe   (KERNEL32.@)
 816  */
 817 BOOL WINAPI PeekNamedPipe( HANDLE hPipe, LPVOID lpvBuffer, DWORD cbBuffer,
 818                            LPDWORD lpcbRead, LPDWORD lpcbAvail, LPDWORD lpcbMessage )
 819 {
 820 #ifdef FIONREAD
 821     int avail=0,fd;
 822
 823     fd = FILE_GetUnixHandle(hPipe, GENERIC_READ);
 824     if (fd == -1) return FALSE;
 825
 826     if (ioctl(fd,FIONREAD, &avail ) != 0)
 827     {
 828         TRACE("FIONREAD failed reason: %s\n",strerror(errno));
 829         close(fd);
 830         return FALSE;
 831     }
 832     if (!avail)  /* check for closed pipe */
 833     {
 834         struct pollfd pollfd;
 835         pollfd.fd = fd;
 836         pollfd.events = POLLIN;
 837         pollfd.revents = 0;
 838         switch (poll( &pollfd, 1, 0 ))
 839         {
 840         case 0:
 841             break;
 842         case 1:  /* got something */
 843             if (!(pollfd.revents & (POLLHUP | POLLERR))) break;
 844             TRACE("POLLHUP | POLLERR\n");
 845             /* fall through */
 846         case -1:
 847             close(fd);
 848             SetLastError(ERROR_BROKEN_PIPE);
 849             return FALSE;
 850         }
 851     }
 852     close(fd);
 853     TRACE(" 0x%08x bytes available\n", avail );
 854     if (!lpvBuffer && lpcbAvail)
 855       {
 856         *lpcbAvail= avail;
 857         return TRUE;
 858       }
 859 #endif /* defined(FIONREAD) */
 860
 861     SetLastError(ERROR_CALL_NOT_IMPLEMENTED);
 862     FIXME("function not implemented\n");
 863     return FALSE;
 864 }
 865
 866 /***********************************************************************
 867  *           SYNC_CompletePipeOverlapped   (Internal)
 868  */
 869 static void SYNC_CompletePipeOverlapped (LPOVERLAPPED overlapped, DWORD result)
 870 {
 871     TRACE("for %p result %08lx\n",overlapped,result);
 872     if(!overlapped)
 873         return;
 874     overlapped->Internal = result;
 875     SetEvent(overlapped->hEvent);
 876 }
 877
 878
 879 /***********************************************************************
 880  *           WaitNamedPipeA   (KERNEL32.@)
 881  */
 882 BOOL WINAPI WaitNamedPipeA (LPCSTR name, DWORD nTimeOut)
 883 {
 884     WCHAR buffer[MAX_PATH];
 885
 886     if (!name) return WaitNamedPipeW( NULL, nTimeOut );
 887
 888     if (!MultiByteToWideChar( CP_ACP, 0, name, -1, buffer, MAX_PATH ))
 889     {
 890         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 891         return 0;
 892     }
 893     return WaitNamedPipeW( buffer, nTimeOut );
 894 }
 895
 896
 897 /***********************************************************************
 898  *           WaitNamedPipeW   (KERNEL32.@)
 899  */
 900 BOOL WINAPI WaitNamedPipeW (LPCWSTR name, DWORD nTimeOut)
 901 {
 902     DWORD len = name ? strlenW(name) : 0;
 903     BOOL ret;
 904     OVERLAPPED ov;
 905
 906     if (len >= MAX_PATH)
 907     {
 908         SetLastError( ERROR_FILENAME_EXCED_RANGE );
 909         return FALSE;
 910     }
 911
 912     TRACE("%s 0x%08lx\n",debugstr_w(name),nTimeOut);
 913
 914     memset(&ov,0,sizeof(ov));
 915     ov.hEvent = CreateEventA( NULL, 0, 0, NULL );
 916     if (!ov.hEvent)
 917         return FALSE;
 918
 919     SERVER_START_REQ( wait_named_pipe )
 920     {
 921         req->timeout = nTimeOut;
 922         req->overlapped = &ov;
 923         req->func = SYNC_CompletePipeOverlapped;
 924         wine_server_add_data( req, name, len * sizeof(WCHAR) );
 925         ret = !wine_server_call_err( req );
 926     }
 927     SERVER_END_REQ;
 928
 929     if(ret)
 930     {
 931         if (WAIT_OBJECT_0==WaitForSingleObject(ov.hEvent,INFINITE))
 932         {
 933             SetLastError(ov.Internal);
 934             ret = (ov.Internal==STATUS_SUCCESS);
 935         }
 936     }
 937     CloseHandle(ov.hEvent);
 938     return ret;
 939 }
 940
 941
 942 /***********************************************************************
 943  *           SYNC_ConnectNamedPipe   (Internal)
 944  */
 945 static BOOL SYNC_ConnectNamedPipe(HANDLE hPipe, LPOVERLAPPED overlapped)
 946 {
 947     BOOL ret;
 948
 949     if(!overlapped)
 950         return FALSE;
 951
 952     overlapped->Internal = STATUS_PENDING;
 953
 954     SERVER_START_REQ( connect_named_pipe )
 955     {
 956         req->handle = hPipe;
 957         req->overlapped = overlapped;
 958         req->func = SYNC_CompletePipeOverlapped;
 959         ret = !wine_server_call_err( req );
 960     }
 961     SERVER_END_REQ;
 962
 963     return ret;
 964 }
 965
 966 /***********************************************************************
 967  *           ConnectNamedPipe   (KERNEL32.@)
 968  */
 969 BOOL WINAPI ConnectNamedPipe(HANDLE hPipe, LPOVERLAPPED overlapped)
 970 {
 971     OVERLAPPED ov;
 972     BOOL ret;
 973
 974     TRACE("(%p,%p)\n",hPipe, overlapped);
 975
 976     if(overlapped)
 977     {
 978         if(SYNC_ConnectNamedPipe(hPipe,overlapped))
 979             SetLastError( ERROR_IO_PENDING );
 980         return FALSE;
 981     }
 982
 983     memset(&ov,0,sizeof(ov));
 984     ov.hEvent = CreateEventA(NULL,0,0,NULL);
 985     if (!ov.hEvent)
 986         return FALSE;
 987
 988     ret=SYNC_ConnectNamedPipe(hPipe, &ov);
 989     if(ret)
 990     {
 991         if (WAIT_OBJECT_0==WaitForSingleObject(ov.hEvent,INFINITE))
 992         {
 993             SetLastError(ov.Internal);
 994             ret = (ov.Internal==STATUS_SUCCESS);
 995         }
 996     }
 997
 998     CloseHandle(ov.hEvent);
 999
1000     return ret;
1001 }
1002
1003 /***********************************************************************
1004  *           DisconnectNamedPipe   (KERNEL32.@)
1005  */
1006 BOOL WINAPI DisconnectNamedPipe(HANDLE hPipe)
1007 {
1008     BOOL ret;
1009
1010     TRACE("(%p)\n",hPipe);
1011
1012     SERVER_START_REQ( disconnect_named_pipe )
1013     {
1014         req->handle = hPipe;
1015         ret = !wine_server_call_err( req );
1016         if (ret && reply->fd != -1) close( reply->fd );
1017     }
1018     SERVER_END_REQ;
1019
1020     return ret;
1021 }
1022
1023 /***********************************************************************
1024  *           TransactNamedPipe   (KERNEL32.@)
1025  */
1026 BOOL WINAPI TransactNamedPipe(
1027     HANDLE hPipe, LPVOID lpInput, DWORD dwInputSize, LPVOID lpOutput,
1028     DWORD dwOutputSize, LPDWORD lpBytesRead, LPOVERLAPPED lpOverlapped)
1029 {
1030     FIXME("%p %p %ld %p %ld %p %p\n",
1031           hPipe, lpInput, dwInputSize, lpOutput,
1032           dwOutputSize, lpBytesRead, lpOverlapped);
1033     if(lpBytesRead)
1034         *lpBytesRead=0;
1035     return FALSE;
1036 }
1037
1038 /***********************************************************************
1039  *           GetNamedPipeInfo   (KERNEL32.@)
1040  */
1041 BOOL WINAPI GetNamedPipeInfo(
1042     HANDLE hNamedPipe, LPDWORD lpFlags, LPDWORD lpOutputBufferSize,
1043     LPDWORD lpInputBufferSize, LPDWORD lpMaxInstances)
1044 {
1045     BOOL ret;
1046
1047     TRACE("%p %p %p %p %p\n", hNamedPipe, lpFlags,
1048           lpOutputBufferSize, lpInputBufferSize, lpMaxInstances);
1049
1050     SERVER_START_REQ( get_named_pipe_info )
1051     {
1052         req->handle = hNamedPipe;
1053         ret = !wine_server_call_err( req );
1054         if(lpFlags) *lpFlags = reply->flags;
1055         if(lpOutputBufferSize) *lpOutputBufferSize = reply->outsize;
1056         if(lpInputBufferSize) *lpInputBufferSize = reply->outsize;
1057         if(lpMaxInstances) *lpMaxInstances = reply->maxinstances;
1058     }
1059     SERVER_END_REQ;
1060
1061     return ret;
1062 }
1063
1064 /***********************************************************************
1065  *           GetNamedPipeHandleStateA  (KERNEL32.@)
1066  */
1067 BOOL WINAPI GetNamedPipeHandleStateA(
1068     HANDLE hNamedPipe, LPDWORD lpState, LPDWORD lpCurInstances,
1069     LPDWORD lpMaxCollectionCount, LPDWORD lpCollectDataTimeout,
1070     LPSTR lpUsername, DWORD nUsernameMaxSize)
1071 {
1072     FIXME("%p %p %p %p %p %p %ld\n",
1073           hNamedPipe, lpState, lpCurInstances,
1074           lpMaxCollectionCount, lpCollectDataTimeout,
1075           lpUsername, nUsernameMaxSize);
1076
1077     return FALSE;
1078 }
1079
1080 /***********************************************************************
1081  *           GetNamedPipeHandleStateW  (KERNEL32.@)
1082  */
1083 BOOL WINAPI GetNamedPipeHandleStateW(
1084     HANDLE hNamedPipe, LPDWORD lpState, LPDWORD lpCurInstances,
1085     LPDWORD lpMaxCollectionCount, LPDWORD lpCollectDataTimeout,
1086     LPWSTR lpUsername, DWORD nUsernameMaxSize)
1087 {
1088     FIXME("%p %p %p %p %p %p %ld\n",
1089           hNamedPipe, lpState, lpCurInstances,
1090           lpMaxCollectionCount, lpCollectDataTimeout,
1091           lpUsername, nUsernameMaxSize);
1092
1093     return FALSE;
1094 }
1095
1096 /***********************************************************************
1097  *           SetNamedPipeHandleState  (KERNEL32.@)
1098  */
1099 BOOL WINAPI SetNamedPipeHandleState(
1100     HANDLE hNamedPipe, LPDWORD lpMode, LPDWORD lpMaxCollectionCount,
1101     LPDWORD lpCollectDataTimeout)
1102 {
1103     FIXME("%p %p %p %p\n",
1104           hNamedPipe, lpMode, lpMaxCollectionCount, lpCollectDataTimeout);
1105     return FALSE;
1106 }
1107
1108 /***********************************************************************
1109  *           CallNamedPipeA  (KERNEL32.@)
1110  */
1111 BOOL WINAPI CallNamedPipeA(
1112     LPCSTR lpNamedPipeName, LPVOID lpInput, DWORD lpInputSize,
1113     LPVOID lpOutput, DWORD lpOutputSize,
1114     LPDWORD lpBytesRead, DWORD nTimeout)
1115 {
1116     FIXME("%s %p %ld %p %ld %p %ld\n",
1117            debugstr_a(lpNamedPipeName), lpInput, lpInputSize,
1118            lpOutput, lpOutputSize, lpBytesRead, nTimeout);
1119     return FALSE;
1120 }
1121
1122 /***********************************************************************
1123  *           CallNamedPipeW  (KERNEL32.@)
1124  */
1125 BOOL WINAPI CallNamedPipeW(
1126     LPCWSTR lpNamedPipeName, LPVOID lpInput, DWORD lpInputSize,
1127     LPVOID lpOutput, DWORD lpOutputSize,
1128     LPDWORD lpBytesRead, DWORD nTimeout)
1129 {
1130     FIXME("%s %p %ld %p %ld %p %ld\n",
1131            debugstr_w(lpNamedPipeName), lpInput, lpInputSize,
1132            lpOutput, lpOutputSize, lpBytesRead, nTimeout);
1133     return FALSE;
1134 }
1135
1136 /******************************************************************
1137  *              CreatePipe (KERNEL32.@)
1138  *
1139  */
1140 BOOL WINAPI CreatePipe( PHANDLE hReadPipe, PHANDLE hWritePipe,
1141                         LPSECURITY_ATTRIBUTES sa, DWORD size )
1142 {
1143     static unsigned  index = 0;
1144     char        name[64];
1145     HANDLE      hr, hw;
1146     unsigned    in_index = index;
1147
1148     *hReadPipe = *hWritePipe = INVALID_HANDLE_VALUE;
1149     /* generate a unique pipe name (system wide) */
1150     do
1151     {
1152         sprintf(name, "\\\\.\\pipe\\Win32.Pipes.%08lu.%08u", GetCurrentProcessId(), ++index);
1153         hr = CreateNamedPipeA(name, PIPE_ACCESS_INBOUND,
1154                               PIPE_TYPE_BYTE | PIPE_WAIT, 1, size, size,
1155                               NMPWAIT_USE_DEFAULT_WAIT, sa);
1156     } while (hr == INVALID_HANDLE_VALUE && index != in_index);
1157     /* from completion sakeness, I think system resources might be exhausted before this happens !! */
1158     if (hr == INVALID_HANDLE_VALUE) return FALSE;
1159
1160     hw = CreateFileA(name, GENERIC_WRITE, 0, sa, OPEN_EXISTING, 0, 0);
1161     if (hw == INVALID_HANDLE_VALUE)
1162     {
1163         CloseHandle(hr);
1164         return FALSE;
1165     }
1166
1167     *hReadPipe = hr;
1168     *hWritePipe = hw;
1169     return TRUE;
1170 }
1171
1172
1173 #ifdef __i386__
1174
1175 /***********************************************************************
1176  *              InterlockedCompareExchange (KERNEL32.@)
1177  */
1178 /* LONG WINAPI InterlockedCompareExchange( PLONG dest, LONG xchg, LONG compare ); */
1179 __ASM_GLOBAL_FUNC(InterlockedCompareExchange,
1180                   "movl 12(%esp),%eax\n\t"
1181                   "movl 8(%esp),%ecx\n\t"
1182                   "movl 4(%esp),%edx\n\t"
1183                   "lock; cmpxchgl %ecx,(%edx)\n\t"
1184                   "ret $12");
1185
1186 /***********************************************************************
1187  *              InterlockedExchange (KERNEL32.@)
1188  */
1189 /* LONG WINAPI InterlockedExchange( PLONG dest, LONG val ); */
1190 __ASM_GLOBAL_FUNC(InterlockedExchange,
1191                   "movl 8(%esp),%eax\n\t"
1192                   "movl 4(%esp),%edx\n\t"
1193                   "lock; xchgl %eax,(%edx)\n\t"
1194                   "ret $8");
1195
1196 /***********************************************************************
1197  *              InterlockedExchangeAdd (KERNEL32.@)
1198  */
1199 /* LONG WINAPI InterlockedExchangeAdd( PLONG dest, LONG incr ); */
1200 __ASM_GLOBAL_FUNC(InterlockedExchangeAdd,
1201                   "movl 8(%esp),%eax\n\t"
1202                   "movl 4(%esp),%edx\n\t"
1203                   "lock; xaddl %eax,(%edx)\n\t"
1204                   "ret $8");
1205
1206 /***********************************************************************
1207  *              InterlockedIncrement (KERNEL32.@)
1208  */
1209 /* LONG WINAPI InterlockedIncrement( PLONG dest ); */
1210 __ASM_GLOBAL_FUNC(InterlockedIncrement,
1211                   "movl 4(%esp),%edx\n\t"
1212                   "movl $1,%eax\n\t"
1213                   "lock; xaddl %eax,(%edx)\n\t"
1214                   "incl %eax\n\t"
1215                   "ret $4");
1216
1217 /***********************************************************************
1218  *              InterlockedDecrement (KERNEL32.@)
1219  */
1220 __ASM_GLOBAL_FUNC(InterlockedDecrement,
1221                   "movl 4(%esp),%edx\n\t"
1222                   "movl $-1,%eax\n\t"
1223                   "lock; xaddl %eax,(%edx)\n\t"
1224                   "decl %eax\n\t"
1225                   "ret $4");
1226
1227 #else  /* __i386__ */
1228
1229 /***********************************************************************
1230  *              InterlockedCompareExchange (KERNEL32.@)
1231  */
1232 LONG WINAPI InterlockedCompareExchange( PLONG dest, LONG xchg, LONG compare )
1233 {
1234     return interlocked_cmpxchg( dest, xchg, compare );
1235 }
1236
1237 /***********************************************************************
1238  *              InterlockedExchange (KERNEL32.@)
1239  */
1240 LONG WINAPI InterlockedExchange( PLONG dest, LONG val )
1241 {
1242     return interlocked_xchg( dest, val );
1243 }
1244
1245 /***********************************************************************
1246  *              InterlockedExchangeAdd (KERNEL32.@)
1247  */
1248 LONG WINAPI InterlockedExchangeAdd( PLONG dest, LONG incr )
1249 {
1250     return interlocked_xchg_add( dest, incr );
1251 }
1252
1253 /***********************************************************************
1254  *              InterlockedIncrement (KERNEL32.@)
1255  */
1256 LONG WINAPI InterlockedIncrement( PLONG dest )
1257 {
1258     return interlocked_xchg_add( dest, 1 ) + 1;
1259 }
1260
1261 /***********************************************************************
1262  *              InterlockedDecrement (KERNEL32.@)
1263  */
1264 LONG WINAPI InterlockedDecrement( PLONG dest )
1265 {
1266     return interlocked_xchg_add( dest, -1 ) - 1;
1267 }
1268
1269 #endif  /* __i386__ */