Changes in / [9ce7eb5:3da12d74] in mainline

Location:

uspace

Files:

• app/netstart/Makefile (modified) (1 diff)
• lib/c/generic/net/modules.c (modified) (5 diffs)
• lib/c/generic/net/packet.c (modified) (4 diffs)
• lib/c/generic/net/socket_client.c (modified) (14 diffs)
• srv/net/net/net.c (modified) (25 diffs)
• srv/net/net/net_standalone.c (modified) (3 diffs)

uspace/app/netstart/Makefile

@@ -29 +29 @@
 
 USPACE_PREFIX = ../..
-LIBS = 
-EXTRA_CFLAGS = 
+LIBS = $(LIBNET_PREFIX)/libnet.a
+EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include
 
 BINARY = netstart

uspace/lib/c/generic/net/modules.c

@@ -41 +41 @@
 #include <async.h>
 #include <malloc.h>
-#include <errno.h>
+#include <err.h>
 #include <sys/time.h>
 
@@ -137 +137 @@
     ipcarg_t arg3, async_client_conn_t client_receiver, suseconds_t timeout)
 {
-        int rc;
+        ERROR_DECLARE;
         
         /* Connect to the needed service */
@@ -144 +144 @@
                 /* Request the bidirectional connection */
                 ipcarg_t phonehash;
-                
-                rc = ipc_connect_to_me(phone, arg1, arg2, arg3, &phonehash);
-                if (rc != EOK) {
+                if (ERROR_OCCURRED(ipc_connect_to_me(phone, arg1, arg2, arg3,
+                    &phonehash))) {
                         ipc_hangup(phone);
-                        return rc;
+                        return ERROR_CODE;
                 }
                 async_new_connection(phonehash, 0, NULL, client_receiver);
@@ -213 +212 @@
 int data_receive(void **data, size_t *length)
 {
+        ERROR_DECLARE;
+
         ipc_callid_t callid;
-        int rc;
 
         if (!data || !length)
@@ -229 +229 @@
 
         // fetch the data
-        rc = async_data_write_finalize(callid, *data, *length);
-        if (rc != EOK) {
+        if (ERROR_OCCURRED(async_data_write_finalize(callid, *data, *length))) {
                 free(data);
-                return rc;
+                return ERROR_CODE;
         }
 

uspace/lib/c/generic/net/packet.c

@@ -41 +41 @@
 #include <unistd.h>
 #include <errno.h>
+#include <err.h>
 
 #include <sys/mman.h>
@@ -90 +91 @@
 int pm_init(void)
 {
-        int rc;
+        ERROR_DECLARE;
 
         fibril_rwlock_initialize(&pm_globals.lock);
-        
         fibril_rwlock_write_lock(&pm_globals.lock);
-        rc = gpm_initialize(&pm_globals.packet_map);
+        ERROR_PROPAGATE(gpm_initialize(&pm_globals.packet_map));
         fibril_rwlock_write_unlock(&pm_globals.lock);
-        
-        return rc;
+        return EOK;
 }
 
@@ -140 +139 @@
 int pm_add(packet_t packet)
 {
+        ERROR_DECLARE;
+
         packet_map_ref map;
-        int rc;
 
         if (!packet_is_valid(packet))
@@ -160 +160 @@
                         }
                         bzero(map, sizeof(packet_map_t));
-                        rc = gpm_add(&pm_globals.packet_map, map);
-                        if (rc < 0) {
+                        if ((ERROR_CODE =
+                            gpm_add(&pm_globals.packet_map, map)) < 0) {
                                 fibril_rwlock_write_unlock(&pm_globals.lock);
                                 free(map);
-                                return rc;
+                                return ERROR_CODE;
                         }
                 } while (PACKET_MAP_PAGE(packet->packet_id) >=

uspace/lib/c/generic/net/socket_client.c

@@ -43 +43 @@
 #include <stdlib.h>
 #include <errno.h>
+#include <err.h>
 
 #include <ipc/services.h>
@@ -211 +212 @@
 static void socket_connection(ipc_callid_t iid, ipc_call_t * icall)
 {
+        ERROR_DECLARE;
+
         ipc_callid_t callid;
         ipc_call_t call;
         socket_ref socket;
-        int rc;
 
 loop:
@@ -229 +231 @@
                     SOCKET_GET_SOCKET_ID(call));
                 if (!socket) {
-                        rc = ENOTSOCK;
+                        ERROR_CODE = ENOTSOCK;
                         fibril_rwlock_read_unlock(&socket_globals.lock);
                         break;
@@ -238 +240 @@
                         fibril_mutex_lock(&socket->receive_lock);
                         // push the number of received packet fragments
-                        rc = dyn_fifo_push(&socket->received,
+                        if (!ERROR_OCCURRED(dyn_fifo_push(&socket->received,
                             SOCKET_GET_DATA_FRAGMENTS(call),
-                            SOCKET_MAX_RECEIVED_SIZE);
-                        if (rc == EOK) {
+                            SOCKET_MAX_RECEIVED_SIZE))) {
                                 // signal the received packet
                                 fibril_condvar_signal(&socket->receive_signal);
@@ -251 +252 @@
                         // push the new socket identifier
                         fibril_mutex_lock(&socket->accept_lock);
-                        rc = dyn_fifo_push(&socket->accepted, 1,
-                            SOCKET_MAX_ACCEPTED_SIZE);
-                        if (rc != EOK) {
+                        if (!ERROR_OCCURRED(dyn_fifo_push(&socket->accepted,
+                            1, SOCKET_MAX_ACCEPTED_SIZE))) {
                                 // signal the accepted socket
                                 fibril_condvar_signal(&socket->accept_signal);
@@ -261 +261 @@
 
                 default:
-                        rc = ENOTSUP;
+                        ERROR_CODE = ENOTSUP;
                 }
 
@@ -280 +280 @@
 
         default:
-                rc = ENOTSUP;
-        }
-
-        ipc_answer_0(callid, (ipcarg_t) rc);
+                ERROR_CODE = ENOTSUP;
+        }
+
+        ipc_answer_0(callid, (ipcarg_t) ERROR_CODE);
         goto loop;
 }
@@ -405 +405 @@
 int socket(int domain, int type, int protocol)
 {
+        ERROR_DECLARE;
+
         socket_ref socket;
         int phone;
@@ -411 +413 @@
         ipcarg_t fragment_size;
         ipcarg_t header_size;
-        int rc;
 
         // find the appropriate service
@@ -478 +479 @@
         }
 
-        rc = (int) async_req_3_3(phone, NET_SOCKET, socket_id, 0, service, NULL,
-            &fragment_size, &header_size);
-        if (rc != EOK) {
+        if (ERROR_OCCURRED((int) async_req_3_3(phone, NET_SOCKET, socket_id, 0,
+            service, NULL, &fragment_size, &header_size))) {
                 fibril_rwlock_write_unlock(&socket_globals.lock);
                 free(socket);
-                return rc;
+                return ERROR_CODE;
         }
 
@@ -492 +492 @@
         socket_initialize(socket, socket_id, phone, service);
         // store the new socket
-        rc = sockets_add(socket_get_sockets(), socket_id, socket);
+        ERROR_CODE = sockets_add(socket_get_sockets(), socket_id, socket);
 
         fibril_rwlock_write_unlock(&socket_globals.lock);
-        if (rc < 0) {
+        if (ERROR_CODE < 0) {
                 dyn_fifo_destroy(&socket->received);
                 dyn_fifo_destroy(&socket->accepted);
@@ -501 +501 @@
                 async_msg_3(phone, NET_SOCKET_CLOSE, (ipcarg_t) socket_id, 0,
                     service);
-                return rc;
+                return ERROR_CODE;
         }
 
@@ -770 +770 @@
 int closesocket(int socket_id)
 {
+        ERROR_DECLARE;
+
         socket_ref socket;
-        int rc;
 
         fibril_rwlock_write_lock(&socket_globals.lock);
@@ -786 +787 @@
 
         // request close
-        rc = (int) async_req_3_0(socket->phone, NET_SOCKET_CLOSE,
-            (ipcarg_t) socket->socket_id, 0, socket->service);
-        if (rc != EOK) {
-                fibril_rwlock_write_unlock(&socket_globals.lock);
-                return rc;
-        }
+        ERROR_PROPAGATE((int) async_req_3_0(socket->phone, NET_SOCKET_CLOSE,
+            (ipcarg_t) socket->socket_id, 0, socket->service));
         // free the socket structure
         socket_destroy(socket);

uspace/srv/net/net/net.c

@@ -42 +42 @@
 #include <ddi.h>
 #include <errno.h>
+#include <err.h>
 #include <malloc.h>
 #include <stdio.h>
@@ -91 +92 @@
     const char *value)
 {
-        int rc;
+        ERROR_DECLARE;
         
         measured_string_ref setting =
@@ -99 +100 @@
         
         /* Add the configuration setting */
-        rc = measured_strings_add(configuration, name, 0, setting);
-        if (rc != EOK) {
+        if (ERROR_OCCURRED(measured_strings_add(configuration, name, 0, setting))) {
                 free(setting);
-                return rc;
+                return ERROR_CODE;
         }
         
@@ -110 +110 @@
 /** Generate new system-unique device identifier.
  *
- * @returns             The system-unique devic identifier.
+ * @returns The system-unique devic identifier.
+ *
  */
 static device_id_t generate_new_device_id(void)
@@ -119 +120 @@
 static int parse_line(measured_strings_ref configuration, char *line)
 {
-        int rc;
+        ERROR_DECLARE;
         
         /* From the beginning */
@@ -169 +170 @@
         
         /* Add the configuration setting */
-        rc = measured_strings_add(configuration, name, 0, setting);
-        if (rc != EOK) {
+        if (ERROR_OCCURRED(measured_strings_add(configuration, name, 0, setting))) {
                 free(setting);
-                return rc;
+                return ERROR_CODE;
         }
         
@@ -181 +181 @@
     measured_strings_ref configuration)
 {
+        ERROR_DECLARE;
+        
         printf("%s: Reading configuration file %s/%s\n", NAME, directory, filename);
         
@@ -204 +206 @@
                         if (index >= BUFFER_SIZE) {
                                 line[BUFFER_SIZE - 1] = '\0';
-                                fprintf(stderr, "%s: Configuration line %u too "
-                                    "long: %s\n", NAME, line_number, line);
+                                fprintf(stderr, "%s: Configuration line %u too long: %s\n",
+                                    NAME, line_number, line);
                                 
                                 /* No space left in the line buffer */
                                 return EOVERFLOW;
+                        } else {
+                                /* Append the character */
+                                line[index] = (char) read;
+                                index++;
                         }
-                        /* Append the character */
-                        line[index] = (char) read;
-                        index++;
                 } else {
                         /* On error or new line */
                         line[index] = '\0';
                         line_number++;
-                        if (parse_line(configuration, line) != EOK) {
-                                fprintf(stderr, "%s: Configuration error on "
-                                    "line %u: %s\n", NAME, line_number, line);
-                        }
+                        if (ERROR_OCCURRED(parse_line(configuration, line)))
+                                fprintf(stderr, "%s: Configuration error on line %u: %s\n",
+                                    NAME, line_number, line);
                         
                         index = 0;
@@ -268 +270 @@
 static int net_initialize(async_client_conn_t client_connection)
 {
-        int rc;
+        ERROR_DECLARE;
         
         netifs_initialize(&net_globals.netifs);
@@ -276 +278 @@
         
         // TODO: dynamic configuration
-        rc = read_configuration();
-        if (rc != EOK)
-                return rc;
-        
-        rc = add_module(NULL, &net_globals.modules, LO_NAME, LO_FILENAME,
-            SERVICE_LO, 0, connect_to_service);
-        if (rc != EOK)
-                return rc;
-        rc = add_module(NULL, &net_globals.modules, DP8390_NAME,
-            DP8390_FILENAME, SERVICE_DP8390, 0, connect_to_service);
-        if (rc != EOK)
-                return rc;
-        rc = add_module(NULL, &net_globals.modules, ETHERNET_NAME,
-            ETHERNET_FILENAME, SERVICE_ETHERNET, 0, connect_to_service);
-        if (rc != EOK)
-                return rc;
-        rc = add_module(NULL, &net_globals.modules, NILDUMMY_NAME,
-            NILDUMMY_FILENAME, SERVICE_NILDUMMY, 0, connect_to_service);
-        if (rc != EOK)
-                return rc;
+        ERROR_PROPAGATE(read_configuration());
+        
+        ERROR_PROPAGATE(add_module(NULL, &net_globals.modules,
+            LO_NAME, LO_FILENAME, SERVICE_LO, 0, connect_to_service));
+        ERROR_PROPAGATE(add_module(NULL, &net_globals.modules,
+            DP8390_NAME, DP8390_FILENAME, SERVICE_DP8390, 0, connect_to_service));
+        ERROR_PROPAGATE(add_module(NULL, &net_globals.modules,
+            ETHERNET_NAME, ETHERNET_FILENAME, SERVICE_ETHERNET, 0,
+            connect_to_service));
+        ERROR_PROPAGATE(add_module(NULL, &net_globals.modules,
+            NILDUMMY_NAME, NILDUMMY_FILENAME, SERVICE_NILDUMMY, 0,
+            connect_to_service));
         
         /* Build specific initialization */
@@ -320 +314 @@
 static int net_module_start(async_client_conn_t client_connection)
 {
+        ERROR_DECLARE;
+        
+        async_set_client_connection(client_connection);
+        ERROR_PROPAGATE(pm_init());
+        
         ipcarg_t phonehash;
-        int rc;
-        
-        async_set_client_connection(client_connection);
-        rc = pm_init();
-        if (rc != EOK)
-                return rc;
-        
-        
-        rc = net_initialize(client_connection);
-        if (rc != EOK)
-                goto out;
-        
-        rc = REGISTER_ME(SERVICE_NETWORKING, &phonehash);
-        if (rc != EOK)
-                goto out;
+        
+        if (ERROR_OCCURRED(net_initialize(client_connection)) ||
+            ERROR_OCCURRED(REGISTER_ME(SERVICE_NETWORKING, &phonehash))) {
+                pm_destroy();
+                return ERROR_CODE;
+        }
         
         async_manager();
-
-out:
+        
         pm_destroy();
-        return rc;
+        return EOK;
 }
 
@@ -426 +415 @@
 static int start_device(netif_t *netif)
 {
-        int rc;
+        ERROR_DECLARE;
         
         /* Mandatory netif */
@@ -467 +456 @@
         int io = setting ? strtol(setting->value, NULL, 16) : 0;
         
-        rc = netif_probe_req_remote(netif->driver->phone, netif->id, irq, io);
-        if (rc != EOK)
-                return rc;
+        ERROR_PROPAGATE(netif_probe_req_remote(netif->driver->phone, netif->id, irq, io));
         
         /* Network interface layer startup */
@@ -481 +468 @@
                 int mtu = setting ? strtol(setting->value, NULL, 10) : 0;
                 
-                rc = nil_device_req(netif->nil->phone, netif->id, mtu,
-                    netif->driver->service);
-                if (rc != EOK)
-                        return rc;
+                ERROR_PROPAGATE(nil_device_req(netif->nil->phone, netif->id, mtu,
+                    netif->driver->service));
                 
                 internet_service = netif->nil->service;
@@ -493 +478 @@
         switch (netif->il->service) {
         case SERVICE_IP:
-                rc = ip_device_req(netif->il->phone, netif->id,
-                    internet_service);
-                if (rc != EOK)
-                        return rc;
+                ERROR_PROPAGATE(ip_device_req(netif->il->phone, netif->id,
+                    internet_service));
                 break;
         default:
@@ -502 +485 @@
         }
         
-        return netif_start_req_remote(netif->driver->phone, netif->id);
+        ERROR_PROPAGATE(netif_start_req_remote(netif->driver->phone, netif->id));
+        return EOK;
 }
 
@@ -520 +504 @@
 static int startup(void)
 {
+        ERROR_DECLARE;
+        
         const char *conf_files[] = {
                 "lo",
@@ -525 +511 @@
         };
         size_t count = sizeof(conf_files) / sizeof(char *);
-        int rc;
         
         size_t i;
@@ -537 +522 @@
                         return EXDEV;
                 
-                rc = measured_strings_initialize(&netif->configuration);
-                if (rc != EOK)
-                        return rc;
+                ERROR_PROPAGATE(measured_strings_initialize(&netif->configuration));
                 
                 /* Read configuration files */
-                rc = read_netif_configuration(conf_files[i], netif);
-                if (rc != EOK) {
+                if (ERROR_OCCURRED(read_netif_configuration(conf_files[i], netif))) {
                         measured_strings_destroy(&netif->configuration);
                         free(netif);
-                        return rc;
+                        return ERROR_CODE;
                 }
                 
@@ -572 +554 @@
                  * and needed modules.
                  */
-                rc = char_map_add(&net_globals.netif_names, netif->name, 0,
-                    index);
-                if (rc != EOK) {
+                if ((ERROR_OCCURRED(char_map_add(&net_globals.netif_names,
+                    netif->name, 0, index))) || (ERROR_OCCURRED(start_device(netif)))) {
                         measured_strings_destroy(&netif->configuration);
                         netifs_exclude_index(&net_globals.netifs, index);
-                        return rc;
-                }
-                
-                rc = start_device(netif);
-                if (rc != EOK) {
-                        measured_strings_destroy(&netif->configuration);
-                        netifs_exclude_index(&net_globals.netifs, index);
-                        return rc;
+                        return ERROR_CODE;
                 }
                 
@@ -620 +594 @@
     int *answer_count)
 {
+        ERROR_DECLARE;
+        
         measured_string_ref strings;
         char *data;
-        int rc;
         
         *answer_count = 0;
@@ -629 +604 @@
                 return EOK;
         case NET_NET_GET_DEVICE_CONF:
-                rc = measured_strings_receive(&strings, &data,
-                    IPC_GET_COUNT(call));
-                if (rc != EOK)
-                        return rc;
+                ERROR_PROPAGATE(measured_strings_receive(&strings, &data,
+                    IPC_GET_COUNT(call)));
                 net_get_device_conf_req(0, IPC_GET_DEVICE(call), &strings,
                     IPC_GET_COUNT(call), NULL);
@@ -639 +612 @@
                 free(data);
                 
-                rc = measured_strings_reply(strings, IPC_GET_COUNT(call));
+                ERROR_CODE = measured_strings_reply(strings, IPC_GET_COUNT(call));
                 free(strings);
-                return rc;
+                return ERROR_CODE;
         case NET_NET_GET_CONF:
-                rc = measured_strings_receive(&strings, &data,
-                    IPC_GET_COUNT(call));
-                if (rc != EOK)
-                        return rc;
+                ERROR_PROPAGATE(measured_strings_receive(&strings, &data,
+                    IPC_GET_COUNT(call)));
                 net_get_conf_req(0, &strings, IPC_GET_COUNT(call), NULL);
                 
@@ -652 +623 @@
                 free(data);
                 
-                rc = measured_strings_reply(strings, IPC_GET_COUNT(call));
+                ERROR_CODE = measured_strings_reply(strings, IPC_GET_COUNT(call));
                 free(strings);
-                return rc;
+                return ERROR_CODE;
         case NET_NET_STARTUP:
                 return startup();
         }
-        
         return ENOTSUP;
 }
@@ -700 +670 @@
 int main(int argc, char *argv[])
 {
-        int rc;
-        
-        rc = net_module_start(net_client_connection);
-        if (rc != EOK) {
-                fprintf(stderr, "%s: net_module_start error %i\n", NAME, rc);
-                return rc;
+        ERROR_DECLARE;
+        
+        if (ERROR_OCCURRED(net_module_start(net_client_connection))) {
+                fprintf(stderr, "%s: net_module_start error %i\n", NAME, ERROR_CODE);
+                return ERROR_CODE;
         }
         

uspace/srv/net/net/net_standalone.c

@@ -42 +42 @@
 #include <ipc/ipc.h>
 #include <ipc/net.h>
-#include <errno.h>
 
 #include <ip_interface.h>
@@ -61 +60 @@
 int net_initialize_build(async_client_conn_t client_connection)
 {
-        int rc;
+        ERROR_DECLARE;
         
         task_id_t task_id = spawn("/srv/ip");
@@ -67 +66 @@
                 return EINVAL;
         
-        rc = add_module(NULL, &net_globals.modules, IP_NAME,
-            IP_FILENAME, SERVICE_IP, task_id, ip_connect_module);
-        if (rc != EOK)
-                return rc;
+        ERROR_PROPAGATE(add_module(NULL, &net_globals.modules, IP_NAME,
+            IP_FILENAME, SERVICE_IP, task_id, ip_connect_module));
         
         if (!spawn("/srv/icmp"))