Changes in uspace/srv/net/tcp/tcp.c [06a1d077:02a09ed] in mainline

File:

• uspace/srv/net/tcp/tcp.c (modified) (13 diffs)

uspace/srv/net/tcp/tcp.c

@@ -69 +69 @@
         size_t pdu_raw_size;
 
-        log_msg(LVL_DEBUG, "tcp_inet_ev_recv()");
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_inet_ev_recv()");
 
         pdu_raw = dgram->data;
@@ -76 +76 @@
         /* Split into header and payload. */
 
-        log_msg(LVL_DEBUG, "tcp_inet_ev_recv() - split header/payload");
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_inet_ev_recv() - split header/payload");
 
         tcp_pdu_t *pdu;
@@ -84 +84 @@
 
         if (pdu_raw_size < sizeof(tcp_header_t)) {
-                log_msg(LVL_WARN, "pdu_raw_size = %zu < sizeof(tcp_header_t) = %zu",
+                log_msg(LOG_DEFAULT, LVL_WARN, "pdu_raw_size = %zu < sizeof(tcp_header_t) = %zu",
                     pdu_raw_size, sizeof(tcp_header_t));
                 return EINVAL;
@@ -96 +96 @@
 
         if (pdu_raw_size < hdr_size) {
-                log_msg(LVL_WARN, "pdu_raw_size = %zu < hdr_size = %zu",
+                log_msg(LOG_DEFAULT, LVL_WARN, "pdu_raw_size = %zu < hdr_size = %zu",
                     pdu_raw_size, hdr_size);
                 return EINVAL;
@@ -102 +102 @@
 
         if (hdr_size < sizeof(tcp_header_t)) {
-                log_msg(LVL_WARN, "hdr_size = %zu < sizeof(tcp_header_t) = %zu",
+                log_msg(LOG_DEFAULT, LVL_WARN, "hdr_size = %zu < sizeof(tcp_header_t) = %zu",
                     hdr_size, sizeof(tcp_header_t));            return EINVAL;
         }
 
-        log_msg(LVL_DEBUG, "pdu_raw_size=%zu, hdr_size=%zu",
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "pdu_raw_size=%zu, hdr_size=%zu",
             pdu_raw_size, hdr_size);
         pdu = tcp_pdu_create(pdu_raw, hdr_size, pdu_raw + hdr_size,
             pdu_raw_size - hdr_size);
         if (pdu == NULL) {
-                log_msg(LVL_WARN, "Failed creating PDU. Dropped.");
+                log_msg(LOG_DEFAULT, LVL_WARN, "Failed creating PDU. Dropped.");
                 return ENOMEM;
         }
 
-        pdu->src_addr.ipv4 = dgram->src.ipv4;
-        pdu->dest_addr.ipv4 = dgram->dest.ipv4;
-        log_msg(LVL_DEBUG, "src: 0x%08x, dest: 0x%08x",
-            pdu->src_addr.ipv4, pdu->dest_addr.ipv4);
+        pdu->src = dgram->src;
+        pdu->dest = dgram->dest;
 
         tcp_received_pdu(pdu);
@@ -137 +135 @@
         pdu_raw = malloc(pdu_raw_size);
         if (pdu_raw == NULL) {
-                log_msg(LVL_ERROR, "Failed to transmit PDU. Out of memory.");
+                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to transmit PDU. Out of memory.");
                 return;
         }
@@ -145 +143 @@
             pdu->text_size);
 
-        dgram.src.ipv4 = pdu->src_addr.ipv4;
-        dgram.dest.ipv4 = pdu->dest_addr.ipv4;
+        dgram.src = pdu->src;
+        dgram.dest = pdu->dest;
         dgram.tos = 0;
         dgram.data = pdu_raw;
@@ -153 +151 @@
         rc = inet_send(&dgram, INET_TTL_MAX, 0);
         if (rc != EOK)
-                log_msg(LVL_ERROR, "Failed to transmit PDU.");
+                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed to transmit PDU.");
 }
 
@@ -162 +160 @@
         tcp_sockpair_t rident;
 
-        log_msg(LVL_DEBUG, "tcp_received_pdu()");
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_received_pdu()");
 
         if (tcp_pdu_decode(pdu, &rident, &dseg) != EOK) {
-                log_msg(LVL_WARN, "Not enough memory. PDU dropped.");
+                log_msg(LOG_DEFAULT, LVL_WARN, "Not enough memory. PDU dropped.");
                 return;
         }
@@ -177 +175 @@
         int rc;
 
-        log_msg(LVL_DEBUG, "tcp_init()");
+        log_msg(LOG_DEFAULT, LVL_DEBUG, "tcp_init()");
 
         tcp_rqueue_init();
-        tcp_rqueue_thread_start();
+        tcp_rqueue_fibril_start();
 
         tcp_ncsim_init();
-        tcp_ncsim_thread_start();
+        tcp_ncsim_fibril_start();
 
         if (0) tcp_test();
@@ -189 +187 @@
         rc = inet_init(IP_PROTO_TCP, &tcp_inet_ev_ops);
         if (rc != EOK) {
-                log_msg(LVL_ERROR, "Failed connecting to internet service.");
+                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed connecting to internet service.");
                 return ENOENT;
         }
@@ -195 +193 @@
         rc = tcp_sock_init();
         if (rc != EOK) {
-                log_msg(LVL_ERROR, "Failed initializing socket service.");
+                log_msg(LOG_DEFAULT, LVL_ERROR, "Failed initializing socket service.");
                 return ENOENT;
         }
@@ -208 +206 @@
         printf(NAME ": TCP (Transmission Control Protocol) network module\n");
 
-        rc = log_init(NAME, LVL_WARN);
+        rc = log_init(NAME);
         if (rc != EOK) {
                 printf(NAME ": Failed to initialize log.\n");