Changeset a46e56b in mainline for uspace/srv/net
- Timestamp:
- 2018-03-22T06:49:35Z (8 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 77f0a1d
- Parents:
- 3e242d2
- git-author:
- Jakub Jermar <jakub@…> (2018-03-21 23:29:06)
- git-committer:
- Jakub Jermar <jakub@…> (2018-03-22 06:49:35)
- Location:
- uspace/srv/net
- Files:
-
- 12 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/dhcp/main.c
r3e242d2 ra46e56b 84 84 } 85 85 86 static void dhcp_link_add_srv(cap_call_handle_t c allid, ipc_call_t *call)86 static void dhcp_link_add_srv(cap_call_handle_t chandle, ipc_call_t *call) 87 87 { 88 88 sysarg_t link_id; … … 94 94 95 95 rc = dhcpsrv_link_add(link_id); 96 async_answer_0(c allid, rc);96 async_answer_0(chandle, rc); 97 97 } 98 98 99 static void dhcp_link_remove_srv(cap_call_handle_t c allid, ipc_call_t *call)99 static void dhcp_link_remove_srv(cap_call_handle_t chandle, ipc_call_t *call) 100 100 { 101 101 sysarg_t link_id; … … 107 107 108 108 rc = dhcpsrv_link_remove(link_id); 109 async_answer_0(c allid, rc);109 async_answer_0(chandle, rc); 110 110 } 111 111 112 static void dhcp_discover_srv(cap_call_handle_t c allid, ipc_call_t *call)112 static void dhcp_discover_srv(cap_call_handle_t chandle, ipc_call_t *call) 113 113 { 114 114 sysarg_t link_id; … … 120 120 121 121 rc = dhcpsrv_discover(link_id); 122 async_answer_0(c allid, rc);122 async_answer_0(chandle, rc); 123 123 } 124 124 125 static void dhcp_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)125 static void dhcp_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 126 126 { 127 127 log_msg(LOG_DEFAULT, LVL_DEBUG, "dhcp_client_conn()"); 128 128 129 129 /* Accept the connection */ 130 async_answer_0(i id, EOK);130 async_answer_0(icall_handle, EOK); 131 131 132 132 while (true) { 133 133 ipc_call_t call; 134 cap_call_handle_t c allid= async_get_call(&call);134 cap_call_handle_t chandle = async_get_call(&call); 135 135 sysarg_t method = IPC_GET_IMETHOD(call); 136 136 137 137 if (!method) { 138 138 /* The other side has hung up */ 139 async_answer_0(c allid, EOK);139 async_answer_0(chandle, EOK); 140 140 return; 141 141 } … … 143 143 switch (method) { 144 144 case DHCP_LINK_ADD: 145 dhcp_link_add_srv(c allid, &call);145 dhcp_link_add_srv(chandle, &call); 146 146 break; 147 147 case DHCP_LINK_REMOVE: 148 dhcp_link_remove_srv(c allid, &call);148 dhcp_link_remove_srv(chandle, &call); 149 149 break; 150 150 case DHCP_DISCOVER: 151 dhcp_discover_srv(c allid, &call);151 dhcp_discover_srv(chandle, &call); 152 152 break; 153 153 default: 154 async_answer_0(c allid, EINVAL);154 async_answer_0(chandle, EINVAL); 155 155 } 156 156 } -
uspace/srv/net/dnsrsrv/dnsrsrv.c
r3e242d2 ra46e56b 86 86 } 87 87 88 static void dnsr_name2host_srv(dnsr_client_t *client, cap_call_handle_t i id,88 static void dnsr_name2host_srv(dnsr_client_t *client, cap_call_handle_t icall_handle, 89 89 ipc_call_t *icall) 90 90 { … … 97 97 DNS_NAME_MAX_SIZE, 0, NULL); 98 98 if (rc != EOK) { 99 async_answer_0(i id, rc);99 async_answer_0(icall_handle, rc); 100 100 return; 101 101 } … … 104 104 rc = dns_name2host(name, &hinfo, ver); 105 105 if (rc != EOK) { 106 async_answer_0(i id, rc);107 return; 108 } 109 110 cap_call_handle_t c allid;106 async_answer_0(icall_handle, rc); 107 return; 108 } 109 110 cap_call_handle_t chandle; 111 111 size_t size; 112 if (!async_data_read_receive(&c allid, &size)) {113 async_answer_0(c allid, EREFUSED);114 async_answer_0(i id, EREFUSED);112 if (!async_data_read_receive(&chandle, &size)) { 113 async_answer_0(chandle, EREFUSED); 114 async_answer_0(icall_handle, EREFUSED); 115 115 return; 116 116 } 117 117 118 118 if (size != sizeof(inet_addr_t)) { 119 async_answer_0(c allid, EINVAL);120 async_answer_0(i id, EINVAL);121 return; 122 } 123 124 rc = async_data_read_finalize(c allid, &hinfo->addr, size);125 if (rc != EOK) { 126 async_answer_0(c allid, rc);127 async_answer_0(i id, rc);128 return; 129 } 130 131 if (!async_data_read_receive(&c allid, &size)) {132 async_answer_0(c allid, EREFUSED);133 async_answer_0(i id, EREFUSED);119 async_answer_0(chandle, EINVAL); 120 async_answer_0(icall_handle, EINVAL); 121 return; 122 } 123 124 rc = async_data_read_finalize(chandle, &hinfo->addr, size); 125 if (rc != EOK) { 126 async_answer_0(chandle, rc); 127 async_answer_0(icall_handle, rc); 128 return; 129 } 130 131 if (!async_data_read_receive(&chandle, &size)) { 132 async_answer_0(chandle, EREFUSED); 133 async_answer_0(icall_handle, EREFUSED); 134 134 return; 135 135 } … … 137 137 size_t act_size = str_size(hinfo->cname); 138 138 if (act_size > size) { 139 async_answer_0(c allid, EINVAL);140 async_answer_0(i id, EINVAL);141 return; 142 } 143 144 rc = async_data_read_finalize(c allid, hinfo->cname, act_size);139 async_answer_0(chandle, EINVAL); 140 async_answer_0(icall_handle, EINVAL); 141 return; 142 } 143 144 rc = async_data_read_finalize(chandle, hinfo->cname, act_size); 145 145 if (rc != EOK) 146 async_answer_0(c allid, rc);147 148 async_answer_0(i id, rc);146 async_answer_0(chandle, rc); 147 148 async_answer_0(icall_handle, rc); 149 149 150 150 dns_hostinfo_destroy(hinfo); 151 151 } 152 152 153 static void dnsr_get_srvaddr_srv(dnsr_client_t *client, cap_call_handle_t i id,153 static void dnsr_get_srvaddr_srv(dnsr_client_t *client, cap_call_handle_t icall_handle, 154 154 ipc_call_t *icall) 155 155 { 156 156 log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_get_srvaddr_srv()"); 157 157 158 cap_call_handle_t c allid;158 cap_call_handle_t chandle; 159 159 size_t size; 160 if (!async_data_read_receive(&c allid, &size)) {161 async_answer_0(c allid, EREFUSED);162 async_answer_0(i id, EREFUSED);160 if (!async_data_read_receive(&chandle, &size)) { 161 async_answer_0(chandle, EREFUSED); 162 async_answer_0(icall_handle, EREFUSED); 163 163 return; 164 164 } 165 165 166 166 if (size != sizeof(inet_addr_t)) { 167 async_answer_0(c allid, EINVAL);168 async_answer_0(i id, EINVAL);167 async_answer_0(chandle, EINVAL); 168 async_answer_0(icall_handle, EINVAL); 169 169 return; 170 170 } … … 172 172 // FIXME locking 173 173 174 errno_t rc = async_data_read_finalize(c allid, &dns_server_addr, size);174 errno_t rc = async_data_read_finalize(chandle, &dns_server_addr, size); 175 175 if (rc != EOK) 176 async_answer_0(c allid, rc);177 178 async_answer_0(i id, rc);179 } 180 181 static void dnsr_set_srvaddr_srv(dnsr_client_t *client, cap_call_handle_t i id,176 async_answer_0(chandle, rc); 177 178 async_answer_0(icall_handle, rc); 179 } 180 181 static void dnsr_set_srvaddr_srv(dnsr_client_t *client, cap_call_handle_t icall_handle, 182 182 ipc_call_t *icall) 183 183 { 184 184 log_msg(LOG_DEFAULT, LVL_DEBUG, "dnsr_set_srvaddr_srv()"); 185 185 186 cap_call_handle_t c allid;186 cap_call_handle_t chandle; 187 187 size_t size; 188 if (!async_data_write_receive(&c allid, &size)) {189 async_answer_0(c allid, EREFUSED);190 async_answer_0(i id, EREFUSED);188 if (!async_data_write_receive(&chandle, &size)) { 189 async_answer_0(chandle, EREFUSED); 190 async_answer_0(icall_handle, EREFUSED); 191 191 return; 192 192 } 193 193 194 194 if (size != sizeof(inet_addr_t)) { 195 async_answer_0(c allid, EINVAL);196 async_answer_0(i id, EINVAL);195 async_answer_0(chandle, EINVAL); 196 async_answer_0(icall_handle, EINVAL); 197 197 return; 198 198 } … … 200 200 // FIXME locking 201 201 202 errno_t rc = async_data_write_finalize(c allid, &dns_server_addr, size);203 if (rc != EOK) { 204 async_answer_0(c allid, rc);205 async_answer_0(i id, rc);206 } 207 208 async_answer_0(i id, rc);209 } 210 211 static void dnsr_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)202 errno_t rc = async_data_write_finalize(chandle, &dns_server_addr, size); 203 if (rc != EOK) { 204 async_answer_0(chandle, rc); 205 async_answer_0(icall_handle, rc); 206 } 207 208 async_answer_0(icall_handle, rc); 209 } 210 211 static void dnsr_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 212 212 { 213 213 dnsr_client_t client; … … 216 216 217 217 /* Accept the connection */ 218 async_answer_0(i id, EOK);218 async_answer_0(icall_handle, EOK); 219 219 220 220 while (true) { 221 221 ipc_call_t call; 222 cap_call_handle_t c allid= async_get_call(&call);222 cap_call_handle_t chandle = async_get_call(&call); 223 223 sysarg_t method = IPC_GET_IMETHOD(call); 224 224 225 225 if (!method) { 226 226 /* The other side has hung up */ 227 async_answer_0(c allid, EOK);227 async_answer_0(chandle, EOK); 228 228 return; 229 229 } … … 231 231 switch (method) { 232 232 case DNSR_NAME2HOST: 233 dnsr_name2host_srv(&client, c allid, &call);233 dnsr_name2host_srv(&client, chandle, &call); 234 234 break; 235 235 case DNSR_GET_SRVADDR: 236 dnsr_get_srvaddr_srv(&client, c allid, &call);236 dnsr_get_srvaddr_srv(&client, chandle, &call); 237 237 break; 238 238 case DNSR_SET_SRVADDR: 239 dnsr_set_srvaddr_srv(&client, c allid, &call);239 dnsr_set_srvaddr_srv(&client, chandle, &call); 240 240 break; 241 241 default: 242 async_answer_0(c allid, EINVAL);242 async_answer_0(chandle, EINVAL); 243 243 } 244 244 } -
uspace/srv/net/ethip/ethip.c
r3e242d2 ra46e56b 63 63 static errno_t ethip_addr_remove(iplink_srv_t *srv, inet_addr_t *addr); 64 64 65 static void ethip_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg);65 static void ethip_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg); 66 66 67 67 static iplink_ops_t ethip_iplink_ops = { … … 142 142 } 143 143 144 static void ethip_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)144 static void ethip_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 145 145 { 146 146 ethip_nic_t *nic; … … 155 155 } 156 156 157 iplink_conn(i id, icall, &nic->iplink);157 iplink_conn(icall_handle, icall, &nic->iplink); 158 158 } 159 159 -
uspace/srv/net/ethip/ethip_nic.c
r3e242d2 ra46e56b 52 52 53 53 static errno_t ethip_nic_open(service_id_t sid); 54 static void ethip_nic_cb_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg);54 static void ethip_nic_cb_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg); 55 55 56 56 static LIST_INITIALIZE(ethip_nic_list); … … 229 229 } 230 230 231 static void ethip_nic_addr_changed(ethip_nic_t *nic, cap_call_handle_t c allid,231 static void ethip_nic_addr_changed(ethip_nic_t *nic, cap_call_handle_t chandle, 232 232 ipc_call_t *call) 233 233 { … … 255 255 256 256 free(addr); 257 async_answer_0(c allid, EOK);258 } 259 260 static void ethip_nic_received(ethip_nic_t *nic, cap_call_handle_t c allid,257 async_answer_0(chandle, EOK); 258 } 259 260 static void ethip_nic_received(ethip_nic_t *nic, cap_call_handle_t chandle, 261 261 ipc_call_t *call) 262 262 { … … 282 282 283 283 log_msg(LOG_DEFAULT, LVL_DEBUG, "ethip_nic_received() done, rc=%s", str_error_name(rc)); 284 async_answer_0(c allid, rc);285 } 286 287 static void ethip_nic_device_state(ethip_nic_t *nic, cap_call_handle_t c allid,284 async_answer_0(chandle, rc); 285 } 286 287 static void ethip_nic_device_state(ethip_nic_t *nic, cap_call_handle_t chandle, 288 288 ipc_call_t *call) 289 289 { 290 290 log_msg(LOG_DEFAULT, LVL_DEBUG, "ethip_nic_device_state()"); 291 async_answer_0(c allid, ENOTSUP);292 } 293 294 static void ethip_nic_cb_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)291 async_answer_0(chandle, ENOTSUP); 292 } 293 294 static void ethip_nic_cb_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 295 295 { 296 296 ethip_nic_t *nic = (ethip_nic_t *)arg; … … 300 300 while (true) { 301 301 ipc_call_t call; 302 cap_call_handle_t c allid= async_get_call(&call);302 cap_call_handle_t chandle = async_get_call(&call); 303 303 304 304 if (!IPC_GET_IMETHOD(call)) { … … 309 309 switch (IPC_GET_IMETHOD(call)) { 310 310 case NIC_EV_ADDR_CHANGED: 311 ethip_nic_addr_changed(nic, c allid, &call);311 ethip_nic_addr_changed(nic, chandle, &call); 312 312 break; 313 313 case NIC_EV_RECEIVED: 314 ethip_nic_received(nic, c allid, &call);314 ethip_nic_received(nic, chandle, &call); 315 315 break; 316 316 case NIC_EV_DEVICE_STATE: 317 ethip_nic_device_state(nic, c allid, &call);317 ethip_nic_device_state(nic, chandle, &call); 318 318 break; 319 319 default: 320 320 log_msg(LOG_DEFAULT, LVL_DEBUG, "unknown IPC method: %" PRIun, IPC_GET_IMETHOD(call)); 321 async_answer_0(c allid, ENOTSUP);321 async_answer_0(chandle, ENOTSUP); 322 322 } 323 323 } -
uspace/srv/net/inetsrv/inetcfg.c
r3e242d2 ra46e56b 253 253 } 254 254 255 static void inetcfg_addr_create_static_srv(cap_call_handle_t i id,255 static void inetcfg_addr_create_static_srv(cap_call_handle_t icall_handle, 256 256 ipc_call_t *icall) 257 257 { … … 260 260 sysarg_t link_id = IPC_GET_ARG1(*icall); 261 261 262 cap_call_handle_t c allid;262 cap_call_handle_t chandle; 263 263 size_t size; 264 if (!async_data_write_receive(&c allid, &size)) {265 async_answer_0(c allid, EINVAL);266 async_answer_0(i id, EINVAL);264 if (!async_data_write_receive(&chandle, &size)) { 265 async_answer_0(chandle, EINVAL); 266 async_answer_0(icall_handle, EINVAL); 267 267 return; 268 268 } 269 269 270 270 if (size != sizeof(inet_naddr_t)) { 271 async_answer_0(c allid, EINVAL);272 async_answer_0(i id, EINVAL);271 async_answer_0(chandle, EINVAL); 272 async_answer_0(icall_handle, EINVAL); 273 273 return; 274 274 } 275 275 276 276 inet_naddr_t naddr; 277 errno_t rc = async_data_write_finalize(c allid, &naddr, size);278 if (rc != EOK) { 279 async_answer_0(c allid, rc);280 async_answer_0(i id, rc);277 errno_t rc = async_data_write_finalize(chandle, &naddr, size); 278 if (rc != EOK) { 279 async_answer_0(chandle, rc); 280 async_answer_0(icall_handle, rc); 281 281 return; 282 282 } … … 286 286 0, NULL); 287 287 if (rc != EOK) { 288 async_answer_0(i id, rc);288 async_answer_0(icall_handle, rc); 289 289 return; 290 290 } … … 293 293 rc = inetcfg_addr_create_static(name, &naddr, link_id, &addr_id); 294 294 free(name); 295 async_answer_1(i id, rc, addr_id);296 } 297 298 static void inetcfg_addr_delete_srv(cap_call_handle_t c allid, ipc_call_t *call)295 async_answer_1(icall_handle, rc, addr_id); 296 } 297 298 static void inetcfg_addr_delete_srv(cap_call_handle_t chandle, ipc_call_t *call) 299 299 { 300 300 sysarg_t addr_id; … … 306 306 307 307 rc = inetcfg_addr_delete(addr_id); 308 async_answer_0(c allid, rc);309 } 310 311 static void inetcfg_addr_get_srv(cap_call_handle_t i id, ipc_call_t *icall)308 async_answer_0(chandle, rc); 309 } 310 311 static void inetcfg_addr_get_srv(cap_call_handle_t icall_handle, ipc_call_t *icall) 312 312 { 313 313 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_addr_get_srv()"); … … 323 323 errno_t rc = inetcfg_addr_get(addr_id, &ainfo); 324 324 if (rc != EOK) { 325 async_answer_0(i id, rc);326 return; 327 } 328 329 cap_call_handle_t c allid;325 async_answer_0(icall_handle, rc); 326 return; 327 } 328 329 cap_call_handle_t chandle; 330 330 size_t size; 331 if (!async_data_read_receive(&c allid, &size)) {332 async_answer_0(c allid, EREFUSED);333 async_answer_0(i id, EREFUSED);331 if (!async_data_read_receive(&chandle, &size)) { 332 async_answer_0(chandle, EREFUSED); 333 async_answer_0(icall_handle, EREFUSED); 334 334 return; 335 335 } 336 336 337 337 if (size != sizeof(inet_naddr_t)) { 338 async_answer_0(c allid, EINVAL);339 async_answer_0(i id, EINVAL);340 return; 341 } 342 343 rc = async_data_read_finalize(c allid, &ainfo.naddr, size);344 if (rc != EOK) { 345 async_answer_0(c allid, rc);346 async_answer_0(i id, rc);347 return; 348 } 349 350 if (!async_data_read_receive(&c allid, &size)) {351 async_answer_0(c allid, EREFUSED);352 async_answer_0(i id, EREFUSED);353 return; 354 } 355 356 rc = async_data_read_finalize(c allid, ainfo.name,338 async_answer_0(chandle, EINVAL); 339 async_answer_0(icall_handle, EINVAL); 340 return; 341 } 342 343 rc = async_data_read_finalize(chandle, &ainfo.naddr, size); 344 if (rc != EOK) { 345 async_answer_0(chandle, rc); 346 async_answer_0(icall_handle, rc); 347 return; 348 } 349 350 if (!async_data_read_receive(&chandle, &size)) { 351 async_answer_0(chandle, EREFUSED); 352 async_answer_0(icall_handle, EREFUSED); 353 return; 354 } 355 356 rc = async_data_read_finalize(chandle, ainfo.name, 357 357 min(size, str_size(ainfo.name))); 358 358 free(ainfo.name); 359 359 360 360 if (rc != EOK) { 361 async_answer_0(c allid, rc);362 async_answer_0(i id, rc);363 return; 364 } 365 366 async_answer_1(i id, rc, ainfo.ilink);367 } 368 369 static void inetcfg_addr_get_id_srv(cap_call_handle_t c allid, ipc_call_t *call)361 async_answer_0(chandle, rc); 362 async_answer_0(icall_handle, rc); 363 return; 364 } 365 366 async_answer_1(icall_handle, rc, ainfo.ilink); 367 } 368 369 static void inetcfg_addr_get_id_srv(cap_call_handle_t chandle, ipc_call_t *call) 370 370 { 371 371 char *name; … … 381 381 0, NULL); 382 382 if (rc != EOK) { 383 async_answer_0(c allid, rc);383 async_answer_0(chandle, rc); 384 384 return; 385 385 } … … 388 388 rc = inetcfg_addr_get_id(name, link_id, &addr_id); 389 389 free(name); 390 async_answer_1(c allid, rc, addr_id);391 } 392 393 static void inetcfg_get_addr_list_srv(cap_call_handle_t c allid, ipc_call_t *call)394 { 395 cap_call_handle_t rcall id;390 async_answer_1(chandle, rc, addr_id); 391 } 392 393 static void inetcfg_get_addr_list_srv(cap_call_handle_t chandle, ipc_call_t *call) 394 { 395 cap_call_handle_t rcall_handle; 396 396 size_t count; 397 397 size_t max_size; … … 403 403 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_get_addr_list_srv()"); 404 404 405 if (!async_data_read_receive(&rcall id, &max_size)) {406 async_answer_0(rcall id, EREFUSED);407 async_answer_0(c allid, EREFUSED);405 if (!async_data_read_receive(&rcall_handle, &max_size)) { 406 async_answer_0(rcall_handle, EREFUSED); 407 async_answer_0(chandle, EREFUSED); 408 408 return; 409 409 } … … 411 411 rc = inetcfg_get_addr_list(&id_buf, &count); 412 412 if (rc != EOK) { 413 async_answer_0(rcall id, rc);414 async_answer_0(c allid, rc);413 async_answer_0(rcall_handle, rc); 414 async_answer_0(chandle, rc); 415 415 return; 416 416 } … … 419 419 size = min(act_size, max_size); 420 420 421 errno_t retval = async_data_read_finalize(rcall id, id_buf, size);421 errno_t retval = async_data_read_finalize(rcall_handle, id_buf, size); 422 422 free(id_buf); 423 423 424 async_answer_1(c allid, retval, act_size);425 } 426 427 static void inetcfg_get_link_list_srv(cap_call_handle_t c allid, ipc_call_t *call)428 { 429 cap_call_handle_t rcall id;424 async_answer_1(chandle, retval, act_size); 425 } 426 427 static void inetcfg_get_link_list_srv(cap_call_handle_t chandle, ipc_call_t *call) 428 { 429 cap_call_handle_t rcall_handle; 430 430 size_t count; 431 431 size_t max_size; … … 437 437 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_get_addr_list_srv()"); 438 438 439 if (!async_data_read_receive(&rcall id, &max_size)) {440 async_answer_0(rcall id, EREFUSED);441 async_answer_0(c allid, EREFUSED);439 if (!async_data_read_receive(&rcall_handle, &max_size)) { 440 async_answer_0(rcall_handle, EREFUSED); 441 async_answer_0(chandle, EREFUSED); 442 442 return; 443 443 } … … 445 445 rc = inetcfg_get_link_list(&id_buf, &count); 446 446 if (rc != EOK) { 447 async_answer_0(rcall id, rc);448 async_answer_0(c allid, rc);447 async_answer_0(rcall_handle, rc); 448 async_answer_0(chandle, rc); 449 449 return; 450 450 } … … 453 453 size = min(act_size, max_size); 454 454 455 errno_t retval = async_data_read_finalize(rcall id, id_buf, size);455 errno_t retval = async_data_read_finalize(rcall_handle, id_buf, size); 456 456 free(id_buf); 457 457 458 async_answer_1(c allid, retval, act_size);459 } 460 461 static void inetcfg_get_sroute_list_srv(cap_call_handle_t c allid, ipc_call_t *call)462 { 463 cap_call_handle_t rcall id;458 async_answer_1(chandle, retval, act_size); 459 } 460 461 static void inetcfg_get_sroute_list_srv(cap_call_handle_t chandle, ipc_call_t *call) 462 { 463 cap_call_handle_t rcall_handle; 464 464 size_t count; 465 465 size_t max_size; … … 471 471 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_get_sroute_list_srv()"); 472 472 473 if (!async_data_read_receive(&rcall id, &max_size)) {474 async_answer_0(rcall id, EREFUSED);475 async_answer_0(c allid, EREFUSED);473 if (!async_data_read_receive(&rcall_handle, &max_size)) { 474 async_answer_0(rcall_handle, EREFUSED); 475 async_answer_0(chandle, EREFUSED); 476 476 return; 477 477 } … … 479 479 rc = inetcfg_get_sroute_list(&id_buf, &count); 480 480 if (rc != EOK) { 481 async_answer_0(rcall id, rc);482 async_answer_0(c allid, rc);481 async_answer_0(rcall_handle, rc); 482 async_answer_0(chandle, rc); 483 483 return; 484 484 } … … 487 487 size = min(act_size, max_size); 488 488 489 errno_t retval = async_data_read_finalize(rcall id, id_buf, size);489 errno_t retval = async_data_read_finalize(rcall_handle, id_buf, size); 490 490 free(id_buf); 491 491 492 async_answer_1(c allid, retval, act_size);493 } 494 495 static void inetcfg_link_add_srv(cap_call_handle_t c allid, ipc_call_t *call)492 async_answer_1(chandle, retval, act_size); 493 } 494 495 static void inetcfg_link_add_srv(cap_call_handle_t chandle, ipc_call_t *call) 496 496 { 497 497 sysarg_t link_id; … … 503 503 504 504 rc = inetcfg_link_add(link_id); 505 async_answer_0(c allid, rc);506 } 507 508 static void inetcfg_link_get_srv(cap_call_handle_t c allid, ipc_call_t *call)509 { 510 cap_call_handle_t name_c allid;511 cap_call_handle_t laddr_c allid;505 async_answer_0(chandle, rc); 506 } 507 508 static void inetcfg_link_get_srv(cap_call_handle_t chandle, ipc_call_t *call) 509 { 510 cap_call_handle_t name_chandle; 511 cap_call_handle_t laddr_chandle; 512 512 size_t name_max_size; 513 513 size_t laddr_max_size; … … 522 522 linfo.name = NULL; 523 523 524 if (!async_data_read_receive(&name_c allid, &name_max_size)) {525 async_answer_0(name_c allid, EREFUSED);526 async_answer_0(c allid, EREFUSED);527 return; 528 } 529 530 if (!async_data_read_receive(&laddr_c allid, &laddr_max_size)) {531 async_answer_0(name_c allid, EREFUSED);532 async_answer_0(c allid, EREFUSED);524 if (!async_data_read_receive(&name_chandle, &name_max_size)) { 525 async_answer_0(name_chandle, EREFUSED); 526 async_answer_0(chandle, EREFUSED); 527 return; 528 } 529 530 if (!async_data_read_receive(&laddr_chandle, &laddr_max_size)) { 531 async_answer_0(name_chandle, EREFUSED); 532 async_answer_0(chandle, EREFUSED); 533 533 return; 534 534 } … … 536 536 rc = inetcfg_link_get(link_id, &linfo); 537 537 if (rc != EOK) { 538 async_answer_0(laddr_c allid, rc);539 async_answer_0(name_c allid, rc);540 async_answer_0(c allid, rc);541 return; 542 } 543 544 errno_t retval = async_data_read_finalize(name_c allid, linfo.name,538 async_answer_0(laddr_chandle, rc); 539 async_answer_0(name_chandle, rc); 540 async_answer_0(chandle, rc); 541 return; 542 } 543 544 errno_t retval = async_data_read_finalize(name_chandle, linfo.name, 545 545 min(name_max_size, str_size(linfo.name))); 546 546 if (retval != EOK) { 547 547 free(linfo.name); 548 async_answer_0(laddr_c allid, retval);549 async_answer_0(c allid, retval);550 return; 551 } 552 553 retval = async_data_read_finalize(laddr_c allid, &linfo.mac_addr,548 async_answer_0(laddr_chandle, retval); 549 async_answer_0(chandle, retval); 550 return; 551 } 552 553 retval = async_data_read_finalize(laddr_chandle, &linfo.mac_addr, 554 554 min(laddr_max_size, sizeof(linfo.mac_addr))); 555 555 556 556 free(linfo.name); 557 557 558 async_answer_1(c allid, retval, linfo.def_mtu);559 } 560 561 static void inetcfg_link_remove_srv(cap_call_handle_t c allid, ipc_call_t *call)558 async_answer_1(chandle, retval, linfo.def_mtu); 559 } 560 561 static void inetcfg_link_remove_srv(cap_call_handle_t chandle, ipc_call_t *call) 562 562 { 563 563 sysarg_t link_id; … … 569 569 570 570 rc = inetcfg_link_remove(link_id); 571 async_answer_0(c allid, rc);572 } 573 574 static void inetcfg_sroute_create_srv(cap_call_handle_t i id,571 async_answer_0(chandle, rc); 572 } 573 574 static void inetcfg_sroute_create_srv(cap_call_handle_t icall_handle, 575 575 ipc_call_t *icall) 576 576 { 577 577 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_sroute_create_srv()"); 578 578 579 cap_call_handle_t c allid;579 cap_call_handle_t chandle; 580 580 size_t size; 581 if (!async_data_write_receive(&c allid, &size)) {582 async_answer_0(c allid, EINVAL);583 async_answer_0(i id, EINVAL);581 if (!async_data_write_receive(&chandle, &size)) { 582 async_answer_0(chandle, EINVAL); 583 async_answer_0(icall_handle, EINVAL); 584 584 return; 585 585 } 586 586 587 587 if (size != sizeof(inet_naddr_t)) { 588 async_answer_0(c allid, EINVAL);589 async_answer_0(i id, EINVAL);588 async_answer_0(chandle, EINVAL); 589 async_answer_0(icall_handle, EINVAL); 590 590 return; 591 591 } 592 592 593 593 inet_naddr_t dest; 594 errno_t rc = async_data_write_finalize(c allid, &dest, size);595 if (rc != EOK) { 596 async_answer_0(c allid, rc);597 async_answer_0(i id, rc);598 return; 599 } 600 601 if (!async_data_write_receive(&c allid, &size)) {602 async_answer_0(c allid, EINVAL);603 async_answer_0(i id, EINVAL);594 errno_t rc = async_data_write_finalize(chandle, &dest, size); 595 if (rc != EOK) { 596 async_answer_0(chandle, rc); 597 async_answer_0(icall_handle, rc); 598 return; 599 } 600 601 if (!async_data_write_receive(&chandle, &size)) { 602 async_answer_0(chandle, EINVAL); 603 async_answer_0(icall_handle, EINVAL); 604 604 return; 605 605 } 606 606 607 607 if (size != sizeof(inet_addr_t)) { 608 async_answer_0(c allid, EINVAL);609 async_answer_0(i id, EINVAL);608 async_answer_0(chandle, EINVAL); 609 async_answer_0(icall_handle, EINVAL); 610 610 return; 611 611 } 612 612 613 613 inet_addr_t router; 614 rc = async_data_write_finalize(c allid, &router, size);615 if (rc != EOK) { 616 async_answer_0(c allid, rc);617 async_answer_0(i id, rc);614 rc = async_data_write_finalize(chandle, &router, size); 615 if (rc != EOK) { 616 async_answer_0(chandle, rc); 617 async_answer_0(icall_handle, rc); 618 618 return; 619 619 } … … 623 623 0, NULL); 624 624 if (rc != EOK) { 625 async_answer_0(i id, rc);625 async_answer_0(icall_handle, rc); 626 626 return; 627 627 } … … 630 630 rc = inetcfg_sroute_create(name, &dest, &router, &sroute_id); 631 631 free(name); 632 async_answer_1(i id, rc, sroute_id);633 } 634 635 static void inetcfg_sroute_delete_srv(cap_call_handle_t c allid, ipc_call_t *call)632 async_answer_1(icall_handle, rc, sroute_id); 633 } 634 635 static void inetcfg_sroute_delete_srv(cap_call_handle_t chandle, ipc_call_t *call) 636 636 { 637 637 sysarg_t sroute_id; … … 643 643 644 644 rc = inetcfg_sroute_delete(sroute_id); 645 async_answer_0(c allid, rc);646 } 647 648 static void inetcfg_sroute_get_srv(cap_call_handle_t i id, ipc_call_t *icall)645 async_answer_0(chandle, rc); 646 } 647 648 static void inetcfg_sroute_get_srv(cap_call_handle_t icall_handle, ipc_call_t *icall) 649 649 { 650 650 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetcfg_sroute_get_srv()"); … … 660 660 errno_t rc = inetcfg_sroute_get(sroute_id, &srinfo); 661 661 if (rc != EOK) { 662 async_answer_0(i id, rc);663 return; 664 } 665 666 cap_call_handle_t c allid;662 async_answer_0(icall_handle, rc); 663 return; 664 } 665 666 cap_call_handle_t chandle; 667 667 size_t size; 668 if (!async_data_read_receive(&c allid, &size)) {669 async_answer_0(c allid, EREFUSED);670 async_answer_0(i id, EREFUSED);668 if (!async_data_read_receive(&chandle, &size)) { 669 async_answer_0(chandle, EREFUSED); 670 async_answer_0(icall_handle, EREFUSED); 671 671 return; 672 672 } 673 673 674 674 if (size != sizeof(inet_naddr_t)) { 675 async_answer_0(c allid, EINVAL);676 async_answer_0(i id, EINVAL);677 return; 678 } 679 680 rc = async_data_read_finalize(c allid, &srinfo.dest, size);681 if (rc != EOK) { 682 async_answer_0(c allid, rc);683 async_answer_0(i id, rc);684 return; 685 } 686 687 if (!async_data_read_receive(&c allid, &size)) {688 async_answer_0(c allid, EREFUSED);689 async_answer_0(i id, EREFUSED);675 async_answer_0(chandle, EINVAL); 676 async_answer_0(icall_handle, EINVAL); 677 return; 678 } 679 680 rc = async_data_read_finalize(chandle, &srinfo.dest, size); 681 if (rc != EOK) { 682 async_answer_0(chandle, rc); 683 async_answer_0(icall_handle, rc); 684 return; 685 } 686 687 if (!async_data_read_receive(&chandle, &size)) { 688 async_answer_0(chandle, EREFUSED); 689 async_answer_0(icall_handle, EREFUSED); 690 690 return; 691 691 } 692 692 693 693 if (size != sizeof(inet_addr_t)) { 694 async_answer_0(c allid, EINVAL);695 async_answer_0(i id, EINVAL);696 return; 697 } 698 699 rc = async_data_read_finalize(c allid, &srinfo.router, size);700 if (rc != EOK) { 701 async_answer_0(c allid, rc);702 async_answer_0(i id, rc);703 return; 704 } 705 706 if (!async_data_read_receive(&c allid, &size)) {707 async_answer_0(c allid, EREFUSED);708 async_answer_0(i id, EREFUSED);709 return; 710 } 711 712 rc = async_data_read_finalize(c allid, srinfo.name,694 async_answer_0(chandle, EINVAL); 695 async_answer_0(icall_handle, EINVAL); 696 return; 697 } 698 699 rc = async_data_read_finalize(chandle, &srinfo.router, size); 700 if (rc != EOK) { 701 async_answer_0(chandle, rc); 702 async_answer_0(icall_handle, rc); 703 return; 704 } 705 706 if (!async_data_read_receive(&chandle, &size)) { 707 async_answer_0(chandle, EREFUSED); 708 async_answer_0(icall_handle, EREFUSED); 709 return; 710 } 711 712 rc = async_data_read_finalize(chandle, srinfo.name, 713 713 min(size, str_size(srinfo.name))); 714 714 free(srinfo.name); 715 715 716 async_answer_0(i id, rc);717 } 718 719 static void inetcfg_sroute_get_id_srv(cap_call_handle_t c allid, ipc_call_t *call)716 async_answer_0(icall_handle, rc); 717 } 718 719 static void inetcfg_sroute_get_id_srv(cap_call_handle_t chandle, ipc_call_t *call) 720 720 { 721 721 char *name; … … 728 728 0, NULL); 729 729 if (rc != EOK) { 730 async_answer_0(c allid, rc);730 async_answer_0(chandle, rc); 731 731 return; 732 732 } … … 735 735 rc = inetcfg_sroute_get_id(name, &sroute_id); 736 736 free(name); 737 async_answer_1(c allid, rc, sroute_id);738 } 739 740 void inet_cfg_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)737 async_answer_1(chandle, rc, sroute_id); 738 } 739 740 void inet_cfg_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 741 741 { 742 742 log_msg(LOG_DEFAULT, LVL_DEBUG, "inet_cfg_conn()"); 743 743 744 744 /* Accept the connection */ 745 async_answer_0(i id, EOK);745 async_answer_0(icall_handle, EOK); 746 746 747 747 while (true) { 748 748 ipc_call_t call; 749 cap_call_handle_t c allid= async_get_call(&call);749 cap_call_handle_t chandle = async_get_call(&call); 750 750 sysarg_t method = IPC_GET_IMETHOD(call); 751 751 … … 753 753 if (!method) { 754 754 /* The other side has hung up */ 755 async_answer_0(c allid, EOK);755 async_answer_0(chandle, EOK); 756 756 return; 757 757 } … … 759 759 switch (method) { 760 760 case INETCFG_ADDR_CREATE_STATIC: 761 inetcfg_addr_create_static_srv(c allid, &call);761 inetcfg_addr_create_static_srv(chandle, &call); 762 762 break; 763 763 case INETCFG_ADDR_DELETE: 764 inetcfg_addr_delete_srv(c allid, &call);764 inetcfg_addr_delete_srv(chandle, &call); 765 765 break; 766 766 case INETCFG_ADDR_GET: 767 inetcfg_addr_get_srv(c allid, &call);767 inetcfg_addr_get_srv(chandle, &call); 768 768 break; 769 769 case INETCFG_ADDR_GET_ID: 770 inetcfg_addr_get_id_srv(c allid, &call);770 inetcfg_addr_get_id_srv(chandle, &call); 771 771 break; 772 772 case INETCFG_GET_ADDR_LIST: 773 inetcfg_get_addr_list_srv(c allid, &call);773 inetcfg_get_addr_list_srv(chandle, &call); 774 774 break; 775 775 case INETCFG_GET_LINK_LIST: 776 inetcfg_get_link_list_srv(c allid, &call);776 inetcfg_get_link_list_srv(chandle, &call); 777 777 break; 778 778 case INETCFG_GET_SROUTE_LIST: 779 inetcfg_get_sroute_list_srv(c allid, &call);779 inetcfg_get_sroute_list_srv(chandle, &call); 780 780 break; 781 781 case INETCFG_LINK_ADD: 782 inetcfg_link_add_srv(c allid, &call);782 inetcfg_link_add_srv(chandle, &call); 783 783 break; 784 784 case INETCFG_LINK_GET: 785 inetcfg_link_get_srv(c allid, &call);785 inetcfg_link_get_srv(chandle, &call); 786 786 break; 787 787 case INETCFG_LINK_REMOVE: 788 inetcfg_link_remove_srv(c allid, &call);788 inetcfg_link_remove_srv(chandle, &call); 789 789 break; 790 790 case INETCFG_SROUTE_CREATE: 791 inetcfg_sroute_create_srv(c allid, &call);791 inetcfg_sroute_create_srv(chandle, &call); 792 792 break; 793 793 case INETCFG_SROUTE_DELETE: 794 inetcfg_sroute_delete_srv(c allid, &call);794 inetcfg_sroute_delete_srv(chandle, &call); 795 795 break; 796 796 case INETCFG_SROUTE_GET: 797 inetcfg_sroute_get_srv(c allid, &call);797 inetcfg_sroute_get_srv(chandle, &call); 798 798 break; 799 799 case INETCFG_SROUTE_GET_ID: 800 inetcfg_sroute_get_id_srv(c allid, &call);800 inetcfg_sroute_get_id_srv(chandle, &call); 801 801 break; 802 802 default: 803 async_answer_0(c allid, EINVAL);803 async_answer_0(chandle, EINVAL); 804 804 } 805 805 } -
uspace/srv/net/inetsrv/inetping.c
r3e242d2 ra46e56b 136 136 } 137 137 138 static void inetping_send_srv(inetping_client_t *client, cap_call_handle_t i id,138 static void inetping_send_srv(inetping_client_t *client, cap_call_handle_t icall_handle, 139 139 ipc_call_t *icall) 140 140 { … … 146 146 sdu.seq_no = IPC_GET_ARG1(*icall); 147 147 148 cap_call_handle_t c allid;148 cap_call_handle_t chandle; 149 149 size_t size; 150 if (!async_data_write_receive(&c allid, &size)) {151 async_answer_0(c allid, EREFUSED);152 async_answer_0(i id, EREFUSED);150 if (!async_data_write_receive(&chandle, &size)) { 151 async_answer_0(chandle, EREFUSED); 152 async_answer_0(icall_handle, EREFUSED); 153 153 return; 154 154 } 155 155 156 156 if (size != sizeof(sdu.src)) { 157 async_answer_0(c allid, EINVAL);158 async_answer_0(i id, EINVAL);159 return; 160 } 161 162 rc = async_data_write_finalize(c allid, &sdu.src, size);163 if (rc != EOK) { 164 async_answer_0(c allid, rc);165 async_answer_0(i id, rc);166 return; 167 } 168 169 if (!async_data_write_receive(&c allid, &size)) {170 async_answer_0(c allid, EREFUSED);171 async_answer_0(i id, EREFUSED);157 async_answer_0(chandle, EINVAL); 158 async_answer_0(icall_handle, EINVAL); 159 return; 160 } 161 162 rc = async_data_write_finalize(chandle, &sdu.src, size); 163 if (rc != EOK) { 164 async_answer_0(chandle, rc); 165 async_answer_0(icall_handle, rc); 166 return; 167 } 168 169 if (!async_data_write_receive(&chandle, &size)) { 170 async_answer_0(chandle, EREFUSED); 171 async_answer_0(icall_handle, EREFUSED); 172 172 return; 173 173 } 174 174 175 175 if (size != sizeof(sdu.dest)) { 176 async_answer_0(c allid, EINVAL);177 async_answer_0(i id, EINVAL);178 return; 179 } 180 181 rc = async_data_write_finalize(c allid, &sdu.dest, size);182 if (rc != EOK) { 183 async_answer_0(c allid, rc);184 async_answer_0(i id, rc);176 async_answer_0(chandle, EINVAL); 177 async_answer_0(icall_handle, EINVAL); 178 return; 179 } 180 181 rc = async_data_write_finalize(chandle, &sdu.dest, size); 182 if (rc != EOK) { 183 async_answer_0(chandle, rc); 184 async_answer_0(icall_handle, rc); 185 185 return; 186 186 } … … 189 189 &sdu.size); 190 190 if (rc != EOK) { 191 async_answer_0(i id, rc);191 async_answer_0(icall_handle, rc); 192 192 return; 193 193 } … … 196 196 free(sdu.data); 197 197 198 async_answer_0(i id, rc);198 async_answer_0(icall_handle, rc); 199 199 } 200 200 201 201 static void inetping_get_srcaddr_srv(inetping_client_t *client, 202 cap_call_handle_t i id, ipc_call_t *icall)202 cap_call_handle_t icall_handle, ipc_call_t *icall) 203 203 { 204 204 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetping_get_srcaddr_srv()"); 205 205 206 cap_call_handle_t c allid;206 cap_call_handle_t chandle; 207 207 size_t size; 208 208 … … 210 210 inet_addr_t remote; 211 211 212 if (!async_data_write_receive(&c allid, &size)) {213 async_answer_0(c allid, EREFUSED);214 async_answer_0(i id, EREFUSED);212 if (!async_data_write_receive(&chandle, &size)) { 213 async_answer_0(chandle, EREFUSED); 214 async_answer_0(icall_handle, EREFUSED); 215 215 return; 216 216 } 217 217 218 218 if (size != sizeof(remote)) { 219 async_answer_0(c allid, EINVAL);220 async_answer_0(i id, EINVAL);221 return; 222 } 223 224 errno_t rc = async_data_write_finalize(c allid, &remote, size);225 if (rc != EOK) { 226 async_answer_0(c allid, rc);227 async_answer_0(i id, rc);219 async_answer_0(chandle, EINVAL); 220 async_answer_0(icall_handle, EINVAL); 221 return; 222 } 223 224 errno_t rc = async_data_write_finalize(chandle, &remote, size); 225 if (rc != EOK) { 226 async_answer_0(chandle, rc); 227 async_answer_0(icall_handle, rc); 228 228 return; 229 229 } … … 231 231 rc = inetping_get_srcaddr(client, &remote, &local); 232 232 if (rc != EOK) { 233 async_answer_0(i id, rc);234 return; 235 } 236 237 if (!async_data_read_receive(&c allid, &size)) {238 async_answer_0(c allid, EREFUSED);239 async_answer_0(i id, EREFUSED);233 async_answer_0(icall_handle, rc); 234 return; 235 } 236 237 if (!async_data_read_receive(&chandle, &size)) { 238 async_answer_0(chandle, EREFUSED); 239 async_answer_0(icall_handle, EREFUSED); 240 240 return; 241 241 } 242 242 243 243 if (size != sizeof(local)) { 244 async_answer_0(c allid, EINVAL);245 async_answer_0(i id, EINVAL);246 return; 247 } 248 249 rc = async_data_read_finalize(c allid, &local, size);244 async_answer_0(chandle, EINVAL); 245 async_answer_0(icall_handle, EINVAL); 246 return; 247 } 248 249 rc = async_data_read_finalize(chandle, &local, size); 250 250 if (rc != EOK) 251 async_answer_0(c allid, rc);252 253 async_answer_0(i id, rc);251 async_answer_0(chandle, rc); 252 253 async_answer_0(icall_handle, rc); 254 254 } 255 255 … … 281 281 } 282 282 283 void inetping_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)283 void inetping_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 284 284 { 285 285 log_msg(LOG_DEFAULT, LVL_DEBUG, "inetping_conn()"); 286 286 287 287 /* Accept the connection */ 288 async_answer_0(i id, EOK);288 async_answer_0(icall_handle, EOK); 289 289 290 290 inetping_client_t client; … … 295 295 while (true) { 296 296 ipc_call_t call; 297 cap_call_handle_t c allid= async_get_call(&call);297 cap_call_handle_t chandle = async_get_call(&call); 298 298 sysarg_t method = IPC_GET_IMETHOD(call); 299 299 300 300 if (!method) { 301 301 /* The other side has hung up */ 302 async_answer_0(c allid, EOK);302 async_answer_0(chandle, EOK); 303 303 break; 304 304 } … … 306 306 switch (method) { 307 307 case INETPING_SEND: 308 inetping_send_srv(&client, c allid, &call);308 inetping_send_srv(&client, chandle, &call); 309 309 break; 310 310 case INETPING_GET_SRCADDR: 311 inetping_get_srcaddr_srv(&client, c allid, &call);311 inetping_get_srcaddr_srv(&client, chandle, &call); 312 312 break; 313 313 default: 314 async_answer_0(c allid, EINVAL);314 async_answer_0(chandle, EINVAL); 315 315 } 316 316 } -
uspace/srv/net/inetsrv/inetsrv.c
r3e242d2 ra46e56b 120 120 } 121 121 122 static void inet_callback_create_srv(inet_client_t *client, cap_call_handle_t c allid,122 static void inet_callback_create_srv(inet_client_t *client, cap_call_handle_t chandle, 123 123 ipc_call_t *call) 124 124 { … … 127 127 async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE); 128 128 if (sess == NULL) { 129 async_answer_0(c allid, ENOMEM);129 async_answer_0(chandle, ENOMEM); 130 130 return; 131 131 } 132 132 133 133 client->sess = sess; 134 async_answer_0(c allid, EOK);134 async_answer_0(chandle, EOK); 135 135 } 136 136 … … 230 230 } 231 231 232 static void inet_get_srcaddr_srv(inet_client_t *client, cap_call_handle_t i id,232 static void inet_get_srcaddr_srv(inet_client_t *client, cap_call_handle_t icall_handle, 233 233 ipc_call_t *icall) 234 234 { … … 237 237 uint8_t tos = IPC_GET_ARG1(*icall); 238 238 239 cap_call_handle_t c allid;239 cap_call_handle_t chandle; 240 240 size_t size; 241 if (!async_data_write_receive(&c allid, &size)) {242 async_answer_0(c allid, EREFUSED);243 async_answer_0(i id, EREFUSED);241 if (!async_data_write_receive(&chandle, &size)) { 242 async_answer_0(chandle, EREFUSED); 243 async_answer_0(icall_handle, EREFUSED); 244 244 return; 245 245 } 246 246 247 247 if (size != sizeof(inet_addr_t)) { 248 async_answer_0(c allid, EINVAL);249 async_answer_0(i id, EINVAL);248 async_answer_0(chandle, EINVAL); 249 async_answer_0(icall_handle, EINVAL); 250 250 return; 251 251 } 252 252 253 253 inet_addr_t remote; 254 errno_t rc = async_data_write_finalize(c allid, &remote, size);255 if (rc != EOK) { 256 async_answer_0(c allid, rc);257 async_answer_0(i id, rc);254 errno_t rc = async_data_write_finalize(chandle, &remote, size); 255 if (rc != EOK) { 256 async_answer_0(chandle, rc); 257 async_answer_0(icall_handle, rc); 258 258 } 259 259 … … 261 261 rc = inet_get_srcaddr(&remote, tos, &local); 262 262 if (rc != EOK) { 263 async_answer_0(i id, rc);264 return; 265 } 266 267 if (!async_data_read_receive(&c allid, &size)) {268 async_answer_0(c allid, EREFUSED);269 async_answer_0(i id, EREFUSED);263 async_answer_0(icall_handle, rc); 264 return; 265 } 266 267 if (!async_data_read_receive(&chandle, &size)) { 268 async_answer_0(chandle, EREFUSED); 269 async_answer_0(icall_handle, EREFUSED); 270 270 return; 271 271 } 272 272 273 273 if (size != sizeof(inet_addr_t)) { 274 async_answer_0(c allid, EINVAL);275 async_answer_0(i id, EINVAL);276 return; 277 } 278 279 rc = async_data_read_finalize(c allid, &local, size);280 if (rc != EOK) { 281 async_answer_0(c allid, rc);282 async_answer_0(i id, rc);283 return; 284 } 285 286 async_answer_0(i id, rc);287 } 288 289 static void inet_send_srv(inet_client_t *client, cap_call_handle_t i id,274 async_answer_0(chandle, EINVAL); 275 async_answer_0(icall_handle, EINVAL); 276 return; 277 } 278 279 rc = async_data_read_finalize(chandle, &local, size); 280 if (rc != EOK) { 281 async_answer_0(chandle, rc); 282 async_answer_0(icall_handle, rc); 283 return; 284 } 285 286 async_answer_0(icall_handle, rc); 287 } 288 289 static void inet_send_srv(inet_client_t *client, cap_call_handle_t icall_handle, 290 290 ipc_call_t *icall) 291 291 { … … 300 300 int df = IPC_GET_ARG4(*icall); 301 301 302 cap_call_handle_t c allid;302 cap_call_handle_t chandle; 303 303 size_t size; 304 if (!async_data_write_receive(&c allid, &size)) {305 async_answer_0(c allid, EREFUSED);306 async_answer_0(i id, EREFUSED);304 if (!async_data_write_receive(&chandle, &size)) { 305 async_answer_0(chandle, EREFUSED); 306 async_answer_0(icall_handle, EREFUSED); 307 307 return; 308 308 } 309 309 310 310 if (size != sizeof(inet_addr_t)) { 311 async_answer_0(c allid, EINVAL);312 async_answer_0(i id, EINVAL);313 return; 314 } 315 316 errno_t rc = async_data_write_finalize(c allid, &dgram.src, size);317 if (rc != EOK) { 318 async_answer_0(c allid, rc);319 async_answer_0(i id, rc);320 } 321 322 if (!async_data_write_receive(&c allid, &size)) {323 async_answer_0(c allid, EREFUSED);324 async_answer_0(i id, EREFUSED);311 async_answer_0(chandle, EINVAL); 312 async_answer_0(icall_handle, EINVAL); 313 return; 314 } 315 316 errno_t rc = async_data_write_finalize(chandle, &dgram.src, size); 317 if (rc != EOK) { 318 async_answer_0(chandle, rc); 319 async_answer_0(icall_handle, rc); 320 } 321 322 if (!async_data_write_receive(&chandle, &size)) { 323 async_answer_0(chandle, EREFUSED); 324 async_answer_0(icall_handle, EREFUSED); 325 325 return; 326 326 } 327 327 328 328 if (size != sizeof(inet_addr_t)) { 329 async_answer_0(c allid, EINVAL);330 async_answer_0(i id, EINVAL);331 return; 332 } 333 334 rc = async_data_write_finalize(c allid, &dgram.dest, size);335 if (rc != EOK) { 336 async_answer_0(c allid, rc);337 async_answer_0(i id, rc);329 async_answer_0(chandle, EINVAL); 330 async_answer_0(icall_handle, EINVAL); 331 return; 332 } 333 334 rc = async_data_write_finalize(chandle, &dgram.dest, size); 335 if (rc != EOK) { 336 async_answer_0(chandle, rc); 337 async_answer_0(icall_handle, rc); 338 338 } 339 339 … … 341 341 &dgram.size); 342 342 if (rc != EOK) { 343 async_answer_0(i id, rc);343 async_answer_0(icall_handle, rc); 344 344 return; 345 345 } … … 348 348 349 349 free(dgram.data); 350 async_answer_0(i id, rc);351 } 352 353 static void inet_set_proto_srv(inet_client_t *client, cap_call_handle_t c allid,350 async_answer_0(icall_handle, rc); 351 } 352 353 static void inet_set_proto_srv(inet_client_t *client, cap_call_handle_t chandle, 354 354 ipc_call_t *call) 355 355 { … … 360 360 361 361 if (proto > UINT8_MAX) { 362 async_answer_0(c allid, EINVAL);362 async_answer_0(chandle, EINVAL); 363 363 return; 364 364 } 365 365 366 366 client->protocol = proto; 367 async_answer_0(c allid, EOK);367 async_answer_0(chandle, EOK); 368 368 } 369 369 … … 387 387 } 388 388 389 static void inet_default_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)389 static void inet_default_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 390 390 { 391 391 inet_client_t client; … … 394 394 395 395 /* Accept the connection */ 396 async_answer_0(i id, EOK);396 async_answer_0(icall_handle, EOK); 397 397 398 398 inet_client_init(&client); … … 400 400 while (true) { 401 401 ipc_call_t call; 402 cap_call_handle_t c allid= async_get_call(&call);402 cap_call_handle_t chandle = async_get_call(&call); 403 403 sysarg_t method = IPC_GET_IMETHOD(call); 404 404 405 405 if (!method) { 406 406 /* The other side has hung up */ 407 async_answer_0(c allid, EOK);407 async_answer_0(chandle, EOK); 408 408 return; 409 409 } … … 411 411 switch (method) { 412 412 case INET_CALLBACK_CREATE: 413 inet_callback_create_srv(&client, c allid, &call);413 inet_callback_create_srv(&client, chandle, &call); 414 414 break; 415 415 case INET_GET_SRCADDR: 416 inet_get_srcaddr_srv(&client, c allid, &call);416 inet_get_srcaddr_srv(&client, chandle, &call); 417 417 break; 418 418 case INET_SEND: 419 inet_send_srv(&client, c allid, &call);419 inet_send_srv(&client, chandle, &call); 420 420 break; 421 421 case INET_SET_PROTO: 422 inet_set_proto_srv(&client, c allid, &call);422 inet_set_proto_srv(&client, chandle, &call); 423 423 break; 424 424 default: 425 async_answer_0(c allid, EINVAL);425 async_answer_0(chandle, EINVAL); 426 426 } 427 427 } -
uspace/srv/net/loopip/loopip.c
r3e242d2 ra46e56b 59 59 static errno_t loopip_addr_remove(iplink_srv_t *srv, inet_addr_t *addr); 60 60 61 static void loopip_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg);61 static void loopip_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg); 62 62 63 63 static iplink_ops_t loopip_iplink_ops = { … … 148 148 } 149 149 150 static void loopip_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)150 static void loopip_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 151 151 { 152 152 log_msg(LOG_DEFAULT, LVL_DEBUG, "loopip_client_conn()"); 153 iplink_conn(i id, icall, &loopip_iplink);153 iplink_conn(icall_handle, icall, &loopip_iplink); 154 154 } 155 155 -
uspace/srv/net/nconfsrv/nconfsrv.c
r3e242d2 ra46e56b 54 54 #define NAME "nconfsrv" 55 55 56 static void ncs_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg);56 static void ncs_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg); 57 57 58 58 static errno_t ncs_init(void) … … 98 98 } 99 99 100 static void ncs_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)100 static void ncs_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 101 101 { 102 async_answer_0(i id, ENOTSUP);102 async_answer_0(icall_handle, ENOTSUP); 103 103 } 104 104 -
uspace/srv/net/slip/slip.c
r3e242d2 ra46e56b 199 199 } 200 200 201 static void slip_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)201 static void slip_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 202 202 { 203 203 log_msg(LOG_DEFAULT, LVL_DEBUG, "slip_client_conn()"); 204 iplink_conn(i id, icall, &slip_iplink);204 iplink_conn(icall_handle, icall, &slip_iplink); 205 205 } 206 206 -
uspace/srv/net/tcp/service.c
r3e242d2 ra46e56b 724 724 * Handle client request to create callback session. 725 725 * 726 * @param client TCP client727 * @param i id Async request ID728 * @param icall Async request data729 */ 730 static void tcp_callback_create_srv(tcp_client_t *client, cap_call_handle_t iid,731 ipc_call_t *icall)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) 732 732 { 733 733 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_callback_create_srv()"); … … 735 735 async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE); 736 736 if (sess == NULL) { 737 async_answer_0(i id, ENOMEM);737 async_answer_0(icall_handle, ENOMEM); 738 738 return; 739 739 } 740 740 741 741 client->sess = sess; 742 async_answer_0(i id, EOK);742 async_answer_0(icall_handle, EOK); 743 743 } 744 744 … … 747 747 * Handle client request to create connection. 748 748 * 749 * @param client TCP client750 * @param i id Async request ID751 * @param icall Async request data752 */ 753 static void tcp_conn_create_srv(tcp_client_t *client, cap_call_handle_t iid,754 ipc_call_t *icall)755 { 756 cap_call_handle_t c allid;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; 757 757 size_t size; 758 758 inet_ep2_t epp; … … 762 762 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_create_srv()"); 763 763 764 if (!async_data_write_receive(&c allid, &size)) {765 async_answer_0(c allid, EREFUSED);766 async_answer_0(i id, EREFUSED);764 if (!async_data_write_receive(&chandle, &size)) { 765 async_answer_0(chandle, EREFUSED); 766 async_answer_0(icall_handle, EREFUSED); 767 767 return; 768 768 } 769 769 770 770 if (size != sizeof(inet_ep2_t)) { 771 async_answer_0(c allid, EINVAL);772 async_answer_0(i id, EINVAL);773 return; 774 } 775 776 rc = async_data_write_finalize(c allid, &epp, size);777 if (rc != EOK) { 778 async_answer_0(c allid, rc);779 async_answer_0(i id, rc);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); 780 780 return; 781 781 } … … 783 783 rc = tcp_conn_create_impl(client, &epp, &conn_id); 784 784 if (rc != EOK) { 785 async_answer_0(i id, rc);786 return; 787 } 788 789 async_answer_1(i id, EOK, conn_id);785 async_answer_0(icall_handle, rc); 786 return; 787 } 788 789 async_answer_1(icall_handle, EOK, conn_id); 790 790 } 791 791 … … 794 794 * Handle client request to destroy connection. 795 795 * 796 * @param client TCP client797 * @param i id Async request ID798 * @param icall Async request data799 */ 800 static void tcp_conn_destroy_srv(tcp_client_t *client, cap_call_handle_t iid,801 ipc_call_t *icall)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) 802 802 { 803 803 sysarg_t conn_id; … … 808 808 conn_id = IPC_GET_ARG1(*icall); 809 809 rc = tcp_conn_destroy_impl(client, conn_id); 810 async_answer_0(i id, rc);810 async_answer_0(icall_handle, rc); 811 811 } 812 812 … … 815 815 * Handle client request to create listener. 816 816 * 817 * @param client TCP client818 * @param i id Async request ID819 * @param icall Async request data820 */ 821 static void tcp_listener_create_srv(tcp_client_t *client, cap_call_handle_t iid,822 ipc_call_t *icall)823 { 824 cap_call_handle_t c allid;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; 825 825 size_t size; 826 826 inet_ep_t ep; … … 830 830 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_listener_create_srv()"); 831 831 832 if (!async_data_write_receive(&c allid, &size)) {833 async_answer_0(c allid, EREFUSED);834 async_answer_0(i id, EREFUSED);832 if (!async_data_write_receive(&chandle, &size)) { 833 async_answer_0(chandle, EREFUSED); 834 async_answer_0(icall_handle, EREFUSED); 835 835 return; 836 836 } 837 837 838 838 if (size != sizeof(inet_ep_t)) { 839 async_answer_0(c allid, EINVAL);840 async_answer_0(i id, EINVAL);841 return; 842 } 843 844 rc = async_data_write_finalize(c allid, &ep, size);845 if (rc != EOK) { 846 async_answer_0(c allid, rc);847 async_answer_0(i id, rc);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); 848 848 return; 849 849 } … … 851 851 rc = tcp_listener_create_impl(client, &ep, &lst_id); 852 852 if (rc != EOK) { 853 async_answer_0(i id, rc);854 return; 855 } 856 857 async_answer_1(i id, EOK, lst_id);853 async_answer_0(icall_handle, rc); 854 return; 855 } 856 857 async_answer_1(icall_handle, EOK, lst_id); 858 858 } 859 859 … … 862 862 * Handle client request to destroy listener. 863 863 * 864 * @param client TCP client865 * @param i id Async request ID866 * @param icall Async request data867 */ 868 static void tcp_listener_destroy_srv(tcp_client_t *client, cap_call_handle_t iid,869 ipc_call_t *icall)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) 870 870 { 871 871 sysarg_t lst_id; … … 876 876 lst_id = IPC_GET_ARG1(*icall); 877 877 rc = tcp_listener_destroy_impl(client, lst_id); 878 async_answer_0(i id, rc);878 async_answer_0(icall_handle, rc); 879 879 } 880 880 … … 883 883 * Handle client request to send FIN. 884 884 * 885 * @param client TCP client886 * @param i id Async request ID887 * @param icall Async request data888 */ 889 static void tcp_conn_send_fin_srv(tcp_client_t *client, cap_call_handle_t iid,890 ipc_call_t *icall)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) 891 891 { 892 892 sysarg_t conn_id; … … 897 897 conn_id = IPC_GET_ARG1(*icall); 898 898 rc = tcp_conn_send_fin_impl(client, conn_id); 899 async_answer_0(i id, rc);899 async_answer_0(icall_handle, rc); 900 900 } 901 901 … … 904 904 * Handle client request to push connection. 905 905 * 906 * @param client TCP client907 * @param i id Async request ID908 * @param icall Async request data909 */ 910 static void tcp_conn_push_srv(tcp_client_t *client, cap_call_handle_t iid,911 ipc_call_t *icall)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) 912 912 { 913 913 sysarg_t conn_id; … … 918 918 conn_id = IPC_GET_ARG1(*icall); 919 919 rc = tcp_conn_push_impl(client, conn_id); 920 async_answer_0(i id, rc);920 async_answer_0(icall_handle, rc); 921 921 } 922 922 … … 925 925 * Handle client request to reset connection. 926 926 * 927 * @param client TCP client928 * @param i id Async request ID929 * @param icall Async request data930 */ 931 static void tcp_conn_reset_srv(tcp_client_t *client, cap_call_handle_t iid,932 ipc_call_t *icall)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) 933 933 { 934 934 sysarg_t conn_id; … … 939 939 conn_id = IPC_GET_ARG1(*icall); 940 940 rc = tcp_conn_reset_impl(client, conn_id); 941 async_answer_0(i id, rc);941 async_answer_0(icall_handle, rc); 942 942 } 943 943 … … 946 946 * Handle client request to send data via connection. 947 947 * 948 * @param client TCP client949 * @param i id Async request ID950 * @param icall Async request data951 */ 952 static void tcp_conn_send_srv(tcp_client_t *client, cap_call_handle_t iid,953 ipc_call_t *icall)954 { 955 cap_call_handle_t c allid;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; 956 956 size_t size; 957 957 sysarg_t conn_id; … … 963 963 /* Receive message data */ 964 964 965 if (!async_data_write_receive(&c allid, &size)) {966 async_answer_0(c allid, EREFUSED);967 async_answer_0(i id, EREFUSED);965 if (!async_data_write_receive(&chandle, &size)) { 966 async_answer_0(chandle, EREFUSED); 967 async_answer_0(icall_handle, EREFUSED); 968 968 return; 969 969 } 970 970 971 971 if (size > MAX_MSG_SIZE) { 972 async_answer_0(c allid, EINVAL);973 async_answer_0(i id, EINVAL);972 async_answer_0(chandle, EINVAL); 973 async_answer_0(icall_handle, EINVAL); 974 974 return; 975 975 } … … 977 977 data = malloc(size); 978 978 if (data == NULL) { 979 async_answer_0(c allid, ENOMEM);980 async_answer_0(i id, ENOMEM);981 return; 982 } 983 984 rc = async_data_write_finalize(c allid, data, size);985 if (rc != EOK) { 986 async_answer_0(c allid, rc);987 async_answer_0(i id, rc);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); 988 988 free(data); 989 989 return; … … 994 994 rc = tcp_conn_send_impl(client, conn_id, data, size); 995 995 if (rc != EOK) { 996 async_answer_0(i id, rc);996 async_answer_0(icall_handle, rc); 997 997 free(data); 998 998 return; 999 999 } 1000 1000 1001 async_answer_0(i id, EOK);1001 async_answer_0(icall_handle, EOK); 1002 1002 free(data); 1003 1003 } … … 1007 1007 * Handle client request to read received data via connection without blocking. 1008 1008 * 1009 * @param client TCP client1010 * @param i id Async request ID1011 * @param icall Async request data1012 */ 1013 static void tcp_conn_recv_srv(tcp_client_t *client, cap_call_handle_t iid,1014 ipc_call_t *icall)1015 { 1016 cap_call_handle_t c allid;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; 1017 1017 sysarg_t conn_id; 1018 1018 size_t size, rsize; … … 1024 1024 conn_id = IPC_GET_ARG1(*icall); 1025 1025 1026 if (!async_data_read_receive(&c allid, &size)) {1027 async_answer_0(c allid, EREFUSED);1028 async_answer_0(i id, EREFUSED);1026 if (!async_data_read_receive(&chandle, &size)) { 1027 async_answer_0(chandle, EREFUSED); 1028 async_answer_0(icall_handle, EREFUSED); 1029 1029 return; 1030 1030 } … … 1033 1033 data = malloc(size); 1034 1034 if (data == NULL) { 1035 async_answer_0(c allid, ENOMEM);1036 async_answer_0(i id, ENOMEM);1035 async_answer_0(chandle, ENOMEM); 1036 async_answer_0(icall_handle, ENOMEM); 1037 1037 return; 1038 1038 } … … 1040 1040 rc = tcp_conn_recv_impl(client, conn_id, data, size, &rsize); 1041 1041 if (rc != EOK) { 1042 async_answer_0(c allid, rc);1043 async_answer_0(i id, rc);1042 async_answer_0(chandle, rc); 1043 async_answer_0(icall_handle, rc); 1044 1044 free(data); 1045 1045 return; 1046 1046 } 1047 1047 1048 rc = async_data_read_finalize(c allid, data, size);1049 if (rc != EOK) { 1050 async_answer_0(i id, rc);1048 rc = async_data_read_finalize(chandle, data, size); 1049 if (rc != EOK) { 1050 async_answer_0(icall_handle, rc); 1051 1051 free(data); 1052 1052 return; 1053 1053 } 1054 1054 1055 async_answer_1(i id, EOK, rsize);1055 async_answer_1(icall_handle, EOK, rsize); 1056 1056 free(data); 1057 1057 … … 1063 1063 * Handle client request to read received data via connection with blocking. 1064 1064 * 1065 * @param client TCP client1066 * @param i id Async request ID1067 * @param icall Async request data1068 */ 1069 static void tcp_conn_recv_wait_srv(tcp_client_t *client, cap_call_handle_t iid,1070 ipc_call_t *icall)1071 { 1072 cap_call_handle_t c allid;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; 1073 1073 sysarg_t conn_id; 1074 1074 size_t size, rsize; … … 1080 1080 conn_id = IPC_GET_ARG1(*icall); 1081 1081 1082 if (!async_data_read_receive(&c allid, &size)) {1082 if (!async_data_read_receive(&chandle, &size)) { 1083 1083 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - data_receive failed"); 1084 async_answer_0(c allid, EREFUSED);1085 async_answer_0(i id, EREFUSED);1084 async_answer_0(chandle, EREFUSED); 1085 async_answer_0(icall_handle, EREFUSED); 1086 1086 return; 1087 1087 } … … 1091 1091 if (data == NULL) { 1092 1092 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - allocation failed"); 1093 async_answer_0(c allid, ENOMEM);1094 async_answer_0(i id, ENOMEM);1093 async_answer_0(chandle, ENOMEM); 1094 async_answer_0(icall_handle, ENOMEM); 1095 1095 return; 1096 1096 } … … 1099 1099 if (rc != EOK) { 1100 1100 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - recv_impl failed rc=%s", str_error_name(rc)); 1101 async_answer_0(c allid, rc);1102 async_answer_0(i id, rc);1101 async_answer_0(chandle, rc); 1102 async_answer_0(icall_handle, rc); 1103 1103 free(data); 1104 1104 return; 1105 1105 } 1106 1106 1107 rc = async_data_read_finalize(c allid, data, size);1107 rc = async_data_read_finalize(chandle, data, size); 1108 1108 if (rc != EOK) { 1109 1109 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv - finalize failed"); 1110 async_answer_0(i id, rc);1110 async_answer_0(icall_handle, rc); 1111 1111 free(data); 1112 1112 return; … … 1114 1114 1115 1115 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_recv_wait_srv(): rsize=%zu", size); 1116 async_answer_1(i id, EOK, rsize);1116 async_answer_1(icall_handle, EOK, rsize); 1117 1117 free(data); 1118 1118 … … 1168 1168 /** Handle TCP client connection. 1169 1169 * 1170 * @param iid Connect call ID 1171 * @param icall Connect call data 1172 * @param arg Connection argument 1173 */ 1174 static void tcp_client_conn(cap_call_handle_t iid, ipc_call_t *icall, void *arg) 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) 1175 1176 { 1176 1177 tcp_client_t client; 1177 1178 1178 1179 /* Accept the connection */ 1179 async_answer_0(i id, EOK);1180 async_answer_0(icall_handle, EOK); 1180 1181 1181 1182 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_client_conn() - client=%p", … … 1187 1188 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_client_conn: wait req"); 1188 1189 ipc_call_t call; 1189 cap_call_handle_t c allid= async_get_call(&call);1190 cap_call_handle_t chandle = async_get_call(&call); 1190 1191 sysarg_t method = IPC_GET_IMETHOD(call); 1191 1192 … … 1194 1195 if (!method) { 1195 1196 /* The other side has hung up */ 1196 async_answer_0(c allid, EOK);1197 async_answer_0(chandle, EOK); 1197 1198 break; 1198 1199 } … … 1200 1201 switch (method) { 1201 1202 case TCP_CALLBACK_CREATE: 1202 tcp_callback_create_srv(&client, c allid, &call);1203 tcp_callback_create_srv(&client, chandle, &call); 1203 1204 break; 1204 1205 case TCP_CONN_CREATE: 1205 tcp_conn_create_srv(&client, c allid, &call);1206 tcp_conn_create_srv(&client, chandle, &call); 1206 1207 break; 1207 1208 case TCP_CONN_DESTROY: 1208 tcp_conn_destroy_srv(&client, c allid, &call);1209 tcp_conn_destroy_srv(&client, chandle, &call); 1209 1210 break; 1210 1211 case TCP_LISTENER_CREATE: 1211 tcp_listener_create_srv(&client, c allid, &call);1212 tcp_listener_create_srv(&client, chandle, &call); 1212 1213 break; 1213 1214 case TCP_LISTENER_DESTROY: 1214 tcp_listener_destroy_srv(&client, c allid, &call);1215 tcp_listener_destroy_srv(&client, chandle, &call); 1215 1216 break; 1216 1217 case TCP_CONN_SEND_FIN: 1217 tcp_conn_send_fin_srv(&client, c allid, &call);1218 tcp_conn_send_fin_srv(&client, chandle, &call); 1218 1219 break; 1219 1220 case TCP_CONN_PUSH: 1220 tcp_conn_push_srv(&client, c allid, &call);1221 tcp_conn_push_srv(&client, chandle, &call); 1221 1222 break; 1222 1223 case TCP_CONN_RESET: 1223 tcp_conn_reset_srv(&client, c allid, &call);1224 tcp_conn_reset_srv(&client, chandle, &call); 1224 1225 break; 1225 1226 case TCP_CONN_SEND: 1226 tcp_conn_send_srv(&client, c allid, &call);1227 tcp_conn_send_srv(&client, chandle, &call); 1227 1228 break; 1228 1229 case TCP_CONN_RECV: 1229 tcp_conn_recv_srv(&client, c allid, &call);1230 tcp_conn_recv_srv(&client, chandle, &call); 1230 1231 break; 1231 1232 case TCP_CONN_RECV_WAIT: 1232 tcp_conn_recv_wait_srv(&client, c allid, &call);1233 tcp_conn_recv_wait_srv(&client, chandle, &call); 1233 1234 break; 1234 1235 default: 1235 async_answer_0(c allid, ENOTSUP);1236 async_answer_0(chandle, ENOTSUP); 1236 1237 break; 1237 1238 } -
uspace/srv/net/udp/service.c
r3e242d2 ra46e56b 335 335 * @param icall Async request data 336 336 */ 337 static void udp_callback_create_srv(udp_client_t *client, cap_call_handle_t i id,337 static void udp_callback_create_srv(udp_client_t *client, cap_call_handle_t icall_handle, 338 338 ipc_call_t *icall) 339 339 { … … 342 342 async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE); 343 343 if (sess == NULL) { 344 async_answer_0(i id, ENOMEM);344 async_answer_0(icall_handle, ENOMEM); 345 345 return; 346 346 } 347 347 348 348 client->sess = sess; 349 async_answer_0(i id, EOK);349 async_answer_0(icall_handle, EOK); 350 350 } 351 351 … … 358 358 * @param icall Async request data 359 359 */ 360 static void udp_assoc_create_srv(udp_client_t *client, cap_call_handle_t i id,360 static void udp_assoc_create_srv(udp_client_t *client, cap_call_handle_t icall_handle, 361 361 ipc_call_t *icall) 362 362 { 363 cap_call_handle_t c allid;363 cap_call_handle_t chandle; 364 364 size_t size; 365 365 inet_ep2_t epp; … … 369 369 log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_create_srv()"); 370 370 371 if (!async_data_write_receive(&c allid, &size)) {372 async_answer_0(c allid, EREFUSED);373 async_answer_0(i id, EREFUSED);371 if (!async_data_write_receive(&chandle, &size)) { 372 async_answer_0(chandle, EREFUSED); 373 async_answer_0(icall_handle, EREFUSED); 374 374 return; 375 375 } 376 376 377 377 if (size != sizeof(inet_ep2_t)) { 378 async_answer_0(c allid, EINVAL);379 async_answer_0(i id, EINVAL);380 return; 381 } 382 383 rc = async_data_write_finalize(c allid, &epp, size);384 if (rc != EOK) { 385 async_answer_0(c allid, rc);386 async_answer_0(i id, rc);378 async_answer_0(chandle, EINVAL); 379 async_answer_0(icall_handle, EINVAL); 380 return; 381 } 382 383 rc = async_data_write_finalize(chandle, &epp, size); 384 if (rc != EOK) { 385 async_answer_0(chandle, rc); 386 async_answer_0(icall_handle, rc); 387 387 return; 388 388 } … … 390 390 rc = udp_assoc_create_impl(client, &epp, &assoc_id); 391 391 if (rc != EOK) { 392 async_answer_0(i id, rc);393 return; 394 } 395 396 async_answer_1(i id, EOK, assoc_id);392 async_answer_0(icall_handle, rc); 393 return; 394 } 395 396 async_answer_1(icall_handle, EOK, assoc_id); 397 397 } 398 398 … … 405 405 * @param icall Async request data 406 406 */ 407 static void udp_assoc_destroy_srv(udp_client_t *client, cap_call_handle_t i id,407 static void udp_assoc_destroy_srv(udp_client_t *client, cap_call_handle_t icall_handle, 408 408 ipc_call_t *icall) 409 409 { … … 415 415 assoc_id = IPC_GET_ARG1(*icall); 416 416 rc = udp_assoc_destroy_impl(client, assoc_id); 417 async_answer_0(i id, rc);417 async_answer_0(icall_handle, rc); 418 418 } 419 419 … … 426 426 * @param icall Async request data 427 427 */ 428 static void udp_assoc_set_nolocal_srv(udp_client_t *client, cap_call_handle_t i id,428 static void udp_assoc_set_nolocal_srv(udp_client_t *client, cap_call_handle_t icall_handle, 429 429 ipc_call_t *icall) 430 430 { … … 436 436 assoc_id = IPC_GET_ARG1(*icall); 437 437 rc = udp_assoc_set_nolocal_impl(client, assoc_id); 438 async_answer_0(i id, rc);438 async_answer_0(icall_handle, rc); 439 439 } 440 440 … … 447 447 * @param icall Async request data 448 448 */ 449 static void udp_assoc_send_msg_srv(udp_client_t *client, cap_call_handle_t i id,449 static void udp_assoc_send_msg_srv(udp_client_t *client, cap_call_handle_t icall_handle, 450 450 ipc_call_t *icall) 451 451 { 452 cap_call_handle_t c allid;452 cap_call_handle_t chandle; 453 453 size_t size; 454 454 inet_ep_t dest; … … 461 461 /* Receive dest */ 462 462 463 if (!async_data_write_receive(&c allid, &size)) {464 async_answer_0(c allid, EREFUSED);465 async_answer_0(i id, EREFUSED);463 if (!async_data_write_receive(&chandle, &size)) { 464 async_answer_0(chandle, EREFUSED); 465 async_answer_0(icall_handle, EREFUSED); 466 466 return; 467 467 } 468 468 469 469 if (size != sizeof(inet_ep_t)) { 470 async_answer_0(c allid, EINVAL);471 async_answer_0(i id, EINVAL);472 return; 473 } 474 475 rc = async_data_write_finalize(c allid, &dest, size);476 if (rc != EOK) { 477 async_answer_0(c allid, rc);478 async_answer_0(i id, rc);470 async_answer_0(chandle, EINVAL); 471 async_answer_0(icall_handle, EINVAL); 472 return; 473 } 474 475 rc = async_data_write_finalize(chandle, &dest, size); 476 if (rc != EOK) { 477 async_answer_0(chandle, rc); 478 async_answer_0(icall_handle, rc); 479 479 return; 480 480 } … … 482 482 /* Receive message data */ 483 483 484 if (!async_data_write_receive(&c allid, &size)) {485 async_answer_0(c allid, EREFUSED);486 async_answer_0(i id, EREFUSED);484 if (!async_data_write_receive(&chandle, &size)) { 485 async_answer_0(chandle, EREFUSED); 486 async_answer_0(icall_handle, EREFUSED); 487 487 return; 488 488 } 489 489 490 490 if (size > MAX_MSG_SIZE) { 491 async_answer_0(c allid, EINVAL);492 async_answer_0(i id, EINVAL);491 async_answer_0(chandle, EINVAL); 492 async_answer_0(icall_handle, EINVAL); 493 493 return; 494 494 } … … 496 496 data = malloc(size); 497 497 if (data == NULL) { 498 async_answer_0(c allid, ENOMEM);499 async_answer_0(i id, ENOMEM);500 } 501 502 rc = async_data_write_finalize(c allid, data, size);503 if (rc != EOK) { 504 async_answer_0(c allid, rc);505 async_answer_0(i id, rc);498 async_answer_0(chandle, ENOMEM); 499 async_answer_0(icall_handle, ENOMEM); 500 } 501 502 rc = async_data_write_finalize(chandle, data, size); 503 if (rc != EOK) { 504 async_answer_0(chandle, rc); 505 async_answer_0(icall_handle, rc); 506 506 free(data); 507 507 return; … … 512 512 rc = udp_assoc_send_msg_impl(client, assoc_id, &dest, data, size); 513 513 if (rc != EOK) { 514 async_answer_0(i id, rc);514 async_answer_0(icall_handle, rc); 515 515 free(data); 516 516 return; 517 517 } 518 518 519 async_answer_0(i id, EOK);519 async_answer_0(icall_handle, EOK); 520 520 free(data); 521 521 } … … 545 545 * @param icall Async request data 546 546 */ 547 static void udp_rmsg_info_srv(udp_client_t *client, cap_call_handle_t i id,547 static void udp_rmsg_info_srv(udp_client_t *client, cap_call_handle_t icall_handle, 548 548 ipc_call_t *icall) 549 549 { 550 cap_call_handle_t c allid;550 cap_call_handle_t chandle; 551 551 size_t size; 552 552 udp_crcv_queue_entry_t *enext; … … 557 557 enext = udp_rmsg_get_next(client); 558 558 559 if (!async_data_read_receive(&c allid, &size)) {560 async_answer_0(c allid, EREFUSED);561 async_answer_0(i id, EREFUSED);559 if (!async_data_read_receive(&chandle, &size)) { 560 async_answer_0(chandle, EREFUSED); 561 async_answer_0(icall_handle, EREFUSED); 562 562 return; 563 563 } 564 564 565 565 if (enext == NULL) { 566 async_answer_0(c allid, ENOENT);567 async_answer_0(i id, ENOENT);568 return; 569 } 570 571 rc = async_data_read_finalize(c allid, &enext->epp.remote,566 async_answer_0(chandle, ENOENT); 567 async_answer_0(icall_handle, ENOENT); 568 return; 569 } 570 571 rc = async_data_read_finalize(chandle, &enext->epp.remote, 572 572 max(size, (size_t)sizeof(inet_ep_t))); 573 573 if (rc != EOK) { 574 async_answer_0(i id, rc);574 async_answer_0(icall_handle, rc); 575 575 return; 576 576 } … … 581 581 log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_rmsg_info_srv(): assoc_id=%zu, " 582 582 "size=%zu", assoc_id, size); 583 async_answer_2(i id, EOK, assoc_id, size);583 async_answer_2(icall_handle, EOK, assoc_id, size); 584 584 } 585 585 … … 592 592 * @param icall Async request data 593 593 */ 594 static void udp_rmsg_read_srv(udp_client_t *client, cap_call_handle_t i id,594 static void udp_rmsg_read_srv(udp_client_t *client, cap_call_handle_t icall_handle, 595 595 ipc_call_t *icall) 596 596 { 597 cap_call_handle_t c allid;597 cap_call_handle_t chandle; 598 598 size_t msg_size; 599 599 udp_crcv_queue_entry_t *enext; … … 608 608 enext = udp_rmsg_get_next(client); 609 609 610 if (!async_data_read_receive(&c allid, &size)) {611 async_answer_0(c allid, EREFUSED);612 async_answer_0(i id, EREFUSED);610 if (!async_data_read_receive(&chandle, &size)) { 611 async_answer_0(chandle, EREFUSED); 612 async_answer_0(icall_handle, EREFUSED); 613 613 return; 614 614 } 615 615 616 616 if (enext == NULL) { 617 async_answer_0(c allid, ENOENT);618 async_answer_0(i id, ENOENT);617 async_answer_0(chandle, ENOENT); 618 async_answer_0(icall_handle, ENOENT); 619 619 return; 620 620 } … … 624 624 625 625 if (off > msg_size) { 626 async_answer_0(c allid, EINVAL);627 async_answer_0(i id, EINVAL);628 return; 629 } 630 631 rc = async_data_read_finalize(c allid, data, min(msg_size - off, size));632 if (rc != EOK) { 633 async_answer_0(i id, rc);634 return; 635 } 636 637 async_answer_0(i id, EOK);626 async_answer_0(chandle, EINVAL); 627 async_answer_0(icall_handle, EINVAL); 628 return; 629 } 630 631 rc = async_data_read_finalize(chandle, data, min(msg_size - off, size)); 632 if (rc != EOK) { 633 async_answer_0(icall_handle, rc); 634 return; 635 } 636 637 async_answer_0(icall_handle, EOK); 638 638 log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_rmsg_read_srv(): OK"); 639 639 } … … 648 648 * @param icall Async request data 649 649 */ 650 static void udp_rmsg_discard_srv(udp_client_t *client, cap_call_handle_t i id,650 static void udp_rmsg_discard_srv(udp_client_t *client, cap_call_handle_t icall_handle, 651 651 ipc_call_t *icall) 652 652 { … … 658 658 if (enext == NULL) { 659 659 log_msg(LOG_DEFAULT, LVL_DEBUG, "usg_rmsg_discard_srv: enext==NULL"); 660 async_answer_0(i id, ENOENT);660 async_answer_0(icall_handle, ENOENT); 661 661 return; 662 662 } … … 665 665 udp_msg_delete(enext->msg); 666 666 free(enext); 667 async_answer_0(i id, EOK);667 async_answer_0(icall_handle, EOK); 668 668 } 669 669 … … 674 674 * @param arg Connection argument 675 675 */ 676 static void udp_client_conn(cap_call_handle_t i id, ipc_call_t *icall, void *arg)676 static void udp_client_conn(cap_call_handle_t icall_handle, ipc_call_t *icall, void *arg) 677 677 { 678 678 udp_client_t client; … … 680 680 681 681 /* Accept the connection */ 682 async_answer_0(i id, EOK);682 async_answer_0(icall_handle, EOK); 683 683 684 684 log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_client_conn()"); … … 691 691 log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_client_conn: wait req"); 692 692 ipc_call_t call; 693 cap_call_handle_t c allid= async_get_call(&call);693 cap_call_handle_t chandle = async_get_call(&call); 694 694 sysarg_t method = IPC_GET_IMETHOD(call); 695 695 … … 698 698 if (!method) { 699 699 /* The other side has hung up */ 700 async_answer_0(c allid, EOK);700 async_answer_0(chandle, EOK); 701 701 break; 702 702 } … … 704 704 switch (method) { 705 705 case UDP_CALLBACK_CREATE: 706 udp_callback_create_srv(&client, c allid, &call);706 udp_callback_create_srv(&client, chandle, &call); 707 707 break; 708 708 case UDP_ASSOC_CREATE: 709 udp_assoc_create_srv(&client, c allid, &call);709 udp_assoc_create_srv(&client, chandle, &call); 710 710 break; 711 711 case UDP_ASSOC_DESTROY: 712 udp_assoc_destroy_srv(&client, c allid, &call);712 udp_assoc_destroy_srv(&client, chandle, &call); 713 713 break; 714 714 case UDP_ASSOC_SET_NOLOCAL: 715 udp_assoc_set_nolocal_srv(&client, c allid, &call);715 udp_assoc_set_nolocal_srv(&client, chandle, &call); 716 716 break; 717 717 case UDP_ASSOC_SEND_MSG: 718 udp_assoc_send_msg_srv(&client, c allid, &call);718 udp_assoc_send_msg_srv(&client, chandle, &call); 719 719 break; 720 720 case UDP_RMSG_INFO: 721 udp_rmsg_info_srv(&client, c allid, &call);721 udp_rmsg_info_srv(&client, chandle, &call); 722 722 break; 723 723 case UDP_RMSG_READ: 724 udp_rmsg_read_srv(&client, c allid, &call);724 udp_rmsg_read_srv(&client, chandle, &call); 725 725 break; 726 726 case UDP_RMSG_DISCARD: 727 udp_rmsg_discard_srv(&client, c allid, &call);727 udp_rmsg_discard_srv(&client, chandle, &call); 728 728 break; 729 729 default: 730 async_answer_0(c allid, ENOTSUP);730 async_answer_0(chandle, ENOTSUP); 731 731 break; 732 732 }
Note:
See TracChangeset
for help on using the changeset viewer.