/* * Copyright 2016 Daniel Lehman * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA */ #include #include #include "windef.h" #include "winbase.h" #include "winnls.h" #include "wine/test.h" #include "winbase.h" #define SECSPERDAY 86400 /* 1601 to 1970 is 369 years plus 89 leap days */ #define SECS_1601_TO_1970 ((369 * 365 + 89) * (ULONGLONG)SECSPERDAY) #define TICKSPERSEC 10000000 #define TICKS_1601_TO_1970 (SECS_1601_TO_1970 * TICKSPERSEC) #define DEFINE_EXPECT(func) \ static BOOL expect_ ## func = FALSE, called_ ## func = FALSE #define SET_EXPECT(func) \ do { \ expect_ ## func = TRUE; \ errno = 0xdeadbeef; \ }while(0) #define CHECK_EXPECT2(func) \ do { \ ok(expect_ ##func, "unexpected call " #func "\n"); \ called_ ## func = TRUE; \ }while(0) #define CHECK_EXPECT(func) \ do { \ CHECK_EXPECT2(func); \ expect_ ## func = FALSE; \ }while(0) #define CHECK_CALLED(func) \ do { \ ok(called_ ## func, "expected " #func "\n"); \ expect_ ## func = called_ ## func = FALSE; \ }while(0) #ifdef _WIN64 DEFINE_EXPECT(function_do_call); DEFINE_EXPECT(function_do_clean); #endif #undef __thiscall #ifdef __i386__ #define __thiscall __stdcall #else #define __thiscall __cdecl #endif /* Emulate a __thiscall */ #ifdef __i386__ #include "pshpack1.h" struct thiscall_thunk { BYTE pop_eax; /* popl %eax (ret addr) */ BYTE pop_edx; /* popl %edx (func) */ BYTE pop_ecx; /* popl %ecx (this) */ BYTE push_eax; /* pushl %eax */ WORD jmp_edx; /* jmp *%edx */ }; #include "poppack.h" static void * (WINAPI *call_thiscall_func1)( void *func, void *this ); static void * (WINAPI *call_thiscall_func2)( void *func, void *this, const void *a ); static void init_thiscall_thunk(void) { struct thiscall_thunk *thunk = VirtualAlloc( NULL, sizeof(*thunk), MEM_COMMIT, PAGE_EXECUTE_READWRITE ); thunk->pop_eax = 0x58; /* popl %eax */ thunk->pop_edx = 0x5a; /* popl %edx */ thunk->pop_ecx = 0x59; /* popl %ecx */ thunk->push_eax = 0x50; /* pushl %eax */ thunk->jmp_edx = 0xe2ff; /* jmp *%edx */ call_thiscall_func1 = (void *)thunk; call_thiscall_func2 = (void *)thunk; } #define call_func1(func,_this) call_thiscall_func1(func,_this) #define call_func2(func,_this,a) call_thiscall_func2(func,_this,a) #else #define init_thiscall_thunk() #define call_func1(func,_this) func(_this) #define call_func2(func,_this,a) func(_this,a) #endif /* __i386__ */ typedef unsigned char MSVCP_bool; typedef struct { void *unk0; BYTE unk1; } task_continuation_context; typedef struct { void *unused; } _ContextCallback; typedef struct { const void *vtable; void (__cdecl *func)(void); int unk[4]; void *unk2[3]; void *this; } function_void_cdecl_void; typedef struct { void *task; MSVCP_bool scheduled; MSVCP_bool started; } _TaskEventLogger; typedef struct { PTP_WORK work; void (__cdecl *callback)(void*); void *arg; } _Threadpool_chore; typedef struct { HANDLE hnd; DWORD id; } _Thrd_t; typedef struct cs_queue { struct cs_queue *next; BOOL free; int unknown; } cs_queue; typedef struct { ULONG_PTR unk_thread_id; cs_queue unk_active; void *unknown[2]; cs_queue *head; void *tail; } critical_section; typedef struct { DWORD flags; critical_section cs; DWORD thread_id; DWORD count; } *_Mtx_t; typedef void *_Cnd_t; typedef struct { __time64_t sec; int nsec; } xtime; typedef int (__cdecl *_Thrd_start_t)(void*); enum file_type { file_not_found = -1, none_file, regular_file, directory_file, symlink_file, block_file, character_file, fifo_file, socket_file, status_unknown }; static unsigned int (__cdecl *p__Thrd_id)(void); static MSVCP_bool (__cdecl *p__Task_impl_base__IsNonBlockingThread)(void); static task_continuation_context* (__thiscall *p_task_continuation_context_ctor)(task_continuation_context*); static void (__thiscall *p__ContextCallback__Assign)(_ContextCallback*, void*); static void (__thiscall *p__ContextCallback__CallInContext)(const _ContextCallback*, function_void_cdecl_void, MSVCP_bool); static void (__thiscall *p__ContextCallback__Capture)(_ContextCallback*); static void (__thiscall *p__ContextCallback__Reset)(_ContextCallback*); static MSVCP_bool (__cdecl *p__ContextCallback__IsCurrentOriginSTA)(_ContextCallback*); static void (__thiscall *p__TaskEventLogger__LogCancelTask)(_TaskEventLogger*); static void (__thiscall *p__TaskEventLogger__LogScheduleTask)(_TaskEventLogger*, MSVCP_bool); static void (__thiscall *p__TaskEventLogger__LogTaskCompleted)(_TaskEventLogger*); static void (__thiscall *p__TaskEventLogger__LogTaskExecutionCompleted)(_TaskEventLogger*); static void (__thiscall *p__TaskEventLogger__LogWorkItemCompleted)(_TaskEventLogger*); static void (__thiscall *p__TaskEventLogger__LogWorkItemStarted)(_TaskEventLogger*); static int (__cdecl *p__Schedule_chore)(_Threadpool_chore*); static int (__cdecl *p__Reschedule_chore)(const _Threadpool_chore*); static void (__cdecl *p__Release_chore)(_Threadpool_chore*); static int (__cdecl *p__Mtx_init)(_Mtx_t*, int); static void (__cdecl *p__Mtx_destroy)(_Mtx_t); static int (__cdecl *p__Mtx_lock)(_Mtx_t); static int (__cdecl *p__Mtx_unlock)(_Mtx_t); static int (__cdecl *p__Cnd_init)(_Cnd_t*); static void (__cdecl *p__Cnd_destroy)(_Cnd_t); static int (__cdecl *p__Cnd_wait)(_Cnd_t, _Mtx_t); static int (__cdecl *p__Cnd_timedwait)(_Cnd_t, _Mtx_t, const xtime*); static int (__cdecl *p__Cnd_broadcast)(_Cnd_t); static int (__cdecl *p__Cnd_signal)(_Cnd_t); static int (__cdecl *p__Thrd_create)(_Thrd_t*, _Thrd_start_t, void*); static int (__cdecl *p__Thrd_join)(_Thrd_t, int*); static int (__cdecl *p__Xtime_diff_to_millis2)(const xtime*, const xtime*); static int (__cdecl *p_xtime_get)(xtime*, int); static void (__cdecl *p_Close_dir)(void*); static MSVCP_bool (__cdecl *p_Current_get)(WCHAR *); static MSVCP_bool (__cdecl *p_Current_set)(WCHAR const *); static int (__cdecl *p_Equivalent)(WCHAR const*, WCHAR const*); static ULONGLONG (__cdecl *p_File_size)(WCHAR const *); static int (__cdecl *p_Resize)(const WCHAR *, UINT64); static __int64 (__cdecl *p_Last_write_time)(WCHAR const*); static void (__cdecl *p_Set_last_write_time)(WCHAR const*, __int64); static int (__cdecl *p_Link)(WCHAR const*, WCHAR const*); static enum file_type (__cdecl *p_Lstat)(WCHAR const *, int *); static int (__cdecl *p_Make_dir)(WCHAR const*); static void* (__cdecl *p_Open_dir)(WCHAR*, WCHAR const*, int *, enum file_type*); static WCHAR* (__cdecl *p_Read_dir)(WCHAR*, void*, enum file_type*); static MSVCP_bool (__cdecl *p_Remove_dir)(WCHAR const*); static int (__cdecl *p_Rename)(WCHAR const*, WCHAR const*); static enum file_type (__cdecl *p_Stat)(WCHAR const *, int *); static int (__cdecl *p_Symlink)(WCHAR const*, WCHAR const*); static WCHAR* (__cdecl *p_Temp_get)(WCHAR *); static int (__cdecl *p_To_byte)(const WCHAR *src, char *dst); static int (__cdecl *p_To_wide)(const char *src, WCHAR *dst); static int (__cdecl *p_Unlink)(WCHAR const*); static ULONG (__cdecl *p__Winerror_message)(ULONG, char*, ULONG); static int (__cdecl *p__Winerror_map)(int); static const char* (__cdecl *p__Syserror_map)(int err); static BOOLEAN (WINAPI *pCreateSymbolicLinkW)(const WCHAR *, const WCHAR *, DWORD); static HMODULE msvcp; #define SETNOFAIL(x,y) x = (void*)GetProcAddress(msvcp,y) #define SET(x,y) do { SETNOFAIL(x,y); ok(x != NULL, "Export '%s' not found\n", y); } while(0) static BOOL init(void) { HANDLE hdll; msvcp = LoadLibraryA("msvcp140.dll"); if(!msvcp) { win_skip("msvcp140.dll not installed\n"); return FALSE; } SET(p__Thrd_id, "_Thrd_id"); SET(p__Task_impl_base__IsNonBlockingThread, "?_IsNonBlockingThread@_Task_impl_base@details@Concurrency@@SA_NXZ"); SET(p__ContextCallback__IsCurrentOriginSTA, "?_IsCurrentOriginSTA@_ContextCallback@details@Concurrency@@CA_NXZ"); SET(p__Winerror_map, "?_Winerror_map@std@@YAHH@Z"); if(sizeof(void*) == 8) { /* 64-bit initialization */ SET(p_task_continuation_context_ctor, "??0task_continuation_context@Concurrency@@AEAA@XZ"); SET(p__ContextCallback__Assign, "?_Assign@_ContextCallback@details@Concurrency@@AEAAXPEAX@Z"); SET(p__ContextCallback__CallInContext, "?_CallInContext@_ContextCallback@details@Concurrency@@QEBAXV?$function@$$A6AXXZ@std@@_N@Z"); SET(p__ContextCallback__Capture, "?_Capture@_ContextCallback@details@Concurrency@@AEAAXXZ"); SET(p__ContextCallback__Reset, "?_Reset@_ContextCallback@details@Concurrency@@AEAAXXZ"); SET(p__TaskEventLogger__LogCancelTask, "?_LogCancelTask@_TaskEventLogger@details@Concurrency@@QEAAXXZ"); SET(p__TaskEventLogger__LogScheduleTask, "?_LogScheduleTask@_TaskEventLogger@details@Concurrency@@QEAAX_N@Z"); SET(p__TaskEventLogger__LogTaskCompleted, "?_LogTaskCompleted@_TaskEventLogger@details@Concurrency@@QEAAXXZ"); SET(p__TaskEventLogger__LogTaskExecutionCompleted, "?_LogTaskExecutionCompleted@_TaskEventLogger@details@Concurrency@@QEAAXXZ"); SET(p__TaskEventLogger__LogWorkItemCompleted, "?_LogWorkItemCompleted@_TaskEventLogger@details@Concurrency@@QEAAXXZ"); SET(p__TaskEventLogger__LogWorkItemStarted, "?_LogWorkItemStarted@_TaskEventLogger@details@Concurrency@@QEAAXXZ"); SET(p__Schedule_chore, "?_Schedule_chore@details@Concurrency@@YAHPEAU_Threadpool_chore@12@@Z"); SET(p__Reschedule_chore, "?_Reschedule_chore@details@Concurrency@@YAHPEBU_Threadpool_chore@12@@Z"); SET(p__Release_chore, "?_Release_chore@details@Concurrency@@YAXPEAU_Threadpool_chore@12@@Z"); SET(p__Winerror_message, "?_Winerror_message@std@@YAKKPEADK@Z"); SET(p__Syserror_map, "?_Syserror_map@std@@YAPEBDH@Z"); } else { #ifdef __arm__ SET(p_task_continuation_context_ctor, "??0task_continuation_context@Concurrency@@AAA@XZ"); SET(p__ContextCallback__Assign, "?_Assign@_ContextCallback@details@Concurrency@@AAAXPAX@Z"); SET(p__ContextCallback__CallInContext, "?_CallInContext@_ContextCallback@details@Concurrency@@QBAXV?$function@$$A6AXXZ@std@@_N@Z"); SET(p__ContextCallback__Capture, "?_Capture@_ContextCallback@details@Concurrency@@AAAXXZ"); SET(p__ContextCallback__Reset, "?_Reset@_ContextCallback@details@Concurrency@@AAAXXZ"); SET(p__TaskEventLogger__LogCancelTask, "?_LogCancelTask@_TaskEventLogger@details@Concurrency@@QAAXXZ"); SET(p__TaskEventLogger__LogScheduleTask, "?_LogScheduleTask@_TaskEventLogger@details@Concurrency@@QAEX_N@Z"); SET(p__TaskEventLogger__LogTaskCompleted, "?_LogTaskCompleted@_TaskEventLogger@details@Concurrency@@QAAXXZ"); SET(p__TaskEventLogger__LogTaskExecutionCompleted, "?_LogTaskExecutionCompleted@_TaskEventLogger@details@Concurrency@@QAAXXZ"); SET(p__TaskEventLogger__LogWorkItemCompleted, "?_LogWorkItemCompleted@_TaskEventLogger@details@Concurrency@@QAAXXZ"); SET(p__TaskEventLogger__LogWorkItemStarted, "?_LogWorkItemStarted@_TaskEventLogger@details@Concurrency@@QAAXXZ"); #else SET(p_task_continuation_context_ctor, "??0task_continuation_context@Concurrency@@AAE@XZ"); SET(p__ContextCallback__Assign, "?_Assign@_ContextCallback@details@Concurrency@@AAEXPAX@Z"); SET(p__ContextCallback__CallInContext, "?_CallInContext@_ContextCallback@details@Concurrency@@QBEXV?$function@$$A6AXXZ@std@@_N@Z"); SET(p__ContextCallback__Capture, "?_Capture@_ContextCallback@details@Concurrency@@AAEXXZ"); SET(p__ContextCallback__Reset, "?_Reset@_ContextCallback@details@Concurrency@@AAEXXZ"); SET(p__TaskEventLogger__LogCancelTask, "?_LogCancelTask@_TaskEventLogger@details@Concurrency@@QAEXXZ"); SET(p__TaskEventLogger__LogScheduleTask, "?_LogScheduleTask@_TaskEventLogger@details@Concurrency@@QAEX_N@Z"); SET(p__TaskEventLogger__LogTaskCompleted, "?_LogTaskCompleted@_TaskEventLogger@details@Concurrency@@QAEXXZ"); SET(p__TaskEventLogger__LogTaskExecutionCompleted, "?_LogTaskExecutionCompleted@_TaskEventLogger@details@Concurrency@@QAEXXZ"); SET(p__TaskEventLogger__LogWorkItemCompleted, "?_LogWorkItemCompleted@_TaskEventLogger@details@Concurrency@@QAEXXZ"); SET(p__TaskEventLogger__LogWorkItemStarted, "?_LogWorkItemStarted@_TaskEventLogger@details@Concurrency@@QAEXXZ"); #endif SET(p__Schedule_chore, "?_Schedule_chore@details@Concurrency@@YAHPAU_Threadpool_chore@12@@Z"); SET(p__Reschedule_chore, "?_Reschedule_chore@details@Concurrency@@YAHPBU_Threadpool_chore@12@@Z"); SET(p__Release_chore, "?_Release_chore@details@Concurrency@@YAXPAU_Threadpool_chore@12@@Z"); SET(p__Winerror_message, "?_Winerror_message@std@@YAKKPADK@Z"); SET(p__Syserror_map, "?_Syserror_map@std@@YAPBDH@Z"); } SET(p__Mtx_init, "_Mtx_init"); SET(p__Mtx_destroy, "_Mtx_destroy"); SET(p__Mtx_lock, "_Mtx_lock"); SET(p__Mtx_unlock, "_Mtx_unlock"); SET(p__Cnd_init, "_Cnd_init"); SET(p__Cnd_destroy, "_Cnd_destroy"); SET(p__Cnd_wait, "_Cnd_wait"); SET(p__Cnd_timedwait, "_Cnd_timedwait"); SET(p__Cnd_broadcast, "_Cnd_broadcast"); SET(p__Cnd_signal, "_Cnd_signal"); SET(p__Thrd_create, "_Thrd_create"); SET(p__Thrd_join, "_Thrd_join"); SET(p__Xtime_diff_to_millis2, "_Xtime_diff_to_millis2"); SET(p_xtime_get, "xtime_get"); SET(p_Close_dir, "_Close_dir"); SET(p_Current_get, "_Current_get"); SET(p_Current_set, "_Current_set"); SET(p_Equivalent, "_Equivalent"); SET(p_File_size, "_File_size"); SET(p_Resize, "_Resize"); SET(p_Last_write_time, "_Last_write_time"); SET(p_Set_last_write_time, "_Set_last_write_time"); SET(p_Link, "_Link"); SET(p_Lstat, "_Lstat"); SET(p_Make_dir, "_Make_dir"); SET(p_Open_dir, "_Open_dir"); SET(p_Read_dir, "_Read_dir"); SET(p_Remove_dir, "_Remove_dir"); SET(p_Rename, "_Rename"); SET(p_Stat, "_Stat"); SET(p_Symlink, "_Symlink"); SET(p_Temp_get, "_Temp_get"); SET(p_To_byte, "_To_byte"); SET(p_To_wide, "_To_wide"); SET(p_Unlink, "_Unlink"); hdll = GetModuleHandleA("kernel32.dll"); pCreateSymbolicLinkW = (void*)GetProcAddress(hdll, "CreateSymbolicLinkW"); init_thiscall_thunk(); return TRUE; } static void test_thrd(void) { ok(p__Thrd_id() == GetCurrentThreadId(), "expected same id, got _Thrd_id %u GetCurrentThreadId %lu\n", p__Thrd_id(), GetCurrentThreadId()); } static void test__Task_impl_base__IsNonBlockingThread(void) { ok(!p__Task_impl_base__IsNonBlockingThread(), "_IsNonBlockingThread() returned true\n"); } static struct { int value[2]; const char* export_name; } vbtable_size_exports_list[] = { {{0x20, 0x20}, "??_8?$basic_iostream@DU?$char_traits@D@std@@@std@@7B?$basic_istream@DU?$char_traits@D@std@@@1@@"}, {{0x10, 0x10}, "??_8?$basic_iostream@DU?$char_traits@D@std@@@std@@7B?$basic_ostream@DU?$char_traits@D@std@@@1@@"}, {{0x20, 0x20}, "??_8?$basic_iostream@GU?$char_traits@G@std@@@std@@7B?$basic_istream@GU?$char_traits@G@std@@@1@@"}, {{0x10, 0x10}, "??_8?$basic_iostream@GU?$char_traits@G@std@@@std@@7B?$basic_ostream@GU?$char_traits@G@std@@@1@@"}, {{0x20, 0x20}, "??_8?$basic_iostream@_WU?$char_traits@_W@std@@@std@@7B?$basic_istream@_WU?$char_traits@_W@std@@@1@@"}, {{0x10, 0x10}, "??_8?$basic_iostream@_WU?$char_traits@_W@std@@@std@@7B?$basic_ostream@_WU?$char_traits@_W@std@@@1@@"}, {{0x18, 0x18}, "??_8?$basic_istream@DU?$char_traits@D@std@@@std@@7B@"}, {{0x18, 0x18}, "??_8?$basic_istream@GU?$char_traits@G@std@@@std@@7B@"}, {{0x18, 0x18}, "??_8?$basic_istream@_WU?$char_traits@_W@std@@@std@@7B@"}, {{ 0x8, 0x10}, "??_8?$basic_ostream@DU?$char_traits@D@std@@@std@@7B@"}, {{ 0x8, 0x10}, "??_8?$basic_ostream@GU?$char_traits@G@std@@@std@@7B@"}, {{ 0x8, 0x10}, "??_8?$basic_ostream@_WU?$char_traits@_W@std@@@std@@7B@"}, {{ 0x0, 0x0}, 0} }; static void test_vbtable_size_exports(void) { int i; const int *p_vbtable; int arch_idx = (sizeof(void*) == 8); for (i = 0; vbtable_size_exports_list[i].export_name; i++) { SET(p_vbtable, vbtable_size_exports_list[i].export_name); ok(p_vbtable[0] == 0, "vbtable[0] wrong, got 0x%x\n", p_vbtable[0]); ok(p_vbtable[1] == vbtable_size_exports_list[i].value[arch_idx], "%d: %s[1] wrong, got 0x%x\n", i, vbtable_size_exports_list[i].export_name, p_vbtable[1]); } } static void test_task_continuation_context(void) { task_continuation_context tcc; memset(&tcc, 0xff, sizeof(tcc)); call_func1(p_task_continuation_context_ctor, &tcc); ok(!tcc.unk0, "tcc.unk0 != NULL (%p)\n", tcc.unk0); ok(!tcc.unk1, "tcc.unk1 != 0 (%x)\n", tcc.unk1); } #ifdef _WIN64 static void __cdecl function_do_call(void *this) { CHECK_EXPECT(function_do_call); } static void __cdecl function_do_clean(void *this, MSVCP_bool b) { CHECK_EXPECT(function_do_clean); ok(b, "b == FALSE\n"); } #endif static void test__ContextCallback(void) { _ContextCallback cc = {0}; void *v = (void*)0xdeadbeef; #ifdef _WIN64 void* function_vtbl[] = { NULL, NULL, (void*)function_do_call, NULL, (void*)function_do_clean, NULL }; function_void_cdecl_void function = { function_vtbl, NULL, {0}, {NULL}, &function }; function_void_cdecl_void function2 = { NULL, NULL, {0}, {NULL}, &function }; #endif call_func2(p__ContextCallback__Assign, &cc, v); ok(!cc.unused, "cc.unused = %p\n", cc.unused); call_func1(p__ContextCallback__Reset, &cc); ok(!cc.unused, "cc.unused = %p\n", cc.unused); call_func1(p__ContextCallback__Capture, &cc); ok(!cc.unused, "cc.unused = %p\n", cc.unused); ok(!p__ContextCallback__IsCurrentOriginSTA(&cc), "IsCurrentOriginSTA returned TRUE\n"); cc.unused = v; call_func2(p__ContextCallback__Assign, &cc, NULL); ok(cc.unused == v, "cc.unused = %p\n", cc.unused); call_func1(p__ContextCallback__Reset, &cc); ok(cc.unused == v, "cc.unused = %p\n", cc.unused); call_func1(p__ContextCallback__Capture, &cc); ok(cc.unused == v, "cc.unused = %p\n", cc.unused); ok(!p__ContextCallback__IsCurrentOriginSTA(&cc), "IsCurrentOriginSTA returned TRUE\n"); ok(cc.unused == v, "cc.unused = %p\n", cc.unused); #ifdef _WIN64 SET_EXPECT(function_do_call); SET_EXPECT(function_do_clean); p__ContextCallback__CallInContext(&cc, function, FALSE); CHECK_CALLED(function_do_call); CHECK_CALLED(function_do_clean); SET_EXPECT(function_do_call); SET_EXPECT(function_do_clean); p__ContextCallback__CallInContext(&cc, function, TRUE); CHECK_CALLED(function_do_call); CHECK_CALLED(function_do_clean); SET_EXPECT(function_do_call); SET_EXPECT(function_do_clean); p__ContextCallback__CallInContext(&cc, function2, FALSE); CHECK_CALLED(function_do_call); CHECK_CALLED(function_do_clean); SET_EXPECT(function_do_call); SET_EXPECT(function_do_clean); p__ContextCallback__CallInContext(&cc, function2, TRUE); CHECK_CALLED(function_do_call); CHECK_CALLED(function_do_clean); #endif } static void test__TaskEventLogger(void) { _TaskEventLogger logger; memset(&logger, 0, sizeof(logger)); call_func1(p__TaskEventLogger__LogCancelTask, &logger); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); call_func2(p__TaskEventLogger__LogScheduleTask, &logger, FALSE); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); call_func1(p__TaskEventLogger__LogTaskCompleted, &logger); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); call_func1(p__TaskEventLogger__LogTaskExecutionCompleted, &logger); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); call_func1(p__TaskEventLogger__LogWorkItemCompleted, &logger); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); call_func1(p__TaskEventLogger__LogWorkItemStarted, &logger); ok(!logger.task, "logger.task = %p\n", logger.task); ok(!logger.scheduled, "logger.scheduled = %x\n", logger.scheduled); ok(!logger.started, "logger.started = %x\n", logger.started); logger.task = (void*)0xdeadbeef; logger.scheduled = TRUE; logger.started = TRUE; call_func1(p__TaskEventLogger__LogCancelTask, &logger); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); call_func2(p__TaskEventLogger__LogScheduleTask, &logger, FALSE); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); call_func1(p__TaskEventLogger__LogTaskCompleted, &logger); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); call_func1(p__TaskEventLogger__LogTaskExecutionCompleted, &logger); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); call_func1(p__TaskEventLogger__LogWorkItemCompleted, &logger); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); call_func1(p__TaskEventLogger__LogWorkItemStarted, &logger); ok(logger.task == (void*)0xdeadbeef, "logger.task = %p\n", logger.task); ok(logger.scheduled, "logger.scheduled = FALSE\n"); ok(logger.started, "logger.started = FALSE\n"); } static void __cdecl chore_callback(void *arg) { HANDLE event = arg; SetEvent(event); } static void test_chore(void) { HANDLE event = CreateEventW(NULL, FALSE, FALSE, NULL); _Threadpool_chore chore, old_chore; DWORD wait; int ret; memset(&chore, 0, sizeof(chore)); ret = p__Schedule_chore(&chore); ok(!ret, "_Schedule_chore returned %d\n", ret); ok(chore.work != NULL, "chore.work == NULL\n"); ok(!chore.callback, "chore.callback != NULL\n"); p__Release_chore(&chore); chore.work = NULL; chore.callback = chore_callback; chore.arg = event; ret = p__Schedule_chore(&chore); ok(!ret, "_Schedule_chore returned %d\n", ret); ok(chore.work != NULL, "chore.work == NULL\n"); ok(chore.callback == chore_callback, "chore.callback = %p, expected %p\n", chore.callback, chore_callback); ok(chore.arg == event, "chore.arg = %p, expected %p\n", chore.arg, event); wait = WaitForSingleObject(event, 500); ok(wait == WAIT_OBJECT_0, "WaitForSingleObject returned %ld\n", wait); if(!GetProcAddress(GetModuleHandleA("kernel32"), "CreateThreadpoolWork")) { win_skip("_Reschedule_chore not supported\n"); p__Release_chore(&chore); CloseHandle(event); return; } old_chore = chore; ret = p__Schedule_chore(&chore); ok(!ret, "_Schedule_chore returned %d\n", ret); ok(old_chore.work != chore.work, "new threadpool work was not created\n"); p__Release_chore(&old_chore); wait = WaitForSingleObject(event, 500); ok(wait == WAIT_OBJECT_0, "WaitForSingleObject returned %ld\n", wait); ret = p__Reschedule_chore(&chore); ok(!ret, "_Reschedule_chore returned %d\n", ret); wait = WaitForSingleObject(event, 500); ok(wait == WAIT_OBJECT_0, "WaitForSingleObject returned %ld\n", wait); p__Release_chore(&chore); ok(!chore.work, "chore.work != NULL\n"); ok(chore.callback == chore_callback, "chore.callback = %p, expected %p\n", chore.callback, chore_callback); ok(chore.arg == event, "chore.arg = %p, expected %p\n", chore.arg, event); p__Release_chore(&chore); CloseHandle(event); } static void test_to_byte(void) { static const WCHAR *tests[] = {L"TEST", L"\x9580\x9581\x9582\x9583"}; char dst[MAX_PATH + 4] = "ABC\0XXXXXXX"; char compare[MAX_PATH + 4] = "ABC\0XXXXXXX"; int ret,expected; unsigned int i, j; WCHAR longstr[MAX_PATH + 3]; ret = p_To_byte(NULL, NULL); ok(!ret, "Got unexpected result %d\n", ret); ret = p_To_byte(tests[0], NULL); ok(!ret, "Got unexpected result %d\n", ret); ret = p_To_byte(NULL, dst); ok(!ret, "Got unexpected result %d\n", ret); ok(!memcmp(dst, compare, sizeof(compare)), "Destination was modified: %s\n", dst); for (i = 0; i < ARRAY_SIZE(tests); ++i) { ret = p_To_byte(tests[i], dst); expected = WideCharToMultiByte(CP_ACP, 0, tests[i], -1, compare, ARRAY_SIZE(compare), NULL, NULL); ok(ret == expected, "Got unexpected result %d, expected %d, test case %u\n", ret, expected, i); ok(!memcmp(dst, compare, sizeof(compare)), "Got unexpected output %s, test case %u\n", dst, i); } /* Output length is limited to MAX_PATH.*/ for (i = MAX_PATH - 2; i < MAX_PATH + 2; ++i) { for (j = 0; j < i; j++) longstr[j] = 'A'; longstr[i] = 0; memset(dst, 0xff, sizeof(dst)); memset(compare, 0xff, sizeof(compare)); ret = p_To_byte(longstr, dst); expected = WideCharToMultiByte(CP_ACP, 0, longstr, -1, compare, MAX_PATH, NULL, NULL); ok(ret == expected, "Got unexpected result %d, expected %d, length %u\n", ret, expected, i); ok(!memcmp(dst, compare, sizeof(compare)), "Got unexpected output %s, length %u\n", dst, i); } } static void test_to_wide(void) { /* öäü߀Ÿ.A.B in cp1252, the two . are an undefined value and delete. * With a different system codepage it will produce different results, so do not hardcode the * expected output but convert it with MultiByteToWideChar. */ static const char special_input[] = {0xf6, 0xe4, 0xfc, 0xdf, 0x80, 0x9f, 0x81, 0x41, 0x7f, 0x42, 0}; static const char *tests[] = {"Testtest", special_input}; WCHAR dst[MAX_PATH + 4] = {'A', 'B', 'C', 0, 'X', 'X', 'X', 'X', 'X', 'X', 'X'}; WCHAR compare[MAX_PATH + 4] = {'A', 'B', 'C', 0, 'X', 'X', 'X', 'X', 'X', 'X', 'X'}; int ret, expected; unsigned int i; char longstr[MAX_PATH + 3]; ret = p_To_wide(NULL, NULL); ok(!ret, "Got unexpected result %d\n", ret); ret = p_To_wide(tests[0], NULL); ok(!ret, "Got unexpected result %d\n", ret); ret = p_To_wide(NULL, dst); ok(!ret, "Got unexpected result %d\n", ret); ok(!memcmp(dst, compare, sizeof(compare)), "Destination was modified: %s\n", wine_dbgstr_w(dst)); for (i = 0; i < ARRAY_SIZE(tests); ++i) { ret = p_To_wide(tests[i], dst); expected = MultiByteToWideChar(CP_ACP, 0, tests[i], -1, compare, ARRAY_SIZE(compare)); ok(ret == expected, "Got unexpected result %d, expected %d, test case %u\n", ret, expected, i); ok(!memcmp(dst, compare, sizeof(compare)), "Got unexpected output %s, test case %u\n", wine_dbgstr_w(dst), i); } /* Output length is limited to MAX_PATH.*/ for (i = MAX_PATH - 2; i < MAX_PATH + 2; ++i) { memset(longstr, 'A', sizeof(longstr)); longstr[i] = 0; memset(dst, 0xff, sizeof(dst)); memset(compare, 0xff, sizeof(compare)); ret = p_To_wide(longstr, dst); expected = MultiByteToWideChar(CP_ACP, 0, longstr, -1, compare, MAX_PATH); ok(ret == expected, "Got unexpected result %d, expected %d, length %u\n", ret, expected, i); ok(!memcmp(dst, compare, sizeof(compare)), "Got unexpected output %s, length %u\n", wine_dbgstr_w(dst), i); } } static void test_File_size(void) { ULONGLONG val; HANDLE file; LARGE_INTEGER file_size; WCHAR temp_path[MAX_PATH], origin_path[MAX_PATH]; int r; GetCurrentDirectoryW(MAX_PATH, origin_path); GetTempPathW(MAX_PATH, temp_path); ok(SetCurrentDirectoryW(temp_path), "SetCurrentDirectoryW to temp_path failed\n"); CreateDirectoryW(L"wine_test_dir", NULL); file = CreateFileW(L"wine_test_dir/f1", GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL); ok(file != INVALID_HANDLE_VALUE, "create file failed: INVALID_HANDLE_VALUE\n"); file_size.QuadPart = 7; ok(SetFilePointerEx(file, file_size, NULL, FILE_BEGIN), "SetFilePointerEx failed\n"); ok(SetEndOfFile(file), "SetEndOfFile failed\n"); CloseHandle(file); val = p_File_size(L"wine_test_dir/f1"); ok(val == 7, "file_size is %s\n", wine_dbgstr_longlong(val)); file = CreateFileW(L"wine_test_dir/f2", GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL); ok(file != INVALID_HANDLE_VALUE, "create file failed: INVALID_HANDLE_VALUE\n"); CloseHandle(file); val = p_File_size(L"wine_test_dir/f2"); ok(val == 0, "file_size is %s\n", wine_dbgstr_longlong(val)); val = p_File_size(L"wine_test_dir"); ok(val == 0, "file_size is %s\n", wine_dbgstr_longlong(val)); errno = 0xdeadbeef; val = p_File_size(L"wine_test_dir/ne"); ok(val == ~(ULONGLONG)0, "file_size is %s\n", wine_dbgstr_longlong(val)); ok(errno == 0xdeadbeef, "errno = %d\n", errno); errno = 0xdeadbeef; val = p_File_size(NULL); ok(val == ~(ULONGLONG)0, "file_size is %s\n", wine_dbgstr_longlong(val)); ok(errno == 0xdeadbeef, "errno = %d\n", errno); r = p_Resize(L"wine_test_dir/f1", 1000); ok(!r, "p_Resize returned %d\n", r); val = p_File_size(L"wine_test_dir/f1"); ok(val == 1000, "file_size is %s\n", wine_dbgstr_longlong(val)); r = p_Resize(L"wine_test_dir/f1", 100); ok(!r, "p_Resize returned %d\n", r); val = p_File_size(L"wine_test_dir/f1"); ok(val == 100, "file_size is %s\n", wine_dbgstr_longlong(val)); r = p_Resize(L"wine_test_dir/f1", 0); ok(!r, "p_Resize returned %d\n", r); val = p_File_size(L"wine_test_dir/f1"); ok(val == 0, "file_size is %s\n", wine_dbgstr_longlong(val)); ok(DeleteFileW(L"wine_test_dir/f1"), "expect wine_test_dir/f1 to exist\n"); r = p_Resize(L"wine_test_dir/f1", 0); ok(r == ERROR_FILE_NOT_FOUND, "p_Resize returned %d\n", r); ok(DeleteFileW(L"wine_test_dir/f2"), "expect wine_test_dir/f2 to exist\n"); ok(RemoveDirectoryW(L"wine_test_dir"), "expect wine_test_dir to exist\n"); ok(SetCurrentDirectoryW(origin_path), "SetCurrentDirectoryW to origin_path failed\n"); } static void test_Current_get(void) { WCHAR temp_path[MAX_PATH], current_path[MAX_PATH], origin_path[MAX_PATH]; BOOL ret; GetCurrentDirectoryW(MAX_PATH, origin_path); GetTempPathW(MAX_PATH, temp_path); ok(SetCurrentDirectoryW(temp_path), "SetCurrentDirectoryW to temp_path failed\n"); ret = p_Current_get(current_path); ok(ret == TRUE, "p_Current_get returned %u\n", ret); wcscat(current_path, L"\\"); ok(!wcscmp(temp_path, current_path), "p_Current_get(): expect: %s, got %s\n", wine_dbgstr_w(temp_path), wine_dbgstr_w(current_path)); ok(SetCurrentDirectoryW(origin_path), "SetCurrentDirectoryW to origin_path failed\n"); ret = p_Current_get(current_path); ok(ret == TRUE, "p_Current_get returned %u\n", ret); ok(!wcscmp(origin_path, current_path), "p_Current_get(): expect: %s, got %s\n", wine_dbgstr_w(origin_path), wine_dbgstr_w(current_path)); } static void test_Current_set(void) { WCHAR temp_path[MAX_PATH], current_path[MAX_PATH], origin_path[MAX_PATH]; MSVCP_bool ret; GetTempPathW(MAX_PATH, temp_path); GetCurrentDirectoryW(MAX_PATH, origin_path); ok(p_Current_set(temp_path), "p_Current_set to temp_path failed\n"); ret = p_Current_get(current_path); ok(ret == TRUE, "p_Current_get returned %u\n", ret); wcscat(current_path, L"\\"); ok(!wcscmp(temp_path, current_path), "p_Current_get(): expect: %s, got %s\n", wine_dbgstr_w(temp_path), wine_dbgstr_w(current_path)); ok(p_Current_set(L"./"), "p_Current_set to temp_path failed\n"); ret = p_Current_get(current_path); ok(ret == TRUE, "p_Current_get returned %u\n", ret); wcscat(current_path, L"\\"); ok(!wcscmp(temp_path, current_path), "p_Current_get(): expect: %s, got %s\n", wine_dbgstr_w(temp_path), wine_dbgstr_w(current_path)); errno = 0xdeadbeef; ok(!p_Current_set(L"not_exist_dir"), "p_Current_set to not_exist_dir succeed\n"); ok(errno == 0xdeadbeef, "errno = %d\n", errno); errno = 0xdeadbeef; ok(!p_Current_set(L"??invalid_name>>"), "p_Current_set to ??invalid_name>> succeed\n"); ok(errno == 0xdeadbeef, "errno = %d\n", errno); ok(p_Current_set(origin_path), "p_Current_set to origin_path failed\n"); ret = p_Current_get(current_path); ok(ret == TRUE, "p_Current_get returned %u\n", ret); ok(!wcscmp(origin_path, current_path), "p_Current_get(): expect: %s, got %s\n", wine_dbgstr_w(origin_path), wine_dbgstr_w(current_path)); } static void test_Stat(void) { int i, perms, expected_perms, ret; HANDLE file; DWORD attr; enum file_type val; WCHAR sys_path[MAX_PATH], origin_path[MAX_PATH], temp_path[MAX_PATH]; struct { WCHAR const *path; enum file_type ret; int perms; int is_todo; } tests[] = { { NULL, file_not_found, 0xdeadbeef, FALSE }, { L"wine_test_dir", directory_file, 0777, FALSE }, { L"wine_test_dir/f1", regular_file, 0777, FALSE }, { L"wine_test_dir/f2", regular_file, 0555, FALSE }, { L"wine_test_dir/ne", file_not_found, 0xdeadbeef, FALSE }, { L"wine_test_dir\\??invalid_name>>", file_not_found, 0xdeadbeef, FALSE }, { L"wine_test_dir\\f1_link", regular_file, 0777, TRUE }, { L"wine_test_dir\\dir_link", directory_file, 0777, TRUE }, }; GetCurrentDirectoryW(MAX_PATH, origin_path); GetTempPathW(MAX_PATH, temp_path); ok(SetCurrentDirectoryW(temp_path), "SetCurrentDirectoryW to temp_path failed\n"); CreateDirectoryW(L"wine_test_dir", NULL); file = CreateFileW(L"wine_test_dir/f1", 0, 0, NULL, CREATE_ALWAYS, 0, NULL); ok(file != INVALID_HANDLE_VALUE, "create file failed: INVALID_HANDLE_VALUE\n"); ok(CloseHandle(file), "CloseHandle\n"); file = CreateFileW(L"wine_test_dir/f2", 0, 0, NULL, CREATE_ALWAYS, 0, NULL); ok(file != INVALID_HANDLE_VALUE, "create file failed: INVALID_HANDLE_VALUE\n"); ok(CloseHandle(file), "CloseHandle\n"); SetFileAttributesW(L"wine_test_dir/f2", FILE_ATTRIBUTE_READONLY); SetLastError(0xdeadbeef); ret = pCreateSymbolicLinkW && pCreateSymbolicLinkW( L"wine_test_dir\\f1_link", L"wine_test_dir/f1", 0); if(!ret && (!pCreateSymbolicLinkW || GetLastError()==ERROR_PRIVILEGE_NOT_HELD || GetLastError()==ERROR_INVALID_FUNCTION)) { tests[6].ret = tests[7].ret = file_not_found; tests[6].perms = tests[7].perms = 0xdeadbeef; win_skip("Privilege not held or symbolic link not supported, skipping symbolic link tests.\n"); }else { ok(ret, "CreateSymbolicLinkW failed\n"); ok(pCreateSymbolicLinkW(L"wine_test_dir\\dir_link", L"wine_test_dir", 1), "CreateSymbolicLinkW failed\n"); } file = CreateNamedPipeW(L"\\\\.\\PiPe\\tests_pipe.c", PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_WAIT, 2, 1024, 1024, NMPWAIT_USE_DEFAULT_WAIT, NULL); ok(file != INVALID_HANDLE_VALUE, "CreateNamedPipe failed\n"); perms = 0xdeadbeef; val = p_Stat(L"\\\\.\\PiPe\\tests_pipe.c", &perms); todo_wine ok(regular_file == val, "_Stat(): expect: regular, got %d\n", val); todo_wine ok(0777 == perms, "_Stat(): perms expect: 0777, got 0%o\n", perms); perms = 0xdeadbeef; val = p_Lstat(L"\\\\.\\PiPe\\tests_pipe.c", &perms); ok(status_unknown == val, "_Lstat(): expect: unknown, got %d\n", val); ok(0xdeadbeef == perms, "_Lstat(): perms expect: 0xdeadbeef, got %x\n", perms); ok(CloseHandle(file), "CloseHandle\n"); file = CreateNamedPipeW(L"\\\\.\\PiPe\\tests_pipe.c", PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_WAIT, 2, 1024, 1024, NMPWAIT_USE_DEFAULT_WAIT, NULL); ok(file != INVALID_HANDLE_VALUE, "CreateNamedPipe failed\n"); perms = 0xdeadbeef; val = p_Lstat(L"\\\\.\\PiPe\\tests_pipe.c", &perms); todo_wine ok(regular_file == val, "_Lstat(): expect: regular, got %d\n", val); todo_wine ok(0777 == perms, "_Lstat(): perms expect: 0777, got 0%o\n", perms); ok(CloseHandle(file), "CloseHandle\n"); for(i=0; i", ERROR_INVALID_NAME }, { L"wine_test_dir\\not_exist2", L"wine_test_dir\\not_exist2", ERROR_FILE_NOT_FOUND }, { L"wine_test_dir\\not_exist2", L"wine_test_dir\\??invalid>", ERROR_FILE_NOT_FOUND } }; GetCurrentDirectoryW(MAX_PATH, current_path); GetTempPathW(MAX_PATH, temp_path); ok(SetCurrentDirectoryW(temp_path), "SetCurrentDirectoryW to temp_path failed\n"); ret = p_Make_dir(L"wine_test_dir"); ok(ret == 1, "_Make_dir(): expect 1 got %d\n", ret); file = CreateFileW(L"wine_test_dir\\f1", GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL); ok(file != INVALID_HANDLE_VALUE, "create file failed: INVALID_HANDLE_VALUE\n"); CloseHandle(file); ret = p_Rename(L"wine_test_dir\\f1", L"wine_test_dir\\f1"); ok(ERROR_SUCCESS == ret, "_Rename(): expect: ERROR_SUCCESS, got %d\n", ret); for(i=0; i 2 && buf_fm[ret_fm - 1] == '\n' && buf_fm[ret_fm - 2] == '\r' && ret + 2 == ret_fm), "ret = %lu, expected %lu\n", ret, ret_fm); ok(!strncmp(buf, buf_fm, ret), "buf = %s, expected %s\n", buf, buf_fm); memset(buf, 'a', sizeof(buf)); ret = p__Winerror_message(0, buf, 2); ok(!ret, "ret = %lu\n", ret); ok(buf[0] == 'a', "buf = %s\n", buf); } static void test__Winerror_map(void) { static struct { int winerr, doserr; BOOL broken; int broken_doserr; } tests[] = { {ERROR_INVALID_FUNCTION, ENOSYS}, {ERROR_FILE_NOT_FOUND, ENOENT}, {ERROR_PATH_NOT_FOUND, ENOENT}, {ERROR_TOO_MANY_OPEN_FILES, EMFILE}, {ERROR_ACCESS_DENIED, EACCES}, {ERROR_INVALID_HANDLE, EINVAL}, {ERROR_NOT_ENOUGH_MEMORY, ENOMEM}, {ERROR_INVALID_ACCESS, EACCES}, {ERROR_OUTOFMEMORY, ENOMEM}, {ERROR_INVALID_DRIVE, ENODEV}, {ERROR_CURRENT_DIRECTORY, EACCES}, {ERROR_NOT_SAME_DEVICE, EXDEV}, {ERROR_WRITE_PROTECT, EACCES}, {ERROR_BAD_UNIT, ENODEV}, {ERROR_NOT_READY, EAGAIN}, {ERROR_SEEK, EIO}, {ERROR_WRITE_FAULT, EIO}, {ERROR_READ_FAULT, EIO}, {ERROR_SHARING_VIOLATION, EACCES}, {ERROR_LOCK_VIOLATION, ENOLCK}, {ERROR_HANDLE_DISK_FULL, ENOSPC}, {ERROR_NOT_SUPPORTED, ENOTSUP, TRUE}, {ERROR_DEV_NOT_EXIST, ENODEV}, {ERROR_FILE_EXISTS, EEXIST}, {ERROR_CANNOT_MAKE, EACCES}, {ERROR_INVALID_PARAMETER, EINVAL, TRUE}, {ERROR_OPEN_FAILED, EIO}, {ERROR_BUFFER_OVERFLOW, ENAMETOOLONG}, {ERROR_DISK_FULL, ENOSPC}, {ERROR_INVALID_NAME, ENOENT, TRUE, EINVAL}, {ERROR_NEGATIVE_SEEK, EINVAL}, {ERROR_BUSY_DRIVE, EBUSY}, {ERROR_DIR_NOT_EMPTY, ENOTEMPTY}, {ERROR_BUSY, EBUSY}, {ERROR_ALREADY_EXISTS, EEXIST}, {ERROR_LOCKED, ENOLCK}, {ERROR_DIRECTORY, EINVAL}, {ERROR_OPERATION_ABORTED, ECANCELED}, {ERROR_NOACCESS, EACCES}, {ERROR_CANTOPEN, EIO}, {ERROR_CANTREAD, EIO}, {ERROR_CANTWRITE, EIO}, {ERROR_RETRY, EAGAIN}, {ERROR_OPEN_FILES, EBUSY}, {ERROR_DEVICE_IN_USE, EBUSY}, {ERROR_REPARSE_TAG_INVALID, EINVAL, TRUE}, {WSAEINTR, EINTR}, {WSAEBADF, EBADF}, {WSAEACCES, EACCES}, {WSAEFAULT, EFAULT}, {WSAEINVAL, EINVAL}, {WSAEMFILE, EMFILE}, {WSAEWOULDBLOCK, EWOULDBLOCK}, {WSAEINPROGRESS, EINPROGRESS}, {WSAEALREADY, EALREADY}, {WSAENOTSOCK, ENOTSOCK}, {WSAEDESTADDRREQ, EDESTADDRREQ}, {WSAEMSGSIZE, EMSGSIZE}, {WSAEPROTOTYPE, EPROTOTYPE}, {WSAENOPROTOOPT, ENOPROTOOPT}, {WSAEPROTONOSUPPORT, EPROTONOSUPPORT}, {WSAEOPNOTSUPP, EOPNOTSUPP}, {WSAEAFNOSUPPORT, EAFNOSUPPORT}, {WSAEADDRINUSE, EADDRINUSE}, {WSAEADDRNOTAVAIL, EADDRNOTAVAIL}, {WSAENETDOWN, ENETDOWN}, {WSAENETUNREACH, ENETUNREACH}, {WSAENETRESET, ENETRESET}, {WSAECONNABORTED, ECONNABORTED}, {WSAECONNRESET, ECONNRESET}, {WSAENOBUFS, ENOBUFS}, {WSAEISCONN, EISCONN}, {WSAENOTCONN, ENOTCONN}, {WSAETIMEDOUT, ETIMEDOUT}, {WSAECONNREFUSED, ECONNREFUSED}, {WSAENAMETOOLONG, ENAMETOOLONG}, {WSAEHOSTUNREACH, EHOSTUNREACH} }; int i, ret; for(i=0; imtx); if(InterlockedIncrement(&cm->started) == cm->thread_no) SetEvent(cm->initialized); if(cm->timed_wait) { xtime xt; p_xtime_get(&xt, 1); xt.sec += 2; r = p__Cnd_timedwait(cm->cnd, cm->mtx, &xt); ok(!r, "timed wait failed\n"); } else { r = p__Cnd_wait(cm->cnd, cm->mtx); ok(!r, "wait failed\n"); } p__Mtx_unlock(cm->mtx); return 0; } static void test_cnd(void) { _Thrd_t threads[NUM_THREADS]; xtime xt, before, after; struct cndmtx cm; int r, i, diff; _Cnd_t cnd; _Mtx_t mtx; r = p__Cnd_init(&cnd); ok(!r, "failed to init cnd\n"); r = p__Mtx_init(&mtx, 0); ok(!r, "failed to init mtx\n"); p__Cnd_destroy(NULL); /* test _Cnd_signal/_Cnd_wait */ cm.initialized = CreateEventW(NULL, FALSE, FALSE, NULL); cm.started = 0; cm.thread_no = 1; cm.cnd = cnd; cm.mtx = mtx; cm.timed_wait = FALSE; p__Thrd_create(&threads[0], cnd_wait_thread, (void*)&cm); WaitForSingleObject(cm.initialized, INFINITE); p__Mtx_lock(mtx); p__Mtx_unlock(mtx); r = p__Cnd_signal(cm.cnd); ok(!r, "failed to signal\n"); p__Thrd_join(threads[0], NULL); /* test _Cnd_timedwait time out */ p__Mtx_lock(mtx); p_xtime_get(&before, 1); xt = before; xt.sec += 1; /* try to avoid failures on spurious wakeup */ p__Cnd_timedwait(cnd, mtx, &xt); r = p__Cnd_timedwait(cnd, mtx, &xt); p_xtime_get(&after, 1); p__Mtx_unlock(mtx); diff = p__Xtime_diff_to_millis2(&after, &before); ok(r == 2, "should have timed out\n"); ok(diff > 1000 - TIMEDELTA, "got %d\n", diff); /* test _Cnd_timedwait */ cm.started = 0; cm.timed_wait = TRUE; p__Thrd_create(&threads[0], cnd_wait_thread, (void*)&cm); WaitForSingleObject(cm.initialized, INFINITE); p__Mtx_lock(mtx); p__Mtx_unlock(mtx); r = p__Cnd_signal(cm.cnd); ok(!r, "failed to signal\n"); p__Thrd_join(threads[0], NULL); /* test _Cnd_broadcast */ cm.started = 0; cm.thread_no = NUM_THREADS; for(i = 0; i < cm.thread_no; i++) p__Thrd_create(&threads[i], cnd_wait_thread, (void*)&cm); WaitForSingleObject(cm.initialized, INFINITE); p__Mtx_lock(mtx); p__Mtx_unlock(mtx); r = p__Cnd_broadcast(cnd); ok(!r, "failed to broadcast\n"); for(i = 0; i < cm.thread_no; i++) p__Thrd_join(threads[i], NULL); p__Cnd_destroy(cnd); p__Mtx_destroy(mtx); CloseHandle(cm.initialized); } START_TEST(msvcp140) { if(!init()) return; test_thrd(); test__Task_impl_base__IsNonBlockingThread(); test_vbtable_size_exports(); test_task_continuation_context(); test__ContextCallback(); test__TaskEventLogger(); test_chore(); test_to_byte(); test_to_wide(); test_File_size(); test_Current_get(); test_Current_set(); test_Stat(); test_dir_operation(); test_Unlink(); test_Temp_get(); test_Rename(); test_Last_write_time(); test__Winerror_message(); test__Winerror_map(); test__Syserror_map(); test_Equivalent(); test_cnd(); FreeLibrary(msvcp); }