Lines Matching refs:op_queue

50 } op_queue;  variable
96 op_queue.op = op; in queue_op()
97 op_queue.args = args; in queue_op()
98 op_queue.pending = true; in queue_op()
100 sem_wait(&op_queue.op_done); in queue_op()
102 return op_queue.ret; in queue_op()
107 return op_queue.pending; in ffa_is_op_pended()
112 switch ((intptr_t)op_queue.op) { in ffa_run_pending_op()
114 op_queue.ret = op_callbacks->rmdir((const char *)op_queue.args); in ffa_run_pending_op()
117 op_queue.ret = op_callbacks->unlink((const char *)op_queue.args); in ffa_run_pending_op()
120 struct op_args_truncate *args = op_queue.args; in ffa_run_pending_op()
122 op_queue.ret = op_callbacks->truncate(args->path, args->size); in ffa_run_pending_op()
126 struct op_args_ftruncate *args = op_queue.args; in ffa_run_pending_op()
128 op_queue.ret = op_callbacks->ftruncate(args->fh, args->size); in ffa_run_pending_op()
132 struct op_args_readwrite *args = op_queue.args; in ffa_run_pending_op()
134 op_queue.ret = op_callbacks->write(args->fh, args->buf, args->size, args->off); in ffa_run_pending_op()
138 struct op_args_readwrite *args = op_queue.args; in ffa_run_pending_op()
140 op_queue.ret = op_callbacks->read(args->fh, args->buf, args->size, args->off); in ffa_run_pending_op()
144 op_queue.ret = op_callbacks->release(*(uint64_t *)op_queue.args); in ffa_run_pending_op()
147 struct op_args_create *args = op_queue.args; in ffa_run_pending_op()
149 op_queue.ret = op_callbacks->create(args->path, args->fh_p); in ffa_run_pending_op()
153 op_queue.ret = op_callbacks->mkdir((const char *)op_queue.args); in ffa_run_pending_op()
159 op_queue.ret = op_callbacks->readdir_read_next((struct ffa_dirent *)op_queue.args); in ffa_run_pending_op()
162 op_queue.ret = op_callbacks->readdir_start((const char *)op_queue.args); in ffa_run_pending_op()
165 struct op_args_readmount *args = op_queue.args; in ffa_run_pending_op()
167 op_queue.ret = op_callbacks->readmount(args->mnt_nbr_p, args->mnt_name_p); in ffa_run_pending_op()
171 struct op_args_stat *args = op_queue.args; in ffa_run_pending_op()
173 op_queue.ret = op_callbacks->stat(args->path, args->entry_p); in ffa_run_pending_op()
180 op_queue.pending = false; in ffa_run_pending_op()
181 sem_post(&op_queue.op_done); in ffa_run_pending_op()
622 err = sem_init(&op_queue.op_done, 0, 0); in ffsa_init_bottom()