vitalif
/
qperf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

More cleanup.

master
Johann George (QLogic) 2007-11-04 00:31:17 -07:00
parent c1e2830a86
commit ca68791bc0
2 changed files with 36 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/README Normal file
View File

@ -0,0 +1,8 @@
To build
./autogen.sh
./configure
make
Notes
* If the library ibverbs is not found, a version of qperf is built that
does not support the RDMA tests.

33
src/socket.c
View File

@ -33,6 +33,7 @@
* SOFTWARE.
*/
#define _GNU_SOURCE
#include <errno.h>
#include <netdb.h>
#include <stdlib.h>
#include <string.h>
@ -44,12 +45,13 @@
* Parameters.
*/
#define AF_INET_SDP 27 /* Family for SDP */
#define AF_INET_RDS 30 /* Family for RDS */
#define AF_INET_RDS 28 /* Family for RDS */
/*
* Function prototypes.
*/
static char *bind_error(int domain);
static void datagram_client_bw(int domain);
static void datagram_client_init(int *fd, int domain,
struct sockaddr_in *addr);
@ -700,20 +702,23 @@ err:
static void
datagram_client_init(int *fd, int domain, struct sockaddr_in *serverAddr)
{
int type;
uint32_t port;
struct hostent *host;
struct sockaddr_in clientAddr;
socklen_t clientLen = sizeof(clientAddr);
client_send_request();
*fd = socket(domain, SOCK_DGRAM, 0);
type = (domain == AF_INET_RDS) ? SOCK_SEQPACKET : SOCK_DGRAM;
*fd = socket(domain, type, 0);
if (*fd < 0)
syserror_die("socket failed");
clientAddr.sin_family = AF_INET;
clientAddr.sin_addr.s_addr = htonl(INADDR_ANY);
clientAddr.sin_port = htons(0);
if (bind(*fd, (struct sockaddr *)&clientAddr, clientLen) < 0)
syserror_die("bind failed");
/* syserror_die("bind failed"); */
syserror_die(bind_error(domain));
if (getsockname(*fd, (struct sockaddr *)&clientAddr, &clientLen) < 0)
syserror_die("getsockname failed");
if (!set_socket_buffer_size(*fd))
@ -741,11 +746,13 @@ datagram_client_init(int *fd, int domain, struct sockaddr_in *serverAddr)
static int
datagram_server_init(int *fd, int domain)
{
int type;
uint32_t port;
struct sockaddr_in addr;
socklen_t len = sizeof(addr);
*fd = socket(domain, SOCK_DGRAM, 0);
type = (domain == AF_INET_RDS) ? SOCK_SEQPACKET : SOCK_DGRAM;
*fd = socket(domain, type, 0);
if (*fd < 0)
return syserror("socket failed");
memset(&addr, 0, len);
@ -753,7 +760,8 @@ datagram_server_init(int *fd, int domain)
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(Req.port);
if (bind(*fd, (struct sockaddr *)&addr, len) < 0) {
syserror("bind failed");
/* syserror("bind failed"); */
syserror(bind_error(domain));
goto err;
}
if (getsockname(*fd, (struct sockaddr *)&addr, &len) < 0) {
@ -773,6 +781,21 @@ err:
}
/*
* Return a bind error message. Once RDS supports INADDR_ANY, this can go
* away. I would fix the code to not use INADDR_ANY except that the RDS code
* still appears to be flaky.
*/
static char *
bind_error(int domain)
{
if (domain == AF_INET_RDS && errno == EINVAL)
return "INADDR_ANY not implemented in this version of RDS";
else
return "bind error";
}
/*
* Send a complete message to a socket. A zero byte write indicates an end of
* file which suggests that we are finished.