Changeset a1e2df13 in mainline for uspace/srv/net/udp


Ignore:
Timestamp:
2012-11-11T21:31:03Z (13 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
25eec4ef
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.

Location:
uspace/srv/net/udp
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • uspace/srv/net/udp/assoc.c

    r141a20d ra1e2df13  
    104104static void udp_assoc_free(udp_assoc_t *assoc)
    105105{
    106         log_msg(LVL_DEBUG, "%s: udp_assoc_free(%p)", assoc->name, assoc);
     106        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: udp_assoc_free(%p)", assoc->name, assoc);
    107107
    108108        while (!list_empty(&assoc->rcv_queue)) {
    … …  
    127127void udp_assoc_addref(udp_assoc_t *assoc)
    128128{
    129         log_msg(LVL_DEBUG, "%s: upd_assoc_addref(%p)", assoc->name, assoc);
     129        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: upd_assoc_addref(%p)", assoc->name, assoc);
    130130        atomic_inc(&assoc->refcnt);
    131131}
    … …  
    139139void udp_assoc_delref(udp_assoc_t *assoc)
    140140{
    141         log_msg(LVL_DEBUG, "%s: udp_assoc_delref(%p)", assoc->name, assoc);
     141        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: udp_assoc_delref(%p)", assoc->name, assoc);
    142142
    143143        if (atomic_predec(&assoc->refcnt) == 0)
    … …  
    154154void udp_assoc_delete(udp_assoc_t *assoc)
    155155{
    156         log_msg(LVL_DEBUG, "%s: udp_assoc_delete(%p)", assoc->name, assoc);
     156        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: udp_assoc_delete(%p)", assoc->name, assoc);
    157157
    158158        assert(assoc->deleted == false);
    … …  
    192192void udp_assoc_set_foreign(udp_assoc_t *assoc, udp_sock_t *fsock)
    193193{
    194         log_msg(LVL_DEBUG, "udp_assoc_set_foreign(%p, %p)", assoc, fsock);
     194        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_set_foreign(%p, %p)", assoc, fsock);
    195195        fibril_mutex_lock(&assoc->lock);
    196196        assoc->ident.foreign = *fsock;
    … …  
    205205void udp_assoc_set_local(udp_assoc_t *assoc, udp_sock_t *lsock)
    206206{
    207         log_msg(LVL_DEBUG, "udp_assoc_set_local(%p, %p)", assoc, lsock);
     207        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_set_local(%p, %p)", assoc, lsock);
    208208        fibril_mutex_lock(&assoc->lock);
    209209        assoc->ident.local = *lsock;
    … …  
    228228        int rc;
    229229
    230         log_msg(LVL_DEBUG, "udp_assoc_send(%p, %p, %p)",
     230        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_send(%p, %p, %p)",
    231231            assoc, fsock, msg);
    232232
    … …  
    261261        udp_rcv_queue_entry_t *rqe;
    262262
    263         log_msg(LVL_DEBUG, "udp_assoc_recv()");
     263        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_recv()");
    264264
    265265        fibril_mutex_lock(&assoc->lock);
    266266        while (list_empty(&assoc->rcv_queue) && !assoc->reset) {
    267                 log_msg(LVL_DEBUG, "udp_assoc_recv() - waiting");
     267                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_recv() - waiting");
    268268                fibril_condvar_wait(&assoc->rcv_queue_cv, &assoc->lock);
    269269        }
    270270
    271271        if (assoc->reset) {
    272                 log_msg(LVL_DEBUG, "udp_assoc_recv() - association was reset");
     272                log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_recv() - association was reset");
    273273                fibril_mutex_unlock(&assoc->lock);
    274274                return ECONNABORTED;
    275275        }
    276276
    277         log_msg(LVL_DEBUG, "udp_assoc_recv() - got a message");
     277        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_recv() - got a message");
    278278        link = list_first(&assoc->rcv_queue);
    279279        rqe = list_get_instance(link, udp_rcv_queue_entry_t, link);
    … …  
    297297        int rc;
    298298
    299         log_msg(LVL_DEBUG, "udp_assoc_received(%p, %p)", rsp, msg);
     299        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_received(%p, %p)", rsp, msg);
    300300
    301301        assoc = udp_assoc_find_ref(rsp);
    302302        if (assoc == NULL) {
    303                 log_msg(LVL_DEBUG, "No association found. Message dropped.");
     303                log_msg(LOG_DEFAULT, LVL_DEBUG, "No association found. Message dropped.");
    304304                /* XXX Generate ICMP error. */
    305305                /* XXX Might propagate error directly by error return. */
    … …  
    309309        rc = udp_assoc_queue_msg(assoc, rsp, msg);
    310310        if (rc != EOK) {
    311                 log_msg(LVL_DEBUG, "Out of memory. Message dropped.");
     311                log_msg(LOG_DEFAULT, LVL_DEBUG, "Out of memory. Message dropped.");
    312312                /* XXX Generate ICMP error? */
    313313        }
    … …  
    332332        udp_rcv_queue_entry_t *rqe;
    333333
    334         log_msg(LVL_DEBUG, "udp_assoc_queue_msg(%p, %p, %p)",
     334        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_queue_msg(%p, %p, %p)",
    335335            assoc, sp, msg);
    336336
    … …  
    355355static bool udp_socket_match(udp_sock_t *sock, udp_sock_t *patt)
    356356{
    357         log_msg(LVL_DEBUG, "udp_socket_match(sock=(%x,%u), pat=(%x,%u))",
     357        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_socket_match(sock=(%x,%u), pat=(%x,%u))",
    358358            sock->addr.ipv4, sock->port, patt->addr.ipv4, patt->port);
    359359
    … …  
    366366                return false;
    367367
    368         log_msg(LVL_DEBUG, " -> match");
     368        log_msg(LOG_DEFAULT, LVL_DEBUG, " -> match");
    369369
    370370        return true;
    … …  
    374374static bool udp_sockpair_match(udp_sockpair_t *sp, udp_sockpair_t *pattern)
    375375{
    376         log_msg(LVL_DEBUG, "udp_sockpair_match(%p, %p)", sp, pattern);
     376        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_sockpair_match(%p, %p)", sp, pattern);
    377377
    378378        if (!udp_socket_match(&sp->local, &pattern->local))
    … …  
    382382                return false;
    383383
    384         log_msg(LVL_DEBUG, "Socket pair matched.");
     384        log_msg(LOG_DEFAULT, LVL_DEBUG, "Socket pair matched.");
    385385        return true;
    386386}
    … …  
    398398static udp_assoc_t *udp_assoc_find_ref(udp_sockpair_t *sp)
    399399{
    400         log_msg(LVL_DEBUG, "udp_assoc_find_ref(%p)", sp);
     400        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_find_ref(%p)", sp);
    401401
    402402        fibril_mutex_lock(&assoc_list_lock);
    … …  
    405405                udp_assoc_t *assoc = list_get_instance(link, udp_assoc_t, link);
    406406                udp_sockpair_t *asp = &assoc->ident;
    407                 log_msg(LVL_DEBUG, "compare with assoc (f:(%x,%u), l:(%x,%u))",
     407                log_msg(LOG_DEFAULT, LVL_DEBUG, "compare with assoc (f:(%x,%u), l:(%x,%u))",
    408408                    asp->foreign.addr.ipv4, asp->foreign.port,
    409409                    asp->local.addr.ipv4, asp->local.port);
    … …  
    414414
    415415                if (udp_sockpair_match(sp, asp)) {
    416                         log_msg(LVL_DEBUG, "Returning assoc %p", assoc);
     416                        log_msg(LOG_DEFAULT, LVL_DEBUG, "Returning assoc %p", assoc);
    417417                        udp_assoc_addref(assoc);
    418418                        fibril_mutex_unlock(&assoc_list_lock);

  • 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);

  • uspace/srv/net/udp/ucall.c

    r141a20d ra1e2df13  
    4747        udp_assoc_t *nassoc;
    4848
    49         log_msg(LVL_DEBUG, "udp_uc_create()");
     49        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_uc_create()");
    5050        nassoc = udp_assoc_new(NULL, NULL);
    5151        if (nassoc == NULL)
    … …  
    5959udp_error_t udp_uc_set_foreign(udp_assoc_t *assoc, udp_sock_t *fsock)
    6060{
    61         log_msg(LVL_DEBUG, "udp_uc_set_foreign(%p, %p)", assoc, fsock);
     61        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_uc_set_foreign(%p, %p)", assoc, fsock);
    6262
    6363        udp_assoc_set_foreign(assoc, fsock);
    … …  
    6767udp_error_t udp_uc_set_local(udp_assoc_t *assoc, udp_sock_t *lsock)
    6868{
    69         log_msg(LVL_DEBUG, "udp_uc_set_local(%p, %p)", assoc, lsock);
     69        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_uc_set_local(%p, %p)", assoc, lsock);
    7070
    7171        udp_assoc_set_local(assoc, lsock);
    … …  
    7979        udp_msg_t msg;
    8080
    81         log_msg(LVL_DEBUG, "%s: udp_uc_send()", assoc->name);
     81        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: udp_uc_send()", assoc->name);
    8282
    8383        msg.data = data;
    … …  
    103103        int rc;
    104104
    105         log_msg(LVL_DEBUG, "%s: udp_uc_receive()", assoc->name);
     105        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: udp_uc_receive()", assoc->name);
    106106        rc = udp_assoc_recv(assoc, &msg, fsock);
    107         log_msg(LVL_DEBUG, "udp_assoc_recv -> %d", rc);
     107        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_assoc_recv -> %d", rc);
    108108        switch (rc) {
    109109        case EOK:
    … …  
    125125void udp_uc_status(udp_assoc_t *assoc, udp_assoc_status_t *astatus)
    126126{
    127         log_msg(LVL_DEBUG, "udp_uc_status()");
     127        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_uc_status()");
    128128//      cstatus->cstate = conn->cstate;
    129129}
    … …  
    131131void udp_uc_destroy(udp_assoc_t *assoc)
    132132{
    133         log_msg(LVL_DEBUG, "udp_uc_destroy()");
     133        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_uc_destroy()");
    134134        udp_assoc_reset(assoc);
    135135        udp_assoc_remove(assoc);

  • uspace/srv/net/udp/udp.c

    r141a20d ra1e2df13  
    5050        int rc;
    5151
    52         log_msg(LVL_DEBUG, "udp_init()");
     52        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_init()");
    5353
    5454        rc = udp_inet_init();
    5555        if (rc != EOK) {
    56                 log_msg(LVL_ERROR, "Failed connecting to internet service.");
     56                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed connecting to internet service.");
    5757                return ENOENT;
    5858        }
    … …  
    6060        rc = udp_sock_init();
    6161        if (rc != EOK) {
    62                 log_msg(LVL_ERROR, "Failed initializing socket service.");
     62                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed initializing socket service.");
    6363                return ENOENT;
    6464        }
    … …  
    7373        printf(NAME ": UDP (User Datagram Protocol) service\n");
    7474
    75         rc = log_init(NAME, LVL_DEBUG);
     75        rc = log_init(NAME);
    7676        if (rc != EOK) {
    7777                printf(NAME ": Failed to initialize log.\n");

  • uspace/srv/net/udp/udp_inet.c

    r141a20d ra1e2df13  
    6161        udp_pdu_t *pdu;
    6262
    63         log_msg(LVL_DEBUG, "udp_inet_ev_recv()");
     63        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_inet_ev_recv()");
    6464
    6565        pdu = udp_pdu_new();
    … …  
    6969        pdu->src.ipv4 = dgram->src.ipv4;
    7070        pdu->dest.ipv4 = dgram->dest.ipv4;
    71         log_msg(LVL_DEBUG, "src: 0x%08x, dest: 0x%08x",
     71        log_msg(LOG_DEFAULT, LVL_DEBUG, "src: 0x%08x, dest: 0x%08x",
    7272            pdu->src.ipv4, pdu->dest.ipv4);
    7373
    … …  
    8484        inet_dgram_t dgram;
    8585
    86         log_msg(LVL_DEBUG, "udp_transmit_pdu()");
     86        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_transmit_pdu()");
    8787
    8888        dgram.src.ipv4 = pdu->src.ipv4;
    … …  
    9494        rc = inet_send(&dgram, INET_TTL_MAX, 0);
    9595        if (rc != EOK)
    96                 log_msg(LVL_ERROR, "Failed to transmit PDU.");
     96                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to transmit PDU.");
    9797
    9898        return rc;
    … …  
    105105        udp_sockpair_t rident;
    106106
    107         log_msg(LVL_DEBUG, "udp_received_pdu()");
     107        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_received_pdu()");
    108108
    109109        if (udp_pdu_decode(pdu, &rident, &dmsg) != EOK) {
    110                 log_msg(LVL_WARN, "Not enough memory. PDU dropped.");
     110                log_msg(LOG_DEFAULT, LVL_WARN, "Not enough memory. PDU dropped.");
    111111                return;
    112112        }
    … …  
    124124        int rc;
    125125
    126         log_msg(LVL_DEBUG, "udp_inet_init()");
     126        log_msg(LOG_DEFAULT, LVL_DEBUG, "udp_inet_init()");
    127127
    128128        rc = inet_init(IP_PROTO_UDP, &udp_inet_ev_ops);
    129129        if (rc != EOK) {
    130                 log_msg(LVL_ERROR, "Failed connecting to internet service.");
     130                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed connecting to internet service.");
    131131                return ENOENT;
    132132        }
Note: See TracChangeset for help on using the changeset viewer.