Home
last modified time | relevance | path

Searched refs:socketId (Results 1 - 25 of 56) sorted by relevance

123

/foundation/communication/ipc/services/dbinder/test/unittest/
H A Ddbinder_remote_listener_unittest.cpp79 int32_t socketId = 1; in HWTEST_F() local
84 dBinderRemoteListener.ServerOnBind(socketId, info); in HWTEST_F()
97 int32_t socketId = -1; in HWTEST_F() local
102 dBinderRemoteListener.ServerOnBind(socketId, info); in HWTEST_F()
115 int32_t socketId = INT_MAX; in HWTEST_F() local
120 dBinderRemoteListener.ServerOnBind(socketId, info); in HWTEST_F()
134 int32_t socketId = 1; in HWTEST_F() local
135 dBinderRemoteListener.serverSocketInfos_[networkId] = socketId; in HWTEST_F()
136 dBinderRemoteListener.ServerOnShutdown(socketId, SHUTDOWN_REASON_PEER); in HWTEST_F()
148 int32_t socketId in HWTEST_F() local
162 int32_t socketId = -1; HWTEST_F() local
176 int32_t socketId = -1; HWTEST_F() local
191 int32_t socketId = 1; HWTEST_F() local
206 int32_t socketId = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/session/
H A Dclient_trans_socket_service_test.cpp63 int32_t socketId = -1; in HWTEST_F() local
67 socketId = Socket(info); in HWTEST_F()
68 ASSERT_EQ(socketId, SOFTBUS_INVALID_PARAM); in HWTEST_F()
74 socketId = Socket(info); in HWTEST_F()
75 ASSERT_EQ(socketId, SOFTBUS_INVALID_PARAM); in HWTEST_F()
80 socketId = Socket(info); in HWTEST_F()
81 ASSERT_EQ(socketId, SOFTBUS_INVALID_PARAM); in HWTEST_F()
97 int32_t socketId = -1; in HWTEST_F() local
103 socketId = Socket(info); in HWTEST_F()
104 ASSERT_EQ(socketId, SOFTBUS_INVALID_PARA in HWTEST_F()
126 int32_t socketId = -1; HWTEST_F() local
156 int32_t socketId = -1; HWTEST_F() local
193 int32_t socketId = Socket(info); HWTEST_F() local
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_agent.cpp109 int32_t socketId = Socket(serverInfo); in JoinDomain() local
110 if (socketId < 0) { in JoinDomain()
111 LOGE("Create Socket fail socketId, socketId = %{public}d", socketId); in JoinDomain()
120 int32_t ret = Listen(socketId, qos, sizeof(qos) / sizeof(qos[0]), &sessionListener); in JoinDomain()
122 Shutdown(socketId); in JoinDomain()
130 serverIdMap_.insert(std::make_pair(sessionName_, socketId)); in JoinDomain()
181 int32_t socketId = Socket(clientInfo); in OpenSession() local
182 if (socketId < FileManagemen in OpenSession()
232 int32_t socketId = Socket(clientInfo); OpenApSession() local
[all...]
H A Dsoftbus_handler.cpp132 int32_t socketId = Socket(serverInfo); in CreateSessionServer() local
133 if (socketId < E_OK) { in CreateSessionServer()
134 LOGE("Create Socket fail socketId, socketId = %{public}d", socketId); in CreateSessionServer()
138 RadarReporter::dSoftBus + std::to_string(socketId)); in CreateSessionServer()
147 int32_t ret = Listen(socketId, qos, sizeof(qos) / sizeof(qos[0]), &sessionListener_[role]); in CreateSessionServer()
150 Shutdown(socketId); in CreateSessionServer()
155 serverIdMap_.insert(std::make_pair(sessionName, socketId)); in CreateSessionServer()
158 LOGI("CreateSessionServer success socketId in CreateSessionServer()
162 OpenSession(const std::string &mySessionName, const std::string &peerSessionName, const std::string &peerDevId, int32_t &socketId) OpenSession() argument
198 CreatSocketId(const std::string &mySessionName, const std::string &peerSessionName, const std::string &peerDevId, int32_t &socketId) CreatSocketId() argument
219 CopySendFile(int32_t socketId, const std::string &sessionName, const std::string &srcUri, const std::string &dstPath) CopySendFile() argument
333 RemoveNetworkId(int32_t socketId) RemoveNetworkId() argument
[all...]
H A Dsoftbus_handler_asset.cpp99 int32_t socketId = Socket(serverInfo); in CreateAssetLocalSessionServer() local
100 if (socketId < E_OK) { in CreateAssetLocalSessionServer()
101 LOGE("Create Socket fail socketId, socketId = %{public}d", socketId); in CreateAssetLocalSessionServer()
109 int32_t ret = Listen(socketId, qos, sizeof(qos) / sizeof(qos[0]), &sessionListener_[DFS_ASSET_ROLE_RECV]); in CreateAssetLocalSessionServer()
112 Shutdown(socketId); in CreateAssetLocalSessionServer()
119 serverIdMap_.insert(std::make_pair(ASSET_LOCAL_SESSION_NAME, socketId)); in CreateAssetLocalSessionServer()
134 int32_t socketId = it->second; in DeleteAssetLocalSessionServer() local
136 Shutdown(socketId); in DeleteAssetLocalSessionServer()
142 AssetBind(const std::string &dstNetworkId, int32_t &socketId) AssetBind() argument
182 AssetSendFile(int32_t socketId, const std::string& sendFile, bool isSingleFile) AssetSendFile() argument
215 closeAssetBind(int32_t socketId) closeAssetBind() argument
222 OnAssetRecvBind(int32_t socketId, const std::string &srcNetWorkId) OnAssetRecvBind() argument
233 GetClientInfo(int32_t socketId) GetClientInfo() argument
244 RemoveClientInfo(int32_t socketId) RemoveClientInfo() argument
253 AddAssetObj(int32_t socketId, const sptr<AssetObj> &assetObj) AddAssetObj() argument
264 GetAssetObj(int32_t socketId) GetAssetObj() argument
276 RemoveAssetObj(int32_t socketId) RemoveAssetObj() argument
285 GenerateAssetObjInfo(int32_t socketId, const std::string &fileName, const sptr<AssetObj> &assetObj) GenerateAssetObjInfo() argument
[all...]
H A Dsoftbus_asset_send_listener.cpp47 void SoftBusAssetSendListener::OnSendAssetFinished(int32_t socketId, const char **fileList, int32_t fileCnt) in OnSendAssetFinished() argument
49 LOGI("Push asset finished, socketId is %{public}d", socketId); in OnSendAssetFinished()
54 auto assetObj = SoftBusHandlerAsset::GetInstance().GetAssetObj(socketId); in OnSendAssetFinished()
61 SoftBusHandlerAsset::GetInstance().closeAssetBind(socketId); in OnSendAssetFinished()
67 void SoftBusAssetSendListener::OnSendAssetError(int32_t socketId, in OnSendAssetError() argument
72 LOGE("SendAssetError, socketId is %{public}d, errorCode %{public}d", socketId, errorCode); in OnSendAssetError()
77 auto assetObj = SoftBusHandlerAsset::GetInstance().GetAssetObj(socketId); in OnSendAssetError()
84 SoftBusHandlerAsset::GetInstance().closeAssetBind(socketId); in OnSendAssetError()
[all...]
H A Dsoftbus_asset_recv_listener.cpp78 void SoftbusAssetRecvListener::OnRecvAssetStart(int32_t socketId, const char **fileList, int32_t fileCnt) in OnRecvAssetStart() argument
80 LOGI("OnRecvFileStart, sessionId = %{public}d, fileCnt = %{public}d", socketId, fileCnt); in OnRecvAssetStart()
85 auto srcNetworkId = SoftBusHandlerAsset::GetInstance().GetClientInfo(socketId); in OnRecvAssetStart()
92 int32_t ret = SoftBusHandlerAsset::GetInstance().GenerateAssetObjInfo(socketId, filePath, assetObj); in OnRecvAssetStart()
103 void SoftbusAssetRecvListener::OnRecvAssetFinished(int32_t socketId, const char **fileList, int32_t fileCnt) in OnRecvAssetFinished() argument
105 LOGI("OnRecvFileFinished, sessionId = %{public}d, fileCnt = %{public}d", socketId, fileCnt); in OnRecvAssetFinished()
110 auto srcNetworkId = SoftBusHandlerAsset::GetInstance().GetClientInfo(socketId); in OnRecvAssetFinished()
117 int32_t ret = SoftBusHandlerAsset::GetInstance().GenerateAssetObjInfo(socketId, firstFilePath, assetObj); in OnRecvAssetFinished()
125 ret = HandleSingleFile(socketId, filePath, assetObj); in OnRecvAssetFinished()
127 ret = HandleZipFile(socketId, filePat in OnRecvAssetFinished()
143 OnRecvAssetError(int32_t socketId, int32_t errorCode, const char **fileList, int32_t fileCnt) OnRecvAssetError() argument
242 HandleSingleFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj) HandleSingleFile() argument
264 HandleZipFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj) HandleZipFile() argument
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/network/softbus/
H A Dsoftbus_handler_asset.h49 int32_t AssetBind(const std::string &dstNetworkId, int32_t &socketId);
50 int32_t AssetSendFile(int32_t socketId, const std::string& sendFile, bool isSingleFile);
51 void closeAssetBind(int32_t socketId);
52 void OnAssetRecvBind(int32_t socketId, const std::string &srcNetWorkId);
54 std::string GetClientInfo(int32_t socketId);
55 void RemoveClientInfo(int32_t socketId);
56 void AddAssetObj(int32_t socketId, const sptr<AssetObj> &assetObj);
57 sptr<AssetObj> GetAssetObj(int32_t socketId);
58 void RemoveAssetObj(int32_t socketId);
60 int32_t GenerateAssetObjInfo(int32_t socketId,
[all...]
H A Dsoftbus_asset_recv_listener.h36 static void OnRecvAssetStart(int32_t socketId, const char **fileList, int32_t fileCnt);
37 static void OnRecvAssetFinished(int32_t socketId, const char **fileList, int32_t fileCnt);
38 static void OnRecvAssetError(int32_t socketId, int32_t errorCode, const char **fileList, int32_t fileCnt);
43 static int32_t HandleSingleFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj);
44 static int32_t HandleZipFile(int32_t socketId, const std::string &filePath, const sptr<AssetObj> &assetObj);
H A Dsoftbus_handler.h43 const std::string &peerDevId, int32_t &socketId);
44 int32_t CopySendFile(int32_t socketId,
55 void RemoveNetworkId(int32_t socketId);
60 const std::string &peerDevId, int32_t &socketId);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/
H A Ddh_transport.cpp56 int32_t DHTransport::OnSocketOpened(int32_t socketId, const PeerSocketInfo &info) in OnSocketOpened() argument
59 "peerPkgName: %{public}s", socketId, info.name, GetAnonyString(info.networkId).c_str(), info.pkgName); in OnSocketOpened()
61 remoteDevSocketIds_[info.networkId] = socketId; in OnSocketOpened()
65 void DHTransport::OnSocketClosed(int32_t socketId, ShutdownReason reason) in OnSocketClosed() argument
67 DHLOGI("OnSocketClosed, socket: %{public}d, reason: %{public}d", socketId, (int32_t)reason); in OnSocketClosed()
70 if (iter->second == socketId) { in OnSocketClosed()
77 void DHTransport::OnBytesReceived(int32_t socketId, const void *data, uint32_t dataLen) in OnBytesReceived() argument
79 if (socketId < 0 || data == nullptr || dataLen == 0 || dataLen > MAX_SEND_MSG_LENGTH) { in OnBytesReceived()
84 std::string remoteNeworkId = GetRemoteNetworkIdBySocketId(socketId); in OnBytesReceived()
86 DHLOGE("Can not find the remote network id by socketId in OnBytesReceived()
316 IsDeviceSessionOpened(const std::string &remoteNetworkId, int32_t &socketId) IsDeviceSessionOpened() argument
331 GetRemoteNetworkIdBySocketId(int32_t socketId) GetRemoteNetworkIdBySocketId() argument
358 int32_t socketId = -1; StartSocket() local
396 int32_t socketId = -1; StopSocket() local
414 int32_t socketId = -1; Send() local
[all...]
/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/
H A Ddbinder_remote_listener.cpp52 DBINDER_LOGI(LOG_LABEL, "socketId:%{public}d, peerNetworkId:%{public}s, peerName:%{public}s", in ServerOnBind()
61 DBINDER_LOGI(LOG_LABEL, "socketId:%{public}d, ShutdownReason:%{public}d", socket, reason); in ServerOnShutdown()
79 DBINDER_LOGI(LOG_LABEL, "socketId:%{public}d, ShutdownReason:%{public}d", socket, reason); in ClientOnShutdown()
101 DBINDER_LOGI(LOG_LABEL, "socketId:%{public}d len:%{public}u", socket, dataLen); in OnBytesReceived()
104 "socketId:%{public}d", dataLen, socket); in OnBytesReceived()
154 int32_t socketId = DBinderSoftbusClient::GetInstance().Socket(socketInfo); in CreateClientSocket() local
155 if (socketId <= 0) { in CreateClientSocket()
160 int32_t ret = DBinderSoftbusClient::GetInstance().Bind(socketId, QOS_TV, QOS_COUNT, &clientListener_); in CreateClientSocket()
162 DBINDER_LOGE(LOG_LABEL, "Bind failed, ret:%{public}d, socketId:%{public}d, peerNetworkId:%{public}s", in CreateClientSocket()
163 ret, socketId, DBinderServic in CreateClientSocket()
207 int32_t socketId = DBinderSoftbusClient::GetInstance().Socket(serverSocketInfo); StartListener() local
278 int32_t socketId = CreateClientSocket(networkId); SendDataToRemote() local
304 int32_t socketId = GetPeerSocketId(networkId); SendDataReply() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/statistics/src/
H A Dclient_trans_statistics.c83 if (ClientGetSessionIdByChannelId(channel->channelId, channel->channelType, &newItem->socketId, false) != in AddSocketResource()
85 TRANS_LOGE(TRANS_SDK, "get socketId failed, channelId=%{public}d", channel->channelId); in AddSocketResource()
93 if (item->socketId == newItem->socketId) { in AddSocketResource()
108 void UpdateChannelStatistics(int32_t socketId, int64_t len) in UpdateChannelStatistics() argument
110 if (socketId < 0 || len <= 0) { in UpdateChannelStatistics()
124 if (item->socketId == socketId) { in UpdateChannelStatistics()
147 !AddNumberToJsonObject(json, "socketId", resource->socketId) || in PackStatistics()
197 int32_t socketId; DeleteSocketResourceByChannelId() local
[all...]
/foundation/communication/ipc/ipc/native/src/core/source/
H A Ddatabus_socket_listener.cpp64 ZLOGI(LABEL, "socketId:%{public}d, deviceId:%{public}s, peerName:%{public}s", in ServerOnBind()
90 ZLOGI(LABEL, "socketId:%{public}d, ShutdownReason:%{public}d", socket, reason); in ServerOnShutdown()
107 ZLOGI(LABEL, "socketId:%{public}d, ShutdownReason:%{public}d", socket, reason); in ClientOnShutdown()
121 ZLOGI(LOG_LABEL, "erase socketId:%{public}d ", it->second); in ClientOnShutdown()
133 ZLOGI(LABEL, "socketId:%{public}d len:%{public}u", socket, dataLen); in OnBytesReceived()
153 int32_t socketId = DBinderSoftbusClient::GetInstance().Socket(serverSocketInfo); in StartServerListener() local
154 if (socketId <= 0) { in StartServerListener()
158 int32_t ret = DBinderSoftbusClient::GetInstance().Listen(socketId, QOS_TV, QOS_COUNT, &serverListener_); in StartServerListener()
161 DBinderSoftbusClient::GetInstance().Shutdown(socketId); in StartServerListener()
164 ZLOGI(LABEL, "Listen ok, socketId in StartServerListener()
212 int32_t socketId = DBinderSoftbusClient::GetInstance().Socket(socketInfo); CreateClientSocket() local
237 ShutdownSocket(int32_t socketId) ShutdownSocket() argument
[all...]
H A Dcomm_auth_info.cpp20 const std::string &deviceId, int32_t socketId) in CommAuthInfo()
22 tokenId_(tokenId), deviceId_(deviceId), socketId_(socketId) in CommAuthInfo()
60 void CommAuthInfo::SetRemoteSocketId(int32_t socketId) in SetRemoteSocketId() argument
62 socketId_ = socketId; in SetRemoteSocketId()
19 CommAuthInfo(IRemoteObject *stub, int pid, int uid, uint32_t tokenId, const std::string &deviceId, int32_t socketId) CommAuthInfo() argument
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/ipc/
H A Ddaemon_execute.cpp84 int32_t socketId; in ExecutePushAsset() local
85 auto ret = SoftBusHandlerAsset::GetInstance().AssetBind(assetObj->dstNetworkId_, socketId); in ExecutePushAsset()
93 SoftBusHandlerAsset::GetInstance().AddAssetObj(socketId, assetObj); in ExecutePushAsset()
98 HandlePushAssetFail(socketId, assetObj); in ExecutePushAsset()
106 LOGE("zip files fail. socketId is %{public}d", socketId); in ExecutePushAsset()
107 HandlePushAssetFail(socketId, assetObj); in ExecutePushAsset()
112 ret = SoftBusHandlerAsset::GetInstance().AssetSendFile(socketId, sendFileName, isSingleFile); in ExecutePushAsset()
115 HandlePushAssetFail(socketId, assetObj); in ExecutePushAsset()
164 int32_t socketId; in RequestSendFileInner() local
266 HandlePushAssetFail(int32_t socketId, const sptr<AssetObj> &assetObj) HandlePushAssetFail() argument
[all...]
/foundation/communication/ipc/ipc/native/src/mock/source/
H A Ddbinder_databus_invoker.cpp173 ZLOGE(LOG_LABEL, "auth handle:%{public}u to socketId failed, socketId:%{public}d", handle, in QuerySessionOfBinderProxy()
192 ZLOGI(LOG_LABEL, "socketId:%{public}d", sessionOfPeer->GetSocketId()); in QueryClientSessionObject()
213 bool DBinderDatabusInvoker::OnReceiveNewConnection(int32_t socketId, int peerPid, int peerUid, in OnReceiveNewConnection() argument
222 AppAuthInfo appAuthInfo = { peerPid, peerUid, 0, socketId, 0, nullptr, networkId }; in OnReceiveNewConnection()
225 socketId, peerName.c_str()); in OnReceiveNewConnection()
230 if (current->StubDetachDBinderSession(socketId, oldTokenId)) { in OnReceiveNewConnection()
231 ZLOGI(LOG_LABEL, "delete left socketId:%{public}d device:%{public}s oldTokenId:%{public}u", socketId, in OnReceiveNewConnection()
236 sessionObject->SetSocketId(socketId); in OnReceiveNewConnection()
270 OnRawDataAvailable(int32_t socketId, const char *data, uint32_t dataSize) OnRawDataAvailable() argument
303 OnMessageAvailable(int32_t socketId, const char *data, ssize_t len) OnMessageAvailable() argument
339 int32_t socketId = sessionOfPeer->GetSocketId(); OnSendMessage() local
354 SendData(std::shared_ptr<BufferObject> sessionBuff, int32_t socketId) SendData() argument
406 int32_t socketId = session->GetSocketId(); OnSendRawData() local
559 int32_t socketId = listener->CreateClientSocket(ownName, UpdateClientSession() local
586 OnDatabusSessionClientSideClosed(int32_t socketId) OnDatabusSessionClientSideClosed() argument
626 OnDatabusSessionServerSideClosed(int32_t socketId) OnDatabusSessionServerSideClosed() argument
765 CheckAndSetCallerInfo(int32_t socketId, uint64_t stubIndex) CheckAndSetCallerInfo() argument
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/shutdown_fuzzer/
H A Dshutdown_fuzzer.cpp27 int32_t socketId = -1; in ShutdownTest() local
28 if (memcpy_s(&socketId, sizeof(int32_t), data, size) != EOK) { in ShutdownTest()
32 Shutdown(socketId); in ShutdownTest()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/transport/
H A Ddh_transport.h43 int32_t OnSocketOpened(int32_t socketId, const PeerSocketInfo &info);
44 void OnSocketClosed(int32_t socketId, ShutdownReason reason);
45 void OnBytesReceived(int32_t socketId, const void *data, uint32_t dataLen);
50 bool IsDeviceSessionOpened(const std::string &remoteDevId, int32_t &socketId);
51 std::string GetRemoteNetworkIdBySocketId(int32_t socketId);
57 // record the socket id for the connection with remote devices, <remote networkId, socketId>
/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_interface.h25 std::shared_ptr<T> DBinderBaseInvoker<T>::WriteTransaction(int cmd, uint32_t flags, int32_t handle, int32_t socketId, in WriteTransaction() argument
28 std::shared_ptr<T> sessionObject = GetSessionObject(handle, socketId); in WriteTransaction()
30 ZLOGE(LOG_LABEL, "session is not exist for listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
31 DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, socketId, RADAR_GET_SESSION_FAIL, __FUNCTION__); in WriteTransaction()
37 ZLOGE(LOG_LABEL, "seqNum invalid, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
38 DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, socketId, RADAR_SEQ_INVALID, __FUNCTION__); in WriteTransaction()
45 ZLOGE(LOG_LABEL, "send rawdata failed, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
46 DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, socketId, RADAR_SEND_RAW_DATA_FAIL, __FUNCTION__); in WriteTransaction()
50 ProcessNormalData(sessionObject, data, handle, socketId, seqNum, cmd, code, flags, status); in WriteTransaction()
52 ZLOGE(LOG_LABEL, "send normal data failed, listenFd:%{public}d handle:%{public}d", socketId, handl in WriteTransaction()
[all...]
H A Ddbinder_base_invoker_object.h113 MessageParcel &data, uint32_t socketId, std::shared_ptr<T> sessionObject) in IRemoteObjectTranslateWhenSend()
163 MessageParcel &data, uint32_t socketId, std::shared_ptr<T> sessionObject) in IRemoteObjectTranslateWhenRcv()
199 if (!TranslateRawData(dataBuffer, data, socketId)) { in IRemoteObjectTranslateWhenRcv()
215 template <class T> std::shared_ptr<T> DBinderBaseInvoker<T>::GetSessionObject(uint32_t handle, uint32_t socketId) in GetSessionObject() argument
222 return QueryClientSessionObject(socketId); in GetSessionObject()
262 bool DBinderBaseInvoker<T>::TranslateRawData(char *dataBuffer, MessageParcel &data, uint32_t socketId) in TranslateRawData() argument
264 if (data.GetOffsetsSize() <= 0 || socketId == 0) { in TranslateRawData()
274 std::shared_ptr<InvokerRawData> receivedRawData = current->QueryRawData(socketId); in TranslateRawData()
276 ZLOGE(LOG_LABEL, "cannot found rawData according to the socketId:%{public}u", socketId); in TranslateRawData()
112 IRemoteObjectTranslateWhenSend(char *dataBuffer, binder_size_t bufferSize, MessageParcel &data, uint32_t socketId, std::shared_ptr<T> sessionObject) IRemoteObjectTranslateWhenSend() argument
162 IRemoteObjectTranslateWhenRcv(char *dataBuffer, binder_size_t bufferSize, MessageParcel &data, uint32_t socketId, std::shared_ptr<T> sessionObject) IRemoteObjectTranslateWhenRcv() argument
442 StartProcessLoop(int32_t socketId, const char *buffer, uint32_t size) StartProcessLoop() argument
474 MakeThreadMessageInfo(int32_t socketId) MakeThreadMessageInfo() argument
[all...]
H A Ddbinder_base_invoker_define.h72 virtual std::shared_ptr<T> WriteTransaction(int cmd, uint32_t flags, int32_t handle, int32_t socketId,
77 virtual void StartProcessLoop(int32_t socketId, const char *buffer, uint32_t size);
97 virtual int CheckAndSetCallerInfo(int32_t socketId, uint64_t stubIndex) = 0;
115 uint32_t socketId, std::shared_ptr<T> sessionObject);
117 uint32_t socketId, std::shared_ptr<T> sessionObject);
118 bool TranslateRawData(char *dataBuffer, MessageParcel &data, uint32_t socketId);
119 std::shared_ptr<T> GetSessionObject(uint32_t handle, uint32_t socketId);
125 int32_t handle, int32_t socketId, uint64_t seqNum, int cmd, __u32 code, __u32 flags, int status);
130 std::shared_ptr<dbinder_transaction_data> transData, int32_t socketId, int status);
131 std::shared_ptr<ThreadProcessInfo> MakeThreadProcessInfo(int32_t socketId, cons
[all...]
H A Ddbinder_base_invoker_process.h171 messageInfo->socketId = static_cast<uint32_t>(listenFd); in ProcessReply()
209 MessageParcel &data, int32_t handle, int32_t socketId, uint64_t seqNum, int cmd, __u32 code, __u32 flags, in ProcessNormalData()
224 if (MoveMessageParcel2TransData(data, sessionObject, transData, socketId, status) != true) { in ProcessNormalData()
225 ZLOGE(LOG_LABEL, "move parcel to transData failed, handle:%{public}d socketId:%{public}d", handle, socketId); in ProcessNormalData()
232 std::shared_ptr<ThreadProcessInfo> DBinderBaseInvoker<T>::MakeThreadProcessInfo(int32_t socketId, const char *inBuffer, in MakeThreadProcessInfo() argument
236 ZLOGE(LOG_LABEL, "buffer is null or size:%{public}u invalid, socketId:%{public}d", size, socketId); in MakeThreadProcessInfo()
247 ZLOGE(LOG_LABEL, "make ThreadProcessInfo fail, socketId:%{public}d", socketId); in MakeThreadProcessInfo()
208 ProcessNormalData(std::shared_ptr<T> sessionObject, MessageParcel &data, int32_t handle, int32_t socketId, uint64_t seqNum, int cmd, __u32 code, __u32 flags, int status) ProcessNormalData() argument
356 MoveMessageParcel2TransData(MessageParcel &data, std::shared_ptr<T> sessionObject, std::shared_ptr<dbinder_transaction_data> transData, int32_t socketId, int status) MoveMessageParcel2TransData() argument
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/dhtransport_fuzzer/
H A Ddhtransport_fuzzer.cpp42 int32_t socketId = *(reinterpret_cast<const int32_t*>(data)); in DhTransportOnBytesReceivedFuzzTest() local
46 dhTransportTest->remoteDevSocketIds_[remoteNetworkId] = socketId; in DhTransportOnBytesReceivedFuzzTest()
47 dhTransportTest->OnBytesReceived(socketId, data, size); in DhTransportOnBytesReceivedFuzzTest()
68 int32_t socketId = 0; in DhTransportIsDeviceSessionOpenedFuzzTest() local
73 dhTransportTest->IsDeviceSessionOpened(remoteNetworkId, socketId); in DhTransportIsDeviceSessionOpenedFuzzTest()
131 int32_t socketId = *(reinterpret_cast<const int32_t*>(data)); in DhTransportOnSocketOpenedFuzzTest() local
142 dhTransportTest->OnSocketOpened(socketId, info); in DhTransportOnSocketOpenedFuzzTest()
150 int32_t socketId = *(reinterpret_cast<const int32_t*>(data)); in DhTransportOnSocketClosedFuzzTest() local
154 dhTransportTest->OnSocketClosed(socketId, reason); in DhTransportOnSocketClosedFuzzTest()
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/bind_fuzzer/
H A Dbind_fuzzer.cpp90 int32_t socketId = -1; in BindTestWithSocketId() local
91 if (memcpy_s(&socketId, sizeof(int32_t), data, sizeof(size)) != EOK) { in BindTestWithSocketId()
113 (void)Bind(socketId, qosInfo, sizeof(qosInfo)/sizeof(qosInfo[0]), &listener); in BindTestWithSocketId()
122 int32_t socketId = 1; in BindTestWithQosInfo() local
146 (void)Bind(socketId, qosInfo.get(), count, &listener); in BindTestWithQosInfo()

Completed in 12 milliseconds

123