/foundation/resourceschedule/memmgr/services/memmgrservice/src/event/ |
D | extension_connection_observer.cpp | 33 ReclaimHandleRequest request; in OnExtensionConnected() local 34 request.callerPid = data.callerPid; in OnExtensionConnected() 35 request.callerUid = data.callerUid; in OnExtensionConnected() 36 request.callerBundleName = data.callerName; in OnExtensionConnected() 37 request.pid = data.extensionPid; in OnExtensionConnected() 38 request.uid = data.extensionUid; in OnExtensionConnected() 39 request.bundleName = data.extensionBundleName; in OnExtensionConnected() 40 request.reason = AppStateUpdateReason::BIND_EXTENSION; in OnExtensionConnected() 41 ReclaimPriorityManager::GetInstance().UpdateReclaimPriority(request); in OnExtensionConnected() 50 ReclaimHandleRequest request; in OnExtensionDisconnected() local [all …]
|
D | bg_task_observer.cpp | 48 ReclaimHandleRequest request; in OnTransientTaskStart() local 49 request.pid = pid; in OnTransientTaskStart() 50 request.uid = uid; in OnTransientTaskStart() 51 request.bundleName = pkgName; in OnTransientTaskStart() 52 request.reason = AppStateUpdateReason::SUSPEND_DELAY_START; in OnTransientTaskStart() 53 ReclaimPriorityManager::GetInstance().UpdateReclaimPriority(request); in OnTransientTaskStart() 68 ReclaimHandleRequest request; in OnTransientTaskEnd() local 69 request.pid = pid; in OnTransientTaskEnd() 70 request.uid = uid; in OnTransientTaskEnd() 71 request.bundleName = pkgName; in OnTransientTaskEnd() [all …]
|
/foundation/ai/ai_engine/services/client/communication_adapter/source/ |
D | sa_client_proxy.cpp | 87 void ParcelClientInfo(IpcIo *request, const ClientInfo &clientInfo) in ParcelClientInfo() argument 89 WriteInt64(request, clientInfo.clientVersion); in ParcelClientInfo() 90 WriteInt32(request, clientInfo.clientId); in ParcelClientInfo() 91 WriteInt32(request, clientInfo.sessionId); in ParcelClientInfo() 92 WriteUint32(request, clientInfo.serverUid); in ParcelClientInfo() 93 WriteUint32(request, clientInfo.clientUid); in ParcelClientInfo() 96 ParcelDataInfo(request, &dataInfo, clientInfo.serverUid); in ParcelClientInfo() 99 void ParcelAlgorithmInfo(IpcIo *request, const AlgorithmInfo &algorithmInfo, const uid_t serverUid) in ParcelAlgorithmInfo() argument 101 WriteInt64(request, algorithmInfo.clientVersion); in ParcelAlgorithmInfo() 102 WriteBool(request, algorithmInfo.isAsync); in ParcelAlgorithmInfo() [all …]
|
/foundation/communication/dsoftbus/core/authentication/src/ |
D | auth_request.c | 37 static uint32_t GetAuthRequestWaitNum(AuthRequest *request) in GetAuthRequestWaitNum() argument 42 if (item->type == request->type && in GetAuthRequestWaitNum() 43 CompareConnInfo(&request->connInfo, &item->connInfo, true)) { in GetAuthRequestWaitNum() 50 NO_SANITIZE("cfi") uint32_t AddAuthRequest(const AuthRequest *request) in AddAuthRequest() argument 52 CHECK_NULL_PTR_RETURN_VALUE(request, 0); in AddAuthRequest() 58 *newRequest = *request; in AddAuthRequest() 69 NO_SANITIZE("cfi") int32_t GetAuthRequest(uint32_t requestId, AuthRequest *request) in GetAuthRequest() argument 71 CHECK_NULL_PTR_RETURN_VALUE(request, SOFTBUS_INVALID_PARAM); in GetAuthRequest() 80 *request = *item; in GetAuthRequest() 85 NO_SANITIZE("cfi") int32_t GetAuthRequestNoLock(uint32_t requestId, AuthRequest *request) in GetAuthRequestNoLock() argument [all …]
|
/foundation/communication/dsoftbus/sdk/bus_center/ipc/small/ |
D | bus_center_server_proxy.c | 165 IpcIo request = {0}; in ServerIpcGetAllOnlineNodeInfo() local 166 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcGetAllOnlineNodeInfo() 167 WriteString(&request, pkgName); in ServerIpcGetAllOnlineNodeInfo() 168 WriteUint32(&request, infoTypeLen); in ServerIpcGetAllOnlineNodeInfo() 172 …int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_GET_ALL_ONLINE_NODE_INFO, &request, &rep… in ServerIpcGetAllOnlineNodeInfo() 218 IpcIo request = {0}; in ServerIpcGetLocalDeviceInfo() local 219 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcGetLocalDeviceInfo() 220 WriteString(&request, pkgName); in ServerIpcGetLocalDeviceInfo() 221 WriteUint32(&request, infoTypeLen); in ServerIpcGetLocalDeviceInfo() 225 … int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_GET_LOCAL_DEVICE_INFO, &request, &reply, in ServerIpcGetLocalDeviceInfo() [all …]
|
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/ |
D | sdp_client.c | 181 SdpClientRequest *request = NULL; in SdpServiceSearch() local 191 request = MEM_MALLOC.alloc(sizeof(SdpClientRequest)); in SdpServiceSearch() 192 (void)memset_s(request, sizeof(SdpClientRequest), 0, sizeof(SdpClientRequest)); in SdpServiceSearch() 205 (void)memcpy_s(&request->addr, sizeof(BtAddr), addr, sizeof(BtAddr)); in SdpServiceSearch() 206 request->pduId = SDP_SERVICE_SEARCH_REQUEST; in SdpServiceSearch() 207 request->transactionId = SdpGetTransactionId(); in SdpServiceSearch() 208 request->resentFlag = false; in SdpServiceSearch() 209 request->packetState = SDP_PACKET_WAIT; in SdpServiceSearch() 210 request->packet = SdpBuildPacket(buffer, length); in SdpServiceSearch() 211 request->assemblePacket = NULL; in SdpServiceSearch() [all …]
|
/foundation/communication/dsoftbus/sdk/transmission/ipc/small/ |
D | trans_server_proxy.c | 108 IpcIo request = {0}; in ServerIpcCreateSessionServer() local 109 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcCreateSessionServer() 110 WriteString(&request, pkgName); in ServerIpcCreateSessionServer() 111 WriteString(&request, sessionName); in ServerIpcCreateSessionServer() 119 …int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_CREATE_SESSION_SERVER, &request, &ret, P… in ServerIpcCreateSessionServer() 137 IpcIo request = {0}; in ServerIpcRemoveSessionServer() local 138 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcRemoveSessionServer() 139 WriteString(&request, pkgName); in ServerIpcRemoveSessionServer() 140 WriteString(&request, sessionName); in ServerIpcRemoveSessionServer() 148 …int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_REMOVE_SESSION_SERVER, &request, &ret, P… in ServerIpcRemoveSessionServer() [all …]
|
/foundation/communication/dsoftbus/sdk/discovery/ipc/small/ |
D | disc_server_proxy.c | 82 IpcIo request = {0}; in ServerIpcPublishService() local 83 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcPublishService() 84 WriteString(&request, pkgName); in ServerIpcPublishService() 95 bool ret = WriteRawData(&request, (void*)&publishSerializer, sizeof(PublishSerializer)); in ServerIpcPublishService() 99 WriteString(&request, info->capability); in ServerIpcPublishService() 101 WriteString(&request, (const char *)(info->capabilityData)); in ServerIpcPublishService() 104 … int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_PUBLISH_SERVICE, &request, NULL, NULL); in ServerIpcPublishService() 124 IpcIo request = {0}; in ServerIpcUnPublishService() local 125 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcUnPublishService() 126 WriteString(&request, pkgName); in ServerIpcUnPublishService() [all …]
|
/foundation/ability/ability_runtime/test/unittest/implicit_start_processor_test/ |
D | implicit_start_processor_test.cpp | 59 AbilityRequest request; variable 61 bool res = processor->ImplicitStartAbility(request, userId); 76 AbilityRequest request; variable 80 request.want = want; 81 bool res = processor->CheckImplicitStartExtensionIsValid(request, extensionInfo); 96 AbilityRequest request; variable 100 request.want = want; 102 bool res = processor->CheckImplicitStartExtensionIsValid(request, extensionInfo); 117 AbilityRequest request; variable 121 request.want = want; [all …]
|
/foundation/communication/wifi/wifi/frameworks/native/src/ |
D | wifi_scan_proxy_lite.cpp | 207 IpcIo request; in SetScanControlInfo() local 211 IpcIoInit(&request, data, IPC_DATA_SIZE_BIG, MAX_IPC_OBJ_COUNT); in SetScanControlInfo() 212 …if (!WriteInterfaceToken(&request, DECLARE_INTERFACE_DESCRIPTOR_L1, DECLARE_INTERFACE_DESCRIPTOR_L… in SetScanControlInfo() 216 (void)WriteInt32(&request, 0); in SetScanControlInfo() 217 (void)WriteInt32(&request, info.scanForbidList.size()); in SetScanControlInfo() 219 (void)WriteInt32(&request, iter->scanScene); in SetScanControlInfo() 220 (void)WriteInt32(&request, static_cast<int>(iter->scanMode)); in SetScanControlInfo() 221 (void)WriteInt32(&request, iter->forbidTime); in SetScanControlInfo() 222 (void)WriteInt32(&request, iter->forbidCount); in SetScanControlInfo() 225 (void)WriteInt32(&request, info.scanIntervalList.size()); in SetScanControlInfo() [all …]
|
/foundation/bundlemanager/bundle_framework_lite/services/bundlemgr_lite/src/ |
D | bundle_daemon_client.cpp | 189 IpcIo request; in RegisterCallback() local 191 IpcIoInit(&request, data, MAX_IO_SIZE, 1); in RegisterCallback() 192 bool writeRemote = WriteRemoteObject(&request, &svcIdentity_); in RegisterCallback() 197 … while (bdsClient_->Invoke(bdsClient_, REGISTER_CALLBACK, &request, this, Notify) != EC_SUCCESS) { in RegisterCallback() 199 …while (bdsClient_->Invoke(bdsClient_, REGISTER_CALLBACK, &request, nullptr, nullptr) != EC_SUCCESS… in RegisterCallback() 210 IpcIo request; in RegisterCallback() local 212 IpcIoInit(&request, data, MAX_IO_SIZE, 0); in RegisterCallback() 215 WriteString(&request, innerStr.c_str()); in RegisterCallback() 217 WriteUint16(&request, strlen(firstPath)); in RegisterCallback() 220 WriteBool(&request, keepData); in RegisterCallback() [all …]
|
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/ |
D | ability_mgr_service_slite.cpp | 123 BOOL AbilityMgrServiceSlite::OnFeatureMessage(Feature *feature, Request *request) in OnFeatureMessage() argument 125 if (feature == nullptr || request == nullptr) { in OnFeatureMessage() 150 BOOL AbilityMgrServiceSlite::ServiceMessageHandle(Service *service, Request *request) in ServiceMessageHandle() argument 152 if (request == nullptr) { in ServiceMessageHandle() 156 if (request->msgId == START_ABILITY) { in ServiceMessageHandle() 157 auto *data = static_cast<StartAbilityData *>(request->data); in ServiceMessageHandle() 165 AdapterFree(request->data); in ServiceMessageHandle() 166 request->data = nullptr; in ServiceMessageHandle() 167 request->len = 0; in ServiceMessageHandle() 168 } else if (request->msgId == TERMINATE_ABILITY) { in ServiceMessageHandle() [all …]
|
/foundation/systemabilitymgr/samgr_lite/samgr/source/ |
D | message.c | 33 int32 SAMGR_SendRequest(const Identity *identity, const Request *request, Handler handler) in SAMGR_SendRequest() argument 35 if (request == NULL || identity == NULL) { in SAMGR_SendRequest() 39 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, NULL}; in SAMGR_SendRequest() 49 int32 SAMGR_SendResponse(const Request *request, const Response *response) in SAMGR_SendResponse() argument 52 if (request == NULL) { in SAMGR_SendResponse() 56 Exchange *exchange = GET_OBJECT(request, Exchange, request); in SAMGR_SendResponse() 74 exchange->handler(&exchange->request, &exchange->response); in SAMGR_SendResponse() 81 exchange->handler(&exchange->request, &exchange->response); in SAMGR_SendResponse() 106 if (exchange->request.len > 0) { in SAMGR_FreeMsg() 107 SAMGR_Free(exchange->request.data); in SAMGR_FreeMsg() [all …]
|
/foundation/ability/dmsfwk_lite/source/ |
D | dmslite_feature.c | 31 static BOOL OnMessage(Feature *feature, Request *request); 73 static BOOL OnMessage(Feature *feature, Request *request) in OnMessage() argument 75 if (feature == NULL || request == NULL) { in OnMessage() 80 switch (request->msgId) { in OnMessage() 82 if (request->data == NULL) { in OnMessage() 87 const RequestData *data = (const RequestData *)request->data; in OnMessage() 96 HandleSessionOpened(request->msgValue); in OnMessage() 99 HandleSessionClosed(request->msgValue); in OnMessage() 102 HandleBytesReceived(request->msgValue, request->data, request->len); in OnMessage() 105 HILOGW("[Unknown msgId = %d]", request->msgId); in OnMessage()
|
/foundation/ai/ai_engine/services/common/platform/os_wrapper/ipc/source/ |
D | aie_ipc.cpp | 51 void IpcIoPushSharedMemory(IpcIo *request, const DataInfo *dataInfo, const uid_t receiverUid) in IpcIoPushSharedMemory() argument 103 WriteInt32(request, shmId); in IpcIoPushSharedMemory() 104 WriteInt32(request, dataInfo->length); in IpcIoPushSharedMemory() 114 int IpcIoPopSharedMemory(IpcIo *request, DataInfo *dataInfo) in IpcIoPopSharedMemory() argument 118 ReadInt32(request, &shmId); in IpcIoPopSharedMemory() 119 ReadInt32(request, &(dataInfo->length)); // make sure all data are popped out. in IpcIoPopSharedMemory() 180 int IpcIoPopMemory(IpcIo *request, DataInfo *dataInfo) in IpcIoPopMemory() argument 184 ReadUint32(request, &dataBufSize); in IpcIoPopMemory() 185 void *dataBuf = (void *)ReadBuffer(request, dataBufSize); in IpcIoPopMemory() 211 void ParcelDataInfo(IpcIo *request, const DataInfo *dataInfo, const uid_t receiverUid) in ParcelDataInfo() argument [all …]
|
/foundation/multimodalinput/input/service/connect_manager/src/ |
D | multimodal_input_connect_def_parcel.cpp | 33 auto* request = new (std::nothrow) ConnectReqParcel(); in Unmarshalling() local 34 if (request == nullptr) { in Unmarshalling() 38 if (!in.ReadInt32(request->data.moduleId)) { in Unmarshalling() 39 delete request; in Unmarshalling() 40 request = nullptr; in Unmarshalling() 44 request->data.clientName = in.ReadString(); in Unmarshalling() 45 return request; in Unmarshalling()
|
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
D | implicit_start_processor.cpp | 78 int ImplicitStartProcessor::ImplicitStartAbility(AbilityRequest &request, int32_t userId) in ImplicitStartAbility() argument 80 HILOG_INFO("implicit start ability by type: %{public}d", request.callType); in ImplicitStartAbility() 87 auto ret = GenerateAbilityRequestByAction(userId, request, dialogAppInfos, deviceType, false); in ImplicitStartAbility() 94 auto startAbilityTask = [imp = shared_from_this(), request, userId, identity] in ImplicitStartAbility() 101 AAFwk::Want targetWant = request.want; in ImplicitStartAbility() 103 auto callBack = [imp, targetWant, request, userId]() -> int32_t { in ImplicitStartAbility() 104 return imp->ImplicitStartAbilityInner(targetWant, request, userId); in ImplicitStartAbility() 106 return imp->CallStartAbilityInner(userId, targetWant, callBack, request.callType); in ImplicitStartAbility() 113 want = sysDialogScheduler->GetTipsDialogWant(request.callerToken); in ImplicitStartAbility() 119 …ret = GenerateAbilityRequestByAction(userId, request, dialogAllAppInfos, deviceType, isMoreHapList… in ImplicitStartAbility() [all …]
|
/foundation/distributeddatamgr/relational_store/frameworks/native/dataability/src/ |
D | ishared_result_set_proxy.cpp | 56 MessageParcel request; in GetAllColumnNames() local 57 request.WriteInterfaceToken(GetDescriptor()); in GetAllColumnNames() 61 static_cast<uint32_t>(ResultSetCode::FUNC_GET_ALL_COLUMN_NAMES), request, reply, msgOption); in GetAllColumnNames() 85 MessageParcel request; in GetRowCount() local 86 request.WriteInterfaceToken(GetDescriptor()); in GetRowCount() 90 static_cast<uint32_t>(ResultSetCode::FUNC_GET_ROW_COUNT), request, reply, msgOption); in GetRowCount() 109 MessageParcel request; in OnGo() local 110 request.WriteInterfaceToken(GetDescriptor()); in OnGo() 111 request.WriteInt32(oldRowIndex); in OnGo() 112 request.WriteInt32(newRowIndex); in OnGo() [all …]
|
/foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/slite/ |
D | abilityms_slite_client.cpp | 55 int32_t AbilityMsClient::SendRequestToAms(Request &request) const in SendRequestToAms() 59 int32_t ret = SAMGR_SendRequest(identity_, &request, nullptr); in SendRequestToAms() 104 Request request = { in StartAbility() local 110 return SendRequestToAms(request); in StartAbility() 118 Request request = { in TerminateAbility() local 124 return SendRequestToAms(request); in TerminateAbility() 129 Request request = { in TerminateMission() local 135 return SendRequestToAms(request); in TerminateMission() 147 Request request = { in TerminateAll() local 153 return SendRequestToAms(request); in TerminateAll() [all …]
|
/foundation/communication/dsoftbus/core/connection/p2p/negotiation/src/ |
D | p2plink_json_payload.c | 92 NO_SANITIZE("cfi") int32_t P2pLinkPackRequestMsg(const P2pRequestMsg *request, P2pContentType type,… in P2pLinkPackRequestMsg() argument 95 if (request == NULL || data == NULL) { in P2pLinkPackRequestMsg() 101 GoInfo *goInfo = (GoInfo *)(request->data); in P2pLinkPackRequestMsg() 107 GcInfo *gcInfo = (GcInfo *)(request->data); in P2pLinkPackRequestMsg() 114 if (!AddNumberToJsonObject(data, KEY_CONTENT_TYPE, request->contentType) || in P2pLinkPackRequestMsg() 115 !AddNumberToJsonObject(data, KEY_COMMAND_TYPE, request->cmdType) || in P2pLinkPackRequestMsg() 116 !AddNumberToJsonObject(data, KEY_VERSION, request->version) || in P2pLinkPackRequestMsg() 117 !AddNumberToJsonObject(data, KEY_ROLE, request->role) || in P2pLinkPackRequestMsg() 118 !AddNumberToJsonObject(data, KEY_EXPECTED_ROLE, request->expectedRole) || in P2pLinkPackRequestMsg() 119 !AddBoolToJsonObject(data, KEY_BRIDGE_SUPPORTED, request->isbridgeSupport) || in P2pLinkPackRequestMsg() [all …]
|
/foundation/ai/ai_engine/services/server/server_executor/source/ |
D | async_msg_handler.cpp | 40 IRequest *request = task.request; in Process() local 41 if (request == nullptr) { in Process() 46 ResGuard<IRequest> guardReq(request); in Process() 47 return pluginAlgorithm_->AsyncProcess(request, this); in Process() 71 int AsyncMsgHandler::SendRequest(IRequest *request) in SendRequest() argument 73 if (request == nullptr) { in SendRequest() 86 int retCode = futureFactory->CreateFuture(request); in SendRequest() 92 Task task(this, request, nullptr); in SendRequest()
|
/foundation/multimedia/histreamer/engine/plugin/plugins/source/http_source/monitor/ |
D | download_monitor.cpp | 31 std::shared_ptr<DownloadRequest>& request) { in DownloadMonitor() argument 32 …adStatus(std::forward<decltype(downloader)>(downloader), std::forward<decltype(request)>(request)); in DownloadMonitor() 58 if (task.request && task.function) { in HttpMonitorLoop() 143 bool DownloadMonitor::NeedRetry(const std::shared_ptr<DownloadRequest>& request) in NeedRetry() argument 145 auto clientError = request->GetClientError(); in NeedRetry() 146 auto serverError = request->GetServerError(); in NeedRetry() 147 auto retryTimes = request->GetRetryTimes(); in NeedRetry() 172 std::shared_ptr<DownloadRequest>& request) in OnDownloadStatus() argument 174 …FALSE_RETURN_MSG(downloader != nullptr, "downloader is null, url is " PUBLIC_LOG_S, request->GetUr… in OnDownloadStatus() 175 if (NeedRetry(request)) { in OnDownloadStatus() [all …]
|
/foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
D | ishared_result_set_proxy.cpp | 55 MessageParcel request; in GetAllColumnNames() local 56 request.WriteInterfaceToken(GetDescriptor()); in GetAllColumnNames() 60 …static_cast<uint32_t>(ISharedResultInterfaceCode::FUNC_GET_ALL_COLUMN_NAMES), request, reply, msgO… in GetAllColumnNames() 83 MessageParcel request; in GetRowCount() local 84 request.WriteInterfaceToken(GetDescriptor()); in GetRowCount() 88 … static_cast<uint32_t>(ISharedResultInterfaceCode::FUNC_GET_ROW_COUNT), request, reply, msgOption); in GetRowCount() 106 MessageParcel request; in OnGo() local 107 request.WriteInterfaceToken(GetDescriptor()); in OnGo() 108 request.WriteInt32(oldRowIndex); in OnGo() 109 request.WriteInt32(newRowIndex); in OnGo() [all …]
|
/foundation/distributedhardware/device_manager/services/service/src/ipc/lite/ |
D | ipc_cmd_parser.cpp | 31 ON_IPC_SET_REQUEST(SERVER_DEVICE_STATE_NOTIFY, std::shared_ptr<IpcReq> pBaseReq, IpcIo &request, ui… in ON_IPC_SET_REQUEST() argument 39 IpcIoInit(&request, buffer, buffLen, 0); in ON_IPC_SET_REQUEST() 40 WriteString(&request, pkgName.c_str()); in ON_IPC_SET_REQUEST() 41 WriteInt32(&request, deviceState); in ON_IPC_SET_REQUEST() 42 bool ret = WriteRawData(&request, &deviceInfo, sizeof(DmDeviceInfo)); in ON_IPC_SET_REQUEST() 61 ON_IPC_SET_REQUEST(SERVER_DEVICE_FOUND, std::shared_ptr<IpcReq> pBaseReq, IpcIo &request, uint8_t *… in ON_IPC_SET_REQUEST() argument 69 IpcIoInit(&request, buffer, buffLen, 0); in ON_IPC_SET_REQUEST() 70 WriteString(&request, pkgName.c_str()); in ON_IPC_SET_REQUEST() 71 WriteUint16(&request, subscribeId); in ON_IPC_SET_REQUEST() 72 bool ret = WriteRawData(&request, &deviceInfo, sizeof(DmDeviceInfo)); in ON_IPC_SET_REQUEST() [all …]
|
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/aging/ |
D | aging_handler_chain.cpp | 45 bool AgingHandlerChain::Process(AgingRequest &request) const in Process() 47 if (!request.IsReachStartAgingThreshold()) { in Process() 54 request.SetAgingCleanType(agingCleanType); in Process() 55 isPassed = InnerProcess(request); in Process() 65 bool AgingHandlerChain::InnerProcess(AgingRequest &request) const in InnerProcess() 69 isPassed = !handler->Process(request); in InnerProcess() 71 isPassed, static_cast<AgingCleanType>(request.GetAgingCleanType())); in InnerProcess()
|