Changes in uspace/app/nettest1/nettest.c [c442f63:9d58539] in mainline

File:

• uspace/app/nettest1/nettest.c (modified) (8 diffs)

uspace/app/nettest1/nettest.c

@@ -41 +41 @@
 #include "print_error.h"
 
+
 /** Creates new sockets.
  *
@@ -51 +52 @@
  * @return Other error codes as defined for the socket() function.
  */
-int sockets_create(int verbose, int *socket_ids, unsigned int sockets,
-    uint16_t family, sock_type_t type)
-{
+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 (unsigned int 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) {
-                        printf("Socket %u (%d) error:\n", index, socket_ids[index]);
+                        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);
@@ -82 +83 @@
  * @return Other error codes as defined for the closesocket() function.
  */
-int sockets_close(int verbose, int *socket_ids, unsigned int sockets)
-{
+int sockets_close(int verbose, int *socket_ids, int sockets)
+{
+        int index;
+        int rc;
+
         if (verbose)
                 printf("\tClose\t");
-        
-        fflush(stdout);
-        
-        for (unsigned int index = 0; index < sockets; index++) {
-                int rc = closesocket(socket_ids[index]);
+
+        fflush(stdout);
+        
+        for (index = 0; index < sockets; index++) {
+                rc = closesocket(socket_ids[index]);
                 if (rc != EOK) {
-                        printf("Socket %u (%d) error:\n", index, socket_ids[index]);
+                        printf("Socket %d (%d) error:\n", index, socket_ids[index]);
                         socket_print_error(stderr, rc, "Socket close: ", "\n");
                         return rc;
                 }
-                
                 if (verbose)
                         print_mark(index);
@@ -114 +117 @@
  * @return Other error codes as defined for the connect() function.
  */
-int sockets_connect(int verbose, int *socket_ids, unsigned int sockets,
-    struct sockaddr *address, socklen_t addrlen)
-{
+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");
@@ -122 +127 @@
         fflush(stdout);
         
-        for (unsigned int index = 0; index < sockets; index++) {
-                int rc = connect(socket_ids[index], address, addrlen);
+        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;
-}
-
-/** Send data via sockets.
- *
- * @param[in] verbose    Print out verbose information.
- * @param[in] socket_ids Stored socket identifiers.
- * @param[in] sockets    Number of sockets.
- * @param[in] address    Destination host address to send data to.
- * @param[in] addrlen    Length of the destination address in bytes.
- * @param[in] data       Data to be sent.
- * @param[in] size       Size of the data in bytes.
- * @param[in] messages   Number of datagrams per socket to be sent.
- * @param[in] type       Socket type.
- *
+                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.
  * @return EOK on success.
  * @return Other error codes as defined for the sendto() function.
- *
- */
-int sockets_sendto(int verbose, int *socket_ids, unsigned int sockets,
-    struct sockaddr *address, socklen_t addrlen, char *data, size_t size,
-    unsigned int messages, sock_type_t type)
-{
+ */
+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;
+        int rc;
+
         if (verbose)
                 printf("\tSendto\t");
-        
-        fflush(stdout);
-        
-        for (unsigned int index = 0; index < sockets; index++) {
-                for (unsigned int message = 0; message < messages; message++) {
-                        int rc;
-                        
-                        switch (type) {
-                        case SOCK_STREAM:
-                                rc = send(socket_ids[index], data, size, 0);
-                                break;
-                        case SOCK_DGRAM:
-                                rc = sendto(socket_ids[index], data, size, 0, address, addrlen);
-                                break;
-                        default:
-                                rc = EINVAL;
-                        }
-                        
+
+        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 %u (%d), message %u error:\n",
-                                    index, socket_ids[index], message);
+                                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;
-}
-
-/** Receive data via sockets.
- *
- * @param[in]     verbose    Print out verbose information.
- * @param[in]     socket_ids Stored socket identifiers.
- * @param[in]     sockets    Number of sockets.
- * @param[in]     address    Source host address of received datagrams.
- * @param[in,out] addrlen    Maximum length of the source address in bytes.
- *                           The actual size of the source address is set.
- * @param[out]    data       Received data.
- * @param[in]     size       Maximum data size in bytes.
- * @param[in]     messages   Number of datagrams per socket to be received.
- *
+                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.
  * @return EOK on success.
  * @return Other error codes as defined for the recvfrom() function.
- *
- */
-int sockets_recvfrom(int verbose, int *socket_ids, unsigned int sockets,
-    struct sockaddr *address, socklen_t *addrlen, char *data, size_t size,
-    unsigned int messages)
-{
+ */
+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)
                 printf("\tRecvfrom\t");
@@ -216 +204 @@
         fflush(stdout);
         
-        for (unsigned int index = 0; index < sockets; index++) {
-                for (unsigned int message = 0; message < messages; message++) {
-                        int rc = recvfrom(socket_ids[index], data, size, 0, address, addrlen);
-                        if (rc < 0) {
-                                printf("Socket %u (%d), message %u error:\n",
-                                    index, socket_ids[index], message);
-                                socket_print_error(stderr, rc, "Socket receive: ", "\n");
-                                return rc;
-                        }
-                }
-                
-                if (verbose)
-                        print_mark(index);
-        }
-        
-        return EOK;
-}
-
-/** Send and receive data via sockets.
+        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) {
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, value, "Socket receive: ", "\n");
+                                return value;
+                        }
+                }
+                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    Print out verbose information.
- * @param[in]     socket_ids Stored socket identifiers.
- * @param[in]     sockets    Number of sockets.
- * @param[in,out] address    Destination host address to send data to.
- *                           The source host address of received datagrams is set.
- * @param[in]     addrlen    Length of the destination address in bytes.
- * @param[in,out] data       Data to be sent. The received data are set.
- * @param[in]     size       Size of the data in bytes.
- * @param[in]     messages   Number of datagrams per socket to be received.
- * @param[in]     type       Socket type.
- *
+ * @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.
  * @return EOK on success.
  * @return Other error codes as defined for the recvfrom() function.
- *
- */
-int sockets_sendto_recvfrom(int verbose, int *socket_ids, unsigned int sockets,
-    struct sockaddr *address, socklen_t *addrlen, char *data,
-    size_t size, unsigned int messages, sock_type_t type)
-{
+ */
+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;
+        int rc;
+
         if (verbose)
                 printf("\tSendto and recvfrom\t");
-        
-        fflush(stdout);
-        
-        for (unsigned int index = 0; index < sockets; index++) {
-                for (unsigned int message = 0; message < messages; message++) {
-                        int rc;
-                        
-                        switch (type) {
-                        case SOCK_STREAM:
-                                rc = send(socket_ids[index], data, size, 0);
-                                break;
-                        case SOCK_DGRAM:
-                                rc = sendto(socket_ids[index], data, size, 0, address, *addrlen);
-                                break;
-                        default:
-                                rc = EINVAL;
-                        }
-                        
+
+        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 %u (%d), message %u error:\n",
-                                    index, socket_ids[index], message);
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
                                 socket_print_error(stderr, rc, "Socket send: ", "\n");
                                 return rc;
                         }
-                        
-                        rc = recvfrom(socket_ids[index], data, size, 0, address, addrlen);
-                        if (rc < 0) {
-                                printf("Socket %u (%d), message %u error:\n",
-                                    index, socket_ids[index], message);
-                                socket_print_error(stderr, rc, "Socket receive: ", "\n");
-                                return rc;
-                        }
-                }
-                
+                        value = recvfrom(socket_ids[index], data, size, 0, address, addrlen);
+                        if (value < 0) {
+                                printf("Socket %d (%d), message %d error:\n", index, socket_ids[index], message);
+                                socket_print_error(stderr, value, "Socket receive: ", "\n");
+                                return value;
+                        }
+                }
                 if (verbose)
                         print_mark(index);
@@ -306 +274 @@
  *
  * @param[in] index The index of the mark to be printed.
- *
- */
-void print_mark(unsigned int index)
+ */
+void print_mark(int index)
 {
         if ((index + 1) % 10)
@@ -314 +281 @@
         else
                 printf("|");
-        
         fflush(stdout);
 }