Changeset 257feec in mainline for uspace/srv/net/udp/sock.c
- Timestamp:
- 2013-06-27T12:48:32Z (12 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 9f391e9
- Parents:
- 679ee84
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/udp/sock.c
r679ee84 r257feec 222 222 assert(false); 223 223 } 224 224 225 225 log_msg(LOG_DEFAULT, LVL_DEBUG, " - success"); 226 226 async_answer_0(callid, rc); … … 428 428 socket = (udp_sockdata_t *)sock_core->specific_data; 429 429 fibril_mutex_lock(&socket->lock); 430 430 431 431 if (socket->assoc == NULL) { 432 432 fibril_mutex_unlock(&socket->lock); … … 444 444 &socket->recv_buffer_lock); 445 445 } 446 446 447 447 log_msg(LOG_DEFAULT, LVL_DEBUG, "Got data in sock recv_buffer"); 448 448 … … 467 467 assert(false); 468 468 } 469 469 470 470 log_msg(LOG_DEFAULT, LVL_DEBUG, "**** udp_uc_receive -> %d", rc); 471 471 472 if (rc != EOK) { 472 473 fibril_mutex_unlock(&socket->recv_buffer_lock); … … 519 520 return; 520 521 } 521 522 522 523 if (length > data_len) 523 524 length = data_len; 524 525 525 526 log_msg(LOG_DEFAULT, LVL_DEBUG, "data read finalize"); 526 527 rc = async_data_read_finalize(rcallid, socket->recv_buffer, length); … … 528 529 if (length < data_len && rc == EOK) 529 530 rc = EOVERFLOW; 530 531 531 532 log_msg(LOG_DEFAULT, LVL_DEBUG, "read_data_length <- %zu", length); 532 533 IPC_SET_ARG2(answer, 0); … … 535 536 async_answer_3(callid, EOK, IPC_GET_ARG1(answer), 536 537 IPC_GET_ARG2(answer), IPC_GET_ARG3(answer)); 537 538 538 539 socket->recv_buffer_used = 0; 539 540 540 541 fibril_condvar_broadcast(&socket->recv_buffer_cv); 541 542 fibril_mutex_unlock(&socket->recv_buffer_lock); … … 612 613 while (true) { 613 614 log_msg(LOG_DEFAULT, LVL_DEBUG, "[] wait for rcv buffer empty()"); 614 while ( sock->recv_buffer_used != 0 && sock->sock_core != NULL) {615 while ((sock->recv_buffer_used != 0) && (sock->sock_core != NULL)) { 615 616 fibril_condvar_wait(&sock->recv_buffer_cv, 616 617 &sock->recv_buffer_lock);
Note:
See TracChangeset
for help on using the changeset viewer.