int write_socket_force(struct ClientSocket *client, char* msg, int len) {
SYNCHRONIZE(synchronized);
- printf("[send %d] %s", len, msg);
+ #ifdef HAVE_THREADS
+ putlog(LOGLEVEL_RAW, "[%d send %d] %s", getCurrentThreadID(), len, msg);
+ #else
+ putlog(LOGLEVEL_RAW, "[send %d] %s", len, msg);
+ #endif
if(!(client->flags & SOCKET_FLAG_HAVE_SSL) || ssl_write(client, msg, len) == -2) {
#ifdef WIN32
send(client->sock, msg, len, 0);
}
#endif
-void socket_loop(int timeout_seconds) {
- if(sockets == NULL) return;
+int socket_loop(int timeout_seconds) {
+ if(sockets == NULL) return 0;
int is_synchronized = 1;
SYNCHRONIZE(synchronized_recv);
fd_set fds;
ret = select(ret + 1, &fds, NULL, NULL, &timeout);
if(ret == 0) {
DESYNCHRONIZE(synchronized_recv);
- return;
+ return 1;
}
for (sock = sockets->data; sock; sock = next) {
next = sock->next;
if(is_synchronized) {
DESYNCHRONIZE(synchronized_recv);
}
+ return (ret + 1);
}
void