Changeset b1bd89ea in mainline for uspace/srv
- Timestamp:
- 2012-04-24T16:15:41Z (14 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 76983ff, bc03679
- Parents:
- 32fef47
- Location:
- uspace/srv/net
- Files:
-
- 2 edited
-
tcp/sock.c (modified) (5 diffs)
-
udp/sock.c (modified) (4 diffs)
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/tcp/sock.c
r32fef47 rb1bd89ea 42 42 #include <ipc/services.h> 43 43 #include <ipc/socket.h> 44 #include <net/modules.h>45 44 #include <net/socket.h> 46 45 #include <ns.h> … … 144 143 sock->sock_core = sock_core; 145 144 146 refresh_answer(&answer, NULL);147 145 SOCKET_SET_SOCKET_ID(answer, sock_id); 148 146 149 147 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, FRAGMENT_SIZE); 150 148 SOCKET_SET_HEADER_SIZE(answer, sizeof(tcp_header_t)); 151 answer_call(callid, EOK, &answer, 3); 149 150 async_answer_3(callid, EOK, IPC_GET_ARG1(answer), 151 IPC_GET_ARG2(answer), IPC_GET_ARG3(answer)); 152 152 } 153 153 … … 468 468 assert(asock_core != NULL); 469 469 470 refresh_answer(&answer, NULL);471 472 470 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, FRAGMENT_SIZE); 473 471 SOCKET_SET_SOCKET_ID(answer, asock_id); 474 472 SOCKET_SET_ADDRESS_LENGTH(answer, sizeof(struct sockaddr_in)); 475 476 answer_call(callid, asock_core->socket_id, &answer, 3); 477 473 474 async_answer_3(callid, asock_core->socket_id, 475 IPC_GET_ARG1(answer), IPC_GET_ARG2(answer), 476 IPC_GET_ARG3(answer)); 477 478 478 /* Push one fragment notification to client's queue */ 479 479 log_msg(LVL_DEBUG, "tcp_sock_accept(): notify data\n"); … … 559 559 } 560 560 561 refresh_answer(&answer, NULL);561 IPC_SET_ARG1(answer, 0); 562 562 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, FRAGMENT_SIZE); 563 answer_call(callid, EOK, &answer, 2); 563 async_answer_2(callid, EOK, IPC_GET_ARG1(answer), 564 IPC_GET_ARG2(answer)); 564 565 fibril_mutex_unlock(&socket->lock); 565 566 } … … 679 680 680 681 SOCKET_SET_READ_DATA_LENGTH(answer, length); 681 a nswer_call(callid, EOK, &answer, 1);682 682 async_answer_1(callid, EOK, IPC_GET_ARG1(answer)); 683 683 684 /* Push one fragment notification to client's queue */ 684 685 tcp_sock_notify_data(sock_core); -
uspace/srv/net/udp/sock.c
r32fef47 rb1bd89ea 43 43 #include <ipc/services.h> 44 44 #include <ipc/socket.h> 45 #include <net/modules.h>46 45 #include <net/socket.h> 47 46 #include <ns.h> … … 134 133 assert(sock_core != NULL); 135 134 sock->sock_core = sock_core; 136 137 138 refresh_answer(&answer, NULL); 135 139 136 SOCKET_SET_SOCKET_ID(answer, sock_id); 140 137 141 138 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, FRAGMENT_SIZE); 142 139 SOCKET_SET_HEADER_SIZE(answer, sizeof(udp_header_t)); 143 answer_call(callid, EOK, &answer, 3); 140 async_answer_3(callid, EOK, IPC_GET_ARG1(answer), 141 IPC_GET_ARG2(answer), IPC_GET_ARG3(answer)); 144 142 } 145 143 … … 369 367 } 370 368 } 371 372 refresh_answer(&answer, NULL);369 370 IPC_SET_ARG1(answer, 0); 373 371 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, FRAGMENT_SIZE); 374 answer_call(callid, EOK, &answer, 2); 372 async_answer_2(callid, EOK, IPC_GET_ARG1(answer), 373 IPC_GET_ARG2(answer)); 375 374 fibril_mutex_unlock(&socket->lock); 375 376 376 out: 377 377 if (addr != NULL) … … 486 486 487 487 log_msg(LVL_DEBUG, "read_data_length <- %zu", length); 488 IPC_SET_ARG2(answer, 0); 488 489 SOCKET_SET_READ_DATA_LENGTH(answer, length); 489 490 SOCKET_SET_ADDRESS_LENGTH(answer, sizeof(addr)); 490 answer_call(callid, EOK, &answer, 3); 491 491 async_answer_3(callid, EOK, IPC_GET_ARG1(answer), 492 IPC_GET_ARG2(answer), IPC_GET_ARG3(answer)); 493 492 494 /* Push one fragment notification to client's queue */ 493 495 udp_sock_notify_data(sock_core);
Note:
See TracChangeset
for help on using the changeset viewer.
