Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/srv/net/tcp/conn.c

    r69a93df7 ra2e3ee6  
    3636
    3737#include <adt/list.h>
    38 #include <bool.h>
     38#include <stdbool.h>
    3939#include <errno.h>
    4040#include <io/log.h>
     
    164164static void tcp_conn_free(tcp_conn_t *conn)
    165165{
    166         log_msg(LVL_DEBUG, "%s: tcp_conn_free(%p)", conn->name, conn);
     166        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_free(%p)", conn->name, conn);
    167167        tcp_tqueue_fini(&conn->retransmit);
    168168
     
    184184void tcp_conn_addref(tcp_conn_t *conn)
    185185{
    186         log_msg(LVL_DEBUG, "%s: tcp_conn_addref(%p)", conn->name, conn);
     186        log_msg(LOG_DEFAULT, LVL_DEBUG2, "%s: tcp_conn_addref(%p)", conn->name, conn);
    187187        atomic_inc(&conn->refcnt);
    188188}
     
    196196void tcp_conn_delref(tcp_conn_t *conn)
    197197{
    198         log_msg(LVL_DEBUG, "%s: tcp_conn_delref(%p)", conn->name, conn);
     198        log_msg(LOG_DEFAULT, LVL_DEBUG2, "%s: tcp_conn_delref(%p)", conn->name, conn);
    199199
    200200        if (atomic_predec(&conn->refcnt) == 0)
     
    211211void tcp_conn_delete(tcp_conn_t *conn)
    212212{
    213         log_msg(LVL_DEBUG, "%s: tcp_conn_delete(%p)", conn->name, conn);
     213        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_delete(%p)", conn->name, conn);
    214214
    215215        assert(conn->deleted == false);
     
    245245        tcp_cstate_t old_state;
    246246
    247         log_msg(LVL_DEBUG, "tcp_conn_state_set(%p)", conn);
     247        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set(%p)", conn);
    248248
    249249        old_state = conn->cstate;
     
    253253        /* Run user callback function */
    254254        if (conn->cstate_cb != NULL) {
    255                 log_msg(LVL_DEBUG, "tcp_conn_state_set() - run user CB");
     255                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set() - run user CB");
    256256                conn->cstate_cb(conn, conn->cstate_cb_arg);
    257257        } else {
    258                 log_msg(LVL_DEBUG, "tcp_conn_state_set() - no user CB");
     258                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set() - no user CB");
    259259        }
    260260
     
    293293        case st_syn_received:
    294294        case st_established:
    295                 log_msg(LVL_DEBUG, "%s: FIN sent -> Fin-Wait-1", conn->name);
     295                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN sent -> Fin-Wait-1", conn->name);
    296296                tcp_conn_state_set(conn, st_fin_wait_1);
    297297                break;
    298298        case st_close_wait:
    299                 log_msg(LVL_DEBUG, "%s: FIN sent -> Last-Ack", conn->name);
     299                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN sent -> Last-Ack", conn->name);
    300300                tcp_conn_state_set(conn, st_last_ack);
    301301                break;
    302302        default:
    303                 log_msg(LVL_ERROR, "%s: Connection state %d", conn->name,
     303                log_msg(LOG_DEFAULT, LVL_ERROR, "%s: Connection state %d", conn->name,
    304304                    conn->cstate);
    305305                assert(false);
     
    312312static bool tcp_socket_match(tcp_sock_t *sock, tcp_sock_t *patt)
    313313{
    314         log_msg(LVL_DEBUG, "tcp_socket_match(sock=(%x,%u), pat=(%x,%u))",
    315             sock->addr.ipv4, sock->port, patt->addr.ipv4, patt->port);
    316 
    317         if (patt->addr.ipv4 != TCP_IPV4_ANY &&
    318             patt->addr.ipv4 != sock->addr.ipv4)
     314        if ((!inet_addr_is_any(&patt->addr)) &&
     315            (!inet_addr_compare(&patt->addr, &sock->addr)))
    319316                return false;
    320317
    321         if (patt->port != TCP_PORT_ANY &&
    322             patt->port != sock->port)
     318        if ((patt->port != TCP_PORT_ANY) &&
     319            (patt->port != sock->port))
    323320                return false;
    324321
    325         log_msg(LVL_DEBUG, " -> match");
     322        log_msg(LOG_DEFAULT, LVL_DEBUG2, " -> match");
    326323
    327324        return true;
     
    331328static bool tcp_sockpair_match(tcp_sockpair_t *sp, tcp_sockpair_t *pattern)
    332329{
    333         log_msg(LVL_DEBUG, "tcp_sockpair_match(%p, %p)", sp, pattern);
     330        log_msg(LOG_DEFAULT, LVL_DEBUG2, "tcp_sockpair_match(%p, %p)", sp, pattern);
    334331
    335332        if (!tcp_socket_match(&sp->local, &pattern->local))
     
    353350tcp_conn_t *tcp_conn_find_ref(tcp_sockpair_t *sp)
    354351{
    355         log_msg(LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
    356 
     352        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
     353       
    357354        fibril_mutex_lock(&conn_list_lock);
    358 
     355       
    359356        list_foreach(conn_list, link) {
    360357                tcp_conn_t *conn = list_get_instance(link, tcp_conn_t, link);
    361358                tcp_sockpair_t *csp = &conn->ident;
    362                 log_msg(LVL_DEBUG, "compare with conn (f:(%x,%u), l:(%x,%u))",
    363                     csp->foreign.addr.ipv4, csp->foreign.port,
    364                     csp->local.addr.ipv4, csp->local.port);
     359               
    365360                if (tcp_sockpair_match(sp, csp)) {
    366361                        tcp_conn_addref(conn);
     
    369364                }
    370365        }
    371 
     366       
    372367        fibril_mutex_unlock(&conn_list_lock);
    373368        return NULL;
     
    380375static void tcp_conn_reset(tcp_conn_t *conn)
    381376{
    382         log_msg(LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
     377        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
    383378        tcp_conn_state_set(conn, st_closed);
    384379        conn->reset = true;
     
    398393{
    399394        /* TODO */
    400         log_msg(LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
     395        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
    401396}
    402397
     
    422417                return true;
    423418        case st_closed:
    424                 log_msg(LVL_WARN, "state=%d", (int) conn->cstate);
     419                log_msg(LOG_DEFAULT, LVL_WARN, "state=%d", (int) conn->cstate);
    425420                assert(false);
    426421        }
     
    436431static void tcp_conn_sa_listen(tcp_conn_t *conn, tcp_segment_t *seg)
    437432{
    438         log_msg(LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
     433        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
    439434
    440435        if ((seg->ctrl & CTL_RST) != 0) {
    441                 log_msg(LVL_DEBUG, "Ignoring incoming RST.");
     436                log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring incoming RST.");
    442437                return;
    443438        }
    444439
    445440        if ((seg->ctrl & CTL_ACK) != 0) {
    446                 log_msg(LVL_DEBUG, "Incoming ACK, send acceptable RST.");
     441                log_msg(LOG_DEFAULT, LVL_DEBUG, "Incoming ACK, send acceptable RST.");
    447442                tcp_reply_rst(&conn->ident, seg);
    448443                return;
     
    450445
    451446        if ((seg->ctrl & CTL_SYN) == 0) {
    452                 log_msg(LVL_DEBUG, "SYN not present. Ignoring segment.");
    453                 return;
    454         }
    455 
    456         log_msg(LVL_DEBUG, "Got SYN, sending SYN, ACK.");
     447                log_msg(LOG_DEFAULT, LVL_DEBUG, "SYN not present. Ignoring segment.");
     448                return;
     449        }
     450
     451        log_msg(LOG_DEFAULT, LVL_DEBUG, "Got SYN, sending SYN, ACK.");
    457452
    458453        conn->rcv_nxt = seg->seq + 1;
     
    460455
    461456
    462         log_msg(LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
     457        log_msg(LOG_DEFAULT, LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
    463458
    464459        if (seg->len > 1)
    465                 log_msg(LVL_WARN, "SYN combined with data, ignoring data.");
     460                log_msg(LOG_DEFAULT, LVL_WARN, "SYN combined with data, ignoring data.");
    466461
    467462        /* XXX select ISS */
     
    493488static void tcp_conn_sa_syn_sent(tcp_conn_t *conn, tcp_segment_t *seg)
    494489{
    495         log_msg(LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
     490        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
    496491
    497492        if ((seg->ctrl & CTL_ACK) != 0) {
    498                 log_msg(LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
     493                log_msg(LOG_DEFAULT, LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
    499494                    conn->snd_una, seg->ack, conn->snd_nxt);
    500495                if (!seq_no_ack_acceptable(conn, seg->ack)) {
    501496                        if ((seg->ctrl & CTL_RST) == 0) {
    502                                 log_msg(LVL_WARN, "ACK not acceptable, send RST");
     497                                log_msg(LOG_DEFAULT, LVL_WARN, "ACK not acceptable, send RST");
    503498                                tcp_reply_rst(&conn->ident, seg);
    504499                        } else {
    505                                 log_msg(LVL_WARN, "RST,ACK not acceptable, drop");
     500                                log_msg(LOG_DEFAULT, LVL_WARN, "RST,ACK not acceptable, drop");
    506501                        }
    507502                        return;
     
    512507                /* If we get here, we have either an acceptable ACK or no ACK */
    513508                if ((seg->ctrl & CTL_ACK) != 0) {
    514                         log_msg(LVL_DEBUG, "%s: Connection reset. -> Closed",
     509                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: Connection reset. -> Closed",
    515510                            conn->name);
    516511                        /* Reset connection */
     
    518513                        return;
    519514                } else {
    520                         log_msg(LVL_DEBUG, "%s: RST without ACK, drop",
     515                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: RST without ACK, drop",
    521516                            conn->name);
    522517                        return;
     
    527522
    528523        if ((seg->ctrl & CTL_SYN) == 0) {
    529                 log_msg(LVL_DEBUG, "No SYN bit, ignoring segment.");
     524                log_msg(LOG_DEFAULT, LVL_DEBUG, "No SYN bit, ignoring segment.");
    530525                return;
    531526        }
     
    544539        }
    545540
    546         log_msg(LVL_DEBUG, "Sent SYN, got SYN.");
     541        log_msg(LOG_DEFAULT, LVL_DEBUG, "Sent SYN, got SYN.");
    547542
    548543        /*
     
    551546         * will always be accepted as new window setting.
    552547         */
    553         log_msg(LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
     548        log_msg(LOG_DEFAULT, LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
    554549            "SND.WL2 = %" PRIu32, seg->wnd, seg->seq, seg->seq);
    555550        conn->snd_wnd = seg->wnd;
     
    558553
    559554        if (seq_no_syn_acked(conn)) {
    560                 log_msg(LVL_DEBUG, "%s: syn acked -> Established", conn->name);
     555                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn acked -> Established", conn->name);
    561556                tcp_conn_state_set(conn, st_established);
    562557                tcp_tqueue_ctrl_seg(conn, CTL_ACK /* XXX */);
    563558        } else {
    564                 log_msg(LVL_DEBUG, "%s: syn not acked -> Syn-Received",
     559                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn not acked -> Syn-Received",
    565560                    conn->name);
    566561                tcp_conn_state_set(conn, st_syn_received);
     
    582577        tcp_segment_t *pseg;
    583578
    584         log_msg(LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
     579        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
    585580
    586581        /* Discard unacceptable segments ("old duplicates") */
    587582        if (!seq_no_segment_acceptable(conn, seg)) {
    588                 log_msg(LVL_DEBUG, "Replying ACK to unacceptable segment.");
     583                log_msg(LOG_DEFAULT, LVL_DEBUG, "Replying ACK to unacceptable segment.");
    589584                tcp_tqueue_ctrl_seg(conn, CTL_ACK);
    590585                tcp_segment_delete(seg);
     
    682677        assert(seq_no_in_rcv_wnd(conn, seg->seq));
    683678
    684         log_msg(LVL_WARN, "SYN is in receive window, should send reset. XXX");
     679        log_msg(LOG_DEFAULT, LVL_WARN, "SYN is in receive window, should send reset. XXX");
    685680
    686681        /*
     
    705700        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    706701                /* ACK is not acceptable, send RST. */
    707                 log_msg(LVL_WARN, "Segment ACK not acceptable, sending RST.");
     702                log_msg(LOG_DEFAULT, LVL_WARN, "Segment ACK not acceptable, sending RST.");
    708703                tcp_reply_rst(&conn->ident, seg);
    709704                tcp_segment_delete(seg);
     
    711706        }
    712707
    713         log_msg(LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
     708        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
    714709
    715710        tcp_conn_state_set(conn, st_established);
     
    730725static cproc_t tcp_conn_seg_proc_ack_est(tcp_conn_t *conn, tcp_segment_t *seg)
    731726{
    732         log_msg(LVL_DEBUG, "tcp_conn_seg_proc_ack_est(%p, %p)", conn, seg);
    733 
    734         log_msg(LVL_DEBUG, "SEG.ACK=%u, SND.UNA=%u, SND.NXT=%u",
     727        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_seg_proc_ack_est(%p, %p)", conn, seg);
     728
     729        log_msg(LOG_DEFAULT, LVL_DEBUG, "SEG.ACK=%u, SND.UNA=%u, SND.NXT=%u",
    735730            (unsigned)seg->ack, (unsigned)conn->snd_una,
    736731            (unsigned)conn->snd_nxt);
    737732
    738733        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    739                 log_msg(LVL_DEBUG, "ACK not acceptable.");
     734                log_msg(LOG_DEFAULT, LVL_DEBUG, "ACK not acceptable.");
    740735                if (!seq_no_ack_duplicate(conn, seg->ack)) {
    741                         log_msg(LVL_WARN, "Not acceptable, not duplicate. "
     736                        log_msg(LOG_DEFAULT, LVL_WARN, "Not acceptable, not duplicate. "
    742737                            "Send ACK and drop.");
    743738                        /* Not acceptable, not duplicate. Send ACK and drop. */
     
    746741                        return cp_done;
    747742                } else {
    748                         log_msg(LVL_DEBUG, "Ignoring duplicate ACK.");
     743                        log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring duplicate ACK.");
    749744                }
    750745        } else {
     
    758753                conn->snd_wl2 = seg->ack;
    759754
    760                 log_msg(LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
     755                log_msg(LOG_DEFAULT, LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
    761756                    ", SND.WL1=%" PRIu32 ", SND.WL2=%" PRIu32,
    762757                    conn->snd_wnd, conn->snd_wl1, conn->snd_wl2);
     
    785780
    786781        if (conn->fin_is_acked) {
    787                 log_msg(LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
     782                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
    788783                tcp_conn_state_set(conn, st_fin_wait_2);
    789784        }
     
    850845
    851846        if (conn->fin_is_acked) {
    852                 log_msg(LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
     847                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
    853848                tcp_conn_remove(conn);
    854849                tcp_conn_state_set(conn, st_closed);
     
    881876static cproc_t tcp_conn_seg_proc_ack(tcp_conn_t *conn, tcp_segment_t *seg)
    882877{
    883         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
     878        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
    884879            conn->name, conn, seg);
    885880
    886881        if ((seg->ctrl & CTL_ACK) == 0) {
    887                 log_msg(LVL_WARN, "Segment has no ACK. Dropping.");
     882                log_msg(LOG_DEFAULT, LVL_WARN, "Segment has no ACK. Dropping.");
    888883                tcp_segment_delete(seg);
    889884                return cp_done;
     
    940935        size_t xfer_size;
    941936
    942         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
     937        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
    943938            conn->name, conn, seg);
    944939
     
    982977        fibril_condvar_broadcast(&conn->rcv_buf_cv);
    983978
    984         log_msg(LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
     979        log_msg(LOG_DEFAULT, LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
    985980
    986981        /* Advance RCV.NXT */
     
    998993                tcp_conn_trim_seg_to_wnd(conn, seg);
    999994        } else {
    1000                 log_msg(LVL_DEBUG, "%s: Nothing left in segment, dropping "
    1001                     "(xfer_size=%zu, SEG.LEN=%zu, seg->ctrl=%u)",
    1002                     conn->name, xfer_size, seg->len, (unsigned)seg->ctrl);
     995                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: Nothing left in segment, dropping "
     996                    "(xfer_size=%zu, SEG.LEN=%" PRIu32 ", seg->ctrl=%u)",
     997                    conn->name, xfer_size, seg->len, (unsigned int) seg->ctrl);
    1003998                /* Nothing left in segment */
    1004999                tcp_segment_delete(seg);
     
    10181013static cproc_t tcp_conn_seg_proc_fin(tcp_conn_t *conn, tcp_segment_t *seg)
    10191014{
    1020         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
     1015        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
    10211016            conn->name, conn, seg);
    1022         log_msg(LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
     1017        log_msg(LOG_DEFAULT, LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
    10231018            (unsigned) seg->ctrl);
    10241019
    10251020        /* Only process FIN if no text is left in segment. */
    10261021        if (tcp_segment_text_size(seg) == 0 && (seg->ctrl & CTL_FIN) != 0) {
    1027                 log_msg(LVL_DEBUG, " - FIN found in segment.");
     1022                log_msg(LOG_DEFAULT, LVL_DEBUG, " - FIN found in segment.");
    10281023
    10291024                /* Send ACK */
     
    10421037                case st_syn_received:
    10431038                case st_established:
    1044                         log_msg(LVL_DEBUG, "%s: FIN received -> Close-Wait",
     1039                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Close-Wait",
    10451040                            conn->name);
    10461041                        tcp_conn_state_set(conn, st_close_wait);
    10471042                        break;
    10481043                case st_fin_wait_1:
    1049                         log_msg(LVL_DEBUG, "%s: FIN received -> Closing",
     1044                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Closing",
    10501045                            conn->name);
    10511046                        tcp_conn_state_set(conn, st_closing);
    10521047                        break;
    10531048                case st_fin_wait_2:
    1054                         log_msg(LVL_DEBUG, "%s: FIN received -> Time-Wait",
     1049                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Time-Wait",
    10551050                            conn->name);
    10561051                        tcp_conn_state_set(conn, st_time_wait);
     
    10911086static void tcp_conn_seg_process(tcp_conn_t *conn, tcp_segment_t *seg)
    10921087{
    1093         log_msg(LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
     1088        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
    10941089        tcp_segment_dump(seg);
    10951090
     
    10971092        /* XXX Permit valid ACKs, URGs and RSTs */
    10981093/*      if (!seq_no_segment_acceptable(conn, seg)) {
    1099                 log_msg(LVL_WARN, "Segment not acceptable, dropping.");
     1094                log_msg(LOG_DEFAULT, LVL_WARN, "Segment not acceptable, dropping.");
    11001095                if ((seg->ctrl & CTL_RST) == 0) {
    11011096                        tcp_tqueue_ctrl_seg(conn, CTL_ACK);
     
    11311126         */
    11321127        if (seg->len > 0) {
    1133                 log_msg(LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
     1128                log_msg(LOG_DEFAULT, LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
    11341129                    seg, (size_t) seg->len);
    11351130                tcp_iqueue_insert_seg(&conn->incoming, seg);
     
    11461141void tcp_conn_segment_arrived(tcp_conn_t *conn, tcp_segment_t *seg)
    11471142{
    1148         log_msg(LVL_DEBUG, "%c: tcp_conn_segment_arrived(%p)",
     1143        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_segment_arrived(%p)",
    11491144            conn->name, seg);
    11501145
     
    11651160                tcp_conn_sa_queue(conn, seg); break;
    11661161        case st_closed:
    1167                 log_msg(LVL_DEBUG, "state=%d", (int) conn->cstate);
     1162                log_msg(LOG_DEFAULT, LVL_DEBUG, "state=%d", (int) conn->cstate);
    11681163                assert(false);
    11691164        }
     
    11781173        tcp_conn_t *conn = (tcp_conn_t *) arg;
    11791174
    1180         log_msg(LVL_DEBUG, "tw_timeout_func(%p)", conn);
     1175        log_msg(LOG_DEFAULT, LVL_DEBUG, "tw_timeout_func(%p)", conn);
    11811176
    11821177        fibril_mutex_lock(&conn->lock);
    11831178
    11841179        if (conn->cstate == st_closed) {
    1185                 log_msg(LVL_DEBUG, "Connection already closed.");
     1180                log_msg(LOG_DEFAULT, LVL_DEBUG, "Connection already closed.");
    11861181                fibril_mutex_unlock(&conn->lock);
    11871182                tcp_conn_delref(conn);
     
    11891184        }
    11901185
    1191         log_msg(LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
     1186        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
    11921187        tcp_conn_remove(conn);
    11931188        tcp_conn_state_set(conn, st_closed);
     
    12401235void tcp_unexpected_segment(tcp_sockpair_t *sp, tcp_segment_t *seg)
    12411236{
    1242         log_msg(LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
     1237        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
    12431238
    12441239        if ((seg->ctrl & CTL_RST) == 0)
     
    12681263        tcp_segment_t *rseg;
    12691264
    1270         log_msg(LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
     1265        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
    12711266
    12721267        rseg = tcp_segment_make_rst(seg);
Note: See TracChangeset for help on using the changeset viewer.