/external/fio/ |
D | ioengines.h | 25 int (*setup)(struct thread_data *); 26 int (*init)(struct thread_data *); 27 int (*prep)(struct thread_data *, struct io_u *); 28 int (*queue)(struct thread_data *, struct io_u *); 29 int (*commit)(struct thread_data *); 30 int (*getevents)(struct thread_data *, unsigned int, unsigned int, const struct timespec *); 31 struct io_u *(*event)(struct thread_data *, int); 33 int (*cancel)(struct thread_data *, struct io_u *); 34 void (*cleanup)(struct thread_data *); 35 int (*open_file)(struct thread_data *, struct fio_file *); [all …]
|
D | file.h | 184 struct thread_data; 185 extern void close_files(struct thread_data *); 186 extern void close_and_free_files(struct thread_data *); 187 extern uint64_t get_start_offset(struct thread_data *, struct fio_file *); 188 extern int __must_check setup_files(struct thread_data *); 189 extern int __must_check file_invalidate_cache(struct thread_data *, struct fio_file *); 190 extern int __must_check generic_open_file(struct thread_data *, struct fio_file *); 191 extern int __must_check generic_close_file(struct thread_data *, struct fio_file *); 192 extern int __must_check generic_get_file_size(struct thread_data *, struct fio_file *); 194 extern int __must_check pre_read_files(struct thread_data *); [all …]
|
D | io_u.h | 99 int (*end_io)(struct thread_data *, struct io_u **); 130 extern struct io_u *__get_io_u(struct thread_data *); 131 extern struct io_u *get_io_u(struct thread_data *); 132 extern void put_io_u(struct thread_data *, struct io_u *); 133 extern void clear_io_u(struct thread_data *, struct io_u *); 134 extern void requeue_io_u(struct thread_data *, struct io_u **); 135 extern int __must_check io_u_sync_complete(struct thread_data *, struct io_u *); 136 extern int __must_check io_u_queued_complete(struct thread_data *, int); 137 extern void io_u_queued(struct thread_data *, struct io_u *); 138 extern int io_u_quiesce(struct thread_data *); [all …]
|
D | fio.h | 143 struct thread_data { struct 165 struct thread_data *parent; argument 500 extern struct thread_data *threads; 502 static inline void fio_ro_check(const struct thread_data *td, struct io_u *io_u) in fio_ro_check() 509 static inline int should_fsync(struct thread_data *td) in should_fsync() 528 extern void clear_io_state(struct thread_data *, int); 529 extern int fio_options_parse(struct thread_data *, char **, int); 532 extern int fio_cmd_option_parse(struct thread_data *, const char *, char *); 533 extern int fio_cmd_ioengine_option_parse(struct thread_data *, const char *, char *); 534 extern void fio_fill_default_options(struct thread_data *); [all …]
|
D | iolog.h | 90 struct thread_data *td; 176 void regrow_logs(struct thread_data *); 227 extern int __must_check read_iolog_get(struct thread_data *, struct io_u *); 228 extern void log_io_u(const struct thread_data *, const struct io_u *); 229 extern void log_file(struct thread_data *, struct fio_file *, enum file_log_act); 230 extern int __must_check init_iolog(struct thread_data *td); 231 extern void log_io_piece(struct thread_data *, struct io_u *); 232 extern void unlog_io_piece(struct thread_data *, struct io_u *); 233 extern void trim_io_piece(struct thread_data *, const struct io_u *); 234 extern void queue_io_piece(struct thread_data *, struct io_piece *); [all …]
|
D | profile.h | 10 int (*td_init)(struct thread_data *); 11 void (*td_exit)(struct thread_data *); 13 int (*fill_io_u_off)(struct thread_data *, struct io_u *, unsigned int *); 14 int (*fill_io_u_size)(struct thread_data *, struct io_u *, unsigned int); 15 struct fio_file *(*get_next_file)(struct thread_data *); 17 int (*io_u_lat)(struct thread_data *, uint64_t); 49 void profile_add_hooks(struct thread_data *); 51 int profile_td_init(struct thread_data *); 52 void profile_td_exit(struct thread_data *);
|
D | verify.h | 95 extern void populate_verify_io_u(struct thread_data *, struct io_u *); 96 extern int __must_check get_next_verify(struct thread_data *td, struct io_u *); 97 extern int __must_check verify_io_u(struct thread_data *, struct io_u **); 98 extern int verify_io_u_async(struct thread_data *, struct io_u **); 99 extern void fill_verify_pattern(struct thread_data *td, void *p, unsigned int len, struct io_u *io_… 100 extern void fill_buffer_pattern(struct thread_data *td, void *p, unsigned int len); 101 extern void fio_verify_init(struct thread_data *td); 106 extern int verify_async_init(struct thread_data *); 107 extern void verify_async_exit(struct thread_data *);
|
D | io_u.c | 38 static void mark_random_map(struct thread_data *td, struct io_u *io_u) in mark_random_map() 55 static uint64_t last_block(struct thread_data *td, struct fio_file *f, in last_block() 89 static int __get_next_rand_offset(struct thread_data *td, struct fio_file *f, in __get_next_rand_offset() 136 static int __get_next_rand_offset_zipf(struct thread_data *td, in __get_next_rand_offset_zipf() 144 static int __get_next_rand_offset_pareto(struct thread_data *td, in __get_next_rand_offset_pareto() 152 static int __get_next_rand_offset_gauss(struct thread_data *td, in __get_next_rand_offset_gauss() 160 static int __get_next_rand_offset_zoned(struct thread_data *td, in __get_next_rand_offset_zoned() 233 static int get_off_from_method(struct thread_data *td, struct fio_file *f, in get_off_from_method() 261 static inline bool should_sort_io(struct thread_data *td) in should_sort_io() 276 static bool should_do_random(struct thread_data *td, enum fio_ddir ddir) in should_do_random() [all …]
|
D | rate-submit.c | 17 struct thread_data *td = sw->priv; in io_workqueue_fn() 64 struct thread_data *td = sw->priv; in io_workqueue_pre_sleep_flush_fn() 74 struct thread_data *td = sw->priv; in io_workqueue_pre_sleep_fn() 84 struct thread_data *td; in io_workqueue_alloc_fn() 99 struct thread_data *parent = sw->wq->td; in io_workqueue_init_worker_fn() 100 struct thread_data *td = sw->priv; in io_workqueue_init_worker_fn() 144 struct thread_data *td = sw->priv; in io_workqueue_exit_worker_fn() 196 static void sum_ddir(struct thread_data *dst, struct thread_data *src, in sum_ddir() 212 struct thread_data *src = sw->priv; in io_workqueue_update_acct_fn() 213 struct thread_data *dst = sw->wq->td; in io_workqueue_update_acct_fn() [all …]
|
D | trim.h | 7 extern bool __must_check get_next_trim(struct thread_data *td, struct io_u *io_u); 8 extern bool io_u_should_trim(struct thread_data *td, struct io_u *io_u); 14 static inline void remove_trim_entry(struct thread_data *td, struct io_piece *ipo) in remove_trim_entry() 23 static inline bool get_next_trim(struct thread_data *td, struct io_u *io_u) in get_next_trim() 27 static inline bool io_u_should_trim(struct thread_data *td, struct io_u *io_u) in io_u_should_trim() 31 static inline void remove_trim_entry(struct thread_data *td, struct io_piece *ipo) in remove_trim_entry()
|
D | fio_time.h | 6 struct thread_data; 16 extern uint64_t usec_sleep(struct thread_data *, unsigned long); 19 extern bool ramp_time_over(struct thread_data *); 20 extern bool in_ramp_time(struct thread_data *); 23 extern void set_epoch_time(struct thread_data *, int);
|
D | cgroup.c | 22 static char *find_cgroup_mnt(struct thread_data *td) in find_cgroup_mnt() 50 static void add_cgroup(struct thread_data *td, const char *name, in add_cgroup() 100 static char *get_cgroup_root(struct thread_data *td, char *mnt) in get_cgroup_root() 112 static int write_int_to_file(struct thread_data *td, const char *path, in write_int_to_file() 132 static int cgroup_write_pid(struct thread_data *td, const char *root) in cgroup_write_pid() 142 static int cgroup_del_pid(struct thread_data *td, char *mnt) in cgroup_del_pid() 147 int cgroup_setup(struct thread_data *td, struct flist_head *clist, char **mnt) in cgroup_setup() 189 void cgroup_shutdown(struct thread_data *td, char **mnt) in cgroup_shutdown()
|
D | filesetup.c | 35 static inline void clear_error(struct thread_data *td) in clear_error() 44 static int extend_file(struct thread_data *td, struct fio_file *f) in extend_file() 231 static int pre_read_file(struct thread_data *td, struct fio_file *f) in pre_read_file() 300 unsigned long long get_rand_file_size(struct thread_data *td) in get_rand_file_size() 315 static int file_size(struct thread_data *td, struct fio_file *f) in file_size() 328 static int bdev_size(struct thread_data *td, struct fio_file *f) in bdev_size() 358 static int char_size(struct thread_data *td, struct fio_file *f) in char_size() 393 static int get_file_size(struct thread_data *td, struct fio_file *f) in get_file_size() 445 static int __file_invalidate_cache(struct thread_data *td, struct fio_file *f, in __file_invalidate_cache() 522 int file_invalidate_cache(struct thread_data *td, struct fio_file *f) in file_invalidate_cache() [all …]
|
D | stat.h | 294 extern void reset_io_stats(struct thread_data *); 295 extern void update_rusage_stat(struct thread_data *); 296 extern void clear_rusage_stat(struct thread_data *); 298 extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long, 300 extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long, 302 extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long, 305 extern void add_iops_sample(struct thread_data *, struct io_u *, 307 extern void add_bw_sample(struct thread_data *, struct io_u *, 333 uint32_t *io_u_block_info(struct thread_data *td, struct io_u *io_u);
|
D | memory.c | 15 void fio_unpin_memory(struct thread_data *td) in fio_unpin_memory() 26 int fio_pin_memory(struct thread_data *td) in fio_pin_memory() 64 static int alloc_mem_shm(struct thread_data *td, unsigned int total_mem) in alloc_mem_shm() 114 static void free_mem_shm(struct thread_data *td) in free_mem_shm() 125 static int alloc_mem_mmap(struct thread_data *td, size_t total_mem) in alloc_mem_mmap() 182 static void free_mem_mmap(struct thread_data *td, size_t total_mem) in free_mem_mmap() 195 static int alloc_mem_malloc(struct thread_data *td, size_t total_mem) in alloc_mem_malloc() 204 static void free_mem_malloc(struct thread_data *td) in free_mem_malloc() 210 static int alloc_mem_cudamalloc(struct thread_data *td, size_t total_mem) in alloc_mem_cudamalloc() 271 static void free_mem_cudamalloc(struct thread_data *td) in free_mem_cudamalloc() [all …]
|
/external/libvpx/libvpx/vp9/encoder/ |
D | vp9_ethread.c | 39 EncWorkerData *const thread_data = (EncWorkerData *)arg1; in enc_worker_hook() local 40 VP9_COMP *const cpi = thread_data->cpi; in enc_worker_hook() 48 for (t = thread_data->start; t < tile_rows * tile_cols; in enc_worker_hook() 53 vp9_encode_tile(cpi, thread_data->td, tile_row, tile_col); in enc_worker_hook() 103 EncWorkerData *thread_data = &cpi->tile_thr_data[i]; in create_enc_workers() local 109 thread_data->cpi = cpi; in create_enc_workers() 112 CHECK_MEM_ERROR(cm, thread_data->td, in create_enc_workers() 113 vpx_memalign(32, sizeof(*thread_data->td))); in create_enc_workers() 114 vp9_zero(*thread_data->td); in create_enc_workers() 117 thread_data->td->leaf_tree = NULL; in create_enc_workers() [all …]
|
/external/curl/lib/ |
D | nwlib.c | 162 libthreaddata_t *thread_data; in GetOrSetUpData() local 167 thread_data = (libthreaddata_t *) NULL; in GetOrSetUpData() 242 && !(err = NXKeyGetValue(key, (void **) &thread_data)) in GetOrSetUpData() 243 && !thread_data) { in GetOrSetUpData() 251 thread_data = malloc(sizeof(libthreaddata_t)); in GetOrSetUpData() 253 if(thread_data) { in GetOrSetUpData() 254 thread_data->_errno = 0; in GetOrSetUpData() 255 thread_data->twentybytes = malloc(20); in GetOrSetUpData() 257 if(!thread_data->twentybytes) { in GetOrSetUpData() 258 free(thread_data); in GetOrSetUpData() [all …]
|
D | asyn-thread.c | 166 struct thread_data *td; /* for thread-self cleanup */ 169 struct thread_data { struct 178 return &(((struct thread_data *)conn->async.os_specific)->tsd); in conn_thread_sync_data() argument 202 int init_thread_sync_data(struct thread_data * td, in init_thread_sync_data() 273 struct thread_data *td = tsd->td; in getaddrinfo_thread() 313 struct thread_data *td = tsd->td; in gethostbyname_thread() 346 struct thread_data *td = (struct thread_data*) async->os_specific; in destroy_async_data() 386 struct thread_data *td = calloc(1, sizeof(struct thread_data)); in init_resolve_thread() 474 struct thread_data *td = (struct thread_data*) conn->async.os_specific; in Curl_resolver_wait_resolv() 511 struct thread_data *td = (struct thread_data*) conn->async.os_specific; in Curl_resolver_is_resolved()
|
/external/fio/engines/ |
D | skeleton_external.c | 29 static struct io_u *fio_skeleton_event(struct thread_data *td, int event) in fio_skeleton_event() 40 static int fio_skeleton_getevents(struct thread_data *td, unsigned int min, in fio_skeleton_getevents() 50 static int fio_skeleton_cancel(struct thread_data *td, struct io_u *io_u) in fio_skeleton_cancel() 65 static int fio_skeleton_queue(struct thread_data *td, struct io_u *io_u) in fio_skeleton_queue() 86 static int fio_skeleton_prep(struct thread_data *td, struct io_u *io_u) in fio_skeleton_prep() 96 static int fio_skeleton_init(struct thread_data *td) in fio_skeleton_init() 106 static void fio_skeleton_cleanup(struct thread_data *td) in fio_skeleton_cleanup() 114 static int fio_skeleton_open(struct thread_data *td, struct fio_file *f) in fio_skeleton_open() 122 static int fio_skeleton_close(struct thread_data *td, struct fio_file *f) in fio_skeleton_close()
|
D | gfapi.h | 17 extern int fio_gf_setup(struct thread_data *td); 18 extern void fio_gf_cleanup(struct thread_data *td); 19 extern int fio_gf_get_file_size(struct thread_data *td, struct fio_file *f); 20 extern int fio_gf_open_file(struct thread_data *td, struct fio_file *f); 21 extern int fio_gf_close_file(struct thread_data *td, struct fio_file *f); 22 extern int fio_gf_unlink_file(struct thread_data *td, struct fio_file *f);
|
D | windowsaio.c | 39 static int fio_windowsaio_getevents(struct thread_data *td, unsigned int min, 41 static struct io_u *fio_windowsaio_event(struct thread_data *td, int event); 42 static int fio_windowsaio_queue(struct thread_data *td, 44 static void fio_windowsaio_cleanup(struct thread_data *td); 46 static int fio_windowsaio_init(struct thread_data *td); 47 static int fio_windowsaio_open_file(struct thread_data *td, struct fio_file *f); 48 static int fio_windowsaio_close_file(struct thread_data fio_unused *td, struct fio_file *f); 50 static int fio_windowsaio_init(struct thread_data *td) in fio_windowsaio_init() 135 static void fio_windowsaio_cleanup(struct thread_data *td) in fio_windowsaio_cleanup() 156 static int fio_windowsaio_open_file(struct thread_data *td, struct fio_file *f) in fio_windowsaio_open_file() [all …]
|
D | net.c | 40 struct thread_data *td; 228 static int set_window_size(struct thread_data *td, int fd) in set_window_size() 263 static int set_mss(struct thread_data *td, int fd) in set_mss() 291 static int poll_wait(struct thread_data *td, int fd, short events) in poll_wait() 332 static int fio_netio_prep(struct thread_data *td, struct io_u *io_u) in fio_netio_prep() 377 static int splice_in(struct thread_data *td, struct io_u *io_u) in splice_in() 387 static int splice_out(struct thread_data *td, struct io_u *io_u, in splice_out() 425 static int vmsplice_io_u_out(struct thread_data *td, struct io_u *io_u, in vmsplice_io_u_out() 436 static int vmsplice_io_u_in(struct thread_data *td, struct io_u *io_u) in vmsplice_io_u_in() 447 static int fio_netio_splice_in(struct thread_data *td, struct io_u *io_u) in fio_netio_splice_in() [all …]
|
D | binject.c | 62 static unsigned int binject_read_commands(struct thread_data *td, void *p, in binject_read_commands() 93 static int fio_binject_getevents(struct thread_data *td, unsigned int min, in fio_binject_getevents() 173 static int fio_binject_doio(struct thread_data *td, struct io_u *io_u) in fio_binject_doio() 186 static int fio_binject_prep(struct thread_data *td, struct io_u *io_u) in fio_binject_prep() 216 static int fio_binject_queue(struct thread_data *td, struct io_u *io_u) in fio_binject_queue() 235 static struct io_u *fio_binject_event(struct thread_data *td, int event) in fio_binject_event() 242 static int binject_open_ctl(struct thread_data *td) in binject_open_ctl() 253 static void binject_unmap_dev(struct thread_data *td, struct binject_file *bf) in binject_unmap_dev() 275 static int binject_map_dev(struct thread_data *td, struct binject_file *bf, in binject_map_dev() 330 static int fio_binject_close_file(struct thread_data *td, struct fio_file *f) in fio_binject_close_file() [all …]
|
D | null.c | 26 static struct io_u *fio_null_event(struct thread_data *td, int event) in fio_null_event() 33 static int fio_null_getevents(struct thread_data *td, unsigned int min_events, in fio_null_getevents() 48 static int fio_null_commit(struct thread_data *td) in fio_null_commit() 63 static int fio_null_queue(struct thread_data *td, struct io_u *io_u) in fio_null_queue() 78 static int fio_null_open(struct thread_data fio_unused *td, in fio_null_open() 84 static void fio_null_cleanup(struct thread_data *td) in fio_null_cleanup() 94 static int fio_null_init(struct thread_data *td) in fio_null_init()
|
/external/google-breakpad/src/common/linux/tests/ |
D | crash_generator.cc | 82 ThreadData* thread_data = reinterpret_cast<ThreadData*>(data); in thread_function() local 84 *(thread_data->thread_id_ptr) = thread_id; in thread_function() 85 int result = pthread_barrier_wait(thread_data->barrier); in thread_function() 283 ThreadData* thread_data = new ThreadData[num_threads]; in CreateThreadsInChildProcess() local 302 thread_data[i].barrier = &thread_barrier; in CreateThreadsInChildProcess() 303 thread_data[i].thread_id_ptr = GetThreadIdPointer(i); in CreateThreadsInChildProcess() 304 if (pthread_create(&thread_data[i].thread, &thread_attributes, in CreateThreadsInChildProcess() 305 thread_function, &thread_data[i]) != 0) { in CreateThreadsInChildProcess() 319 delete[] thread_data; in CreateThreadsInChildProcess()
|