Changeset b40bfac for uspace/app – HelenOS

uspace/app/bdsh/exec.c

-              rd70a463
+              rb40bfac
 #include <fcntl.h>
 #include <str_error.h>
+#include <errno.h>
 #include "config.h"
 …
         task_exit_t texit;
         char *tmp;
         int retval;
+        int rc, retval;
         tmp = str_dup(find_command(cmd));
         free(found);
         tid = task_spawn(tmp, (const char **) argv, &retval);
+        rc = task_spawnv(&tid, tmp, (const char **) argv);
         free(tmp);
         if (tid == 0) {
+        if (rc != 0) {
                 cli_error(CL_EEXEC, "%s: Cannot spawn `%s' (%s)", progname, cmd,
                     str_error(retval));
+                    str_error(rc));
                 return 1;
+        }
+        task_wait(tid, &texit, &retval);
+        if (texit != TASK_EXIT_NORMAL) {
+        rc = task_wait(tid, &texit, &retval);
+        if (rc != EOK) {
+                printf("%s: Failed waiting for command (%s)\n", str_error(rc));
+        } else if (texit != TASK_EXIT_NORMAL) {
                 printf("%s: Command failed (unexpectedly terminated)\n", progname);
         } else if (retval != 0) {
                 printf("%s: Command failed (%s)\n",
                     progname, str_error(retval));
+                printf("%s: Command failed (exit code %d)\n",
+                    progname, retval);
+        }

uspace/app/getterm/getterm.c

-              rd70a463
+              rb40bfac
 #include <task.h>
 #include <str_error.h>
+#include <errno.h>
 #include "version.h"
 …
 static task_id_t spawn(const char *fname)
+{
+        const char *args[2];
+        task_id_t id;
+        int rc;
+        args[0] = fname;
+        args[1] = NULL;
+        int err;
+        task_id_t id = task_spawn(fname, args, &err);
+        if (id == 0)
+        rc = task_spawnl(&id, fname, fname, NULL);
+        if (rc != EOK) {
                 printf("%s: Error spawning %s (%s)\n", APP_NAME, fname,
+                    str_error(err));
+                    str_error(rc));
+                return 0;
+        }
         return id;

uspace/app/init/init.c

-              rd70a463
+              rb40bfac
 static void spawn(const char *fname)
+{
         const char *argv[2];
+        int rc;
         struct stat s;
 …
         printf("%s: Spawning %s\n", NAME, fname);
+        argv[0] = fname;
+        argv[1] = NULL;
+        int err;
+        if (!task_spawn(fname, argv, &err))
+        rc = task_spawnl(NULL, fname, fname, NULL);
+        if (rc != EOK) {
                 printf("%s: Error spawning %s (%s)\n", NAME, fname,
+                    str_error(err));
+                    str_error(rc));
+        }
+}
 static void srv_start(const char *fname)
+{
-        const char *argv[2];
         task_id_t id;
         task_exit_t texit;
 …
         printf("%s: Starting %s\n", NAME, fname);
+        argv[0] = fname;
+        argv[1] = NULL;
+        id = task_spawn(fname, argv, &retval);
+        rc = task_spawnl(&id, fname, fname, NULL);
         if (!id) {
                 printf("%s: Error spawning %s (%s)\n", NAME, fname,
                     str_error(retval));
+                    str_error(rc));
                 return;
+        }
 …
         if (rc != EOK) {
                 printf("%s: Error waiting for %s (%s(\n", NAME, fname,
+                    str_error(retval));
+                return;
+        }
+        if ((texit != TASK_EXIT_NORMAL) || (retval != 0)) {
+                printf("%s: Server %s failed to start (%s)\n", NAME,
+                        fname, str_error(retval));
+                    str_error(rc));
+                return;
+        }
+        if (texit != TASK_EXIT_NORMAL) {
+                printf("%s: Server %s failed to start (unexpectedly "
+                    "terminated)\n", NAME, fname);
+                return;
+        }
+        if (retval != 0) {
+                printf("%s: Server %s failed to start (exit code %d)\n", NAME,
+                        fname, retval);
+        }
+}
 …
 static void console(const char *dev)
+{
-        const char *argv[3];
         char hid_in[DEVMAP_NAME_MAXLEN];
         int rc;
 …
         dev_handle_t handle;
         rc = devmap_device_get_handle(dev, &handle, IPC_FLAG_BLOCKING);
+        if (rc == EOK) {
+                argv[0] = SRV_CONSOLE;
+                argv[1] = hid_in;
+                argv[2] = NULL;
+                if (!task_spawn(SRV_CONSOLE, argv, &rc))
+                        printf("%s: Error spawning %s %s (%s)\n", NAME, SRV_CONSOLE,
+                            hid_in, str_error(rc));
+        } else
+        if (rc != EOK) {
                 printf("%s: Error waiting on %s (%s)\n", NAME, hid_in,
                     str_error(rc));
+                return;
+        }
+        rc = task_spawnl(NULL, SRV_CONSOLE, SRV_CONSOLE, hid_in, NULL);
+        if (rc != EOK) {
+                printf("%s: Error spawning %s %s (%s)\n", NAME, SRV_CONSOLE,
+                    hid_in, str_error(rc));
+        }
+}
 static void getterm(const char *dev, const char *app)
+{
-        const char *argv[4];
         char term[DEVMAP_NAME_MAXLEN];
         int rc;
 …
         dev_handle_t handle;
         rc = devmap_device_get_handle(dev, &handle, IPC_FLAG_BLOCKING);
+        if (rc == EOK) {
+                argv[0] = APP_GETTERM;
+                argv[1] = term;
+                argv[2] = app;
+                argv[3] = NULL;
+                if (!task_spawn(APP_GETTERM, argv, &rc))
+                        printf("%s: Error spawning %s %s %s (%s)\n", NAME, APP_GETTERM,
+                            term, app, str_error(rc));
+        } else
+        if (rc != EOK) {
                 printf("%s: Error waiting on %s (%s)\n", NAME, term,
                     str_error(rc));
+                return;
+        }
+        rc = task_spawnl(NULL, APP_GETTERM, APP_GETTERM, term, app, NULL);
+        if (rc != EOK) {
+                printf("%s: Error spawning %s %s %s (%s)\n", NAME,
+                    APP_GETTERM, term, app, str_error(rc));
+        }
+}

uspace/app/netecho/netecho.c

-              rd70a463
+              rb40bfac
 /** @addtogroup netecho
  *  @{
+ * @{
  */
 /** @file
  *  Network echo application.
  *  Answers received packets.
+ * Network echo application.
+ * Answers received packets.
  */
 …
 #include <task.h>
 #include <arg_parse.h>
-#include <err.h>
 #include <net/in.h>
 …
 #include "print_error.h"
+/** Network echo module name.
+ */
+/** Network echo module name. */
 #define NAME    "Network Echo"
+/** Prints the application help.
+ */
+void echo_print_help(void);
+/** Module entry point.
+ *  Reads command line parameters and starts listenning.
+ *  @param[in] argc The number of command line parameters.
+ *  @param[in] argv The command line parameters.
+ *  @returns EOK on success.
+ */
+int main(int argc, char * argv[]);
+void echo_print_help(void){
+static void echo_print_help(void)
+{
         printf(
                 "Network Echo aplication\n" \
 …
+}
+int main(int argc, char * argv[]){
+        ERROR_DECLARE;
+        size_t size                     = 1024;
+        int verbose                     = 0;
+        char * reply            = NULL;
+        sock_type_t type        = SOCK_DGRAM;
+        int count                       = -1;
+        int family                      = PF_INET;
+        uint16_t port           = 7;
+        int backlog                     = 3;
+        socklen_t max_length                            = sizeof(struct sockaddr_in6);
+int main(int argc, char *argv[])
+{
+        size_t size = 1024;
+        int verbose = 0;
+        char *reply = NULL;
+        sock_type_t type = SOCK_DGRAM;
+        int count = -1;
+        int family = PF_INET;
+        uint16_t port = 7;
+        int backlog = 3;
+        socklen_t max_length = sizeof(struct sockaddr_in6);
         uint8_t address_data[max_length];
         struct sockaddr * address                       = (struct sockaddr *) address_data;
         struct sockaddr_in * address_in         = (struct sockaddr_in *) address;
         struct sockaddr_in6 * address_in6       = (struct sockaddr_in6 *) address;
+        struct sockaddr *address = (struct sockaddr *) address_data;
+        struct sockaddr_in *address_in = (struct sockaddr_in *) address;
+        struct sockaddr_in6 *address_in6 = (struct sockaddr_in6 *) address;
         socklen_t addrlen;
         char address_string[INET6_ADDRSTRLEN];
         uint8_t * address_start;
+        uint8_t *address_start;
         int socket_id;
         int listening_id;
         char * data;
+        char *data;
         size_t length;
         int index;
         size_t reply_length;
         int value;
+        int rc;
         // parse the command line arguments
+        for(index = 1; index < argc; ++ index){
+                if(argv[index][0] == '-'){
+                        switch(argv[index][1]){
+                                case 'b':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &backlog, 0));
+                                        break;
+                                case 'c':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &count, 0));
+                                        break;
+                                case 'f':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 0, socket_parse_protocol_family));
+                                        break;
+                                case 'h':
+        for (index = 1; index < argc; ++ index) {
+                if (argv[index][0] == '-') {
+                        switch (argv[index][1]) {
+                        case 'b':
+                                rc = arg_parse_int(argc, argv, &index, &backlog, 0);
+                                if (rc != EOK)
+                                        return rc;
+                                break;
+                        case 'c':
+                                rc = arg_parse_int(argc, argv, &index, &count, 0);
+                                if (rc != EOK)
+                                        return rc;
+                                break;
+                        case 'f':
+                                rc = arg_parse_name_int(argc, argv, &index, &family, 0, socket_parse_protocol_family);
+                                if (rc != EOK)
+                                        return rc;
+                                break;
+                        case 'h':
+                                echo_print_help();
+                                return EOK;
+                                break;
+                        case 'p':
+                                rc = arg_parse_int(argc, argv, &index, &value, 0);
+                                if (rc != EOK)
+                                        return rc;
+                                port = (uint16_t) value;
+                                break;
+                        case 'r':
+                                rc = arg_parse_string(argc, argv, &index, &reply, 0);
+                                if (rc != EOK)
+                                        return rc;
+                                break;
+                        case 's':
+                                rc = arg_parse_int(argc, argv, &index, &value, 0);
+                                if (rc != EOK)
+                                        return rc;
+                                size = (value >= 0) ? (size_t) value : 0;
+                                break;
+                        case 't':
+                                rc = arg_parse_name_int(argc, argv, &index, &value, 0, socket_parse_socket_type);
+                                if (rc != EOK)
+                                        return rc;
+                                type = (sock_type_t) value;
+                                break;
+                        case 'v':
+                                verbose = 1;
+                                break;
+                        // long options with the double minus sign ('-')
+                        case '-':
+                                if (str_lcmp(argv[index] + 2, "backlog=", 6) == 0) {
+                                        rc = arg_parse_int(argc, argv, &index, &backlog, 8);
+                                        if (rc != EOK)
+                                                return rc;
+                                } else if (str_lcmp(argv[index] + 2, "count=", 6) == 0) {
+                                        rc = arg_parse_int(argc, argv, &index, &count, 8);
+                                } else if (str_lcmp(argv[index] + 2, "family=", 7) == 0) {
+                                        rc = arg_parse_name_int(argc, argv, &index, &family, 9, socket_parse_protocol_family);
+                                        if (rc != EOK)
+                                                return rc;
+                                } else if (str_lcmp(argv[index] + 2, "help", 5) == 0) {
                                         echo_print_help();
                                         return EOK;
+                                        break;
+                                case 'p':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                } else if (str_lcmp(argv[index] + 2, "port=", 5) == 0) {
+                                        rc = arg_parse_int(argc, argv, &index, &value, 7);
+                                        if (rc != EOK)
+                                                return rc;
                                         port = (uint16_t) value;
+                                        break;
+                                case 'r':
+                                        ERROR_PROPAGATE(arg_parse_string(argc, argv, &index, &reply, 0));
+                                        break;
+                                case 's':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                } else if (str_lcmp(argv[index] + 2, "reply=", 6) == 0) {
+                                        rc = arg_parse_string(argc, argv, &index, &reply, 8);
+                                        if (rc != EOK)
+                                                return rc;
+                                } else if (str_lcmp(argv[index] + 2, "size=", 5) == 0) {
+                                        rc = arg_parse_int(argc, argv, &index, &value, 7);
+                                        if (rc != EOK)
+                                                return rc;
                                         size = (value >= 0) ? (size_t) value : 0;
+                                        break;
+                                case 't':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 0, socket_parse_socket_type));
+                                } else if (str_lcmp(argv[index] + 2, "type=", 5) == 0) {
+                                        rc = arg_parse_name_int(argc, argv, &index, &value, 7, socket_parse_socket_type);
+                                        if (rc != EOK)
+                                                return rc;
                                         type = (sock_type_t) value;
+                                        break;
+                                case 'v':
+                                } else if (str_lcmp(argv[index] + 2, "verbose", 8) == 0) {
                                         verbose = 1;
+                                        break;
+                                // long options with the double minus sign ('-')
+                                case '-':
+                                        if(str_lcmp(argv[index] + 2, "backlog=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &backlog, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "count=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &count, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "family=", 7) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 9, socket_parse_protocol_family));
+                                        }else if(str_lcmp(argv[index] + 2, "help", 5) == 0){
+                                                echo_print_help();
+                                                return EOK;
+                                        }else if(str_lcmp(argv[index] + 2, "port=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 7));
+                                                port = (uint16_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "reply=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_string(argc, argv, &index, &reply, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "size=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 7));
+                                                size = (value >= 0) ? (size_t) value : 0;
+                                        }else if(str_lcmp(argv[index] + 2, "type=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 7, socket_parse_socket_type));
+                                                type = (sock_type_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "verbose", 8) == 0){
+                                                verbose = 1;
+                                        }else{
+                                                echo_print_help();
+                                                return EINVAL;
+                                        }
+                                        break;
+                                default:
+                                } else {
                                         echo_print_help();
                                         return EINVAL;
+                                }
+                                break;
+                        default:
+                                echo_print_help();
+                                return EINVAL;
+                        }
                 }else{
+                } else {
                         echo_print_help();
                         return EINVAL;
 …
         // check the buffer size
         if(size <= 0){
+        if (size <= 0) {
                 fprintf(stderr, "Receive size too small (%d). Using 1024 bytes instead.\n", size);
                 size = 1024;
 …
         // size plus the terminating null (\0)
         data = (char *) malloc(size + 1);
         if(! data){
+        if (!data) {
                 fprintf(stderr, "Failed to allocate receive buffer.\n");
                 return ENOMEM;
 …
         // prepare the address buffer
         bzero(address_data, max_length);
         switch(family){
                 case PF_INET:
                         address_in->sin_family = AF_INET;
                         address_in->sin_port = htons(port);
                         addrlen = sizeof(struct sockaddr_in);
                         break;
                 case PF_INET6:
                         address_in6->sin6_family = AF_INET6;
                         address_in6->sin6_port = htons(port);
                         addrlen = sizeof(struct sockaddr_in6);
                         break;
                 default:
                         fprintf(stderr, "Protocol family is not supported\n");
                         return EAFNOSUPPORT;
+        switch (family) {
+        case PF_INET:
+                address_in->sin_family = AF_INET;
+                address_in->sin_port = htons(port);
+                addrlen = sizeof(struct sockaddr_in);
+                break;
+        case PF_INET6:
+                address_in6->sin6_family = AF_INET6;
+                address_in6->sin6_port = htons(port);
+                addrlen = sizeof(struct sockaddr_in6);
+                break;
+        default:
+                fprintf(stderr, "Protocol family is not supported\n");
+                return EAFNOSUPPORT;
+        }
         // get a listening socket
         listening_id = socket(family, type, 0);
         if(listening_id < 0){
+        if (listening_id < 0) {
                 socket_print_error(stderr, listening_id, "Socket create: ", "\n");
                 return listening_id;
 …
         // if the stream socket is used
         if(type == SOCK_STREAM){
+        if (type == SOCK_STREAM) {
                 // check the backlog
                 if(backlog <= 0){
+                if (backlog <= 0) {
                         fprintf(stderr, "Accepted sockets queue size too small (%d). Using 3 instead.\n", size);
                         backlog = 3;
+                }
                 // set the backlog
+                if(ERROR_OCCURRED(listen(listening_id, backlog))){
+                        socket_print_error(stderr, ERROR_CODE, "Socket listen: ", "\n");
+                        return ERROR_CODE;
+                rc = listen(listening_id, backlog);
+                if (rc != EOK) {
+                        socket_print_error(stderr, rc, "Socket listen: ", "\n");
+                        return rc;
+                }
+        }
         // bind the listenning socket
+        if(ERROR_OCCURRED(bind(listening_id, address, addrlen))){
+                socket_print_error(stderr, ERROR_CODE, "Socket bind: ", "\n");
+                return ERROR_CODE;
+        }
+        if(verbose){
+        rc = bind(listening_id, address, addrlen);
+        if (rc != EOK) {
+                socket_print_error(stderr, rc, "Socket bind: ", "\n");
+                return rc;
+        }
+        if (verbose)
                 printf("Socket %d listenning at %d\n", listening_id, port);
+        }
         socket_id = listening_id;
 …
         // do count times
         // or indefinitely if set to a negative value
         while(count){
+        while (count) {
                 addrlen = max_length;
                 if(type == SOCK_STREAM){
+                if (type == SOCK_STREAM) {
                         // acceept a socket if the stream socket is used
                         socket_id = accept(listening_id, address, &addrlen);
                         if(socket_id <= 0){
+                        if (socket_id <= 0) {
                                 socket_print_error(stderr, socket_id, "Socket accept: ", "\n");
                         }else{
                                 if(verbose){
+                        } else {
+                                if (verbose)
                                         printf("Socket %d accepted\n", socket_id);
+                                }
+                        }
+                }
                 // if the datagram socket is used or the stream socked was accepted
                 if(socket_id > 0){
+                if (socket_id > 0) {
                         // receive an echo request
                         value = recvfrom(socket_id, data, size, 0, address, &addrlen);
                         if(value < 0){
+                        if (value < 0) {
                                 socket_print_error(stderr, value, "Socket receive: ", "\n");
                         }else{
+                        } else {
                                 length = (size_t) value;
                                 if(verbose){
+                                if (verbose) {
                                         // print the header
                                         // get the source port and prepare the address buffer
                                         address_start = NULL;
                                         switch(address->sa_family){
                                                 case AF_INET:
                                                         port = ntohs(address_in->sin_port);
                                                         address_start = (uint8_t *) &address_in->sin_addr.s_addr;
                                                         break;
                                                 case AF_INET6:
                                                         port = ntohs(address_in6->sin6_port);
                                                         address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
                                                         break;
                                                 default:
                                                         fprintf(stderr, "Address family %d (0x%X) is not supported.\n", address->sa_family);
+                                        switch (address->sa_family) {
+                                        case AF_INET:
+                                                port = ntohs(address_in->sin_port);
+                                                address_start = (uint8_t *) &address_in->sin_addr.s_addr;
+                                                break;
+                                        case AF_INET6:
+                                                port = ntohs(address_in6->sin6_port);
+                                                address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
+                                                break;
+                                        default:
+                                                fprintf(stderr, "Address family %d (0x%X) is not supported.\n", address->sa_family);
+                                        }
                                         // parse the source address
+                                        if(address_start){
+                                                if(ERROR_OCCURRED(inet_ntop(address->sa_family, address_start, address_string, sizeof(address_string)))){
+                                                        fprintf(stderr, "Received address error %d\n", ERROR_CODE);
+                                                }else{
+                                        if (address_start) {
+                                                rc = inet_ntop(address->sa_family, address_start, address_string, sizeof(address_string));
+                                                if (rc != EOK) {
+                                                        fprintf(stderr, "Received address error %d\n", rc);
+                                                } else {
                                                         data[length] = '\0';
                                                         printf("Socket %d received %d bytes from %s:%d\n%s\n", socket_id, length, address_string, port, data);
 …
                                 // answer the request either with the static reply or the original data
+                                if(ERROR_OCCURRED(sendto(socket_id, reply ? reply : data, reply ? reply_length : length, 0, address, addrlen))){
+                                        socket_print_error(stderr, ERROR_CODE, "Socket send: ", "\n");
+                                }
+                                rc = sendto(socket_id, reply ? reply : data, reply ? reply_length : length, 0, address, addrlen);
+                                if (rc != EOK)
+                                        socket_print_error(stderr, rc, "Socket send: ", "\n");
+                        }
                         // close the accepted stream socket
                         if(type == SOCK_STREAM){
                                 if(ERROR_OCCURRED(closesocket(socket_id))){
                                         socket_print_error(stderr, ERROR_CODE, "Close socket: ", "\n");
+                                }
+                        if (type == SOCK_STREAM) {
+                                rc = closesocket(socket_id);
+                                if (rc != EOK)
+                                        socket_print_error(stderr, rc, "Close socket: ", "\n");
+                        }
 …
                 // decrease the count if positive
                 if(count > 0){
                         -- count;
                         if(verbose){
+                if (count > 0) {
+                        count--;
+                        if (verbose)
                                 printf("Waiting for next %d packet(s)\n", count);
+                        }
+                }
+        }
+        if(verbose){
+                }
+        }
+        if (verbose)
                 printf("Closing the socket\n");
+        }
         // close the listenning socket
+        if(ERROR_OCCURRED(closesocket(listening_id))){
+                socket_print_error(stderr, ERROR_CODE, "Close socket: ", "\n");
+                return ERROR_CODE;
+        }
+        if(verbose){
+        rc = closesocket(listening_id);
+        if (rc != EOK) {
+                socket_print_error(stderr, rc, "Close socket: ", "\n");
+                return rc;
+        }
+        if (verbose)
                 printf("Exiting\n");
+        }
         return EOK;

uspace/app/netecho/print_error.c

-              rd70a463
+              rb40bfac
 /** @addtogroup net_app
  *  @{
+ * @{
  */
 /** @file
  *  Generic application error printing functions implementation.
+ * Generic application error printing functions implementation.
  */
+#include "print_error.h"
 #include <stdio.h>
 …
 #include <net/icmp_codes.h>
+#include "print_error.h"
+/** Prints the specific ICMP error description.
+ *
+ * @param[in] output The description output stream. May be NULL.
+ * @param[in] error_code The ICMP error code.
+ * @param[in] prefix The error description prefix. May be NULL.
+ * @param[in] suffix The error description suffix. May be NULL.
+ */
+void icmp_print_error(FILE *output, int error_code, const char *prefix, const char *suffix)
+{
+        if (!output)
+                return;
+        if (prefix)
+                fprintf(output, "%s", prefix);
+        switch (error_code) {
+        case ICMP_DEST_UNREACH:
+                fprintf(output, "ICMP Destination Unreachable (%d) error", error_code);
+                break;
+        case ICMP_SOURCE_QUENCH:
+                fprintf(output, "ICMP Source Quench (%d) error", error_code);
+                break;
+        case ICMP_REDIRECT:
+                fprintf(output, "ICMP Redirect (%d) error", error_code);
+                break;
+        case ICMP_ALTERNATE_ADDR:
+                fprintf(output, "ICMP Alternate Host Address (%d) error", error_code);
+                break;
+        case ICMP_ROUTER_ADV:
+                fprintf(output, "ICMP Router Advertisement (%d) error", error_code);
+                break;
+        case ICMP_ROUTER_SOL:
+                fprintf(output, "ICMP Router Solicitation (%d) error", error_code);
+                break;
+        case ICMP_TIME_EXCEEDED:
+                fprintf(output, "ICMP Time Exceeded (%d) error", error_code);
+                break;
+        case ICMP_PARAMETERPROB:
+                fprintf(output, "ICMP Paramenter Problem (%d) error", error_code);
+                break;
+        case ICMP_CONVERSION_ERROR:
+                fprintf(output, "ICMP Datagram Conversion Error (%d) error", error_code);
+                break;
+        case ICMP_REDIRECT_MOBILE:
+                fprintf(output, "ICMP Mobile Host Redirect (%d) error", error_code);
+                break;
+        case ICMP_SKIP:
+                fprintf(output, "ICMP SKIP (%d) error", error_code);
+                break;
+        case ICMP_PHOTURIS:
+                fprintf(output, "ICMP Photuris (%d) error", error_code);
+                break;
+        default:
+                fprintf(output, "Other (%d) error", error_code);
+        }
+void icmp_print_error(FILE * output, int error_code, const char * prefix, const char * suffix){
+        if(output){
+                if(prefix){
+                        fprintf(output, "%s", prefix);
+                }
+                switch(error_code){
+                        case ICMP_DEST_UNREACH:
+                                fprintf(output, "ICMP Destination Unreachable (%d) error", error_code);
+                                break;
+                        case ICMP_SOURCE_QUENCH:
+                                fprintf(output, "ICMP Source Quench (%d) error", error_code);
+                                break;
+                        case ICMP_REDIRECT:
+                                fprintf(output, "ICMP Redirect (%d) error", error_code);
+                                break;
+                        case ICMP_ALTERNATE_ADDR:
+                                fprintf(output, "ICMP Alternate Host Address (%d) error", error_code);
+                                break;
+                        case ICMP_ROUTER_ADV:
+                                fprintf(output, "ICMP Router Advertisement (%d) error", error_code);
+                                break;
+                        case ICMP_ROUTER_SOL:
+                                fprintf(output, "ICMP Router Solicitation (%d) error", error_code);
+                                break;
+                        case ICMP_TIME_EXCEEDED:
+                                fprintf(output, "ICMP Time Exceeded (%d) error", error_code);
+                                break;
+                        case ICMP_PARAMETERPROB:
+                                fprintf(output, "ICMP Paramenter Problem (%d) error", error_code);
+                                break;
+                        case ICMP_CONVERSION_ERROR:
+                                fprintf(output, "ICMP Datagram Conversion Error (%d) error", error_code);
+                                break;
+                        case ICMP_REDIRECT_MOBILE:
+                                fprintf(output, "ICMP Mobile Host Redirect (%d) error", error_code);
+                                break;
+                        case ICMP_SKIP:
+                                fprintf(output, "ICMP SKIP (%d) error", error_code);
+                                break;
+                        case ICMP_PHOTURIS:
+                                fprintf(output, "ICMP Photuris (%d) error", error_code);
+                                break;
+                        default:
+                                fprintf(output, "Other (%d) error", error_code);
+                }
+                if(suffix){
+                        fprintf(output, "%s", suffix);
+                }
+        }
+        if (suffix)
+                fprintf(output, "%s", suffix);
+}
+void print_error(FILE * output, int error_code, const char * prefix, const char * suffix){
+        if(IS_ICMP_ERROR(error_code)){
+/** Prints the error description.
+ *
+ * Supports ICMP and socket error codes.
+ *
+ * @param[in] output The description output stream. May be NULL.
+ * @param[in] error_code The error code.
+ * @param[in] prefix The error description prefix. May be NULL.
+ * @param[in] suffix The error description suffix. May be NULL.
+ */
+void print_error(FILE *output, int error_code, const char *prefix, const char *suffix)
+{
+        if (IS_ICMP_ERROR(error_code))
                 icmp_print_error(output, error_code, prefix, suffix);
         }else if(IS_SOCKET_ERROR(error_code)){
+        else if(IS_SOCKET_ERROR(error_code))
                 socket_print_error(output, error_code, prefix, suffix);
+        }
+}
+void socket_print_error(FILE * output, int error_code, const char * prefix, const char * suffix){
+        if(output){
+                if(prefix){
+                        fprintf(output, "%s", prefix);
+                }
+                switch(error_code){
+                        case ENOTSOCK:
+                                fprintf(output, "Not a socket (%d) error", error_code);
+                                break;
+                        case EPROTONOSUPPORT:
+                                fprintf(output, "Protocol not supported (%d) error", error_code);
+                                break;
+                        case ESOCKTNOSUPPORT:
+                                fprintf(output, "Socket type not supported (%d) error", error_code);
+                                break;
+                        case EPFNOSUPPORT:
+                                fprintf(output, "Protocol family not supported (%d) error", error_code);
+                                break;
+                        case EAFNOSUPPORT:
+                                fprintf(output, "Address family not supported (%d) error", error_code);
+                                break;
+                        case EADDRINUSE:
+                                fprintf(output, "Address already in use (%d) error", error_code);
+                                break;
+                        case ENOTCONN:
+                                fprintf(output, "Socket not connected (%d) error", error_code);
+                                break;
+                        case NO_DATA:
+                                fprintf(output, "No data (%d) error", error_code);
+                                break;
+                        case EINPROGRESS:
+                                fprintf(output, "Another operation in progress (%d) error", error_code);
+                                break;
+                        case EDESTADDRREQ:
+                                fprintf(output, "Destination address required (%d) error", error_code);
+                        case TRY_AGAIN:
+                                fprintf(output, "Try again (%d) error", error_code);
+                        default:
+                                fprintf(output, "Other (%d) error", error_code);
+                }
+                if(suffix){
+                        fprintf(output, "%s", suffix);
+                }
+/** Prints the specific socket error description.
+ *
+ * @param[in] output The description output stream. May be NULL.
+ * @param[in] error_code The socket error code.
+ * @param[in] prefix The error description prefix. May be NULL.
+ * @param[in] suffix The error description suffix. May be NULL.
+ */
+void socket_print_error(FILE *output, int error_code, const char *prefix, const char *suffix)
+{
+        if (!output)
+                return;
+        if (prefix)
+                fprintf(output, "%s", prefix);
+        switch (error_code) {
+        case ENOTSOCK:
+                fprintf(output, "Not a socket (%d) error", error_code);
+                break;
+        case EPROTONOSUPPORT:
+                fprintf(output, "Protocol not supported (%d) error", error_code);
+                break;
+        case ESOCKTNOSUPPORT:
+                fprintf(output, "Socket type not supported (%d) error", error_code);
+                break;
+        case EPFNOSUPPORT:
+                fprintf(output, "Protocol family not supported (%d) error", error_code);
+                break;
+        case EAFNOSUPPORT:
+                fprintf(output, "Address family not supported (%d) error", error_code);
+                break;
+        case EADDRINUSE:
+                fprintf(output, "Address already in use (%d) error", error_code);
+                break;
+        case ENOTCONN:
+                fprintf(output, "Socket not connected (%d) error", error_code);
+                break;
+        case NO_DATA:
+                fprintf(output, "No data (%d) error", error_code);
+                break;
+        case EINPROGRESS:
+                fprintf(output, "Another operation in progress (%d) error", error_code);
+                break;
+        case EDESTADDRREQ:
+                fprintf(output, "Destination address required (%d) error", error_code);
+        case TRY_AGAIN:
+                fprintf(output, "Try again (%d) error", error_code);
+        default:
+                fprintf(output, "Other (%d) error", error_code);
+        }
+        if (suffix)
+                fprintf(output, "%s", suffix);
+}
 /** @}
  */

uspace/app/netecho/print_error.h

-              rd70a463
+              rb40bfac
 /** @addtogroup net_app
  *  @{
+ * @{
  */
 /** @file
  *  Generic application error printing functions.
+ * Generic application error printing functions.
  */
+#ifndef __NET_APP_PRINT__
+#define __NET_APP_PRINT__
+#ifndef NET_APP_PRINT_
+#define NET_APP_PRINT_
+#include <stdio.h>
 /** Returns whether the error code may be an ICMP error code.
+ *  @param[in] error_code The error code.
+ *  @returns A value indicating whether the error code may be an ICMP error code.
+ *
+ * @param[in] error_code The error code.
+ * @returns A value indicating whether the error code may be an ICMP error code.
  */
 #define IS_ICMP_ERROR(error_code)               ((error_code) > 0)
+#define IS_ICMP_ERROR(error_code)       ((error_code) > 0)
 /** Returns whether the error code may be socket error code.
+ *  @param[in] error_code The error code.
+ *  @returns A value indicating whether the error code may be a socket error code.
+ *
+ * @param[in] error_code The error code.
+ * @returns A value indicating whether the error code may be a socket error code.
  */
 #define IS_SOCKET_ERROR(error_code)     ((error_code) < 0)
+/** Prints the specific ICMP error description.
+ *  @param[in] output The description output stream. May be NULL.
+ *  @param[in] error_code The ICMP error code.
+ *  @param[in] prefix The error description prefix. May be NULL.
+ *  @param[in] suffix The error description suffix. May be NULL.
+ */
+extern void icmp_print_error(FILE * output, int error_code, const char * prefix, const char * suffix);
+/** Prints the error description.
+ *  Supports ICMP and socket error codes.
+ *  @param[in] output The description output stream. May be NULL.
+ *  @param[in] error_code The error code.
+ *  @param[in] prefix The error description prefix. May be NULL.
+ *  @param[in] suffix The error description suffix. May be NULL.
+ */
+extern void print_error(FILE * output, int error_code, const char * prefix, const char * suffix);
+/** Prints the specific socket error description.
+ *  @param[in] output The description output stream. May be NULL.
+ *  @param[in] error_code The socket error code.
+ *  @param[in] prefix The error description prefix. May be NULL.
+ *  @param[in] suffix The error description suffix. May be NULL.
+ */
+extern void socket_print_error(FILE * output, int error_code, const char * prefix, const char * suffix);
+extern void icmp_print_error(FILE *, int, const char *, const char *);
+extern void print_error(FILE *, int, const char *, const char *);
+extern void socket_print_error(FILE *, int, const char *, const char *);
 #endif

uspace/app/netstart/Makefile

-              rd70a463
+              rb40bfac
+#
 USPACE_PREFIX = ../../..
+USPACE_PREFIX = ../..
 LIBS = $(LIBNET_PREFIX)/libnet.a
 EXTRA_CFLAGS = -I$(LIBNET_PREFIX)/include
 …
 SOURCES = \
+        netstart.c \
+        self_test.c
+        netstart.c
 include $(USPACE_PREFIX)/Makefile.common

uspace/app/netstart/netstart.c

-              rd70a463
+              rb40bfac
 /** @file
+ *
  * Start the networking subsystem.
- * Perform networking self-test if executed
- * with the -s argument.
+ *
  */
 …
 #include <task.h>
 #include <str_error.h>
-#include <err.h>
 #include <ipc/ipc.h>
 #include <ipc/services.h>
 …
 #include <net/modules.h>
-#include "self_test.h"
 /** Start a module.
+ *
+ * @param[in] desc The module description
+ * @param[in] path The module absolute path.
+ *
+ * @returns true on succesful spanwning
+ * @returns false on failure
+ *
+ * @param[in] desc      The module description
+ * @param[in] path      The module absolute path.
+ * @returns             True on succesful spanwning.
+ * @returns             False on failure
  */
 static bool spawn(const char *desc, const char *path)
+{
+        int rc;
         printf("%s: Spawning %s (%s)\n", NAME, desc, path);
+        const char *argv[2];
+        argv[0] = path;
+        argv[1] = NULL;
+        int err;
+        if (task_spawn(path, argv, &err) == 0) {
+        rc = task_spawnl(NULL, path, path, NULL);
+        if (rc != EOK) {
                 fprintf(stderr, "%s: Error spawning %s (%s)\n", NAME, path,
                     str_error(err));
+                    str_error(rc));
                 return false;
+        }
 …
 int main(int argc, char *argv[])
+{
+        ERROR_DECLARE;
+        /* Run self-tests */
+        if ((argc > 1) && (str_cmp(argv[1], "-s") == 0))
+                ERROR_PROPAGATE(self_test());
+        int rc;
         if (!spawn("networking service", "/srv/net"))
 …
         int net_phone = connect_to_service(SERVICE_NETWORKING);
+        if (ERROR_OCCURRED(ipc_call_sync_0_0(net_phone, NET_NET_STARTUP))) {
+                fprintf(stderr, "%s: Startup error %d\n", NAME, ERROR_CODE);
+                return ERROR_CODE;
+        rc = ipc_call_sync_0_0(net_phone, NET_NET_STARTUP);
+        if (rc != EOK) {
+                fprintf(stderr, "%s: Startup error %d\n", NAME, rc);
+                return rc;
+        }

uspace/app/nettest1/nettest.c

-              rd70a463
+              rb40bfac
 /** @addtogroup nettest
  *  @{
+ * @{
  */
 /** @file
  *  Networking test support functions implementation.
+ * Networking test support functions implementation.
  */
 #include <stdio.h>
-#include <err.h>
 #include <net/socket.h>
 …
 #include "print_error.h"
+int sockets_create(int verbose, int * socket_ids, int sockets, int family, sock_type_t type){
+        int index;
+        if(verbose){
+/** Creates new sockets.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[out] socket_ids A field to store the socket identifiers.
+ * @param[in] sockets The number of sockets to create. Should be at most the size of the field.
+ * @param[in] family The socket address family.
+ * @param[in] type The socket type.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the socket() function.
+ */
+int sockets_create(int verbose, int *socket_ids, int sockets, int family, sock_type_t type)
+{
+        int index;
+        if (verbose)
                 printf("Create\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
                 socket_ids[index] = socket(family, type, 0);
                 if(socket_ids[index] < 0){
+                if (socket_ids[index] < 0) {
                         printf("Socket %d (%d) error:\n", index, socket_ids[index]);
                         socket_print_error(stderr, socket_ids[index], "Socket create: ", "\n");
                         return socket_ids[index];
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+int sockets_close(int verbose, int * socket_ids, int sockets){
+        ERROR_DECLARE;
+        int index;
+        if(verbose){
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Closes sockets.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[in] socket_ids A field of stored socket identifiers.
+ * @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the closesocket() function.
+ */
+int sockets_close(int verbose, int *socket_ids, int sockets)
+{
+        int index;
+        int rc;
+        if (verbose)
                 printf("\tClose\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+                if(ERROR_OCCURRED(closesocket(socket_ids[index]))){
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
+                rc = closesocket(socket_ids[index]);
+                if (rc != EOK) {
                         printf("Socket %d (%d) error:\n", index, socket_ids[index]);
+                        socket_print_error(stderr, ERROR_CODE, "Socket close: ", "\n");
+                        return ERROR_CODE;
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+int sockets_connect(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t addrlen){
+        ERROR_DECLARE;
+        int index;
+        if(verbose){
+                        socket_print_error(stderr, rc, "Socket close: ", "\n");
+                        return rc;
+                }
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Connects sockets.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[in] socket_ids A field of stored socket identifiers.
+ * @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ * @param[in] address The destination host address to connect to.
+ * @param[in] addrlen The length of the destination address in bytes.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the connect() function.
+ */
+int sockets_connect(int verbose, int *socket_ids, int sockets, struct sockaddr *address, socklen_t addrlen)
+{
+        int index;
+        int rc;
+        if (verbose)
                 printf("\tConnect\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+                if(ERROR_OCCURRED(connect(socket_ids[index], address, addrlen))){
+                        socket_print_error(stderr, ERROR_CODE, "Socket connect: ", "\n");
+                        return ERROR_CODE;
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+int sockets_sendto(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t addrlen, char * data, int size, int messages){
+        ERROR_DECLARE;
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
+                rc = connect(socket_ids[index], address, addrlen);
+                if (rc != EOK) {
+                        socket_print_error(stderr, rc, "Socket connect: ", "\n");
+                        return rc;
+                }
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Sends data via sockets.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[in] socket_ids A field of stored socket identifiers.
+ * @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ * @param[in] address The destination host address to send data to.
+ * @param[in] addrlen The length of the destination address in bytes.
+ * @param[in] data The data to be sent.
+ * @param[in] size The data size in bytes.
+ * @param[in] messages The number of datagrams per socket to be sent.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the sendto() function.
+ */
+int sockets_sendto(int verbose, int *socket_ids, int sockets, struct sockaddr *address, socklen_t addrlen, char *data, int size, int messages)
+{
         int index;
         int message;
+        if(verbose){
+        int rc;
+        if (verbose)
                 printf("\tSendto\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+                for(message = 0; message < messages; ++ message){
+                        if(ERROR_OCCURRED(sendto(socket_ids[index], data, size, 0, address, addrlen))){
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, ERROR_CODE, "Socket send: ", "\n");
+                                return ERROR_CODE;
+                        }
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+int sockets_recvfrom(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t * addrlen, char * data, int size, int messages){
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
+                for (message = 0; message < messages; message++) {
+                        rc = sendto(socket_ids[index], data, size, 0, address, addrlen);
+                        if (rc != EOK) {
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, rc, "Socket send: ", "\n");
+                                return rc;
+                        }
+                }
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Receives data via sockets.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[in] socket_ids A field of stored socket identifiers.
+ * @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ * @param[in] address The source host address of received datagrams.
+ * @param[in,out] addrlen The maximum length of the source address in bytes. The actual size of the source address is set instead.
+ * @param[out] data The received data.
+ * @param[in] size The maximum data size in bytes.
+ * @param[in] messages The number of datagrams per socket to be received.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the recvfrom() function.
+ */
+int sockets_recvfrom(int verbose, int *socket_ids, int sockets, struct sockaddr *address, socklen_t *addrlen, char *data, int size, int messages)
+{
         int value;
         int index;
         int message;
         if(verbose){
+        if (verbose)
                 printf("\tRecvfrom\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+                for(message = 0; message < messages; ++ message){
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
+                for (message = 0; message < messages; message++) {
                         value = recvfrom(socket_ids[index], data, size, 0, address, addrlen);
                         if(value < 0){
+                        if (value < 0) {
                                 printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
                                 socket_print_error(stderr, value, "Socket receive: ", "\n");
 …
+                        }
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+int sockets_sendto_recvfrom(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t * addrlen, char * data, int size, int messages){
+        ERROR_DECLARE;
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Sends and receives data via sockets.
+ *
+ * Each datagram is sent and a reply read consequently.
+ * The next datagram is sent after the reply is received.
+ *
+ * @param[in] verbose A value indicating whether to print out verbose information.
+ * @param[in] socket_ids A field of stored socket identifiers.
+ * @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ * @param[in,out] address The destination host address to send data to. The source host address of received datagrams is set instead.
+ * @param[in] addrlen The length of the destination address in bytes.
+ * @param[in,out] data The data to be sent. The received data are set instead.
+ * @param[in] size The data size in bytes.
+ * @param[in] messages The number of datagrams per socket to be received.
+ * @returns EOK on success.
+ * @returns Other error codes as defined for the recvfrom() function.
+ */
+int sockets_sendto_recvfrom(int verbose, int *socket_ids, int sockets, struct sockaddr *address, socklen_t *addrlen, char *data, int size, int messages)
+{
         int value;
         int index;
         int message;
+        if(verbose){
+        int rc;
+        if (verbose)
                 printf("\tSendto and recvfrom\t");
+        }
+        fflush(stdout);
+        for(index = 0; index < sockets; ++ index){
+                for(message = 0; message < messages; ++ message){
+                        if(ERROR_OCCURRED(sendto(socket_ids[index], data, size, 0, address, * addrlen))){
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, ERROR_CODE, "Socket send: ", "\n");
+                                return ERROR_CODE;
+        fflush(stdout);
+        for (index = 0; index < sockets; index++) {
+                for (message = 0; message < messages; message++) {
+                        rc = sendto(socket_ids[index], data, size, 0, address, *addrlen);
+                        if (rc != EOK) {
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, rc, "Socket send: ", "\n");
+                                return rc;
+                        }
                         value = recvfrom(socket_ids[index], data, size, 0, address, addrlen);
                         if(value < 0){
+                        if (value < 0) {
                                 printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
                                 socket_print_error(stderr, value, "Socket receive: ", "\n");
 …
+                        }
+                }
+                if(verbose){
+                        print_mark(index);
+                }
+        }
+        return EOK;
+}
+void print_mark(int index){
+        if((index + 1) % 10){
+                if (verbose)
+                        print_mark(index);
+        }
+        return EOK;
+}
+/** Prints a mark.
+ *
+ * If the index is a multiple of ten, a different mark is printed.
+ *
+ * @param[in] index The index of the mark to be printed.
+ */
+void print_mark(int index)
+{
+        if ((index + 1) % 10)
                 printf("*");
         }else{
+        else
                 printf("|");
+        }
         fflush(stdout);
+}

uspace/app/nettest1/nettest.h

-              rd70a463
+              rb40bfac
 /** @addtogroup nettest
  *  @{
+ * @{
  */
 /** @file
  *  Networking test support functions.
+ * Networking test support functions.
  */
 #ifndef __NET_TEST__
 #define __NET_TEST__
+#ifndef NET_TEST_
+#define NET_TEST_
 #include <net/socket.h>
+/** Prints a mark.
+ *  If the index is a multiple of ten, a different mark is printed.
+ *  @param[in] index The index of the mark to be printed.
+ */
+extern void print_mark(int index);
+/** Creates new sockets.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[out] socket_ids A field to store the socket identifiers.
+ *  @param[in] sockets The number of sockets to create. Should be at most the size of the field.
+ *  @param[in] family The socket address family.
+ *  @param[in] type The socket type.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the socket() function.
+ */
+extern int sockets_create(int verbose, int * socket_ids, int sockets, int family, sock_type_t type);
+/** Closes sockets.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[in] socket_ids A field of stored socket identifiers.
+ *  @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the closesocket() function.
+ */
+extern int sockets_close(int verbose, int * socket_ids, int sockets);
+/** Connects sockets.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[in] socket_ids A field of stored socket identifiers.
+ *  @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ *  @param[in] address The destination host address to connect to.
+ *  @param[in] addrlen The length of the destination address in bytes.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the connect() function.
+ */
+extern int sockets_connect(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t addrlen);
+/** Sends data via sockets.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[in] socket_ids A field of stored socket identifiers.
+ *  @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ *  @param[in] address The destination host address to send data to.
+ *  @param[in] addrlen The length of the destination address in bytes.
+ *  @param[in] data The data to be sent.
+ *  @param[in] size The data size in bytes.
+ *  @param[in] messages The number of datagrams per socket to be sent.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the sendto() function.
+ */
+extern int sockets_sendto(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t addrlen, char * data, int size, int messages);
+/** Receives data via sockets.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[in] socket_ids A field of stored socket identifiers.
+ *  @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ *  @param[in] address The source host address of received datagrams.
+ *  @param[in,out] addrlen The maximum length of the source address in bytes. The actual size of the source address is set instead.
+ *  @param[out] data The received data.
+ *  @param[in] size The maximum data size in bytes.
+ *  @param[in] messages The number of datagrams per socket to be received.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the recvfrom() function.
+ */
+extern int sockets_recvfrom(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t * addrlen, char * data, int size, int messages);
+/** Sends and receives data via sockets.
+ *  Each datagram is sent and a reply read consequently.
+ *  The next datagram is sent after the reply is received.
+ *  @param[in] verbose A value indicating whether to print out verbose information.
+ *  @param[in] socket_ids A field of stored socket identifiers.
+ *  @param[in] sockets The number of sockets in the field. Should be at most the size of the field.
+ *  @param[in,out] address The destination host address to send data to. The source host address of received datagrams is set instead.
+ *  @param[in] addrlen The length of the destination address in bytes.
+ *  @param[in,out] data The data to be sent. The received data are set instead.
+ *  @param[in] size The data size in bytes.
+ *  @param[in] messages The number of datagrams per socket to be received.
+ *  @returns EOK on success.
+ *  @returns Other error codes as defined for the recvfrom() function.
+ */
+extern int sockets_sendto_recvfrom(int verbose, int * socket_ids, int sockets, struct sockaddr * address, socklen_t * addrlen, char * data, int size, int messages);
+extern void print_mark(int);
+extern int sockets_create(int, int *, int, int, sock_type_t);
+extern int sockets_close(int, int *, int);
+extern int sockets_connect(int, int *, int, struct sockaddr *, socklen_t);
+extern int sockets_sendto(int, int *, int, struct sockaddr *, socklen_t, char *, int, int);
+extern int sockets_recvfrom(int, int *, int, struct sockaddr *, socklen_t *, char *, int, int);
+extern int sockets_sendto_recvfrom(int, int *, int, struct sockaddr *, socklen_t *, char *, int, int);
 #endif
 …
 /** @}
  */

uspace/app/nettest1/nettest1.c

-              rd70a463
+              rb40bfac
 /** @addtogroup nettest
  *  @{
+ * @{
  */
 /** @file
+ *  Networking test 1 application - sockets.
+ */
+ * Networking test 1 application - sockets.
+ */
+#include "nettest.h"
+#include "print_error.h"
 #include <malloc.h>
 …
 #include <time.h>
 #include <arg_parse.h>
-#include <err.h>
 #include <net/in.h>
 …
 #include <net/socket_parse.h>
+#include "nettest.h"
+#include "print_error.h"
+/** Echo module name.
+ */
+/** Echo module name. */
 #define NAME    "Nettest1"
+/** Packet data pattern.
+ */
+/** Packet data pattern. */
 #define NETTEST1_TEXT   "Networking test 1 - sockets"
+/** Module entry point.
+ *  Starts testing.
+ *  @param[in] argc The number of command line parameters.
+ *  @param[in] argv The command line parameters.
+ *  @returns EOK on success.
+ */
+int main(int argc, char * argv[]);
+/** Prints the application help.
+ */
+void nettest1_print_help(void);
+/** Refreshes the data.
+ *  Fills the data block with the NETTEST1_TEXT pattern.
+ *  @param[out] data The data block.
+ *  @param[in] size The data block size in bytes.
+ */
+void nettest1_refresh_data(char * data, size_t size);
+int main(int argc, char * argv[]){
+        ERROR_DECLARE;
+        size_t size                     = 27;
+        int verbose                     = 0;
+        sock_type_t type        = SOCK_DGRAM;
+        int sockets                     = 10;
+        int messages            = 10;
+        int family                      = PF_INET;
+        uint16_t port           = 7;
+        socklen_t max_length                            = sizeof(struct sockaddr_in6);
+        uint8_t address_data[max_length];
+        struct sockaddr * address                       = (struct sockaddr *) address_data;
+        struct sockaddr_in * address_in         = (struct sockaddr_in *) address;
+        struct sockaddr_in6 * address_in6       = (struct sockaddr_in6 *) address;
+        socklen_t addrlen;
+//      char address_string[INET6_ADDRSTRLEN];
+        uint8_t * address_start;
+        int * socket_ids;
+        char * data;
+static int family = PF_INET;
+static sock_type_t type = SOCK_DGRAM;
+static char *data;
+static size_t size = 27;
+static int verbose = 0;
+static struct sockaddr *address;
+static socklen_t addrlen;
+static int sockets;
+static int messages;
+static uint16_t port;
+static void nettest1_print_help(void)
+{
+        printf(
+            "Network Networking test 1 aplication - sockets\n"
+            "Usage: echo [options] numeric_address\n"
+            "Where options are:\n"
+            "-f protocol_family | --family=protocol_family\n"
+            "\tThe listenning socket protocol family. Only the PF_INET and "
+            "PF_INET6 are supported.\n"
+            "\n"
+            "-h | --help\n"
+            "\tShow this application help.\n"
+            "\n"
+            "-m count | --messages=count\n"
+            "\tThe number of messages to send and receive per socket. The "
+            "default is 10.\n"
+            "\n"
+            "-n sockets | --sockets=count\n"
+            "\tThe number of sockets to use. The default is 10.\n"
+            "\n"
+            "-p port_number | --port=port_number\n"
+            "\tThe port number the application should send messages to. The "
+            "default is 7.\n"
+            "\n"
+            "-s packet_size | --size=packet_size\n"
+            "\tThe packet data size the application sends. The default is "
+            "28 bytes.\n"
+            "\n"
+            "-v | --verbose\n"
+            "\tShow all output messages.\n");
+}
+/** Parse one command-line option.
+ *
+ * @param argc          Number of all command-line arguments.
+ * @param argv          All command-line arguments.
+ * @param index         Current argument index (in, out).
+ */
+static int nettest1_parse_opt(int argc, char *argv[], int *index)
+{
         int value;
+        int rc;
+        switch (argv[*index][1]) {
+        /*
+         * Short options with only one letter
+         */
+        case 'f':
+                rc = arg_parse_name_int(argc, argv, index, &family, 0, socket_parse_protocol_family);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'h':
+                nettest1_print_help();
+                return EOK;
+        case 'm':
+                rc = arg_parse_int(argc, argv, index, &messages, 0);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'n':
+                rc = arg_parse_int(argc, argv, index, &sockets, 0);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'p':
+                rc = arg_parse_int(argc, argv, index, &value, 0);
+                if (rc != EOK)
+                        return rc;
+                port = (uint16_t) value;
+                break;
+        case 's':
+                rc = arg_parse_int(argc, argv, index, &value, 0);
+                if (rc != EOK)
+                        return rc;
+                size = (value >= 0) ? (size_t) value : 0;
+                break;
+        case 't':
+                rc = arg_parse_name_int(argc, argv, index, &value, 0, socket_parse_socket_type);
+                if (rc != EOK)
+                        return rc;
+                type = (sock_type_t) value;
+                break;
+        case 'v':
+                verbose = 1;
+                break;
+        /*
+         * Long options with double dash ('-')
+         */
+        case '-':
+                if (str_lcmp(argv[*index] + 2, "family=", 7) == 0) {
+                        rc = arg_parse_name_int(argc, argv, index, &family, 9,
+                            socket_parse_protocol_family);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "help", 5) == 0) {
+                        nettest1_print_help();
+                        return EOK;
+                } else if (str_lcmp(argv[*index] + 2, "messages=", 6) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &messages, 8);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "sockets=", 6) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &sockets, 8);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "port=", 5) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &value, 7);
+                        if (rc != EOK)
+                                return rc;
+                        port = (uint16_t) value;
+                } else if (str_lcmp(argv[*index] + 2, "type=", 5) == 0) {
+                        rc = arg_parse_name_int(argc, argv, index, &value, 7,
+                            socket_parse_socket_type);
+                        if (rc != EOK)
+                                return rc;
+                        type = (sock_type_t) value;
+                } else if (str_lcmp(argv[*index] + 2, "verbose", 8) == 0) {
+                        verbose = 1;
+                } else {
+                        nettest1_print_help();
+                        return EINVAL;
+                }
+                break;
+        default:
+                nettest1_print_help();
+                return EINVAL;
+        }
+        return EOK;
+}
+/** Fill buffer with the NETTEST1_TEXT pattern.
+ *
+ * @param buffer        Data buffer.
+ * @param size          Buffer size in bytes.
+ */
+static void nettest1_fill_buffer(char *buffer, size_t size)
+{
+        size_t length;
+        length = 0;
+        while (size > length + sizeof(NETTEST1_TEXT) - 1) {
+                memcpy(buffer + length, NETTEST1_TEXT,
+                    sizeof(NETTEST1_TEXT) - 1);
+                length += sizeof(NETTEST1_TEXT) - 1;
+        }
+        memcpy(buffer + length, NETTEST1_TEXT, size - length);
+        buffer[size] = '\0';
+}
+static int nettest1_test(int *socket_ids, int nsockets, int nmessages)
+{
+        int rc;
+        if (verbose)
+                printf("%d sockets, %d messages\n", nsockets, nmessages);
+        rc = sockets_create(verbose, socket_ids, nsockets, family, type);
+        if (rc != EOK)
+                return rc;
+        if (type == SOCK_STREAM) {
+                rc = sockets_connect(verbose, socket_ids, nsockets, address,
+                    addrlen);
+                if (rc != EOK)
+                        return rc;
+        }
+        rc = sockets_sendto_recvfrom(verbose, socket_ids, nsockets, address,
+            &addrlen, data, size, nmessages);
+        if (rc != EOK)
+                return rc;
+        rc = sockets_close(verbose, socket_ids, nsockets);
+        if (rc != EOK)
+                return rc;
+        if (verbose)
+                printf("\tOK\n");
+        /****/
+        rc = sockets_create(verbose, socket_ids, nsockets, family, type);
+        if (rc != EOK)
+                return rc;
+        if (type == SOCK_STREAM) {
+                rc = sockets_connect(verbose, socket_ids, nsockets, address,
+                    addrlen);
+                if (rc != EOK)
+                        return rc;
+        }
+        rc = sockets_sendto(verbose, socket_ids, nsockets, address, addrlen,
+            data, size, nmessages);
+        if (rc != EOK)
+                return rc;
+        rc = sockets_recvfrom(verbose, socket_ids, nsockets, address, &addrlen,
+            data, size, nmessages);
+        if (rc != EOK)
+                return rc;
+        rc = sockets_close(verbose, socket_ids, nsockets);
+        if (rc != EOK)
+                return rc;
+        if (verbose)
+                printf("\tOK\n");
+        return EOK;
+}
+int main(int argc, char *argv[])
+{
+        socklen_t max_length;
+        uint8_t *address_data[sizeof(struct sockaddr_in6)];
+        struct sockaddr_in *address_in;
+        struct sockaddr_in6 *address_in6;
+        uint8_t *address_start;
+        int *socket_ids;
         int index;
         struct timeval time_before;
         struct timeval time_after;
+        // parse the command line arguments
+        // stop before the last argument if it does not start with the minus sign ('-')
+        for(index = 1; (index < argc - 1) || ((index == argc - 1) && (argv[index][0] == '-')); ++ index){
+                // options should start with the minus sign ('-')
+                if(argv[index][0] == '-'){
+                        switch(argv[index][1]){
+                                // short options with only one letter
+                                case 'f':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 0, socket_parse_protocol_family));
+                                        break;
+                                case 'h':
+                                        nettest1_print_help();
+                                        return EOK;
+                                        break;
+                                case 'm':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &messages, 0));
+                                        break;
+                                case 'n':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &sockets, 0));
+                                        break;
+                                case 'p':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                        port = (uint16_t) value;
+                                        break;
+                                case 's':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                        size = (value >= 0) ? (size_t) value : 0;
+                                        break;
+                                case 't':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 0, socket_parse_socket_type));
+                                        type = (sock_type_t) value;
+                                        break;
+                                case 'v':
+                                        verbose = 1;
+                                        break;
+                                // long options with the double minus sign ('-')
+                                case '-':
+                                        if(str_lcmp(argv[index] + 2, "family=", 7) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 9, socket_parse_protocol_family));
+                                        }else if(str_lcmp(argv[index] + 2, "help", 5) == 0){
+                                                nettest1_print_help();
+                                                return EOK;
+                                        }else if(str_lcmp(argv[index] + 2, "messages=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &messages, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "sockets=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &sockets, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "port=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 7));
+                                                port = (uint16_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "type=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 7, socket_parse_socket_type));
+                                                type = (sock_type_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "verbose", 8) == 0){
+                                                verbose = 1;
+                                        }else{
+                                                nettest1_print_help();
+                                                return EINVAL;
+                                        }
+                                        break;
+                                default:
+                                        nettest1_print_help();
+                                        return EINVAL;
+                        }
+                }else{
+        int rc;
+        max_length = sizeof(address_data);
+        address = (struct sockaddr *) address_data;
+        address_in = (struct sockaddr_in *) address;
+        address_in6 = (struct sockaddr_in6 *) address;
+        sockets = 10;
+        messages = 10;
+        port = 7;
+        /*
+         * Parse the command line arguments. Stop before the last argument
+         * if it does not start with dash ('-')
+         */
+        for (index = 1; (index < argc - 1) || ((index == argc - 1) && (argv[index][0] == '-')); index++) {
+                /* Options should start with dash ('-') */
+                if (argv[index][0] == '-') {
+                        rc = nettest1_parse_opt(argc, argv, &index);
+                        if (rc != EOK)
+                                return rc;
+                } else {
                         nettest1_print_help();
                         return EINVAL;
 …
+        }
         // if not before the last argument containing the address
         if(index >= argc){
+        /* If not before the last argument containing the address */
+        if (index >= argc) {
                 printf("Command line error: missing address\n");
                 nettest1_print_help();
 …
+        }
         // prepare the address buffer
+        /* Prepare the address buffer */
         bzero(address_data, max_length);
+        switch(family){
+                case PF_INET:
+                        address_in->sin_family = AF_INET;
+                        address_in->sin_port = htons(port);
+                        address_start = (uint8_t *) &address_in->sin_addr.s_addr;
+                        addrlen = sizeof(struct sockaddr_in);
+                        break;
+                case PF_INET6:
+                        address_in6->sin6_family = AF_INET6;
+                        address_in6->sin6_port = htons(port);
+                        address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
+                        addrlen = sizeof(struct sockaddr_in6);
+                        break;
+                default:
+                        fprintf(stderr, "Address family is not supported\n");
+                        return EAFNOSUPPORT;
+        }
+        // parse the last argument which should contain the address
+        if(ERROR_OCCURRED(inet_pton(family, argv[argc - 1], address_start))){
+                fprintf(stderr, "Address parse error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        // check the buffer size
+        if(size <= 0){
+                fprintf(stderr, "Data buffer size too small (%d). Using 1024 bytes instead.\n", size);
+        switch (family) {
+        case PF_INET:
+                address_in->sin_family = AF_INET;
+                address_in->sin_port = htons(port);
+                address_start = (uint8_t *) &address_in->sin_addr.s_addr;
+                addrlen = sizeof(struct sockaddr_in);
+                break;
+        case PF_INET6:
+                address_in6->sin6_family = AF_INET6;
+                address_in6->sin6_port = htons(port);
+                address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
+                addrlen = sizeof(struct sockaddr_in6);
+                break;
+        default:
+                fprintf(stderr, "Address family is not supported\n");
+                return EAFNOSUPPORT;
+        }
+        /* Parse the last argument which should contain the address */
+        rc = inet_pton(family, argv[argc - 1], address_start);
+        if (rc != EOK) {
+                fprintf(stderr, "Address parse error %d\n", rc);
+                return rc;
+        }
+        /* Check data buffer size */
+        if (size <= 0) {
+                fprintf(stderr, "Data buffer size too small (%d). Using 1024 "
+                    "bytes instead.\n", size);
                 size = 1024;
+        }
+        // prepare the buffer
+        // size plus the terminating null (\0)
+        /*
+         * Prepare data buffer. Allocate size bytes plus one for the
+         * trailing null character.
+         */
         data = (char *) malloc(size + 1);
         if(! data){
+        if (!data) {
                 fprintf(stderr, "Failed to allocate data buffer.\n");
                 return ENOMEM;
+        }
+        nettest1_refresh_data(data, size);
+        // check the socket count
+        if(sockets <= 0){
+                fprintf(stderr, "Socket count too small (%d). Using 2 instead.\n", sockets);
+        nettest1_fill_buffer(data, size);
+        /* Check socket count */
+        if (sockets <= 0) {
+                fprintf(stderr, "Socket count too small (%d). Using "
+                    "2 instead.\n", sockets);
                 sockets = 2;
+        }
+        // prepare the socket buffer
+        // count plus the terminating null (\0)
+        /*
+         * Prepare socket buffer. Allocate count fields plus the terminating
+         * null (\0).
+         */
         socket_ids = (int *) malloc(sizeof(int) * (sockets + 1));
         if(! socket_ids){
+        if (!socket_ids) {
                 fprintf(stderr, "Failed to allocate receive buffer.\n");
                 return ENOMEM;
 …
         socket_ids[sockets] = NULL;
         if(verbose){
+        if (verbose)
                 printf("Starting tests\n");
+        }
+        if(verbose){
+                printf("1 socket, 1 message\n");
+        }
+        if(ERROR_OCCURRED(gettimeofday(&time_before, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, 1, family, type));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, 1));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, 1, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, 1, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto_recvfrom(verbose, socket_ids, 1, address, &addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, 1));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, 1, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, 1, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto(verbose, socket_ids, 1, address, addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_recvfrom(verbose, socket_ids, 1, address, &addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, 1));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        if(verbose){
+                printf("1 socket, %d messages\n", messages);
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, 1, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, 1, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto_recvfrom(verbose, socket_ids, 1, address, &addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, 1));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, 1, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, 1, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto(verbose, socket_ids, 1, address, addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_recvfrom(verbose, socket_ids, 1, address, &addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, 1));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        if(verbose){
+                printf("%d sockets, 1 message\n", sockets);
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, sockets, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, sockets, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto(verbose, socket_ids, sockets, address, addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, 1));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        if(verbose){
+                printf("%d sockets, %d messages\n", sockets, messages);
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, sockets, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(verbose){
+                printf("\tOK\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, sockets, address, addrlen));
+        }
+        ERROR_PROPAGATE(sockets_sendto(verbose, socket_ids, sockets, address, addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(ERROR_OCCURRED(gettimeofday(&time_after, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        if(verbose){
+                printf("\tOK\n");
+        }
+        printf("Tested in %d microseconds\n", tv_sub(&time_after, &time_before));
+        if(verbose){
+        rc = gettimeofday(&time_before, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        nettest1_test(socket_ids,       1,        1);
+        nettest1_test(socket_ids,       1, messages);
+        nettest1_test(socket_ids, sockets,        1);
+        nettest1_test(socket_ids, sockets, messages);
+        rc = gettimeofday(&time_after, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        printf("Tested in %d microseconds\n", tv_sub(&time_after,
+            &time_before));
+        if (verbose)
                 printf("Exiting\n");
+        }
         return EOK;
+}
-void nettest1_print_help(void){
-        printf(
-                "Network Networking test 1 aplication - sockets\n" \
-                "Usage: echo [options] numeric_address\n" \
-                "Where options are:\n" \
-                "-f protocol_family | --family=protocol_family\n" \
-                "\tThe listenning socket protocol family. Only the PF_INET and PF_INET6 are supported.\n"
-                "\n" \
-                "-h | --help\n" \
-                "\tShow this application help.\n"
-                "\n" \
-                "-m count | --messages=count\n" \
-                "\tThe number of messages to send and receive per socket. The default is 10.\n" \
-                "\n" \
-                "-n sockets | --sockets=count\n" \
-                "\tThe number of sockets to use. The default is 10.\n" \
-                "\n" \
-                "-p port_number | --port=port_number\n" \
-                "\tThe port number the application should send messages to. The default is 7.\n" \
-                "\n" \
-                "-s packet_size | --size=packet_size\n" \
-                "\tThe packet data size the application sends. The default is 28 bytes.\n" \
-                "\n" \
-                "-v | --verbose\n" \
-                "\tShow all output messages.\n"
-        );
+}
-void nettest1_refresh_data(char * data, size_t size){
-        size_t length;
-        // fill the data
-        length = 0;
-        while(size > length + sizeof(NETTEST1_TEXT) - 1){
-                memcpy(data + length, NETTEST1_TEXT, sizeof(NETTEST1_TEXT) - 1);
-                length += sizeof(NETTEST1_TEXT) - 1;
+        }
-        memcpy(data + length, NETTEST1_TEXT, size - length);
-        data[size] = '\0';
+}
 /** @}

uspace/app/nettest2/nettest2.c

-              rd70a463
+              rb40bfac
 /** @addtogroup nettest
  *  @{
+ * @{
  */
 /** @file
+ *  Networking test 2 application - transfer.
+ */
+ * Networking test 2 application - transfer.
+ */
+#include "nettest.h"
+#include "print_error.h"
 #include <malloc.h>
 …
 #include <time.h>
 #include <arg_parse.h>
 #include <err.h>
+#include <bool.h>
 #include <net/in.h>
 …
 #include <net/socket_parse.h>
+#include "nettest.h"
+#include "print_error.h"
+/** Echo module name.
+ */
+/** Echo module name. */
 #define NAME    "Nettest2"
+/** Packet data pattern.
+ */
+/** Packet data pattern. */
 #define NETTEST2_TEXT   "Networking test 2 - transfer"
+/** Module entry point.
+ *  Starts testing.
+ *  @param[in] argc The number of command line parameters.
+ *  @param[in] argv The command line parameters.
+ *  @returns EOK on success.
+ */
+int main(int argc, char * argv[]);
+/** Prints the application help.
+ */
+void nettest2_print_help(void);
+/** Refreshes the data.
+ *  Fills the data block with the NETTEST1_TEXT pattern.
+ *  @param[out] data The data block.
+ *  @param[in] size The data block size in bytes.
+ */
+void nettest2_refresh_data(char * data, size_t size);
+int main(int argc, char * argv[]){
+        ERROR_DECLARE;
+        size_t size                     = 28;
+        int verbose                     = 0;
+        sock_type_t type        = SOCK_DGRAM;
+        int sockets                     = 10;
+        int messages            = 10;
+        int family                      = PF_INET;
+        uint16_t port           = 7;
+        socklen_t max_length                            = sizeof(struct sockaddr_in6);
+        uint8_t address_data[max_length];
+        struct sockaddr * address                       = (struct sockaddr *) address_data;
+        struct sockaddr_in * address_in         = (struct sockaddr_in *) address;
+        struct sockaddr_in6 * address_in6       = (struct sockaddr_in6 *) address;
+static size_t size;
+static bool verbose;
+static sock_type_t type;
+static int sockets;
+static int messages;
+static int family;
+static uint16_t port;
+static void nettest2_print_help(void)
+{
+        printf(
+            "Network Networking test 2 aplication - UDP transfer\n"
+            "Usage: echo [options] address\n"
+            "Where options are:\n"
+            "-f protocol_family | --family=protocol_family\n"
+            "\tThe listenning socket protocol family. Only the PF_INET and "
+            "PF_INET6 are supported.\n"
+            "\n"
+            "-h | --help\n"
+            "\tShow this application help.\n"
+            "\n"
+            "-m count | --messages=count\n"
+            "\tThe number of messages to send and receive per socket. The "
+            "default is 10.\n"
+            "\n"
+            "-n sockets | --sockets=count\n"
+            "\tThe number of sockets to use. The default is 10.\n"
+            "\n"
+            "-p port_number | --port=port_number\n"
+            "\tThe port number the application should send messages to. The "
+            "default is 7.\n"
+            "\n"
+            "-s packet_size | --size=packet_size\n"
+            "\tThe packet data size the application sends. The default is 29 "
+            "bytes.\n"
+            "\n"
+            "-v | --verbose\n"
+            "\tShow all output messages.\n");
+}
+/** Fill buffer with the NETTEST2_TEXT pattern.
+ *
+ * @param buffer        Data buffer.
+ * @param size          Buffer size in bytes.
+ */
+static void nettest2_fill_buffer(char *buffer, size_t size)
+{
+        size_t length;
+        length = 0;
+        while (size > length + sizeof(NETTEST2_TEXT) - 1) {
+                memcpy(buffer + length, NETTEST2_TEXT,
+                    sizeof(NETTEST2_TEXT) - 1);
+                length += sizeof(NETTEST2_TEXT) - 1;
+        }
+        memcpy(buffer + length, NETTEST2_TEXT, size - length);
+        buffer[size] = '\0';
+}
+/** Parse one command-line option.
+ *
+ * @param argc          Number of all command-line arguments.
+ * @param argv          All command-line arguments.
+ * @param index         Current argument index (in, out).
+ */
+static int nettest2_parse_opt(int argc, char *argv[], int *index)
+{
+        int value;
+        int rc;
+        switch (argv[*index][1]) {
+        /*
+         * Short options with only one letter
+         */
+        case 'f':
+                rc = arg_parse_name_int(argc, argv, index, &family, 0,
+                    socket_parse_protocol_family);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'h':
+                nettest2_print_help();
+                return EOK;
+                break;
+        case 'm':
+                rc = arg_parse_int(argc, argv, index, &messages, 0);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'n':
+                rc = arg_parse_int(argc, argv, index, &sockets, 0);
+                if (rc != EOK)
+                        return rc;
+                break;
+        case 'p':
+                rc = arg_parse_int(argc, argv, index, &value, 0);
+                if (rc != EOK)
+                        return rc;
+                port = (uint16_t) value;
+                break;
+        case 's':
+                rc = arg_parse_int(argc, argv, index, &value, 0);
+                if (rc != EOK)
+                        return rc;
+                size = (value >= 0) ? (size_t) value : 0;
+                break;
+        case 't':
+                rc = arg_parse_name_int(argc, argv, index, &value, 0,
+                    socket_parse_socket_type);
+                if (rc != EOK)
+                        return rc;
+                type = (sock_type_t) value;
+                break;
+        case 'v':
+                verbose = true;
+                break;
+        /*
+         * Long options with double dash ('-')
+         */
+        case '-':
+                if (str_lcmp(argv[*index] + 2, "family=", 7) == 0) {
+                        rc = arg_parse_name_int(argc, argv, index, &family, 9,
+                            socket_parse_protocol_family);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "help", 5) == 0) {
+                        nettest2_print_help();
+                        return EOK;
+                } else if (str_lcmp(argv[*index] + 2, "messages=", 6) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &messages, 8);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "sockets=", 6) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &sockets, 8);
+                        if (rc != EOK)
+                                return rc;
+                } else if (str_lcmp(argv[*index] + 2, "port=", 5) == 0) {
+                        rc = arg_parse_int(argc, argv, index, &value, 7);
+                        if (rc != EOK)
+                                return rc;
+                        port = (uint16_t) value;
+                } else if (str_lcmp(argv[*index] + 2, "type=", 5) == 0) {
+                        rc = arg_parse_name_int(argc, argv, index, &value, 7,
+                            socket_parse_socket_type);
+                        if (rc != EOK)
+                                return rc;
+                        type = (sock_type_t) value;
+                } else if (str_lcmp(argv[*index] + 2, "verbose", 8) == 0) {
+                        verbose = 1;
+                } else {
+                        nettest2_print_help();
+                        return EINVAL;
+                }
+                break;
+        default:
+                nettest2_print_help();
+                return EINVAL;
+        }
+        return EOK;
+}
+int main(int argc, char *argv[])
+{
+        socklen_t max_length;
+        uint8_t address_data[sizeof(struct sockaddr_in6)];
+        struct sockaddr *address;
+        struct sockaddr_in *address_in;
+        struct sockaddr_in6 *address_in6;
         socklen_t addrlen;
+//      char address_string[INET6_ADDRSTRLEN];
+        uint8_t * address_start;
+        int * socket_ids;
+        char * data;
+        int value;
+        uint8_t *address_start;
+        int *socket_ids;
+        char *data;
         int index;
         struct timeval time_before;
         struct timeval time_after;
+        // parse the command line arguments
+        // stop before the last argument if it does not start with the minus sign ('-')
+        for(index = 1; (index < argc - 1) || ((index == argc - 1) && (argv[index][0] == '-')); ++ index){
+                // options should start with the minus sign ('-')
+                if(argv[index][0] == '-'){
+                        switch(argv[index][1]){
+                                // short options with only one letter
+                                case 'f':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 0, socket_parse_protocol_family));
+                                        break;
+                                case 'h':
+                                        nettest2_print_help();
+                                        return EOK;
+                                        break;
+                                case 'm':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &messages, 0));
+                                        break;
+                                case 'n':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &sockets, 0));
+                                        break;
+                                case 'p':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                        port = (uint16_t) value;
+                                        break;
+                                case 's':
+                                        ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 0));
+                                        size = (value >= 0) ? (size_t) value : 0;
+                                        break;
+                                case 't':
+                                        ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 0, socket_parse_socket_type));
+                                        type = (sock_type_t) value;
+                                        break;
+                                case 'v':
+                                        verbose = 1;
+                                        break;
+                                // long options with the double minus sign ('-')
+                                case '-':
+                                        if(str_lcmp(argv[index] + 2, "family=", 7) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &family, 9, socket_parse_protocol_family));
+                                        }else if(str_lcmp(argv[index] + 2, "help", 5) == 0){
+                                                nettest2_print_help();
+                                                return EOK;
+                                        }else if(str_lcmp(argv[index] + 2, "messages=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &messages, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "sockets=", 6) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &sockets, 8));
+                                        }else if(str_lcmp(argv[index] + 2, "port=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_int(argc, argv, &index, &value, 7));
+                                                port = (uint16_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "type=", 5) == 0){
+                                                ERROR_PROPAGATE(arg_parse_name_int(argc, argv, &index, &value, 7, socket_parse_socket_type));
+                                                type = (sock_type_t) value;
+                                        }else if(str_lcmp(argv[index] + 2, "verbose", 8) == 0){
+                                                verbose = 1;
+                                        }else{
+                                                nettest2_print_help();
+                                                return EINVAL;
+                                        }
+                                        break;
+                                default:
+                                        nettest2_print_help();
+                                        return EINVAL;
+                        }
+                }else{
+        int rc;
+        size = 28;
+        verbose = false;
+        type = SOCK_DGRAM;
+        sockets = 10;
+        messages = 10;
+        family = PF_INET;
+        port = 7;
+        max_length = sizeof(address_data);
+        address = (struct sockaddr *) address_data;
+        address_in = (struct sockaddr_in *) address;
+        address_in6 = (struct sockaddr_in6 *) address;
+        /*
+         * Parse the command line arguments.
+         *
+         * Stop before the last argument if it does not start with dash ('-')
+         */
+        for (index = 1; (index < argc - 1) || ((index == argc - 1) &&
+            (argv[index][0] == '-')); ++index) {
+                /* Options should start with dash ('-') */
+                if (argv[index][0] == '-') {
+                        rc = nettest2_parse_opt(argc, argv, &index);
+                        if (rc != EOK)
+                                return rc;
+                } else {
                         nettest2_print_help();
                         return EINVAL;
 …
+        }
         // if not before the last argument containing the address
         if(index >= argc){
+        /* If not before the last argument containing the address */
+        if (index >= argc) {
                 printf("Command line error: missing address\n");
                 nettest2_print_help();
 …
+        }
         // prepare the address buffer
+        /* Prepare the address buffer */
         bzero(address_data, max_length);
+        switch(family){
+                case PF_INET:
+                        address_in->sin_family = AF_INET;
+                        address_in->sin_port = htons(port);
+                        address_start = (uint8_t *) &address_in->sin_addr.s_addr;
+                        addrlen = sizeof(struct sockaddr_in);
+                        break;
+                case PF_INET6:
+                        address_in6->sin6_family = AF_INET6;
+                        address_in6->sin6_port = htons(port);
+                        address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
+                        addrlen = sizeof(struct sockaddr_in6);
+                        break;
+                default:
+                        fprintf(stderr, "Address family is not supported\n");
+                        return EAFNOSUPPORT;
+        }
+        // parse the last argument which should contain the address
+        if(ERROR_OCCURRED(inet_pton(family, argv[argc - 1], address_start))){
+                fprintf(stderr, "Address parse error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        // check the buffer size
+        if(size <= 0){
+                fprintf(stderr, "Data buffer size too small (%d). Using 1024 bytes instead.\n", size);
+        switch (family) {
+        case PF_INET:
+                address_in->sin_family = AF_INET;
+                address_in->sin_port = htons(port);
+                address_start = (uint8_t *) &address_in->sin_addr.s_addr;
+                addrlen = sizeof(struct sockaddr_in);
+                break;
+        case PF_INET6:
+                address_in6->sin6_family = AF_INET6;
+                address_in6->sin6_port = htons(port);
+                address_start = (uint8_t *) &address_in6->sin6_addr.s6_addr;
+                addrlen = sizeof(struct sockaddr_in6);
+                break;
+        default:
+                fprintf(stderr, "Address family is not supported\n");
+                return EAFNOSUPPORT;
+        }
+        /* Parse the last argument which should contain the address. */
+        rc = inet_pton(family, argv[argc - 1], address_start);
+        if (rc != EOK) {
+                fprintf(stderr, "Address parse error %d\n", rc);
+                return rc;
+        }
+        /* Check data buffer size. */
+        if (size <= 0) {
+                fprintf(stderr, "Data buffer size too small (%d). Using 1024 "
+                    "bytes instead.\n", size);
                 size = 1024;
+        }
+        // prepare the buffer
+        // size plus terminating null (\0)
+        /*
+         * Prepare the buffer. Allocate size bytes plus one for terminating
+         * null character.
+         */
         data = (char *) malloc(size + 1);
         if(! data){
+        if (!data) {
                 fprintf(stderr, "Failed to allocate data buffer.\n");
                 return ENOMEM;
+        }
+        nettest2_refresh_data(data, size);
+        // check the socket count
+        if(sockets <= 0){
+                fprintf(stderr, "Socket count too small (%d). Using 2 instead.\n", sockets);
+        /* Fill buffer with a pattern. */
+        nettest2_fill_buffer(data, size);
+        /* Check socket count. */
+        if (sockets <= 0) {
+                fprintf(stderr, "Socket count too small (%d). Using "
+                    "2 instead.\n", sockets);
                 sockets = 2;
+        }
+        // prepare the socket buffer
+        // count plus the terminating null (\0)
+        /*
+         * Prepare the socket buffer.
+         * Allocate count entries plus the terminating null (\0)
+         */
         socket_ids = (int *) malloc(sizeof(int) * (sockets + 1));
         if(! socket_ids){
+        if (!socket_ids) {
                 fprintf(stderr, "Failed to allocate receive buffer.\n");
                 return ENOMEM;
 …
         socket_ids[sockets] = NULL;
         if(verbose){
+        if (verbose)
                 printf("Starting tests\n");
+        }
+        ERROR_PROPAGATE(sockets_create(verbose, socket_ids, sockets, family, type));
+        if(type == SOCK_STREAM){
+                ERROR_PROPAGATE(sockets_connect(verbose, socket_ids, sockets, address, addrlen));
+        }
+        if(verbose){
+        rc = sockets_create(verbose, socket_ids, sockets, family, type);
+        if (rc != EOK)
+                return rc;
+        if (type == SOCK_STREAM) {
+                rc = sockets_connect(verbose, socket_ids, sockets,
+                    address, addrlen);
+                if (rc != EOK)
+                        return rc;
+        }
+        if (verbose)
                 printf("\n");
+        }
+        if(ERROR_OCCURRED(gettimeofday(&time_before, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        ERROR_PROPAGATE(sockets_sendto_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, messages));
+        if(ERROR_OCCURRED(gettimeofday(&time_after, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        if(verbose){
+        rc = gettimeofday(&time_before, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        rc = sockets_sendto_recvfrom(verbose, socket_ids, sockets, address,
+            &addrlen, data, size, messages);
+        if (rc != EOK)
+                return rc;
+        rc = gettimeofday(&time_after, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        if (verbose)
                 printf("\tOK\n");
+        }
+        printf("sendto + recvfrom tested in %d microseconds\n", tv_sub(&time_after, &time_before));
+        if(ERROR_OCCURRED(gettimeofday(&time_before, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        ERROR_PROPAGATE(sockets_sendto(verbose, socket_ids, sockets, address, addrlen, data, size, messages));
+        ERROR_PROPAGATE(sockets_recvfrom(verbose, socket_ids, sockets, address, &addrlen, data, size, messages));
+        if(ERROR_OCCURRED(gettimeofday(&time_after, NULL))){
+                fprintf(stderr, "Get time of day error %d\n", ERROR_CODE);
+                return ERROR_CODE;
+        }
+        if(verbose){
+        printf("sendto + recvfrom tested in %d microseconds\n",
+            tv_sub(&time_after, &time_before));
+        rc = gettimeofday(&time_before, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        rc = sockets_sendto(verbose, socket_ids, sockets, address, addrlen,
+            data, size, messages);
+        if (rc != EOK)
+                return rc;
+        rc = sockets_recvfrom(verbose, socket_ids, sockets, address, &addrlen,
+            data, size, messages);
+        if (rc != EOK)
+                return rc;
+        rc = gettimeofday(&time_after, NULL);
+        if (rc != EOK) {
+                fprintf(stderr, "Get time of day error %d\n", rc);
+                return rc;
+        }
+        if (verbose)
                 printf("\tOK\n");
+        }
+        printf("sendto, recvfrom tested in %d microseconds\n", tv_sub(&time_after, &time_before));
+        ERROR_PROPAGATE(sockets_close(verbose, socket_ids, sockets));
+        if(verbose){
+        printf("sendto, recvfrom tested in %d microseconds\n",
+            tv_sub(&time_after, &time_before));
+        rc = sockets_close(verbose, socket_ids, sockets);
+        if (rc != EOK)
+                return rc;
+        if (verbose)
                 printf("\nExiting\n");
+        }
         return EOK;
+}
-void nettest2_print_help(void){
-        printf(
-                "Network Networking test 2 aplication - UDP transfer\n" \
-                "Usage: echo [options] numeric_address\n" \
-                "Where options are:\n" \
-                "-f protocol_family | --family=protocol_family\n" \
-                "\tThe listenning socket protocol family. Only the PF_INET and PF_INET6 are supported.\n"
-                "\n" \
-                "-h | --help\n" \
-                "\tShow this application help.\n"
-                "\n" \
-                "-m count | --messages=count\n" \
-                "\tThe number of messages to send and receive per socket. The default is 10.\n" \
-                "\n" \
-                "-n sockets | --sockets=count\n" \
-                "\tThe number of sockets to use. The default is 10.\n" \
-                "\n" \
-                "-p port_number | --port=port_number\n" \
-                "\tThe port number the application should send messages to. The default is 7.\n" \
-                "\n" \
-                "-s packet_size | --size=packet_size\n" \
-                "\tThe packet data size the application sends. The default is 29 bytes.\n" \
-                "\n" \
-                "-v | --verbose\n" \
-                "\tShow all output messages.\n"
-        );
+}
-void nettest2_refresh_data(char * data, size_t size){
-        size_t length;
-        // fill the data
-        length = 0;
-        while(size > length + sizeof(NETTEST2_TEXT) - 1){
-                memcpy(data + length, NETTEST2_TEXT, sizeof(NETTEST2_TEXT) - 1);
-                length += sizeof(NETTEST2_TEXT) - 1;
+        }
-        memcpy(data + length, NETTEST2_TEXT, size - length);
-        data[size] = '\0';
+}
 /** @}
  */

uspace/app/redir/redir.c

-              rd70a463
+              rb40bfac
 #include <task.h>
 #include <str_error.h>
+#include <errno.h>
 #define NAME  "redir"
 …
 static task_id_t spawn(int argc, char *argv[])
+{
+        const char **args = (const char **) calloc(argc + 1, sizeof(char *));
+        const char **args;
+        task_id_t id;
+        int rc;
+        args = (const char **) calloc(argc + 1, sizeof(char *));
         if (!args) {
                 printf("No memory available\n");
 …
         args[argc] = NULL;
+        int err;
+        task_id_t id = task_spawn(argv[0], args, &err);
+        rc = task_spawnv(&id, argv[0], args);
         free(args);
         if (id == 0)
+        if (rc != EOK) {
                 printf("%s: Error spawning %s (%s)\n", NAME, argv[0],
+                    str_error(err));
+                    str_error(rc));
+        }
         return id;

uspace/app/sbi/src/os/helenos.c

-              rd70a463
+              rb40bfac
         task_id_t tid;
         task_exit_t texit;
         int retval;
         tid = task_spawn(cmd[0], (char const * const *) cmd, &retval);
         if (tid == 0) {
+        int rc, retval;
+        rc = task_spawnv(&tid, cmd[0], (char const * const *) cmd);
+        if (rc != EOK) {
                 printf("Error: Failed spawning '%s' (%s).\n", cmd[0],
                     str_error(retval));
+                    str_error(rc));
                 exit(1);
+        }
         /* XXX Handle exit status and return value. */
+        task_wait(tid, &texit, &retval);
+        rc = task_wait(tid, &texit, &retval);
+        (void) rc;
         return EOK;

Context Navigation

Changeset b40bfac in mainline for uspace/app

Legend:

uspace/app/bdsh/exec.c

uspace/app/getterm/getterm.c

uspace/app/init/init.c

uspace/app/netecho/netecho.c

uspace/app/netecho/print_error.c

uspace/app/netecho/print_error.h

uspace/app/netstart/Makefile

uspace/app/netstart/netstart.c

uspace/app/nettest1/nettest.c

uspace/app/nettest1/nettest.h

uspace/app/nettest1/nettest1.c

uspace/app/nettest2/nettest2.c

uspace/app/redir/redir.c

uspace/app/sbi/src/os/helenos.c

Download in other formats: