diff options
| author | Lu Qiuwen <[email protected]> | 2023-04-27 17:26:57 +0800 |
|---|---|---|
| committer | Lu Qiuwen <[email protected]> | 2023-05-05 14:00:54 +0800 |
| commit | e5ac798f7c3e8bb0aab4e5552df2e3f5b93db0eb (patch) | |
| tree | 8bbb91f429e9459a2128b085f6ceac7b80054f84 /include | |
| parent | 64fcf8c75c433eca07315d3e56512075b529d5ba (diff) | |
增加poll时注册外部事件fd的功能并改进poll相关的实现。
Diffstat (limited to 'include')
| -rw-r--r-- | include/external/marsio.h | 4 | ||||
| -rw-r--r-- | include/internal/vdev_define.h | 7 |
2 files changed, 10 insertions, 1 deletions
diff --git a/include/external/marsio.h b/include/external/marsio.h index 791f73b..f3314c5 100644 --- a/include/external/marsio.h +++ b/include/external/marsio.h @@ -110,7 +110,7 @@ enum mr_buff_metadata_type /* dir, internal->external or external->internal */ MR_BUFF_DIR = 4, /* payload offset */ - MR_BUFF_PAYLOAD_OFFSET = 5 + MR_BUFF_PAYLOAD_OFFSET = 5, }; #ifdef __cplusplus @@ -152,6 +152,8 @@ int marsio_option_set(struct mr_instance * instance, marsio_opt_type_t opt_type, int marsio_init(struct mr_instance * instance, const char * appsym); int marsio_thread_init(struct mr_instance * instance); int marsio_destory(struct mr_instance * instance); + +int marsio_poll_register_eventfd(struct mr_instance * instance, int eventfd, unsigned int tid); int marsio_poll_wait(struct mr_instance * instance, struct mr_vdev * vdevs[], unsigned int nr_vdevs, unsigned int tid, int timeout); struct mr_vdev * marsio_open_device(struct mr_instance * instance, const char * devsym, unsigned int nr_rxstream, diff --git a/include/internal/vdev_define.h b/include/internal/vdev_define.h index 54ad015..b12417f 100644 --- a/include/internal/vdev_define.h +++ b/include/internal/vdev_define.h @@ -51,6 +51,13 @@ struct vdev_stat_info uint64_t ltx_deliver[MR_SID_MAX]; uint64_t ltx_missed[MR_SID_MAX]; uint64_t ltx_total_len[MR_SID_MAX]; + +#if 0 + /* NOTIFY */ + uint64_t notify_state_waiting[MR_SID_MAX]; + uint64_t notify_state_running[MR_SID_MAX]; + uint64_t notify_state_ready[MR_SID_MAX]; +#endif }; /* 虚拟设备信息 */ |