Changeset 28a3e74 in mainline for uspace/lib/net
- Timestamp:
- 2011-04-02T09:22:46Z (14 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 250dbef, b2a081ae
- Parents:
- ea53529
- Location:
- uspace/lib/net
- Files:
-
- 8 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/lib/net/generic/generic.c
rea53529 r28a3e74 106 106 return EBADMEM; 107 107 108 / / request the address108 /* Request the address */ 109 109 message_id = async_send_1(phone, (sysarg_t) message, 110 110 (sysarg_t) device_id, NULL); … … 112 112 async_wait_for(message_id, &result); 113 113 114 / / if not successful114 /* If not successful */ 115 115 if ((string == EOK) && (result != EOK)) { 116 / / clear the data116 /* Clear the data */ 117 117 free(*address); 118 118 free(*data); … … 242 242 return EBADMEM; 243 243 244 / / request the translation244 /* Request the translation */ 245 245 message_id = async_send_3(phone, (sysarg_t) message, 246 246 (sysarg_t) device_id, (sysarg_t) count, (sysarg_t) service, NULL); … … 249 249 async_wait_for(message_id, &result); 250 250 251 / / if not successful251 /* If not successful */ 252 252 if ((string == EOK) && (result != EOK)) { 253 / / clear the data253 /* Clear the data */ 254 254 free(*translation); 255 255 free(*data); -
uspace/lib/net/generic/net_checksum.c
rea53529 r28a3e74 52 52 uint16_t compact_checksum(uint32_t sum) 53 53 { 54 / / shorten to the 16 bits54 /* Shorten to the 16 bits */ 55 55 while (sum >> 16) 56 56 sum = (sum & 0xffff) + (sum >> 16); … … 72 72 size_t index; 73 73 74 / / sum all the 16 bit fields74 /* Sum all the 16 bit fields */ 75 75 for (index = 0; index + 1 < length; index += 2) 76 76 seed += (data[index] << 8) + data[index + 1]; 77 77 78 / / last odd byte with zero padding78 /* Last odd byte with zero padding */ 79 79 if (index + 1 == length) 80 80 seed += data[index] << 8; … … 94 94 size_t index; 95 95 96 / / process full bytes96 /* Process full bytes */ 97 97 while (length >= 8) { 98 / / add the data98 /* Add the data */ 99 99 seed ^= (*data) << 24; 100 100 101 / / for each added bit101 /* For each added bit */ 102 102 for (index = 0; index < 8; ++index) { 103 / / if the first bit is set103 /* If the first bit is set */ 104 104 if (seed & 0x80000000) { 105 / / shift and divide the checksum105 /* Shift and divide the checksum */ 106 106 seed = (seed << 1) ^ ((uint32_t) CRC_DIVIDER_BE); 107 107 } else { 108 / / shift otherwise108 /* shift otherwise */ 109 109 seed <<= 1; 110 110 } 111 111 } 112 112 113 / / move to the next byte113 /* Move to the next byte */ 114 114 ++data; 115 115 length -= 8; 116 116 } 117 117 118 / / process the odd bits118 /* Process the odd bits */ 119 119 if (length > 0) { 120 / / add the data with zero padding120 /* Add the data with zero padding */ 121 121 seed ^= ((*data) & (0xff << (8 - length))) << 24; 122 122 123 / / for each added bit123 /* For each added bit */ 124 124 for (index = 0; index < length; ++index) { 125 / / if the first bit is set125 /* If the first bit is set */ 126 126 if (seed & 0x80000000) { 127 / / shift and divide the checksum127 /* Shift and divide the checksum */ 128 128 seed = (seed << 1) ^ ((uint32_t) CRC_DIVIDER_BE); 129 129 } else { 130 / / shift otherwise130 /* Shift otherwise */ 131 131 seed <<= 1; 132 132 } … … 148 148 size_t index; 149 149 150 / / process full bytes150 /* Process full bytes */ 151 151 while (length >= 8) { 152 / / add the data152 /* Add the data */ 153 153 seed ^= (*data); 154 154 155 / / for each added bit155 /* For each added bit */ 156 156 for (index = 0; index < 8; ++index) { 157 / / if the last bit is set157 /* If the last bit is set */ 158 158 if (seed & 1) { 159 / / shift and divide the checksum159 /* Shift and divide the checksum */ 160 160 seed = (seed >> 1) ^ ((uint32_t) CRC_DIVIDER_LE); 161 161 } else { 162 / / shift otherwise162 /* Shift otherwise */ 163 163 seed >>= 1; 164 164 } 165 165 } 166 166 167 / / move to the next byte167 /* Move to the next byte */ 168 168 ++data; 169 169 length -= 8; 170 170 } 171 171 172 / / process the odd bits172 /* Process the odd bits */ 173 173 if (length > 0) { 174 / / add the data with zero padding174 /* Add the data with zero padding */ 175 175 seed ^= (*data) >> (8 - length); 176 176 177 177 for (index = 0; index < length; ++index) { 178 / / if the last bit is set178 /* If the last bit is set */ 179 179 if (seed & 1) { 180 / / shift and divide the checksum180 /* Shift and divide the checksum */ 181 181 seed = (seed >> 1) ^ ((uint32_t) CRC_DIVIDER_LE); 182 182 } else { 183 / / shift otherwise183 /* Shift otherwise */ 184 184 seed >>= 1; 185 185 } … … 198 198 uint16_t flip_checksum(uint16_t checksum) 199 199 { 200 / / flip, zero is returned as 0xFFFF (not flipped)200 /* Flip, zero is returned as 0xFFFF (not flipped) */ 201 201 checksum = ~checksum; 202 202 return checksum ? checksum : IP_CHECKSUM_ZERO; … … 216 216 uint16_t ip_checksum(uint8_t *data, size_t length) 217 217 { 218 / / compute, compact and flip the data checksum218 /* Compute, compact and flip the data checksum */ 219 219 return flip_checksum(compact_checksum(compute_checksum(0, data, 220 220 length))); -
uspace/lib/net/generic/packet_client.c
rea53529 r28a3e74 267 267 return NULL; 268 268 269 / / get a new packet269 /* Get a new packet */ 270 270 copy = packet_get_4_remote(phone, PACKET_DATA_LENGTH(packet), 271 271 PACKET_MAX_ADDRESS_LENGTH(packet), packet->max_prefix, … … 274 274 return NULL; 275 275 276 / / get addresses276 /* Get addresses */ 277 277 addrlen = packet_get_addr(packet, &src, &dest); 278 / / copy data278 /* Copy data */ 279 279 if ((packet_copy_data(copy, packet_get_data(packet), 280 280 PACKET_DATA_LENGTH(packet)) == EOK) && 281 / / copy addresses if present281 /* Copy addresses if present */ 282 282 ((addrlen <= 0) || 283 283 (packet_set_addr(copy, src, dest, addrlen) == EOK))) { -
uspace/lib/net/il/ip_client.c
rea53529 r28a3e74 123 123 return EOK; 124 124 125 / / TODO IPv6125 /* TODO IPv6 */ 126 126 /* case AF_INET6: 127 127 if (addrlen != sizeof(struct sockaddr_in6)) … … 159 159 size_t padding; 160 160 161 // compute the padding if IP options are set 162 // multiple of 4 bytes 161 /* 162 * Compute the padding if IP options are set 163 * multiple of 4 bytes 164 */ 163 165 padding = ipopt_length % 4; 164 166 if (padding) { … … 167 169 } 168 170 169 / / prefix the header171 /* Prefix the header */ 170 172 data = (uint8_t *) packet_prefix(packet, sizeof(ip_header_t) + padding); 171 173 if (!data) 172 174 return ENOMEM; 173 175 174 / / add the padding176 /* Add the padding */ 175 177 while (padding--) 176 178 data[sizeof(ip_header_t) + padding] = IPOPT_NOOP; 177 179 178 / / set the header180 /* Set the header */ 179 181 header = (ip_header_t *) data; 180 182 header->header_length = IP_COMPUTE_HEADER_LENGTH(sizeof(ip_header_t) + … … 256 258 header_in->data_length = htons(data_length); 257 259 return EOK; 258 / / TODO IPv6260 /* TODO IPv6 */ 259 261 } else { 260 262 return EINVAL; -
uspace/lib/net/include/ip_client.h
rea53529 r28a3e74 54 54 socklen_t, struct sockaddr *, socklen_t, size_t, void **, size_t *); 55 55 56 / / TODO ipopt manipulation56 /* TODO ipopt manipulation */ 57 57 58 58 #endif -
uspace/lib/net/tl/icmp_client.c
rea53529 r28a3e74 81 81 *mtu = header->un.frag.mtu; 82 82 83 / / remove debug dump83 /* Remove debug dump */ 84 84 #ifdef CONFIG_DEBUG 85 85 printf("ICMP error %d (%d) in packet %d\n", header->type, header->code, -
uspace/lib/net/tl/socket_core.c
rea53529 r28a3e74 91 91 int packet_id; 92 92 93 / / if bound93 /* If bound */ 94 94 if (socket->port) { 95 / / release the port95 /* Release the port */ 96 96 socket_port_release(global_sockets, socket); 97 97 } 98 98 99 / / release all received packets99 /* Release all received packets */ 100 100 while ((packet_id = dyn_fifo_pop(&socket->received)) >= 0) 101 101 pq_release_remote(packet_phone, packet_id); … … 166 166 int rc; 167 167 168 / / create a wrapper168 /* Create a wrapper */ 169 169 socket_ref = malloc(sizeof(*socket_ref)); 170 170 if (!socket_ref) … … 172 172 173 173 *socket_ref = socket; 174 / / add the wrapper174 /* Add the wrapper */ 175 175 rc = socket_port_map_add(&socket_port->map, key, key_length, 176 176 socket_ref); … … 206 206 int rc; 207 207 208 / / create a wrapper208 /* Create a wrapper */ 209 209 socket_port = malloc(sizeof(*socket_port)); 210 210 if (!socket_port) … … 221 221 goto fail; 222 222 223 / / register the incomming port223 /* Register the incoming port */ 224 224 rc = socket_ports_add(global_sockets, port, socket_port); 225 225 if (rc < 0) … … 277 277 278 278 address_in = (struct sockaddr_in *) addr; 279 / / find the socket279 /* Find the socket */ 280 280 socket = socket_cores_find(local_sockets, socket_id); 281 281 if (!socket) 282 282 return ENOTSOCK; 283 283 284 / / bind a free port?284 /* Bind a free port? */ 285 285 if (address_in->sin_port <= 0) 286 286 return socket_bind_free_port(global_sockets, socket, 287 287 free_ports_start, free_ports_end, last_used_port); 288 288 289 / / try to find the port289 /* Try to find the port */ 290 290 socket_port = socket_ports_find(global_sockets, 291 291 ntohs(address_in->sin_port)); 292 292 if (socket_port) { 293 / / already used293 /* Already used */ 294 294 return EADDRINUSE; 295 295 } 296 296 297 / / if bound297 /* If bound */ 298 298 if (socket->port) { 299 / / release the port299 /* Release the port */ 300 300 socket_port_release(global_sockets, socket); 301 301 } … … 306 306 307 307 case AF_INET6: 308 / / TODO IPv6308 /* TODO IPv6 */ 309 309 break; 310 310 } … … 333 333 int index; 334 334 335 / / from the last used one335 /* From the last used one */ 336 336 index = last_used_port; 337 337 … … 339 339 ++index; 340 340 341 / / til the range end341 /* Till the range end */ 342 342 if (index >= free_ports_end) { 343 / / start from the range beginning343 /* Start from the range beginning */ 344 344 index = free_ports_start - 1; 345 345 do { 346 346 ++index; 347 / / til the last used one347 /* Till the last used one */ 348 348 if (index >= last_used_port) { 349 / / none found349 /* None found */ 350 350 return ENOTCONN; 351 351 } 352 352 } while (socket_ports_find(global_sockets, index)); 353 353 354 / / found, break immediately354 /* Found, break immediately */ 355 355 break; 356 356 } … … 384 384 socket_id = 1; 385 385 ++count; 386 / / only this branch for last_id386 /* Only this branch for last_id */ 387 387 } else { 388 388 if (socket_id < INT_MAX) { … … 425 425 return EINVAL; 426 426 427 / / store the socket427 /* Store the socket */ 428 428 if (*socket_id <= 0) { 429 429 positive = (*socket_id == 0); … … 441 441 return ENOMEM; 442 442 443 / / initialize443 /* Initialize */ 444 444 socket->phone = app_phone; 445 445 socket->port = -1; … … 493 493 int accepted_id; 494 494 495 / / find the socket495 /* Find the socket */ 496 496 socket = socket_cores_find(local_sockets, socket_id); 497 497 if (!socket) 498 498 return ENOTSOCK; 499 499 500 / / destroy all accepted sockets500 /* Destroy all accepted sockets */ 501 501 while ((accepted_id = dyn_fifo_pop(&socket->accepted)) >= 0) 502 502 socket_destroy(packet_phone, accepted_id, local_sockets, … … 535 535 next_packet = pq_next(packet); 536 536 if (!next_packet) { 537 / / write all if only one fragment537 /* Write all if only one fragment */ 538 538 rc = data_reply(packet_get_data(packet), 539 539 packet_get_data_length(packet)); 540 540 if (rc != EOK) 541 541 return rc; 542 / / store the total length542 /* Store the total length */ 543 543 *length = packet_get_data_length(packet); 544 544 } else { 545 / / count the packet fragments545 /* Count the packet fragments */ 546 546 fragments = 1; 547 547 next_packet = pq_next(packet); … … 549 549 ++fragments; 550 550 551 / / compute and store the fragment lengths551 /* Compute and store the fragment lengths */ 552 552 lengths = (size_t *) malloc(sizeof(size_t) * fragments + 553 553 sizeof(size_t)); … … 565 565 } 566 566 567 / / write the fragment lengths567 /* Write the fragment lengths */ 568 568 rc = data_reply(lengths, sizeof(int) * (fragments + 1)); 569 569 if (rc != EOK) { … … 573 573 next_packet = packet; 574 574 575 / / write the fragments575 /* Write the fragments */ 576 576 for (index = 0; index < fragments; ++index) { 577 577 rc = data_reply(packet_get_data(next_packet), … … 584 584 } 585 585 586 / / store the total length586 /* Store the total length */ 587 587 *length = lengths[fragments]; 588 588 free(lengths); … … 636 636 return; 637 637 638 / / find ports638 /* Find ports */ 639 639 socket_port = socket_ports_find(global_sockets, socket->port); 640 640 if (socket_port) { 641 / / find the socket641 /* Find the socket */ 642 642 socket_ref = socket_port_map_find(&socket_port->map, 643 643 socket->key, socket->key_length); … … 646 646 --socket_port->count; 647 647 648 / / release if empty648 /* Release if empty */ 649 649 if (socket_port->count <= 0) { 650 / / destroy the map650 /* Destroy the map */ 651 651 socket_port_map_destroy(&socket_port->map, free); 652 / / release the port652 /* Release the port */ 653 653 socket_ports_exclude(global_sockets, 654 654 socket->port, free); 655 655 } else { 656 / / remove656 /* Remove */ 657 657 socket_port_map_exclude(&socket_port->map, 658 658 socket->key, socket->key_length, free); … … 685 685 int rc; 686 686 687 / / find ports687 /* Find ports */ 688 688 socket_port = socket_ports_find(global_sockets, port); 689 689 if (!socket_port) 690 690 return ENOENT; 691 691 692 / / add the socket692 /* Add the socket */ 693 693 rc = socket_port_add_core(socket_port, socket, key, key_length); 694 694 if (rc != EOK) -
uspace/lib/net/tl/tl_common.c
rea53529 r28a3e74 255 255 int length; 256 256 257 / / detach the first packet and release the others257 /* Detach the first packet and release the others */ 258 258 next = pq_detach(packet); 259 259 if (next) … … 262 262 length = packet_get_addr(packet, &src, NULL); 263 263 if ((length > 0) && (!error) && (icmp_phone >= 0) && 264 // set both addresses to the source one (avoids the source address 265 // deletion before setting the destination one) 264 /* 265 * Set both addresses to the source one (avoids the source address 266 * deletion before setting the destination one) 267 */ 266 268 (packet_set_addr(packet, src, src, (size_t) length) == EOK)) { 267 269 return EOK; … … 299 301 return EINVAL; 300 302 301 / / get the data length303 /* Get the data length */ 302 304 if (!async_data_write_receive(&callid, &length)) 303 305 return EINVAL; 304 306 305 / / get a new packet307 /* Get a new packet */ 306 308 *packet = packet_get_4_remote(packet_phone, length, dimension->addr_len, 307 309 prefix + dimension->prefix, dimension->suffix); … … 309 311 return ENOMEM; 310 312 311 / / allocate space in the packet313 /* Allocate space in the packet */ 312 314 data = packet_suffix(*packet, length); 313 315 if (!data) { … … 316 318 } 317 319 318 / / read the data into the packet320 /* Read the data into the packet */ 319 321 rc = async_data_write_finalize(callid, data, length); 320 322 if (rc != EOK) { … … 323 325 } 324 326 325 / / set the packet destination address327 /* Set the packet destination address */ 326 328 rc = packet_set_addr(*packet, NULL, (uint8_t *) addr, addrlen); 327 329 if (rc != EOK) {
Note:
See TracChangeset
for help on using the changeset viewer.