Ignore:
File:
1 edited

Legend:

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

    ra2e3ee6 r69a93df7  
    3636
    3737#include <adt/list.h>
    38 #include <stdbool.h>
     38#include <bool.h>
    3939#include <errno.h>
    4040#include <io/log.h>
     
    164164static void tcp_conn_free(tcp_conn_t *conn)
    165165{
    166         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_free(%p)", conn->name, conn);
     166        log_msg(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(LOG_DEFAULT, LVL_DEBUG2, "%s: tcp_conn_addref(%p)", conn->name, conn);
     186        log_msg(LVL_DEBUG, "%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(LOG_DEFAULT, LVL_DEBUG2, "%s: tcp_conn_delref(%p)", conn->name, conn);
     198        log_msg(LVL_DEBUG, "%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(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_delete(%p)", conn->name, conn);
     213        log_msg(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(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set(%p)", conn);
     247        log_msg(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(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set() - run user CB");
     255                log_msg(LVL_DEBUG, "tcp_conn_state_set() - run user CB");
    256256                conn->cstate_cb(conn, conn->cstate_cb_arg);
    257257        } else {
    258                 log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_state_set() - no user CB");
     258                log_msg(LVL_DEBUG, "tcp_conn_state_set() - no user CB");
    259259        }
    260260
     
    293293        case st_syn_received:
    294294        case st_established:
    295                 log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN sent -> Fin-Wait-1", conn->name);
     295                log_msg(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(LOG_DEFAULT, LVL_DEBUG, "%s: FIN sent -> Last-Ack", conn->name);
     299                log_msg(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(LOG_DEFAULT, LVL_ERROR, "%s: Connection state %d", conn->name,
     303                log_msg(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         if ((!inet_addr_is_any(&patt->addr)) &&
    315             (!inet_addr_compare(&patt->addr, &sock->addr)))
     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)
    316319                return false;
    317320
    318         if ((patt->port != TCP_PORT_ANY) &&
    319             (patt->port != sock->port))
     321        if (patt->port != TCP_PORT_ANY &&
     322            patt->port != sock->port)
    320323                return false;
    321324
    322         log_msg(LOG_DEFAULT, LVL_DEBUG2, " -> match");
     325        log_msg(LVL_DEBUG, " -> match");
    323326
    324327        return true;
     
    328331static bool tcp_sockpair_match(tcp_sockpair_t *sp, tcp_sockpair_t *pattern)
    329332{
    330         log_msg(LOG_DEFAULT, LVL_DEBUG2, "tcp_sockpair_match(%p, %p)", sp, pattern);
     333        log_msg(LVL_DEBUG, "tcp_sockpair_match(%p, %p)", sp, pattern);
    331334
    332335        if (!tcp_socket_match(&sp->local, &pattern->local))
     
    350353tcp_conn_t *tcp_conn_find_ref(tcp_sockpair_t *sp)
    351354{
    352         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
    353        
     355        log_msg(LVL_DEBUG, "tcp_conn_find_ref(%p)", sp);
     356
    354357        fibril_mutex_lock(&conn_list_lock);
    355        
     358
    356359        list_foreach(conn_list, link) {
    357360                tcp_conn_t *conn = list_get_instance(link, tcp_conn_t, link);
    358361                tcp_sockpair_t *csp = &conn->ident;
    359                
     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);
    360365                if (tcp_sockpair_match(sp, csp)) {
    361366                        tcp_conn_addref(conn);
     
    364369                }
    365370        }
    366        
     371
    367372        fibril_mutex_unlock(&conn_list_lock);
    368373        return NULL;
     
    375380static void tcp_conn_reset(tcp_conn_t *conn)
    376381{
    377         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
     382        log_msg(LVL_DEBUG, "%s: tcp_conn_reset()", conn->name);
    378383        tcp_conn_state_set(conn, st_closed);
    379384        conn->reset = true;
     
    393398{
    394399        /* TODO */
    395         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
     400        log_msg(LVL_DEBUG, "%s: tcp_reset_signal()", conn->name);
    396401}
    397402
     
    417422                return true;
    418423        case st_closed:
    419                 log_msg(LOG_DEFAULT, LVL_WARN, "state=%d", (int) conn->cstate);
     424                log_msg(LVL_WARN, "state=%d", (int) conn->cstate);
    420425                assert(false);
    421426        }
     
    431436static void tcp_conn_sa_listen(tcp_conn_t *conn, tcp_segment_t *seg)
    432437{
    433         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
     438        log_msg(LVL_DEBUG, "tcp_conn_sa_listen(%p, %p)", conn, seg);
    434439
    435440        if ((seg->ctrl & CTL_RST) != 0) {
    436                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring incoming RST.");
     441                log_msg(LVL_DEBUG, "Ignoring incoming RST.");
    437442                return;
    438443        }
    439444
    440445        if ((seg->ctrl & CTL_ACK) != 0) {
    441                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Incoming ACK, send acceptable RST.");
     446                log_msg(LVL_DEBUG, "Incoming ACK, send acceptable RST.");
    442447                tcp_reply_rst(&conn->ident, seg);
    443448                return;
     
    445450
    446451        if ((seg->ctrl & CTL_SYN) == 0) {
    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.");
     452                log_msg(LVL_DEBUG, "SYN not present. Ignoring segment.");
     453                return;
     454        }
     455
     456        log_msg(LVL_DEBUG, "Got SYN, sending SYN, ACK.");
    452457
    453458        conn->rcv_nxt = seg->seq + 1;
     
    455460
    456461
    457         log_msg(LOG_DEFAULT, LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
     462        log_msg(LVL_DEBUG, "rcv_nxt=%u", conn->rcv_nxt);
    458463
    459464        if (seg->len > 1)
    460                 log_msg(LOG_DEFAULT, LVL_WARN, "SYN combined with data, ignoring data.");
     465                log_msg(LVL_WARN, "SYN combined with data, ignoring data.");
    461466
    462467        /* XXX select ISS */
     
    488493static void tcp_conn_sa_syn_sent(tcp_conn_t *conn, tcp_segment_t *seg)
    489494{
    490         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
     495        log_msg(LVL_DEBUG, "tcp_conn_sa_syn_sent(%p, %p)", conn, seg);
    491496
    492497        if ((seg->ctrl & CTL_ACK) != 0) {
    493                 log_msg(LOG_DEFAULT, LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
     498                log_msg(LVL_DEBUG, "snd_una=%u, seg.ack=%u, snd_nxt=%u",
    494499                    conn->snd_una, seg->ack, conn->snd_nxt);
    495500                if (!seq_no_ack_acceptable(conn, seg->ack)) {
    496501                        if ((seg->ctrl & CTL_RST) == 0) {
    497                                 log_msg(LOG_DEFAULT, LVL_WARN, "ACK not acceptable, send RST");
     502                                log_msg(LVL_WARN, "ACK not acceptable, send RST");
    498503                                tcp_reply_rst(&conn->ident, seg);
    499504                        } else {
    500                                 log_msg(LOG_DEFAULT, LVL_WARN, "RST,ACK not acceptable, drop");
     505                                log_msg(LVL_WARN, "RST,ACK not acceptable, drop");
    501506                        }
    502507                        return;
     
    507512                /* If we get here, we have either an acceptable ACK or no ACK */
    508513                if ((seg->ctrl & CTL_ACK) != 0) {
    509                         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: Connection reset. -> Closed",
     514                        log_msg(LVL_DEBUG, "%s: Connection reset. -> Closed",
    510515                            conn->name);
    511516                        /* Reset connection */
     
    513518                        return;
    514519                } else {
    515                         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: RST without ACK, drop",
     520                        log_msg(LVL_DEBUG, "%s: RST without ACK, drop",
    516521                            conn->name);
    517522                        return;
     
    522527
    523528        if ((seg->ctrl & CTL_SYN) == 0) {
    524                 log_msg(LOG_DEFAULT, LVL_DEBUG, "No SYN bit, ignoring segment.");
     529                log_msg(LVL_DEBUG, "No SYN bit, ignoring segment.");
    525530                return;
    526531        }
     
    539544        }
    540545
    541         log_msg(LOG_DEFAULT, LVL_DEBUG, "Sent SYN, got SYN.");
     546        log_msg(LVL_DEBUG, "Sent SYN, got SYN.");
    542547
    543548        /*
     
    546551         * will always be accepted as new window setting.
    547552         */
    548         log_msg(LOG_DEFAULT, LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
     553        log_msg(LVL_DEBUG, "SND.WND := %" PRIu32 ", SND.WL1 := %" PRIu32 ", "
    549554            "SND.WL2 = %" PRIu32, seg->wnd, seg->seq, seg->seq);
    550555        conn->snd_wnd = seg->wnd;
     
    553558
    554559        if (seq_no_syn_acked(conn)) {
    555                 log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn acked -> Established", conn->name);
     560                log_msg(LVL_DEBUG, "%s: syn acked -> Established", conn->name);
    556561                tcp_conn_state_set(conn, st_established);
    557562                tcp_tqueue_ctrl_seg(conn, CTL_ACK /* XXX */);
    558563        } else {
    559                 log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: syn not acked -> Syn-Received",
     564                log_msg(LVL_DEBUG, "%s: syn not acked -> Syn-Received",
    560565                    conn->name);
    561566                tcp_conn_state_set(conn, st_syn_received);
     
    577582        tcp_segment_t *pseg;
    578583
    579         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
     584        log_msg(LVL_DEBUG, "tcp_conn_sa_seq(%p, %p)", conn, seg);
    580585
    581586        /* Discard unacceptable segments ("old duplicates") */
    582587        if (!seq_no_segment_acceptable(conn, seg)) {
    583                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Replying ACK to unacceptable segment.");
     588                log_msg(LVL_DEBUG, "Replying ACK to unacceptable segment.");
    584589                tcp_tqueue_ctrl_seg(conn, CTL_ACK);
    585590                tcp_segment_delete(seg);
     
    677682        assert(seq_no_in_rcv_wnd(conn, seg->seq));
    678683
    679         log_msg(LOG_DEFAULT, LVL_WARN, "SYN is in receive window, should send reset. XXX");
     684        log_msg(LVL_WARN, "SYN is in receive window, should send reset. XXX");
    680685
    681686        /*
     
    700705        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    701706                /* ACK is not acceptable, send RST. */
    702                 log_msg(LOG_DEFAULT, LVL_WARN, "Segment ACK not acceptable, sending RST.");
     707                log_msg(LVL_WARN, "Segment ACK not acceptable, sending RST.");
    703708                tcp_reply_rst(&conn->ident, seg);
    704709                tcp_segment_delete(seg);
     
    706711        }
    707712
    708         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
     713        log_msg(LVL_DEBUG, "%s: SYN ACKed -> Established", conn->name);
    709714
    710715        tcp_conn_state_set(conn, st_established);
     
    725730static cproc_t tcp_conn_seg_proc_ack_est(tcp_conn_t *conn, tcp_segment_t *seg)
    726731{
    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",
     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",
    730735            (unsigned)seg->ack, (unsigned)conn->snd_una,
    731736            (unsigned)conn->snd_nxt);
    732737
    733738        if (!seq_no_ack_acceptable(conn, seg->ack)) {
    734                 log_msg(LOG_DEFAULT, LVL_DEBUG, "ACK not acceptable.");
     739                log_msg(LVL_DEBUG, "ACK not acceptable.");
    735740                if (!seq_no_ack_duplicate(conn, seg->ack)) {
    736                         log_msg(LOG_DEFAULT, LVL_WARN, "Not acceptable, not duplicate. "
     741                        log_msg(LVL_WARN, "Not acceptable, not duplicate. "
    737742                            "Send ACK and drop.");
    738743                        /* Not acceptable, not duplicate. Send ACK and drop. */
     
    741746                        return cp_done;
    742747                } else {
    743                         log_msg(LOG_DEFAULT, LVL_DEBUG, "Ignoring duplicate ACK.");
     748                        log_msg(LVL_DEBUG, "Ignoring duplicate ACK.");
    744749                }
    745750        } else {
     
    753758                conn->snd_wl2 = seg->ack;
    754759
    755                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
     760                log_msg(LVL_DEBUG, "Updating send window, SND.WND=%" PRIu32
    756761                    ", SND.WL1=%" PRIu32 ", SND.WL2=%" PRIu32,
    757762                    conn->snd_wnd, conn->snd_wl1, conn->snd_wl2);
     
    780785
    781786        if (conn->fin_is_acked) {
    782                 log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
     787                log_msg(LVL_DEBUG, "%s: FIN acked -> Fin-Wait-2", conn->name);
    783788                tcp_conn_state_set(conn, st_fin_wait_2);
    784789        }
     
    845850
    846851        if (conn->fin_is_acked) {
    847                 log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
     852                log_msg(LVL_DEBUG, "%s: FIN acked -> Closed", conn->name);
    848853                tcp_conn_remove(conn);
    849854                tcp_conn_state_set(conn, st_closed);
     
    876881static cproc_t tcp_conn_seg_proc_ack(tcp_conn_t *conn, tcp_segment_t *seg)
    877882{
    878         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
     883        log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_ack(%p, %p)",
    879884            conn->name, conn, seg);
    880885
    881886        if ((seg->ctrl & CTL_ACK) == 0) {
    882                 log_msg(LOG_DEFAULT, LVL_WARN, "Segment has no ACK. Dropping.");
     887                log_msg(LVL_WARN, "Segment has no ACK. Dropping.");
    883888                tcp_segment_delete(seg);
    884889                return cp_done;
     
    935940        size_t xfer_size;
    936941
    937         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
     942        log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_text(%p, %p)",
    938943            conn->name, conn, seg);
    939944
     
    977982        fibril_condvar_broadcast(&conn->rcv_buf_cv);
    978983
    979         log_msg(LOG_DEFAULT, LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
     984        log_msg(LVL_DEBUG, "Received %zu bytes of data.", xfer_size);
    980985
    981986        /* Advance RCV.NXT */
     
    993998                tcp_conn_trim_seg_to_wnd(conn, seg);
    994999        } else {
    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);
     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);
    9981003                /* Nothing left in segment */
    9991004                tcp_segment_delete(seg);
     
    10131018static cproc_t tcp_conn_seg_proc_fin(tcp_conn_t *conn, tcp_segment_t *seg)
    10141019{
    1015         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
     1020        log_msg(LVL_DEBUG, "%s: tcp_conn_seg_proc_fin(%p, %p)",
    10161021            conn->name, conn, seg);
    1017         log_msg(LOG_DEFAULT, LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
     1022        log_msg(LVL_DEBUG, " seg->len=%zu, seg->ctl=%u", (size_t) seg->len,
    10181023            (unsigned) seg->ctrl);
    10191024
    10201025        /* Only process FIN if no text is left in segment. */
    10211026        if (tcp_segment_text_size(seg) == 0 && (seg->ctrl & CTL_FIN) != 0) {
    1022                 log_msg(LOG_DEFAULT, LVL_DEBUG, " - FIN found in segment.");
     1027                log_msg(LVL_DEBUG, " - FIN found in segment.");
    10231028
    10241029                /* Send ACK */
     
    10371042                case st_syn_received:
    10381043                case st_established:
    1039                         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Close-Wait",
     1044                        log_msg(LVL_DEBUG, "%s: FIN received -> Close-Wait",
    10401045                            conn->name);
    10411046                        tcp_conn_state_set(conn, st_close_wait);
    10421047                        break;
    10431048                case st_fin_wait_1:
    1044                         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Closing",
     1049                        log_msg(LVL_DEBUG, "%s: FIN received -> Closing",
    10451050                            conn->name);
    10461051                        tcp_conn_state_set(conn, st_closing);
    10471052                        break;
    10481053                case st_fin_wait_2:
    1049                         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: FIN received -> Time-Wait",
     1054                        log_msg(LVL_DEBUG, "%s: FIN received -> Time-Wait",
    10501055                            conn->name);
    10511056                        tcp_conn_state_set(conn, st_time_wait);
     
    10861091static void tcp_conn_seg_process(tcp_conn_t *conn, tcp_segment_t *seg)
    10871092{
    1088         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
     1093        log_msg(LVL_DEBUG, "tcp_conn_seg_process(%p, %p)", conn, seg);
    10891094        tcp_segment_dump(seg);
    10901095
     
    10921097        /* XXX Permit valid ACKs, URGs and RSTs */
    10931098/*      if (!seq_no_segment_acceptable(conn, seg)) {
    1094                 log_msg(LOG_DEFAULT, LVL_WARN, "Segment not acceptable, dropping.");
     1099                log_msg(LVL_WARN, "Segment not acceptable, dropping.");
    10951100                if ((seg->ctrl & CTL_RST) == 0) {
    10961101                        tcp_tqueue_ctrl_seg(conn, CTL_ACK);
     
    11261131         */
    11271132        if (seg->len > 0) {
    1128                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
     1133                log_msg(LVL_DEBUG, "Re-insert segment %p. seg->len=%zu",
    11291134                    seg, (size_t) seg->len);
    11301135                tcp_iqueue_insert_seg(&conn->incoming, seg);
     
    11411146void tcp_conn_segment_arrived(tcp_conn_t *conn, tcp_segment_t *seg)
    11421147{
    1143         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_conn_segment_arrived(%p)",
     1148        log_msg(LVL_DEBUG, "%c: tcp_conn_segment_arrived(%p)",
    11441149            conn->name, seg);
    11451150
     
    11601165                tcp_conn_sa_queue(conn, seg); break;
    11611166        case st_closed:
    1162                 log_msg(LOG_DEFAULT, LVL_DEBUG, "state=%d", (int) conn->cstate);
     1167                log_msg(LVL_DEBUG, "state=%d", (int) conn->cstate);
    11631168                assert(false);
    11641169        }
     
    11731178        tcp_conn_t *conn = (tcp_conn_t *) arg;
    11741179
    1175         log_msg(LOG_DEFAULT, LVL_DEBUG, "tw_timeout_func(%p)", conn);
     1180        log_msg(LVL_DEBUG, "tw_timeout_func(%p)", conn);
    11761181
    11771182        fibril_mutex_lock(&conn->lock);
    11781183
    11791184        if (conn->cstate == st_closed) {
    1180                 log_msg(LOG_DEFAULT, LVL_DEBUG, "Connection already closed.");
     1185                log_msg(LVL_DEBUG, "Connection already closed.");
    11811186                fibril_mutex_unlock(&conn->lock);
    11821187                tcp_conn_delref(conn);
     
    11841189        }
    11851190
    1186         log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
     1191        log_msg(LVL_DEBUG, "%s: TW Timeout -> Closed", conn->name);
    11871192        tcp_conn_remove(conn);
    11881193        tcp_conn_state_set(conn, st_closed);
     
    12351240void tcp_unexpected_segment(tcp_sockpair_t *sp, tcp_segment_t *seg)
    12361241{
    1237         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
     1242        log_msg(LVL_DEBUG, "tcp_unexpected_segment(%p, %p)", sp, seg);
    12381243
    12391244        if ((seg->ctrl & CTL_RST) == 0)
     
    12631268        tcp_segment_t *rseg;
    12641269
    1265         log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
     1270        log_msg(LVL_DEBUG, "tcp_reply_rst(%p, %p)", sp, seg);
    12661271
    12671272        rseg = tcp_segment_make_rst(seg);
Note: See TracChangeset for help on using the changeset viewer.