StarMirror/toxcore
1
0
Fork 0
mirror of https://github.com/irungentoo/toxcore.git synced 2024-03-22 13:30:51 +08:00
Code Issues Projects Releases Wiki Activity

Fixed possible threading issue.

Browse Source
This commit is contained in:
irungentoo 2014-12-03 14:22:41 -05:00
parent 4a27f61956
commit 475c157d68
No known key found for this signature in database
GPG Key ID: 10349DC9BED89E98
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
toxcore/net_crypto.c
View File

@ -1168,7 +1168,15 @@ static int handle_data_packet_helper(const Net_Crypto *c, int crypt_connection_i
if (add_data_to_buffer(&conn->recv_array, num, &dt) != 0)
return -1;
while (read_data_beg_buffer(&conn->recv_array, &dt) != -1) {
while (1) {
pthread_mutex_lock(&conn->mutex);
int ret = read_data_beg_buffer(&conn->recv_array, &dt);
pthread_mutex_unlock(&conn->mutex);
if (ret == -1)
break;
if (conn->connection_data_callback)
conn->connection_data_callback(conn->connection_data_callback_object, conn->connection_data_callback_id, dt.data,
dt.length);