Changeset a1e2df13 in mainline for uspace/srv/net/udp/sock.c


Ignore:
Timestamp:
2012-11-11T21:31:03Z (11 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
25eec4e
Parents:
141a20d (diff), d1538a1 (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/srv/net/udp/sock.c

    r141a20d ra1e2df13  
    8888static void udp_sock_notify_data(socket_core_t *sock_core)
    8989{
    90         log_msg(LVL_DEBUG, "udp_sock_notify_data(%d)", sock_core->socket_id);
     90        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_notify_data(%d)", sock_core->socket_id);
    9191        async_exch_t *exch = async_exchange_begin(sock_core->sess);
    9292        async_msg_5(exch, NET_SOCKET_RECEIVED, (sysarg_t)sock_core->socket_id,
    … …  
    103103        ipc_call_t answer;
    104104
    105         log_msg(LVL_DEBUG, "udp_sock_socket()");
    106         sock = calloc(sizeof(udp_sockdata_t), 1);
     105        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_socket()");
     106        sock = calloc(1, sizeof(udp_sockdata_t));
    107107        if (sock == NULL) {
    108108                async_answer_0(callid, ENOMEM);
    … …  
    167167        udp_error_t urc;
    168168
    169         log_msg(LVL_DEBUG, "udp_sock_bind()");
    170         log_msg(LVL_DEBUG, " - async_data_write_accept");
     169        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_bind()");
     170        log_msg(LOG_DEFAULT, LVL_DEBUG, " - async_data_write_accept");
    171171
    172172        addr = NULL;
    … …  
    178178        }
    179179
    180         log_msg(LVL_DEBUG, " - call socket_bind");
     180        log_msg(LOG_DEFAULT, LVL_DEBUG, " - call socket_bind");
    181181        rc = socket_bind(&client->sockets, &gsock, SOCKET_GET_SOCKET_ID(call),
    182182            addr, addr_size, UDP_FREE_PORTS_START, UDP_FREE_PORTS_END,
    … …  
    192192        }
    193193
    194         log_msg(LVL_DEBUG, " - call socket_cores_find");
     194        log_msg(LOG_DEFAULT, LVL_DEBUG, " - call socket_cores_find");
    195195        sock_core = socket_cores_find(&client->sockets, SOCKET_GET_SOCKET_ID(call));
    196196        if (sock_core == NULL) {
    … …  
    222222        }
    223223
    224         log_msg(LVL_DEBUG, " - success");
     224        log_msg(LOG_DEFAULT, LVL_DEBUG, " - success");
    225225        async_answer_0(callid, rc);
    226226out:
    … …  
    231231static void udp_sock_listen(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    232232{
    233         log_msg(LVL_DEBUG, "udp_sock_listen()");
     233        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_listen()");
    234234        async_answer_0(callid, ENOTSUP);
    235235}
    … …  
    237237static void udp_sock_connect(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    238238{
    239         log_msg(LVL_DEBUG, "udp_sock_connect()");
     239        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connect()");
    240240        async_answer_0(callid, ENOTSUP);
    241241}
    … …  
    243243static void udp_sock_accept(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    244244{
    245         log_msg(LVL_DEBUG, "udp_sock_accept()");
     245        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_accept()");
    246246        async_answer_0(callid, ENOTSUP);
    247247}
    … …  
    264264        int rc;
    265265
    266         log_msg(LVL_DEBUG, "udp_sock_send()");
     266        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_send()");
    267267
    268268        addr = NULL;
    … …  
    323323                        fibril_mutex_unlock(&socket->lock);
    324324                        async_answer_0(callid, rc);
    325                         log_msg(LVL_DEBUG, "udp_sock_sendto: Failed to "
     325                        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_sendto: Failed to "
    326326                            "determine local address.");
    327327                        return;
    … …  
    329329
    330330                socket->assoc->ident.local.addr.ipv4 = loc_addr.ipv4;
    331                 log_msg(LVL_DEBUG, "Local IP address is %x",
     331                log_msg(LOG_DEFAULT, LVL_DEBUG, "Local IP address is %x",
    332332                    socket->assoc->ident.local.addr.ipv4);
    333333        }
    … …  
    405405        int rc;
    406406
    407         log_msg(LVL_DEBUG, "%p: udp_sock_recv[from]()", client);
     407        log_msg(LOG_DEFAULT, LVL_DEBUG, "%p: udp_sock_recv[from]()", client);
    408408
    409409        socket_id = SOCKET_GET_SOCKET_ID(call);
    … …  
    427427        (void)flags;
    428428
    429         log_msg(LVL_DEBUG, "udp_sock_recvfrom(): lock recv_buffer lock");
     429        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recvfrom(): lock recv_buffer lock");
    430430        fibril_mutex_lock(&socket->recv_buffer_lock);
    431431        while (socket->recv_buffer_used == 0 && socket->recv_error == UDP_EOK) {
    432                 log_msg(LVL_DEBUG, "udp_sock_recvfrom(): wait for cv");
     432                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recvfrom(): wait for cv");
    433433                fibril_condvar_wait(&socket->recv_buffer_cv,
    434434                    &socket->recv_buffer_lock);
    435435        }
    436436
    437         log_msg(LVL_DEBUG, "Got data in sock recv_buffer");
     437        log_msg(LOG_DEFAULT, LVL_DEBUG, "Got data in sock recv_buffer");
    438438
    439439        rsock = socket->recv_fsock;
    … …  
    441441        urc = socket->recv_error;
    442442
    443         log_msg(LVL_DEBUG, "**** recv data_len=%zu", data_len);
     443        log_msg(LOG_DEFAULT, LVL_DEBUG, "**** recv data_len=%zu", data_len);
    444444
    445445        switch (urc) {
    … …  
    458458        }
    459459
    460         log_msg(LVL_DEBUG, "**** udp_uc_receive -> %d", rc);
     460        log_msg(LOG_DEFAULT, LVL_DEBUG, "**** udp_uc_receive -> %d", rc);
    461461        if (rc != EOK) {
    462462                fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    472472                addr.sin_port = host2uint16_t_be(rsock.port);
    473473
    474                 log_msg(LVL_DEBUG, "addr read receive");
     474                log_msg(LOG_DEFAULT, LVL_DEBUG, "addr read receive");
    475475                if (!async_data_read_receive(&rcallid, &addr_length)) {
    476476                        fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    483483                        addr_length = sizeof(addr);
    484484
    485                 log_msg(LVL_DEBUG, "addr read finalize");
     485                log_msg(LOG_DEFAULT, LVL_DEBUG, "addr read finalize");
    486486                rc = async_data_read_finalize(rcallid, &addr, addr_length);
    487487                if (rc != EOK) {
    … …  
    493493        }
    494494
    495         log_msg(LVL_DEBUG, "data read receive");
     495        log_msg(LOG_DEFAULT, LVL_DEBUG, "data read receive");
    496496        if (!async_data_read_receive(&rcallid, &length)) {
    497497                fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    504504                length = data_len;
    505505
    506         log_msg(LVL_DEBUG, "data read finalize");
     506        log_msg(LOG_DEFAULT, LVL_DEBUG, "data read finalize");
    507507        rc = async_data_read_finalize(rcallid, socket->recv_buffer, length);
    508508
    … …  
    510510                rc = EOVERFLOW;
    511511
    512         log_msg(LVL_DEBUG, "read_data_length <- %zu", length);
     512        log_msg(LOG_DEFAULT, LVL_DEBUG, "read_data_length <- %zu", length);
    513513        IPC_SET_ARG2(answer, 0);
    514514        SOCKET_SET_READ_DATA_LENGTH(answer, length);
    … …  
    531531        int rc;
    532532
    533         log_msg(LVL_DEBUG, "udp_sock_close()");
     533        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_close()");
    534534        socket_id = SOCKET_GET_SOCKET_ID(call);
    535535
    … …  
    544544
    545545        fibril_mutex_lock(&socket->recv_buffer_lock);
    546         log_msg(LVL_DEBUG, "udp_sock_close - set socket->sock_core = NULL");
     546        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_close - set socket->sock_core = NULL");
    547547        socket->sock_core = NULL;
    548548        fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    553553            udp_free_sock_data);
    554554        if (rc != EOK) {
    555                 log_msg(LVL_DEBUG, "udp_sock_close - socket_destroy failed");
     555                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_close - socket_destroy failed");
    556556                fibril_mutex_unlock(&socket->lock);
    557557                async_answer_0(callid, rc);
    … …  
    559559        }
    560560
    561         log_msg(LVL_DEBUG, "udp_sock_close - broadcast recv_buffer_cv");
     561        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_close - broadcast recv_buffer_cv");
    562562        fibril_condvar_broadcast(&socket->recv_buffer_cv);
    563563
    … …  
    568568static void udp_sock_getsockopt(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    569569{
    570         log_msg(LVL_DEBUG, "udp_sock_getsockopt()");
     570        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_getsockopt()");
    571571        async_answer_0(callid, ENOTSUP);
    572572}
    … …  
    574574static void udp_sock_setsockopt(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    575575{
    576         log_msg(LVL_DEBUG, "udp_sock_setsockopt()");
     576        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_setsockopt()");
    577577        async_answer_0(callid, ENOTSUP);
    578578}
    … …  
    585585        size_t rcvd;
    586586
    587         log_msg(LVL_DEBUG, "udp_sock_recv_fibril()");
     587        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recv_fibril()");
    588588
    589589        fibril_mutex_lock(&sock->recv_buffer_lock);
    590590
    591591        while (true) {
    592                 log_msg(LVL_DEBUG, "[] wait for rcv buffer empty()");
     592                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] wait for rcv buffer empty()");
    593593                while (sock->recv_buffer_used != 0 && sock->sock_core != NULL) {
    594594                        fibril_condvar_wait(&sock->recv_buffer_cv,
    … …  
    596596                }
    597597
    598                 log_msg(LVL_DEBUG, "[] call udp_uc_receive()");
     598                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] call udp_uc_receive()");
    599599                urc = udp_uc_receive(sock->assoc, sock->recv_buffer,
    600600                    UDP_FRAGMENT_SIZE, &rcvd, &xflags, &sock->recv_fsock);
    601601                sock->recv_error = urc;
    602602
    603                 log_msg(LVL_DEBUG, "[] udp_uc_receive -> %d", urc);
     603                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] udp_uc_receive -> %d", urc);
    604604
    605605                if (sock->sock_core != NULL)
    … …  
    607607
    608608                if (urc != UDP_EOK) {
    609                         log_msg(LVL_DEBUG, "[] urc != UDP_EOK, break");
     609                        log_msg(LOG_DEFAULT, LVL_DEBUG, "[] urc != UDP_EOK, break");
    610610                        fibril_condvar_broadcast(&sock->recv_buffer_cv);
    611611                        break;
    612612                }
    613613
    614                 log_msg(LVL_DEBUG, "[] got data - broadcast recv_buffer_cv");
     614                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] got data - broadcast recv_buffer_cv");
    615615
    616616                sock->recv_buffer_used = rcvd;
    … …  
    618618        }
    619619
    620         log_msg(LVL_DEBUG, "udp_sock_recv_fibril() exited loop");
     620        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recv_fibril() exited loop");
    621621        fibril_mutex_unlock(&sock->recv_buffer_lock);
    622622        udp_uc_destroy(sock->assoc);
    623623
    624         log_msg(LVL_DEBUG, "udp_sock_recv_fibril() terminated");
     624        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recv_fibril() terminated");
    625625
    626626        return 0;
    … …  
    640640
    641641        while (true) {
    642                 log_msg(LVL_DEBUG, "udp_sock_connection: wait");
     642                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: wait");
    643643                callid = async_get_call(&call);
    644644                if (!IPC_GET_IMETHOD(call))
    645645                        break;
    646646
    647                 log_msg(LVL_DEBUG, "udp_sock_connection: METHOD=%d",
     647                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: METHOD=%d",
    648648                    (int)IPC_GET_IMETHOD(call));
    649649
    … …  
    688688
    689689        /* Clean up */
    690         log_msg(LVL_DEBUG, "udp_sock_connection: Clean up");
     690        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: Clean up");
    691691        async_hangup(client.sess);
    692692        socket_cores_release(NULL, &client.sockets, &gsock, udp_free_sock_data);
Note: See TracChangeset for help on using the changeset viewer.