Home
last modified time | relevance | path

Searched refs:buffer (Results 1 – 25 of 50) sorted by relevance

12

/commonlibrary/ets_utils/js_api_module/buffer/test/
Dtest_napi.cpp39 void FillZero(OHOS::buffer::Buffer *buf, size_t size) in FillZero()
54 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer();
67 OHOS::buffer::Buffer *buf1 = new OHOS::buffer::Buffer();
69 OHOS::buffer::Buffer *buf2 = new OHOS::buffer::Buffer();
82 OHOS::buffer::Buffer *poolBuffer = new OHOS::buffer::Buffer();
84 OHOS::buffer::Buffer *buf2 = new OHOS::buffer::Buffer();
89 OHOS::buffer::Buffer *buf3 = new OHOS::buffer::Buffer();
103 OHOS::buffer::Buffer *buf2 = new OHOS::buffer::Buffer();
118 OHOS::buffer::Buffer *buf = new OHOS::buffer::Buffer();
131 OHOS::buffer::Buffer *buffer = new OHOS::buffer::Buffer(); variable
[all …]
/commonlibrary/memory_utils/libdmabufheap/test/unittest/libdmabufheap/
Ddmabuf_alloc_test.cpp85 DmabufHeapBuffer buffer = { .size = BUFFER_SIZE, .heapFlags = 0 }; variable
86 ASSERT_EQ(0, DmabufHeapBufferAlloc(heapFd, &buffer));
88 void *ptr = mmap(NULL, BUFFER_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, buffer.fd, 0);
91 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW));
95 ASSERT_EQ(0, DmabufHeapBufferSyncEnd(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW));
101 ASSERT_EQ(0, DmabufHeapBufferFree(&buffer));
113 DmabufHeapBuffer buffer = { .size = BUFFER_SIZE, .heapFlags = 0 }; variable
114 ASSERT_EQ(0, DmabufHeapBufferAlloc(heapFd, &buffer));
116 void *ptr = mmap(NULL, BUFFER_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, buffer.fd, 0);
119 ASSERT_EQ(0, DmabufHeapBufferSyncStart(buffer.fd, DMA_BUF_HEAP_BUF_SYNC_RW));
[all …]
/commonlibrary/rust/ylong_http/ylong_http/src/h1/response/
Ddecoder.rs135 ($case:expr, $buffer:expr) => {{
137 Some(unparsed) => $buffer = unparsed,
144 ($case:expr, $buffer:expr) => {{
145 if $buffer.is_empty() {
148 } else if $buffer[0] == b'\r' || $buffer[0] == b'\n' {
149 return Ok(Some($buffer));
228 buffer: &'a [u8], in version_phase()
231 match status_token(buffer)? { in version_phase()
252 buffer: &'a [u8], in status_code_phase()
255 match status_token(buffer)? { in status_code_phase()
[all …]
/commonlibrary/memory_utils/libdmabufheap/src/
Ddmabuf_alloc.c76 int DmabufHeapBufferAlloc(unsigned int heapFd, DmabufHeapBuffer *buffer) in DmabufHeapBufferAlloc() argument
78 if (buffer->size == 0) { in DmabufHeapBufferAlloc()
84 .len = buffer->size, in DmabufHeapBufferAlloc()
86 .heap_flags = buffer->heapFlags, in DmabufHeapBufferAlloc()
90 HILOG_ERROR(LOG_CORE, "alloc buffer failed, size = %zu, ret = %d.", buffer->size, ret); in DmabufHeapBufferAlloc()
94 buffer->fd = data.fd; in DmabufHeapBufferAlloc()
98 int DmabufHeapBufferFree(DmabufHeapBuffer *buffer) in DmabufHeapBufferFree() argument
100 return close(buffer->fd); in DmabufHeapBufferFree()
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
Dylong_io_tcp_client.rs26 let mut buffer = [0_u8; 1024]; in main() localVariable
36 match stream.read(&mut buffer) { in main()
38 println!("1.Receive msg: {}\n", String::from_utf8_lossy(&buffer)); in main()
52 if stream.read(&mut buffer).is_ok() { in main()
53 println!("2.Receive msg: {}\n", String::from_utf8_lossy(&buffer)); in main()
/commonlibrary/ets_utils/
DREADME.md74 │ ├── new XmlSerializer(buffer: ArrayBuffer | DataView, encoding?: string) # 创建XmlSerializer…
86 │ ├── new (buffer: ArrayBuffer | DataView, encoding?: string) # 创建XmlPullParser…
100 │ ├── buffer # buffer属性
214 | XmlSerializer(buffer: ArrayBuffer \| DataView, encoding?: string) | 创建并返回一个XmlSerializer对象，该XmlSe…
225 | XmlPullParser(buffer: ArrayBuffer \| DataView, encoding?: string) | 创建并返回一个XmlPullParser对象，该XmlPu…
235 | from(buffer: Buffer \| Uint8Array): Buffer | 创建并复制buffer数据到新的Buffer实例并返回。 |
241 | length: number | buffer的字节长度。 |
242 | buffer: ArrayBuffer | ArrayBuffer对象。 |
243 | byteOffset: number | 当前buffer所在内存池的偏移量。 |
526 37、new XmlSerializer(buffer: ArrayBuffer | DataView, encoding?: string)
[all …]
/commonlibrary/ets_utils/js_util_module/util/
Djs_textencoder.cpp35 std::string buffer = ""; in Encode() local
37 EncodeIntoChinese(env, src, encoding_, buffer); in Encode()
44 buffer.resize(bufferSize); in Encode()
45 … if (napi_get_value_string_utf8(env, src, buffer.data(), bufferSize + 1, &bufferSize) != napi_ok) { in Encode()
51 size_t outLen = buffer.length(); in Encode()
55 if (memcpy_s(data, outLen, reinterpret_cast<void*>(buffer.data()), outLen) != EOK) { in Encode()
Djs_uuid.cpp201 std::string buffer = ""; in DoParseUUID() local
209 buffer.resize(bufferSize); in DoParseUUID()
210 status = napi_get_value_string_utf8(env, src, buffer.data(), bufferSize + 1, &bufferSize); in DoParseUUID()
220 while (!buffer.empty()) { in DoParseUUID()
221 *count = ConvertBits(buffer); in DoParseUUID()
Djs_base64.h144 static void EndStdEncode(napi_env env, napi_status status, void *buffer);
146 static void EndStdEncodeToString(napi_env env, napi_status status, void *buffer);
148 static void EndStdDecode(napi_env env, napi_status status, void *buffer);
/commonlibrary/ets_utils/js_api_module/buffer/
Djs_buffer.cpp26 namespace OHOS::buffer { namespace
38 void Buffer::Init(Buffer *buffer) in Init() argument
40 if (buffer != nullptr && buffer->length_ > 0) { in Init()
41 this->raw_ = reinterpret_cast<uint8_t *>(malloc(buffer->length_)); in Init()
45 this->length_ = buffer->length_; in Init()
46 if (memcpy_s(raw_, length_, buffer->raw_ + buffer->byteOffset_, length_) != EOK) { in Init()
63 void Buffer::Init(uint8_t *buffer, unsigned int byteOffset, unsigned int length) in Init() argument
65 if (buffer != nullptr) { in Init()
66 this->raw_ = buffer; in Init()
373 void Buffer::FillBuffer(Buffer *buffer, unsigned int offset, unsigned int end) in FillBuffer() argument
[all …]
DBUILD.gn29 rebase_path("/commonlibrary/ets_utils/js_api_module/buffer"),
51 js_buffer_obj_path = base_output_path + "/buffer.c"
53 js_buffer_obj_path = base_output_path + "/buffer.o"
63 dst_file = rebase_path(target_out_dir + "/buffer.abc")
65 out_puts = [ target_out_dir + "/buffer.abc" ]
72 input = "$target_out_dir/buffer.abc"
89 ohos_shared_library("buffer") {
146 public_deps = [ ":buffer" ]
Dnative_module_buffer.cpp33 namespace OHOS::buffer { namespace
96 Buffer *buffer = nullptr; in FromStringUtf8() local
97 NAPI_CALL(env, napi_unwrap(env, thisVar, reinterpret_cast<void **>(&buffer))); in FromStringUtf8()
98 buffer->WriteString(utf8Str, utf8Str.length()); in FromStringUtf8()
106 Buffer *buffer = nullptr; in FromStringASCII() local
107 NAPI_CALL(env, napi_unwrap(env, thisVar, reinterpret_cast<void **>(&buffer))); in FromStringASCII()
109 buffer->WriteString(asciiStr, size); in FromStringASCII()
123 Buffer *buffer = nullptr; in FromStringUtf16LE() local
124 NAPI_CALL(env, napi_unwrap(env, thisVar, reinterpret_cast<void **>(&buffer))); in FromStringUtf16LE()
127 buffer->WriteString(u16Str, 0, u16Str.size() * 2); in FromStringUtf16LE()
[all …]
Djs_buffer.h27 namespace OHOS::buffer {
43 void Init(Buffer *buffer);
45 void Init(uint8_t *buffer, unsigned int byteOffset, unsigned int length);
77 void FillBuffer(Buffer *buffer, unsigned int offset, unsigned int end);
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
Ddecoder.rs173 buffer: Vec<u8>, field
292 buffer: vec![], in default()
350 let mut buffer = buf; in decode() localVariable
353 Header => match self.decode_frame_header(buffer)? { in decode()
355 buffer = remain; in decode()
362 Payload => match self.decode_frame_payload(buffer)? { in decode()
365 buffer = remain; in decode()
393 self.buffer.extend_from_slice(buf); in decode_frame_payload()
414 self.buffer.clear() in decode_frame_payload()
425 self.buffer.extend_from_slice(buf); in decode_ping_payload()
[all …]
/commonlibrary/memory_utils/libdmabufheap/include/
Ddmabuf_alloc.h48 int DmabufHeapBufferAlloc(unsigned int heapFd, DmabufHeapBuffer *buffer);
50 int DmabufHeapBufferFree(DmabufHeapBuffer *buffer);
/commonlibrary/ets_utils/js_util_module/util/test/
Dtest_util.cpp167 char *buffer = nullptr; variable
169 napi_get_value_string_utf8(env, result, buffer, -1, &bufferSize);
171 buffer = new char[bufferSize + 1];
172 napi_get_value_string_utf8(env, result, buffer, bufferSize + 1, &bufferSize);
175 ASSERT_STREQ(buffer, "GBK");
176 if (buffer != nullptr) {
177 delete []buffer;
178 buffer = nullptr;
194 char *buffer = nullptr; variable
196 napi_get_value_string_utf8(env, result, buffer, -1, &bufferSize);
[all …]
/commonlibrary/c_utils/base/test/unittest/common/
Dutils_parcel_test.cpp191 bool SendData(void *&buffer, size_t size, const uint8_t *data) in SendData() argument
196 buffer = malloc(size); in SendData()
197 if (buffer == nullptr) { in SendData()
200 if (memcpy_s(buffer, size, data, size) != EOK) { in SendData()
665 void *buffer = nullptr; variable
667 if (!SendData(buffer, size, reinterpret_cast<const uint8_t *>(parcel1.GetData()))) {
670 parcel2.ParseFrom(reinterpret_cast<uintptr_t>(buffer), parcel1.GetDataSize());
755 void *buffer = nullptr; variable
757 if (!SendData(buffer, size, reinterpret_cast<const uint8_t *>(parcel1.GetData()))) {
761 bool result = parcel2.ParseFrom(reinterpret_cast<uintptr_t>(buffer), parcel1.GetDataSize());
[all …]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
Dylong_tokio_async_file.rs63 let mut buffer = [0_u8]; localVariable
67 file.read_exact(&mut buffer).await.unwrap();
68 READ_BUFFER[i] = buffer[0];
Dsync_benchmarks.rs73 let mut buffer = [0_u8]; in std_read_file_by_chars() localVariable
77 file.read_exact(&mut buffer).unwrap(); in std_read_file_by_chars()
78 *tar = buffer[0]; in std_read_file_by_chars()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/task_helpers/
Dmod.rs87 let mut buffer = [0; BUFFER_SIZE]; in init_write_buffer() localVariable
88 for (i, tar) in buffer.iter_mut().enumerate().take(BUFFER_SIZE) { in init_write_buffer()
94 .zip(buffer.as_slice().iter()) in init_write_buffer()
/commonlibrary/ets_utils/platform/ohos/
Dutil_helper.cpp51 void EncodeIntoChinese(napi_env env, napi_value src, std::string encoding, std::string& buffer) in EncodeIntoChinese() argument
55 engine->EncodeToChinese(nativeValue, buffer, encoding); in EncodeIntoChinese()
/commonlibrary/ets_utils/platform/default/
Dutil_helper.cpp77 void EncodeIntoChinese(napi_env env, napi_value src, std::string encoding, std::string& buffer) in EncodeIntoChinese() argument
84 buffer = UtilPlugin::EncodeIntoChinese(input, encoding); in EncodeIntoChinese()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dqueue.rs121 buffer: Box<[UnsafeCell<MaybeUninit<Task>>]>, field
168 let mut buffer = Vec::with_capacity(cap as usize); in new() localVariable
171 buffer.push(UnsafeCell::new(MaybeUninit::uninit())); in new()
177 buffer: buffer.into(), in new()
224 let task = self.buffer[(pos & MASK) as usize].get(); in pop_front()
271 let ptr = self.buffer[idx].get(); in push_back()
314 let task_ptr = self.buffer[src_idx].get(); in push_overflowed()
383 let task_ptr = self.buffer[src_idx].get(); in steal_into()
386 let ptr = dst.inner.buffer[des_idx].get(); in steal_into()
396 let task_ptr = self.buffer[src_idx].get(); in steal_into()
[all …]
/commonlibrary/ets_utils/js_sys_module/process/
Djs_childprocess.h144 static void EndStdOut(napi_env env, napi_status status, void* buffer);
146 static void EndStdErr(napi_env env, napi_status status, void* buffer);
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
Dencoder.rs564 let mut buffer = [0u8; 256]; in ut_repr_encode_state_encode() localVariable
567 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
571 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
579 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
587 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
595 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
600 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()
608 let result = repr.encode(&mut buffer); in ut_repr_encode_state_encode()

12