Home
last modified time | relevance | path

Searched refs:read (Results 1 - 25 of 378) sorted by relevance

12345678910>>...16

/foundation/communication/ipc/interfaces/innerkits/rust/tests/
H A Dparcel_remote.rs65 reply.write(&data.read::<bool>().unwrap()); in parcel_remote_primitive()
66 reply.write(&data.read::<bool>().unwrap()); in parcel_remote_primitive()
67 reply.write(&data.read::<i8>().unwrap()); in parcel_remote_primitive()
68 reply.write(&data.read::<i8>().unwrap()); in parcel_remote_primitive()
69 reply.write(&data.read::<i16>().unwrap()); in parcel_remote_primitive()
70 reply.write(&data.read::<i16>().unwrap()); in parcel_remote_primitive()
71 reply.write(&data.read::<i32>().unwrap()); in parcel_remote_primitive()
72 reply.write(&data.read::<i32>().unwrap()); in parcel_remote_primitive()
73 reply.write(&data.read::<i64>().unwrap()); in parcel_remote_primitive()
74 reply.write(&data.read in parcel_remote_primitive()
[all...]
H A Dinteractive.rs23 assert!(msg.read::<bool>().unwrap()); in check_parcel()
24 assert_eq!(msg.read::<u8>().unwrap(), u8::MAX); in check_parcel()
25 assert_eq!(msg.read::<u16>().unwrap(), u16::MAX); in check_parcel()
26 assert_eq!(msg.read::<u32>().unwrap(), u32::MAX); in check_parcel()
27 assert_eq!(msg.read::<u64>().unwrap(), u64::MAX); in check_parcel()
29 assert_eq!(msg.read::<i8>().unwrap(), i8::MAX); in check_parcel()
30 assert_eq!(msg.read::<i16>().unwrap(), i16::MAX); in check_parcel()
31 assert_eq!(msg.read::<i32>().unwrap(), i32::MAX); in check_parcel()
32 assert_eq!(msg.read::<i64>().unwrap(), i64::MAX); in check_parcel()
34 assert_eq!(msg.read in check_parcel()
[all...]
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dlock_free_queue.c36 queue->read = 0; in LFQUE_Create()
48 return (nextWrite == queue->read); in LFQUE_IsFull()
53 return (queue->write == queue->read); in LFQUE_IsEmpty()
98 uint32 copyLen = (queue->totalSize - queue->read < queue->itemSize) ? in LFQUE_Pop()
99 (queue->totalSize - queue->read) : queue->itemSize; in LFQUE_Pop()
100 if (memcpy_s(element, copyLen, &queue->buffer[queue->read], copyLen) != EOK) { in LFQUE_Pop()
112 uint32 read = queue->read + queue->itemSize; in LFQUE_Pop() local
113 if (read >= queue->totalSize) { in LFQUE_Pop()
114 read in LFQUE_Pop()
[all...]
/foundation/ability/idl_tool/test/rust/moduletest/service/src/
H A DIIdlTestService.rs77 let i_bool : bool = data.read()?; in on_remote_request()
83 let i_byte : i8 = data.read()?; in on_remote_request()
89 let i_short : i16 = data.read()?; in on_remote_request()
95 let i_int : i32 = data.read()?; in on_remote_request()
101 let i_long : i64 = data.read()?; in on_remote_request()
107 let i_float : f32 = data.read()?; in on_remote_request()
113 let i_double : f64 = data.read()?; in on_remote_request()
119 let i_string : String = data.read()?; in on_remote_request()
125 let i_bool : bool = data.read()?; in on_remote_request()
126 let i_long : i64 = data.read() in on_remote_request()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/
H A Dconnect.rs54 let time = parcel.read::<u64>()?; in deserialize()
106 let index = parcel.read::<i32>()?; in deserialize()
144 let index = parcel.read::<u32>()?; in deserialize()
219 let index = parcel.read::<u32>()?; in deserialize()
223 let number = parcel.read::<i64>()?; in deserialize()
227 let real = parcel.read::<f64>()?; in deserialize()
235 let boolean = parcel.read::<bool>()?; in deserialize()
239 let blob = parcel.read::<Vec<u8>>()?; in deserialize()
243 let asset = parcel.read::<CloudAsset>()?; in deserialize()
247 let assets = parcel.read in deserialize()
534 fn read(&mut self, msg_parcel: &mut MsgParcel) -> Result<(), Error> { read() functions
619 fn read(&mut self, msg_parcel: &mut MsgParcel) -> Result<(), Error> { read() functions
[all...]
H A Dmod.rs56 let length = msg_parcel.read::<i32>()?;
60 let value = msg_parcel.read::<V>()?;
78 let length = msg_parcel.read::<i32>()? as usize;
81 let value = msg_parcel.read::<T>()?;
113 assert_eq!(parcel.read::<i32>().unwrap(), 3); in ut_vec_raw_write()
114 assert_eq!(parcel.read::<String>().unwrap(), String::from("value1")); in ut_vec_raw_write()
115 assert_eq!(parcel.read::<String>().unwrap(), String::from("value2")); in ut_vec_raw_write()
116 assert_eq!(parcel.read::<String>().unwrap(), String::from("value3")); in ut_vec_raw_write()
H A Ddatabase.rs42 let interval = parcel.read::<i32>()?; in deserialize()
43 let session_id = parcel.read::<i32>()?; in deserialize()
94 let length = parcel.read::<i32>()? as usize; in deserialize()
122 .read::<Error>()
128 .read::<Ids>()
163 .read::<i32>()
167 .read::<Error>()
174 .read::<ValueBucket>()
210 .read::<i32>()
214 .read
[all...]
H A Dasset.rs147 let operation_type = parcel.read::<AssetStatus>()?; in deserialize()
239 .read::<i32>()
243 .read::<Error>()
249 .read::<CloudAsset>()
291 .read::<i32>()
295 .read::<Error>()
301 .read::<CloudAsset>()
/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/
H A Dexts.rs43 /// Data structures that can be deserialized and read out by MsgPracel,typically
59 /// let a = parcel.read()?;
60 /// let b = parcel.read()?;
66 /// Deserialize and read out from MsgParcel.
86 let null: i32 = parcel.read()?; in deserialize()
90 parcel.read().map(Some) in deserialize()
110 /// 2. Write this type to the MsgParcel and then read it out, check the
128 assert!(msg.read::<bool>().unwrap()); in serialize_test()
129 assert_eq!(String::from("hello"), msg.read::<String>().unwrap()); in serialize_test()
136 /// 2. Write this type to the MsgParcel and then read i
[all...]
H A Dwrapper.rs536 fn read<T: Process>(parcel: Pin<&mut MessageParcel>) -> IpcResult<T> { in deserialize() functions
542 parcel.read_process(read) in deserialize()
590 /// 2. Write a value to the MsgParcel and then read it out, check the
604 assert!(msg.read::<bool>().unwrap()); in primitive()
607 assert!(!msg.read::<bool>().unwrap()); in primitive()
610 assert_eq!(i8::MAX, msg.read().unwrap()); in primitive()
612 assert_eq!(i8::MIN, msg.read().unwrap()); in primitive()
615 assert_eq!(i16::MAX, msg.read().unwrap()); in primitive()
617 assert_eq!(i16::MIN, msg.read().unwrap()); in primitive()
620 assert_eq!(i32::MAX, msg.read() in primitive()
[all...]
/foundation/communication/ipc/example/rust_test/service/src/
H A Dlib.rs102 let num1: i32 = data.read().expect("Failed to read num1 in addition operation"); in on_icalc_remote_request()
103 let num2: i32 = data.read().expect("Failed to read num2 in addition operation"); in on_icalc_remote_request()
109 let num1: i32 = data.read().expect("Failed to read num1 in subtraction operation"); in on_icalc_remote_request()
110 let num2: i32 = data.read().expect("Failed to read num1 in subtraction operation"); in on_icalc_remote_request()
116 let num1: i32 = data.read().expect("Failed to read num in on_icalc_remote_request()
[all...]
/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/examples/audio_rust_sa/src/
H A Dproxy.rs34 reply.read().unwrap() in on_start_reason()
43 reply.read().unwrap() in on_idle_reason()
52 reply.read().unwrap() in on_active_reason()
61 reply.read().unwrap() in on_add()
70 reply.read().unwrap() in on_remove()
86 reply.read().unwrap() in get_stop_reason()
/foundation/arkui/ace_engine/adapter/preview/sdk/dump/
H A Dresource_index.py111 header = fp_resource_index.read(128)
112 length = fp_resource_index.read(4)
113 key_count = fp_resource_index.read(4)
121 buf = fp_resource_index.read(4)
124 buf = fp_resource_index.read(4)
127 buf = fp_resource_index.read(4)
133 buf = fp_resource_index.read(8)
149 idss_buf = fp_resource_index.read(4)
151 idss_buf = fp_resource_index.read(4)
156 buf = fp_resource_index.read(
[all...]
/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/test/unittest/
H A Degl_wrapper_context_test.cpp47 EGLSurface read = nullptr; in HWTEST_F() local
48 ctx.SetCurrentSurface(draw, read); in HWTEST_F()
51 ASSERT_EQ(read, result); in HWTEST_F()
/foundation/multimedia/av_codec/test/moduletest/muxer/InnerAPI/
H A DInnerAVMuxerStablityTest.cpp73 read(g_inputFile, static_cast<void *>(&extraSize), sizeof(extraSize)); in AddTrack()
76 read(g_inputFile, buffer.data(), extraSize); in AddTrack()
103 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddAudioTrack()
106 read(g_inputFile, buffer.data(), extraSize); in AddAudioTrack()
121 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddAudioTrackAAC()
124 read(g_inputFile, buffer.data(), extraSize); in AddAudioTrackAAC()
140 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddVideoTrack()
143 read(g_inputFile, buffer.data(), extraSize); in AddVideoTrack()
158 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in RemoveHeader()
160 read(g_inputFil in RemoveHeader()
[all...]
H A DInnerAVMuxerFunctionTest.cpp61 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddAudioTrack()
64 read(g_inputFile, buffer.data(), extraSize); in AddAudioTrack()
81 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddAudioTrackAAC()
84 read(g_inputFile, buffer.data(), extraSize); in AddAudioTrackAAC()
101 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddVideoTrack()
104 read(g_inputFile, buffer.data(), extraSize); in AddVideoTrack()
139 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in RemoveHeader()
141 read(g_inputFile, buffer, extraSize); in RemoveHeader()
155 ret = read(g_inputFile, static_cast<void*>(&dataTrackId), sizeof(dataTrackId)); in WriteTrackSample()
159 ret = read(g_inputFil in WriteTrackSample()
[all...]
/foundation/multimedia/av_codec/test/unittest/video_test/video_test/capbilities/data_producer/raw_data_reader/
H A Drawdata_reader.cpp60 inputFile_->read(reinterpret_cast<char *>(bufferAddr), width * 4); // 4: RGBA 4 channels in ReadInputBufferWithStrideRGBA()
72 inputFile_->read(reinterpret_cast<char *>(bufferAddr), width); in ReadInputBufferWithStrideYUVI420()
77 inputFile_->read(reinterpret_cast<char *>(bufferAddr), width / RATIO_CHROMA_UV); in ReadInputBufferWithStrideYUVI420()
89 inputFile_->read(reinterpret_cast<char *>(bufferAddr), width); in ReadInputBufferWithStrideYUV420()
94 inputFile_->read(reinterpret_cast<char *>(bufferAddr), width); in ReadInputBufferWithStrideYUV420()
/foundation/graphic/graphic_3d/lume/LumeRender/src/gles/
H A Dshader_module_gles.cpp187 Reader read { ptr }; in ProcessShaderModule()
188 const auto constants = read.GetUint8(); in ProcessShaderModule()
191 refl.type = read.GetUint32(); in ProcessShaderModule()
192 refl.offset = read.GetUint16(); in ProcessShaderModule()
193 refl.size = read.GetUint16(); in ProcessShaderModule()
194 refl.arraySize = read.GetUint16(); in ProcessShaderModule()
195 refl.arrayStride = read.GetUint16(); in ProcessShaderModule()
196 refl.matrixStride = read.GetUint16(); in ProcessShaderModule()
198 refl.name += read.GetStringView(); in ProcessShaderModule()
/foundation/multimedia/av_codec/test/unittest/video_test/vcodec_framework_test/stable_sample/sample/encoder/
H A Dvenc_sample.cpp50 signal->inFile_->read(reinterpret_cast<char *>(addr), width); in ReadYUV420SP()
66 signal->inFile_->read(reinterpret_cast<char *>(addr), width); in ReadYUV420P()
73 signal->inFile_->read(reinterpret_cast<char *>(addr), width); in ReadYUV420P()
87 signal->inFile_->read(reinterpret_cast<char *>(addr), width); in ReadRGBA()
593 (void)signal_->inFile_->read(dst + i, sampleWidth_);
/foundation/graphic/graphic_2d/frameworks/opengl_wrapper/src/EGL/
H A Degl_wrapper_context.cpp33 void EglWrapperContext::SetCurrentSurface(EGLSurface draw, EGLSurface read) in SetCurrentSurface() argument
37 read_ = read; in SetCurrentSurface()
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/
H A Drs_profiler_base.cpp614 data.read(reinterpret_cast<char*>(&size), sizeof(size)); in CreateRenderSurfaceNode()
618 data.read(reinterpret_cast<char*>(name.data()), size); in CreateRenderSurfaceNode()
620 data.read(reinterpret_cast<char*>(&size), sizeof(size)); in CreateRenderSurfaceNode()
623 data.read(reinterpret_cast<char*>(bundleName.data()), size); in CreateRenderSurfaceNode()
626 data.read(reinterpret_cast<char*>(&nodeType), sizeof(nodeType)); in CreateRenderSurfaceNode()
629 data.read(reinterpret_cast<char*>(&backgroundAlpha), sizeof(backgroundAlpha)); in CreateRenderSurfaceNode()
632 data.read(reinterpret_cast<char*>(&globalAlpha), sizeof(globalAlpha)); in CreateRenderSurfaceNode()
651 data.read(reinterpret_cast<char*>(&count), sizeof(count)); in UnmarshalNodes()
656 data.read(reinterpret_cast<char*>(&count), sizeof(count)); in UnmarshalNodes()
676 data.read(reinterpret_cas in UnmarshalNode()
[all...]
/foundation/multimedia/av_codec/test/moduletest/muxer/NativeAPI/
H A DNativeAVMuxerFunctionTest.cpp75 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddAudioTrack()
78 read(g_inputFile, buffer, extraSize); in AddAudioTrack()
103 read(g_inputFile, static_cast<void*>(&extraSize), sizeof(extraSize)); in AddVideoTrack()
106 read(g_inputFile, buffer, extraSize); in AddVideoTrack()
149 ret = read(g_inputFile, static_cast<void*>(&dataTrackId), sizeof(dataTrackId)); in ReadFile()
151 cout << "read dataTrackId error, ret is: " << ret << endl; in ReadFile()
154 ret = read(g_inputFile, static_cast<void*>(&pts), sizeof(pts)); in ReadFile()
156 cout << "read info.pts error, ret is: " << ret << endl; in ReadFile()
159 ret = read(g_inputFile, static_cast<void*>(&dataSize), sizeof(dataSize)); in ReadFile()
161 cout << "read dataSiz in ReadFile()
[all...]
/foundation/multimedia/av_codec/test/nativedemo/avmuxer/
H A Davmuxer_demo_base.cpp327 file->read(reinterpret_cast<char*>(&pts), sizeof(pts)); in ReadSampleDataInfo()
332 file->read(reinterpret_cast<char*>(&flags), sizeof(flags)); in ReadSampleDataInfo()
337 file->read(reinterpret_cast<char*>(&size), sizeof(size)); in ReadSampleDataInfo()
346 file->read(reinterpret_cast<char*>(buffer->memory_->GetAddr()), size); in ReadSampleDataInfo()
362 file->read(reinterpret_cast<char*>(&pts), sizeof(pts)); in ReadSampleDataInfoByBufferQueue()
367 file->read(reinterpret_cast<char*>(&flags), sizeof(flags)); in ReadSampleDataInfoByBufferQueue()
372 file->read(reinterpret_cast<char*>(&size), sizeof(size)); in ReadSampleDataInfoByBufferQueue()
384 file->read(reinterpret_cast<char*>(buffer->memory_->GetAddr()), size); in ReadSampleDataInfoByBufferQueue()
527 coverFile_->read(reinterpret_cast<char*>(avMemBuffer->memory_->GetAddr()), size); in WriteCoverSample()
556 videoFile_->read(reinterpret_cas in AddVideoTrack()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/systemtest/
H A Dvsync_ltpo_test.cpp164 read(pipeFd[0], &changeRefreshRate, sizeof(changeRefreshRate)); in Process1()
179 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
213 read(pipeFd[0], &changeRefreshRate, sizeof(changeRefreshRate)); in Process1()
227 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
261 read(pipeFd[0], &changeRefreshRate, sizeof(changeRefreshRate)); in Process1()
275 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
309 read(pipeFd[0], &changeRefreshRate, sizeof(changeRefreshRate)); in Process1()
323 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
355 read(pipeFd[0], buf, sizeof(buf)); in Process1()
368 read(pipe1F in Process2()
[all...]
/foundation/ai/ai_engine/services/server/plugin_manager/
H A Dget_config_ini.py75 config.read(config_file_path)
81 config.read(config_file_path, encoding=code)
89 config.read(config_file_path, encoding=encoding)
173 ini_content = file_object.read()

Completed in 15 milliseconds

12345678910>>...16