| /foundation/ai/ai_engine/services/common/platform/queuepool/ |
| H A D | queue.h | 30 explicit Queue(size_t maxQueueSize);
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/src/ |
| H A D | message_looper.h | 34 int32_t Init(uint32_t maxQueueSize, uint32_t msgPayloadLen, std::string name);
|
| H A D | hi_state_machine.h | 33 int32_t Init(uint32_t maxQueueSize, uint32_t maxMsgPayloadSize, const std::string smName);
|
| H A D | hi_state_machine.cpp | 53 int32_t HiStateMachine::Init(uint32_t maxQueueSize, uint32_t maxMsgPayloadSize, const std::string smName) in Init() argument
65 if (m_looper->Init(maxQueueSize, maxMsgPayloadSize, smName) != HI_SUCCESS) { in Init()
|
| H A D | message_looper.cpp | 63 int32_t MessageLooper::Init(uint32_t maxQueueSize, uint32_t msgPayloadLen, std::string name) in Init() argument
84 if (m_msgPool->Init(maxQueueSize, msgPayloadLen) != HI_SUCCESS) { in Init()
|
| H A D | hi_fsm.cpp | 105 int32_t HI_FSM_Create(void **stateMachine, uint32_t maxQueueSize, uint32_t msgPayloadLen, const char *fsmName) in HI_FSM_Create() argument
123 if (fsmInstance->stateMachine->Init(maxQueueSize, msgPayloadLen, fsmName) != HI_SUCCESS) { in HI_FSM_Create()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/include/ |
| H A D | hi_fsm.h | 52 int32_t HI_FSM_Create(void **stateMachine, uint32_t maxQueueSize, uint32_t msgPayloadLen,
|
| /foundation/arkui/napi/sample/native_module_systemtest/ |
| H A D | js_test_threadsafe_napi.cpp | 39 uint32_t maxQueueSize = 0; member
178 // jsfunc, abort/release, startSecondary, maxQueueSize
202 NAPI_CALL(env, napi_get_value_uint32(env, argv[THREAD_ARG_THREE], &tsinfo.maxQueueSize)); in StartThreadInternal()
204 NAPI_CALL(env, napi_create_threadsafe_function(env, argv[0], nullptr, asyncName, tsinfo.maxQueueSize, in StartThreadInternal()
216 // Startup param: jsfunc, abort/release, startSecondary, maxQueueSize
|
| /foundation/arkui/napi/native_engine/ |
| H A D | native_safe_async_work.h | 65 size_t maxQueueSize,
|
| H A D | native_safe_async_work.cpp | 77 size_t maxQueueSize, in NativeSafeAsyncWork()
83 :engine_(engine), engineId_(engine->GetId()), maxQueueSize_(maxQueueSize), in NativeSafeAsyncWork()
73 NativeSafeAsyncWork(NativeEngine* engine, napi_value func, napi_value asyncResource, napi_value asyncResourceName, size_t maxQueueSize, size_t threadCount, void* finalizeData, NativeFinalize finalizeCallback, void* context, NativeThreadSafeFunctionCallJs callJsCallback) NativeSafeAsyncWork() argument
|
| H A D | native_engine.cpp | 357 napi_value asyncResourceName, size_t maxQueueSize, size_t threadCount, void* finalizeData, in CreateSafeAsyncWork()
360 return new NativeSafeAsyncWork(this, func, asyncResource, asyncResourceName, maxQueueSize, threadCount, in CreateSafeAsyncWork()
356 CreateSafeAsyncWork(napi_value func, napi_value asyncResource, napi_value asyncResourceName, size_t maxQueueSize, size_t threadCount, void* finalizeData, NativeFinalize finalizeCallback, void* context, NativeThreadSafeFunctionCallJs callJsCallback) CreateSafeAsyncWork() argument
|
| H A D | native_engine.h | 178 napi_value asyncResourceName, size_t maxQueueSize, size_t threadCount, void* finalizeData,
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/ |
| H A D | liteplayer_state_machine.h | 103 int32_t Init(uint32_t maxQueueSize, uint32_t maxMsgPayloadSize);
|
| H A D | liteplayer_state_machine.cpp | 308 int32_t PlayerControlStateMachine::Init(uint32_t maxQueueSize, uint32_t maxMsgPayloadSize) in Init() argument
311 int32_t ret = HiStateMachine::Init(maxQueueSize, maxMsgPayloadSize, playerControlSmName); in Init()
|
| /foundation/communication/bluetooth/frameworks/js/napi/src/socket/ |
| H A D | napi_bluetooth_spp_client.cpp | 289 const size_t maxQueueSize = 0; // 0 means no limited in NapiSppCreateThreadSafeFunc() local
296 name, maxQueueSize, initialThreadCount, nullptr, nullptr, nullptr, NapiThreadSafeFuncCallJs, &tsfn)); in NapiSppCreateThreadSafeFunc()
|