Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed

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

    r78192cc7 rb243da3  
    9090        /* Wait for connection to be established or reset */
    9191        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_open: Wait for connection.");
    92         tcp_conn_lock(nconn);
     92        fibril_mutex_lock(&nconn->lock);
    9393        while (nconn->cstate == st_listen ||
    9494            nconn->cstate == st_syn_sent ||
    … …  
    100100                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_open: Connection was reset.");
    101101                assert(nconn->cstate == st_closed);
    102                 tcp_conn_unlock(nconn);
     102                fibril_mutex_unlock(&nconn->lock);
    103103                return TCP_ERESET;
    104104        }
    105105
    106         tcp_conn_unlock(nconn);
     106        fibril_mutex_unlock(&nconn->lock);
    107107        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_open: Connection was established.");
    108108
    … …  
    121121        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_uc_send()", conn->name);
    122122
    123         tcp_conn_lock(conn);
     123        fibril_mutex_lock(&conn->lock);
    124124
    125125        if (conn->cstate == st_closed) {
    126                 tcp_conn_unlock(conn);
     126                fibril_mutex_unlock(&conn->lock);
    127127                return TCP_ENOTEXIST;
    128128        }
    … …  
    135135
    136136        if (conn->snd_buf_fin) {
    137                 tcp_conn_unlock(conn);
     137                fibril_mutex_unlock(&conn->lock);
    138138                return TCP_ECLOSING;
    139139        }
    … …  
    149149
    150150                if (conn->reset) {
    151                         tcp_conn_unlock(conn);
     151                        fibril_mutex_unlock(&conn->lock);
    152152                        return TCP_ERESET;
    153153                }
    … …  
    165165
    166166        tcp_tqueue_new_data(conn);
    167         tcp_conn_unlock(conn);
     167        fibril_mutex_unlock(&conn->lock);
    168168
    169169        return TCP_EOK;
    … …  
    178178        log_msg(LOG_DEFAULT, LVL_DEBUG, "%s: tcp_uc_receive()", conn->name);
    179179
    180         tcp_conn_lock(conn);
     180        fibril_mutex_lock(&conn->lock);
    181181
    182182        if (conn->cstate == st_closed) {
    183                 tcp_conn_unlock(conn);
     183                fibril_mutex_unlock(&conn->lock);
    184184                return TCP_ENOTEXIST;
    185185        }
    … …  
    197197                if (conn->rcv_buf_fin) {
    198198                        /* End of data, peer closed connection */
    199                         tcp_conn_unlock(conn);
     199                        fibril_mutex_unlock(&conn->lock);
    200200                        return TCP_ECLOSING;
    201201                } else {
    202202                        /* Connection was reset */
    203203                        assert(conn->reset);
    204                         tcp_conn_unlock(conn);
     204                        fibril_mutex_unlock(&conn->lock);
    205205                        return TCP_ERESET;
    206206                }
    … …  
    227227            conn->name, xfer_size);
    228228
    229         tcp_conn_unlock(conn);
     229        fibril_mutex_unlock(&conn->lock);
    230230
    231231        return TCP_EOK;
    … …  
    238238            conn);
    239239
    240         tcp_conn_lock(conn);
     240        fibril_mutex_lock(&conn->lock);
    241241
    242242        if (conn->cstate == st_closed) {
    243243                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_close - ENOTEXIST");
    244                 tcp_conn_unlock(conn);
     244                fibril_mutex_unlock(&conn->lock);
    245245                return TCP_ENOTEXIST;
    246246        }
    … …  
    250250                tcp_conn_reset(conn);
    251251                tcp_conn_remove(conn);
    252                 tcp_conn_unlock(conn);
    253252                return TCP_EOK;
    254253        }
    … …  
    256255        if (conn->snd_buf_fin) {
    257256                log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_uc_close - ECLOSING");
    258                 tcp_conn_unlock(conn);
     257                fibril_mutex_unlock(&conn->lock);
    259258                return TCP_ECLOSING;
    260259        }
    … …  
    264263        tcp_tqueue_new_data(conn);
    265264
    266         tcp_conn_unlock(conn);
     265        fibril_mutex_unlock(&conn->lock);
    267266        return TCP_EOK;
    268267}
    … …  
    322321        }
    323322
    324         tcp_conn_lock(conn);
     323        fibril_mutex_lock(&conn->lock);
    325324
    326325        if (conn->cstate == st_closed) {
    327326                log_msg(LOG_DEFAULT, LVL_WARN, "Connection is closed.");
    328327                tcp_unexpected_segment(sp, seg);
    329                 tcp_conn_unlock(conn);
     328                fibril_mutex_unlock(&conn->lock);
    330329                tcp_conn_delref(conn);
    331330                return;
    … …  
    343342        tcp_conn_segment_arrived(conn, seg);
    344343
    345         tcp_conn_unlock(conn);
     344        fibril_mutex_unlock(&conn->lock);
    346345        tcp_conn_delref(conn);
    347346}
Note: See TracChangeset for help on using the changeset viewer.