#defineTHREAD_JOIN(handle) \

(WaitForSingleObject(handle, INFINITE) != WAIT_OBJECT_0 ? \

GETERRNO() : CloseHandle(handle) ? 0 : GETERRNO())

#defineTHREAD_BARRIER_T SYNCHRONIZATION_BARRIER

#defineTHREAD_BARRIER_INIT(barrier,n) \

(InitializeSynchronizationBarrier((barrier), (n), 0) ? 0 : GETERRNO())

#defineTHREAD_BARRIER_WAIT(barrier) \

EnterSynchronizationBarrier((barrier), \

SYNCHRONIZATION_BARRIER_FLAGS_BLOCK_ONLY)

#defineTHREAD_BARRIER_DESTROY(barrier)

#elif defined(ENABLE_THREAD_SAFETY)

#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) \

pthread_join((handle), NULL)

#defineTHREAD_BARRIER_T pthread_barrier_t

#defineTHREAD_BARRIER_INIT(barrier,n) \

pthread_barrier_init((barrier), NULL, (n))

#defineTHREAD_BARRIER_WAIT(barrier) pthread_barrier_wait((barrier))

#defineTHREAD_BARRIER_DESTROY(barrier) pthread_barrier_destroy((barrier))

#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)

#defineTHREAD_BARRIER_DESTROY(barrier)

staticRandomStatebase_random_sequence;

staticTHREAD_BARRIER_Tbarrier;

if (duration>0)

setalarm(duration);

errno=THREAD_BARRIER_INIT(&barrier,nthreads);

if (errno!=0)

pg_log_fatal("could not initialize barrier: %m");

for (i=1;i<nthreads;i++)

printResults(&stats,pg_time_now()-bench_start,conn_total_duration,

bench_start-start_time,latency_late);

THREAD_BARRIER_DESTROY(&barrier);

if (exit_code!=0)

pg_log_fatal("Run was aborted; the above results are incomplete.");

state[i].state=CSTATE_CHOOSE_SCRIPT;

THREAD_BARRIER_WAIT(&barrier);

thread_start=pg_time_now();

thread->started_time=thread_start;

last_report=thread_start;

for (inti=0;i<nstate;i++)

{

if ((state[i].con=doConnect())==NULL)

{

THREAD_BARRIER_WAIT(&barrier);

gotodone;

}

}

thread->conn_duration=0;

}

THREAD_BARRIER_WAIT(&barrier);

start=pg_time_now();

thread->bench_start=start;