Home
last modified time | relevance | path

Searched refs:seq (Results 1 – 25 of 237) sorted by relevance

12345678910

/ohos5.0/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_pending_packet.c30 int64_t seq; member
55 if (pending->id == id && pending->seq == seq) { in ConnBrCreateBrPendingPacket()
69 pending->seq = seq; in ConnBrCreateBrPendingPacket()
95 if (pending->id == id && pending->seq == seq) { in ConnBrDelBrPendingPacket()
116 if (item->id == id && item->seq == seq) { in ConnBrGetBrPendingPacket()
167 if (item->seq == seq && item->id == id) { in ConnBrSetBrPendingPacket()
216 .seq = peerSeq, in ConnBrOnAckRequest()
222 if (seq < 0) { in ConnBrOnAckRequest()
227 return (int32_t)seq; in ConnBrOnAckRequest()
235 uint64_t seq = 0; in ConnBrOnAckResponse() local
[all …]
H A Dsoftbus_conn_br_trans.c200 int64_t seq = ctlMsgSeqGenerator++; in ConnBrPackCtlMessage() local
222 head.seq = seq; in ConnBrPackCtlMessage()
245 return seq; in ConnBrPackCtlMessage()
262 connectionId, pid, len, flag, module, seq); in ConnBrPostBytes()
268 connectionId, pid, len, flag, module, seq); in ConnBrPostBytes()
278 connectionId, pid, len, flag, module, seq); in ConnBrPostBytes()
309 connectionId, pid, len, flag, module, seq); in ConnBrPostBytes()
319 node->seq = seq; in ConnBrPostBytes()
333 connectionId, pid, len, flag, module, seq); in ConnBrPostBytes()
363 .seq = connection->sequence, in SendAckUnsafe()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_trans.c46 header->seq = ntohl(tmp->seq); in UnpackTransHeader()
73 buffer->seq = 0; in DiscardBuffer()
94 if (buffer->seq != 0) { in ConnGattTransRecv()
126 if (buffer->seq != 0 && (buffer->seq != header.seq || buffer->total != header.total)) { in ConnGattTransRecv()
160 … connectionId, dataLen, header.seq, header.total, header.size, header.offset, it->header.seq, in ConnGattTransRecv()
190 buffer->seq = header.seq; in ConnGattTransRecv()
293 header->seq = htonl(sequence); in ConnGattTransSend()
375 node->seq = seq; in ConnBlePostBytesInner()
450 header->seq = seq; in ConnBlePackCtrlMsgHeader()
454 return seq; in ConnBlePackCtrlMsgHeader()
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/ble/mock/
H A Dconnection_ble_client_mock.cpp40 int64_t seq = 10; in ConnGattTransRecvReturnConnModule() local
41 head->seq = seq; in ConnGattTransRecvReturnConnModule()
53 int64_t seq = 10; in ConnGattTransRecvReturnConnModule1() local
54 head->seq = seq; in ConnGattTransRecvReturnConnModule1()
65 int64_t seq = 10; in ConnGattTransRecvReturnOldNearby() local
66 head->seq = seq; in ConnGattTransRecvReturnOldNearby()
77 int64_t seq = 10; in ConnGattTransRecvReturnDefult() local
78 head->seq = seq; in ConnGattTransRecvReturnDefult()
89 int64_t seq = 10; in ActionOfConnGattTransRecv() local
90 head->seq = seq; in ActionOfConnGattTransRecv()
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/
H A Dclient_trans_pending_test.cpp65 uint64_t seq = 0; variable
67 int ret = CreatePendingPacket(id, seq);
70 ret = CreatePendingPacket(TEST_SESSION_ID, seq);
76 ret = CreatePendingPacket(id, seq);
80 ret = GetPendingPacketData(id, seq, waitMillis, true, nullptr);
93 ret = SetPendingPacketData(id, seq, &pendDate);
96 ret = SetPendingPacketData(id, seq, nullptr);
102 ret = SetPendingPacketData(TEST_SESSION_ID_SECOND, seq, &pendDate);
108 ret = GetPendingPacketData(id, seq, waitMillis, false, &pendDate);
114 DeletePendingPacket(id, seq);
[all …]
/ohos5.0/base/hiviewdfx/hiview/base/event_store/sequence/
H A Dsys_event_sequence_mgr.cpp60 int64_t seq = 0; in SysEventSequenceManager() local
61 ReadSeqFromFile(seq); in SysEventSequenceManager()
62 curSeq_.store(seq, std::memory_order_release); in SysEventSequenceManager()
65 void SysEventSequenceManager::SetSequence(int64_t seq) in SetSequence() argument
67 curSeq_.store(seq, std::memory_order_release); in SetSequence()
68 WriteSeqToFile(seq); in SetSequence()
76 void SysEventSequenceManager::WriteSeqToFile(int64_t seq) in WriteSeqToFile() argument
79 std::string content(std::to_string(seq)); in WriteSeqToFile()
85 void SysEventSequenceManager::ReadSeqFromFile(int64_t& seq) in ReadSeqFromFile() argument
93 seq = static_cast<int64_t>(strtoll(content.c_str(), nullptr, 0)); in ReadSeqFromFile()
[all …]
/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_pending.c30 uint64_t seq; member
55 static int32_t CheckPendingPacketExisted(uint32_t id, uint64_t seq) in CheckPendingPacketExisted() argument
63 if (pending->id == id && pending->seq == seq) { in CheckPendingPacketExisted()
73 int32_t CreatePendingPacket(uint32_t id, uint64_t seq) in CreatePendingPacket() argument
75 int32_t ret = CheckPendingPacketExisted(id, seq); in CreatePendingPacket()
88 pending->seq = seq; in CreatePendingPacket()
114 void DeletePendingPacket(uint32_t id, uint64_t seq) in DeletePendingPacket() argument
122 if (pending->id == id && pending->seq == seq) { in DeletePendingPacket()
181 if (item->id == id && item->seq == seq) { in GetPendingPacketData()
210 int32_t SetPendingPacketData(uint32_t id, uint64_t seq, const TransPendData *data) in SetPendingPacketData() argument
[all …]
H A Dclient_trans_proxy_file_helper.c62 *(uint32_t *)(data + FRAME_HEAD_LEN) = SoftBusHtoLl(seq); in SendFileTransResult()
77 if (seq == NULL || result == NULL || side == NULL) { in UnpackFileTransResultFrame()
92 (*seq) = SoftBusLtoHl((*(uint32_t *)(data + FRAME_HEAD_LEN))); in UnpackFileTransResultFrame()
163 info->seq++; in PackReadFileData()
164 (*(uint32_t *)(fileFrame->fileData)) = SoftBusHtoLl(info->seq); in PackReadFileData()
204 (*(uint32_t *)(fileFrame->fileData)) = SoftBusHtoLl(seq); in PackReadFileRetransData()
208 FrameIndexToType((uint64_t)seq, info->frameNum)); in PackReadFileRetransData()
236 fileFrame->seq = SoftBusLtoHl((*(uint32_t *)(fileFrame->fileData))); in UnpackFileDataFrame()
252 fileFrame->seq = SoftBusLtoHl((*(uint32_t *)(fileFrame->fileData))); in UnpackFileDataFrame()
263 if ((info == NULL) || (seq <= 0)) { in RetransFileFrameBySeq()
[all …]
/ohos5.0/base/request/request/frameworks/js/napi/src/
H A Djs_task.cpp90 REQUEST_HILOGI("JsUpload seq %{public}d", seq); in JsUpload()
97 return JsMain(env, info, Version::API8, seq); in JsUpload()
103 REQUEST_HILOGI("JsDownload seq %{public}d", seq); in JsDownload()
107 return JsMain(env, info, Version::API8, seq); in JsDownload()
114 return JsMain(env, info, Version::API9, seq); in JsRequestFile()
120 REQUEST_HILOGI("create seq %{public}d", seq); in JsCreate()
121 return JsMain(env, info, Version::API10, seq); in JsCreate()
139 seq, status); in JsMain()
146 auto exec = [context, seq]() { in JsMain()
194 seq); in CreateExec()
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/bus_center/fuzztest/ispassseqcheck_fuzzer/
H A Dispassseqcheck_fuzzer.cpp47 int32_t seq = *const_cast<int32_t *>(reinterpret_cast<const int32_t *>(rawData)); in IsPassSeqCheckSwitch() local
53 seqInfo.maxSeq = seq; in IsPassSeqCheckSwitch()
55 IsPassSeqCheck(&seqInfo, seq); in IsPassSeqCheckSwitch()
59 seqInfo.minSeq = seq; in IsPassSeqCheckSwitch()
62 IsPassSeqCheck(&seqInfo, seq); in IsPassSeqCheckSwitch()
66 seqInfo.minSeq = seq; in IsPassSeqCheckSwitch()
67 seqInfo.maxSeq = seq; in IsPassSeqCheckSwitch()
69 IsPassSeqCheck(&seqInfo, seq); in IsPassSeqCheckSwitch()
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dblockaware.h56 uint32_t seq; member
208 uint32_t seq; in seqlock_start_read() local
210 seq = *reinterpret_cast<const volatile uint32_t *>(seq_ptr); in seqlock_start_read()
211 if ((seq & 1U) == 0U) { in seqlock_start_read()
217 return seq; in seqlock_start_read()
229 uint32_t seq; in BlockawareLoadSnapshot() local
231 seq = seqlock_start_read(&kinfoPage->seq); in BlockawareLoadSnapshot()
233 } while (!seqlock_check(&kinfoPage->seq, seq)); in BlockawareLoadSnapshot()
/ohos5.0/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Dapp_domain_verify_task_mgr.cpp32 …AutoSeqReleaser(SafeMap<uint32_t, std::shared_ptr<IHttpTask>>* map, uint32_t seq) : seq_(seq), map… in AutoSeqReleaser() argument
118 auto seq = httpTask->GetTaskId(); in GetTaskWrapper() local
121 AutoSeqReleaser releaser(taskMap, seq); in GetTaskWrapper()
133 …[&taskMap, &httpTask, &promise, seq](const HttpClientRequest& request, const HttpClientResponse& r… in GetTaskWrapper()
136 AutoSeqReleaser releaser(taskMap, seq); in GetTaskWrapper()
139 clientTask->OnFail([&taskMap, httpTask, &promise, seq](const HttpClientRequest& request, in GetTaskWrapper()
143 AutoSeqReleaser releaser(taskMap, seq); in GetTaskWrapper()
147 …[&taskMap, &httpTask, &promise, seq](const HttpClientRequest& request, const HttpClientResponse& r… in GetTaskWrapper()
150 AutoSeqReleaser releaser(taskMap, seq); in GetTaskWrapper()
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_p2p_test.cpp284 int64_t seq = 1; variable
323 int64_t seq = 1; variable
363 int64_t seq = 1; variable
369 data->seq = 1;
374 OnAuthMsgProc(authHandle, flags, seq, nullptr);
377 OnAuthMsgProc(authHandle, flags, seq, nullptr);
425 int64_t seq = 1; variable
605 int32_t seq = NOAMAL_SEQ; variable
606 ret = AddP2pOrHmlTrigger(fd, myAddr, seq);
623 int32_t seq = NOAMAL_SEQ; variable
[all …]
/ohos5.0/base/hiviewdfx/hisysevent/adapter/native/idl/src/
H A Dquery_sys_event_callback_stub.cpp54 std::vector<int64_t> seq; in OnRemoteRequest() local
55 ret = data.ReadInt64Vector(&seq); in OnRemoteRequest()
60 OnQuery(sysEvent, seq); in OnRemoteRequest()
76 int64_t seq = 0; in OnRemoteRequest() local
77 ret = data.ReadInt64(seq); in OnRemoteRequest()
82 OnComplete(reason, total, seq); in OnRemoteRequest()
H A Dhisysevent_query_proxy.cpp23 const ::std::vector<int64_t>& seq) in OnQuery()
30 queryCallback->OnQuery(destSysEvents, seq); in OnQuery()
34 void HiSysEventQueryProxy::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
37 queryCallback->OnComplete(reason, total, seq); in OnComplete()
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/clienttranspending_fuzzer/
H A Dclienttranspending_fuzzer.cpp37 uint64_t seq = *(reinterpret_cast<const uint64_t*>(data)); in ClientTransPendingTest() local
42 CreatePendingPacket(id, seq); in ClientTransPendingTest()
43 DeletePendingPacket(id, seq); in ClientTransPendingTest()
44 GetPendingPacketData(id, seq, waitMillis, isDelete, &pendDate); in ClientTransPendingTest()
45 SetPendingPacketData(id, seq, &pendDate); in ClientTransPendingTest()
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_p2p.c374 authHandle.authId, module, flag, seq); in SendAuthData()
378 .seq = seq, in SendAuthData()
703 conn = GetSessionConnByReq(seq); in AddHmlTrigger()
721 return AddHmlTrigger(fd, myAddr, seq); in AddP2pOrHmlTrigger()
745 conn = GetSessionConnByReq(seq); in OnVerifyP2pReply()
782 if (AddP2pOrHmlTrigger(fd, myAddr, seq) != SOFTBUS_OK) { in OnVerifyP2pReply()
822 data->module, data->seq, data->len); in OnAuthDataRecv()
833 OnAuthMsgProc(authHandle, data->flag, data->seq, json); in OnAuthDataRecv()
1044 uint64_t seq = TransTdcGetNewSeqId(); in OpenP2pDirectChannel() local
1045 if (seq == INVALID_SEQ_ID) { in OpenP2pDirectChannel()
[all …]
/ohos5.0/drivers/hdf_core/framework/model/misc/vibrator/driver/src/
H A Dvibrator_haptic.c34 uint32_t *seq = NULL; in MallocEffectNode() local
42 seq = (uint32_t *)OsalMemCalloc(seqSize); in MallocEffectNode()
43 if (seq == NULL) { in MallocEffectNode()
51 OsalMemFree(seq); in MallocEffectNode()
54 node->seq = seq; in MallocEffectNode()
98 ret = parser->GetUint32Array(childNode, "seq", effectNode->seq, count, 0); in ParserHapticEffect()
114 OsalMemFree(effectNode->seq); in ParserHapticEffect()
274 hapticData->currentEffectSeq = &(pos->seq[0]); in GetHapticSeqByEffect()
390 if (pos->seq != NULL) { in FreeHapticConfig()
391 OsalMemFree(pos->seq); in FreeHapticConfig()
[all …]
/ohos5.0/base/notification/distributed_notification_service/services/ans/src/notification_smart_reminder/
H A Dreminder_affected.cpp95 for (int32_t seq = 0; seq < DistributedDeviceStatus::STATUS_SIZE; seq++) { in ValidStatus() local
96 if (strStatus.at(seq) != STATUS_DEFAULT && in ValidStatus()
97 strStatus.at(seq) != STATUS_ENABLE && strStatus.at(seq) != STATUS_DISABLE) { in ValidStatus()
/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/
H A Dclient_trans_pending.h32 int32_t CreatePendingPacket(uint32_t id, uint64_t seq);
33 void DeletePendingPacket(uint32_t id, uint64_t seq);
35 int32_t GetPendingPacketData(uint32_t id, uint64_t seq, uint32_t waitMillis, bool isDelete, TransPe…
36 int32_t SetPendingPacketData(uint32_t id, uint64_t seq, const TransPendData *data);
/ohos5.0/base/notification/distributed_notification_service/frameworks/ans/src/
H A Dnotification_flags.cpp229 for (int32_t seq = 0; seq < strReminderFlags.size(); seq++) { in GetReminderFlagsByString() local
230 if (!ValidCharReminderFlag(strReminderFlags[seq], seq)) { in GetReminderFlagsByString()
249 bool NotificationFlags::ValidCharReminderFlag(const char &charReminderFlag, const int32_t &seq) in ValidCharReminderFlag() argument
254 …if ((seq == SOUND_ENABLED_SEQ || seq == VIBRATION_ENABLED_SEQ) && charReminderFlag == CHAR_FLAG_ST… in ValidCharReminderFlag()
/ohos5.0/foundation/communication/dsoftbus/core/connection/br/include/
H A Dsoftbus_conn_br_pending_packet.h29 int32_t ConnBrCreateBrPendingPacket(uint32_t id, int64_t seq);
30 void ConnBrDelBrPendingPacket(uint32_t id, int64_t seq);
32 int32_t ConnBrGetBrPendingPacket(uint32_t id, int64_t seq, uint32_t waitMillis, void **data);
33 int32_t ConnBrSetBrPendingPacket(uint32_t id, int64_t seq, void *data);
/ohos5.0/foundation/communication/dsoftbus/adapter/common/bus_center/network/
H A Dlnn_linkwatch.c60 static int32_t ProcessNetlinkAnswer(struct nlmsghdr *answer, int32_t bufLen, uint32_t seq) in ProcessNetlinkAnswer() argument
72 if (hdr->nlmsg_seq != seq) { in ProcessNetlinkAnswer()
165 int32_t infoDataLen, seq; in LnnIsLinkReady() local
168 seq = time(NULL); in LnnIsLinkReady()
169 if (seq < 0) { in LnnIsLinkReady()
170 seq = 0; in LnnIsLinkReady()
172 req.hdr.nlmsg_seq = ++seq; in LnnIsLinkReady()
/ohos5.0/base/hiviewdfx/hiview/base/include/
H A Devent_priority_queue.h24 bool remove(uint64_t seq) in remove() argument
26 auto it = std::find_if(this->c.begin(), this->c.end(), [seq](T event) { in remove()
27 return event.seq == seq; in remove()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/br/
H A Dbr_mock.cpp122 int32_t ConnBrCreateBrPendingPacket(uint32_t id, int64_t seq) in ConnBrCreateBrPendingPacket() argument
124 return GetConnectionBrInterface()->ConnBrCreateBrPendingPacket(id, seq); in ConnBrCreateBrPendingPacket()
127 void ConnBrDelBrPendingPacket(uint32_t id, int64_t seq) in ConnBrDelBrPendingPacket() argument
129 return GetConnectionBrInterface()->ConnBrDelBrPendingPacket(id, seq); in ConnBrDelBrPendingPacket()
132 int32_t ConnBrGetBrPendingPacket(uint32_t id, int64_t seq, uint32_t waitMillis, void **data) in ConnBrGetBrPendingPacket() argument
134 return GetConnectionBrInterface()->ConnBrGetBrPendingPacket(id, seq, waitMillis, data); in ConnBrGetBrPendingPacket()

12345678910