coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-06 08:46:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

add test for robust(windows)

Browse Source
This commit is contained in:
mutouyun 2021-06-06 18:50:24 +08:00
parent 6746e1a740
commit ef2988b6e1
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
test/test_pthread.cpp
View File

@ -1,9 +1,10 @@
#include <thread>
#include <iostream>
#include "test.h"
#ifdef __linux__
#if defined(__linux__) || defined(__linux)
#include <pthread.h>
#include <time.h>
@ -21,8 +22,6 @@ TEST(PThread, Robust) {
struct timespec tout;
clock_gettime(CLOCK_REALTIME, &tout);
struct tm *tmp = localtime(&tout.tv_sec);
tout.tv_sec += 1; /* 1 seconds from now */
int r = pthread_mutex_timedlock(&mutex, &tout);
EXPECT_EQ(r, EOWNERDEAD);
@ -30,4 +29,21 @@ TEST(PThread, Robust) {
pthread_mutex_unlock(&mutex);
pthread_mutex_destroy(&mutex);
}
#endif // __linux__
#elif defined(WIN64) || defined(_WIN64) || defined(__WIN64__) || \
defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__)
#include <Windows.h>
#include <tchar.h>
TEST(PThread, Robust) {
HANDLE lock = CreateMutex(NULL, FALSE, _T("test-robust"));
std::thread{[] {
HANDLE lock = CreateMutex(NULL, FALSE, _T("test-robust"));
WaitForSingleObject(lock, 0);
}}.join();
DWORD r = WaitForSingleObject(lock, 0);
EXPECT_EQ(r, WAIT_ABANDONED);
CloseHandle(lock);
}
#endif // !__linux__