staging: usbip: userspace: usbip_network: rename and cleanup function
authormatt mooney <mfm@muteddisk.com>
Thu, 26 May 2011 13:17:13 +0000 (06:17 -0700)
committerGreg Kroah-Hartman <gregkh@suse.de>
Tue, 7 Jun 2011 20:56:13 +0000 (13:56 -0700)
Rename tcp_connection to usbip_net_tcp_connection, which alludes to a
usbip network library that will eventually follow. The implementation
of this function has also been cleaned up.

Headers had to be adjusted due to the elimination of the old usbip.h.

Signed-off-by: matt mooney <mfm@muteddisk.com>
Signed-off-by: Greg Kroah-Hartman <gregkh@suse.de>
drivers/staging/usbip/userspace/src/usbip_network.c
drivers/staging/usbip/userspace/src/usbip_network.h

index 01be3c7211d5c8a1091510ef36eb98fb2a299951..ef93b02833eaa8653f62763416f9cba5e87496a0 100644 (file)
@@ -3,6 +3,16 @@
  * Copyright (C) 2005-2007 Takahiro Hirofuchi
  */
 
+#include <sys/socket.h>
+#include <arpa/inet.h>
+
+#include <string.h>
+
+#include <netdb.h>
+#include <netinet/tcp.h>
+#include <unistd.h>
+
+#include "usbip_common.h"
 #include "usbip_network.h"
 
 void pack_uint32_t(int pack, uint32_t *num)
@@ -186,66 +196,49 @@ int usbip_set_keepalive(int sockfd)
        return ret;
 }
 
-/* IPv6 Ready */
 /*
- * moved here from vhci_attach.c
+ * IPv6 Ready
  */
-int tcp_connect(char *hostname, char *service)
+int usbip_net_tcp_connect(char *hostname, char *port)
 {
-       struct addrinfo hints, *res, *res0;
+       struct addrinfo hints, *res, *rp;
        int sockfd;
-       int err;
-
+       int ret;
 
        memset(&hints, 0, sizeof(hints));
+       hints.ai_family = AF_UNSPEC;
        hints.ai_socktype = SOCK_STREAM;
 
        /* get all possible addresses */
-       err = getaddrinfo(hostname, service, &hints, &res0);
-       if (err) {
-               err("%s %s: %s", hostname, service, gai_strerror(err));
-               return -1;
+       ret = getaddrinfo(hostname, port, &hints, &res);
+       if (ret < 0) {
+               dbg("getaddrinfo: %s port %s: %s", hostname, port,
+                   gai_strerror(ret));
+               return ret;
        }
 
-       /* try all the addresses */
-       for (res = res0; res; res = res->ai_next) {
-               char hbuf[NI_MAXHOST], sbuf[NI_MAXSERV];
-
-               err = getnameinfo(res->ai_addr, res->ai_addrlen,
-                               hbuf, sizeof(hbuf), sbuf, sizeof(sbuf), NI_NUMERICHOST | NI_NUMERICSERV);
-               if (err) {
-                       err("%s %s: %s", hostname, service, gai_strerror(err));
-                       continue;
-               }
-
-               dbg("trying %s port %s\n", hbuf, sbuf);
-
-               sockfd = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
-               if (sockfd < 0) {
-                       err("socket");
+       /* try the addresses */
+       for (rp = res; rp; rp = rp->ai_next) {
+               sockfd = socket(rp->ai_family, rp->ai_socktype,
+                               rp->ai_protocol);
+               if (sockfd < 0)
                        continue;
-               }
 
                /* should set TCP_NODELAY for usbip */
                usbip_set_nodelay(sockfd);
-               /* TODO: write code for heatbeat */
+               /* TODO: write code for heartbeat */
                usbip_set_keepalive(sockfd);
 
-               err = connect(sockfd, res->ai_addr, res->ai_addrlen);
-               if (err < 0) {
-                       close(sockfd);
-                       continue;
-               }
+               if (connect(sockfd, rp->ai_addr, rp->ai_addrlen) == 0)
+                       break;
 
-               /* connected */
-               dbg("connected to %s:%s", hbuf, sbuf);
-               freeaddrinfo(res0);
-               return sockfd;
+               close(sockfd);
        }
 
+       if (!rp)
+               return EAI_SYSTEM;
 
-       dbg("%s:%s, %s", hostname, service, "no destination to connect to");
-       freeaddrinfo(res0);
+       freeaddrinfo(res);
 
-       return -1;
+       return sockfd;
 }
index 1225466e1c592f1bed7421ba57ad3a8de30425a4..82b08118e0b2c1f6a387533030e852f1783508f0 100644 (file)
@@ -2,19 +2,20 @@
  * Copyright (C) 2005-2007 Takahiro Hirofuchi
  */
 
-#ifndef _USBIP_NETWORK_H
-#define _USBIP_NETWORK_H
+#ifndef __USBIP_NETWORK_H
+#define __USBIP_NETWORK_H
 
-#include "usbip.h"
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <netinet/tcp.h>
+#ifdef HAVE_CONFIG_H
+#include "../config.h"
+#endif
 
+#include <sys/types.h>
+#include <sysfs/libsysfs.h>
 
-/* -------------------------------------------------- */
-/* Define Protocol Format                             */
-/* -------------------------------------------------- */
+#include <stdint.h>
 
+#define USBIP_PORT 3240
+#define USBIP_PORT_STRING "3240"
 
 /* ---------------------------------------------------------------------- */
 /* Common header for all the kinds of PDUs. */
@@ -38,7 +39,6 @@ struct op_common {
        pack_uint32_t(pack, &(op_common)->status );\
 } while (0)
 
-
 /* ---------------------------------------------------------------------- */
 /* Dummy Code */
 #define OP_UNSPEC      0x00
@@ -60,7 +60,6 @@ struct op_devinfo_reply {
        struct usb_interface uinf[];
 } __attribute__((packed));
 
-
 /* ---------------------------------------------------------------------- */
 /* Import a remote USB device. */
 #define OP_IMPORT      0x03
@@ -83,8 +82,6 @@ struct op_import_reply {
        pack_usb_device(pack, &(reply)->udev);\
 } while (0)
 
-
-
 /* ---------------------------------------------------------------------- */
 /* Export a USB device to a remote host. */
 #define OP_EXPORT      0x06
@@ -128,8 +125,6 @@ struct op_unexport_reply {
 #define PACK_OP_UNEXPORT_REPLY(pack, reply)  do {\
 } while (0)
 
-
-
 /* ---------------------------------------------------------------------- */
 /* Negotiate IPSec encryption key. (still not used) */
 #define OP_CRYPKEY     0x04
@@ -172,11 +167,6 @@ struct op_devlist_reply_extra {
        pack_uint32_t(pack, &(reply)->ndev);\
 } while (0)
 
-
-/* -------------------------------------------------- */
-/* Declare Prototype Function                         */
-/* -------------------------------------------------- */
-
 void pack_uint32_t(int pack, uint32_t *num);
 void pack_uint16_t(int pack, uint16_t *num);
 void pack_usb_device(int pack, struct usb_device *udev);
@@ -190,9 +180,6 @@ int usbip_set_reuseaddr(int sockfd);
 int usbip_set_nodelay(int sockfd);
 int usbip_set_keepalive(int sockfd);
 
-int tcp_connect(char *hostname, char *service);
+int usbip_net_tcp_connect(char *hostname, char *port);
 
-#define USBIP_PORT 3240
-#define USBIP_PORT_STRING "3240"
-
-#endif
+#endif /* __USBIP_NETWORK_H */