return index;
}
-int bind_to_cpu(int index)
+static int bind_to_cpu(int index)
{
cpu_set_t cpu_mask;
pid_t pid;
return 0;
}
-int accept_loop(int listen_sk)
+static int accept_loop(int listen_sk)
{
- unsigned long received;
struct sockaddr addr;
unsigned int len = sizeof(addr);
int sk;
return error("accept");
/* read forever */
- received = 0;
for (;;) {
int ret = recv(sk, NULL, 128*1024*1024, MSG_TRUNC);
- if (ret > 0) {
- received += ret;
+ if (ret > 0)
continue;
- }
- if (!ret)
+ else if (!ret)
break;
if (errno == EAGAIN || errno == EINTR)
continue;
goto again;
}
-int server(int offset)
+static int server(int offset)
{
- struct sockaddr addr;
struct sockaddr_in saddr_in;
+ struct sockaddr addr;
unsigned int len;
int sk;
return mtime_since(s, &t);
}
-int client_rw(int out_fd, int file_fd, int offset)
+static int client_rw(int out_fd, int file_fd, int offset)
{
int loops = client_loops;
struct timeval start;
if ((mtime_since_now(&start) < max_client_run * 1000) && loops)
goto again;
+ free(buf);
size = sb.st_size >> 10;
size *= (client_loops - loops);
msecs = mtime_since_now(&start);
return 0;
}
-int client_mmap(int out_fd, int file_fd, int offset)
+static int client_mmap(int out_fd, int file_fd, int offset)
{
int loops = client_loops;
struct timeval start;
}
-int client_splice_loop(int out_fd, int fd, int *pfd, int offset)
+static int client_splice_loop(int out_fd, int fd, int *pfd, int offset)
{
struct timeval start;
unsigned long long size;
return 0;
}
-int client_splice(int out_fd, int file_fd, int offset)
+static int client_splice(int out_fd, int file_fd, int offset)
{
int pfd[2], ret;
return ret;
}
-int do_client(int out_fd, int file_fd, int offset)
+static int do_client(int out_fd, int file_fd, int offset)
{
int ret;
return sk;
}
-int client(int offset)
+static int client(int offset)
{
int file_fd, out_fd;
char fname[64];