| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/ |
| H A D | lnn_lane_query.c | 82 static int32_t GetLaneResource(LaneTransType transType, LaneLinkType *optLink, uint32_t *linkNum, in GetLaneResource() argument
89 switch (transType) { in GetLaneResource()
105 LNN_LOGE(LNN_LANE, "lane type is not supported, transType=%{public}d", transType); in GetLaneResource()
316 int32_t ret = GetLaneResource(queryInfo->transType, optLink, &linkNum, isHighBand); in QueryByRequireLink()
336 int32_t ret = GetLaneResource(queryInfo->transType, optLink, &linkNum, false); in QueryByDefaultLink()
358 LNN_LOGI(LNN_LANE, "Query lane by prefer linklist, transType=%{public}d, minBW=%{public}d", in QueryLaneResource()
359 queryInfo->transType, qosInfo->minBW); in QueryLaneResource()
362 LNN_LOGI(LNN_LANE, "Query lane by default linklist, transType=%{public}d", queryInfo->transType); in QueryLaneResource()
[all...] |
| H A D | lnn_select_rule.c | 448 static int32_t CheckLaneValid(const char *networkId, LaneLinkType linkType, LaneTransType transType) in CheckLaneValid() argument
462 bool isStream = (transType == LANE_T_RAW_STREAM || transType == LANE_T_COMMON_VIDEO || in CheckLaneValid()
463 transType == LANE_T_COMMON_VOICE); in CheckLaneValid()
504 if ((CheckLaneValid(networkId, g_laneBandWidth[bandWidthType][i], request->transType) == SOFTBUS_OK)) { in DecideOptimalLinks()
532 if ((CheckLaneValid(networkId, g_retryLaneList[bandWidthType][i], request->transType) == SOFTBUS_OK) && in DecideRetryLinks()
604 (CheckLaneValid(peerNetWorkId, LANE_HML, request->transType) != SOFTBUS_OK)) { in UpdateHmlPriority()
687 return CheckLaneValid(networkId, g_laneBandWidth[bandWidthType][0], request->transType); in GetErrCodeOfRequest()
|
| H A D | lnn_lane_select.c | 75 static int32_t GetLaneDefaultLink(LaneTransType transType, LaneLinkType *optLink, uint32_t *linkNum) in GetLaneDefaultLink() argument
81 switch (transType) { in GetLaneDefaultLink()
97 LNN_LOGE(LNN_LANE, "lane type is not supported. type=%{public}d", transType); in GetLaneDefaultLink()
190 bool isStream = (request->transType == LANE_T_RAW_STREAM || in SelectByPreferredLink()
191 request->transType == LANE_T_COMMON_VIDEO || in SelectByPreferredLink()
192 request->transType == LANE_T_COMMON_VOICE); in SelectByPreferredLink()
220 int32_t ret = GetLaneDefaultLink(request->transType, optionalLink, &optLinkNum); in SelectByDefaultLink()
|
| H A D | lnn_trans_lane.c | 92 LaneTransType transType; member
286 linkNode->transType = request->transType; in TriggerLink()
408 linkNode->transType = allocInfo->transType; in TriggerLinkWithQos()
468 selectParam.transType = allocInfo->transType; in AllocValidLane()
511 allocInfo->transType = allocInfoExt->commInfo.transType; in LaneAllocInfoConvert()
635 info.commInfo.transType in ProcessSpecifiedLink()
[all...] |
| H A D | lnn_lane_model.c | 68 (param->transType << TRANS_TYPE_SHIFT) | (param->priority << PRIORITY_SHIFT)); in GenerateLaneProfileId()
149 param.transType = profile->content; in BindLaneIdToProfile()
|
| H A D | lnn_lane.c | 315 LNN_LOGI(LNN_LANE, "alloc lane enter, laneReqId=%{public}u, laneType=%{public}d, transType=%{public}d, " in LnnAllocLane()
317 laneReqId, allocInfo->type, allocInfo->transType, in LnnAllocLane()
364 "transType=%{public}d, minBW=%{public}u, maxLaneLatency=%{public}u, minLaneLatency=%{public}u", in LnnReAllocLane()
365 laneReqId, laneId, allocInfo->type, allocInfo->transType, in LnnReAllocLane()
474 LNN_LOGI(LNN_LANE, "laneRequest, laneReqId=%{public}u, laneType=%{public}d, transType=%{public}d", in LnnRequestLane()
475 laneReqId, request->type, request->requestInfo.trans.transType); in LnnRequestLane()
|
| H A D | lnn_ctrl_lane.c | 248 requestInfo->transType = allocInfo->transType; in CreateLinkRequestNode()
|
| /foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/include/ |
| H A D | lnn_lane_interface.h | 166 LaneTransType transType; member
188 LaneTransType transType; member
211 LaneTransType transType; member
236 LaneTransType transType; member
244 LaneTransType transType; member
|
| H A D | lnn_lane_select.h | 27 LaneTransType transType; member
|
| H A D | lnn_lane_model.h | 27 uint32_t transType : 4; member
|
| H A D | lnn_lane_link.h | 57 LaneTransType transType; member
|
| /foundation/communication/dsoftbus/tests/core/bus_center/lnn/lane/src/ |
| H A D | lnn_lane_query_test.cpp | 113 query.transType = LANE_T_BYTE; in HWTEST_F()
144 query.transType = LANE_T_BYTE; in HWTEST_F()
170 query.transType = LANE_T_MSG; in HWTEST_F()
194 query.transType = LANE_T_FILE; in HWTEST_F()
222 query.transType = LANE_T_RAW_STREAM; in HWTEST_F()
229 query.transType = LANE_T_COMMON_VIDEO; in HWTEST_F()
233 query.transType = LANE_T_COMMON_VOICE; in HWTEST_F()
250 query.transType = LANE_T_RAW_STREAM; in HWTEST_F()
271 LaneTransType transType = LANE_T_MIX; in HWTEST_F() local
272 int32_t ret = GetLaneResource(transType, linkLis in HWTEST_F()
[all...] |
| H A D | lnn_lane_test.cpp | 355 static void CreateAllocInfoForAllocTest(LaneTransType transType, uint32_t minBW, uint32_t maxLaneLatency, in CreateAllocInfoForAllocTest() argument
362 allocInfo->transType = transType; in CreateAllocInfoForAllocTest()
1278 param.transType = LANE_T_FILE; in HWTEST_F()
1313 selectParam.transType = LANE_T_FILE; in HWTEST_F()
1339 selectParam.transType = LANE_T_MIX; in HWTEST_F()
1357 selectParam.transType = LANE_T_FILE; in HWTEST_F()
1396 selectParam.transType = LANE_T_FILE; in HWTEST_F()
1440 request.transType = LANE_T_FILE; in HWTEST_F()
1474 request.transType in HWTEST_F()
[all...] |
| /foundation/communication/dsoftbus/tests/core/bus_center/lnn/unittest/ |
| H A D | lane_test.cpp | 264 selectParam.transType = LANE_T_FILE; in HWTEST_F()
283 selectParam.transType = LANE_T_FILE; in HWTEST_F()
304 selectParam.transType = LANE_T_BYTE; in HWTEST_F()
326 selectParam.transType = LANE_T_BYTE; in HWTEST_F()
346 reqInfo.transType = LANE_T_BYTE; in HWTEST_F()
371 reqInfo.transType = LANE_T_BYTE; in HWTEST_F()
396 allocInfo.transType = LANE_T_RAW_STREAM; in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_natural_store_connection.h | 147 int StartTransactionInner(bool isCommitNotify, TransactType transType = TransactType::DEFERRED);
149 int StartTransactionNormally(bool isCommitNotify, TransactType transType = TransactType::DEFERRED);
|
| H A D | rd_single_ver_natural_store_connection.cpp | 629 int RdSingleVerNaturalStoreConnection::StartTransactionInner(bool isCommitNotify, TransactType transType) in StartTransactionInner() argument
634 return StartTransactionNormally(isCommitNotify, transType); in StartTransactionInner()
638 int RdSingleVerNaturalStoreConnection::StartTransactionNormally(bool isCommitNotify, TransactType transType) in StartTransactionNormally() argument
661 errCode = handle->StartTransaction(transType); in StartTransactionNormally()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_connection.h | 154 int StartTransactionInner(TransactType transType = TransactType::DEFERRED);
205 int StartTransactionInCacheMode(TransactType transType = TransactType::DEFERRED);
206 int StartTransactionNormally(TransactType transType = TransactType::DEFERRED);
|
| H A D | sqlite_single_ver_natural_store_connection.cpp | 1218 int SQLiteSingleVerNaturalStoreConnection::StartTransactionInner(TransactType transType) in StartTransactionInner() argument
1221 return StartTransactionInCacheMode(transType); in StartTransactionInner()
1223 return StartTransactionNormally(transType); in StartTransactionInner()
1227 int SQLiteSingleVerNaturalStoreConnection::StartTransactionInCacheMode(TransactType transType) in StartTransactionInCacheMode() argument
1239 errCode = handle->StartTransaction(transType); in StartTransactionInCacheMode()
1250 int SQLiteSingleVerNaturalStoreConnection::StartTransactionNormally(TransactType transType) in StartTransactionNormally() argument
1287 errCode = handle->StartTransaction(transType); in StartTransactionNormally()
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/common/src/ |
| H A D | trans_channel_common.c | 145 LaneTransType transType = TransGetLaneTransTypeBySession(param); in TransGetChannelType() local
146 if (transType == LANE_T_BUTT) { in TransGetChannelType()
152 } else if (transType == LANE_T_FILE || transType == LANE_T_COMMON_VIDEO || transType == LANE_T_COMMON_VOICE || in TransGetChannelType()
153 transType == LANE_T_RAW_STREAM) { in TransGetChannelType()
155 } else if ((transType == LANE_T_MSG) && (type != LANE_P2P) && (type != LANE_P2P_REUSE) && (type != LANE_HML)) { in TransGetChannelType()
|
| H A D | trans_lane_pending_ctl.c | 285 TransEventExtra *extra, const SessionParam *param, uint32_t laneHandle, LaneTransType transType, int32_t ret) in BuildTransEventExtra()
292 extra->laneTransType = transType; in BuildTransEventExtra()
620 LaneTransType transType) in CheckSocketChannelState()
627 BuildTransEventExtra(extra, param, laneHandle, transType, SOFTBUS_TRANS_STOP_BIND_BY_CANCEL); in CheckSocketChannelState()
653 LaneTransType transType = (LaneTransType)TransGetLaneTransTypeBySession(¶m); in TransOnAsyncLaneSuccess() local
656 BuildTransEventExtra(&extra, ¶m, laneHandle, transType, SOFTBUS_OK); in TransOnAsyncLaneSuccess()
658 ret = CheckSocketChannelState(laneHandle, ¶m, &extra, transType); in TransOnAsyncLaneSuccess()
714 LaneTransType transType = (LaneTransType)TransGetLaneTransTypeBySession(¶m); in TransOnAsyncLaneFail() local
717 BuildTransEventExtra(&extra, ¶m, laneHandle, transType, reason); in TransOnAsyncLaneFail()
972 LaneTransType transType in GetAllocInfoBySessionParam() local
284 BuildTransEventExtra( TransEventExtra *extra, const SessionParam *param, uint32_t laneHandle, LaneTransType transType, int32_t ret) BuildTransEventExtra() argument
619 CheckSocketChannelState(uint32_t laneHandle, const SessionParam *param, TransEventExtra *extra, LaneTransType transType) CheckSocketChannelState() argument
1023 LaneTransType transType = (LaneTransType)TransGetLaneTransTypeBySession(param); GetRequestOptionBySessionParam() local
[all...] |
| /foundation/communication/ipc/services/dbinder/c/include/ |
| H A D | dbinder_types.h | 104 uint32_t transType; member
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| H A D | hci.c | 338 uint8_t transType = (type == PACKET_TYPE_EVENT) ? TRANSMISSON_TYPE_C2H_EVENT : TRANSMISSON_TYPE_C2H_DATA; in HciOnReceivedHciPacket() local
339 g_transmissionCallback(transType, btPacket->data, btPacket->size); in HciOnReceivedHciPacket()
|
| /foundation/communication/ipc/services/dbinder/c/src/ |
| H A D | dbinder_service.c | 245 .transType = DATABUS_TYPE, in SendEntryToRemote()
602 switch (replyMessage.transType) { in OnRemoteInvokerMessage()
612 RPC_LOG_ERROR("OnRemoteInvokerMessage msg transType invalid"); in OnRemoteInvokerMessage()
703 session->type = replyMessage->transType; in MakeSessionByReplyMessage()
|
| /foundation/communication/ipc/services/dbinder/dbinder_service/src/ |
| H A D | dbinder_service.cpp | 403 message->transType = GetRemoteTransType(); in CreateMessage()
571 if (replyMessage->transType != IRemoteObject::DATABUS_TYPE) { in LoadSystemAbilityComplete()
602 replyMessage->transType = reason; // reuse transType send back error code in SendReplyMessageToRemote()
915 static_cast<int32_t>(replyMessage->stubIndex), replyMessage->transType, replyMessage->seqNumber); in OnRemoteErrorMessage()
977 session->type = replyMessage->transType; in InitializeSession()
|
| /foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/ |
| H A D | RdbStoreTransJsunit.test.js | 33 async function insertInThread(context, transType, insertCount = 1) {
37 rdbTrans = await rdbStore.createTransaction(transType);
63 async function queryInThread(context, transType, querySql) {
67 rdbTrans = await rdbStore.createTransaction(transType);
|