Changes in uspace/srv/net/il/ip/ip.c [6b82009:9934f7d] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/il/ip/ip.c
r6b82009 r9934f7d 77 77 #include <il_skel.h> 78 78 79 // FIXME: remove this header 80 #include <kernel/ipc/ipc_methods.h> 81 79 82 /** IP module name. */ 80 83 #define NAME "ip" … … 122 125 static void ip_receiver(ipc_callid_t, ipc_call_t *, void *); 123 126 124 /** Release the packet and returns the result. 125 * 126 * @param[in] packet Packet queue to be released. 127 * @param[in] result Result to be returned. 128 * 129 * @return Result parameter. 130 * 127 /** Releases the packet and returns the result. 128 * 129 * @param[in] packet The packet queue to be released. 130 * @param[in] result The result to be returned. 131 * @return The result parameter. 131 132 */ 132 133 static int ip_release_and_return(packet_t *packet, int result) 133 134 { 134 pq_release_remote(ip_globals.net_ sess, packet_get_id(packet));135 pq_release_remote(ip_globals.net_phone, packet_get_id(packet)); 135 136 return result; 136 137 } 137 138 138 /** Return the ICMP session. 139 * 140 * Search the registered protocols. 141 * 142 * @return Found ICMP session. 143 * @return NULL if the ICMP is not registered. 144 * 145 */ 146 static async_sess_t *ip_get_icmp_session(void) 147 { 139 /** Returns the ICMP phone. 140 * 141 * Searches the registered protocols. 142 * 143 * @return The found ICMP phone. 144 * @return ENOENT if the ICMP is not registered. 145 */ 146 static int ip_get_icmp_phone(void) 147 { 148 ip_proto_t *proto; 149 int phone; 150 148 151 fibril_rwlock_read_lock(&ip_globals.protos_lock); 149 ip_proto_t *proto = ip_protos_find(&ip_globals.protos, IPPROTO_ICMP);150 async_sess_t *sess = proto ? proto->sess : NULL;152 proto = ip_protos_find(&ip_globals.protos, IPPROTO_ICMP); 153 phone = proto ? proto->phone : ENOENT; 151 154 fibril_rwlock_read_unlock(&ip_globals.protos_lock); 152 153 return sess; 155 return phone; 154 156 } 155 157 … … 180 182 next = pq_detach(packet); 181 183 if (next) 182 pq_release_remote(ip_globals.net_ sess, packet_get_id(next));184 pq_release_remote(ip_globals.net_phone, packet_get_id(next)); 183 185 184 186 if (!header) { … … 219 221 } 220 222 221 /** Prepare the ICMP notification packet.222 * 223 * Release additional packets and keeponly the first one.223 /** Prepares the ICMP notification packet. 224 * 225 * Releases additional packets and keeps only the first one. 224 226 * All packets are released on error. 225 227 * 226 * @param[in] error Packet error service. 227 * @param[in] packet Packet or the packet queue to be reported as faulty. 228 * @param[in] header First packet IP header. May be NULL. 229 * 230 * @return Found ICMP session. 231 * @return NULL if the error parameter is set. 232 * @return NULL if the ICMP session is not found. 233 * @return NULL if the ip_prepare_icmp() fails. 234 * 235 */ 236 static async_sess_t *ip_prepare_icmp_and_get_session(services_t error, 237 packet_t *packet, ip_header_t *header) 238 { 239 async_sess_t *sess = ip_get_icmp_session(); 240 241 if ((error) || (!sess) || (ip_prepare_icmp(packet, header))) { 242 pq_release_remote(ip_globals.net_sess, packet_get_id(packet)); 243 return NULL; 244 } 245 246 return sess; 247 } 248 249 int il_initialize(async_sess_t *net_sess) 228 * @param[in] error The packet error service. 229 * @param[in] packet The packet or the packet queue to be reported as faulty. 230 * @param[in] header The first packet IP header. May be NULL. 231 * @return The found ICMP phone. 232 * @return EINVAL if the error parameter is set. 233 * @return EINVAL if the ICMP phone is not found. 234 * @return EINVAL if the ip_prepare_icmp() fails. 235 */ 236 static int 237 ip_prepare_icmp_and_get_phone(services_t error, packet_t *packet, 238 ip_header_t *header) 239 { 240 int phone; 241 242 phone = ip_get_icmp_phone(); 243 if (error || (phone < 0) || ip_prepare_icmp(packet, header)) 244 return ip_release_and_return(packet, EINVAL); 245 return phone; 246 } 247 248 int il_initialize(int net_phone) 250 249 { 251 250 fibril_rwlock_initialize(&ip_globals.lock); … … 254 253 fibril_rwlock_initialize(&ip_globals.netifs_lock); 255 254 256 ip_globals.net_ sess = net_sess;255 ip_globals.net_phone = net_phone; 257 256 ip_globals.packet_counter = 0; 258 257 ip_globals.gateway.address.s_addr = 0; … … 356 355 357 356 /* Get configuration */ 358 rc = net_get_device_conf_req(ip_globals.net_ sess, ip_netif->device_id,357 rc = net_get_device_conf_req(ip_globals.net_phone, ip_netif->device_id, 359 358 &configuration, count, &data); 360 359 if (rc != EOK) … … 424 423 425 424 /* Bind netif service which also initializes the device */ 426 ip_netif-> sess= nil_bind_service(ip_netif->service,425 ip_netif->phone = nil_bind_service(ip_netif->service, 427 426 (sysarg_t) ip_netif->device_id, SERVICE_IP, 428 427 ip_receiver); 429 if (ip_netif-> sess == NULL) {428 if (ip_netif->phone < 0) { 430 429 printf("Failed to contact the nil service %d\n", 431 430 ip_netif->service); 432 return ENOENT;431 return ip_netif->phone; 433 432 } 434 433 … … 439 438 address.length = sizeof(in_addr_t); 440 439 441 rc = arp_device_req(ip_netif->arp-> sess,440 rc = arp_device_req(ip_netif->arp->phone, 442 441 ip_netif->device_id, SERVICE_IP, ip_netif->service, 443 442 &address); … … 450 449 451 450 /* Get packet dimensions */ 452 rc = nil_packet_size_req(ip_netif-> sess, ip_netif->device_id,451 rc = nil_packet_size_req(ip_netif->phone, ip_netif->device_id, 453 452 &ip_netif->packet_dimension); 454 453 if (rc != EOK) … … 482 481 } 483 482 484 static int ip_device_req_local(device_id_t device_id, services_t netif) 483 static int ip_device_req_local(int il_phone, device_id_t device_id, 484 services_t netif) 485 485 { 486 486 ip_netif_t *ip_netif; … … 516 516 517 517 /* Print the settings */ 518 printf("%s: Device registered (id: %d, ipv: %d, conf: %s)\n",519 NAME, ip_netif->device_id, ip_netif-> ipv,518 printf("%s: Device registered (id: %d, phone: %d, ipv: %d, conf: %s)\n", 519 NAME, ip_netif->device_id, ip_netif->phone, ip_netif->ipv, 520 520 ip_netif->dhcp ? "dhcp" : "static"); 521 521 … … 932 932 933 933 /* Create the last fragment */ 934 new_packet = packet_get_4_remote(ip_globals.net_ sess, prefix, length,934 new_packet = packet_get_4_remote(ip_globals.net_phone, prefix, length, 935 935 suffix, ((addrlen > addr_len) ? addrlen : addr_len)); 936 936 if (!new_packet) … … 969 969 /* Create middle fragments */ 970 970 while (IP_TOTAL_LENGTH(header) > length) { 971 new_packet = packet_get_4_remote(ip_globals.net_ sess, prefix,971 new_packet = packet_get_4_remote(ip_globals.net_phone, prefix, 972 972 length, suffix, 973 973 ((addrlen >= addr_len) ? addrlen : addr_len)); … … 994 994 } 995 995 996 /** Check the packet queue lengths and fragments the packets if needed.996 /** Checks the packet queue lengths and fragments the packets if needed. 997 997 * 998 998 * The ICMP_FRAG_NEEDED error notification may be sent if the packet needs to 999 999 * be fragmented and the fragmentation is not allowed. 1000 1000 * 1001 * @param[in,out] packet Packet or the packet queue to be checked. 1002 * @param[in] prefix Minimum prefix size. 1003 * @param[in] content Maximum content size. 1004 * @param[in] suffix Minimum suffix size. 1005 * @param[in] addr_len Minimum address length. 1006 * @param[in] error Error module service. 1007 * 1008 * @return The packet or the packet queue of the allowed length. 1009 * @return NULL if there are no packets left. 1010 * 1011 */ 1012 static packet_t *ip_split_packet(packet_t *packet, size_t prefix, size_t content, 1013 size_t suffix, socklen_t addr_len, services_t error) 1001 * @param[in,out] packet The packet or the packet queue to be checked. 1002 * @param[in] prefix The minimum prefix size. 1003 * @param[in] content The maximum content size. 1004 * @param[in] suffix The minimum suffix size. 1005 * @param[in] addr_len The minimum address length. 1006 * @param[in] error The error module service. 1007 * @return The packet or the packet queue of the allowed length. 1008 * @return NULL if there are no packets left. 1009 */ 1010 static packet_t * 1011 ip_split_packet(packet_t *packet, size_t prefix, size_t content, size_t suffix, 1012 socklen_t addr_len, services_t error) 1014 1013 { 1015 1014 size_t length; … … 1017 1016 packet_t *new_packet; 1018 1017 int result; 1019 async_sess_t *sess;1020 1018 int phone; 1019 1021 1020 next = packet; 1022 1021 /* Check all packets */ … … 1040 1039 /* Fragmentation needed? */ 1041 1040 if (result == EPERM) { 1042 sess = ip_prepare_icmp_and_get_session(error, next, NULL); 1043 if (sess) { 1041 phone = ip_prepare_icmp_and_get_phone( 1042 error, next, NULL); 1043 if (phone >= 0) { 1044 1044 /* Fragmentation necessary ICMP */ 1045 icmp_destination_unreachable_msg( sess,1045 icmp_destination_unreachable_msg(phone, 1046 1046 ICMP_FRAG_NEEDED, content, next); 1047 1047 } 1048 1048 } else { 1049 pq_release_remote(ip_globals.net_ sess,1049 pq_release_remote(ip_globals.net_phone, 1050 1050 packet_get_id(next)); 1051 1051 } … … 1061 1061 } 1062 1062 1063 /** Send the packet or the packet queue via the specified route.1063 /** Sends the packet or the packet queue via the specified route. 1064 1064 * 1065 1065 * The ICMP_HOST_UNREACH error notification may be sent if route hardware 1066 1066 * destination address is found. 1067 1067 * 1068 * @param[in,out] packet Packet to be sent.1069 * @param[in] netif Target network interface.1070 * @param[in] route Target route.1071 * @param[in] src Source address.1072 * @param[in] dest Destination address.1073 * @param[in] error Error module service.1074 * 1075 * @return EOK on success.1076 * @return Other error codes as defined for arp_translate_req().1077 * @return Other error codes as defined for ip_prepare_packet().1078 * 1068 * @param[in,out] packet The packet to be sent. 1069 * @param[in] netif The target network interface. 1070 * @param[in] route The target route. 1071 * @param[in] src The source address. 1072 * @param[in] dest The destination address. 1073 * @param[in] error The error module service. 1074 * @return EOK on success. 1075 * @return Other error codes as defined for the arp_translate_req() 1076 * function. 1077 * @return Other error codes as defined for the ip_prepare_packet() 1078 * function. 1079 1079 */ 1080 1080 static int ip_send_route(packet_t *packet, ip_netif_t *netif, … … 1084 1084 measured_string_t *translation; 1085 1085 uint8_t *data; 1086 async_sess_t *sess;1086 int phone; 1087 1087 int rc; 1088 1088 … … 1093 1093 destination.length = sizeof(dest.s_addr); 1094 1094 1095 rc = arp_translate_req(netif->arp-> sess, netif->device_id,1095 rc = arp_translate_req(netif->arp->phone, netif->device_id, 1096 1096 SERVICE_IP, &destination, &translation, &data); 1097 1097 if (rc != EOK) { 1098 pq_release_remote(ip_globals.net_ sess,1098 pq_release_remote(ip_globals.net_phone, 1099 1099 packet_get_id(packet)); 1100 1100 return rc; … … 1106 1106 free(data); 1107 1107 } 1108 sess = ip_prepare_icmp_and_get_session(error, packet,1108 phone = ip_prepare_icmp_and_get_phone(error, packet, 1109 1109 NULL); 1110 if ( sess) {1110 if (phone >= 0) { 1111 1111 /* Unreachable ICMP if no routing */ 1112 icmp_destination_unreachable_msg( sess,1112 icmp_destination_unreachable_msg(phone, 1113 1113 ICMP_HOST_UNREACH, 0, packet); 1114 1114 } … … 1122 1122 rc = ip_prepare_packet(src, dest, packet, translation); 1123 1123 if (rc != EOK) { 1124 pq_release_remote(ip_globals.net_ sess, packet_get_id(packet));1124 pq_release_remote(ip_globals.net_phone, packet_get_id(packet)); 1125 1125 } else { 1126 1126 packet = ip_split_packet(packet, netif->packet_dimension.prefix, … … 1129 1129 netif->packet_dimension.addr_len, error); 1130 1130 if (packet) { 1131 nil_send_msg(netif-> sess, netif->device_id, packet,1131 nil_send_msg(netif->phone, netif->device_id, packet, 1132 1132 SERVICE_IP); 1133 1133 } … … 1142 1142 } 1143 1143 1144 static int ip_send_msg_local( device_id_t device_id, packet_t *packet,1145 services_t sender, services_t error)1144 static int ip_send_msg_local(int il_phone, device_id_t device_id, 1145 packet_t *packet, services_t sender, services_t error) 1146 1146 { 1147 1147 int addrlen; … … 1152 1152 in_addr_t *dest; 1153 1153 in_addr_t *src; 1154 async_sess_t *sess;1154 int phone; 1155 1155 int rc; 1156 1156 … … 1197 1197 if (!netif || !route) { 1198 1198 fibril_rwlock_read_unlock(&ip_globals.netifs_lock); 1199 sess = ip_prepare_icmp_and_get_session(error, packet, NULL);1200 if ( sess) {1199 phone = ip_prepare_icmp_and_get_phone(error, packet, NULL); 1200 if (phone >= 0) { 1201 1201 /* Unreachable ICMP if no routing */ 1202 icmp_destination_unreachable_msg( sess,1202 icmp_destination_unreachable_msg(phone, 1203 1203 ICMP_NET_UNREACH, 0, packet); 1204 1204 } … … 1228 1228 if (!netif || !route) { 1229 1229 fibril_rwlock_read_unlock(&ip_globals.netifs_lock); 1230 sess = ip_prepare_icmp_and_get_session(error, packet,1230 phone = ip_prepare_icmp_and_get_phone(error, packet, 1231 1231 NULL); 1232 if ( sess) {1232 if (phone >= 0) { 1233 1233 /* Unreachable ICMP if no routing */ 1234 icmp_destination_unreachable_msg( sess,1234 icmp_destination_unreachable_msg(phone, 1235 1235 ICMP_HOST_UNREACH, 0, packet); 1236 1236 } … … 1316 1316 { 1317 1317 ip_proto_t *proto; 1318 async_sess_t *sess;1318 int phone; 1319 1319 services_t service; 1320 1320 tl_received_msg_t received_msg; … … 1369 1369 if (!proto) { 1370 1370 fibril_rwlock_read_unlock(&ip_globals.protos_lock); 1371 sess = ip_prepare_icmp_and_get_session(error, packet, header);1372 if ( sess) {1371 phone = ip_prepare_icmp_and_get_phone(error, packet, header); 1372 if (phone >= 0) { 1373 1373 /* Unreachable ICMP */ 1374 icmp_destination_unreachable_msg( sess,1374 icmp_destination_unreachable_msg(phone, 1375 1375 ICMP_PROT_UNREACH, 0, packet); 1376 1376 } … … 1384 1384 rc = received_msg(device_id, packet, service, error); 1385 1385 } else { 1386 rc = tl_received_msg(proto-> sess, device_id, packet,1386 rc = tl_received_msg(proto->phone, device_id, packet, 1387 1387 proto->service, error); 1388 1388 fibril_rwlock_read_unlock(&ip_globals.protos_lock); … … 1418 1418 in_addr_t dest; 1419 1419 ip_route_t *route; 1420 async_sess_t *sess;1420 int phone; 1421 1421 struct sockaddr *addr; 1422 1422 struct sockaddr_in addr_in; … … 1431 1431 if ((header->header_checksum) && 1432 1432 (IP_HEADER_CHECKSUM(header) != IP_CHECKSUM_ZERO)) { 1433 sess = ip_prepare_icmp_and_get_session(0, packet, header);1434 if ( sess) {1433 phone = ip_prepare_icmp_and_get_phone(0, packet, header); 1434 if (phone >= 0) { 1435 1435 /* Checksum error ICMP */ 1436 icmp_parameter_problem_msg( sess, ICMP_PARAM_POINTER,1436 icmp_parameter_problem_msg(phone, ICMP_PARAM_POINTER, 1437 1437 ((size_t) ((void *) &header->header_checksum)) - 1438 1438 ((size_t) ((void *) header)), packet); … … 1442 1442 1443 1443 if (header->ttl <= 1) { 1444 sess = ip_prepare_icmp_and_get_session(0, packet, header);1445 if ( sess) {1444 phone = ip_prepare_icmp_and_get_phone(0, packet, header); 1445 if (phone >= 0) { 1446 1446 /* TTL exceeded ICMP */ 1447 icmp_time_exceeded_msg( sess, ICMP_EXC_TTL, packet);1447 icmp_time_exceeded_msg(phone, ICMP_EXC_TTL, packet); 1448 1448 } 1449 1449 return EINVAL; … … 1473 1473 route = ip_find_route(dest); 1474 1474 if (!route) { 1475 sess = ip_prepare_icmp_and_get_session(0, packet, header);1476 if ( sess) {1475 phone = ip_prepare_icmp_and_get_phone(0, packet, header); 1476 if (phone >= 0) { 1477 1477 /* Unreachable ICMP */ 1478 icmp_destination_unreachable_msg( sess,1478 icmp_destination_unreachable_msg(phone, 1479 1479 ICMP_HOST_UNREACH, 0, packet); 1480 1480 } … … 1493 1493 } 1494 1494 1495 sess = ip_prepare_icmp_and_get_session(0, packet, header);1496 if ( sess) {1495 phone = ip_prepare_icmp_and_get_phone(0, packet, header); 1496 if (phone >= 0) { 1497 1497 /* Unreachable ICMP if no routing */ 1498 icmp_destination_unreachable_msg( sess, ICMP_HOST_UNREACH, 0,1498 icmp_destination_unreachable_msg(phone, ICMP_HOST_UNREACH, 0, 1499 1499 packet); 1500 1500 } … … 1503 1503 } 1504 1504 1505 /** Return the device packet dimensions for sending.1506 * 1507 * @param[in] device_id Device identifier.1508 * @param[ out] addr_len Minimum reserved address length.1509 * @param[ out] prefix Minimum reserved prefix size.1510 * @param[out] content Maximum content size.1511 * @param[out] suffix Minimum reserved suffix size.1512 * 1513 * @ return EOK on success.1514 * 1505 /** Returns the device packet dimensions for sending. 1506 * 1507 * @param[in] phone The service module phone. 1508 * @param[in] message The service specific message. 1509 * @param[in] device_id The device identifier. 1510 * @param[out] addr_len The minimum reserved address length. 1511 * @param[out] prefix The minimum reserved prefix size. 1512 * @param[out] content The maximum content size. 1513 * @param[out] suffix The minimum reserved suffix size. 1514 * @return EOK on success. 1515 1515 */ 1516 1516 static int ip_packet_size_message(device_id_t device_id, size_t *addr_len, … … 1595 1595 * @param[in,out] icall Message parameters. 1596 1596 * @param[in] arg Local argument. 1597 *1598 1597 */ 1599 1598 static void ip_receiver(ipc_callid_t iid, ipc_call_t *icall, void *arg) … … 1611 1610 1612 1611 case NET_IL_RECEIVED: 1613 rc = packet_translate_remote(ip_globals.net_ sess, &packet,1612 rc = packet_translate_remote(ip_globals.net_phone, &packet, 1614 1613 IPC_GET_PACKET(*icall)); 1615 1614 if (rc == EOK) { … … 1638 1637 } 1639 1638 1640 /** Register the transport layer protocol.1639 /** Registers the transport layer protocol. 1641 1640 * 1642 1641 * The traffic of this protocol will be supplied using either the receive 1643 1642 * function or IPC message. 1644 1643 * 1645 * @param[in] protocol Transport layer module protocol. 1646 * @param[in] service Transport layer module service. 1647 * @param[in] sess Transport layer module session. 1648 * @param[in] received_msg Receiving function. 1649 * 1650 * @return EOK on success. 1651 * @return EINVAL if the protocol parameter and/or the service 1652 * parameter is zero. 1653 * @return EINVAL if the phone parameter is not a positive number 1654 * and the tl_receive_msg is NULL. 1655 * @return ENOMEM if there is not enough memory left. 1656 * 1657 */ 1658 static int ip_register(int protocol, services_t service, async_sess_t *sess, 1644 * @param[in] protocol The transport layer module protocol. 1645 * @param[in] service The transport layer module service. 1646 * @param[in] phone The transport layer module phone. 1647 * @param[in] received_msg The receiving function. 1648 * @return EOK on success. 1649 * @return EINVAL if the protocol parameter and/or the service 1650 * parameter is zero. 1651 * @return EINVAL if the phone parameter is not a positive number 1652 * and the tl_receive_msg is NULL. 1653 * @return ENOMEM if there is not enough memory left. 1654 */ 1655 static int 1656 ip_register(int protocol, services_t service, int phone, 1659 1657 tl_received_msg_t received_msg) 1660 1658 { … … 1662 1660 int index; 1663 1661 1664 if ( (!protocol) || (!service) || ((!sess) && (!received_msg)))1662 if (!protocol || !service || ((phone < 0) && !received_msg)) 1665 1663 return EINVAL; 1666 1664 1667 1665 proto = (ip_proto_t *) malloc(sizeof(ip_protos_t)); 1668 1666 if (!proto) … … 1671 1669 proto->protocol = protocol; 1672 1670 proto->service = service; 1673 proto-> sess = sess;1671 proto->phone = phone; 1674 1672 proto->received_msg = received_msg; 1675 1673 … … 1683 1681 fibril_rwlock_write_unlock(&ip_globals.protos_lock); 1684 1682 1685 printf("%s: Protocol registered (protocol: %d )\n",1686 NAME, proto->protocol );1683 printf("%s: Protocol registered (protocol: %d, phone: %d)\n", 1684 NAME, proto->protocol, proto->phone); 1687 1685 1688 1686 return EOK; 1689 1687 } 1690 1688 1691 static int ip_add_route_req_local(device_id_t device_id, in_addr_t address, 1689 1690 static int 1691 ip_add_route_req_local(int ip_phone, device_id_t device_id, in_addr_t address, 1692 1692 in_addr_t netmask, in_addr_t gateway) 1693 1693 { … … 1723 1723 } 1724 1724 1725 static int ip_set_gateway_req_local(device_id_t device_id, in_addr_t gateway) 1725 static int 1726 ip_set_gateway_req_local(int ip_phone, device_id_t device_id, in_addr_t gateway) 1726 1727 { 1727 1728 ip_netif_t *netif; … … 1747 1748 /** Notify the IP module about the received error notification packet. 1748 1749 * 1749 * @param[in] device_id Device identifier. 1750 * @param[in] packet Received packet or the received packet queue. 1751 * @param[in] target Target internetwork module service to be 1752 * delivered to. 1753 * @param[in] error Packet error reporting service. Prefixes the 1754 * received packet. 1755 * 1756 * @return EOK on success. 1757 * 1758 */ 1759 static int ip_received_error_msg_local(device_id_t device_id, 1750 * @param[in] ip_phone The IP module phone used for (semi)remote calls. 1751 * @param[in] device_id The device identifier. 1752 * @param[in] packet The received packet or the received packet queue. 1753 * @param[in] target The target internetwork module service to be 1754 * delivered to. 1755 * @param[in] error The packet error reporting service. Prefixes the 1756 * received packet. 1757 * @return EOK on success. 1758 * 1759 */ 1760 static int 1761 ip_received_error_msg_local(int ip_phone, device_id_t device_id, 1760 1762 packet_t *packet, services_t target, services_t error) 1761 1763 { … … 1802 1804 address.value = (uint8_t *) &header->destination_address; 1803 1805 address.length = sizeof(header->destination_address); 1804 arp_clear_address_req(netif->arp-> sess,1806 arp_clear_address_req(netif->arp->phone, 1805 1807 netif->device_id, SERVICE_IP, &address); 1806 1808 } … … 1816 1818 } 1817 1819 1818 static int ip_get_route_req_local(ip_protocol_t protocol, 1820 static int 1821 ip_get_route_req_local(int ip_phone, ip_protocol_t protocol, 1819 1822 const struct sockaddr *destination, socklen_t addrlen, 1820 1823 device_id_t *device_id, void **header, size_t *headerlen) … … 1917 1920 return EOK; 1918 1921 1919 async_sess_t *callback = 1920 async_callback_receive_start(EXCHANGE_SERIALIZE, call); 1921 if (callback) 1922 switch (IPC_GET_IMETHOD(*call)) { 1923 case IPC_M_CONNECT_TO_ME: 1922 1924 return ip_register(IL_GET_PROTO(*call), IL_GET_SERVICE(*call), 1923 callback, NULL); 1924 1925 switch (IPC_GET_IMETHOD(*call)) { 1925 IPC_GET_PHONE(*call), NULL); 1926 1926 1927 case NET_IP_DEVICE: 1927 return ip_device_req_local( IPC_GET_DEVICE(*call),1928 return ip_device_req_local(0, IPC_GET_DEVICE(*call), 1928 1929 IPC_GET_SERVICE(*call)); 1929 1930 1930 1931 case NET_IP_RECEIVED_ERROR: 1931 rc = packet_translate_remote(ip_globals.net_ sess, &packet,1932 rc = packet_translate_remote(ip_globals.net_phone, &packet, 1932 1933 IPC_GET_PACKET(*call)); 1933 1934 if (rc != EOK) 1934 1935 return rc; 1935 return ip_received_error_msg_local( IPC_GET_DEVICE(*call),1936 return ip_received_error_msg_local(0, IPC_GET_DEVICE(*call), 1936 1937 packet, IPC_GET_TARGET(*call), IPC_GET_ERROR(*call)); 1937 1938 1938 1939 case NET_IP_ADD_ROUTE: 1939 return ip_add_route_req_local( IPC_GET_DEVICE(*call),1940 return ip_add_route_req_local(0, IPC_GET_DEVICE(*call), 1940 1941 IP_GET_ADDRESS(*call), IP_GET_NETMASK(*call), 1941 1942 IP_GET_GATEWAY(*call)); 1942 1943 1943 1944 case NET_IP_SET_GATEWAY: 1944 return ip_set_gateway_req_local( IPC_GET_DEVICE(*call),1945 return ip_set_gateway_req_local(0, IPC_GET_DEVICE(*call), 1945 1946 IP_GET_GATEWAY(*call)); 1946 1947 … … 1951 1952 return rc; 1952 1953 1953 rc = ip_get_route_req_local( IP_GET_PROTOCOL(*call), addr,1954 rc = ip_get_route_req_local(0, IP_GET_PROTOCOL(*call), addr, 1954 1955 (socklen_t) addrlen, &device_id, &header, &headerlen); 1955 1956 if (rc != EOK) … … 1982 1983 1983 1984 case NET_IP_SEND: 1984 rc = packet_translate_remote(ip_globals.net_ sess, &packet,1985 rc = packet_translate_remote(ip_globals.net_phone, &packet, 1985 1986 IPC_GET_PACKET(*call)); 1986 1987 if (rc != EOK) 1987 1988 return rc; 1988 1989 1989 return ip_send_msg_local( IPC_GET_DEVICE(*call), packet, 0,1990 return ip_send_msg_local(0, IPC_GET_DEVICE(*call), packet, 0, 1990 1991 IPC_GET_ERROR(*call)); 1991 1992 }
Note:
See TracChangeset
for help on using the changeset viewer.