| /base/request/request/services/src/service/command/ |
| H A D | construct.rs | 41 let action: u32 = data.read()?;
44 let version: u32 = data.read()?;
47 let mode: u32 = data.read()?;
50 let bundle_type: u32 = data.read()?;
52 let cover: bool = data.read()?;
54 let network: u32 = data.read()?;
57 let metered: bool = data.read()?;
59 let roaming: bool = data.read()?;
61 let retry: bool = data.read()?;
63 let redirect: bool = data.read()
[all...] |
| H A D | search.rs | 24 let bundle: String = data.read()?;
35 let before: i64 = data.read()?;
37 let after: i64 = data.read()?;
39 let state: u32 = data.read()?;
41 let action: u32 = data.read()?;
43 let mode: u32 = data.read()?;
|
| H A D | touch.rs | 22 let task_id: String = data.read()?;
31 let token: String = data.read()?;
|
| H A D | pause.rs | 25 let version: u32 = data.read()?;
32 let task_id: String = data.read()?;
|
| H A D | get_task.rs | 23 let task_id: String = data.read()?;
42 let token: String = data.read()?;
|
| H A D | remove.rs | 25 let version: u32 = data.read()?;
32 let task_id: String = data.read()?;
|
| /base/hiviewdfx/hilog/services/hilogd/ |
| H A D | log_compress.cpp | 69 size_t read = inBuffer.offset; in Compress() local
72 bool flag = read - src_pos < toRead; in Compress()
75 if (memmove_s(buffIn, CHUNK, inBuffer.content + src_pos, read - src_pos) != 0) { in Compress()
78 cStream.avail_in = read - src_pos; in Compress()
79 src_pos += read - src_pos; in Compress()
91 compression if all of source has been read in */ in Compress()
139 size_t read = inBuffer.offset;
142 bool flag = read - src_pos < toRead;
145 if (memmove_s(buffIn, CHUNK, inBuffer.content + src_pos, read - src_pos) != 0) {
148 input = {buffIn, read
[all...] |
| /base/request/request/test/rustest/src/ |
| H A D | lib.rs | 74 let ret: i32 = reply.read().unwrap(); in new()
112 let ret: i32 = reply.read().unwrap(); in construct()
114 reply.read::<i32>().unwrap() as u32 in construct()
134 let ret: i32 = reply.read().unwrap();
146 let ret: i32 = reply.read().unwrap(); in query()
158 let ret: i32 = reply.read().unwrap(); in query_mime_type()
160 let mime: String = reply.read().unwrap(); in query_mime_type()
181 let ret: i32 = reply.read().unwrap();
193 let ret: i32 = reply.read().unwrap(); in resume()
205 let ret: i32 = reply.read() in start()
[all...] |
| /base/update/packaging_tools/ |
| H A D | unpack_updater_package.py | 94 compinfo_len_buffer = package_file.read(COMPINFO_LEN_SIZE)
104 next_tlv_type_buffer = package_file.read(HASH_TYPE_SIZE)
110 hashdata_len_buffer = package_file.read(HASH_LENGTH_SIZE)
117 sign_len_buffer = package_file.read(HASH_LENGTH_SIZE)
131 component_addr = package_file.read(self.addr_size)
135 component_type_buffer = package_file.read(COMPONENT_TYPE_SIZE)
139 component_size_buffer = package_file.read(COMPONENT_SIZE_SIZE)
174 image_buffer = package_file.read(component_size)
|
| H A D | build_pkcs7.py | 49 der_bytes = cert_file.read()
66 hash_sha256.update(package_file.read(BLOCK_SIZE))
69 hash_sha256.update(package_file.read(remain_len))
75 # read private key from pem file
78 key_data = f_r.read()
99 # read private key from pem file
102 key_data = f_r.read()
142 f_signed.write(f_unsign.read(BLOCK_SIZE))
145 f_signed.write(f_unsign.read(remain_len))
|
| H A D | create_signed_data.py | 33 chunk = file.read(BLOCK_SIZE)
36 chunk = file.read(BLOCK_SIZE)
|
| /base/security/huks/test/fuzz_test/innerapi_fuzzer/ |
| H A D | hks_fuzz_util.h | 31 ReadType read = reinterpret_cast<ReadType>(data); in ReadData() local
34 return read; in ReadData()
|
| /base/hiviewdfx/hiview/base/event_store/utility/reader/ |
| H A D | content_reader_version_3.cpp | 35 docStream.read(reinterpret_cast<char*>(&header), sizeof(EventStore::DocHeader)); in ReadDocDetails()
37 docStream.read(reinterpret_cast<char*>(&sysVersionSize), sizeof(uint32_t)); in ReadDocDetails()
43 docStream.read(sysVersionstr, sysVersionSize); in ReadDocDetails()
45 HIVIEW_LOGD("version read from db:%{public}s", sysVersion.c_str()); in ReadDocDetails()
|
| /base/security/asset/frameworks/ipc/src/ |
| H A D | lib.rs | 81 let len = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_map()
87 let tag = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_map()
91 let v = parcel.read::<bool>().map_err(ipc_err_handle)?; in deserialize_map()
95 let v = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_map()
99 let v = parcel.read::<Vec<u8>>().map_err(ipc_err_handle)?; in deserialize_map()
121 let len = parcel.read::<u32>().map_err(ipc_err_handle)?; in deserialize_maps()
|
| /base/hiviewdfx/hidumper/frameworks/native/src/executor/ |
| H A D | cmd_dumper.cpp | 126 ssize_t read = 0; in GetLineData() local
127 read = getline(&line_buffer, &len, fp); in GetLineData()
128 if (read != -1) { in GetLineData()
129 if (line_buffer[read - 1] == '\n') { in GetLineData()
130 line_buffer[read - 1] = '\0'; // replease \n in GetLineData()
150 // read one line
|
| H A D | file_stream_dumper.cpp | 99 // read one line
108 ssize_t read = 0; in ReadLineInFile() local
109 read = getline(&line_buffer, &len, fp_); in ReadLineInFile()
110 if (read != -1) { in ReadLineInFile()
111 if (line_buffer[read-1] == '\n') { in ReadLineInFile()
112 line_buffer[read-1] = '\0'; // replease \n in ReadLineInFile()
|
| /base/request/request/pre_download/native/src/cache/ |
| H A D | data.rs | 98 .read(true)
147 fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> { in read() functions
149 ReaderData::Cursor(c) => c.read(buf), in read()
150 ReaderData::File(f) => f.read(buf), in read()
166 use std::fs::read;
|
| /base/security/asset/interfaces/inner_kits/rs/src/ |
| H A D | lib.rs | 87 let res = reply.read::<Vec<u8>>().map_err(ipc_err_handle)?; in pre_query()
112 match reply.read::<u32>().map_err(ipc_err_handle)? { in send_request()
115 let msg = reply.read::<String>().map_err(ipc_err_handle)?; in send_request()
|
| /base/startup/init/test/exec_test/ |
| H A D | server.c | 30 if (read(sockFd, buffer, sizeof(buffer) - 1) > 0) {
in main()
|
| /base/startup/init/interfaces/innerkits/fs_manager/erofs_overlay/ |
| H A D | erofs_overlay_common.c | 61 ssize_t nbytes = read(fd, &superBlock, sizeof(superBlock));
in CheckIsExt4()
63 BEGET_LOGE("read ext4 super block fail");
in CheckIsExt4()
92 ssize_t nbytes = read(fd, &superBlock, sizeof(superBlock));
in CheckIsErofs()
94 BEGET_LOGE("read erofs super block fail");
in CheckIsErofs()
|
| /base/update/sys_installer/services/module_update/util/include/ |
| H A D | module_ipc_helper.h | 46 const std::function<void(MessageParcel &, T &)> &read) in ReadList()
54 read(reply, item); in ReadList()
45 ReadList(MessageParcel &reply, std::list<T> &list, const std::function<void(MessageParcel &, T &)> &read) ReadList() argument
|
| /base/security/dlp_permission_service/interfaces/inner_api/dlp_fuse/test/unittest/src/ |
| H A D | dlp_fuse_test.cpp | 225 ASSERT_EQ(read(linkfd1, readBuf, SIX), SIX); in CheckLinkFd()
227 // read hole data, offset 0x1000 size 6 in CheckLinkFd()
230 ASSERT_GE(read(linkfd1, readBuf, SIX), SIX); in CheckLinkFd()
236 ASSERT_EQ(read(linkfd1, readBuf, SIX), SIX); in CheckLinkFd()
241 ASSERT_EQ(read(linkfd1, readBuf, SIXTEEN), SIXTEEN); in CheckLinkFd()
246 ASSERT_EQ(read(linkfd1, readBuf, SIX), SIX); in CheckLinkFd()
251 ASSERT_EQ(read(linkfd1, readBuf, SIX), SIX); in CheckLinkFd()
256 ASSERT_EQ(read(linkfd1, readBuf, EIGHTEEN), EIGHTEEN); in CheckLinkFd()
266 ASSERT_EQ(read(g_recoveryFileFd, readBuf, SIX), SIX); in CheckRecoverFd()
269 // read hol in CheckRecoverFd()
[all...] |
| /base/startup/init/services/begetctl/ |
| H A D | misc_daemon.cpp | 98 if (read(fd, &magic, sizeof(uint32_t)) != sizeof(uint32_t)) { in WriteLogo()
172 if (read(fd1, &magic, sizeof(uint32_t)) != sizeof(uint32_t)) { in WriteLogoToMisc()
173 BSH_LOGI("Failed read errno %d ", errno); in WriteLogoToMisc()
177 if (read(fd1, &size, sizeof(uint32_t)) != sizeof(uint32_t)) { in WriteLogoToMisc()
178 BSH_LOGI("Failed read migic errno %d ", errno); in WriteLogoToMisc()
|
| /base/global/resource_management_lite/frameworks/resmgr_lite/src/ |
| H A D | global_utils.c | 405 int32_t ret = read(file, cache, INDEX_DEFAULT_OFFSET);
in GetDefaultOffsetValue()
415 int32_t ret = read(file, cache, INDEX_DEFAULT_OFFSET);
in GetKeyValue()
436 (void)read(file, defaultCache, INDEX_DEFAULT_OFFSET);
in GetIdItem()
439 (void)read(file, defaultCache, INDEX_DEFAULT_OFFSET);
in GetIdItem()
442 (void)read(file, defaultCache, INDEX_DEFAULT_OFFSET);
in GetIdItem()
445 (void)read(file, lengthCache, VALUE_LENGTH_OFFSET);
in GetIdItem()
456 (void)read(file, idItem->value, idItem->valueLen);
in GetIdItem()
458 (void)read(file, lengthCache, VALUE_LENGTH_OFFSET);
in GetIdItem()
473 (void)read(file, idItem->name, idItem->nameLen);
in GetIdItem()
|
| /base/startup/hvb/tools/ |
| H A D | hvbtool.py | 204 lines = child.stdout.read().split(b'\n')
313 header = self.img_handler.read(self.SIMAGE_HEADER_SIZE)
368 chunk_header = self.img_handler.read(ImageChunk.CHUNK_HEADER_SIZE)
384 fill_data = self.img_handler.read(4)
399 self.img_handler.read(4)
532 def read(self, size): member in ImageHandle
539 read.
542 size: Number of bytes to read.
549 data = self.img_handler.read(size)
565 data.extend(self.img_handler.read(chunk_pos_to_g
[all...] |