Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed

  • uspace/srv/net/tcp/service.c

    rb752a31 r5a6cc679  
    724724 * Handle client request to create callback session.
    725725 *
    726  * @param client        TCP client
    727  * @param icall_handle  Async request call handle
    728  * @param icall         Async request data
    729  */
    730 static void tcp_callback_create_srv(tcp_client_t *client,
    731     cap_call_handle_t icall_handle, ipc_call_t *icall)
     726 * @param client  TCP client
     727 * @param iid     Async request ID
     728 * @param icall   Async request data
     729 */
     730static void tcp_callback_create_srv(tcp_client_t *client, ipc_callid_t iid,
     731    ipc_call_t *icall)
    732732{
    733733        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_callback_create_srv()");
    … …  
    735735        async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE);
    736736        if (sess == NULL) {
    737                 async_answer_0(icall_handle, ENOMEM);
     737                async_answer_0(iid, ENOMEM);
    738738                return;
    739739        }
    740740
    741741        client->sess = sess;
    742         async_answer_0(icall_handle, EOK);
     742        async_answer_0(iid, EOK);
    743743}
    744744
    … …  
    747747 * Handle client request to create connection.
    748748 *
    749  * @param client        TCP client
    750  * @param icall_handle  Async request call handle
    751  * @param icall         Async request data
    752  */
    753 static void tcp_conn_create_srv(tcp_client_t *client,
    754     cap_call_handle_t icall_handle, ipc_call_t *icall)
    755 {
    756         cap_call_handle_t chandle;
     749 * @param client   TCP client
     750 * @param iid      Async request ID
     751 * @param icall    Async request data
     752 */
     753static void tcp_conn_create_srv(tcp_client_t *client, ipc_callid_t iid,
     754    ipc_call_t *icall)
     755{
     756        ipc_callid_t callid;
    757757        size_t size;
    758758        inet_ep2_t epp;
    … …  
    762762        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_create_srv()");
    763763
    764         if (!async_data_write_receive(&chandle, &size)) {
    765                 async_answer_0(chandle, EREFUSED);
    766                 async_answer_0(icall_handle, EREFUSED);
     764        if (!async_data_write_receive(&callid, &size)) {
     765                async_answer_0(callid, EREFUSED);
     766                async_answer_0(iid, EREFUSED);
    767767                return;
    768768        }
    769769
    770770        if (size != sizeof(inet_ep2_t)) {
    771                 async_answer_0(chandle, EINVAL);
    772                 async_answer_0(icall_handle, EINVAL);
    773                 return;
    774         }
    775 
    776         rc = async_data_write_finalize(chandle, &epp, size);
    777         if (rc != EOK) {
    778                 async_answer_0(chandle, rc);
    779                 async_answer_0(icall_handle, rc);
     771                async_answer_0(callid, EINVAL);
     772                async_answer_0(iid, EINVAL);
     773                return;
     774        }
     775
     776        rc = async_data_write_finalize(callid, &epp, size);
     777        if (rc != EOK) {
     778                async_answer_0(callid, rc);
     779                async_answer_0(iid, rc);
    780780                return;
    781781        }
    … …  
    783783        rc = tcp_conn_create_impl(client, &epp, &conn_id);
    784784        if (rc != EOK) {
    785                 async_answer_0(icall_handle, rc);
    786                 return;
    787         }
    788 
    789         async_answer_1(icall_handle, EOK, conn_id);
     785                async_answer_0(iid, rc);
     786                return;
     787        }
     788
     789        async_answer_1(iid, EOK, conn_id);
    790790}
    791791
    … …  
    794794 * Handle client request to destroy connection.
    795795 *
    796  * @param client        TCP client
    797  * @param icall_handle  Async request call handle
    798  * @param icall         Async request data
    799  */
    800 static void tcp_conn_destroy_srv(tcp_client_t *client,
    801     cap_call_handle_t icall_handle, ipc_call_t *icall)
     796 * @param client   TCP client
     797 * @param iid      Async request ID
     798 * @param icall    Async request data
     799 */
     800static void tcp_conn_destroy_srv(tcp_client_t *client, ipc_callid_t iid,
     801    ipc_call_t *icall)
    802802{
    803803        sysarg_t conn_id;
    … …  
    808808        conn_id = IPC_GET_ARG1(*icall);
    809809        rc = tcp_conn_destroy_impl(client, conn_id);
    810         async_answer_0(icall_handle, rc);
     810        async_answer_0(iid, rc);
    811811}
    812812
    … …  
    815815 * Handle client request to create listener.
    816816 *
    817  * @param client        TCP client
    818  * @param icall_handle  Async request call handle
    819  * @param icall         Async request data
    820  */
    821 static void tcp_listener_create_srv(tcp_client_t *client,
    822     cap_call_handle_t icall_handle, ipc_call_t *icall)
    823 {
    824         cap_call_handle_t chandle;
     817 * @param client   TCP client
     818 * @param iid      Async request ID
     819 * @param icall    Async request data
     820 */
     821static void tcp_listener_create_srv(tcp_client_t *client, ipc_callid_t iid,
     822    ipc_call_t *icall)
     823{
     824        ipc_callid_t callid;
    825825        size_t size;
    826826        inet_ep_t ep;
    … …  
    830830        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_listener_create_srv()");
    831831
    832         if (!async_data_write_receive(&chandle, &size)) {
    833                 async_answer_0(chandle, EREFUSED);
    834                 async_answer_0(icall_handle, EREFUSED);
     832        if (!async_data_write_receive(&callid, &size)) {
     833                async_answer_0(callid, EREFUSED);
     834                async_answer_0(iid, EREFUSED);
    835835                return;
    836836        }
    837837
    838838        if (size != sizeof(inet_ep_t)) {
    839                 async_answer_0(chandle, EINVAL);
    840                 async_answer_0(icall_handle, EINVAL);
    841                 return;
    842         }
    843 
    844         rc = async_data_write_finalize(chandle, &ep, size);
    845         if (rc != EOK) {
    846                 async_answer_0(chandle, rc);
    847                 async_answer_0(icall_handle, rc);
     839                async_answer_0(callid, EINVAL);
     840                async_answer_0(iid, EINVAL);
     841                return;
     842        }
     843
     844        rc = async_data_write_finalize(callid, &ep, size);
     845        if (rc != EOK) {
     846                async_answer_0(callid, rc);
     847                async_answer_0(iid, rc);
    848848                return;
    849849        }
    … …  
    851851        rc = tcp_listener_create_impl(client, &ep, &lst_id);
    852852        if (rc != EOK) {
    853                 async_answer_0(icall_handle, rc);
    854                 return;
    855         }
    856 
    857         async_answer_1(icall_handle, EOK, lst_id);
     853                async_answer_0(iid, rc);
     854                return;
     855        }
     856
     857        async_answer_1(iid, EOK, lst_id);
    858858}
    859859
    … …  
    862862 * Handle client request to destroy listener.
    863863 *
    864  * @param client        TCP client
    865  * @param icall_handle  Async request call handle
    866  * @param icall         Async request data
    867  */
    868 static void tcp_listener_destroy_srv(tcp_client_t *client,
    869     cap_call_handle_t icall_handle, ipc_call_t *icall)
     864 * @param client   TCP client
     865 * @param iid      Async request ID
     866 * @param icall    Async request data
     867 */
     868static void tcp_listener_destroy_srv(tcp_client_t *client, ipc_callid_t iid,
     869    ipc_call_t *icall)
    870870{
    871871        sysarg_t lst_id;
    … …  
    876876        lst_id = IPC_GET_ARG1(*icall);
    877877        rc = tcp_listener_destroy_impl(client, lst_id);
    878         async_answer_0(icall_handle, rc);
     878        async_answer_0(iid, rc);
    879879}
    880880
    … …  
    883883 * Handle client request to send FIN.
    884884 *
    885  * @param client        TCP client
    886  * @param icall_handle  Async request call handle
    887  * @param icall         Async request data
    888  */
    889 static void tcp_conn_send_fin_srv(tcp_client_t *client,
    890     cap_call_handle_t icall_handle, ipc_call_t *icall)
     885 * @param client   TCP client
     886 * @param iid      Async request ID
     887 * @param icall    Async request data
     888 */
     889static void tcp_conn_send_fin_srv(tcp_client_t *client, ipc_callid_t iid,
     890    ipc_call_t *icall)
    891891{
    892892        sysarg_t conn_id;
    … …  
    897897        conn_id = IPC_GET_ARG1(*icall);
    898898        rc = tcp_conn_send_fin_impl(client, conn_id);
    899         async_answer_0(icall_handle, rc);
     899        async_answer_0(iid, rc);
    900900}
    901901
    … …  
    904904 * Handle client request to push connection.
    905905 *
    906  * @param client        TCP client
    907  * @param icall_handle  Async request call handle
    908  * @param icall         Async request data
    909  */
    910 static void tcp_conn_push_srv(tcp_client_t *client,
    911     cap_call_handle_t icall_handle, ipc_call_t *icall)
     906 * @param client   TCP client
     907 * @param iid      Async request ID
     908 * @param icall    Async request data
     909 */
     910static void tcp_conn_push_srv(tcp_client_t *client, ipc_callid_t iid,
     911    ipc_call_t *icall)
    912912{
    913913        sysarg_t conn_id;
    … …  
    918918        conn_id = IPC_GET_ARG1(*icall);
    919919        rc = tcp_conn_push_impl(client, conn_id);
    920         async_answer_0(icall_handle, rc);
     920        async_answer_0(iid, rc);
    921921}
    922922
    … …  
    925925 * Handle client request to reset connection.
    926926 *
    927  * @param client        TCP client
    928  * @param icall_handle  Async request call handle
    929  * @param icall         Async request data
    930  */
    931 static void tcp_conn_reset_srv(tcp_client_t *client,
    932     cap_call_handle_t icall_handle, ipc_call_t *icall)
     927 * @param client   TCP client
     928 * @param iid      Async request ID
     929 * @param icall    Async request data
     930 */
     931static void tcp_conn_reset_srv(tcp_client_t *client, ipc_callid_t iid,
     932    ipc_call_t *icall)
    933933{
    934934        sysarg_t conn_id;
    … …  
    939939        conn_id = IPC_GET_ARG1(*icall);
    940940        rc = tcp_conn_reset_impl(client, conn_id);
    941         async_answer_0(icall_handle, rc);
     941        async_answer_0(iid, rc);
    942942}
    943943
    … …  
    946946 * Handle client request to send data via connection.
    947947 *
    948  * @param client        TCP client
    949  * @param icall_handle  Async request call handle
    950  * @param icall         Async request data
    951  */
    952 static void tcp_conn_send_srv(tcp_client_t *client,
    953     cap_call_handle_t icall_handle, ipc_call_t *icall)
    954 {
    955         cap_call_handle_t chandle;
     948 * @param client   TCP client
     949 * @param iid      Async request ID
     950 * @param icall    Async request data
     951 */
     952static void tcp_conn_send_srv(tcp_client_t *client, ipc_callid_t iid,
     953    ipc_call_t *icall)
     954{
     955        ipc_callid_t callid;
    956956        size_t size;
    957957        sysarg_t conn_id;
    … …  
    963963        /* Receive message data */
    964964
    965         if (!async_data_write_receive(&chandle, &size)) {
    966                 async_answer_0(chandle, EREFUSED);
    967                 async_answer_0(icall_handle, EREFUSED);
     965        if (!async_data_write_receive(&callid, &size)) {
     966                async_answer_0(callid, EREFUSED);
     967                async_answer_0(iid, EREFUSED);
    968968                return;
    969969        }
    970970
    971971        if (size > MAX_MSG_SIZE) {
    972                 async_answer_0(chandle, EINVAL);
    973                 async_answer_0(icall_handle, EINVAL);
     972                async_answer_0(callid, EINVAL);
     973                async_answer_0(iid, EINVAL);
    974974                return;
    975975        }
    … …  
    977977        data = malloc(size);
    978978        if (data == NULL) {
    979                 async_answer_0(chandle, ENOMEM);
    980                 async_answer_0(icall_handle, ENOMEM);
    981                 return;
    982         }
    983 
    984         rc = async_data_write_finalize(chandle, data, size);
    985         if (rc != EOK) {
    986                 async_answer_0(chandle, rc);
    987                 async_answer_0(icall_handle, rc);
     979                async_answer_0(callid, ENOMEM);
     980                async_answer_0(iid, ENOMEM);
     981                return;
     982        }
     983
     984        rc = async_data_write_finalize(callid, data, size);
     985        if (rc != EOK) {
     986                async_answer_0(callid, rc);
     987                async_answer_0(iid, rc);
    988988                free(data);
    989989                return;
    … …  
    994994        rc = tcp_conn_send_impl(client, conn_id, data, size);
    995995        if (rc != EOK) {
    996                 async_answer_0(icall_handle, rc);
     996                async_answer_0(iid, rc);
    997997                free(data);
    998998                return;
    999999        }
    10001000
    1001         async_answer_0(icall_handle, EOK);
     1001        async_answer_0(iid, EOK);
    10021002        free(data);
    10031003}
    … …  
    10071007 * Handle client request to read received data via connection without blocking.
    10081008 *
    1009  * @param client        TCP client
    1010  * @param icall_handle  Async request call handle
    1011  * @param icall         Async request data
    1012  */
    1013 static void tcp_conn_recv_srv(tcp_client_t *client,
    1014     cap_call_handle_t icall_handle, ipc_call_t *icall)
    1015 {
    1016         cap_call_handle_t chandle;
     1009 * @param client   TCP client
     1010 * @param iid      Async request ID
     1011 * @param icall    Async request data
     1012 */
     1013static void tcp_conn_recv_srv(tcp_client_t *client, ipc_callid_t iid,
     1014    ipc_call_t *icall)
     1015{
     1016        ipc_callid_t callid;
    10171017        sysarg_t conn_id;
    10181018        size_t size, rsize;
    … …  
    10241024        conn_id = IPC_GET_ARG1(*icall);
    10251025
    1026         if (!async_data_read_receive(&chandle, &size)) {
    1027                 async_answer_0(chandle, EREFUSED);
    1028                 async_answer_0(icall_handle, EREFUSED);
     1026        if (!async_data_read_receive(&callid, &size)) {
     1027                async_answer_0(callid, EREFUSED);
     1028                async_answer_0(iid, EREFUSED);
    10291029                return;
    10301030        }
    … …  
    10331033        data = malloc(size);
    10341034        if (data == NULL) {
    1035                 async_answer_0(chandle, ENOMEM);
    1036                 async_answer_0(icall_handle, ENOMEM);
     1035                async_answer_0(callid, ENOMEM);
     1036                async_answer_0(iid, ENOMEM);
    10371037                return;
    10381038        }
    … …  
    10401040        rc = tcp_conn_recv_impl(client, conn_id, data, size, &rsize);
    10411041        if (rc != EOK) {
    1042                 async_answer_0(chandle, rc);
    1043                 async_answer_0(icall_handle, rc);
     1042                async_answer_0(callid, rc);
     1043                async_answer_0(iid, rc);
    10441044                free(data);
    10451045                return;
    10461046        }
    10471047
    1048         rc = async_data_read_finalize(chandle, data, size);
    1049         if (rc != EOK) {
    1050                 async_answer_0(icall_handle, rc);
     1048        rc = async_data_read_finalize(callid, data, size);
     1049        if (rc != EOK) {
     1050                async_answer_0(iid, rc);
    10511051                free(data);
    10521052                return;
    10531053        }
    10541054
    1055         async_answer_1(icall_handle, EOK, rsize);
     1055        async_answer_1(iid, EOK, rsize);
    10561056        free(data);
    10571057
    … …  
    10631063 * Handle client request to read received data via connection with blocking.
    10641064 *
    1065  * @param client        TCP client
    1066  * @param icall_handle  Async request call handle
    1067  * @param icall         Async request data
    1068  */
    1069 static void tcp_conn_recv_wait_srv(tcp_client_t *client,
    1070     cap_call_handle_t icall_handle, ipc_call_t *icall)
    1071 {
    1072         cap_call_handle_t chandle;
     1065 * @param client   TCP client
     1066 * @param iid      Async request ID
     1067 * @param icall    Async request data
     1068 */
     1069static void tcp_conn_recv_wait_srv(tcp_client_t *client, ipc_callid_t iid,
     1070    ipc_call_t *icall)
     1071{
     1072        ipc_callid_t callid;
    10731073        sysarg_t conn_id;
    10741074        size_t size, rsize;
    … …  
    10801080        conn_id = IPC_GET_ARG1(*icall);
    10811081
    1082         if (!async_data_read_receive(&chandle, &size)) {
     1082        if (!async_data_read_receive(&callid, &size)) {
    10831083                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - data_receive failed");
    1084                 async_answer_0(chandle, EREFUSED);
    1085                 async_answer_0(icall_handle, EREFUSED);
     1084                async_answer_0(callid, EREFUSED);
     1085                async_answer_0(iid, EREFUSED);
    10861086                return;
    10871087        }
    … …  
    10911091        if (data == NULL) {
    10921092                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - allocation failed");
    1093                 async_answer_0(chandle, ENOMEM);
    1094                 async_answer_0(icall_handle, ENOMEM);
     1093                async_answer_0(callid, ENOMEM);
     1094                async_answer_0(iid, ENOMEM);
    10951095                return;
    10961096        }
    … …  
    10991099        if (rc != EOK) {
    11001100                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - recv_impl failed rc=%s", str_error_name(rc));
    1101                 async_answer_0(chandle, rc);
    1102                 async_answer_0(icall_handle, rc);
     1101                async_answer_0(callid, rc);
     1102                async_answer_0(iid, rc);
    11031103                free(data);
    11041104                return;
    11051105        }
    11061106
    1107         rc = async_data_read_finalize(chandle, data, size);
     1107        rc = async_data_read_finalize(callid, data, size);
    11081108        if (rc != EOK) {
    11091109                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - finalize failed");
    1110                 async_answer_0(icall_handle, rc);
     1110                async_answer_0(iid, rc);
    11111111                free(data);
    11121112                return;
    … …  
    11141114
    11151115        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv(): rsize=%zu", size);
    1116         async_answer_1(icall_handle, EOK, rsize);
     1116        async_answer_1(iid, EOK, rsize);
    11171117        free(data);
    11181118
    … …  
    11681168/** Handle TCP client connection.
    11691169 *
    1170  * @param icall_handle  Connect call handle
    1171  * @param icall         Connect call data
    1172  * @param arg           Connection argument
    1173  */
    1174 static void tcp_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall,
    1175     void *arg)
     1170 * @param iid   Connect call ID
     1171 * @param icall Connect call data
     1172 * @param arg   Connection argument
     1173 */
     1174static void tcp_client_conn(ipc_callid_t iid, ipc_call_t *icall, void *arg)
    11761175{
    11771176        tcp_client_t client;
    11781177
    11791178        /* Accept the connection */
    1180         async_answer_0(icall_handle, EOK);
     1179        async_answer_0(iid, EOK);
    11811180
    11821181        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_client_conn() - client=%p",
    … …  
    11881187                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_client_conn: wait req");
    11891188                ipc_call_t call;
    1190                 cap_call_handle_t chandle = async_get_call(&call);
     1189                ipc_callid_t callid = async_get_call(&call);
    11911190                sysarg_t method = IPC_GET_IMETHOD(call);
    11921191
    … …  
    11951194                if (!method) {
    11961195                        /* The other side has hung up */
    1197                         async_answer_0(chandle, EOK);
     1196                        async_answer_0(callid, EOK);
    11981197                        break;
    11991198                }
    … …  
    12011200                switch (method) {
    12021201                case TCP_CALLBACK_CREATE:
    1203                         tcp_callback_create_srv(&client, chandle, &call);
     1202                        tcp_callback_create_srv(&client, callid, &call);
    12041203                        break;
    12051204                case TCP_CONN_CREATE:
    1206                         tcp_conn_create_srv(&client, chandle, &call);
     1205                        tcp_conn_create_srv(&client, callid, &call);
    12071206                        break;
    12081207                case TCP_CONN_DESTROY:
    1209                         tcp_conn_destroy_srv(&client, chandle, &call);
     1208                        tcp_conn_destroy_srv(&client, callid, &call);
    12101209                        break;
    12111210                case TCP_LISTENER_CREATE:
    1212                         tcp_listener_create_srv(&client, chandle, &call);
     1211                        tcp_listener_create_srv(&client, callid, &call);
    12131212                        break;
    12141213                case TCP_LISTENER_DESTROY:
    1215                         tcp_listener_destroy_srv(&client, chandle, &call);
     1214                        tcp_listener_destroy_srv(&client, callid, &call);
    12161215                        break;
    12171216                case TCP_CONN_SEND_FIN:
    1218                         tcp_conn_send_fin_srv(&client, chandle, &call);
     1217                        tcp_conn_send_fin_srv(&client, callid, &call);
    12191218                        break;
    12201219                case TCP_CONN_PUSH:
    1221                         tcp_conn_push_srv(&client, chandle, &call);
     1220                        tcp_conn_push_srv(&client, callid, &call);
    12221221                        break;
    12231222                case TCP_CONN_RESET:
    1224                         tcp_conn_reset_srv(&client, chandle, &call);
     1223                        tcp_conn_reset_srv(&client, callid, &call);
    12251224                        break;
    12261225                case TCP_CONN_SEND:
    1227                         tcp_conn_send_srv(&client, chandle, &call);
     1226                        tcp_conn_send_srv(&client, callid, &call);
    12281227                        break;
    12291228                case TCP_CONN_RECV:
    1230                         tcp_conn_recv_srv(&client, chandle, &call);
     1229                        tcp_conn_recv_srv(&client, callid, &call);
    12311230                        break;
    12321231                case TCP_CONN_RECV_WAIT:
    1233                         tcp_conn_recv_wait_srv(&client, chandle, &call);
     1232                        tcp_conn_recv_wait_srv(&client, callid, &call);
    12341233                        break;
    12351234                default:
    1236                         async_answer_0(chandle, ENOTSUP);
     1235                        async_answer_0(callid, ENOTSUP);
    12371236                        break;
    12381237                }
Note: See TracChangeset for help on using the changeset viewer.