commit 89e5fad91bc33f1687cca6b1bf5aa3084c424650
author Jens Axboe <axboe@kernel.dk> Mon Mar 05 09:21:12 2012 +0100
committer Jens Axboe <axboe@kernel.dk> Mon Mar 05 09:21:12 2012 +0100
tree b1a02c733d9b9a1176e9905f174840803bb4aa8e
parent a52766160d7f2a937c74d4adee1819ef00467d4b

Pass in client for thread/group status op

Signed-off-by: Jens Axboe <axboe@kernel.dk>

client.c

diff --git a/client.c b/client.c
index 23c5b6c..a65cbcb 100644
--- a/client.c
+++ b/client.c
@@ -22,8 +22,8 @@
 #include "hash.h"
 
 static void handle_du(struct fio_client *client, struct fio_net_cmd *cmd);
-static void handle_ts(struct fio_net_cmd *cmd);
-static void handle_gs(struct fio_net_cmd *cmd);
+static void handle_ts(struct fio_client *client, struct fio_net_cmd *cmd);
+static void handle_gs(struct fio_client *client, struct fio_net_cmd *cmd);
 static void handle_probe(struct fio_client *client, struct fio_net_cmd *cmd);
 static void handle_text(struct fio_client *client, struct fio_net_cmd *cmd);
 
@@ -621,7 +621,7 @@
 	dst->groupid	= le32_to_cpu(src->groupid);
 }
 
-static void handle_ts(struct fio_net_cmd *cmd)
+static void handle_ts(struct fio_client *client, struct fio_net_cmd *cmd)
 {
 	struct cmd_ts_pdu *p = (struct cmd_ts_pdu *) cmd->payload;
 
@@ -642,7 +642,7 @@
 	}
 }
 
-static void handle_gs(struct fio_net_cmd *cmd)
+static void handle_gs(struct fio_client *client, struct fio_net_cmd *cmd)
 {
 	struct group_run_stats *gs = (struct group_run_stats *) cmd->payload;
 
@@ -899,7 +899,7 @@
 		convert_ts(&p->ts, &p->ts);
 		convert_gs(&p->rs, &p->rs);
 
-		ops->thread_status(cmd);
+		ops->thread_status(client, cmd);
 		free(cmd);
 		break;
 		}
@@ -908,7 +908,7 @@
 
 		convert_gs(gs, gs);
 
-		ops->group_stats(cmd);
+		ops->group_stats(client, cmd);
 		free(cmd);
 		break;
 		}