| /ohos5.0/foundation/communication/ipc/ipc/native/c/manager/src/ |
| H A D | serializer.c | 55 io->bufferCur = io->bufferBase = (char *)buffer + objectsSize; in IpcIoInit()
56 io->offsetsCur = io->offsetsBase = (size_t *)buffer; in IpcIoInit()
65 if (io != NULL) { in IpcIoAvailable()
162 if (io == NULL) { in WriteInt32()
176 if (io == NULL) { in WriteUint32()
190 if (io == NULL) { in WriteBool()
199 if (io == NULL) { in WriteBoolUnaligned()
213 if (io == NULL) { in WritePointer()
227 if (io == NULL) { in WriteInt8()
236 if (io == NULL) { in WriteInt8Unaligned()
[all …]
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/c/ipc/include/ |
| H A D | serializer.h | 61 int32_t ReadFileDescriptor(IpcIo *io);
63 bool WriteBool(IpcIo *io, bool value);
64 bool WriteInt8(IpcIo *io, int8_t value);
65 bool WriteInt16(IpcIo *io, int16_t value);
66 bool WriteInt32(IpcIo *io, int32_t value);
67 bool WriteInt64(IpcIo *io, int64_t value);
77 bool WriteFloat(IpcIo *io, float value);
82 bool ReadBool(IpcIo *io, bool *value);
83 bool ReadInt8(IpcIo *io, int8_t *value);
91 bool ReadFloat(IpcIo *io, float *value);
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/test/serializer/ |
| H A D | utils_serializer_test.cpp | 968 IpcIo io; variable
985 IpcIo io; variable
1134 IpcIo io; variable
1150 IpcIo io; variable
1167 IpcIo io; variable
1183 IpcIo io; variable
1200 IpcIo io; variable
1216 IpcIo io; variable
1233 IpcIo io; variable
1250 IpcIo io; variable
[all …]
|
| /ohos5.0/foundation/multimedia/media_lite/frameworks/recorder_lite/binder/ |
| H A D | recorder_client.cpp | 114 IpcIo io; in RecorderClient() local
144 IpcIo io; in ~RecorderClient() local
173 IpcIo io; in SetVideoSource() local
191 IpcIo io; in SetVideoEncoder() local
207 IpcIo io; in SetVideoSize() local
224 IpcIo io; in SetVideoFrameRate() local
239 IpcIo io; in SetVideoEncodingBitRate() local
254 IpcIo io; in SetCaptureRate() local
284 IpcIo io; in GetSurface() local
299 IpcIo io; in SetAudioSource() local
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/ipc/small/ |
| H A D | trans_client_proxy.c | 66 IpcIo io; in ClientIpcOnChannelOpened() local
69 WriteString(&io, sessionName); in ClientIpcOnChannelOpened()
118 IpcIo io; in ClientIpcOnChannelBind() local
146 IpcIo io; in ClientIpcOnChannelOpenFailed() local
151 WriteInt32(&io, errCode); in ClientIpcOnChannelOpenFailed()
177 IpcIo io; in ClientIpcOnChannelLinkDown() local
181 WriteInt32(&io, routeType); in ClientIpcOnChannelLinkDown()
206 IpcIo io; in ClientIpcOnChannelClosed() local
235 IpcIo io; in ClientIpcOnChannelMsgReceived() local
281 IpcIo io; in ClientIpcSetChannelInfo() local
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/ipc/src/linux/ |
| H A D | serializer_inner.c | 26 if (io->offsetsCur == NULL) { in IoPushBinderObj()
33 io->offsetsLeft--; in IoPushBinderObj()
34 *(io->offsetsCur) = (char*)ptr - (char*)io->bufferBase; in IoPushBinderObj()
35 io->offsetsCur++; in IoPushBinderObj()
38 io->flag |= IPC_IO_OVERFLOW; in IoPushBinderObj()
73 if (io->offsetsCur == NULL) { in IpcIoPopRef()
77 if (io->offsetsLeft == 0) { in IpcIoPopRef()
83 io->offsetsCur++; in IpcIoPopRef()
84 io->offsetsLeft--; in IpcIoPopRef()
129 if (io == NULL) { in WriteFileDescriptor()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 16 use std::os::unix::io::AsRawFd;
17 use std::{fmt, io, net};
134 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
150 pub fn ttl(&self) -> io::Result<u32> { in ttl()
308 pub fn broadcast(&self) -> io::Result<bool> { in broadcast()
330 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
499 pub fn ttl(&self) -> io::Result<u32> { in ttl()
655 pub fn broadcast(&self) -> io::Result<bool> { in broadcast()
739 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
762 ) -> io::Result<()> { in register()
[all …]
|
| /ohos5.0/foundation/window/window_manager_lite/frameworks/wms/ |
| H A D | lite_win_requestor.cpp | 73 IpcIo io; in GetSurface() local
91 IpcIo io; in Show() local
94 WriteInt32(&io, id_); in Show()
104 IpcIo io; in Hide() local
117 IpcIo io; in RaiseToTop() local
130 IpcIo io; in LowerToBottom() local
143 IpcIo io; in MoveTo() local
147 WriteUint32(&io, x); in MoveTo()
148 WriteUint32(&io, y); in MoveTo()
158 IpcIo io; in Resize() local
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 15 use std::io;
16 use std::io::{Read, Write};
27 use crate::io::{poll_ready, ReadBuf};
35 io: Option<E>, field
63 pub fn new(mut io: E, interest: Option<Interest>) -> io::Result<AsyncSource<E>> { in new()
69 io: Some(io), in new()
98 let mut io = self.io.take().unwrap(); localVariable
100 Ok(io)
141 ) -> io::Result<R> {
179 ) -> Poll<io::Result<()>>
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | driver_handle.rs | 16 use std::io;
41 pub(crate) io: IoHandle,
67 self.io.register_source(io, interest)
70 pub(crate) fn io_deregister(&self, io: &mut impl Source) -> io::Result<()> {
71 self.io.deregister_source(io)
109 ) -> io::Result<()> {
110 self.io.register_source_with_token(io, token, interest)
117 use std::io;
126 io: &'static IoHandle,
139 self.io.register_source(io, interest)
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 16 use std::os::windows::io::{AsRawSocket, RawSocket};
17 use std::{fmt, io, net};
92 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr()
189 pub fn broadcast(&self) -> io::Result<bool> { in broadcast()
220 pub fn ttl(&self) -> io::Result<u32> { in ttl()
242 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
409 pub fn ttl(&self) -> io::Result<u32> { in ttl()
535 pub fn broadcast(&self) -> io::Result<bool> { in broadcast()
619 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
642 ) -> io::Result<()> { in register()
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/ |
| H A D | serializer_inner.c | 45 IPC_IO_RETURN_IF_FAIL(io != NULL); in IoPushSpecObj()
49 io->offsetsLeft--; in IoPushSpecObj()
50 *(io->offsetsCur) = (char*)ptr - io->bufferBase; in IoPushSpecObj()
51 io->offsetsCur++; in IoPushSpecObj()
54 io->flag |= IPC_IO_OVERFLOW; in IoPushSpecObj()
63 if ((io->offsetsLeft == 0) || (*(io->offsetsCur) != io->bufferCur - io->bufferBase)) { in IoPopSpecObj()
69 io->offsetsCur++; in IoPopSpecObj()
70 io->offsetsLeft--; in IoPopSpecObj()
75 io->flag |= IPC_IO_OVERFLOW; in IoPopSpecObj()
107 if (io == NULL) { in WriteRemoteObject()
[all …]
|
| /ohos5.0/base/startup/init/interfaces/innerkits/fs_manager/libfs_dm/ |
| H A D | fs_dm.c | 56 err = memset_s(io, sizeof(*io), 0, sizeof(*io)); in InitDmIo()
65 io->data_size = sizeof(*io); in InitDmIo()
66 io->data_start = 0; in InitDmIo()
72 err = strcpy_s(io->name, sizeof(io->name), devName); in InitDmIo()
84 struct dm_ioctl io; in CreateDmDevice() local
133 io->data_start = sizeof(*io); in LoadDmDeviceTable()
172 struct dm_ioctl io; in ActiveDmDevice() local
196 struct dm_ioctl io; in GetDmDevPath() local
311 struct dm_ioctl io; in FsDmRemoveDevice() local
344 struct dm_ioctl io; in DmGetDeviceName() local
[all …]
|
| /ohos5.0/foundation/multimedia/media_lite/frameworks/player_lite/binder/ |
| H A D | player_client.cpp | 209 IpcIo io; in SetSource() local
245 IpcIo io; in Prepare() local
261 IpcIo io; in Play() local
277 IpcIo io; in IsPlaying() local
293 IpcIo io; in Pause() local
309 IpcIo io; in Stop() local
324 IpcIo io; in Rewind() local
342 IpcIo io; in SetVolume() local
360 IpcIo io; in SetSurface() local
388 IpcIo io; in SetLoop() local
[all …]
|
| /ohos5.0/foundation/graphic/surface_lite/frameworks/ |
| H A D | buffer_queue_producer.cpp | 33 ReadUint8(io, &isWaiting); in OnRequestBuffer()
51 buffer.ReadFromIpcIo(*io); in OnFlushBuffer()
59 buffer.ReadFromIpcIo(*io); in OnCancelBuffer()
81 ReadUint32(io, &queueSize); in OnSetQueueSize()
83 return OnSendReply(io, reply); in OnSetQueueSize()
94 ReadUint32(io, &width); in OnSetWidthAndHeight()
96 ReadUint32(io, &height); in OnSetWidthAndHeight()
114 ReadUint32(io, &format); in OnSetFormat()
145 ReadUint32(io, &size); in OnSetSize()
158 ReadUint32(io, &usage); in OnSetUsage()
[all …]
|
| /ohos5.0/foundation/multimedia/camera_lite/frameworks/binder/src/ |
| H A D | camera_device_client.cpp | 87 IpcIo io; in SetCameraConfig() local
123 WriteInt32(&io, qfactor); in SerilizeFrameConfig()
127 WriteInt32(&io, streamFps); in SerilizeFrameConfig()
131 WriteInt32(&io, invertMode); in SerilizeFrameConfig()
142 WriteInt32(&io, format); in SerilizeFrameConfig()
156 IpcIo io; in TriggerLoopingCapture() local
184 IpcIo io; in TriggerSingleCapture() local
213 IpcIo io; in StopLoopingCapture() local
221 WriteInt32(&io, type); in StopLoopingCapture()
233 IpcIo io; in Release() local
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 14 use std::io::{self, IoSlice, IoSliceMut, Read, Write};
16 use std::os::unix::io::AsRawFd;
44 pub fn try_clone(&self) -> io::Result<Self> { in try_clone()
66 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr()
86 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr()
117 pub fn nodelay(&self) -> io::Result<bool> { in nodelay()
185 pub fn ttl(&self) -> io::Result<u32> { in ttl()
190 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
239 fn flush(&mut self) -> io::Result<()> { in flush()
267 fn flush(&mut self) -> io::Result<()> { in flush()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/bus_center/ipc/small/src/ |
| H A D | bus_center_client_proxy.c | 76 IpcIo io; in ClientOnJoinLNNResult() local
81 WriteInt32(&io, retCode); in ClientOnJoinLNNResult()
108 IpcIo io; in ClientOnLeaveLNNResult() local
112 WriteInt32(&io, retCode); in ClientOnLeaveLNNResult()
136 IpcIo io; in ClinetOnNodeOnlineStateChanged() local
184 IpcIo io; in ClinetOnNodeBasicInfoChanged() local
187 WriteInt32(&io, type); in ClinetOnNodeBasicInfoChanged()
234 IpcIo io; in ClientOnTimeSyncResult() local
265 IpcIo io; in ClientOnPublishLNNResult() local
295 IpcIo io; in ClientOnRefreshLNNResult() local
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 16 use std::io::IoSlice;
21 use std::{fmt, io};
64 type Output = io::Result<ExitStatus>;
92 pub(crate) fn stdio<T: IntoRawFd>(io: T) -> io::Result<ChildStdio> { in stdio()
93 let mut pipe = Pipe::from(io); in stdio()
99 fn to_blocking_file(io: ChildStdio) -> io::Result<File> { in to_blocking_file()
124 pub(crate) fn to_stdio(io: ChildStdio) -> io::Result<Stdio> { in to_stdio()
125 to_blocking_file(io).map(Stdio::from) in to_stdio()
144 ) -> Poll<io::Result<usize>> { in poll_write()
152 ) -> Poll<io::Result<usize>> { in poll_write_vectored()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 15 use std::io::{IoSlice, IoSliceMut, Read, Write};
19 use std::{fmt, io, net};
61 pub fn try_clone(&self) -> io::Result<Self> { in try_clone()
84 pub fn local_addr(&self) -> io::Result<SocketAddr> { in local_addr()
104 pub fn peer_addr(&self) -> io::Result<SocketAddr> { in peer_addr()
154 pub fn nodelay(&self) -> io::Result<bool> { in nodelay()
206 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
222 pub fn ttl(&self) -> io::Result<u32> { in ttl()
237 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
289 fn flush(&mut self) -> io::Result<()> {
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_json/src/reader/ |
| H A D | io_reader.rs | 15 use std::io::{Error, ErrorKind, Read, Result};
31 io: R, field
57 pub(crate) fn new(io: R) -> Self { in new()
59 io, in new()
228 use std::io::{ErrorKind, Read};
302 let io = TestIo::new(Vec::new()); in ut_io_reader_new() localVariable
339 let io = TestWouldBlockIo::new(); in ut_io_reader_next() localVariable
345 let io = TestErrIo::new(); in ut_io_reader_next() localVariable
378 let io = TestErrIo::new(); in ut_io_reader_peek() localVariable
483 let io = TestIo::new(vec![1]); in ut_io_reader_start_caching() localVariable
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 14 use std::io::{Cursor, Read};
82 io: Option<BoxStreamData>, field
90 io: Some(io), in new()
139 if let Some(io) = self.io.take() { in data()
154 if let Some(mut io) = self.io.take() { in data()
179 self.io = Some(io); in data()
192 io: Option<BoxStreamData>, field
200 io: Some(io), in new()
226 self.io = None; in data()
235 while let Some(mut io) = self.io.take() { in data()
[all …]
|
| /ohos5.0/foundation/bundlemanager/bundle_framework_lite/frameworks/bundle_lite/src/ |
| H A D | element_name.cpp | 92 WriteInt32(io, VALUE_NULL); in SerializeElement()
96 WriteInt32(io, VALUE_OBJECT); in SerializeElement()
97 WriteString(io, element->deviceId); in SerializeElement()
100 WriteInt32(io, VALUE_NULL); in SerializeElement()
104 WriteInt32(io, VALUE_OBJECT); in SerializeElement()
105 WriteString(io, element->bundleName); in SerializeElement()
108 WriteInt32(io, VALUE_NULL); in SerializeElement()
112 WriteInt32(io, VALUE_OBJECT); in SerializeElement()
125 ReadInt32(io, &naspac); in DeserializeElement()
130 ReadInt32(io, &naspac); in DeserializeElement()
[all …]
|
| /ohos5.0/foundation/multimedia/audio_lite/frameworks/binder/ |
| H A D | audio_capturer_client.cpp | 135 IpcIo io; in AudioCapturerClient() local
188 IpcIo io; in ~AudioCapturerClient() local
208 IpcIo io; in GetMinFrameCount() local
211 WriteInt32(&io, sampleRate); in GetMinFrameCount()
227 IpcIo io; in GetFrameCount() local
248 IpcIo io; in GetStatus() local
275 IpcIo io; in SetCapturerInfo() local
297 IpcIo io; in GetCapturerInfo() local
317 IpcIo io; in Start() local
338 IpcIo io; in Stop() local
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 15 use std::io;
22 use crate::io::ReadBuf;
181 io::ErrorKind::InvalidInput, in connect()
239 None => Err(io::Error::new( in send_to()
312 ) -> Poll<io::Result<usize>> { in poll_send_to()
472 ) -> Poll<io::Result<SocketAddr>> { in poll_peek_from()
572 ) -> Poll<io::Result<SocketAddr>> { in poll_recv_from()
696 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
1342 pub fn take_error(&self) -> io::Result<Option<io::Error>> { in take_error()
1444 use std::io;
[all …]
|