struct fio_client {
struct flist_head list;
- struct flist_head fd_hash_list;
- struct flist_head name_hash_list;
+ struct flist_head hash_list;
struct sockaddr_in addr;
struct sockaddr_un addr_un;
char *hostname;
+ int port;
int fd;
+ char *name;
+
int state;
int skip_newline;
int is_sock;
#define FIO_CLIENT_HASH_BITS 7
#define FIO_CLIENT_HASH_SZ (1 << FIO_CLIENT_HASH_BITS)
#define FIO_CLIENT_HASH_MASK (FIO_CLIENT_HASH_SZ - 1)
-static struct flist_head client_fd_hash[FIO_CLIENT_HASH_SZ];
-static struct flist_head client_name_hash[FIO_CLIENT_HASH_SZ];
+static struct flist_head client_hash[FIO_CLIENT_HASH_SZ];
static int handle_client(struct fio_client *client);
-static void fio_client_add_fd_hash(struct fio_client *client)
+static void fio_client_add_hash(struct fio_client *client)
{
int bucket = hash_long(client->fd, FIO_CLIENT_HASH_BITS);
bucket &= FIO_CLIENT_HASH_MASK;
- flist_add(&client->fd_hash_list, &client_fd_hash[bucket]);
+ flist_add(&client->hash_list, &client_hash[bucket]);
}
-static void fio_client_remove_fd_hash(struct fio_client *client)
+static void fio_client_remove_hash(struct fio_client *client)
{
- if (!flist_empty(&client->fd_hash_list))
- flist_del_init(&client->fd_hash_list);
-}
-
-static void fio_client_add_name_hash(struct fio_client *client)
-{
- int bucket = jhash(client->hostname, strlen(client->hostname), 0);
-
- bucket &= FIO_CLIENT_HASH_MASK;
- flist_add(&client->name_hash_list, &client_name_hash[bucket]);
-}
-
-static void fio_client_remove_name_hash(struct fio_client *client)
-{
- if (!flist_empty(&client->name_hash_list))
- flist_del_init(&client->name_hash_list);
+ if (!flist_empty(&client->hash_list))
+ flist_del_init(&client->hash_list);
}
static void fio_init fio_client_hash_init(void)
{
int i;
- for (i = 0; i < FIO_CLIENT_HASH_SZ; i++) {
- INIT_FLIST_HEAD(&client_fd_hash[i]);
- INIT_FLIST_HEAD(&client_name_hash[i]);
- }
+ for (i = 0; i < FIO_CLIENT_HASH_SZ; i++)
+ INIT_FLIST_HEAD(&client_hash[i]);
}
static struct fio_client *find_client_by_fd(int fd)
struct fio_client *client;
struct flist_head *entry;
- flist_for_each(entry, &client_fd_hash[bucket]) {
- client = flist_entry(entry, struct fio_client, fd_hash_list);
+ flist_for_each(entry, &client_hash[bucket]) {
+ client = flist_entry(entry, struct fio_client, hash_list);
if (client->fd == fd)
return client;
return NULL;
}
-static struct fio_client *find_client_by_name(const char *name)
-{
- int bucket = jhash(name, strlen(name), 0) & FIO_CLIENT_HASH_BITS;
- struct fio_client *client;
- struct flist_head *entry;
-
- flist_for_each(entry, &client_name_hash[bucket]) {
- client = flist_entry(entry, struct fio_client, name_hash_list);
-
- if (!strcmp(name, client->hostname))
- return client;
- }
-
- return NULL;
-}
-
static void remove_client(struct fio_client *client)
{
dprint(FD_NET, "client: removed <%s>\n", client->hostname);
flist_del(&client->list);
- fio_client_remove_fd_hash(client);
- fio_client_remove_name_hash(client);
+ fio_client_remove_hash(client);
free(client->hostname);
if (client->argv)
free(client->argv);
+ if (client->name)
+ free(client->name);
free(client);
nr_clients--;
}
-static int __fio_client_add_cmd_option(struct fio_client *client,
- const char *opt)
+static void __fio_client_add_cmd_option(struct fio_client *client,
+ const char *opt)
{
int index;
- if (client->argc == FIO_NET_CMD_JOBLINE_ARGV) {
- log_err("fio: max cmd line number reached.\n");
- log_err("fio: cmd line <%s> has been ignored.\n", opt);
- return 1;
- }
-
index = client->argc++;
client->argv = realloc(client->argv, sizeof(char *) * client->argc);
client->argv[index] = strdup(opt);
dprint(FD_NET, "client: add cmd %d: %s\n", index, opt);
- return 0;
}
-int fio_client_add_cmd_option(const char *hostname, const char *opt)
+void fio_client_add_cmd_option(void *cookie, const char *opt)
{
- struct fio_client *client;
+ struct fio_client *client = cookie;
- if (!hostname || !opt)
- return 0;
-
- client = find_client_by_name(hostname);
- if (!client) {
- log_err("fio: unknown client %s\n", hostname);
- return 1;
- }
+ if (!client || !opt)
+ return;
- return __fio_client_add_cmd_option(client, opt);
+ __fio_client_add_cmd_option(client, opt);
}
-void fio_client_add(const char *hostname)
+int fio_client_add(const char *hostname, void **cookie)
{
struct fio_client *client;
- dprint(FD_NET, "client: added <%s>\n", hostname);
client = malloc(sizeof(*client));
memset(client, 0, sizeof(*client));
INIT_FLIST_HEAD(&client->list);
- INIT_FLIST_HEAD(&client->fd_hash_list);
- INIT_FLIST_HEAD(&client->name_hash_list);
+ INIT_FLIST_HEAD(&client->hash_list);
- if (!strncmp(hostname, "sock:", 5)) {
- client->hostname = strdup(hostname + 5);
- client->is_sock = 1;
- } else
- client->hostname = strdup(hostname);
+ if (fio_server_parse_string(hostname, &client->hostname,
+ &client->is_sock, &client->port,
+ &client->addr.sin_addr))
+ return -1;
client->fd = -1;
- fio_client_add_name_hash(client);
-
__fio_client_add_cmd_option(client, "fio");
flist_add(&client->list, &client_list);
nr_clients++;
+ dprint(FD_NET, "client: added <%s>\n", client->hostname);
+ *cookie = client;
+ return 0;
}
static int fio_client_connect_ip(struct fio_client *client)
int fd;
client->addr.sin_family = AF_INET;
- client->addr.sin_port = htons(fio_net_port);
-
- if (inet_aton(client->hostname, &client->addr.sin_addr) != 1) {
- struct hostent *hent;
-
- hent = gethostbyname(client->hostname);
- if (!hent) {
- log_err("fio: gethostbyname: %s\n", strerror(errno));
- log_err("fio: failed looking up hostname %s\n",
- client->hostname);
- return -1;
- }
-
- memcpy(&client->addr.sin_addr, hent->h_addr, 4);
- }
+ client->addr.sin_port = htons(client->port);
fd = socket(AF_INET, SOCK_STREAM, 0);
if (fd < 0) {
if (connect(fd, (struct sockaddr *) &client->addr, sizeof(client->addr)) < 0) {
log_err("fio: connect: %s\n", strerror(errno));
- log_err("fio: failed to connect to %s\n", client->hostname);
+ log_err("fio: failed to connect to %s:%u\n", client->hostname,
+ client->port);
close(fd);
return -1;
}
dprint(FD_NET, "client: connect to host %s\n", client->hostname);
- memset(&client->addr, 0, sizeof(client->addr));
-
if (client->is_sock)
fd = fio_client_connect_sock(client);
else
return 1;
client->fd = fd;
- fio_client_add_fd_hash(client);
+ fio_client_add_hash(client);
client->state = Client_connected;
return 0;
}
static void sig_int(int sig)
{
- dprint(FD_NET, "client: got sign %d\n", sig);
+ dprint(FD_NET, "client: got signal %d\n", sig);
fio_clients_terminate();
}
static int send_client_cmd_line(struct fio_client *client)
{
- struct cmd_line_pdu *pdu;
+ struct cmd_single_line_pdu *cslp;
+ struct cmd_line_pdu *clp;
+ unsigned long offset;
+ void *pdu;
+ size_t mem;
int i, ret;
dprint(FD_NET, "client: send cmdline %d\n", client->argc);
- pdu = malloc(sizeof(*pdu));
- for (i = 0; i < client->argc; i++)
- strcpy((char *) pdu->argv[i], client->argv[i]);
+ /*
+ * Find out how much mem we need
+ */
+ for (i = 0, mem = 0; i < client->argc; i++)
+ mem += strlen(client->argv[i]) + 1;
+
+ /*
+ * We need one cmd_line_pdu, and argc number of cmd_single_line_pdu
+ */
+ mem += sizeof(*clp) + (client->argc * sizeof(*cslp));
+
+ pdu = malloc(mem);
+ clp = pdu;
+ offset = sizeof(*clp);
+
+ for (i = 0; i < client->argc; i++) {
+ uint16_t arg_len = strlen(client->argv[i]) + 1;
- pdu->argc = cpu_to_le16(client->argc);
- ret = fio_net_send_cmd(client->fd, FIO_NET_CMD_JOBLINE, pdu, sizeof(*pdu));
+ cslp = pdu + offset;
+ strcpy((char *) cslp->text, client->argv[i]);
+ cslp->len = cpu_to_le16(arg_len);
+ offset += sizeof(*cslp) + arg_len;
+ }
+
+ clp->lines = cpu_to_le16(client->argc);
+ ret = fio_net_send_cmd(client->fd, FIO_NET_CMD_JOBLINE, pdu, mem);
free(pdu);
return ret;
}
if (len) {
log_err("fio: failed reading job file %s\n", filename);
close(fd);
+ free(buf);
return 1;
}
display_thread_status(je);
}
-static void handle_probe(struct fio_net_cmd *cmd)
+static void handle_probe(struct fio_client *client, struct fio_net_cmd *cmd)
{
struct cmd_probe_pdu *probe = (struct cmd_probe_pdu *) cmd->payload;
+ const char *os, *arch;
+
+ os = fio_get_os_string(probe->os);
+ if (!os)
+ os = "unknown";
- log_info("Probe: hostname=%s, be=%u, fio ver %u.%u.%u\n",
- probe->hostname, probe->bigendian, probe->fio_major,
+ arch = fio_get_arch_string(probe->arch);
+ if (!arch)
+ os = "unknown";
+
+ log_info("hostname=%s, be=%u, os=%s, arch=%s, fio=%u.%u.%u\n",
+ probe->hostname, probe->bigendian, os, arch, probe->fio_major,
probe->fio_minor, probe->fio_patch);
+
+ if (!client->name)
+ client->name = strdup((char *) probe->hostname);
}
static int handle_client(struct fio_client *client)
break;
case FIO_NET_CMD_TEXT: {
const char *buf = (const char *) cmd->payload;
+ const char *name;
int fio_unused ret;
+ name = client->name ? client->name : client->hostname;
+
if (!client->skip_newline)
- fprintf(f_out, "<%s> ", client->hostname);
+ fprintf(f_out, "<%s> ", name);
ret = fwrite(buf, cmd->pdu_len, 1, f_out);
fflush(f_out);
client->skip_newline = strchr(buf, '\n') == NULL;
free(cmd);
break;
case FIO_NET_CMD_PROBE:
- handle_probe(cmd);
+ handle_probe(client, cmd);
free(cmd);
break;
case FIO_NET_CMD_START:
projects / fio.git / blobdiff