Revision: 14520
Author: adrian.chadd
Date: Wed Mar 31 02:06:42 2010
Log: Issue #94 - fatal() -> libcore_fatalf()
http://code.google.com/p/lusca-cache/source/detail?r=14520
Modified:
/branches/LUSCA_HEAD/libasyncio/aiops_win32.c
=======================================
--- /branches/LUSCA_HEAD/libasyncio/aiops_win32.c Wed Mar 24 23:16:16 2010
+++ /branches/LUSCA_HEAD/libasyncio/aiops_win32.c Wed Mar 31 02:06:42 2010
@@ -129,21 +129,21 @@
FALSE, /* child process's don't inherit the handle */
DUPLICATE_SAME_ACCESS)) {
/* spit errors */
- fatal("couldn't get current thread handle\n");
+ libcore_fatalf("couldn't get current thread handle\n");
}
/* Initialize request queue */
if ((request_queue.mutex = CreateMutex(NULL, /* no inheritance */
FALSE, /* start unowned (as per mutex_init) */
NULL) /* no name */
) == NULL) {
- fatal("failed to create mutex\n");
+ libcore_fatalf("failed to create mutex\n");
}
if ((request_queue.cond = CreateEvent(NULL, /* no
inheritance */
FALSE, /* auto signal reset - which I think is
pthreads like ? */
FALSE, /* start non signaled */
NULL) /* no name */
) == NULL) {
- fatal("failed to create condition event variable.\n");
+ libcore_fatalf("failed to create condition event variable.\n");
}
request_queue.head = NULL;
request_queue.tailp = &request_queue.head;
@@ -155,14 +155,14 @@
FALSE, /* start unowned (as per mutex_init) */
NULL) /* no name */
) == NULL) {
- fatal("failed to create mutex\n");
+ libcore_fatalf("failed to create mutex\n");
}
if ((done_queue.cond = CreateEvent(NULL, /* no inheritance */
TRUE, /* manually signaled - which I think is
pthreads like ? */
FALSE, /* start non signaled */
NULL) /* no name */
) == NULL) {
- fatal("failed to create condition event variable.\n");
+ libcore_fatalf("failed to create condition event variable.\n");
}
done_queue.head = NULL;
done_queue.tailp = &done_queue.head;
@@ -281,7 +281,7 @@
/* lock the thread info */
if (WAIT_FAILED == WaitForSingleObject(request_queue.mutex, INFINITE))
{
- fatal("Can't get ownership of mutex\n");
+ libcore_fatalf("Can't get ownership of mutex\n");
}
/* duplicate the handle */
if (!DuplicateHandle(GetCurrentProcess(), /* pseudo handle, don't
close */
@@ -291,10 +291,10 @@
0, /* required access */
FALSE, /* child process's don't inherit the handle */
DUPLICATE_SAME_ACCESS))
- fatal("Can't duplicate mutex handle\n");
+ libcore_fatalf("Can't duplicate mutex handle\n");
if (!ReleaseMutex(request_queue.mutex)) {
CloseHandle(cond);
- fatal("Can't release mutex\n");
+ libcore_fatalf("Can't release mutex\n");
}
while (1) {
DWORD rv;
@@ -429,10 +429,10 @@
*request_queue.tailp = request;
request_queue.tailp = &request->next;
if (!SetEvent(request_queue.cond))
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
if (!ReleaseMutex(request_queue.mutex)) {
/* unexpected error */
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
}
} else {
/* Oops, the request queue is blocked, use request_queue2 */
@@ -448,10 +448,10 @@
*request_queue.tailp = request_queue2.head;
request_queue.tailp = &request->next;
if (!SetEvent(request_queue.cond))
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
if (!ReleaseMutex(request_queue.mutex)) {
/* unexpected error */
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
}
request_queue2.head = NULL;
request_queue2.tailp = &request_queue2.head;
@@ -790,10 +790,10 @@
*request_queue.tailp = request_queue2.head;
request_queue.tailp = request_queue2.tailp;
if (!SetEvent(request_queue.cond))
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
if (!ReleaseMutex(request_queue.mutex)) {
/* unexpected error */
- fatal("couldn't push queue\n");
+ libcore_fatalf("couldn't push queue\n");
}
request_queue2.head = NULL;
request_queue2.tailp = &request_queue2.head;
@@ -809,7 +809,7 @@
done_queue.tailp = &done_queue.head;
if (!ReleaseMutex(done_queue.mutex)) {
/* unexpected error */
- fatal("couldn't poll queue\n");
+ libcore_fatalf("couldn't poll queue\n");
}
*done_requests.tailp = requests;
request_queue_len -= 1;
--
You received this message because you are subscribed to the Google Groups
"lusca-commit" group.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to
[email protected].
For more options, visit this group at
http://groups.google.com/group/lusca-commit?hl=en.
