10#ifndef __DAOS_TASK_H__
11#define __DAOS_TASK_H__
13#if defined(__cplusplus)
17#include <daos_types.h>
21#include <daos_errno.h>
27#include <daos_pipeline.h>
31 DAOS_OPC_INVALID = -1,
36 DAOS_OPC_MGMT_LIST_POOLS = 2,
38 DAOS_OPC_MGMT_GET_BS_STATE,
41 DAOS_OPC_POOL_CONNECT = 5,
42 DAOS_OPC_POOL_DISCONNECT,
43 DAOS_OPC_POOL_EXCLUDE,
44 DAOS_OPC_POOL_EXCLUDE_OUT,
47 DAOS_OPC_POOL_QUERY_INFO,
48 DAOS_OPC_POOL_LIST_ATTR,
49 DAOS_OPC_POOL_GET_ATTR,
50 DAOS_OPC_POOL_SET_ATTR,
51 DAOS_OPC_POOL_DEL_ATTR,
52 DAOS_OPC_POOL_STOP_SVC,
53 DAOS_OPC_POOL_LIST_CONT,
56 DAOS_OPC_CONT_CREATE = 18,
59 DAOS_OPC_CONT_DESTROY,
61 DAOS_OPC_CONT_SET_PROP,
62 DAOS_OPC_CONT_UPDATE_ACL,
63 DAOS_OPC_CONT_DELETE_ACL,
64 DAOS_OPC_CONT_AGGREGATE,
65 DAOS_OPC_CONT_ROLLBACK,
66 DAOS_OPC_CONT_SUBSCRIBE,
67 DAOS_OPC_CONT_LIST_ATTR,
68 DAOS_OPC_CONT_GET_ATTR,
69 DAOS_OPC_CONT_SET_ATTR,
70 DAOS_OPC_CONT_DEL_ATTR,
71 DAOS_OPC_CONT_ALLOC_OIDS,
72 DAOS_OPC_CONT_LIST_SNAP,
73 DAOS_OPC_CONT_CREATE_SNAP,
74 DAOS_OPC_CONT_DESTROY_SNAP,
77 DAOS_OPC_TX_OPEN = 37,
80 DAOS_OPC_TX_OPEN_SNAP,
85 DAOS_OPC_OBJ_QUERY_CLASS = 44,
86 DAOS_OPC_OBJ_LIST_CLASS,
90 DAOS_OPC_OBJ_PUNCH_DKEYS,
91 DAOS_OPC_OBJ_PUNCH_AKEYS,
93 DAOS_OPC_OBJ_QUERY_KEY,
97 DAOS_OPC_OBJ_LIST_DKEY,
98 DAOS_OPC_OBJ_LIST_AKEY,
99 DAOS_OPC_OBJ_LIST_RECX,
100 DAOS_OPC_OBJ_LIST_OBJ,
103 DAOS_OPC_ARRAY_CREATE = 60,
105 DAOS_OPC_ARRAY_CLOSE,
106 DAOS_OPC_ARRAY_DESTROY,
108 DAOS_OPC_ARRAY_WRITE,
109 DAOS_OPC_ARRAY_PUNCH,
110 DAOS_OPC_ARRAY_GET_SIZE,
111 DAOS_OPC_ARRAY_SET_SIZE,
115 DAOS_OPC_KV_OPEN = 70,
123 DAOS_OPC_POOL_FILTER_CONT,
124 DAOS_OPC_OBJ_KEY2ANCHOR,
125 DAOS_OPC_CONT_SNAP_OIT_CREATE,
126 DAOS_OPC_CONT_SNAP_OIT_DESTROY,
129 DAOS_OPC_PIPELINE_RUN,
1109daos_task_create(daos_opc_t opc,
tse_sched_t *sched,
1110 unsigned int num_deps,
tse_task_t *dep_tasks[],
1127daos_task_reset(
tse_task_t *task, daos_opc_t opc);
1162daos_task_set_priv(
tse_task_t *task,
void *priv);
1177daos_progress(
tse_sched_t *sched, int64_t timeout,
bool *is_empty);
1179#if defined(__cplusplus)
unsigned int open_with_attr
daos_array_stbuf_t * stbuf
char const *const * names
char const *const * names
void const *const * values
char const *const * names
daos_mgmt_pool_info_t * pools
struct daos_oclass_list * clist
daos_anchor_t * dkey_anchor
daos_epoch_range_t * eprs
daos_anchor_t * akey_anchor
struct daos_oclass_attr * cattr
struct daos_obj_attr * oa
struct daos_oclass_attr * cattr
daos_pipeline_t * pipeline
daos_pipeline_stats_t * stats
char const *const * names
struct daos_pool_cont_info2 * cont_buf
daos_pool_cont_filter_t * filt
char const *const * names
struct daos_pool_cont_info * cont_buf
daos_target_info_t * info
void const *const * values
char const *const * names