Home
last modified time | relevance | path

Searched refs:tos (Results 1 - 25 of 30) sorted by relevance

12

/foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/include/
H A Dtrans_udp_channel_manager.h42 uint8_t tos; member
81 int32_t UdpChannelFileTransLimit(const ChannelInfo *channel, uint8_t tos);
83 int32_t UdpChannelFileTransRecoveryLimit(uint8_t tos);
/foundation/communication/dsoftbus/core/transmission/ipc/mini/
H A Dtrans_client_proxy.c74 int32_t ClientIpcOnTransLimitChange(const char *pkgName, int32_t pid, int32_t channelId, uint8_t tos) in ClientIpcOnTransLimitChange() argument
79 (void)tos; in ClientIpcOnTransLimitChange()
/foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/src/
H A Dtrans_udp_channel_manager.c583 static void FillNotifyList(ListNode *notifyList, uint8_t tos) in FillNotifyList() argument
592 udpChannelNode->tos != tos) { in FillNotifyList()
603 static int32_t ModifyUdpChannelTos(uint8_t tos) in ModifyUdpChannelTos() argument
611 FillNotifyList(&notifyList, tos); in ModifyUdpChannelTos()
613 TRANS_LOGI(TRANS_CTRL, "no need to modify tos."); in ModifyUdpChannelTos()
620 ret = ClientIpcOnTransLimitChange(notifyNode->pkgName, notifyNode->pid, notifyNode->channelId, tos); in ModifyUdpChannelTos()
637 udpChannelNodeTemp->tos = tos; in ModifyUdpChannelTos()
648 int32_t UdpChannelFileTransLimit(const ChannelInfo *channel, uint8_t tos) in UdpChannelFileTransLimit() argument
671 UdpChannelFileTransRecoveryLimit(uint8_t tos) UdpChannelFileTransRecoveryLimit() argument
[all...]
/foundation/communication/dsoftbus/core/connection/common/include/
H A Dsoftbus_tcp_socket.h36 int32_t SetIpTos(int fd, uint32_t tos);
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/include/
H A Dclient_trans_file.h58 int32_t NotifyTransLimitChanged(int32_t channelId, uint8_t tos);
/foundation/communication/dsoftbus/core/transmission/ipc/include/
H A Dtrans_client_proxy.h47 int32_t ClientIpcOnTransLimitChange(const char *pkgName, int32_t pid, int32_t channelId, uint8_t tos);
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/mock/
H A Dtrans_tcp_direct_message_test_mock.cpp207 int32_t SetIpTos(int32_t fd, uint32_t tos) in SetIpTos() argument
209 return GetTransTcpDirectMessageInterface()->SetIpTos(fd, tos); in SetIpTos()
H A Dtrans_tcp_direct_message_test_mock.h76 virtual int32_t SetIpTos(int32_t fd, uint32_t tos) = 0;
126 MOCK_METHOD2(SetIpTos, int32_t (int32_t fd, uint32_t tos));
/foundation/communication/dsoftbus/tests/core/transmission/ipc/
H A Dtrans_client_proxy_test.cpp454 uint8_t tos = 0; in HWTEST_F() local
455 int32_t ret = ClientIpcOnTransLimitChange(nullptr, TEST_PID, TEST_CHANNELID, tos); in HWTEST_F()
458 ret = ClientIpcOnTransLimitChange(g_pkgName, TEST_PID, TEST_CHANNELID, tos); in HWTEST_F()
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_tcp_socket.c184 int32_t SetIpTos(int fd, uint32_t tos) in SetIpTos() argument
186 int rc = SoftBusSocketSetOpt(fd, SOFTBUS_IPPROTO_IP, SOFTBUS_IP_TOS, &tos, sizeof(tos)); in SetIpTos()
188 CONN_LOGE(CONN_COMMON, "set tos failed, fd=%{public}d", fd); in SetIpTos()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/src/
H A Dclient_trans_udp_manager.c718 int32_t TransLimitChange(int32_t channelId, uint8_t tos) in TransLimitChange() argument
720 if (tos != FILE_PRIORITY_BK && tos != FILE_PRIORITY_BE) { in TransLimitChange()
721 TRANS_LOGE(TRANS_FILE, "invalid ip tos"); in TransLimitChange()
731 TRANS_LOGE(TRANS_FILE, "server side no need to set ip tos"); in TransLimitChange()
738 uint8_t dfileTos = tos; in TransLimitChange()
746 TRANS_LOGE(TRANS_FILE, "NSTACKX_DFileSetOpt, channelId=%{public}d, ret=%{public}d, tos=%{public}hhu", channelId, in TransLimitChange()
747 ret, tos); in TransLimitChange()
/foundation/communication/dsoftbus/sdk/frame/standard/src/
H A Dsoftbus_client_stub.cpp102 uint8_t tos; in OnClientTransLimitChangeInner() local
104 data.ReadUint8(tos), SOFTBUS_TRANS_PROXY_READRAWDATA_FAILED, COMM_SDK, "read tos failed"); in OnClientTransLimitChangeInner()
106 int32_t ret = OnClientTransLimitChange(channelId, tos); in OnClientTransLimitChangeInner()
113 int32_t SoftBusClientStub::OnClientTransLimitChange(int32_t channelId, uint8_t tos) in OnClientTransLimitChange() argument
115 return TransLimitChange(channelId, tos); in OnClientTransLimitChange()
H A Dif_softbus_client.cpp167 int32_t ISoftBusClient::OnClientTransLimitChange(int32_t channelId, uint8_t tos) in OnClientTransLimitChange() argument
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/include/
H A Dclient_trans_udp_manager.h91 int32_t TransLimitChange(int32_t channelId, uint8_t tos);
/foundation/communication/dsoftbus/sdk/frame/standard/include/
H A Dif_softbus_client.h79 virtual int32_t OnClientTransLimitChange(int32_t channelId, uint8_t tos);
H A Dsoftbus_client_stub.h61 int32_t OnClientTransLimitChange(int32_t channelId, uint8_t tos) override;
/foundation/communication/dsoftbus/core/transmission/ipc/standard/include/
H A Dtrans_client_proxy_standard.h52 int32_t OnClientTransLimitChange(int32_t channelId, uint8_t tos) override;
/foundation/communication/dsoftbus/core/transmission/ipc/standard/src/
H A Dtrans_client_proxy.cpp207 int32_t ClientIpcOnTransLimitChange(const char *pkgName, int32_t pid, int32_t channelId, uint8_t tos) in ClientIpcOnTransLimitChange() argument
219 return clientProxy->OnClientTransLimitChange(channelId, tos); in ClientIpcOnTransLimitChange()
H A Dtrans_client_proxy_standard.cpp106 int32_t TransClientProxy::OnClientTransLimitChange(int32_t channelId, uint8_t tos) in OnClientTransLimitChange() argument
122 if (!data.WriteUint8(tos)) { in OnClientTransLimitChange()
123 TRANS_LOGE(TRANS_CTRL, "write tos failed"); in OnClientTransLimitChange()
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/udp_negotiation/
H A Dtrans_udp_manager_test.cpp822 uint8_t tos = FILE_PRIORITY_BK; in HWTEST_F() local
823 int32_t ret = ModifyUdpChannelTos(tos); in HWTEST_F()
832 channel->tos = FILE_PRIORITY_BE; in HWTEST_F()
836 ret = ModifyUdpChannelTos(tos); in HWTEST_F()
/foundation/communication/dsoftbus/core/transmission/ipc/small/
H A Dtrans_client_proxy.c304 int32_t ClientIpcOnTransLimitChange(const char *pkgName, int32_t pid, int32_t channelId, uint8_t tos) in ClientIpcOnTransLimitChange() argument
309 (void)tos; in ClientIpcOnTransLimitChange()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/
H A Dvtp_stream_socket.h124 bool SetIpTos(int fd, const StreamAttr &tos);
H A Dvtp_stream_socket.cpp1238 bool VtpStreamSocket::SetIpTos(int fd, const StreamAttr &tos) in SetIpTos() argument
1240 auto tmp = tos.GetIntValue(); in SetIpTos()
1246 TRANS_LOGD(TRANS_STREAM, "Success to set ip tos: fd=%{public}d, tos=%{public}d", fd, tmp); in SetIpTos()
1253 int tos; in GetIpTos() local
1254 int size = sizeof(tos); in GetIpTos()
1256 if (FtGetSockOpt(streamFd_, IPPROTO_IP, IP_TOS, &tos, &size) != ERR_OK) { in GetIpTos()
1261 return std::move(StreamAttr(tos)); in GetIpTos()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/
H A Dclient_trans_tcp_direct_message.c192 uint32_t tos = (flags == FLAG_BYTES) ? BYTE_TOS : MESSAGE_TOS; in TransTdcProcessPostData() local
194 tos = (flags == FLAG_BYTES) ? COLLABORATE_BYTE_TOS : MESSAGE_TOS; in TransTdcProcessPostData()
196 if (SetIpTos(channel->detail.fd, tos) != SOFTBUS_OK) { in TransTdcProcessPostData()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/
H A Dclient_trans_file.c575 int32_t NotifyTransLimitChanged(int32_t channelId, uint8_t tos) in NotifyTransLimitChanged() argument
600 if (tos == FILE_PRIORITY_BE) { in NotifyTransLimitChanged()

Completed in 19 milliseconds

12