Changeset a1a101d in mainline for uspace/srv/net/tcp/sock.c


Ignore:
Timestamp:
2012-08-17T16:58:51Z (13 years ago)
Author:
Vojtech Horky <vojtechhorky@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
bc0ccab
Parents:
920d0fc
Message:

Get rid of log_log_msg()

All calls to log_msg(LVL_*) were rewritten to
log_msg(LOG_DEFAULT, LVL_*).

File:
1 edited

Legend:

Unmodified
Added
Removed

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

    r920d0fc ra1a101d  
    9191static void tcp_sock_notify_data(socket_core_t *sock_core)
    9292{
    93         log_msg(LVL_DEBUG, "tcp_sock_notify_data(%d)", sock_core->socket_id);
     93        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_notify_data(%d)", sock_core->socket_id);
    9494        async_exch_t *exch = async_exchange_begin(sock_core->sess);
    9595        async_msg_5(exch, NET_SOCKET_RECEIVED, (sysarg_t)sock_core->socket_id,
    … …  
    100100static void tcp_sock_notify_aconn(socket_core_t *lsock_core)
    101101{
    102         log_msg(LVL_DEBUG, "tcp_sock_notify_aconn(%d)", lsock_core->socket_id);
     102        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_notify_aconn(%d)", lsock_core->socket_id);
    103103        async_exch_t *exch = async_exchange_begin(lsock_core->sess);
    104104        async_msg_5(exch, NET_SOCKET_ACCEPTED, (sysarg_t)lsock_core->socket_id,
    … …  
    111111        tcp_sockdata_t *sock;
    112112
    113         log_msg(LVL_DEBUG, "tcp_sock_create()");
     113        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_create()");
    114114        *rsock = NULL;
    115115
    … …  
    133133static void tcp_sock_uncreate(tcp_sockdata_t *sock)
    134134{
    135         log_msg(LVL_DEBUG, "tcp_sock_uncreate()");
     135        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_uncreate()");
    136136        free(sock);
    137137}
    … …  
    142142        int rc;
    143143
    144         log_msg(LVL_DEBUG, "tcp_sock_finish_setup()");
     144        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_finish_setup()");
    145145
    146146        sock->recv_fibril = fibril_create(tcp_sock_recv_fibril, sock);
    … …  
    171171        ipc_call_t answer;
    172172
    173         log_msg(LVL_DEBUG, "tcp_sock_socket()");
     173        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_socket()");
    174174
    175175        rc = tcp_sock_create(client, &sock);
    … …  
    208208        tcp_sockdata_t *socket;
    209209
    210         log_msg(LVL_DEBUG, "tcp_sock_bind()");
    211         log_msg(LVL_DEBUG, " - async_data_write_accept");
     210        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_bind()");
     211        log_msg(LOG_DEFAULT, LVL_DEBUG, " - async_data_write_accept");
    212212        rc = async_data_write_accept((void **) &addr, false, 0, 0, 0, &addr_len);
    213213        if (rc != EOK) {
    … …  
    216216        }
    217217
    218         log_msg(LVL_DEBUG, " - call socket_bind");
     218        log_msg(LOG_DEFAULT, LVL_DEBUG, " - call socket_bind");
    219219        rc = socket_bind(&client->sockets, &gsock, SOCKET_GET_SOCKET_ID(call),
    220220            addr, addr_len, TCP_FREE_PORTS_START, TCP_FREE_PORTS_END,
    … …  
    225225        }
    226226
    227         log_msg(LVL_DEBUG, " - call socket_cores_find");
     227        log_msg(LOG_DEFAULT, LVL_DEBUG, " - call socket_cores_find");
    228228        sock_core = socket_cores_find(&client->sockets, SOCKET_GET_SOCKET_ID(call));
    229229        if (sock_core != NULL) {
    … …  
    233233        }
    234234
    235         log_msg(LVL_DEBUG, " - success");
     235        log_msg(LOG_DEFAULT, LVL_DEBUG, " - success");
    236236        async_answer_0(callid, EOK);
    237237}
    … …  
    250250        int i;
    251251
    252         log_msg(LVL_DEBUG, "tcp_sock_listen()");
     252        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_listen()");
    253253
    254254        socket_id = SOCKET_GET_SOCKET_ID(call);
    … …  
    284284        }
    285285
    286         log_msg(LVL_DEBUG, " - open connections");
     286        log_msg(LOG_DEFAULT, LVL_DEBUG, " - open connections");
    287287
    288288        lsocket.addr.ipv4 = TCP_IPV4_ANY;
    … …  
    337337        tcp_sock_t fsocket;
    338338
    339         log_msg(LVL_DEBUG, "tcp_sock_connect()");
     339        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_connect()");
    340340
    341341        rc = async_data_write_accept((void **) &addr, false, 0, 0, 0, &addr_len);
    … …  
    377377                        fibril_mutex_unlock(&socket->lock);
    378378                        async_answer_0(callid, rc);
    379                         log_msg(LVL_DEBUG, "tcp_sock_connect: Failed to "
     379                        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_connect: Failed to "
    380380                            "determine local address.");
    381381                        return;
    … …  
    383383
    384384                socket->laddr.ipv4 = loc_addr.ipv4;
    385                 log_msg(LVL_DEBUG, "Local IP address is %x", socket->laddr.ipv4);
     385                log_msg(LOG_DEFAULT, LVL_DEBUG, "Local IP address is %x", socket->laddr.ipv4);
    386386        }
    387387
    … …  
    431431        int rc;
    432432
    433         log_msg(LVL_DEBUG, "tcp_sock_accept()");
     433        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_accept()");
    434434
    435435        socket_id = SOCKET_GET_SOCKET_ID(call);
    … …  
    445445        fibril_mutex_lock(&socket->lock);
    446446
    447         log_msg(LVL_DEBUG, " - verify socket->conn");
     447        log_msg(LOG_DEFAULT, LVL_DEBUG, " - verify socket->conn");
    448448        if (socket->conn != NULL) {
    449449                fibril_mutex_unlock(&socket->lock);
    … …  
    498498
    499499        asocket->conn = conn;
    500         log_msg(LVL_DEBUG, "tcp_sock_accept():create asocket\n");
     500        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_accept():create asocket\n");
    501501
    502502        rc = tcp_sock_finish_setup(asocket, &asock_id);
    … …  
    510510        fibril_add_ready(asocket->recv_fibril);
    511511
    512         log_msg(LVL_DEBUG, "tcp_sock_accept(): find acore\n");
     512        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_accept(): find acore\n");
    513513
    514514        SOCKET_SET_DATA_FRAGMENT_SIZE(answer, TCP_SOCK_FRAGMENT_SIZE);
    … …  
    521521       
    522522        /* Push one fragment notification to client's queue */
    523         log_msg(LVL_DEBUG, "tcp_sock_accept(): notify data\n");
     523        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_accept(): notify data\n");
    524524        fibril_mutex_unlock(&socket->lock);
    525525}
    … …  
    539539        int rc;
    540540
    541         log_msg(LVL_DEBUG, "tcp_sock_send()");
     541        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_send()");
    542542        socket_id = SOCKET_GET_SOCKET_ID(call);
    543543        fragments = SOCKET_GET_DATA_FRAGMENTS(call);
    … …  
    611611static void tcp_sock_sendto(tcp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    612612{
    613         log_msg(LVL_DEBUG, "tcp_sock_sendto()");
     613        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_sendto()");
    614614        async_answer_0(callid, ENOTSUP);
    615615}
    … …  
    629629        int rc;
    630630
    631         log_msg(LVL_DEBUG, "%p: tcp_sock_recv[from]()", client);
     631        log_msg(LOG_DEFAULT, LVL_DEBUG, "%p: tcp_sock_recv[from]()", client);
    632632
    633633        socket_id = SOCKET_GET_SOCKET_ID(call);
    … …  
    651651        (void)flags;
    652652
    653         log_msg(LVL_DEBUG, "tcp_sock_recvfrom(): lock recv_buffer_lock");
     653        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_recvfrom(): lock recv_buffer_lock");
    654654        fibril_mutex_lock(&socket->recv_buffer_lock);
    655655        while (socket->recv_buffer_used == 0 && socket->recv_error == TCP_EOK) {
    656                 log_msg(LVL_DEBUG, "wait for recv_buffer_cv + recv_buffer_used != 0");
     656                log_msg(LOG_DEFAULT, LVL_DEBUG, "wait for recv_buffer_cv + recv_buffer_used != 0");
    657657                fibril_condvar_wait(&socket->recv_buffer_cv,
    658658                    &socket->recv_buffer_lock);
    659659        }
    660660
    661         log_msg(LVL_DEBUG, "Got data in sock recv_buffer");
     661        log_msg(LOG_DEFAULT, LVL_DEBUG, "Got data in sock recv_buffer");
    662662
    663663        data_len = socket->recv_buffer_used;
    … …  
    679679        }
    680680
    681         log_msg(LVL_DEBUG, "**** recv result -> %d", rc);
     681        log_msg(LOG_DEFAULT, LVL_DEBUG, "**** recv result -> %d", rc);
    682682        if (rc != EOK) {
    683683                fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    694694                addr.sin_port = host2uint16_t_be(rsock->port);
    695695
    696                 log_msg(LVL_DEBUG, "addr read receive");
     696                log_msg(LOG_DEFAULT, LVL_DEBUG, "addr read receive");
    697697                if (!async_data_read_receive(&rcallid, &addr_length)) {
    698698                        fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    705705                        addr_length = sizeof(addr);
    706706
    707                 log_msg(LVL_DEBUG, "addr read finalize");
     707                log_msg(LOG_DEFAULT, LVL_DEBUG, "addr read finalize");
    708708                rc = async_data_read_finalize(rcallid, &addr, addr_length);
    709709                if (rc != EOK) {
    … …  
    715715        }
    716716
    717         log_msg(LVL_DEBUG, "data read receive");
     717        log_msg(LOG_DEFAULT, LVL_DEBUG, "data read receive");
    718718        if (!async_data_read_receive(&rcallid, &length)) {
    719719                fibril_mutex_unlock(&socket->recv_buffer_lock);
    … …  
    726726                length = data_len;
    727727
    728         log_msg(LVL_DEBUG, "data read finalize");
     728        log_msg(LOG_DEFAULT, LVL_DEBUG, "data read finalize");
    729729        rc = async_data_read_finalize(rcallid, socket->recv_buffer, length);
    730730
    731731        socket->recv_buffer_used -= length;
    732         log_msg(LVL_DEBUG, "tcp_sock_recvfrom: %zu left in buffer",
     732        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_recvfrom: %zu left in buffer",
    733733            socket->recv_buffer_used);
    734734        if (socket->recv_buffer_used > 0) {
    … …  
    758758        int rc;
    759759
    760         log_msg(LVL_DEBUG, "tcp_sock_close()");
     760        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_close()");
    761761        socket_id = SOCKET_GET_SOCKET_ID(call);
    762762
    … …  
    798798static void tcp_sock_getsockopt(tcp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    799799{
    800         log_msg(LVL_DEBUG, "tcp_sock_getsockopt()");
     800        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_getsockopt()");
    801801        async_answer_0(callid, ENOTSUP);
    802802}
    … …  
    804804static void tcp_sock_setsockopt(tcp_client_t *client, ipc_callid_t callid, ipc_call_t call)
    805805{
    806         log_msg(LVL_DEBUG, "tcp_sock_setsockopt()");
     806        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_setsockopt()");
    807807        async_answer_0(callid, ENOTSUP);
    808808}
    … …  
    815815        tcp_sockdata_t *socket = lconn->socket;
    816816
    817         log_msg(LVL_DEBUG, "tcp_sock_cstate_cb()");
     817        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_cstate_cb()");
    818818        fibril_mutex_lock(&socket->lock);
    819819        assert(conn == lconn->conn);
    … …  
    828828        list_append(&lconn->ready_list, &socket->ready);
    829829
    830         log_msg(LVL_DEBUG, "tcp_sock_cstate_cb(): notify accept");
     830        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_cstate_cb(): notify accept");
    831831
    832832        /* Push one accept notification to client's queue */
    … …  
    842842        tcp_error_t trc;
    843843
    844         log_msg(LVL_DEBUG, "tcp_sock_recv_fibril()");
     844        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_recv_fibril()");
    845845
    846846        fibril_mutex_lock(&sock->recv_buffer_lock);
    847847
    848848        while (true) {
    849                 log_msg(LVL_DEBUG, "call tcp_uc_receive()");
     849                log_msg(LOG_DEFAULT, LVL_DEBUG, "call tcp_uc_receive()");
    850850                while (sock->recv_buffer_used != 0 && sock->sock_core != NULL)
    851851                        fibril_condvar_wait(&sock->recv_buffer_cv,
    … …  
    863863                }
    864864
    865                 log_msg(LVL_DEBUG, "got data - broadcast recv_buffer_cv");
     865                log_msg(LOG_DEFAULT, LVL_DEBUG, "got data - broadcast recv_buffer_cv");
    866866
    867867                sock->recv_buffer_used = data_len;
    … …  
    895895                        break;
    896896
    897                 log_msg(LVL_DEBUG, "tcp_sock_connection: METHOD=%d\n",
     897                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_connection: METHOD=%d\n",
    898898                    (int)IPC_GET_IMETHOD(call));
    899899
    … …  
    940940
    941941        /* Clean up */
    942         log_msg(LVL_DEBUG, "tcp_sock_connection: Clean up");
     942        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_sock_connection: Clean up");
    943943        async_hangup(client.sess);
    944944        socket_cores_release(NULL, &client.sockets, &gsock, tcp_free_sock_data);
Note: See TracChangeset for help on using the changeset viewer.