Changeset 3bacee1 in mainline for uspace/srv/net/tcp
- Timestamp:
- 2018-04-12T16:27:17Z (7 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 3cf22f9
- Parents:
- 76d0981d
- git-author:
- Jiri Svoboda <jiri@…> (2018-04-11 19:25:33)
- git-committer:
- Jiri Svoboda <jiri@…> (2018-04-12 16:27:17)
- Location:
- uspace/srv/net/tcp
- Files:
-
- 7 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/net/tcp/conn.c
r76d0981d r3bacee1 156 156 157 157 /* Initialize retransmission queue */ 158 if (tcp_tqueue_init(&conn->retransmit, conn, &tcp_conn_tqueue_cb) 159 !=EOK) {158 if (tcp_tqueue_init(&conn->retransmit, conn, &tcp_conn_tqueue_cb) != 159 EOK) { 160 160 goto error; 161 161 } -
uspace/srv/net/tcp/inet.c
r76d0981d r3bacee1 97 97 if (hdr_size < sizeof(tcp_header_t)) { 98 98 log_msg(LOG_DEFAULT, LVL_WARN, "hdr_size = %zu < sizeof(tcp_header_t) = %zu", 99 hdr_size, sizeof(tcp_header_t)); return EINVAL; 99 hdr_size, sizeof(tcp_header_t)); 100 return EINVAL; 100 101 } 101 102 -
uspace/srv/net/tcp/pdu.c
r76d0981d r3bacee1 73 73 74 74 for (i = 0; i < words; i++) { 75 w = ((uint16_t)bdata[2 *i] << 8) | bdata[2*i + 1];75 w = ((uint16_t)bdata[2 * i] << 8) | bdata[2 * i + 1]; 76 76 sum = tcp_ocadd16(sum, w); 77 77 } 78 78 79 79 if (size % 2 != 0) { 80 w = ((uint16_t)bdata[2 *words] << 8);80 w = ((uint16_t)bdata[2 * words] << 8); 81 81 sum = tcp_ocadd16(sum, w); 82 82 } -
uspace/srv/net/tcp/seq_no.c
r76d0981d r3bacee1 170 170 171 171 /* Beginning of segment is inside window */ 172 b_in = seq_no_le_lt(conn->rcv_nxt, seg->seq, conn->rcv_nxt 173 +conn->rcv_wnd);172 b_in = seq_no_le_lt(conn->rcv_nxt, seg->seq, conn->rcv_nxt + 173 conn->rcv_wnd); 174 174 175 175 /* End of segment is inside window */ -
uspace/srv/net/tcp/test/conn.c
r76d0981d r3bacee1 139 139 140 140 while (conn->cstate == st_syn_sent) 141 141 fibril_condvar_wait(&conn->cstate_cv, &conn->lock); 142 142 143 143 PCUT_ASSERT_INT_EQUALS(st_closed, conn->cstate); … … 194 194 /* Wait for client-side state to transition */ 195 195 while (cconn->cstate == st_syn_sent) 196 196 fibril_condvar_wait(&cconn->cstate_cv, &cconn->lock); 197 197 198 198 PCUT_ASSERT_INT_EQUALS(st_established, cconn->cstate); … … 203 203 tcp_conn_lock(sconn); 204 204 while (sconn->cstate == st_listen || sconn->cstate == st_syn_received) 205 205 fibril_condvar_wait(&sconn->cstate_cv, &sconn->lock); 206 206 207 207 PCUT_ASSERT_INT_EQUALS(st_established, sconn->cstate); -
uspace/srv/net/tcp/test/rqueue.c
r76d0981d r3bacee1 107 107 seg_cnt = 0; 108 108 109 109 inet_ep2_init(&epp); 110 110 111 111 tcp_rqueue_fibril_start(); -
uspace/srv/net/tcp/test/seq_no.c
r76d0981d r3bacee1 130 130 conn->rcv_wnd = (uint32_t) -10; 131 131 132 PCUT_ASSERT_FALSE(seq_no_in_rcv_wnd(conn, 19));132 PCUT_ASSERT_FALSE(seq_no_in_rcv_wnd(conn, 19)); 133 133 PCUT_ASSERT_TRUE(seq_no_in_rcv_wnd(conn, 20)); 134 134 PCUT_ASSERT_TRUE(seq_no_in_rcv_wnd(conn, 21));
Note:
See TracChangeset
for help on using the changeset viewer.