Commit 1e35d87d authored by matt mooney's avatar matt mooney Committed by Greg Kroah-Hartman

staging: usbip: userspace: usbip_network: rename and cleanup function

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: default avatarmatt mooney <mfm@muteddisk.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@suse.de>
parent d2c15e25
...@@ -3,6 +3,16 @@ ...@@ -3,6 +3,16 @@
* Copyright (C) 2005-2007 Takahiro Hirofuchi * 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" #include "usbip_network.h"
void pack_uint32_t(int pack, uint32_t *num) void pack_uint32_t(int pack, uint32_t *num)
...@@ -186,66 +196,49 @@ int usbip_set_keepalive(int sockfd) ...@@ -186,66 +196,49 @@ int usbip_set_keepalive(int sockfd)
return ret; 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 sockfd;
int err; int ret;
memset(&hints, 0, sizeof(hints)); memset(&hints, 0, sizeof(hints));
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM; hints.ai_socktype = SOCK_STREAM;
/* get all possible addresses */ /* get all possible addresses */
err = getaddrinfo(hostname, service, &hints, &res0); ret = getaddrinfo(hostname, port, &hints, &res);
if (err) { if (ret < 0) {
err("%s %s: %s", hostname, service, gai_strerror(err)); dbg("getaddrinfo: %s port %s: %s", hostname, port,
return -1; 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); /* try the addresses */
for (rp = res; rp; rp = rp->ai_next) {
sockfd = socket(res->ai_family, res->ai_socktype, res->ai_protocol); sockfd = socket(rp->ai_family, rp->ai_socktype,
if (sockfd < 0) { rp->ai_protocol);
err("socket"); if (sockfd < 0)
continue; continue;
}
/* should set TCP_NODELAY for usbip */ /* should set TCP_NODELAY for usbip */
usbip_set_nodelay(sockfd); usbip_set_nodelay(sockfd);
/* TODO: write code for heatbeat */ /* TODO: write code for heartbeat */
usbip_set_keepalive(sockfd); usbip_set_keepalive(sockfd);
err = connect(sockfd, res->ai_addr, res->ai_addrlen); if (connect(sockfd, rp->ai_addr, rp->ai_addrlen) == 0)
if (err < 0) { break;
close(sockfd);
continue;
}
/* connected */ close(sockfd);
dbg("connected to %s:%s", hbuf, sbuf);
freeaddrinfo(res0);
return sockfd;
} }
if (!rp)
return EAI_SYSTEM;
dbg("%s:%s, %s", hostname, service, "no destination to connect to"); freeaddrinfo(res);
freeaddrinfo(res0);
return -1; return sockfd;
} }
...@@ -2,19 +2,20 @@ ...@@ -2,19 +2,20 @@
* Copyright (C) 2005-2007 Takahiro Hirofuchi * Copyright (C) 2005-2007 Takahiro Hirofuchi
*/ */
#ifndef _USBIP_NETWORK_H #ifndef __USBIP_NETWORK_H
#define _USBIP_NETWORK_H #define __USBIP_NETWORK_H
#include "usbip.h" #ifdef HAVE_CONFIG_H
#include <sys/types.h> #include "../config.h"
#include <sys/socket.h> #endif
#include <netinet/tcp.h>
#include <sys/types.h>
#include <sysfs/libsysfs.h>
/* -------------------------------------------------- */ #include <stdint.h>
/* Define Protocol Format */
/* -------------------------------------------------- */
#define USBIP_PORT 3240
#define USBIP_PORT_STRING "3240"
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* Common header for all the kinds of PDUs. */ /* Common header for all the kinds of PDUs. */
...@@ -38,7 +39,6 @@ struct op_common { ...@@ -38,7 +39,6 @@ struct op_common {
pack_uint32_t(pack, &(op_common)->status );\ pack_uint32_t(pack, &(op_common)->status );\
} while (0) } while (0)
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* Dummy Code */ /* Dummy Code */
#define OP_UNSPEC 0x00 #define OP_UNSPEC 0x00
...@@ -60,7 +60,6 @@ struct op_devinfo_reply { ...@@ -60,7 +60,6 @@ struct op_devinfo_reply {
struct usb_interface uinf[]; struct usb_interface uinf[];
} __attribute__((packed)); } __attribute__((packed));
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* Import a remote USB device. */ /* Import a remote USB device. */
#define OP_IMPORT 0x03 #define OP_IMPORT 0x03
...@@ -83,8 +82,6 @@ struct op_import_reply { ...@@ -83,8 +82,6 @@ struct op_import_reply {
pack_usb_device(pack, &(reply)->udev);\ pack_usb_device(pack, &(reply)->udev);\
} while (0) } while (0)
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* Export a USB device to a remote host. */ /* Export a USB device to a remote host. */
#define OP_EXPORT 0x06 #define OP_EXPORT 0x06
...@@ -128,8 +125,6 @@ struct op_unexport_reply { ...@@ -128,8 +125,6 @@ struct op_unexport_reply {
#define PACK_OP_UNEXPORT_REPLY(pack, reply) do {\ #define PACK_OP_UNEXPORT_REPLY(pack, reply) do {\
} while (0) } while (0)
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* Negotiate IPSec encryption key. (still not used) */ /* Negotiate IPSec encryption key. (still not used) */
#define OP_CRYPKEY 0x04 #define OP_CRYPKEY 0x04
...@@ -172,11 +167,6 @@ struct op_devlist_reply_extra { ...@@ -172,11 +167,6 @@ struct op_devlist_reply_extra {
pack_uint32_t(pack, &(reply)->ndev);\ pack_uint32_t(pack, &(reply)->ndev);\
} while (0) } while (0)
/* -------------------------------------------------- */
/* Declare Prototype Function */
/* -------------------------------------------------- */
void pack_uint32_t(int pack, uint32_t *num); void pack_uint32_t(int pack, uint32_t *num);
void pack_uint16_t(int pack, uint16_t *num); void pack_uint16_t(int pack, uint16_t *num);
void pack_usb_device(int pack, struct usb_device *udev); void pack_usb_device(int pack, struct usb_device *udev);
...@@ -190,9 +180,6 @@ int usbip_set_reuseaddr(int sockfd); ...@@ -190,9 +180,6 @@ int usbip_set_reuseaddr(int sockfd);
int usbip_set_nodelay(int sockfd); int usbip_set_nodelay(int sockfd);
int usbip_set_keepalive(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 #endif /* __USBIP_NETWORK_H */
#define USBIP_PORT_STRING "3240"
#endif
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment