You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

event.h 8.4 kB

5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
4 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
5 years ago
4 years ago
5 years ago
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279
  1. /**
  2. * Copyright 2019-2020 Huawei Technologies Co., Ltd
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. #ifndef CCE_RUNTIME_EVENT_H
  17. #define CCE_RUNTIME_EVENT_H
  18. #include "base.h"
  19. #if defined(__cplusplus)
  20. extern "C" {
  21. #endif
  22. typedef enum rtEventWaitStatus {
  23. EVENT_STATUS_COMPLETE = 0,
  24. EVENT_STATUS_NOT_READY = 1,
  25. EVENT_STATUS_MAX = 2,
  26. } rtEventWaitStatus_t;
  27. /**
  28. * @ingroup event_flags
  29. * @brief event op bit flags
  30. */
  31. #define RT_EVENT_DEFAULT (0x0EU)
  32. #define RT_EVENT_WITH_FLAG (0x0BU)
  33. #define RT_EVENT_DDSYNC_NS 0x01U
  34. #define RT_EVENT_STREAM_MARK 0x02U
  35. #define RT_EVENT_DDSYNC 0x04U
  36. #define RT_EVENT_TIME_LINE 0x08U
  37. /**
  38. * @ingroup dvrt_event
  39. * @brief create event instance
  40. * @param [in|out] event created event
  41. * @return RT_ERROR_NONE for ok
  42. * @return RT_ERROR_INVALID_VALUE for error input
  43. */
  44. RTS_API rtError_t rtEventCreate(rtEvent_t *event);
  45. /**
  46. * @ingroup dvrt_event
  47. * @brief create event instance with flag
  48. * @param [in|out] event created event flag event op flag
  49. * @return RT_ERROR_NONE for ok
  50. * @return RT_ERROR_INVALID_VALUE for error input
  51. */
  52. RTS_API rtError_t rtEventCreateWithFlag(rtEvent_t *event, uint32_t flag);
  53. /**
  54. * @ingroup dvrt_event
  55. * @brief destroy event instance
  56. * @param [in] event event to destroy
  57. * @return RT_ERROR_NONE for ok
  58. * @return RT_ERROR_INVALID_VALUE for error input
  59. */
  60. RTS_API rtError_t rtEventDestroy(rtEvent_t event);
  61. /**
  62. * @ingroup dvrt_event
  63. * @brief get event id
  64. * @param [in] event_ event to be get
  65. * @param [in|out] event_id event_id id
  66. * @return RT_ERROR_NONE for ok
  67. * @return RT_ERROR_INVALID_VALUE for error input
  68. */
  69. RTS_API rtError_t rtGetEventID(rtEvent_t event, uint32_t *eventId);
  70. /**
  71. * @ingroup dvrt_event
  72. * @brief event record
  73. * @param [int] event event to record
  74. * @param [int] stream stream handle
  75. * @return RT_ERROR_NONE for ok
  76. * @return RT_ERROR_INVALID_VALUE for error input
  77. */
  78. RTS_API rtError_t rtEventRecord(rtEvent_t event, rtStream_t stream);
  79. /**
  80. * @ingroup dvrt_event
  81. * @brief event reset
  82. * @param [int] event event to reset
  83. * @param [int] stream stream handle
  84. * @return RT_ERROR_NONE for ok
  85. */
  86. RTS_API rtError_t rtEventReset(rtEvent_t event, rtStream_t stream);
  87. /**
  88. * @ingroup dvrt_event
  89. * @brief wait event to be complete
  90. * @param [in] event event to wait
  91. * @return RT_ERROR_NONE for ok
  92. * @return RT_ERROR_INVALID_VALUE for error input
  93. */
  94. RTS_API rtError_t rtEventSynchronize(rtEvent_t event);
  95. /**
  96. * @ingroup dvrt_event
  97. * @brief Queries an event's status
  98. * @param [in] event event to query
  99. * @return RT_ERROR_NONE for complete
  100. * @return RT_ERROR_EVENT_NOT_COMPLETE for not complete
  101. */
  102. RTS_API rtError_t rtEventQuery(rtEvent_t event);
  103. /**
  104. * @ingroup dvrt_event
  105. * @brief Queries an event's wait status
  106. * @param [in] event event to query
  107. * @param [in out] EVENT_WAIT_STATUS status
  108. * @return EVENT_STATUS_COMPLETE for complete
  109. * @return EVENT_STATUS_NOT_READY for not complete
  110. */
  111. RTS_API rtError_t rtEventQueryWaitStatus(rtEvent_t event, rtEventWaitStatus_t *status);
  112. /**
  113. * @ingroup dvrt_event
  114. * @brief computes the elapsed time between events.
  115. * @param [in] time time between start and end in ms
  116. * @param [in] start starting event
  117. * @param [in] end ending event
  118. * @return RT_ERROR_NONE for ok, errno for failed
  119. */
  120. RTS_API rtError_t rtEventElapsedTime(float32_t *time, rtEvent_t start, rtEvent_t end);
  121. /**
  122. * @ingroup dvrt_event
  123. * @brief get the elapsed time from a event after event recorded.
  124. * @param [in] time time in ms
  125. * @param [in] event event handle
  126. * @return RT_ERROR_NONE for ok, errno for failed
  127. */
  128. RTS_API rtError_t rtEventGetTimeStamp(uint64_t *time, rtEvent_t event);
  129. /**
  130. * @ingroup dvrt_event
  131. * @brief name an event
  132. * @param [in] event event to be named
  133. * @param [in] name identification name
  134. * @return RT_ERROR_NONE for ok
  135. * @return RT_ERROR_INVALID_VALUE for error input of event, name
  136. * @return RT_ERROR_DRV_ERR for driver error
  137. */
  138. RTS_API rtError_t rtNameEvent(rtEvent_t event, const char_t *name);
  139. /**
  140. * @ingroup dvrt_event
  141. * @brief Create a notify
  142. * @param [in] device_id device id
  143. * @param [in|out] notify_ notify to be created
  144. * @return RT_ERROR_NONE for ok
  145. * @return RT_ERROR_INVALID_VALUE for error input
  146. */
  147. RTS_API rtError_t rtNotifyCreate(int32_t deviceId, rtNotify_t *notify);
  148. /**
  149. * @ingroup dvrt_event
  150. * @brief Destroy a notify
  151. * @param [in] notify_ notify to be destroyed
  152. * @return RT_ERROR_NONE for ok
  153. * @return RT_ERROR_INVALID_VALUE for error input
  154. * @return RT_ERROR_DRV_ERR for driver error
  155. */
  156. RTS_API rtError_t rtNotifyDestroy(rtNotify_t notify);
  157. /**
  158. * @ingroup dvrt_event
  159. * @brief Record a notify
  160. * @param [in] notify_ notify to be recorded
  161. * @param [in] stream_ input stream
  162. * @return RT_ERROR_NONE for ok
  163. * @return RT_ERROR_INVALID_VALUE for error input
  164. * @return RT_ERROR_STREAM_CONTEXT for stream is not in current ctx
  165. */
  166. RTS_API rtError_t rtNotifyRecord(rtNotify_t notify, rtStream_t stream);
  167. /**
  168. * @ingroup dvrt_event
  169. * @brief Wait for a notify
  170. * @param [in] notify_ notify to be wait
  171. * @param [in] stream_ input stream
  172. * @return RT_ERROR_NONE for ok
  173. * @return RT_ERROR_INVALID_VALUE for error input
  174. * @return RT_ERROR_STREAM_CONTEXT for stream is not in current ctx
  175. */
  176. RTS_API rtError_t rtNotifyWait(rtNotify_t notify, rtStream_t stream);
  177. /**
  178. * @ingroup dvrt_event
  179. * @brief Wait for a notify with time out
  180. * @param [in] notify notify to be wait
  181. * @param [in] stream input stream
  182. * @param [in] timeOut input timeOut
  183. * @return RT_ERROR_NONE for ok
  184. * @return RT_ERROR_INVALID_VALUE for error input
  185. * @return RT_ERROR_STREAM_CONTEXT for stream is not in current ctx
  186. */
  187. RTS_API rtError_t rtNotifyWaitWithTimeOut(rtNotify_t notify, rtStream_t stream, uint32_t timeOut);
  188. /**
  189. * @ingroup dvrt_event
  190. * @brief Name a notify
  191. * @param [in] notify_ notify to be named
  192. * @param [in|out] name identification name
  193. * @return RT_ERROR_NONE for ok
  194. * @return RT_ERROR_INVALID_VALUE for error input
  195. */
  196. RTS_API rtError_t rtNameNotify(rtNotify_t notify, const char_t *name);
  197. /**
  198. * @ingroup dvrt_event
  199. * @brief get notify id
  200. * @param [in] notify_ notify to be get
  201. * @param [in|out] notify_id notify id
  202. * @return RT_ERROR_NONE for ok
  203. * @return RT_ERROR_INVALID_VALUE for error input
  204. */
  205. RTS_API rtError_t rtGetNotifyID(rtNotify_t notify, uint32_t *notifyId);
  206. /**
  207. * @ingroup dvrt_event
  208. * @brief Set a notify to IPC notify
  209. * @param [in] notify_ notify to be set to IPC notify
  210. * @param [in] name identification name
  211. * @return RT_ERROR_NONE for ok
  212. * @return RT_ERROR_INVALID_VALUE for error input of
  213. */
  214. RTS_API rtError_t rtIpcSetNotifyName(rtNotify_t notify, char_t *name, uint32_t len);
  215. /**
  216. * @ingroup dvrt_event
  217. * @brief Open IPC notify
  218. * @param [out] notify the opened notify
  219. * @param [in] name identification name
  220. * @return RT_ERROR_NONE for ok
  221. * @return RT_ERROR_INVALID_VALUE for error input
  222. */
  223. RTS_API rtError_t rtIpcOpenNotify(rtNotify_t *notify, const char_t *name);
  224. /**
  225. * @ingroup dvrt_event
  226. * @brief Get the physical address corresponding to notify
  227. * @param [in] notify notify to be queried
  228. * @param [in] devAddrOffset device physical address offset
  229. * @return RT_ERROR_NONE for ok
  230. * @return RT_ERROR_INVALID_VALUE for error input
  231. * @return RT_ERROR_DRV_ERR for driver error
  232. */
  233. RTS_API rtError_t rtNotifyGetAddrOffset(rtNotify_t notify, uint64_t *devAddrOffset);
  234. /**
  235. * @ingroup dvrt_event
  236. * @brief Ipc set notify pid
  237. * @param [in] name name to be queried
  238. * @param [in] pid process id
  239. * @param [in] num length of pid[]
  240. * @return RT_ERROR_NONE for ok
  241. * @return RT_ERROR_INVALID_VALUE for error input
  242. * @return RT_ERROR_DRV_ERR for driver error
  243. */
  244. RTS_API rtError_t rtSetIpcNotifyPid(const char_t *name, int32_t pid[], int32_t num);
  245. #if defined(__cplusplus)
  246. }
  247. #endif
  248. #endif // CCE_RUNTIME_EVENT_H

图引擎模块(GE)是MindSpore的一个子模块,其代码由C++实现,位于前端模块ME和底层硬件之间,起到承接作用。图引擎模块以ME下发的图作为输入,然后进行一系列的深度图优化操作,最后输出一张可以在底层硬件上高效运行的图。GE针对昇腾AI处理器的硬件结构特点,做了特定的优化工作,以此来充分发挥出昇腾AI处理器的强大算力。在进行模型训练/推理时,GE会被自动调用而用户并不感知。GE主要由GE API和GE Core两部分组成,详细的架构图如下所示