$PostgreSQL: pgsql/contrib/pgbench/README.pgbench,v 1.18 2007/04/08 01:15:07 ishii Exp $

$PostgreSQL: pgsql/contrib/pgbench/README.pgbench,v 1.19 2007/07/06 13:36:55 wieck Exp $

pgbench README

Variables can also be defined by using -D option.

\usleep usec

causes script execution to sleep for the specified duration in

microseconds.

example:

\setrandom usec 1000000 3000000

\usleep :usec

Example, TPC-B like benchmark can be defined as follows(scaling

factor = 1):

intecnt;/* error count */

intlisten;/* 0 indicates that an async query has been

intsleeping;/* 1 indicates that the client is napping */

structtimevaluntil;/* napping until */

Variable*variables;/* array of variable definitions */

intnvariables;

structtimevaltxn_begin;/* used for measuring latencies */

top:

commands=sql_files[st->use_file];

if (st->sleeping)

{/* are we sleeping? */

intusec;

structtimevalnow;

gettimeofday(&now,NULL);

usec= (st->until.tv_sec-now.tv_sec)*1000000+

st->until.tv_usec-now.tv_usec;

if (usec <=0)

st->sleeping=0;/* Done sleeping, go ahead with next command */

return;/* Still sleeping, nothing to do here */

}

if (st->listen)

{/* are we receiver? */

if (commands[st->state]->type==SQL_COMMAND)

st->listen=1;

}

elseif (pg_strcasecmp(argv[0],"usleep")==0)

{

char*var;

intusec;

structtimevalnow;

if (*argv[1]==':')

{

if ((var=getVariable(st,argv[1]+1))==NULL)

{

fprintf(stderr,"%s: undefined variable %s\n",argv[0],argv[1]);

st->ecnt++;

return;

}

usec=atoi(var);

}

usec=atoi(argv[1]);

gettimeofday(&now,NULL);

st->until.tv_sec=now.tv_sec+ (now.tv_usec+usec) /1000000;

st->until.tv_usec= (now.tv_usec+usec) %1000000;

st->sleeping=1;

st->listen=1;

}

gototop;

}

fprintf(stderr,"%s: extra argument \"%s\" ignored\n",

my_commands->argv[0],my_commands->argv[j]);

}

elseif (pg_strcasecmp(my_commands->argv[0],"usleep")==0)

{

if (my_commands->argc<2)

{

fprintf(stderr,"%s: missing argument\n",my_commands->argv[0]);

returnNULL;

}

for (j=2;j<my_commands->argc;j++)

fprintf(stderr,"%s: extra argument \"%s\" ignored\n",

my_commands->argv[0],my_commands->argv[j]);

}

{

fprintf(stderr,"invalid command %s\n",my_commands->argv[0]);

fprintf(stderr,"Invalid command %s\n",my_commands->argv[0]);

returnNULL;

}

}

fd_setinput_mask;

intnsocks;/* return from select(2) */

intmaxsock;/* max socket number to be waited */

structtimevalnow;

structtimevaltimeout;

intmin_usec;

structrlimitrlim;

FD_ZERO(&input_mask);

maxsock=-1;

min_usec=-1;

for (i=0;i<nclients;i++)

{

Command**commands=sql_files[state[i].use_file];

if (state[i].con&&commands[state[i].state]->type!=META_COMMAND)

if (state[i].sleeping)

{

intthis_usec;

intsock=PQsocket(state[i].con);

if (min_usec<0)

{

gettimeofday(&now,NULL);

min_usec=0;

}

this_usec= (state[i].until.tv_sec-now.tv_sec)*1000000+

state[i].until.tv_usec-now.tv_usec;

if (this_usec>0&& (min_usec==0||this_usec<min_usec))

min_usec=this_usec;

FD_SET(sock,&input_mask);

if (maxsock<sock)

maxsock=sock;

}

elseif (state[i].con&&commands[state[i].state]->type!=META_COMMAND)

{

intsock=PQsocket(state[i].con);

if (maxsock!=-1)

{

if ((nsocks=select(maxsock+1,&input_mask, (fd_set*)NULL,

(fd_set*)NULL, (structtimeval*)NULL))<0)

if (min_usec >=0)

{

timeout.tv_sec=min_usec /1000000;

timeout.tv_usec=min_usec %1000000;

nsocks=select(maxsock+1,&input_mask, (fd_set*)NULL,

(fd_set*)NULL,&timeout);

}

nsocks=select(maxsock+1,&input_mask, (fd_set*)NULL,

(fd_set*)NULL, (structtimeval*)NULL);

if (nsocks<0)

{

if (errno==EINTR)

continue;

fprintf(stderr,"select failed: %s\n",strerror(errno));

exit(1);

}

elseif (nsocks==0)

{/* timeout */

fprintf(stderr,"select timeout\n");

}

exit(0);

}

}