Changeset b910455 in mainline for uspace/lib/net/tl/socket_core.c


Ignore:
Timestamp:
2011-04-07T09:46:11Z (13 years ago)
Author:
Jakub Jermar <jakub@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
6639ae1
Parents:
f6bffee (diff), 8e80d3f (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.
Message:

Merge mainline changes.

File:
1 edited

Legend:

Unmodified
Added
Removed

  • uspace/lib/net/tl/socket_core.c

    rf6bffee rb910455  
    9191        int packet_id;
    9292
    93         // if bound
     93        /* If bound */
    9494        if (socket->port) {
    95                 // release the port
     95                /* Release the port */
    9696                socket_port_release(global_sockets, socket);
    9797        }
    9898       
    99         // release all received packets
     99        /* Release all received packets */
    100100        while ((packet_id = dyn_fifo_pop(&socket->received)) >= 0)
    101101                pq_release_remote(packet_phone, packet_id);
    … …  
    107107                socket_release(socket);
    108108
    109         socket_cores_exclude(local_sockets, socket->socket_id);
     109        socket_cores_exclude(local_sockets, socket->socket_id, free);
    110110}
    111111
    … …  
    166166        int rc;
    167167
    168         // create a wrapper
     168        /* Create a wrapper */
    169169        socket_ref = malloc(sizeof(*socket_ref));
    170170        if (!socket_ref)
    … …  
    172172
    173173        *socket_ref = socket;
    174         // add the wrapper
     174        /* Add the wrapper */
    175175        rc = socket_port_map_add(&socket_port->map, key, key_length,
    176176            socket_ref);
    … …  
    206206        int rc;
    207207
    208         // create a wrapper
     208        /* Create a wrapper */
    209209        socket_port = malloc(sizeof(*socket_port));
    210210        if (!socket_port)
    … …  
    221221                goto fail;
    222222       
    223         // register the incomming port
     223        /* Register the incoming port */
    224224        rc = socket_ports_add(global_sockets, port, socket_port);
    225225        if (rc < 0)
    … …  
    230230
    231231fail:
    232         socket_port_map_destroy(&socket_port->map);
     232        socket_port_map_destroy(&socket_port->map, free);
    233233        free(socket_port);
    234234        return rc;
    … …  
    277277               
    278278                address_in = (struct sockaddr_in *) addr;
    279                 // find the socket
     279                /* Find the socket */
    280280                socket = socket_cores_find(local_sockets, socket_id);
    281281                if (!socket)
    282282                        return ENOTSOCK;
    283283               
    284                 // bind a free port?
     284                /* Bind a free port? */
    285285                if (address_in->sin_port <= 0)
    286286                        return socket_bind_free_port(global_sockets, socket,
    287287                             free_ports_start, free_ports_end, last_used_port);
    288288               
    289                 // try to find the port
     289                /* Try to find the port */
    290290                socket_port = socket_ports_find(global_sockets,
    291291                    ntohs(address_in->sin_port));
    292292                if (socket_port) {
    293                         // already used
     293                        /* Already used */
    294294                        return EADDRINUSE;
    295295                }
    296296               
    297                 // if bound
     297                /* If bound */
    298298                if (socket->port) {
    299                         // release the port
     299                        /* Release the port */
    300300                        socket_port_release(global_sockets, socket);
    301301                }
    … …  
    306306               
    307307        case AF_INET6:
    308                 // TODO IPv6
     308                /* TODO IPv6 */
    309309                break;
    310310        }
    … …  
    333333        int index;
    334334
    335         // from the last used one
     335        /* From the last used one */
    336336        index = last_used_port;
    337337       
    … …  
    339339                ++index;
    340340               
    341                 // til the range end
     341                /* Till the range end */
    342342                if (index >= free_ports_end) {
    343                         // start from the range beginning
     343                        /* Start from the range beginning */
    344344                        index = free_ports_start - 1;
    345345                        do {
    346346                                ++index;
    347                                 // til the last used one
     347                                /* Till the last used one */
    348348                                if (index >= last_used_port) {
    349                                         // none found
     349                                        /* None found */
    350350                                        return ENOTCONN;
    351351                                }
    352352                        } while (socket_ports_find(global_sockets, index));
    353353                       
    354                         // found, break immediately
     354                        /* Found, break immediately */
    355355                        break;
    356356                }
    … …  
    384384                        socket_id = 1;
    385385                        ++count;
    386                 // only this branch for last_id
     386                /* Only this branch for last_id */
    387387                } else {
    388388                        if (socket_id < INT_MAX) {
    … …  
    425425                return EINVAL;
    426426       
    427         // store the socket
     427        /* Store the socket */
    428428        if (*socket_id <= 0) {
    429429                positive = (*socket_id == 0);
    … …  
    441441                return ENOMEM;
    442442       
    443         // initialize
     443        /* Initialize */
    444444        socket->phone = app_phone;
    445445        socket->port = -1;
    … …  
    493493        int accepted_id;
    494494
    495         // find the socket
     495        /* Find the socket */
    496496        socket = socket_cores_find(local_sockets, socket_id);
    497497        if (!socket)
    498498                return ENOTSOCK;
    499499       
    500         // destroy all accepted sockets
     500        /* Destroy all accepted sockets */
    501501        while ((accepted_id = dyn_fifo_pop(&socket->accepted)) >= 0)
    502502                socket_destroy(packet_phone, accepted_id, local_sockets,
    … …  
    535535        next_packet = pq_next(packet);
    536536        if (!next_packet) {
    537                 // write all if only one fragment
     537                /* Write all if only one fragment */
    538538                rc = data_reply(packet_get_data(packet),
    539539                    packet_get_data_length(packet));
    540540                if (rc != EOK)
    541541                        return rc;
    542                 // store the total length
     542                /* Store the total length */
    543543                *length = packet_get_data_length(packet);
    544544        } else {
    545                 // count the packet fragments
     545                /* Count the packet fragments */
    546546                fragments = 1;
    547547                next_packet = pq_next(packet);
    … …  
    549549                        ++fragments;
    550550               
    551                 // compute and store the fragment lengths
     551                /* Compute and store the fragment lengths */
    552552                lengths = (size_t *) malloc(sizeof(size_t) * fragments +
    553553                    sizeof(size_t));
    … …  
    565565                }
    566566               
    567                 // write the fragment lengths
     567                /* Write the fragment lengths */
    568568                rc = data_reply(lengths, sizeof(int) * (fragments + 1));
    569569                if (rc != EOK) {
    … …  
    573573                next_packet = packet;
    574574               
    575                 // write the fragments
     575                /* Write the fragments */
    576576                for (index = 0; index < fragments; ++index) {
    577577                        rc = data_reply(packet_get_data(next_packet),
    … …  
    584584                }
    585585               
    586                 // store the total length
     586                /* Store the total length */
    587587                *length = lengths[fragments];
    588588                free(lengths);
    … …  
    636636                return;
    637637       
    638         // find ports
     638        /* Find ports */
    639639        socket_port = socket_ports_find(global_sockets, socket->port);
    640640        if (socket_port) {
    641                 // find the socket
     641                /* Find the socket */
    642642                socket_ref = socket_port_map_find(&socket_port->map,
    643643                    socket->key, socket->key_length);
    … …  
    646646                        --socket_port->count;
    647647                       
    648                         // release if empty
     648                        /* Release if empty */
    649649                        if (socket_port->count <= 0) {
    650                                 // destroy the map
    651                                 socket_port_map_destroy(&socket_port->map);
    652                                 // release the port
     650                                /* Destroy the map */
     651                                socket_port_map_destroy(&socket_port->map, free);
     652                                /* Release the port */
    653653                                socket_ports_exclude(global_sockets,
    654                                     socket->port);
     654                                    socket->port, free);
    655655                        } else {
    656                                 // remove
     656                                /* Remove */
    657657                                socket_port_map_exclude(&socket_port->map,
    658                                     socket->key, socket->key_length);
     658                                    socket->key, socket->key_length, free);
    659659                        }
    660660                }
    … …  
    685685        int rc;
    686686
    687         // find ports
     687        /* Find ports */
    688688        socket_port = socket_ports_find(global_sockets, port);
    689689        if (!socket_port)
    690690                return ENOENT;
    691691       
    692         // add the socket
     692        /* Add the socket */
    693693        rc = socket_port_add_core(socket_port, socket, key, key_length);
    694694        if (rc != EOK)
Note: See TracChangeset for help on using the changeset viewer.