/foundation/communication/netmanager_base/services/netmanagernative/bpf/src/ |
H A D | bitmap_manager.cpp | 491 uint32_t off = Rfind(tmpStart, mask, IPV4_BIT_COUNT - 1, 1); in GetIp4AndMask() local 492 if (off != IPV4_BIT_COUNT) { in GetIp4AndMask() 493 AddIp(tmpStart, off + 1, list); in GetIp4AndMask() 494 ChangeStart(off + 1, tmpStart); in GetIp4AndMask() 495 off = Rfind(startIpInt, mask, off, 0); in GetIp4AndMask() 496 while (off != IPV4_BIT_COUNT && off != mask) { in GetIp4AndMask() 497 AddIp(tmpStart, off + 1, list); in GetIp4AndMask() 498 ChangeStart(off in GetIp4AndMask() 628 uint32_t off = BIT_PER_BYTE - bits - 1; ChangeIp6Start() local 660 uint32_t off = RfindIp6(addr6Start, prefixlen, IPV6_BIT_COUNT - 1, 1); GetIp6AndMask() local [all...] |
/foundation/communication/netmanager_base/test/netcommon/unittest/net_common_test/ |
H A D | net_datashare_utils_test.cpp | 73 std::string off = "0"; in HWTEST_F() local 74 ret = netDataShareHelperUtils_->Insert(wifiUri, KEY_SHARING_WIFI, off); in HWTEST_F() 81 ret = netDataShareHelperUtils_->Insert(usbUri, KEY_SHARING_USB, off); in HWTEST_F() 88 ret = netDataShareHelperUtils_->Insert(bluetoothUri, KEY_SHARING_BLUETOOTH, off); in HWTEST_F() 106 std::string off = "0"; in HWTEST_F() local 107 ret = netDataShareHelperUtils_->Insert(wifiUri, KEY_SHARING_WIFI, off); in HWTEST_F() 114 ret = netDataShareHelperUtils_->Insert(usbUri, KEY_SHARING_USB, off); in HWTEST_F() 121 ret = netDataShareHelperUtils_->Insert(bluetoothUri, KEY_SHARING_BLUETOOTH, off); in HWTEST_F() 137 std::string off = "0"; in HWTEST_F() local 138 ret = netDataShareHelperUtils_->Update(wifiUri, KEY_SHARING_WIFI, off); in HWTEST_F() 169 std::string off = "0"; HWTEST_F() local [all...] |
/foundation/communication/netmanager_base/test/netmanagerutils/unittest/netmanager_base_common_test/ |
H A D | netmanager_data_share_utils_test.cpp | 103 std::string off = "0"; in HWTEST_F() local 105 int ret = netDataShareHelperUtils_->Insert(usbUri, KEY_WIFI, off); in HWTEST_F() 119 std::string off = "0"; in HWTEST_F() local 121 int ret = netDataShareHelperUtils_->Insert(blueToothUri, KEY_WIFI, off); in HWTEST_F() 143 std::string off = "0"; in HWTEST_F() local 145 int ret = netDataShareHelperUtils_->Update(wifiUri, KEY_WIFI, off); in HWTEST_F() 159 std::string off = "0"; in HWTEST_F() local 161 int ret = netDataShareHelperUtils_->Update(usbUri, KEY_USB, off); in HWTEST_F() 175 std::string off = "0"; in HWTEST_F() local 177 int ret = netDataShareHelperUtils_->Update(bluetooth, KEY_USB, off); in HWTEST_F() [all...] |
/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/ |
H A D | file_operations_local_test.cpp | 300 off_t off = 0; in HWTEST_F() local 305 fileoperationslocal_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 329 off_t off = 0; in HWTEST_F() local 333 fileoperationslocal_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 357 off_t off = 0; in HWTEST_F() local 362 fileoperationslocal_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 386 off_t off = 0; in HWTEST_F() local 390 fileoperationslocal_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 414 off_t off = 0; in HWTEST_F() local 419 fileoperationslocal_->ReadDir(req, ino, size, off, in HWTEST_F() [all...] |
H A D | fuse_operations_test.cpp | 731 off_t off = 0; in HWTEST_F() local 734 fuseoperations_->ReadDir(req, FUSE_ROOT_ID, size, off, &fi); in HWTEST_F() 757 off_t off = 0; in HWTEST_F() local 760 fuseoperations_->ReadDir(req, 0, size, off, &fi); in HWTEST_F() 791 off_t off = 0; in HWTEST_F() local 794 fuseoperations_->ReadDir(req, 0, size, off, &fi); in HWTEST_F() 1306 off_t off = 0; in HWTEST_F() local 1309 fuseoperations_->Read(req, FUSE_ROOT_ID, size, off, &fi); in HWTEST_F() 1332 off_t off = 0; in HWTEST_F() local 1335 fuseoperations_->Read(req, 0, size, off, in HWTEST_F() 1366 off_t off = 0; HWTEST_F() local 1635 off_t off = 0; HWTEST_F() local 1661 off_t off = 0; HWTEST_F() local 1695 off_t off = 0; HWTEST_F() local [all...] |
H A D | file_operations_cloud_test.cpp | 593 off_t off = 0; in HWTEST_F() local 598 fileOperationsCloud_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 621 off_t off = 0; in HWTEST_F() local 626 fileOperationsCloud_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 650 off_t off = 0; in HWTEST_F() local 655 fileOperationsCloud_->ReadDir(req, ino, size, off, &fi); in HWTEST_F() 1873 off_t off = 0; in HWTEST_F() local 1877 fileOperationsCloud_->Read(req, reinterpret_cast<fuse_ino_t>(&ino), size, off, &fi); in HWTEST_F() 1900 off_t off = 0; in HWTEST_F() local 1906 fileOperationsCloud_->Read(req, reinterpret_cast<fuse_ino_t>(&ino), size, off, in HWTEST_F() 1929 off_t off = 0; HWTEST_F() local 1957 off_t off = 0; HWTEST_F() local 2519 off_t off = 0; HWTEST_F() local 2547 off_t off = 0; HWTEST_F() local 2576 off_t off = 0; HWTEST_F() local 2605 off_t off = 0; HWTEST_F() local 2635 off_t off = 0; HWTEST_F() local [all...] |
/foundation/filemanagement/dfs_service/test/unittests/cloud_disk/mock/ |
H A D | file_operations_cloud_mock.cpp | 316 static size_t FindNextPos(const vector<CloudDiskFileInfo> &childInfos, off_t off) in FindNextPos() argument 319 /* Find the first valid offset beyond @off */ in FindNextPos() 320 if (childInfos[i].nextOff > off) { in FindNextPos() 324 /* If @off is beyond all valid offset, then return the index after the last info */ in FindNextPos() 325 if (!childInfos.empty() && childInfos.back().nextOff < off) { in FindNextPos() 331 static size_t FindNextPos(const vector<MetaBase> &childInfos, off_t off) in FindNextPos() argument 334 /* Find the first valid offset beyond @off */ in FindNextPos() 335 if (childInfos[i].nextOff > off) { in FindNextPos() 339 /* If @off is beyond all valid offset, then return the index after the last info */ in FindNextPos() 340 if (!childInfos.empty() && childInfos.back().nextOff < off) { in FindNextPos() 367 CloudSeekDir(fuse_req_t req, fuse_ino_t ino, off_t off, const std::vector<T> &childInfos) CloudSeekDir() argument 390 AddDirEntryToBuf(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, const std::vector<T> &childInfos) AddDirEntryToBuf() argument 396 ReadDirForRecycle(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi) ReadDirForRecycle() argument 402 ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi) ReadDir() argument 618 WriteBuf(fuse_req_t req, fuse_ino_t ino, struct fuse_bufvec *bufv, off_t off, struct fuse_file_info *fi) WriteBuf() argument 641 Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence, struct fuse_file_info *fi) Lseek() argument [all...] |
H A D | libfuse_mock.cpp | 61 int fuse_reply_lseek(fuse_req_t req, off_t off) in fuse_reply_lseek() argument 63 return Assistant::ins->fuse_reply_lseek(req, off); in fuse_reply_lseek()
|
H A D | file_operations_helper_mock.cpp | 174 off_t off, size_t maxSize) in FuseReplyLimited() 176 if (off < bufSize) { in FuseReplyLimited() 177 size_t size = (bufSize - off) < maxSize ? (bufSize - off) : maxSize; in FuseReplyLimited() 178 fuse_reply_buf(req, buf + off, size); in FuseReplyLimited() 173 FuseReplyLimited(fuse_req_t req, const char *buf, size_t bufSize, off_t off, size_t maxSize) FuseReplyLimited() argument
|
H A D | file_operations_local_mock.cpp | 59 void FileOperationsLocal::ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, in ReadDir() argument 105 FileOperationsHelper::FuseReplyLimited(req, entryData.c_str(), len, off, size); in ReadDir()
|
/foundation/distributeddatamgr/data_object/samples/distributedNotepad/entry/src/main/js/model/ |
H A D | DistributedDataModel.js | 46 this.distributedObject.off('change'); 48 this.distributedObject.off('status'); 57 console.info('start off'); 59 this.distributedObject.off('change', this.#callback); 71 console.info('start off'); 73 this.distributedObject.off('status', this.#statusCallback);
|
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/ |
H A D | RdbStoreDistributedJsunit.test.js | 332 rdbStore.off("dataChange", data_relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (device) => { 335 console.log(TAG + "off dataChange success"); 365 rdbStore.off("dataChange", data_relationalStore.SubscribeType.SUBSCRIBE_TYPE_CLOUD, (device) => { 368 console.log(TAG + "off dataChange success"); 397 rdbStore.off("dataChange", data_relationalStore.SubscribeType.SUBSCRIBE_TYPE_CLOUD_DETAILS, (device) => { 400 console.log(TAG + "off dataChange success"); 413 rdbStore.off("dataChange", data_relationalStore.SubscribeType.SUBSCRIBE_TYPE_REMOTE); 414 console.log(TAG + "off dataChange success"); 427 rdbStore.off("dataChange", data_relationalStore.SubscribeType.SUBSCRIBE_TYPE_CLOUD, null); 428 console.log(TAG + "off dataChang [all...] |
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/cloud_disk/ |
H A D | fuse_operations.cpp | 161 void FuseOperations::ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, in ReadDir() argument 167 opsPtr->ReadDir(req, ino, size, off, fi); in ReadDir() 176 inoPtr->ops->ReadDir(req, ino, size, off, fi); in ReadDir() 296 off_t off, struct fuse_file_info *fi) in WriteBuf() 300 opsPtr->WriteBuf(req, ino, bufv, off, fi); in WriteBuf() 309 inoPtr->ops->WriteBuf(req, ino, bufv, off, fi); in WriteBuf() 343 void FuseOperations::Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence, in Lseek() argument 348 opsPtr->Lseek(req, ino, off, whence, fi); in Lseek() 357 inoPtr->ops->Lseek(req, ino, off, whence, fi); in Lseek() 295 WriteBuf(fuse_req_t req, fuse_ino_t ino, struct fuse_bufvec *bufv, off_t off, struct fuse_file_info *fi) WriteBuf() argument
|
H A D | file_operations_helper.cpp | 149 off_t off, size_t maxSize) in FuseReplyLimited() 151 if (off < bufSize) { in FuseReplyLimited() 152 size_t size = (bufSize - off) < maxSize ? (bufSize - off) : maxSize; in FuseReplyLimited() 153 fuse_reply_buf(req, buf + off, size); in FuseReplyLimited() 148 FuseReplyLimited(fuse_req_t req, const char *buf, size_t bufSize, off_t off, size_t maxSize) FuseReplyLimited() argument
|
H A D | file_operations_cloud.cpp | 576 static size_t FindNextPos(const vector<CloudDiskFileInfo> &childInfos, off_t off) in FindNextPos() argument 579 /* Find the first valid offset beyond @off */ in FindNextPos() 580 if (childInfos[i].nextOff > off) { in FindNextPos() 584 /* If @off is beyond all valid offset, then return the index after the last info */ in FindNextPos() 585 if (!childInfos.empty() && childInfos.back().nextOff < off) { in FindNextPos() 591 static size_t FindNextPos(const vector<MetaBase> &childInfos, off_t off) in FindNextPos() argument 594 /* Find the first valid offset beyond @off */ in FindNextPos() 595 if (childInfos[i].nextOff > off) { in FindNextPos() 599 /* If @off is beyond all valid offset, then return the index after the last info */ in FindNextPos() 600 if (!childInfos.empty() && childInfos.back().nextOff < off) { in FindNextPos() 628 CloudSeekDir(fuse_req_t req, fuse_ino_t ino, off_t off, const std::vector<T> &childInfos) CloudSeekDir() argument 651 AddDirEntryToBuf(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, const std::vector<T> &childInfos) AddDirEntryToBuf() argument 680 ReadDirForRecycle(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi) ReadDirForRecycle() argument 709 ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, struct fuse_file_info *fi) ReadDir() argument 1363 WriteBuf(fuse_req_t req, fuse_ino_t ino, struct fuse_bufvec *bufv, off_t off, struct fuse_file_info *fi) WriteBuf() argument 1525 Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence, struct fuse_file_info *fi) Lseek() argument [all...] |
H A D | file_operations_base.cpp | 96 void FileOperationsBase::ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, in ReadDir() argument 150 off_t off, struct fuse_file_info *fi) in WriteBuf() 167 void FileOperationsBase::Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence, in Lseek() argument 149 WriteBuf(fuse_req_t req, fuse_ino_t ino, struct fuse_bufvec *bufv, off_t off, struct fuse_file_info *fi) WriteBuf() argument
|
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/include/cloud_disk/ |
H A D | file_operations_cloud.h | 37 void ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, 48 off_t off, struct fuse_file_info *fi) override; 51 void Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence,
|
H A D | file_operations_base.h | 44 virtual void ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, 55 off_t off, struct fuse_file_info *fi); 58 virtual void Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence,
|
H A D | fuse_operations.h | 39 static void ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off, 50 off_t off, struct fuse_file_info *fi); 53 static void Lseek(fuse_req_t req, fuse_ino_t ino, off_t off, int whence,
|
H A D | file_operations_local.h | 28 void ReadDir(fuse_req_t req, fuse_ino_t ino, size_t size, off_t off,
|
/foundation/distributeddatamgr/kv_store/test/unittest/distributeddata/ |
H A D | KvManagerDataPromiseJsTest.js | 697 kvManager.off('distributedDataServiceDie', deathCallback); 717 kvManager.off('distributedDataServiceDie', deathCallback1); 718 kvManager.off('distributedDataServiceDie', deathCallback2); 735 kvManager.off('distributedDataServiceDie', deathCallback); 750 kvManager.off('distributedDataServiceDie', deathCallback); 766 kvManager.off('distributedDataServiceDie', deathCallback); 786 kvManager.off('distributedDataServiceDie', deathCallback1); 802 kvManager.off('distributedDataServiceDie', deathCallback); 803 kvManager.off('distributedDataServiceDie', deathCallback); 819 kvManager.off('distributedDataServiceDi [all...] |
/foundation/arkui/ace_engine/test/tools/event_tree_to_graph/src/bats/ |
H A D | dump_event.bat | 14 @echo off
38 @echo off
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/media_manager/ |
H A D | media_manager.cpp | 83 auto off = lseek(outputFileFd_, 0, SEEK_END); in Pause() 84 DP_CHECK_ERROR_RETURN_RET_LOG(off == static_cast<off_t>(ERROR_FAIL), ERROR_FAIL, "write temp lseek failed."); in Pause() 250 auto off = lseek(tempFileFd_, size - TEMP_PTS_SIZE, SEEK_SET); in GetRecoverInfo() 251 DP_CHECK_ERROR_RETURN_RET_LOG(off == static_cast<off_t>(ERROR_FAIL), ERROR_FAIL, "lseek recover failed."); in GetRecoverInfo()
|
H A D | reader.cpp | 47 auto off = lseek(inputFd, DEFAULT_OFFSET, SEEK_END); in Create() local 48 DP_CHECK_ERROR_RETURN_RET_LOG(off == static_cast<off_t>(ERROR_FAIL), ERROR_FAIL, "reader lseek failed."); in Create() 49 source_ = MediaAVCodec::AVSourceFactory::CreateWithFD(inputFd, DEFAULT_OFFSET, off); in Create()
|
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/avdtp/ |
H A D | avdtp_message.h | 136 uint16_t AvdtBuildCapability(const Packet *pkt, const AvdtSepConfig *cfg, uint8_t off, uint8_t sigId); 170 void AvdtParseSetconfig(uint16_t streamHandle, const Packet *pkt, uint16_t off, uint8_t *errCode, uint8_t *errParam); 171 void AvdtParseReconfig(uint16_t streamHandle, const Packet *pkt, uint16_t off, uint8_t *errCode, uint8_t *errParam);
|