Home
last modified time | relevance | path

Searched refs:exchange (Results 1 - 25 of 45) sorted by relevance

12

/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dmessage.c30 static int32 SharedSend(MQueueId queueId, Exchange *exchange, int initRef);
31 static BOOL FreeReference(Exchange *exchange);
39 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, NULL}; in SAMGR_SendRequest() local
40 exchange.id.queueId = NULL; in SAMGR_SendRequest()
42 exchange.id.queueId = SAMGR_GetCurrentQueueID(); in SAMGR_SendRequest()
43 exchange.type = MSG_CON; in SAMGR_SendRequest()
46 return QUEUE_Put(identity->queueId, &exchange, 0, DONT_WAIT); in SAMGR_SendRequest()
56 Exchange *exchange = GET_OBJECT(request, Exchange, request); in SAMGR_SendResponse() local
57 if (exchange->type != MSG_CON) { in SAMGR_SendResponse()
61 if (exchange in SAMGR_SendResponse()
100 SAMGR_FreeMsg(Exchange *exchange) SAMGR_FreeMsg() argument
123 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, token}; SAMGR_SendSharedRequest() local
141 Exchange exchange = {0}; SAMGR_SendSharedDirectRequest() local
171 Exchange *exchange = GET_OBJECT(request, Exchange, request); SAMGR_SendResponseByIdentity() local
180 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) SharedSend() argument
204 FreeReference(Exchange *exchange) FreeReference() argument
[all...]
H A Dtask_manager.c33 static void EndWork(ServiceImpl *service, const Exchange *exchange);
35 static void ProcRequest(Exchange *exchange, ServiceImpl *serviceImpl);
36 static void ProcDirectRequest(Exchange *exchange);
37 static void ProcResponse(Exchange *exchange);
38 static ServiceImpl *CorrectServiceImpl(Exchange *exchange, ServiceImpl *serviceImpl);
101 Exchange exchange = {0}; in SAMGR_ReleaseTaskPool() local
102 exchange.type = MSG_EXIT; in SAMGR_ReleaseTaskPool()
103 QUEUE_Put(pool->queueId, &exchange, 0, DONT_WAIT); in SAMGR_ReleaseTaskPool()
128 Exchange exchange; in TaskEntry() local
129 uint32 msgRcvRet = SAMGR_MsgRecv((MQueueId)argv, (uint8 *)&exchange, sizeo in TaskEntry()
151 ProcRequest(Exchange *exchange, ServiceImpl *serviceImpl) ProcRequest() argument
164 ProcResponse(Exchange *exchange) ProcResponse() argument
177 ProcDirectRequest(Exchange *exchange) ProcDirectRequest() argument
190 CorrectServiceImpl(Exchange *exchange, ServiceImpl *serviceImpl) CorrectServiceImpl() argument
228 EndWork(ServiceImpl *service, const Exchange *exchange) EndWork() argument
[all...]
H A Dmessage_inner.h41 short type; /**< The exchange type. */
56 int32 SAMGR_FreeMsg(Exchange *exchange);
/foundation/graphic/graphic_3d/lume/Lume_3D/src/property/
H A Dproperty_handle.cpp28 : IPropertyHandle(), owner_(BASE_NS::exchange(other.owner_, nullptr)),
29 data_(BASE_NS::exchange(other.data_, nullptr)), size_(BASE_NS::exchange(other.size_, 0U)) in exchange() function
35 owner_ = BASE_NS::exchange(other.owner_, nullptr);
36 data_ = BASE_NS::exchange(other.data_, nullptr);
37 size_ = BASE_NS::exchange(other.size_, 0U);
/foundation/graphic/graphic_3d/lume/LumeEngine/ecshelper/PropertyTools/
H A Dproperty_value.h41 : type_(other.type_), // exchange(other.type_, PropertyType::INVALID)),
42 count_(BASE_NS::exchange(other.count_, 0U)), data_(BASE_NS::exchange(other.data_, nullptr)),
43 index_(BASE_NS::exchange(other.index_, 0U)) in exchange() function in PropertyValue
146 type_ = BASE_NS::exchange(other.type_, {});
147 count_ = BASE_NS::exchange(other.count_, 0U);
148 data_ = BASE_NS::exchange(other.data_, nullptr);
149 index_ = BASE_NS::exchange(other.index_, 0U);
/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/property/
H A Dscoped_handle.h62 : handle_(BASE_NS::exchange(other.handle_, nullptr)), data_(BASE_NS::exchange(other.data_, nullptr)) in ScopedHandle()
75 handle_ = BASE_NS::exchange(other.handle_, nullptr);
76 data_ = BASE_NS::exchange(other.data_, nullptr);
/foundation/graphic/graphic_3d/lume/LumeEngine/api/core/ecs/
H A Dentity_reference.h76 : entity_(BASE_NS::exchange(other.entity_, Entity {})), counter_(BASE_NS::exchange(other.counter_, nullptr)) in exchange() function in EntityReference
94 entity_ = BASE_NS::exchange(other.entity_, Entity {});
95 counter_ = BASE_NS::exchange(other.counter_, nullptr);
/foundation/graphic/graphic_3d/lume/LumeRender/api/render/
H A Dresource_handle.h202 : handle_(BASE_NS::exchange(other.handle_, {})), counter_(BASE_NS::exchange(other.counter_, nullptr)) in exchange() function
208 handle_ = BASE_NS::exchange(other.handle_, {});
209 counter_ = BASE_NS::exchange(other.counter_, nullptr);
/foundation/graphic/graphic_3d/lume/LumeBase/api/base/containers/
H A Drefcnt_ptr.h46 refcnt_ptr(refcnt_ptr&& ptr) noexcept : ptr_(exchange(ptr.ptr_, nullptr)) {} in exchange() function in refcnt_ptr
107 ptr_ = exchange(r.ptr_, nullptr);
121 ptr_ = exchange(other.ptr_, ptr_);
/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/components/
H A Dpost_process_configuration_component_manager.cpp666 : manager_(other.manager_), entity_(exchange(other.entity_, {})), generation_(exchange(other.generation_, 0u)),
667 rLocked_(other.rLocked_.exchange(0)), wLocked_(exchange(other.wLocked_, false)), data_(exchange(other.data_, {})),
668 customProperties_(exchange(other.customProperties_, {})) in exchange() function
676 entity_ = exchange(other.entity_, {});
677 generation_ = exchange(other.generation_, 0u);
678 dirty_ = exchange(other.dirty_, false);
679 rLocked_ = other.rLocked_.exchange(
[all...]
H A Dmaterial_component_manager.cpp110 using BASE_NS::exchange;
883 : manager_(other.manager_), entity_(exchange(other.entity_, {})), cachedShader_(exchange(other.cachedShader_, {})),
884 metaData_(exchange(other.metaData_, nullptr)), generation_(exchange(other.generation_, 0U)),
885 rLocked_(exchange(other.rLocked_, 0U)), wLocked_(exchange(other.wLocked_, false)),
886 data_(exchange(other.data_, {})), custom_(exchange(other.custom_, {})) in exchange() function
894 entity_ = exchange(othe
[all...]
/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/utils/
H A Dhgm_one_shot_timer.cpp142 if (stopFlag_.exchange(false)) { in CheckForResetAndStop()
145 if (state != HgmTimerState::STOP && resetFlag_.exchange(false)) { in CheckForResetAndStop()
184 bool isRunning = running_.exchange(true); in Start()
198 if (running_.exchange(false) && handler_ != nullptr) { in Stop()
/foundation/distributeddatamgr/pasteboard/services/dfx/src/
H A Dpasteboard_trace.cpp47 if (isSetBytraceEnabled_.exchange(true)) { in SetBytraceEnable()
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/
H A Devent_handler.h44 : event_ { BASE_NS::move(other.event_) }, token_ { BASE_NS::exchange(other.token_, {}) }
51 token_ = BASE_NS::exchange(other.token_, {});
/foundation/resourceschedule/ffrt/src/util/
H A DIntrusiveList.h72 nd.next = std::exchange(m_head.next, &nd);
81 m_head.next = std::exchange(node->next, node);
/foundation/resourceschedule/ffrt/src/sync/
H A Dsync.h49 if (l.exchange(sync_detail::LOCK, std::memory_order_acquire) == sync_detail::UNLOCK) { in lock()
H A Dmutex.cpp68 while (l.exchange(sync_detail::WAIT, std::memory_order_acquire) != sync_detail::UNLOCK) { in lock()
211 if (l.exchange(sync_detail::UNLOCK, std::memory_order_release) == sync_detail::WAIT) { in unlock()
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Ddds_trace.h44 if (!enable.exchange(true)) { in DdsTrace()
/foundation/multimedia/audio_framework/services/audio_service/server/src/
H A Daudio_manager_listener_proxy.cpp127 if (!isFirstOnCapturerStateCallbackSent_.exchange(true)) { in TrigerFirstOnCapturerStateCallback()
/foundation/distributeddatamgr/pasteboard/framework/framework/device/
H A Ddistributed_module_config.cpp41 if (!retrying_.exchange(true)) { in Notify()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/src/
H A Dstream_adaptor.cpp74 aliveState_.exchange(state); in SetAliveState()
/foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/hgm_screen_manager/
H A Dhgm_core.h91 return screenRefreshRateImme_.exchange(0); in GetScreenRefreshRateImme()
/foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/modifier/
H A Drs_modifier_manager.cpp125 return std::exchange(hasFirstFrameAnimation_, false); in HasFirstFrameAnimation()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_client.cpp91 if (isOpening_.exchange(true)) { in OpenConnect()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dcallbacks.h207 Description : Adp function if user has not registered the callback for automatic exchange the value
218 IN volatile FILLP_ULONG exchange);

Completed in 11 milliseconds

12