Changeset 9520af7 in mainline for uspace/srv/net/tcp/test/conn.c

Timestamp:

2017-09-12T15:48:01Z (8 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

1d40c93d

Parents:

0a1e7e4

Message:

Allow TCP conn tests that involve transferring data by enabling an internal loopback. Add simple →SYN, ←RST test.

File:

• uspace/srv/net/tcp/test/conn.c (modified) (4 diffs)

uspace/srv/net/tcp/test/conn.c

@@ -33 +33 @@
 
 #include "../conn.h"
+#include "../rqueue.h"
+#include "../ucall.h"
 
 PCUT_INIT
 
 PCUT_TEST_SUITE(conn);
+
+static tcp_rqueue_cb_t test_rqueue_cb = {
+        .seg_received = tcp_as_segment_arrived
+};
 
 PCUT_TEST_BEFORE
@@ -48 +54 @@
         rc = tcp_conns_init();
         PCUT_ASSERT_ERRNO_VAL(EOK, rc);
+
+        tcp_rqueue_init(&test_rqueue_cb);
+        tcp_rqueue_fibril_start();
 }
 
 PCUT_TEST_AFTER
 {
+        tcp_rqueue_fini();
         tcp_conns_fini();
 }
@@ -71 +81 @@
 }
 
-/** Test adding, finding and removing a connection */
-PCUT_TEST(add_find_remove)
+/** Test adding, finding and deleting a connection */
+PCUT_TEST(add_find_delete)
 {
         tcp_conn_t *conn, *cfound;
@@ -101 +111 @@
 }
 
+/** Test trying to connect to endpoint that sends RST back */
+PCUT_TEST(connect_rst)
+{
+        tcp_conn_t *conn;
+        inet_ep2_t epp;
+        int rc;
+
+        tcp_conn_lb = tcp_lb_segment;
+
+        inet_ep2_init(&epp);
+        inet_addr(&epp.local.addr, 127, 0, 0, 1);
+        inet_addr(&epp.remote.addr, 127, 0, 0, 1);
+        epp.remote.port = inet_port_user_lo;
+
+        conn = tcp_conn_new(&epp);
+        PCUT_ASSERT_NOT_NULL(conn);
+
+        rc = tcp_conn_add(conn);
+        PCUT_ASSERT_ERRNO_VAL(EOK, rc);
+
+        PCUT_ASSERT_INT_EQUALS(st_listen, conn->cstate);
+
+        tcp_conn_lock(conn);
+        tcp_conn_sync(conn);
+        PCUT_ASSERT_INT_EQUALS(st_syn_sent, conn->cstate);
+
+        while (conn->cstate == st_syn_sent)
+                fibril_condvar_wait(&conn->cstate_cv, &conn->lock);
+
+        PCUT_ASSERT_INT_EQUALS(st_closed, conn->cstate);
+
+        tcp_conn_unlock(conn);
+        tcp_conn_delete(conn);
+}
+
 PCUT_EXPORT(conn);