Changes in uspace/srv/net/tl/udp/udp.c [14f1db0:849ed54] in mainline

File:

• uspace/srv/net/tl/udp/udp.c (modified) (15 diffs)

uspace/srv/net/tl/udp/udp.c

@@ -48 +48 @@
 #include <adt/dynamic_fifo.h>
 #include <packet/packet_client.h>
-#include <packet_remote.h>
 #include <net_checksum.h>
 #include <in.h>
@@ -64 +63 @@
 #include <socket_messages.h>
 #include <tl_common.h>
-#include <tl_local.h>
-#include <tl_interface.h>
 #include <tl_messages.h>
 
@@ -261 +258 @@
         icmp_type_t type;
         icmp_code_t code;
-        void *ip_header;
+        ip_pseudo_header_ref ip_header;
         struct sockaddr * src;
         struct sockaddr * dest;
@@ -359 +356 @@
                         while(tmp_packet){
                                 next_packet = pq_detach(tmp_packet);
-                                pq_release_remote(udp_globals.net_phone, packet_get_id(tmp_packet));
+                                pq_release(udp_globals.net_phone, packet_get_id(tmp_packet));
                                 tmp_packet = next_packet;
                         }
@@ -385 +382 @@
         // queue the received packet
         if(ERROR_OCCURRED(dyn_fifo_push(&socket->received, packet_get_id(packet), SOCKET_MAX_RECEIVED_SIZE))
-            || ERROR_OCCURRED(tl_get_ip_packet_dimension(udp_globals.ip_phone, &udp_globals.dimensions, device_id, &packet_dimension))){
+                || ERROR_OCCURRED(tl_get_ip_packet_dimension(udp_globals.ip_phone, &udp_globals.dimensions, device_id, &packet_dimension))){
                 return udp_release_and_return(packet, ERROR_CODE);
         }
@@ -395 +392 @@
 }
 
-int udp_message_standalone(ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count){
+int udp_message(ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count){
         ERROR_DECLARE;
 
@@ -403 +400 @@
         switch(IPC_GET_METHOD(*call)){
                 case NET_TL_RECEIVED:
-                        if(! ERROR_OCCURRED(packet_translate_remote(udp_globals.net_phone, &packet, IPC_GET_PACKET(call)))){
+                        if(! ERROR_OCCURRED(packet_translate(udp_globals.net_phone, &packet, IPC_GET_PACKET(call)))){
                                 ERROR_CODE = udp_received_msg(IPC_GET_DEVICE(call), packet, SERVICE_UDP, IPC_GET_ERROR(call));
                         }
@@ -460 +457 @@
 
                                 if(res == EOK){
-                                        if (tl_get_ip_packet_dimension(udp_globals.ip_phone, &udp_globals.dimensions, DEVICE_INVALID_ID, &packet_dimension) == EOK){
+                                        if(tl_get_ip_packet_dimension(udp_globals.ip_phone, &udp_globals.dimensions, DEVICE_INVALID_ID, &packet_dimension) == EOK){
                                                 SOCKET_SET_DATA_FRAGMENT_SIZE(answer, packet_dimension->content);
                                         }
@@ -536 +533 @@
         uint16_t dest_port;
         uint32_t checksum;
-        void *ip_header;
+        ip_pseudo_header_ref ip_header;
         size_t headerlen;
         device_id_t device_id;
@@ -665 +662 @@
                 return NO_DATA;
         }
-        ERROR_PROPAGATE(packet_translate_remote(udp_globals.net_phone, &packet, packet_id));
+        ERROR_PROPAGATE(packet_translate(udp_globals.net_phone, &packet, packet_id));
         // get udp header
         data = packet_get_data(packet);
         if(! data){
-                pq_release_remote(udp_globals.net_phone, packet_id);
+                pq_release(udp_globals.net_phone, packet_id);
                 return NO_DATA;
         }
@@ -677 +674 @@
         result = packet_get_addr(packet, (uint8_t **) &addr, NULL);
         if(ERROR_OCCURRED(tl_set_address_port(addr, result, ntohs(header->source_port)))){
-                pq_release_remote(udp_globals.net_phone, packet_id);
+                pq_release(udp_globals.net_phone, packet_id);
                 return ERROR_CODE;
         }
@@ -692 +689 @@
         // release the packet
         dyn_fifo_pop(&socket->received);
-        pq_release_remote(udp_globals.net_phone, packet_get_id(packet));
+        pq_release(udp_globals.net_phone, packet_get_id(packet));
         // return the total length
         return (int) length;
@@ -698 +695 @@
 
 int udp_release_and_return(packet_t packet, int result){
-        pq_release_remote(udp_globals.net_phone, packet_get_id(packet));
+        pq_release(udp_globals.net_phone, packet_get_id(packet));
         return result;
 }
+
+#ifdef CONFIG_NETWORKING_modular
+
+#include <tl_standalone.h>
 
 /** Default thread for new connections.
@@ -728 +729 @@
                 
                 /* Process the message */
-                int res = tl_module_message_standalone(callid, &call, &answer,
-                    &answer_count);
+                int res = tl_module_message(callid, &call, &answer, &answer_count);
                 
                 /* End if said to either by the message or the processing result */
@@ -753 +753 @@
         ERROR_DECLARE;
         
+        /* Print the module label */
+        printf("Task %d - %s\n", task_get_id(), NAME);
+        
         /* Start the module */
-        if (ERROR_OCCURRED(tl_module_start_standalone(tl_client_connection)))
+        if (ERROR_OCCURRED(tl_module_start(tl_client_connection))) {
+                printf(" - ERROR %i\n", ERROR_CODE);
                 return ERROR_CODE;
+        }
         
         return EOK;
 }
 
+#endif /* CONFIG_NETWORKING_modular */
+
 /** @}
  */