Changeset 4e5c7ba in mainline for uspace/srv/net/tl/tcp/tcp.c


Ignore:
Timestamp:
2010-11-18T22:36:12Z (14 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
f772bc55
Parents:
cb569e6
Message:

Remove xxx_ref typedefs (part 1).

File:
1 edited

Legend:

Unmodified
Added
Removed

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

    rcb569e6 r4e5c7ba  
    166166
    167167static int tcp_release_and_return(packet_t, int);
    168 static void tcp_prepare_operation_header(socket_core_ref, tcp_socket_data_ref,
    169     tcp_header_ref, int synchronize, int);
     168static void tcp_prepare_operation_header(socket_core_ref, tcp_socket_data_t *,
     169    tcp_header_t *, int synchronize, int);
    170170static int tcp_prepare_timeout(int (*)(void *), socket_core_ref,
    171     tcp_socket_data_ref, size_t, tcp_socket_state_t, suseconds_t, int);
     171    tcp_socket_data_t *, size_t, tcp_socket_state_t, suseconds_t, int);
    172172static void tcp_free_socket_data(socket_core_ref);
    173173
    … …  
    179179static int tcp_connect_core(socket_core_ref, socket_cores_ref,
    180180    struct sockaddr *, socklen_t);
    181 static int tcp_queue_prepare_packet(socket_core_ref, tcp_socket_data_ref,
     181static int tcp_queue_prepare_packet(socket_core_ref, tcp_socket_data_t *,
    182182    packet_t, size_t);
    183 static int tcp_queue_packet(socket_core_ref, tcp_socket_data_ref, packet_t,
     183static int tcp_queue_packet(socket_core_ref, tcp_socket_data_t *, packet_t,
    184184    size_t);
    185 static packet_t tcp_get_packets_to_send(socket_core_ref, tcp_socket_data_ref);
     185static packet_t tcp_get_packets_to_send(socket_core_ref, tcp_socket_data_t *);
    186186static void tcp_send_packets(device_id_t, packet_t);
    187187
    188 static void tcp_process_acknowledgement(socket_core_ref, tcp_socket_data_ref,
    189     tcp_header_ref);
    190 static packet_t tcp_send_prepare_packet(socket_core_ref, tcp_socket_data_ref,
     188static void tcp_process_acknowledgement(socket_core_ref, tcp_socket_data_t *,
     189    tcp_header_t *);
     190static packet_t tcp_send_prepare_packet(socket_core_ref, tcp_socket_data_t *,
    191191    packet_t, size_t, size_t);
    192 static packet_t tcp_prepare_copy(socket_core_ref, tcp_socket_data_ref, packet_t,
     192static packet_t tcp_prepare_copy(socket_core_ref, tcp_socket_data_t *, packet_t,
    193193    size_t, size_t);
    194 /* static */ void tcp_retransmit_packet(socket_core_ref, tcp_socket_data_ref,
     194/* static */ void tcp_retransmit_packet(socket_core_ref, tcp_socket_data_t *,
    195195    size_t);
    196196static int tcp_create_notification_packet(packet_t *, socket_core_ref,
    197     tcp_socket_data_ref, int, int);
    198 static void tcp_refresh_socket_data(tcp_socket_data_ref);
    199 
    200 static void tcp_initialize_socket_data(tcp_socket_data_ref);
    201 
    202 static int tcp_process_listen(socket_core_ref, tcp_socket_data_ref,
    203     tcp_header_ref, packet_t, struct sockaddr *, struct sockaddr *, size_t);
    204 static int tcp_process_syn_sent(socket_core_ref, tcp_socket_data_ref,
    205     tcp_header_ref, packet_t);
    206 static int tcp_process_syn_received(socket_core_ref, tcp_socket_data_ref,
    207     tcp_header_ref, packet_t);
    208 static int tcp_process_established(socket_core_ref, tcp_socket_data_ref,
    209     tcp_header_ref, packet_t, int, size_t);
    210 static int tcp_queue_received_packet(socket_core_ref, tcp_socket_data_ref,
     197    tcp_socket_data_t *, int, int);
     198static void tcp_refresh_socket_data(tcp_socket_data_t *);
     199
     200static void tcp_initialize_socket_data(tcp_socket_data_t *);
     201
     202static int tcp_process_listen(socket_core_ref, tcp_socket_data_t *,
     203    tcp_header_t *, packet_t, struct sockaddr *, struct sockaddr *, size_t);
     204static int tcp_process_syn_sent(socket_core_ref, tcp_socket_data_t *,
     205    tcp_header_t *, packet_t);
     206static int tcp_process_syn_received(socket_core_ref, tcp_socket_data_t *,
     207    tcp_header_t *, packet_t);
     208static int tcp_process_established(socket_core_ref, tcp_socket_data_t *,
     209    tcp_header_t *, packet_t, int, size_t);
     210static int tcp_queue_received_packet(socket_core_ref, tcp_socket_data_t *,
    211211    packet_t, int, size_t);
    212212
    … …  
    290290        size_t offset;
    291291        int result;
    292         tcp_header_ref header;
     292        tcp_header_t *header;
    293293        socket_core_ref socket;
    294         tcp_socket_data_ref socket_data;
     294        tcp_socket_data_t *socket_data;
    295295        packet_t next_packet;
    296296        size_t total_length;
    … …  
    343343
    344344        /* Get tcp header */
    345         header = (tcp_header_ref) packet_get_data(packet);
     345        header = (tcp_header_t *) packet_get_data(packet);
    346346        if (!header)
    347347                return tcp_release_and_return(packet, NO_DATA);
    … …  
    380380
    381381        printf("socket id %d\n", socket->socket_id);
    382         socket_data = (tcp_socket_data_ref) socket->specific_data;
     382        socket_data = (tcp_socket_data_t *) socket->specific_data;
    383383        assert(socket_data);
    384384
    … …  
    497497}
    498498
    499 int tcp_process_established(socket_core_ref socket, tcp_socket_data_ref
    500     socket_data, tcp_header_ref header, packet_t packet, int fragments,
     499int tcp_process_established(socket_core_ref socket, tcp_socket_data_t *
     500    socket_data, tcp_header_t *header, packet_t packet, int fragments,
    501501    size_t total_length)
    502502{
    … …  
    806806
    807807int tcp_queue_received_packet(socket_core_ref socket,
    808     tcp_socket_data_ref socket_data, packet_t packet, int fragments,
     808    tcp_socket_data_t *socket_data, packet_t packet, int fragments,
    809809    size_t total_length)
    810810{
    … …  
    842842}
    843843
    844 int tcp_process_syn_sent(socket_core_ref socket, tcp_socket_data_ref
    845     socket_data, tcp_header_ref header, packet_t packet)
     844int tcp_process_syn_sent(socket_core_ref socket, tcp_socket_data_t *
     845    socket_data, tcp_header_t *header, packet_t packet)
    846846{
    847847        packet_t next_packet;
    … …  
    901901
    902902int tcp_process_listen(socket_core_ref listening_socket,
    903     tcp_socket_data_ref listening_socket_data, tcp_header_ref header,
     903    tcp_socket_data_t *listening_socket_data, tcp_header_t *header,
    904904    packet_t packet, struct sockaddr *src, struct sockaddr *dest,
    905905    size_t addrlen)
    … …  
    907907        packet_t next_packet;
    908908        socket_core_ref socket;
    909         tcp_socket_data_ref socket_data;
     909        tcp_socket_data_t *socket_data;
    910910        int socket_id;
    911911        int listening_socket_id = listening_socket->socket_id;
    … …  
    922922                return tcp_release_and_return(packet, EINVAL);
    923923
    924         socket_data = (tcp_socket_data_ref) malloc(sizeof(*socket_data));
     924        socket_data = (tcp_socket_data_t *) malloc(sizeof(*socket_data));
    925925        if (!socket_data)
    926926                return tcp_release_and_return(packet, ENOMEM);
    … …  
    979979        }
    980980        listening_socket_data =
    981             (tcp_socket_data_ref) listening_socket->specific_data;
     981            (tcp_socket_data_t *) listening_socket->specific_data;
    982982        assert(listening_socket_data);
    983983
    … …  
    991991                return ENOTSOCK;
    992992        }
    993         socket_data = (tcp_socket_data_ref) socket->specific_data;
     993        socket_data = (tcp_socket_data_t *) socket->specific_data;
    994994        assert(socket_data);
    995995
    … …  
    10611061
    10621062int tcp_process_syn_received(socket_core_ref socket,
    1063     tcp_socket_data_ref socket_data, tcp_header_ref header, packet_t packet)
     1063    tcp_socket_data_t *socket_data, tcp_header_t *header, packet_t packet)
    10641064{
    10651065        socket_core_ref listening_socket;
    1066         tcp_socket_data_ref listening_socket_data;
     1066        tcp_socket_data_t *listening_socket_data;
    10671067        int rc;
    10681068
    … …  
    10861086        if (listening_socket) {
    10871087                listening_socket_data =
    1088                     (tcp_socket_data_ref) listening_socket->specific_data;
     1088                    (tcp_socket_data_t *) listening_socket->specific_data;
    10891089                assert(listening_socket_data);
    10901090
    … …  
    11281128
    11291129void tcp_process_acknowledgement(socket_core_ref socket,
    1130     tcp_socket_data_ref socket_data, tcp_header_ref header)
     1130    tcp_socket_data_t *socket_data, tcp_header_t *header)
    11311131{
    11321132        size_t number;
    … …  
    12651265}
    12661266
    1267 void tcp_refresh_socket_data(tcp_socket_data_ref socket_data)
     1267void tcp_refresh_socket_data(tcp_socket_data_t *socket_data)
    12681268{
    12691269        assert(socket_data);
    … …  
    12811281}
    12821282
    1283 void tcp_initialize_socket_data(tcp_socket_data_ref socket_data)
     1283void tcp_initialize_socket_data(tcp_socket_data_t *socket_data)
    12841284{
    12851285        assert(socket_data);
    … …  
    13041304        ipc_call_t answer;
    13051305        int answer_count;
    1306         tcp_socket_data_ref socket_data;
     1306        tcp_socket_data_t *socket_data;
    13071307        socket_core_ref socket;
    13081308        packet_dimension_ref packet_dimension;
    … …  
    13361336                case NET_SOCKET:
    13371337                        socket_data =
    1338                             (tcp_socket_data_ref) malloc(sizeof(*socket_data));
     1338                            (tcp_socket_data_t *) malloc(sizeof(*socket_data));
    13391339                        if (!socket_data) {
    13401340                                res = ENOMEM;
    … …  
    13831383                                    SOCKET_GET_SOCKET_ID(call));
    13841384                                if (socket) {
    1385                                         socket_data = (tcp_socket_data_ref)
     1385                                        socket_data = (tcp_socket_data_t *)
    13861386                                            socket->specific_data;
    13871387                                        assert(socket_data);
    … …  
    15431543        int keep_write_lock = false;
    15441544        socket_core_ref socket;
    1545         tcp_socket_data_ref socket_data;
     1545        tcp_socket_data_t *socket_data;
    15461546
    15471547        assert(timeout);
    … …  
    15611561                goto out;
    15621562       
    1563         socket_data = (tcp_socket_data_ref) socket->specific_data;
     1563        socket_data = (tcp_socket_data_t *) socket->specific_data;
    15641564        assert(socket_data);
    15651565        if (socket_data->local_sockets != timeout->local_sockets)
    … …  
    16191619        tcp_timeout_ref timeout = data;
    16201620        socket_core_ref socket;
    1621         tcp_socket_data_ref socket_data;
     1621        tcp_socket_data_t *socket_data;
    16221622        fibril_rwlock_t *local_lock;
    16231623
    … …  
    16351635
    16361636        if (socket && (socket->socket_id == timeout->socket_id)) {
    1637                 socket_data = (tcp_socket_data_ref) socket->specific_data;
     1637                socket_data = (tcp_socket_data_t *) socket->specific_data;
    16381638                assert(socket_data);
    16391639                if (socket_data->local_sockets == timeout->local_sockets) {
    … …  
    16561656}
    16571657
    1658 void tcp_retransmit_packet(socket_core_ref socket, tcp_socket_data_ref
     1658void tcp_retransmit_packet(socket_core_ref socket, tcp_socket_data_t *
    16591659    socket_data, size_t sequence_number)
    16601660{
    … …  
    16871687{
    16881688        socket_core_ref socket;
    1689         tcp_socket_data_ref socket_data;
     1689        tcp_socket_data_t *socket_data;
    16901690
    16911691        assert(local_sockets);
    … …  
    17001700       
    17011701        /* Get the socket specific data */
    1702         socket_data = (tcp_socket_data_ref) socket->specific_data;
     1702        socket_data = (tcp_socket_data_t *) socket->specific_data;
    17031703        assert(socket_data);
    17041704
    … …  
    17401740    struct sockaddr *addr, socklen_t addrlen)
    17411741{
    1742         tcp_socket_data_ref socket_data;
     1742        tcp_socket_data_t *socket_data;
    17431743        packet_t packet;
    17441744        int rc;
    … …  
    17491749
    17501750        /* Get the socket specific data */
    1751         socket_data = (tcp_socket_data_ref) socket->specific_data;
     1751        socket_data = (tcp_socket_data_t *) socket->specific_data;
    17521752        assert(socket_data);
    17531753        assert(socket->specific_data == socket_data);
    … …  
    18291829
    18301830int tcp_queue_prepare_packet(socket_core_ref socket,
    1831     tcp_socket_data_ref socket_data, packet_t packet, size_t data_length)
    1832 {
    1833         tcp_header_ref header;
     1831    tcp_socket_data_t *socket_data, packet_t packet, size_t data_length)
     1832{
     1833        tcp_header_t *header;
    18341834        int rc;
    18351835
    … …  
    18391839
    18401840        /* Get TCP header */
    1841         header = (tcp_header_ref) packet_get_data(packet);
     1841        header = (tcp_header_t *) packet_get_data(packet);
    18421842        if (!header)
    18431843                return NO_DATA;
    … …  
    18591859}
    18601860
    1861 int tcp_queue_packet(socket_core_ref socket, tcp_socket_data_ref socket_data,
     1861int tcp_queue_packet(socket_core_ref socket, tcp_socket_data_t *socket_data,
    18621862    packet_t packet, size_t data_length)
    18631863{
    … …  
    18811881}
    18821882
    1883 packet_t tcp_get_packets_to_send(socket_core_ref socket, tcp_socket_data_ref
     1883packet_t tcp_get_packets_to_send(socket_core_ref socket, tcp_socket_data_t *
    18841884    socket_data)
    18851885{
    … …  
    19411941}
    19421942
    1943 packet_t tcp_send_prepare_packet(socket_core_ref socket, tcp_socket_data_ref
     1943packet_t tcp_send_prepare_packet(socket_core_ref socket, tcp_socket_data_t *
    19441944    socket_data, packet_t packet, size_t data_length, size_t sequence_number)
    19451945{
    1946         tcp_header_ref header;
     1946        tcp_header_t *header;
    19471947        uint32_t checksum;
    19481948        int rc;
    … …  
    19611961
    19621962        /* Get the header */
    1963         header = (tcp_header_ref) packet_get_data(packet);
     1963        header = (tcp_header_t *) packet_get_data(packet);
    19641964        if (!header) {
    19651965                pq_release_remote(tcp_globals.net_phone, packet_get_id(packet));
    … …  
    20022002}
    20032003
    2004 packet_t tcp_prepare_copy(socket_core_ref socket, tcp_socket_data_ref
     2004packet_t tcp_prepare_copy(socket_core_ref socket, tcp_socket_data_t *
    20052005    socket_data, packet_t packet, size_t data_length, size_t sequence_number)
    20062006{
    … …  
    20332033
    20342034void tcp_prepare_operation_header(socket_core_ref socket,
    2035     tcp_socket_data_ref socket_data, tcp_header_ref header, int synchronize,
     2035    tcp_socket_data_t *socket_data, tcp_header_t *header, int synchronize,
    20362036    int finalize)
    20372037{
    … …  
    20502050
    20512051int tcp_prepare_timeout(int (*timeout_function)(void *tcp_timeout_t),
    2052     socket_core_ref socket, tcp_socket_data_ref socket_data,
     2052    socket_core_ref socket, tcp_socket_data_t *socket_data,
    20532053    size_t sequence_number, tcp_socket_state_t state, suseconds_t timeout,
    20542054    int globals_read_only)
    … …  
    21002100{
    21012101        socket_core_ref socket;
    2102         tcp_socket_data_ref socket_data;
     2102        tcp_socket_data_t *socket_data;
    21032103        int packet_id;
    21042104        packet_t packet;
    … …  
    21172117                return NO_DATA;
    21182118
    2119         socket_data = (tcp_socket_data_ref) socket->specific_data;
     2119        socket_data = (tcp_socket_data_t *) socket->specific_data;
    21202120
    21212121        /* Check state */
    … …  
    21582158{
    21592159        socket_core_ref socket;
    2160         tcp_socket_data_ref socket_data;
     2160        tcp_socket_data_t *socket_data;
    21612161        packet_dimension_ref packet_dimension;
    21622162        packet_t packet;
    21632163        size_t total_length;
    2164         tcp_header_ref header;
     2164        tcp_header_t *header;
    21652165        int index;
    21662166        int result;
    … …  
    21792179                return NO_DATA;
    21802180
    2181         socket_data = (tcp_socket_data_ref) socket->specific_data;
     2181        socket_data = (tcp_socket_data_t *) socket->specific_data;
    21822182
    21832183        /* Check state */
    … …  
    22332233{
    22342234        socket_core_ref socket;
    2235         tcp_socket_data_ref socket_data;
     2235        tcp_socket_data_t *socket_data;
    22362236        packet_t packet;
    22372237        int rc;
    … …  
    22432243
    22442244        /* Get the socket specific data */
    2245         socket_data = (tcp_socket_data_ref) socket->specific_data;
     2245        socket_data = (tcp_socket_data_t *) socket->specific_data;
    22462246        assert(socket_data);
    22472247
    … …  
    22992299
    23002300int tcp_create_notification_packet(packet_t *packet, socket_core_ref socket,
    2301     tcp_socket_data_ref socket_data, int synchronize, int finalize)
     2301    tcp_socket_data_t *socket_data, int synchronize, int finalize)
    23022302{
    23032303        packet_dimension_ref packet_dimension;
    2304         tcp_header_ref header;
     2304        tcp_header_t *header;
    23052305        int rc;
    23062306
    … …  
    23372337        socket_core_ref accepted;
    23382338        socket_core_ref socket;
    2339         tcp_socket_data_ref socket_data;
     2339        tcp_socket_data_t *socket_data;
    23402340        packet_dimension_ref packet_dimension;
    23412341        int rc;
    … …  
    23512351
    23522352        /* Get the socket specific data */
    2353         socket_data = (tcp_socket_data_ref) socket->specific_data;
     2353        socket_data = (tcp_socket_data_t *) socket->specific_data;
    23542354        assert(socket_data);
    23552355
    … …  
    23692369
    23702370                /* Get the socket specific data */
    2371                 socket_data = (tcp_socket_data_ref) accepted->specific_data;
     2371                socket_data = (tcp_socket_data_t *) accepted->specific_data;
    23722372                assert(socket_data);
    23732373                /* TODO can it be in another state? */
    … …  
    24072407void tcp_free_socket_data(socket_core_ref socket)
    24082408{
    2409         tcp_socket_data_ref socket_data;
     2409        tcp_socket_data_t *socket_data;
    24102410
    24112411        assert(socket);
    … …  
    24142414
    24152415        /* Get the socket specific data */
    2416         socket_data = (tcp_socket_data_ref) socket->specific_data;
     2416        socket_data = (tcp_socket_data_t *) socket->specific_data;
    24172417        assert(socket_data);
    24182418
Note: See TracChangeset for help on using the changeset viewer.