#defineTHREAD_T HANDLE

#defineTHREAD_FUNC_RETURN_TYPE unsigned

#defineTHREAD_FUNC_RETURN return 0

#defineTHREAD_FUNC_CC __stdcall

#defineTHREAD_CREATE(handle,function,arg) \

((*(handle) = (HANDLE) _beginthreadex(NULL, 0, (function), (arg), 0, NULL)) == 0 ? errno : 0)

#defineTHREAD_JOIN(handle) \

#defineTHREAD_T pthread_t

#defineTHREAD_FUNC_RETURN_TYPE void *

#defineTHREAD_FUNC_RETURN return NULL

#defineTHREAD_CREATE(handle,function,arg) \

pthread_create((handle), NULL, (function), (arg))

#defineTHREAD_JOIN(handle) \

#defineTHREAD_T void *

#defineTHREAD_FUNC_RETURN_TYPE void *

#defineTHREAD_FUNC_RETURN return NULL

#defineTHREAD_BARRIER_T int

#defineTHREAD_BARRIER_INIT(barrier,n) (*(barrier) = 0)

#defineTHREAD_BARRIER_WAIT(barrier)

staticvoidprocessXactStats(TState*thread,CState*st,pg_time_usec_t*now,

boolskipped,StatsData*agg);

staticvoidaddScript(ParsedScriptscript);

staticTHREAD_FUNC_RETURN_TYPEthreadRun(void*arg);

staticTHREAD_FUNC_RETURN_TYPETHREAD_FUNC_CCthreadRun(void*arg);

staticvoidfinishCon(CState*st);

staticvoidsetalarm(intseconds);

staticsocket_set*alloc_socket_set(intcount);

{

if (skipped)

fprintf(logfile,"%d "INT64_FORMAT" skipped %d %ld %ld",

fprintf(logfile,"%d "INT64_FORMAT" skipped %d "INT64_FORMAT" "

INT64_FORMAT,

st->id,st->cnt,st->use_file,now /1000000,now %1000000);

fprintf(logfile,"%d "INT64_FORMAT" %.0f %d %ld %ld",

fprintf(logfile,"%d "INT64_FORMAT" %.0f %d "INT64_FORMAT" "

INT64_FORMAT,

st->id,st->cnt,latency,st->use_file,

now /1000000,now %1000000);

if (throttle_delay)

returnexit_code;

}

threadRun(void*arg)

{

TState*thread= (TState*)arg;