Home
last modified time | relevance | path

Searched refs:threadflow (Results 1 – 9 of 9) sorted by relevance

/onnv-gate/usr/src/cmd/filebench/common/
H A Dthreadflow.c84 threadflow_createthread(threadflow_t *threadflow) in threadflow_createthread() argument
87 memsize = avd_get_int(threadflow->tf_memsize); in threadflow_createthread()
88 threadflow->tf_constmemsize = memsize; in threadflow_createthread()
91 threadflow->tf_name, memsize); in threadflow_createthread()
93 if (threadflow->tf_attrs & THREADFLOW_USEISM) in threadflow_createthread()
96 if (pthread_create(&threadflow->tf_tid, NULL, in threadflow_createthread()
97 (void *(*)(void*))flowop_start, threadflow) != 0) { in threadflow_createthread()
125 threadflow_t *threadflow = procflow->pf_threads; in threadflow_init() local
130 while (threadflow) { in threadflow_init()
135 instances = avd_get_int(threadflow->tf_instances); in threadflow_init()
[all …]
H A Dflowop_library.c87 static int flowoplib_fdnum(threadflow_t *threadflow, flowop_t *flowop);
88 static int flowoplib_print(threadflow_t *threadflow, flowop_t *flowop);
89 static int flowoplib_write(threadflow_t *threadflow, flowop_t *flowop);
90 static int flowoplib_read(threadflow_t *threadflow, flowop_t *flowop);
92 static int flowoplib_block(threadflow_t *threadflow, flowop_t *flowop);
93 static int flowoplib_wakeup(threadflow_t *threadflow, flowop_t *flowop);
94 static int flowoplib_hog(threadflow_t *threadflow, flowop_t *flowop);
95 static int flowoplib_delay(threadflow_t *threadflow, flowop_t *flowop);
96 static int flowoplib_sempost(threadflow_t *threadflow, flowop_t *flowop);
98 static int flowoplib_semblock(threadflow_t *threadflow, flowop_t *flowop);
[all …]
H A Dflowop.c41 static flowop_t *flowop_define_common(threadflow_t *threadflow, char *name,
43 static int flowop_composite(threadflow_t *threadflow, flowop_t *flowop);
144 flowop_beginop(threadflow_t *threadflow, flowop_t *flowop) in flowop_beginop() argument
148 if ((noproc == 0) && (threadflow->tf_lwpusagefd == 0)) { in flowop_beginop()
153 threadflow->tf_lwpusagefd = open(procname, O_RDONLY); in flowop_beginop()
156 (void) pread(threadflow->tf_lwpusagefd, in flowop_beginop()
157 &threadflow->tf_susage, in flowop_beginop()
161 if (threadflow->tf_eusage.pr_stime.tv_nsec) { in flowop_beginop()
163 TIMESPEC_TO_HRTIME(threadflow->tf_eusage.pr_utime, in flowop_beginop()
164 threadflow->tf_susage.pr_utime) + in flowop_beginop()
[all …]
H A Dthreadflow.h72 typedef struct threadflow { struct
83 struct threadflow *tf_next; /* Next on proc list */ argument
111 void flowop_start(threadflow_t *threadflow); argument
113 void threadflow_allstarted(pid_t pid, threadflow_t *threadflow);
H A Dflowop.h61 struct threadflow *fo_thread; /* Backpointer to thread */
162 int flowoplib_iosetup(threadflow_t *threadflow, flowop_t *flowop,
165 void flowop_endop(threadflow_t *threadflow, flowop_t *flowop, int64_t bytes);
166 void flowop_beginop(threadflow_t *threadflow, flowop_t *flowop);
167 void flowop_destruct_all_flows(threadflow_t *threadflow);
H A Dfb_localfs.c135 static int fb_lfsflow_aiowrite(threadflow_t *threadflow, flowop_t *flowop);
136 static int fb_lfsflow_aiowait(threadflow_t *threadflow, flowop_t *flowop);
312 fb_lfsflow_aiowrite(threadflow_t *threadflow, flowop_t *flowop) in fb_lfsflow_aiowrite() argument
322 if ((ret = flowoplib_iosetup(threadflow, flowop, &wss, &iobuf, in fb_lfsflow_aiowrite()
354 flowop_beginop(threadflow, flowop); in fb_lfsflow_aiowrite()
360 flowop_endop(threadflow, flowop, iosize); in fb_lfsflow_aiowrite()
381 fb_lfsflow_aiowait(threadflow_t *threadflow, flowop_t *flowop) in fb_lfsflow_aiowait() argument
414 flowop_beginop(threadflow, flowop); in fb_lfsflow_aiowait()
439 flowop_endop(threadflow, flowop, 0); in fb_lfsflow_aiowait()
470 flowop_endop(threadflow, flowop, 0); in fb_lfsflow_aiowait()
[all …]
H A Dprocflow.h48 struct threadflow *pf_threads;
H A Dparser_gram.y2317 threadflow_t *threadflow, template; in parser_thread_define() local
2363 if ((threadflow = threadflow_define(procflow, name, in parser_thread_define()
2372 threadflow->tf_attrs |= THREADFLOW_USEISM; in parser_thread_define()
2378 parser_flowop_define(inner_cmd, threadflow, in parser_thread_define()
2379 &threadflow->tf_thrd_fops, FLOW_MASTER); in parser_thread_define()
/onnv-gate/usr/src/cmd/filebench/
H A DMakefile.com46 threadflow.c \