struct admin_list *admin;
struct admin_message msg;
+ lock_debug("handle+");
if ((what & LCR_FD_READ)) {
/* read from socket */
len = read(lcr_sock, &msg, sizeof(msg));
close_socket();
release_all_calls();
schedule_timer(&socket_retry, SOCKET_RETRY_TIMER, 0);
+ lock_debug("handle-");
return 0;
}
if (len > 0) {
/* write to socket */
if (!admin_first) {
socket_fd.when &= ~LCR_FD_WRITE;
+ lock_debug("handle-");
return 0;
}
admin = admin_first;
}
}
+ lock_debug("handle-");
return 0;
}
{
char byte;
+ lock_debug("wake+");
read(wake_pipe[0], &byte, 1);
wake_global = 0;
+ lock_debug("wake-");
return 0;
}
printf("9"); fflush(stdout);
work = 1;
lcr_fd->cb(lcr_fd, flags, lcr_fd->cb_instance, lcr_fd->cb_index);
+printf("0"); fflush(stdout);
if (unregistered)
goto restart;
printf("-"); fflush(stdout);