/foundation/communication/ipc/interfaces/innerkits/c/ipc/include/ |
H A D | serializer.h | 49 #define IPC_IO_INITIALIZED 0x01 /* ipc flag indicates whether io is initialized */ 50 #define IPC_IO_OVERFLOW 0x02 /* ipc flag indicates whether io is running out of space */ 54 void IpcIoInit(IpcIo* io, void* buffer, size_t bufferSize, size_t maxobjects); 57 bool WriteRemoteObject(IpcIo *io, const SvcIdentity *svc); 58 bool WriteFileDescriptor(IpcIo *io, uint32_t fd); 60 bool ReadRemoteObject(IpcIo *io, SvcIdentity *svc); 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_ [all...] |
/foundation/communication/ipc/ipc/native/c/manager/src/ |
H A D | serializer.c | 32 if (io != NULL) { \ 33 io->flag |= IPC_IO_OVERFLOW; \ 40 void IpcIoInit(IpcIo *io, void *buffer, size_t bufferSize, size_t maxobjects) in IpcIoInit() argument 42 if ((io == NULL) || (buffer == NULL) || (bufferSize == 0) || in IpcIoInit() 49 io->flag = IPC_IO_OVERFLOW; in IpcIoInit() 50 io->bufferLeft = 0; in IpcIoInit() 51 io->offsetsLeft = 0; in IpcIoInit() 55 io->bufferCur = io->bufferBase = (char *)buffer + objectsSize; in IpcIoInit() 56 io in IpcIoInit() 62 IpcIoAvailable(IpcIo *io) IpcIoAvailable() argument 71 IoPush(IpcIo *io, size_t size) IoPush() argument 88 IoPop(IpcIo *io, size_t size) IoPop() argument 106 IoPushUnaligned(IpcIo *io, size_t size) IoPushUnaligned() argument 160 WriteInt32(IpcIo *io, int32_t value) WriteInt32() argument 174 WriteUint32(IpcIo *io, uint32_t value) WriteUint32() argument 188 WriteBool(IpcIo *io, bool value) WriteBool() argument 197 WriteBoolUnaligned(IpcIo *io, bool value) WriteBoolUnaligned() argument 211 WritePointer(IpcIo *io, uintptr_t value) WritePointer() argument 225 WriteInt8(IpcIo *io, int8_t value) WriteInt8() argument 234 WriteInt8Unaligned(IpcIo *io, int8_t value) WriteInt8Unaligned() argument 248 WriteUint8(IpcIo *io, uint8_t value) WriteUint8() argument 257 WriteUint8Unaligned(IpcIo *io, uint8_t value) WriteUint8Unaligned() argument 271 WriteInt16(IpcIo *io, int16_t value) WriteInt16() argument 280 WriteInt16Unaligned(IpcIo *io, int16_t value) WriteInt16Unaligned() argument 294 WriteUint16(IpcIo *io, uint16_t value) WriteUint16() argument 303 WriteUint16Unaligned(IpcIo *io, uint16_t value) WriteUint16Unaligned() argument 317 WriteInt64(IpcIo *io, int64_t value) WriteInt64() argument 331 WriteUint64(IpcIo *io, uint64_t value) WriteUint64() argument 345 WriteFloat(IpcIo *io, float value) WriteFloat() argument 359 WriteDouble(IpcIo *io, double value) WriteDouble() argument 373 WriteString(IpcIo *io, const char *value) WriteString() argument 408 IoPopUnaligned(IpcIo *io, size_t size) IoPopUnaligned() argument 425 ReadBool(IpcIo *io, bool *value) ReadBool() argument 439 ReadBoolUnaligned(IpcIo *io, bool *value) ReadBoolUnaligned() argument 453 ReadPointer(IpcIo *io) ReadPointer() argument 463 ReadInt8(IpcIo *io, int8_t *value) ReadInt8() argument 477 ReadInt8Unaligned(IpcIo *io, int8_t *value) ReadInt8Unaligned() argument 491 ReadUint8(IpcIo *io, uint8_t *value) ReadUint8() argument 505 ReadUInt8Unaligned(IpcIo *io, uint8_t *value) ReadUInt8Unaligned() argument 519 ReadInt16(IpcIo *io, int16_t *value) ReadInt16() argument 533 ReadInt16Unaligned(IpcIo *io, int16_t *value) ReadInt16Unaligned() argument 547 ReadUint16(IpcIo *io, uint16_t *value) ReadUint16() argument 561 ReadUInt16Unaligned(IpcIo *io, uint16_t *value) ReadUInt16Unaligned() argument 575 ReadInt32(IpcIo *io, int32_t *value) ReadInt32() argument 589 ReadUint32(IpcIo *io, uint32_t *value) ReadUint32() argument 603 ReadInt64(IpcIo *io, int64_t *value) ReadInt64() argument 617 ReadUint64(IpcIo *io, uint64_t *value) ReadUint64() argument 631 ReadFloat(IpcIo *io, float *value) ReadFloat() argument 645 ReadDouble(IpcIo *io, double *value) ReadDouble() argument 659 ReadString(IpcIo *io, size_t *len) ReadString() argument 681 WriteBufferAddTerminator(IpcIo *io, const void *value, size_t size, size_t sizeType) WriteBufferAddTerminator() argument 712 WriteString16(IpcIo *io, const uint16_t *value, size_t len) WriteString16() argument 736 WriteBuffer(IpcIo *io, const void *data, size_t size) WriteBuffer() argument 766 WriteInterfaceToken(IpcIo *io, const uint16_t *name, size_t len) WriteInterfaceToken() argument 785 WriteRawData(IpcIo *io, const void *data, size_t size) WriteRawData() argument 805 WriteBoolVector(IpcIo *io, const bool *val, size_t size) WriteBoolVector() argument 825 WriteInt8Vector(IpcIo *io, const int8_t *val, size_t size) WriteInt8Vector() argument 849 WriteInt16Vector(IpcIo *io, const int16_t *val, size_t size) WriteInt16Vector() argument 869 WriteInt32Vector(IpcIo *io, const int32_t *val, size_t size) WriteInt32Vector() argument 893 WriteInt64Vector(IpcIo *io, const int64_t *val, size_t size) WriteInt64Vector() argument 917 WriteUInt8Vector(IpcIo *io, const uint8_t *val, size_t size) WriteUInt8Vector() argument 941 WriteUInt16Vector(IpcIo *io, const uint16_t *val, size_t size) WriteUInt16Vector() argument 965 WriteUInt32Vector(IpcIo *io, const uint32_t *val, size_t size) WriteUInt32Vector() argument 989 WriteUInt64Vector(IpcIo *io, const uint64_t *val, size_t size) WriteUInt64Vector() argument 1013 WriteFloatVector(IpcIo *io, const float *val, size_t size) WriteFloatVector() argument 1037 WriteDoubleVector(IpcIo *io, const double *val, size_t size) WriteDoubleVector() argument 1061 ReadString16(IpcIo *io, size_t *len) ReadString16() argument 1082 ReadInterfaceToken(IpcIo *io, size_t *len) ReadInterfaceToken() argument 1103 ReadBuffer(IpcIo *io, size_t size) ReadBuffer() argument 1112 ReadRawData(IpcIo *io, size_t size) ReadRawData() argument 1126 ReadBoolVector(IpcIo *io, size_t *size) ReadBoolVector() argument 1156 ReadInt8Vector(IpcIo *io, size_t *size) ReadInt8Vector() argument 1177 ReadInt16Vector(IpcIo *io, size_t *size) ReadInt16Vector() argument 1206 ReadInt32Vector(IpcIo *io, size_t *size) ReadInt32Vector() argument 1227 ReadInt64Vector(IpcIo *io, size_t *size) ReadInt64Vector() argument 1248 ReadUInt8Vector(IpcIo *io, size_t *size) ReadUInt8Vector() argument 1269 ReadUInt16Vector(IpcIo *io, size_t *size) ReadUInt16Vector() argument 1290 ReadUInt32Vector(IpcIo *io, size_t *size) ReadUInt32Vector() argument 1311 ReadUInt64Vector(IpcIo *io, size_t *size) ReadUInt64Vector() argument 1332 ReadFloatVector(IpcIo *io, size_t *size) ReadFloatVector() argument 1353 ReadDoubleVector(IpcIo *io, size_t *size) ReadDoubleVector() argument [all...] |
/foundation/communication/ipc/ipc/native/c/ipc/src/linux/ |
H A D | serializer_inner.c | 24 static struct flat_binder_object *IoPushBinderObj(IpcIo *io) in IoPushBinderObj() argument 26 if (io->offsetsCur == NULL) { in IoPushBinderObj() 31 ptr = IoPush(io, sizeof(struct flat_binder_object)); in IoPushBinderObj() 32 if ((ptr != NULL) && io->offsetsLeft) { 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() 43 static bool IpcIoPushObject(IpcIo *io, uint32_ argument 57 IpcIoPushRef(IpcIo *io, uint32_t handle, uintptr_t cookie) IpcIoPushRef() argument 71 IpcIoPopRef(IpcIo *io) IpcIoPopRef() argument 90 WriteRemoteObject(IpcIo *io, const SvcIdentity *svc) WriteRemoteObject() argument 105 ReadRemoteObject(IpcIo *io, SvcIdentity *svc) ReadRemoteObject() argument 127 WriteFileDescriptor(IpcIo *io, uint32_t fd) WriteFileDescriptor() argument 146 ReadFileDescriptor(IpcIo *io) ReadFileDescriptor() argument [all...] |
/foundation/window/window_manager_lite/frameworks/wms/ |
H A D | lite_win_requestor.cpp | 73 IpcIo io; in GetSurface() local 75 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in GetSurface() 76 WriteInt32(&io, id_); in GetSurface() 81 int32_t ret = proxy_->Invoke(proxy_, LiteWMS_GetSurface, &io, ¶, Callback); in GetSurface() 91 IpcIo io; in Show() local 93 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in Show() 94 WriteInt32(&io, id_); in Show() 96 int32_t ret = proxy_->Invoke(proxy_, LiteWMS_Show, &io, NULL, NULL); in Show() 104 IpcIo io; in Hide() local 106 IpcIoInit(&io, tmpDat in Hide() 117 IpcIo io; RaiseToTop() local 130 IpcIo io; LowerToBottom() local 143 IpcIo io; MoveTo() local 158 IpcIo io; Resize() local 173 IpcIo io; Update() local [all...] |
H A D | lite_wm_requestor.cpp | 98 IpcIo io; in ClientRegister() local 100 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 1); in ClientRegister() 109 WriteRemoteObject(&io, &svc); in ClientRegister() 110 int32_t ret = proxy_->Invoke(proxy_, LiteWMS_ClientRegister, &io, NULL, Callback); in ClientRegister() 118 IpcIo io; in GetLayerInfo() local 120 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in GetLayerInfo() 125 int32_t ret = proxy_->Invoke(proxy_, LiteWMS_GetLayerInfo, &io, ¶, Callback); in GetLayerInfo() 133 IpcIo io; in CreateWindow() local 135 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in CreateWindow() 136 WriteRawData(&io, in CreateWindow() 152 IpcIo io; RemoveWindow() local 165 IpcIo io; GetEventData() local 236 IpcIo io; Screenshot() local [all...] |
/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/ |
H A D | serializer_inner.c | 26 if (io != NULL) { \ 27 io->flag |= IPC_IO_OVERFLOW; \ 43 static SpecialObj* IoPushSpecObj(IpcIo* io) in IoPushSpecObj() argument 45 IPC_IO_RETURN_IF_FAIL(io != NULL); in IoPushSpecObj() 46 IPC_IO_RETURN_IF_FAIL(io->offsetsCur != NULL); in IoPushSpecObj() 47 SpecialObj* ptr = IoPush(io, sizeof(SpecialObj)); in IoPushSpecObj() 48 if ((ptr != NULL) && io->offsetsLeft) { in IoPushSpecObj() 49 io->offsetsLeft--; in IoPushSpecObj() 50 *(io->offsetsCur) = (char*)ptr - io in IoPushSpecObj() 59 IoPopSpecObj(IpcIo* io) IoPopSpecObj() argument 105 WriteRemoteObject(IpcIo *io, const SvcIdentity *svc) WriteRemoteObject() argument 152 ReadRemoteObject(IpcIo *io, SvcIdentity *svc) ReadRemoteObject() argument 164 WriteFileDescriptor(IpcIo *io, uint32_t fd) WriteFileDescriptor() argument 175 ReadFileDescriptor(IpcIo *io) ReadFileDescriptor() argument [all...] |
/foundation/multimedia/media_lite/frameworks/recorder_lite/binder/ |
H A D | recorder_client.cpp | 114 IpcIo io; in RecorderClient() local 116 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in RecorderClient() 118 int32_t ret = proxy_->Invoke(proxy_, REC_FUNC_CONNECT, &io, ¶, SimpleCallback); in RecorderClient() 144 IpcIo io; in ~RecorderClient() local 146 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in ~RecorderClient() 148 uint32_t ret = proxy_->Invoke(proxy_, REC_FUNC_DISCONNECT, &io, ¶, DisConnectCallback); in ~RecorderClient() 173 IpcIo io; in SetVideoSource() local 175 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in SetVideoSource() 177 WriteRawData(&io, &source, sizeof(source)); in SetVideoSource() 179 uint32_t ret = proxy_->Invoke(proxy_, REC_FUNC_SET_VIDEOSOURCE, &io, in SetVideoSource() 191 IpcIo io; SetVideoEncoder() local 207 IpcIo io; SetVideoSize() local 224 IpcIo io; SetVideoFrameRate() local 239 IpcIo io; SetVideoEncodingBitRate() local 254 IpcIo io; SetCaptureRate() local 267 GetSurfaceCallback(void *owner, int code, IpcIo *io) GetSurfaceCallback() argument 284 IpcIo io; GetSurface() local 299 IpcIo io; SetAudioSource() local 316 IpcIo io; SetAudioEncoder() local 331 IpcIo io; SetAudioSampleRate() local 346 IpcIo io; SetAudioChannels() local 361 IpcIo io; SetAudioEncodingBitRate() local 376 IpcIo io; SetMaxDuration() local 390 IpcIo io; SetOutputFormat() local 405 IpcIo io; SetOutputPath() local 440 IpcIo io; SetOutputFile() local 460 IpcIo io; SetNextOutputFile() local 475 IpcIo io; SetMaxFileSize() local 501 IpcIo io; SetRecorderCallback() local 523 IpcIo io; Prepare() local 536 IpcIo io; Start() local 549 IpcIo io; Pause() local 562 IpcIo io; Resume() local 575 IpcIo io; Stop() local 589 IpcIo io; Reset() local 602 IpcIo io; Release() local 615 IpcIo io; SetFileSplitDuration() local 636 IpcIo io; SetDataSource() local [all...] |
/foundation/communication/ipc/ipc/test/serializer/ |
H A D | utils_serializer_test.cpp | 56 void WriteTestData(IpcIo* io, const struct TestData &data) in WriteTestData() argument 60 result = WriteBool(io, data.boolTest); in WriteTestData() 63 result = WriteInt8(io, data.int8Test); in WriteTestData() 66 result = WriteInt16(io, data.int16Test); in WriteTestData() 69 result = WriteInt32(io, data.int32Test); in WriteTestData() 72 result = WriteUint8(io, data.uint8Test); in WriteTestData() 75 result = WriteUint16(io, data.uint16Test); in WriteTestData() 78 result = WriteUint32(io, data.uint32Test); in WriteTestData() 82 void ReadTestData(IpcIo* io, const struct TestData &data) in ReadTestData() argument 85 bool result = ReadBool(io, in ReadTestData() 145 IpcIo io; HWTEST_F() local 157 IpcIo io; HWTEST_F() local 168 WriteTestDataUnaligned(IpcIo* io, const struct TestData &data) WriteTestDataUnaligned() argument 188 ReadTestDataUnaligned(IpcIo* io, const struct TestData &data) ReadTestDataUnaligned() argument 240 IpcIo io; HWTEST_F() local 251 IpcIo io; HWTEST_F() local 283 IpcIo io; HWTEST_F() local 295 IpcIo io; HWTEST_F() local 334 IpcIo io; HWTEST_F() local 346 IpcIo io; HWTEST_F() local 389 IpcIo io; HWTEST_F() local 399 IpcIo io; HWTEST_F() local 435 IpcIo io; HWTEST_F() local 447 IpcIo io; HWTEST_F() local 485 IpcIo io; HWTEST_F() local 498 IpcIo io; HWTEST_F() local 535 IpcIo io; HWTEST_F() local 545 IpcIo io; HWTEST_F() local 584 IpcIo io; HWTEST_F() local 595 IpcIo io; HWTEST_F() local 641 IpcIo io; HWTEST_F() local 652 IpcIo io; HWTEST_F() local 694 IpcIo io; HWTEST_F() local 705 IpcIo io; HWTEST_F() local 750 IpcIo io; HWTEST_F() local 761 IpcIo io; HWTEST_F() local 805 IpcIo io; HWTEST_F() local 816 IpcIo io; HWTEST_F() local 857 IpcIo io; HWTEST_F() local 866 IpcIo io; HWTEST_F() local 902 IpcIo io; HWTEST_F() local 911 IpcIo io; HWTEST_F() local 942 IpcIo io; HWTEST_F() local 951 IpcIo io; HWTEST_F() local 968 IpcIo io; HWTEST_F() local 985 IpcIo io; HWTEST_F() local 1017 IpcIo io; HWTEST_F() local 1026 IpcIo io; HWTEST_F() local 1059 IpcIo io; HWTEST_F() local 1068 IpcIo io; HWTEST_F() local 1099 IpcIo io; HWTEST_F() local 1111 IpcIo io; HWTEST_F() local 1134 IpcIo io; HWTEST_F() local 1150 IpcIo io; HWTEST_F() local 1167 IpcIo io; HWTEST_F() local 1183 IpcIo io; HWTEST_F() local 1200 IpcIo io; HWTEST_F() local 1216 IpcIo io; HWTEST_F() local 1233 IpcIo io; HWTEST_F() local 1250 IpcIo io; HWTEST_F() local 1267 IpcIo io; HWTEST_F() local 1284 IpcIo io; HWTEST_F() local 1301 IpcIo io; HWTEST_F() local 1318 IpcIo io; HWTEST_F() local 1335 IpcIo io; HWTEST_F() local 1352 IpcIo io; HWTEST_F() local 1369 IpcIo io; HWTEST_F() local 1386 IpcIo io; HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/core/transmission/ipc/small/ |
H A D | trans_client_proxy.c | 44 static int32_t OnUdpChannelOpenedAsServer(const SvcIdentity *svc, IpcIo *io) in OnUdpChannelOpenedAsServer() argument 50 int32_t ans = SendRequest(*svc, CLIENT_ON_CHANNEL_OPENED, io, &reply, option, &ptr); in OnUdpChannelOpenedAsServer() 66 IpcIo io; in ClientIpcOnChannelOpened() local 68 IpcIoInit(&io, tmpData, MAX_SOFT_BUS_IPC_LEN_EX, (channel->channelType == CHANNEL_TYPE_TCP_DIRECT) ? 1 : 0); in ClientIpcOnChannelOpened() 69 WriteString(&io, sessionName); in ClientIpcOnChannelOpened() 70 WriteInt32(&io, channel->channelId); in ClientIpcOnChannelOpened() 71 WriteInt32(&io, channel->channelType); in ClientIpcOnChannelOpened() 72 WriteBool(&io, channel->isServer); in ClientIpcOnChannelOpened() 73 WriteBool(&io, channel->isEnabled); in ClientIpcOnChannelOpened() 74 WriteBool(&io, channe in ClientIpcOnChannelOpened() 118 IpcIo io; ClientIpcOnChannelBind() local 146 IpcIo io; ClientIpcOnChannelOpenFailed() local 177 IpcIo io; ClientIpcOnChannelLinkDown() local 206 IpcIo io; ClientIpcOnChannelClosed() local 235 IpcIo io; ClientIpcOnChannelMsgReceived() local 281 IpcIo io; ClientIpcSetChannelInfo() local [all...] |
/foundation/multimedia/camera_lite/frameworks/binder/src/ |
H A D | camera_device_client.cpp | 87 IpcIo io; in SetCameraConfig() local 89 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 1); in SetCameraConfig() 94 WriteString(&io, cameraId_.c_str()); in SetCameraConfig() 100 uint32_t ret = proxy_->Invoke(proxy_, CAMERA_SERVER_SET_CAMERA_CONFIG, &io, ¶, Callback); in SetCameraConfig() 108 int32_t SerilizeFrameConfig(IpcIo &io, FrameConfig &fc, uint32_t maxSurfaceNum) in SerilizeFrameConfig() argument 110 WriteInt32(&io, fc.GetFrameConfigType()); in SerilizeFrameConfig() 116 WriteUint32(&io, surfaceList.size()); in SerilizeFrameConfig() 118 dynamic_cast<SurfaceImpl *>(surface)->WriteIoIpcIo(io); in SerilizeFrameConfig() 123 WriteInt32(&io, qfactor); in SerilizeFrameConfig() 127 WriteInt32(&io, streamFp in SerilizeFrameConfig() 156 IpcIo io; TriggerLoopingCapture() local 184 IpcIo io; TriggerSingleCapture() local 213 IpcIo io; StopLoopingCapture() local 233 IpcIo io; Release() local 272 IpcIo io; SetCameraCallback() local [all...] |
H A D | camera_service_client.cpp | 170 IpcIo io; in GetCameraIdList() local 172 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in GetCameraIdList() 176 uint32_t ret = proxy_->Invoke(proxy_, CAMERA_SERVER_GET_CAMERAIDLIST, &io, ¶, Callback); in GetCameraIdList() 186 IpcIo io; in GetCameraModeNum() local 188 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in GetCameraModeNum() 192 uint32_t ret = proxy_->Invoke(proxy_, CAMERA_SERVER_GET_CAMERA_MODE_NUM, &io, ¶, Callback); in GetCameraModeNum() 206 IpcIo io; in GetCameraAbility() local 208 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in GetCameraAbility() 209 WriteString(&io, cameraId.c_str()); in GetCameraAbility() 215 uint32_t ret = proxy_->Invoke(proxy_, CAMERA_SERVER_GET_CAMERA_ABILITY, &io, in GetCameraAbility() 235 IpcIo io; GetCameraInfo() local 285 IpcIo io; SetCameraMode() local 318 IpcIo io; CreateCamera() local [all...] |
/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_m/ |
H A D | serializer_inner.c | 21 bool WriteRemoteObject(IpcIo *io, const SvcIdentity *svc) in WriteRemoteObject() argument 23 if (io == NULL || svc == NULL) { in WriteRemoteObject() 24 RPC_LOG_ERROR("write io or svc is NULL ..."); in WriteRemoteObject() 27 return WriteBuffer(io, svc, sizeof(SvcIdentity)); in WriteRemoteObject() 30 bool WriteFileDescriptor(IpcIo *io, uint32_t fd) in WriteFileDescriptor() argument 32 (void)io; in WriteFileDescriptor() 37 bool ReadRemoteObject(IpcIo *io, SvcIdentity *svc) in ReadRemoteObject() argument 39 if (io == NULL || svc == NULL) { in ReadRemoteObject() 40 RPC_LOG_ERROR("read io or svc is NULL ..."); in ReadRemoteObject() 43 SvcIdentity *svcId = ReadBuffer(io, sizeo in ReadRemoteObject() 54 ReadFileDescriptor(IpcIo *io) ReadFileDescriptor() argument [all...] |
/foundation/bundlemanager/bundle_framework_lite/frameworks/bundle_lite/src/ |
H A D | element_name.cpp | 85 bool SerializeElement(IpcIo *io, const ElementName *element) in SerializeElement() argument 87 if ((io == nullptr) || (element == nullptr)) { in SerializeElement() 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_OBJEC in SerializeElement() 118 DeserializeElement(ElementName *element, IpcIo *io) DeserializeElement() argument [all...] |
/foundation/multimedia/media_lite/frameworks/player_lite/binder/ |
H A D | player_client.cpp | 209 IpcIo io; in SetSource() local 211 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in SetSource() 213 WriteInt32(&io, sourceType); in SetSource() 218 WriteString(&io, str); in SetSource() 236 uint32_t ret = proxy_->Invoke(proxy_, PLAYER_SERVER_SET_SOURCE, &io, ¶, Callback); in SetSource() 245 IpcIo io; in Prepare() local 247 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in Prepare() 252 uint32_t ret = proxy_->Invoke(proxy_, PLAYER_SERVER_PREPARE, &io, ¶, Callback); in Prepare() 261 IpcIo io; in Play() local 263 IpcIoInit(&io, tmpDat in Play() 277 IpcIo io; IsPlaying() local 293 IpcIo io; Pause() local 309 IpcIo io; Stop() local 324 IpcIo io; Rewind() local 342 IpcIo io; SetVolume() local 360 IpcIo io; SetSurface() local 388 IpcIo io; SetLoop() local 405 IpcIo io; IsSingleLooping() local 421 IpcIo io; GetCurrentPosition() local 439 IpcIo io; GetDuration() local 455 IpcIo io; GetVideoWidth() local 472 IpcIo io; GetVideoHeight() local 489 IpcIo io; Reset() local 509 IpcIo io; Release() local 584 IpcIo io; SetPlayerCallback() local 601 IpcIo io; GetPlayerState() local 618 IpcIo io; SetPlaybackSpeed() local 635 IpcIo io; GetPlaybackSpeed() local 652 IpcIo io; SetParameter() local 706 IpcIo io; SetAudioStreamType() local 723 IpcIo io; GetAudioStreamType() local [all...] |
/foundation/graphic/surface_lite/frameworks/ |
H A D | surface_buffer_impl.cpp | 125 void SurfaceBufferImpl::ReadFromIpcIo(IpcIo& io) in ReadFromIpcIo() argument 127 ReadInt32(&io, &(bufferData_.handle.key)); in ReadFromIpcIo() 128 ReadUint64(&io, &(bufferData_.handle.phyAddr)); in ReadFromIpcIo() 129 ReadUint32(&io, &(bufferData_.handle.reserveFds)); in ReadFromIpcIo() 130 ReadUint32(&io, &(bufferData_.handle.reserveInts)); in ReadFromIpcIo() 131 ReadUint32(&io, &(bufferData_.size)); in ReadFromIpcIo() 132 ReadUint32(&io, &(bufferData_.usage)); in ReadFromIpcIo() 133 ReadUint32(&io, &len_); in ReadFromIpcIo() 135 ReadUint32(&io, &extDataSize); in ReadFromIpcIo() 139 ReadUint32(&io, in ReadFromIpcIo() 161 WriteToIpcIo(IpcIo& io) WriteToIpcIo() argument [all...] |
H A D | buffer_queue_producer.cpp | 27 typedef int32_t (*IpcMsgHandle)(BufferQueueProducer* product, IpcIo *io, IpcIo *reply); 30 static int32_t OnRequestBuffer(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) in OnRequestBuffer() argument 33 ReadUint8(io, &isWaiting); in OnRequestBuffer() 48 static int32_t OnFlushBuffer(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) in OnFlushBuffer() argument 51 buffer.ReadFromIpcIo(*io); in OnFlushBuffer() 56 static int32_t OnCancelBuffer(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) in OnCancelBuffer() argument 59 buffer.ReadFromIpcIo(*io); in OnCancelBuffer() 65 static int32_t OnGetAttr(uint32_t attr, IpcIo *io, IpcIo *reply) in OnGetAttr() argument 72 static int32_t OnSendReply(IpcIo *io, IpcIo *reply) in OnSendReply() argument 78 static int32_t OnSetQueueSize(BufferQueueProducer* product, IpcIo *io, IpcI argument 86 OnGetQueueSize(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetQueueSize() argument 91 OnSetWidthAndHeight(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetWidthAndHeight() argument 101 OnGetWidth(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetWidth() argument 106 OnGetHeight(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetHeight() argument 111 OnSetFormat(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetFormat() argument 119 OnGetFormat(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetFormat() argument 124 OnSetStrideAlignment(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetStrideAlignment() argument 132 GetStrideAlignment(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) GetStrideAlignment() argument 137 OnGetStride(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetStride() argument 142 OnSetSize(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetSize() argument 150 OnGetSize(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetSize() argument 155 OnSetUsage(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetUsage() argument 163 OnGetUsage(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetUsage() argument 168 OnSetUserData(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnSetUserData() argument 188 OnGetUserData(BufferQueueProducer* product, IpcIo *io, IpcIo *reply) OnGetUserData() argument [all...] |
/foundation/communication/dsoftbus/core/bus_center/ipc/small/src/ |
H A D | bus_center_client_proxy.c | 76 IpcIo io; in ClientOnJoinLNNResult() local 78 IpcIoInit(&io, tmpData, MAX_SOFT_BUS_IPC_LEN, 0); in ClientOnJoinLNNResult() 79 WriteUint32(&io, addrTypeLen); in ClientOnJoinLNNResult() 80 WriteBuffer(&io, addr, addrTypeLen); in ClientOnJoinLNNResult() 81 WriteInt32(&io, retCode); in ClientOnJoinLNNResult() 83 WriteString(&io, networkId); in ClientOnJoinLNNResult() 93 int32_t ans = SendRequest(svc, CLIENT_ON_JOIN_RESULT, &io, NULL, option, NULL); in ClientOnJoinLNNResult() 108 IpcIo io; in ClientOnLeaveLNNResult() local 110 IpcIoInit(&io, tmpData, MAX_SOFT_BUS_IPC_LEN, 0); in ClientOnLeaveLNNResult() 111 WriteString(&io, networkI in ClientOnLeaveLNNResult() 136 IpcIo io; ClinetOnNodeOnlineStateChanged() local 184 IpcIo io; ClinetOnNodeBasicInfoChanged() local 234 IpcIo io; ClientOnTimeSyncResult() local 265 IpcIo io; ClientOnPublishLNNResult() local 295 IpcIo io; ClientOnRefreshLNNResult() local 325 IpcIo io; ClientOnRefreshDeviceFound() local [all...] |
/foundation/window/window_manager_lite/frameworks/ims/ |
H A D | input_event_listener_proxy.cpp | 54 int32_t InputEventListenerProxy::ReceiveMsgHandler(uint32_t code, IpcIo* io, IpcIo* reply, MessageOption option) in ReceiveMsgHandler() argument 59 RawEvent* eventTemp = static_cast<RawEvent*>(ReadRawData(io, sizeof(RawEvent))); in ReceiveMsgHandler() 80 IpcIo io; in RegisterInputEventListener() local 82 IpcIoInit(&io, tmpData, IMS_DEFAULT_IPC_SIZE, 1); in RegisterInputEventListener() 91 WriteRemoteObject(&io, &svc); in RegisterInputEventListener() 92 WriteBool(&io, listener->IsAlwaysInvoke()); in RegisterInputEventListener() 93 int32_t ret = proxy_->Invoke(proxy_, LITEIMS_CLIENT_REGISTER, &io, NULL, NULL); in RegisterInputEventListener() 105 IpcIo io; in UnregisterInputEventListener() local 107 IpcIoInit(&io, tmpData, IMS_DEFAULT_IPC_SIZE, 1); in UnregisterInputEventListener() 108 int32_t ret = proxy_->Invoke(proxy_, LITEIMS_CLIENT_UNREGISTER, &io, NUL in UnregisterInputEventListener() [all...] |
/foundation/multimedia/audio_lite/frameworks/binder/ |
H A D | audio_capturer_client.cpp | 135 IpcIo io; in AudioCapturerClient() local 149 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in AudioCapturerClient() 162 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 1); in AudioCapturerClient() 163 dynamic_cast<SurfaceImpl *>(surface_.get())->WriteIoIpcIo(io); in AudioCapturerClient() 165 ret = proxy_->Invoke(proxy_, AUD_CAP_FUNC_SET_SURFACE, &io, ¶, ProxyCallbackFunc); in AudioCapturerClient() 188 IpcIo io; in ~AudioCapturerClient() local 190 IpcIoInit(&io, tmpData, DEFAULT_IPC_SIZE, 0); in ~AudioCapturerClient() 192 uint32_t ret = proxy_->Invoke(proxy_, AUD_CAP_FUNC_DISCONNECT, &io, ¶, ProxyCallbackFunc); in ~AudioCapturerClient() 208 IpcIo io; in GetMinFrameCount() local 210 IpcIoInit(&io, tmpDat in GetMinFrameCount() 227 IpcIo io; GetFrameCount() local 248 IpcIo io; GetStatus() local 275 IpcIo io; SetCapturerInfo() local 297 IpcIo io; GetCapturerInfo() local 317 IpcIo io; Start() local 338 IpcIo io; Stop() local 359 IpcIo io; Release() local [all...] |
/foundation/multimedia/camera_lite/services/server/src/ |
H A D | camera_server.cpp | 199 FrameConfig *DeserializeFrameConfig(IpcIo &io) in DeserializeFrameConfig() argument 202 ReadInt32(&io, &type); in DeserializeFrameConfig() 206 ReadUint32(&io, &surfaceNum); in DeserializeFrameConfig() 208 Surface *surface = SurfaceImpl::GenericSurfaceByIpcIo(io); in DeserializeFrameConfig() 218 ReadInt32(&io, &qfactor); in DeserializeFrameConfig() 223 ReadInt32(&io, &streamFps); in DeserializeFrameConfig() 226 ReadInt32(&io, &invertMode); in DeserializeFrameConfig() 229 ReadInt32(&io, &streamCrop.x); in DeserializeFrameConfig() 230 ReadInt32(&io, &streamCrop.y); in DeserializeFrameConfig() 231 ReadInt32(&io, in DeserializeFrameConfig() 313 IpcIo io; OnCameraStatusChange() local 328 IpcIo io; OnTriggerSingleCaptureFinished() local 344 IpcIo io; OnTriggerLoopingCaptureFinished() local 359 IpcIo io; OnCameraConfigured() local [all...] |
/foundation/ai/ai_engine/services/server/communication_adapter/source/ |
H A D | client_listener_handler.cpp | 45 void AsyncProcessWorker::IpcIoResponse(IResponse *response, IpcIo &io, char *data, int length) in IpcIoResponse() argument 51 IpcIoInit(&io, data, length, IPC_OBJECT_COUNTS); in IpcIoResponse() 54 WriteInt32(&io, retCode); in IpcIoResponse() 57 WriteInt32(&io, requestId); in IpcIoResponse() 61 WriteInt32(&io, sessionId); in IpcIoResponse() 64 ParcelDataInfo(&io, &result, response->GetClientUid()); in IpcIoResponse() 73 IpcIo io; in OneAction() local 75 IpcIoResponse(response, io, tmpData, MAX_IO_SIZE); in OneAction() 87 int32_t retCode = SendRequest(*svcIdentity, ON_ASYNC_PROCESS_CODE, &io, &reply, option, nullptr); in OneAction()
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/minimp3_adapter/ |
H A D | minimp3_wrapper.c | 40 int Minimp3WrapperMp3decDetectCb(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize) in Minimp3WrapperMp3decDetectCb() argument 42 return mp3dec_detect_cb(io, buf, bufSize); in Minimp3WrapperMp3decDetectCb() 51 int Minimp3WrapperMp3decIterateCb(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize, in Minimp3WrapperMp3decIterateCb() argument 54 return mp3dec_iterate_cb(io, buf, bufSize, callback, userData); in Minimp3WrapperMp3decIterateCb()
|
H A D | minimp3_wrapper.h | 41 int (*detecCb)(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize); 45 int (*iterateCb)(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize, 56 int Minimp3WrapperMp3decDetectCb(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize); 61 int Minimp3WrapperMp3decIterateCb(Minimp3WrapperMp3decIO *io, uint8_t *buf, size_t bufSize,
|
/foundation/ability/ability_lite/frameworks/want_lite/src/ |
H A D | want.cpp | 284 bool SerializeWant(IpcIo *io, const Want *want) 286 if ((io == nullptr) || (want == nullptr) || (want->dataLength > DATA_LENGTH)) { 291 WriteInt32(io, VALUE_NULL); 293 WriteInt32(io, VALUE_OBJECT); 294 if (!SerializeElement(io, want->element)) { 298 WriteInt32(io, want->dataLength); 300 WriteBuffer(io, want->data, want->dataLength); 303 WriteInt32(io, VALUE_NULL); 305 WriteInt32(io, VALUE_OBJECT); 306 bool ret = WriteRemoteObject(io, wan [all...] |
/foundation/distributedhardware/device_manager/services/service/src/ipc/lite/ |
H A D | ipc_server_listener.cpp | 53 IpcIo io; in SendRequest() local 55 if (IpcCmdRegister::GetInstance().SetRequest(cmdCode, req, io, data, MAX_DM_IPC_LEN) != DM_OK) { in SendRequest() 63 if (::SendRequest(svc, cmdCode, &io, nullptr, option, nullptr) != DM_OK) { in SendRequest() 74 IpcIo io; in SendAll() local 79 if (IpcCmdRegister::GetInstance().SetRequest(cmdCode, req, io, data, MAX_DM_IPC_LEN) != DM_OK) { in SendAll() 88 if (::SendRequest(svc, cmdCode, &io, nullptr, option, nullptr) != DM_OK) { in SendAll()
|