#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
+#include <assert.h>
#include "rx.h"
#include "rx_clock.h"
#endif
fprintf(stderr, "clock: could not set interval timer; \
aborted(errno=%d)\n", errno);
fflush(stderr);
- exit(1);
+ assert(0);
}
if (relclock_epoch.usec + startvalue.usec >= otimer.it_value.tv_usec) {
relclock_epoch.sec = relclock_epoch.sec +
if (pthread_attr_init(&tattr) != 0) {
dpf(("Unable to Create Rx server thread (pthread_attr_init)\n"));
- exit(1);
+ assert(0);
}
if (pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED) != 0) {
dpf
(("Unable to Create Rx server thread (pthread_attr_setdetachstate)\n"));
- exit(1);
+ assert(0);
}
/*
AFS_SIGSET_CLEAR();
if (pthread_create(&thread, &tattr, server_entry, (void *)proc) != 0) {
dpf(("Unable to Create Rx server thread\n"));
- exit(1);
+ assert(0);
}
AFS_SIGSET_RESTORE();
}
if (!(p = rxi_AllocPacket(RX_PACKET_CLASS_RECEIVE))) {
/* Could this happen with multiple socket listeners? */
dpf(("rxi_Listener: no packets!")); /* Shouldn't happen */
- exit(1);
+ assert(0);
}
}
if (pthread_attr_init(&tattr) != 0) {
dpf
(("Unable to create Rx event handling thread (pthread_attr_init)\n"));
- exit(1);
+ assert(0);
}
if (pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED) != 0) {
dpf
(("Unable to create Rx event handling thread (pthread_attr_setdetachstate)\n"));
- exit(1);
+ assert(0);
}
AFS_SIGSET_CLEAR();
if (pthread_create(&event_handler_thread, &tattr, event_handler, NULL) !=
0) {
dpf(("Unable to create Rx event handling thread\n"));
- exit(1);
+ assert(0);
}
MUTEX_ENTER(&rx_pthread_mutex);
++rxi_pthread_hinum;
if (pthread_attr_init(&tattr) != 0) {
dpf
(("Unable to create socket listener thread (pthread_attr_init)\n"));
- exit(1);
+ assert(0);
}
if (pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED) != 0) {
dpf
(("Unable to create socket listener thread (pthread_attr_setdetachstate)\n"));
- exit(1);
+ assert(0);
}
AFS_SIGSET_CLEAR();
if (pthread_create(&thread, &tattr, rx_ListenerProc, (void *)(intptr_t)sock) != 0) {
dpf(("Unable to create socket listener thread\n"));
- exit(1);
+ assert(0);
}
MUTEX_ENTER(&rx_pthread_mutex);
++rxi_pthread_hinum;