/*
- dbench version 1
- Copyright (C) Andrew Tridgell 1999
+ dbench version 3
+
+ Copyright (C) Andrew Tridgell 1999-2004
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2 of the License, or
+ the Free Software Foundation; either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ along with this program; if not, see <http://www.gnu.org/licenses/>.
*/
/* This file links against either fileio.c to do operations against a
#include "dbench.h"
-char *client_filename = DATADIR "client_oplocks.txt";
+#define ival(s) strtol(s, NULL, 0)
+
+static void nb_target_rate(struct child_struct *child, double rate)
+{
+ double tdelay;
+
+ if (child->rate.last_bytes == 0) {
+ child->rate.last_bytes = child->bytes;
+ child->rate.last_time = timeval_current();
+ return;
+ }
+
+ if (rate != 0) {
+ tdelay = (child->bytes - child->rate.last_bytes)/(1.0e6*rate) -
+ timeval_elapsed(&child->rate.last_time);
+ } else {
+ tdelay = - timeval_elapsed(&child->rate.last_time);
+ }
+ if (tdelay > 0 && rate != 0) {
+ msleep(tdelay*1000);
+ } else {
+ child->max_latency = MAX(child->max_latency, -tdelay);
+ }
+ child->rate.last_time = timeval_current();
+ child->rate.last_bytes = child->bytes;
+}
-FILE * open_client_dump(void)
+static void nb_time_reset(struct child_struct *child)
{
- FILE *f;
+ child->starttime = timeval_current();
+}
- if ((f = fopen(client_filename, "rt")) != NULL)
- return f;
+static void nb_time_delay(struct child_struct *child, double targett)
+{
+ double elapsed = timeval_elapsed(&child->starttime);
+ if (targett > elapsed) {
+ msleep(1000*(targett - elapsed));
+ } else if (elapsed - targett > child->max_latency) {
+ child->max_latency = MAX(elapsed - targett, child->max_latency);
+ }
+}
+
+static void finish_op(struct child_struct *child, struct op *op)
+{
+ double t = timeval_elapsed(&child->lasttime);
+ op->count++;
+ op->total_time += t;
+ if (t > op->max_latency) {
+ op->max_latency = t;
+ }
+}
- fprintf(stderr,
- "dbench: error opening %s: %s\n", client_filename,
- strerror(errno));
+#define OP_LATENCY(opname) finish_op(child, &child->op.op_ ## opname)
- return NULL;
+/*
+ one child operation
+ */
+static void child_op(struct child_struct *child, char **params,
+ const char *fname, const char *fname2, const char *status)
+{
+ child->lasttime = timeval_current();
+
+ if (!strcmp(params[0],"NTCreateX")) {
+ nb_createx(child, fname, ival(params[2]), ival(params[3]),
+ ival(params[4]), status);
+ OP_LATENCY(NTCreateX);
+ } else if (!strcmp(params[0],"Close")) {
+ nb_close(child, ival(params[1]), status);
+ OP_LATENCY(Close);
+ } else if (!strcmp(params[0],"Rename")) {
+ nb_rename(child, fname, fname2, status);
+ OP_LATENCY(Rename);
+ } else if (!strcmp(params[0],"Unlink")) {
+ nb_unlink(child, fname, ival(params[2]), status);
+ OP_LATENCY(Unlink);
+ } else if (!strcmp(params[0],"Deltree")) {
+ nb_deltree(child, fname);
+ OP_LATENCY(Deltree);
+ } else if (!strcmp(params[0],"Rmdir")) {
+ nb_rmdir(child, fname, status);
+ OP_LATENCY(Rmdir);
+ } else if (!strcmp(params[0],"Mkdir")) {
+ nb_mkdir(child, fname, status);
+ OP_LATENCY(Mkdir);
+ } else if (!strcmp(params[0],"QUERY_PATH_INFORMATION")) {
+ nb_qpathinfo(child, fname, ival(params[2]), status);
+ OP_LATENCY(Qpathinfo);
+ } else if (!strcmp(params[0],"QUERY_FILE_INFORMATION")) {
+ nb_qfileinfo(child, ival(params[1]), ival(params[2]), status);
+ OP_LATENCY(Qfileinfo);
+ } else if (!strcmp(params[0],"QUERY_FS_INFORMATION")) {
+ nb_qfsinfo(child, ival(params[1]), status);
+ OP_LATENCY(Qfsinfo);
+ } else if (!strcmp(params[0],"SET_FILE_INFORMATION")) {
+ nb_sfileinfo(child, ival(params[1]), ival(params[2]), status);
+ OP_LATENCY(Sfileinfo);
+ } else if (!strcmp(params[0],"FIND_FIRST")) {
+ nb_findfirst(child, fname, ival(params[2]),
+ ival(params[3]), ival(params[4]), status);
+ OP_LATENCY(Find);
+ } else if (!strcmp(params[0],"WriteX")) {
+ nb_writex(child, ival(params[1]),
+ ival(params[2]), ival(params[3]), ival(params[4]),
+ status);
+ OP_LATENCY(WriteX);
+ } else if (!strcmp(params[0],"LockX")) {
+ nb_lockx(child, ival(params[1]),
+ ival(params[2]), ival(params[3]), status);
+ OP_LATENCY(LockX);
+ } else if (!strcmp(params[0],"UnlockX")) {
+ nb_unlockx(child, ival(params[1]),
+ ival(params[2]), ival(params[3]), status);
+ OP_LATENCY(UnlockX);
+ } else if (!strcmp(params[0],"ReadX")) {
+ nb_readx(child, ival(params[1]),
+ ival(params[2]), ival(params[3]), ival(params[4]),
+ status);
+ OP_LATENCY(ReadX);
+ } else if (!strcmp(params[0],"Flush")) {
+ nb_flush(child, ival(params[1]), status);
+ OP_LATENCY(Flush);
+ } else if (!strcmp(params[0],"Sleep")) {
+ nb_sleep(child, ival(params[1]), status);
+ } else {
+ printf("[%d] Unknown operation %s in pid %d\n",
+ child->line, params[0], getpid());
+ }
}
-#define ival(s) strtol(s, NULL, 0)
-void child_run(struct child_struct *child)
+/* run a test that simulates an approximate netbench client load */
+void child_run(struct child_struct *child0, const char *loadfile)
{
int i;
- char line[1024];
- char cname[20];
+ char line[1024], fname[1024], fname2[1024];
+ char **sparams, **params;
+ char *p;
+ const char *status;
FILE *f;
- char *params[20];
-
- child->line = 0;
+ pid_t parent = getppid();
+ double targett;
+ struct child_struct *child;
- sprintf(cname,"client%d", child->id);
+ for (child=child0;child<child0+options.clients_per_process;child++) {
+ child->line = 0;
+ asprintf(&child->cname,"client%d", child->id);
+ }
- f = open_client_dump();
+ sparams = calloc(20, sizeof(char *));
+ for (i=0;i<20;i++) {
+ sparams[i] = malloc(100);
+ }
- if (!f) {
+ f = fopen(loadfile, "r");
+ if (f == NULL) {
+ perror(loadfile);
exit(1);
}
+again:
+ for (child=child0;child<child0+options.clients_per_process;child++) {
+ nb_time_reset(child);
+ }
+
while (fgets(line, sizeof(line)-1, f)) {
- child->line++;
+ params = sparams;
+
+ if (kill(parent, 0) == -1) {
+ exit(1);
+ }
+
+ for (child=child0;child<child0+options.clients_per_process;child++) {
+ if (child->done) goto done;
+ child->line++;
+ }
+
+ line[strlen(line)-1] = 0;
- all_string_sub(line,"client1", cname);
all_string_sub(line,"\\", "/");
all_string_sub(line," /", " ");
- /* parse the command parameters */
- params[0] = strtok(line," \n");
- i = 0;
- while (params[i]) params[++i] = strtok(NULL," \n");
- params[i] = "";
+ p = line;
+ for (i=0;
+ i<19 && next_token(&p, params[i], " ");
+ i++) ;
+
+ params[i][0] = 0;
- if (i < 2) continue;
+ if (i < 2 || params[0][0] == '#') continue;
if (!strncmp(params[0],"SMB", 3)) {
printf("ERROR: You are using a dbench 1 load file\n");
exit(1);
}
- if (!strcmp(params[0],"NTCreateX")) {
- nb_createx(child, params[1], ival(params[2]), ival(params[3]),
- ival(params[4]));
- } else if (!strcmp(params[0],"Close")) {
- nb_close(child, ival(params[1]));
- } else if (!strcmp(params[0],"Rename")) {
- nb_rename(child, params[1], params[2]);
- } else if (!strcmp(params[0],"Unlink")) {
- nb_unlink(child, params[1]);
- } else if (!strcmp(params[0],"Deltree")) {
- nb_deltree(child, params[1]);
- } else if (!strcmp(params[0],"Rmdir")) {
- nb_rmdir(child, params[1]);
- } else if (!strcmp(params[0],"QUERY_PATH_INFORMATION")) {
- nb_qpathinfo(child, params[1]);
- } else if (!strcmp(params[0],"QUERY_FILE_INFORMATION")) {
- nb_qfileinfo(child, ival(params[1]));
- } else if (!strcmp(params[0],"QUERY_FS_INFORMATION")) {
- nb_qfsinfo(child, ival(params[1]));
- } else if (!strcmp(params[0],"FIND_FIRST")) {
- nb_findfirst(child, params[1]);
- } else if (!strcmp(params[0],"WriteX")) {
- nb_writex(child, ival(params[1]),
- ival(params[2]), ival(params[3]), ival(params[4]));
- } else if (!strcmp(params[0],"ReadX")) {
- nb_readx(child, ival(params[1]),
- ival(params[2]), ival(params[3]), ival(params[4]));
- } else if (!strcmp(params[0],"Flush")) {
- nb_flush(child, ival(params[1]));
+ if (i > 0 && isdigit(params[0][0])) {
+ targett = strtod(params[0], NULL);
+ params++;
+ i--;
} else {
- printf("Unknown operation %s\n", params[0]);
- fflush(stdout);
- exit(1);
+ targett = 0.0;
+ }
+
+ if (strncmp(params[i-1], "NT_STATUS_", 10) != 0 &&
+ strncmp(params[i-1], "0x", 2) != 0) {
+ printf("Badly formed status at line %d\n", child->line);
+ continue;
+ }
+
+ status = params[i-1];
+
+ for (child=child0;child<child0+options.clients_per_process;child++) {
+ fname[0] = 0;
+ fname2[0] = 0;
+
+ if (i>1 && params[1][0] == '/') {
+ snprintf(fname, sizeof(fname), "%s%s", child->directory, params[1]);
+ all_string_sub(fname,"client1", child->cname);
+ }
+ if (i>2 && params[2][0] == '/') {
+ snprintf(fname2, sizeof(fname2), "%s%s", child->directory, params[2]);
+ all_string_sub(fname2,"client1", child->cname);
+ }
+
+ if (options.targetrate != 0 || targett == 0.0) {
+ nb_target_rate(child, options.targetrate);
+ } else {
+ nb_time_delay(child, targett);
+ }
+ child_op(child, params, fname, fname2, status);
}
}
- fclose(f);
- nb_cleanup(child);
+ rewind(f);
+ goto again;
- child->done = 1;
+done:
+ fclose(f);
+ for (child=child0;child<child0+options.clients_per_process;child++) {
+ child->cleanup = 1;
+ fflush(stdout);
+ nb_cleanup(child);
+ child->cleanup_finished = 1;
+ }
}
git.samba.org / tridge / dbench.git / blobdiff