Skip to content
Snippets Groups Projects
Commit 26f4a92f authored by Deucе's avatar Deucе :ok_hand_tone4:
Browse files

Only read readable sockets.

parent 7d32d524
No related branches found
No related tags found
No related merge requests found
......@@ -29,13 +29,13 @@ rlogin_input_thread(void *args)
rd = recv(rlogin_sock, conn_api.rd_buf, conn_api.rd_buf_size, 0);
if (rd <= 0)
break;
}
buffered = 0;
while (rlogin_sock != INVALID_SOCKET && buffered < rd) {
pthread_mutex_lock(&(conn_inbuf.mutex));
buffer = conn_buf_wait_free(&conn_inbuf, rd - buffered, 1000);
buffered += conn_buf_put(&conn_inbuf, conn_api.rd_buf + buffered, buffer);
pthread_mutex_unlock(&(conn_inbuf.mutex));
buffered = 0;
while (rlogin_sock != INVALID_SOCKET && buffered < rd) {
pthread_mutex_lock(&(conn_inbuf.mutex));
buffer = conn_buf_wait_free(&conn_inbuf, rd - buffered, 1000);
buffered += conn_buf_put(&conn_inbuf, conn_api.rd_buf + buffered, buffer);
pthread_mutex_unlock(&(conn_inbuf.mutex));
}
}
}
conn_api.input_thread_running = 2;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment