Ignore:
File:
1 edited

Legend:

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

    rf0a2720 rf597bc4  
    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_DEBUG2, "%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_DEBUG2, "%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_DEBUG2, "tcp_socket_match(sock=(%x,%u), pat=(%x,%u))",
     314        log_msg(LOG_DEFAULT, LVL_DEBUG2, "tcp_socket_match(sock=(%x,%u), pat=(%x,%u))",
    315315            sock->addr.ipv4, sock->port, patt->addr.ipv4, patt->port);
    316316
     
    323323                return false;
    324324
    325         log_msg(LVL_DEBUG2, " -> match");
     325        log_msg(LOG_DEFAULT, LVL_DEBUG2, " -> match");
    326326
    327327        return true;
     
    331331static bool tcp_sockpair_match(tcp_sockpair_t *sp, tcp_sockpair_t *pattern)
    332332{
    333         log_msg(LVL_DEBUG2, "tcp_sockpair_match(%p, %p)", sp, pattern);
     333        log_msg(LOG_DEFAULT, LVL_DEBUG2, "tcp_sockpair_match(%p, %p)", sp, pattern);
    334334
    335335        if (!tcp_socket_match(&sp->local, &pattern->local))
     
    353353tcp_conn_t *tcp_conn_find_ref(tcp_sockpair_t *sp)
    354354{
    355         log_msg(LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
    356 
     355        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
     356       
     357        log_msg(LOG_DEFAULT, LVL_DEBUG2, "compare conn (f:(%x,%u), l:(%x,%u))",
     358            sp->foreign.addr.ipv4, sp->foreign.port,
     359            sp->local.addr.ipv4, sp->local.port);
     360       
    357361        fibril_mutex_lock(&conn_list_lock);
    358 
     362       
    359363        list_foreach(conn_list, link) {
    360364                tcp_conn_t *conn = list_get_instance(link, tcp_conn_t, link);
    361365                tcp_sockpair_t *csp = &conn->ident;
    362                 log_msg(LVL_DEBUG2, "compare with conn (f:(%x,%u), l:(%x,%u))",
     366               
     367                log_msg(LOG_DEFAULT, LVL_DEBUG2, " - with (f:(%x,%u), l:(%x,%u))",
    363368                    csp->foreign.addr.ipv4, csp->foreign.port,
    364369                    csp->local.addr.ipv4, csp->local.port);
     370               
    365371                if (tcp_sockpair_match(sp, csp)) {
    366372                        tcp_conn_addref(conn);
     
    369375                }
    370376        }
    371 
     377       
    372378        fibril_mutex_unlock(&conn_list_lock);
    373379        return NULL;
     
    380386static void tcp_conn_reset(tcp_conn_t *conn)
    381387{
    382         log_msg(LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
     388        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
    383389        tcp_conn_state_set(conn, st_closed);
    384390        conn->reset = true;
     
    398404{
    399405        /* TODO */
    400         log_msg(LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
     406        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
    401407}
    402408
     
    422428                return true;
    423429        case st_closed:
    424                 log_msg(LVL_WARN, "state=%d", (int) conn->cstate);
     430                log_msg(LOG_DEFAULT, LVL_WARN, "state=%d", (int) conn->cstate);
    425431                assert(false);
    426432        }
     
    436442static void tcp_conn_sa_listen(tcp_conn_t *conn, tcp_segment_t *seg)
    437443{
    438         log_msg(LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
     444        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
    439445
    440446        if ((seg->ctrl & CTL_RST) != 0) {
    441                 log_msg(LVL_DEBUG, "Ignoring incoming RST.");
     447                log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring incoming RST.");
    442448                return;
    443449        }
    444450
    445451        if ((seg->ctrl & CTL_ACK) != 0) {
    446                 log_msg(LVL_DEBUG, "Incoming ACK, send acceptable RST.");
     452                log_msg(LOG_DEFAULT, LVL_DEBUG, "Incoming ACK, send acceptable RST.");
    447453                tcp_reply_rst(&conn->ident, seg);
    448454                return;
     
    450456
    451457        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.");
     458                log_msg(LOG_DEFAULT, LVL_DEBUG, "SYN not present. Ignoring segment.");
     459                return;
     460        }
     461
     462        log_msg(LOG_DEFAULT, LVL_DEBUG, "Got SYN, sending SYN, ACK.");
    457463
    458464        conn->rcv_nxt = seg->seq + 1;
     
    460466
    461467
    462         log_msg(LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
     468        log_msg(LOG_DEFAULT, LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
    463469
    464470        if (seg->len > 1)
    465                 log_msg(LVL_WARN, "SYN combined with data, ignoring data.");
     471                log_msg(LOG_DEFAULT, LVL_WARN, "SYN combined with data, ignoring data.");
    466472
    467473        /* XXX select ISS */
     
    493499static void tcp_conn_sa_syn_sent(tcp_conn_t *conn, tcp_segment_t *seg)
    494500{
    495         log_msg(LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
     501        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
    496502
    497503        if ((seg->ctrl & CTL_ACK) != 0) {
    498                 log_msg(LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
     504                log_msg(LOG_DEFAULT, LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
    499505                    conn->snd_una, seg->ack, conn->snd_nxt);
    500506                if (!seq_no_ack_acceptable(conn, seg->ack)) {
    501507                        if ((seg->ctrl & CTL_RST) == 0) {
    502                                 log_msg(LVL_WARN, "ACK not acceptable, send RST");
     508                                log_msg(LOG_DEFAULT, LVL_WARN, "ACK not acceptable, send RST");
    503509                                tcp_reply_rst(&conn->ident, seg);
    504510                        } else {
    505                                 log_msg(LVL_WARN, "RST,ACK not acceptable, drop");
     511                                log_msg(LOG_DEFAULT, LVL_WARN, "RST,ACK not acceptable, drop");
    506512                        }
    507513                        return;
     
    512518                /* If we get here, we have either an acceptable ACK or no ACK */
    513519                if ((seg->ctrl & CTL_ACK) != 0) {
    514                         log_msg(LVL_DEBUG, "%s: Connection reset. -> Closed",
     520                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: Connection reset. -> Closed",
    515521                            conn->name);
    516522                        /* Reset connection */
     
    518524                        return;
    519525                } else {
    520                         log_msg(LVL_DEBUG, "%s: RST without ACK, drop",
     526                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: RST without ACK, drop",
    521527                            conn->name);
    522528                        return;
     
    527533
    528534        if ((seg->ctrl & CTL_SYN) == 0) {
    529                 log_msg(LVL_DEBUG, "No SYN bit, ignoring segment.");
     535                log_msg(LOG_DEFAULT, LVL_DEBUG, "No SYN bit, ignoring segment.");
    530536                return;
    531537        }
     
    544550        }
    545551
    546         log_msg(LVL_DEBUG, "Sent SYN, got SYN.");
     552        log_msg(LOG_DEFAULT, LVL_DEBUG, "Sent SYN, got SYN.");
    547553
    548554        /*
     
    551557         * will always be accepted as new window setting.
    552558         */
    553         log_msg(LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
     559        log_msg(LOG_DEFAULT, LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
    554560            "SND.WL2 = %" PRIu32, seg->wnd, seg->seq, seg->seq);
    555561        conn->snd_wnd = seg->wnd;
     
    558564
    559565        if (seq_no_syn_acked(conn)) {
    560                 log_msg(LVL_DEBUG, "%s: syn acked -> Established", conn->name);
     566                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn acked -> Established", conn->name);
    561567                tcp_conn_state_set(conn, st_established);
    562568                tcp_tqueue_ctrl_seg(conn, CTL_ACK /* XXX */);
    563569        } else {
    564                 log_msg(LVL_DEBUG, "%s: syn not acked -> Syn-Received",
     570                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn not acked -> Syn-Received",
    565571                    conn->name);
    566572                tcp_conn_state_set(conn, st_syn_received);
     
    582588        tcp_segment_t *pseg;
    583589
    584         log_msg(LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
     590        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
    585591
    586592        /* Discard unacceptable segments ("old duplicates") */
    587593        if (!seq_no_segment_acceptable(conn, seg)) {
    588                 log_msg(LVL_DEBUG, "Replying ACK to unacceptable segment.");
     594                log_msg(LOG_DEFAULT, LVL_DEBUG, "Replying ACK to unacceptable segment.");
    589595                tcp_tqueue_ctrl_seg(conn, CTL_ACK);
    590596                tcp_segment_delete(seg);
     
    682688        assert(seq_no_in_rcv_wnd(conn, seg->seq));
    683689
    684         log_msg(LVL_WARN, "SYN is in receive window, should send reset. XXX");
     690        log_msg(LOG_DEFAULT, LVL_WARN, "SYN is in receive window, should send reset. XXX");
    685691
    686692        /*
     
    705711        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    706712                /* ACK is not acceptable, send RST. */
    707                 log_msg(LVL_WARN, "Segment ACK not acceptable, sending RST.");
     713                log_msg(LOG_DEFAULT, LVL_WARN, "Segment ACK not acceptable, sending RST.");
    708714                tcp_reply_rst(&conn->ident, seg);
    709715                tcp_segment_delete(seg);
     
    711717        }
    712718
    713         log_msg(LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
     719        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
    714720
    715721        tcp_conn_state_set(conn, st_established);
     
    730736static cproc_t tcp_conn_seg_proc_ack_est(tcp_conn_t *conn, tcp_segment_t *seg)
    731737{
    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",
     738        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_seg_proc_ack_est(%p, %p)", conn, seg);
     739
     740        log_msg(LOG_DEFAULT, LVL_DEBUG, "SEG.ACK=%u, SND.UNA=%u, SND.NXT=%u",
    735741            (unsigned)seg->ack, (unsigned)conn->snd_una,
    736742            (unsigned)conn->snd_nxt);
    737743
    738744        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    739                 log_msg(LVL_DEBUG, "ACK not acceptable.");
     745                log_msg(LOG_DEFAULT, LVL_DEBUG, "ACK not acceptable.");
    740746                if (!seq_no_ack_duplicate(conn, seg->ack)) {
    741                         log_msg(LVL_WARN, "Not acceptable, not duplicate. "
     747                        log_msg(LOG_DEFAULT, LVL_WARN, "Not acceptable, not duplicate. "
    742748                            "Send ACK and drop.");
    743749                        /* Not acceptable, not duplicate. Send ACK and drop. */
     
    746752                        return cp_done;
    747753                } else {
    748                         log_msg(LVL_DEBUG, "Ignoring duplicate ACK.");
     754                        log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring duplicate ACK.");
    749755                }
    750756        } else {
     
    758764                conn->snd_wl2 = seg->ack;
    759765
    760                 log_msg(LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
     766                log_msg(LOG_DEFAULT, LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
    761767                    ", SND.WL1=%" PRIu32 ", SND.WL2=%" PRIu32,
    762768                    conn->snd_wnd, conn->snd_wl1, conn->snd_wl2);
     
    785791
    786792        if (conn->fin_is_acked) {
    787                 log_msg(LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
     793                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
    788794                tcp_conn_state_set(conn, st_fin_wait_2);
    789795        }
     
    850856
    851857        if (conn->fin_is_acked) {
    852                 log_msg(LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
     858                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
    853859                tcp_conn_remove(conn);
    854860                tcp_conn_state_set(conn, st_closed);
     
    881887static cproc_t tcp_conn_seg_proc_ack(tcp_conn_t *conn, tcp_segment_t *seg)
    882888{
    883         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
     889        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
    884890            conn->name, conn, seg);
    885891
    886892        if ((seg->ctrl & CTL_ACK) == 0) {
    887                 log_msg(LVL_WARN, "Segment has no ACK. Dropping.");
     893                log_msg(LOG_DEFAULT, LVL_WARN, "Segment has no ACK. Dropping.");
    888894                tcp_segment_delete(seg);
    889895                return cp_done;
     
    940946        size_t xfer_size;
    941947
    942         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
     948        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
    943949            conn->name, conn, seg);
    944950
     
    982988        fibril_condvar_broadcast(&conn->rcv_buf_cv);
    983989
    984         log_msg(LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
     990        log_msg(LOG_DEFAULT, LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
    985991
    986992        /* Advance RCV.NXT */
     
    9981004                tcp_conn_trim_seg_to_wnd(conn, seg);
    9991005        } else {
    1000                 log_msg(LVL_DEBUG, "%s: Nothing left in segment, dropping "
     1006                log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: Nothing left in segment, dropping "
    10011007                    "(xfer_size=%zu, SEG.LEN=%" PRIu32 ", seg->ctrl=%u)",
    10021008                    conn->name, xfer_size, seg->len, (unsigned int) seg->ctrl);
     
    10181024static cproc_t tcp_conn_seg_proc_fin(tcp_conn_t *conn, tcp_segment_t *seg)
    10191025{
    1020         log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
     1026        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
    10211027            conn->name, conn, seg);
    1022         log_msg(LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
     1028        log_msg(LOG_DEFAULT, LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
    10231029            (unsigned) seg->ctrl);
    10241030
    10251031        /* Only process FIN if no text is left in segment. */
    10261032        if (tcp_segment_text_size(seg) == 0 && (seg->ctrl & CTL_FIN) != 0) {
    1027                 log_msg(LVL_DEBUG, " - FIN found in segment.");
     1033                log_msg(LOG_DEFAULT, LVL_DEBUG, " - FIN found in segment.");
    10281034
    10291035                /* Send ACK */
     
    10421048                case st_syn_received:
    10431049                case st_established:
    1044                         log_msg(LVL_DEBUG, "%s: FIN received -> Close-Wait",
     1050                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Close-Wait",
    10451051                            conn->name);
    10461052                        tcp_conn_state_set(conn, st_close_wait);
    10471053                        break;
    10481054                case st_fin_wait_1:
    1049                         log_msg(LVL_DEBUG, "%s: FIN received -> Closing",
     1055                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Closing",
    10501056                            conn->name);
    10511057                        tcp_conn_state_set(conn, st_closing);
    10521058                        break;
    10531059                case st_fin_wait_2:
    1054                         log_msg(LVL_DEBUG, "%s: FIN received -> Time-Wait",
     1060                        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Time-Wait",
    10551061                            conn->name);
    10561062                        tcp_conn_state_set(conn, st_time_wait);
     
    10911097static void tcp_conn_seg_process(tcp_conn_t *conn, tcp_segment_t *seg)
    10921098{
    1093         log_msg(LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
     1099        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
    10941100        tcp_segment_dump(seg);
    10951101
     
    10971103        /* XXX Permit valid ACKs, URGs and RSTs */
    10981104/*      if (!seq_no_segment_acceptable(conn, seg)) {
    1099                 log_msg(LVL_WARN, "Segment not acceptable, dropping.");
     1105                log_msg(LOG_DEFAULT, LVL_WARN, "Segment not acceptable, dropping.");
    11001106                if ((seg->ctrl & CTL_RST) == 0) {
    11011107                        tcp_tqueue_ctrl_seg(conn, CTL_ACK);
     
    11311137         */
    11321138        if (seg->len > 0) {
    1133                 log_msg(LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
     1139                log_msg(LOG_DEFAULT, LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
    11341140                    seg, (size_t) seg->len);
    11351141                tcp_iqueue_insert_seg(&conn->incoming, seg);
     
    11461152void tcp_conn_segment_arrived(tcp_conn_t *conn, tcp_segment_t *seg)
    11471153{
    1148         log_msg(LVL_DEBUG, "%s: tcp_conn_segment_arrived(%p)",
     1154        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_segment_arrived(%p)",
    11491155            conn->name, seg);
    11501156
     
    11651171                tcp_conn_sa_queue(conn, seg); break;
    11661172        case st_closed:
    1167                 log_msg(LVL_DEBUG, "state=%d", (int) conn->cstate);
     1173                log_msg(LOG_DEFAULT, LVL_DEBUG, "state=%d", (int) conn->cstate);
    11681174                assert(false);
    11691175        }
     
    11781184        tcp_conn_t *conn = (tcp_conn_t *) arg;
    11791185
    1180         log_msg(LVL_DEBUG, "tw_timeout_func(%p)", conn);
     1186        log_msg(LOG_DEFAULT, LVL_DEBUG, "tw_timeout_func(%p)", conn);
    11811187
    11821188        fibril_mutex_lock(&conn->lock);
    11831189
    11841190        if (conn->cstate == st_closed) {
    1185                 log_msg(LVL_DEBUG, "Connection already closed.");
     1191                log_msg(LOG_DEFAULT, LVL_DEBUG, "Connection already closed.");
    11861192                fibril_mutex_unlock(&conn->lock);
    11871193                tcp_conn_delref(conn);
     
    11891195        }
    11901196
    1191         log_msg(LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
     1197        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
    11921198        tcp_conn_remove(conn);
    11931199        tcp_conn_state_set(conn, st_closed);
     
    12401246void tcp_unexpected_segment(tcp_sockpair_t *sp, tcp_segment_t *seg)
    12411247{
    1242         log_msg(LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
     1248        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
    12431249
    12441250        if ((seg->ctrl & CTL_RST) == 0)
     
    12681274        tcp_segment_t *rseg;
    12691275
    1270         log_msg(LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
     1276        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
    12711277
    12721278        rseg = tcp_segment_make_rst(seg);
Note: See TracChangeset for help on using the changeset viewer.