/foundation/distributedhardware/distributed_camera/services/channel/test/unittest/common/channel/ |
H A D | session_mock.cpp | 30 int Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument 34 (void)qosCount; in Listen() 39 int Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument 43 (void)qosCount; in Bind() 87 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in EvaluateQos() argument 92 (void)qosCount; in EvaluateQos()
|
H A D | socket.h | 160 void (*OnQos)(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount); 188 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); 207 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); 312 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount);
|
/foundation/distributedhardware/distributed_input/common/test/mock/ |
H A D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument 28 (void)qosCount; in Listen() 33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument 37 (void)qosCount; in Bind() 81 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in EvaluateQos() argument 86 (void)qosCount; in EvaluateQos()
|
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/mock/ |
H A D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument 28 (void)qosCount; in Listen() 33 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument 37 (void)qosCount; in Bind() 81 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in EvaluateQos() argument 86 (void)qosCount; in EvaluateQos()
|
/foundation/filemanagement/dfs_service/test/mock/ |
H A D | socket_mock.cpp | 24 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument 26 return DfsSocket::dfsSocket->Listen(socket, qos, qosCount, listener); in Listen() 29 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument 31 return DfsSocket::dfsSocket->Bind(socket, qos, qosCount, listener); in Bind()
|
/foundation/communication/dsoftbus/sdk/transmission/session/src/ |
H A D | client_trans_socket_service.c | 120 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() argument 123 return ClientListen(socket, qos, qosCount, listener); in Listen() 126 static int32_t StartBindWaitTimer(int32_t socket, const QosTV qos[], uint32_t qosCount) in StartBindWaitTimer() argument 130 int32_t ret = GetQosValue(qos, qosCount, QOS_TYPE_MAX_WAIT_TIMEOUT, &maxWaitTime, DEFAULT_MAX_WAIT_TIMEOUT); in StartBindWaitTimer() 144 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() argument 151 int32_t ret = StartBindWaitTimer(socket, qos, qosCount); in Bind() 160 ret = ClientBind(socket, qos, qosCount, listener, false); in Bind() 169 int32_t BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in BindAsync() argument 177 int32_t ret = StartBindWaitTimer(socket, qos, qosCount); in BindAsync() 186 ret = ClientBind(socket, qos, qosCount, listene in BindAsync() 202 EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) EvaluateQos() argument [all...] |
H A D | client_trans_session_service.c | 255 param->qosCount = 0; in InitSessionParam() 513 .qosCount = 0, in OpenSessionSync() 1063 static int32_t GetMaxIdleTimeout(const QosTV *qos, uint32_t qosCount, uint32_t *maxIdleTimeout) in GetMaxIdleTimeout() argument 1067 int32_t ret = GetQosValue(qos, qosCount, QOS_TYPE_MAX_IDLE_TIMEOUT, &tmpIdleTime, TRANS_DEFAULT_MAX_IDLE_TIMEOUT); in GetMaxIdleTimeout() 1109 int32_t ClientBind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener, bool isAsync) in ClientBind() argument 1112 !IsValidAsyncBindSocketListener(listener, isAsync) || !IsValidQosInfo(qos, qosCount)) { in ClientBind() 1129 ret = GetMaxIdleTimeout(qos, qosCount, &maxIdleTimeout); in ClientBind() 1138 ret = ClientIpcOpenSession(socket, qos, qosCount, &transInfo, isAsync); in ClientBind() 1161 int32_t ClientListen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in ClientListen() argument 1163 if (!IsValidSocketListener(listener, true) || !IsValidQosInfo(qos, qosCount)) { in ClientListen() [all...] |
/foundation/communication/dsoftbus/interfaces/kits/transport/ |
H A D | socket.h | 163 * @param qosCount Indicates the number of the third parameter <b>qos</b>.
167 void (*OnQos)(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount);
221 * @param qosCount Indicates the number of the second parameter <b>qos</b>.
229 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
239 * @param qosCount Indicates the number of the second parameter <b>qos</b>.
249 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
268 int32_t BindAsync(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
367 * @param qosCount Indicates the number of the fourth parameter <b>qos</b>.
373 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount);
|
/foundation/communication/ipc/ipc/native/src/core/source/ |
H A D | dbinder_softbus_client.cpp | 163 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Listen() 167 return listenFunc_(socket, qos, qosCount, listener); in Listen() 180 return listenFunc_(socket, qos, qosCount, listener); in Listen() 184 int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) in Bind() 188 return bindFunc_(socket, qos, qosCount, listener); in Bind() 201 return bindFunc_(socket, qos, qosCount, listener); in Bind() 162 Listen( int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) Listen() argument 183 Bind( int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener) Bind() argument
|
/foundation/communication/dsoftbus/sdk/transmission/session/include/ |
H A D | client_trans_session_adapter.h | 28 int32_t ClientListen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); 29 int32_t ClientBind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener, bool isAsync);
|
H A D | client_trans_session_manager.h | 229 int32_t sessionId, const QosTV *qos, uint32_t qosCount, TransInfo *transInfo, bool isAsync); 259 inline bool IsValidQosInfo(const QosTV qos[], uint32_t qosCount) in IsValidQosInfo() argument 261 return (qos == NULL) ? (qosCount == 0) : (qosCount <= QOS_TYPE_BUTT); in IsValidQosInfo()
|
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/ |
H A D | softbus_session.cpp | 44 static void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos() argument 46 LOGI("[SOFTBUS]OnQos, socket: %{public}d, QoSEvent: %{public}d, qosCount: %{public}u", socket, (int32_t)eventId, in OnQos() 47 qosCount); in OnQos() 48 if (qosCount > QOS_TYPE_BUTT) { in OnQos() 49 LOGE("OnQos invalid qosCount"); in OnQos() 52 for (uint32_t idx = 0; idx < qosCount; idx++) { in OnQos()
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/mock/src/ |
H A D | mock_soft_bus.cpp | 104 int Listen(int32_t socket, const QosTV *qos, uint32_t qosCount, const ISocketListener *listener)
in Listen() argument 112 int Bind(int32_t socket, const QosTV *qos, uint32_t qosCount, const ISocketListener *listener)
in Bind() argument
|
/foundation/distributedhardware/device_manager/test/softbusfuzztest/softbussessionobject_fuzzer/ |
H A D | softbus_session_object_fuzzer.cpp | 63 uint32_t qosCount = 3; in SoftBusSessionFuzzTest() local 75 softbusSession->iSocketListener_.OnQos(socket, eventId, qos, qosCount); in SoftBusSessionFuzzTest()
|
/foundation/communication/dsoftbus/core/frame/standard/init/src/ |
H A D | softbus_server.cpp | 385 static void ConvertQosInfo(const QosTV *qos, uint32_t qosCount, QosInfo *qosInfo) in ConvertQosInfo() argument 387 if (qos == NULL || qosCount == 0) { in ConvertQosInfo() 391 for (uint32_t i = 0; i < qosCount; i++) { in ConvertQosInfo() 409 uint32_t qosCount) in EvaluateQos() 412 || qosCount > QOS_TYPE_BUTT) { in EvaluateQos() 427 ConvertQosInfo(qos, qosCount, &qosInfo); in EvaluateQos() 408 EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) EvaluateQos() argument
|
/foundation/communication/dsoftbus/core/frame/small/init/src/ |
H A D | trans_server_stub.c | 173 if (!ReadUint32(req, ¶m->qosCount)) { in ReadQosInfo() 178 if (param->qosCount == 0) { in ReadQosInfo() 182 if (param->qosCount > QOS_TYPE_BUTT) { in ReadQosInfo() 183 TRANS_LOGE(TRANS_SDK, "read invalid qosCount=%{public}" PRIu32, param->qosCount); in ReadQosInfo() 187 const QosTV *qosInfo = (QosTV *)ReadBuffer(req, sizeof(QosTV) * param->qosCount); in ReadQosInfo() 193 if (memcpy_s(param->qos, sizeof(QosTV) * QOS_TYPE_BUTT, qosInfo, sizeof(QosTV) * param->qosCount) != EOK) { in ReadQosInfo()
|
/foundation/communication/dsoftbus/sdk/transmission/ipc/mini/ |
H A D | trans_server_proxy.c | 133 int32_t ServerIpcEvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in ServerIpcEvaluateQos() argument 138 (void)qosCount; in ServerIpcEvaluateQos()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/bind_fuzzer/ |
H A D | bind_fuzzer.cpp | 63 static void OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQosFuzzTest() argument 68 (void)qosCount; in OnQosFuzzTest()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/listen_fuzzer/ |
H A D | listen_fuzzer.cpp | 63 static void OnQosFuzzTest(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQosFuzzTest() argument 68 (void)qosCount; in OnQosFuzzTest()
|
/foundation/communication/ipc/ipc/native/src/core/include/ |
H A D | dbinder_softbus_client.h | 47 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener); 48 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
|
/foundation/communication/dsoftbus/sdk/transmission/ipc/small/ |
H A D | trans_server_proxy.c | 73 if (!WriteUint32(request, param->qosCount)) { in WriteQosInfo() 78 if (param->qosCount > 0) { in WriteQosInfo() 79 if (!WriteBuffer(request, param->qos, sizeof(QosTV) * param->qosCount)) { in WriteQosInfo() 448 int32_t ServerIpcEvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in ServerIpcEvaluateQos() argument 453 (void)qosCount; in ServerIpcEvaluateQos()
|
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
H A D | dh_transport.cpp | 209 void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos() argument 211 if (qosCount == 0 || qosCount > MAX_ROUND_SIZE) { in OnQos() 212 DHLOGE("qosCount is invalid!"); in OnQos() 215 DHLOGI("OnQos, socket: %{public}d, QoSEvent: %{public}d, qosCount: %{public}" PRIu32, in OnQos() 216 socket, (int32_t)eventId, qosCount); in OnQos() 217 for (uint32_t idx = 0; idx < qosCount; idx++) { in OnQos()
|
/foundation/communication/dsoftbus/sdk/transmission/ipc/include/ |
H A D | trans_server_proxy.h | 44 int32_t ServerIpcEvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount);
|
/foundation/communication/dsoftbus/core/transmission/common/include/ |
H A D | softbus_trans_def.h | 40 uint32_t qosCount; member
|
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/transserverproxyextern_fuzzer/ |
H A D | transserverproxyextern_fuzzer.cpp | 235 uint32_t qosCount = 1; in ServerIpcEvaluateQosTest() local 237 (void)ServerIpcEvaluateQos(peerNetworkId, dataType, &qosTv, qosCount); in ServerIpcEvaluateQosTest() 238 (void)ServerIpcEvaluateQos(nullptr, dataType, &qosTv, qosCount); in ServerIpcEvaluateQosTest()
|