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


Ignore:
Timestamp:
2012-10-23T13:16:49Z (12 years ago)
Author:
Vojtech Horky <vojtechhorky@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
6ecf5b8
Parents:
32b3a12 (diff), b2ac3998 (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

    r32b3a12 rb800b0e  
    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()");
     105        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_socket()");
    106106        sock = calloc(1, sizeof(udp_sockdata_t));
    107107        if (sock == NULL) {
    … …  
    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, "tcp_sock_close()");
     533        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_close()");
    534534        socket_id = SOCKET_GET_SOCKET_ID(call);
    535535
    … …  
    557557static void udp_sock_getsockopt(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    558558{
    559         log_msg(LVL_DEBUG, "udp_sock_getsockopt()");
     559        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_getsockopt()");
    560560        async_answer_0(callid, ENOTSUP);
    561561}
    … …  
    563563static void udp_sock_setsockopt(udp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    564564{
    565         log_msg(LVL_DEBUG, "udp_sock_setsockopt()");
     565        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_setsockopt()");
    566566        async_answer_0(callid, ENOTSUP);
    567567}
    … …  
    574574        size_t rcvd;
    575575
    576         log_msg(LVL_DEBUG, "udp_sock_recv_fibril()");
     576        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_recv_fibril()");
    577577
    578578        while (true) {
    579                 log_msg(LVL_DEBUG, "[] wait for rcv buffer empty()");
     579                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] wait for rcv buffer empty()");
    580580                fibril_mutex_lock(&sock->recv_buffer_lock);
    581581                while (sock->recv_buffer_used != 0) {
    … …  
    584584                }
    585585
    586                 log_msg(LVL_DEBUG, "[] call udp_uc_receive()");
     586                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] call udp_uc_receive()");
    587587                urc = udp_uc_receive(sock->assoc, sock->recv_buffer,
    588588                    UDP_FRAGMENT_SIZE, &rcvd, &xflags, &sock->recv_fsock);
    … …  
    597597                }
    598598
    599                 log_msg(LVL_DEBUG, "[] got data - broadcast recv_buffer_cv");
     599                log_msg(LOG_DEFAULT, LVL_DEBUG, "[] got data - broadcast recv_buffer_cv");
    600600
    601601                sock->recv_buffer_used = rcvd;
    … …  
    622622
    623623        while (true) {
    624                 log_msg(LVL_DEBUG, "udp_sock_connection: wait");
     624                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: wait");
    625625                callid = async_get_call(&call);
    626626                if (!IPC_GET_IMETHOD(call))
    627627                        break;
    628628
    629                 log_msg(LVL_DEBUG, "udp_sock_connection: METHOD=%d",
     629                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: METHOD=%d",
    630630                    (int)IPC_GET_IMETHOD(call));
    631631
    … …  
    670670
    671671        /* Clean up */
    672         log_msg(LVL_DEBUG, "udp_sock_connection: Clean up");
     672        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sock_connection: Clean up");
    673673        async_hangup(client.sess);
    674674        socket_cores_release(NULL, &client.sockets, &gsock, udp_free_sock_data);
Note: See TracChangeset for help on using the changeset viewer.