Home
last modified time | relevance | path

Searched refs:sessionId (Results 1 - 25 of 832) sorted by relevance

12345678910>>...34

/foundation/communication/dsoftbus/tests/sdk/transmission/session/
H A Dclient_trans_message_service_test.cpp101 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
103 TRANS_LOGI(TRANS_TEST, "session opened, sessionId=%{public}d", sessionId); in OnSessionOpened()
107 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
109 TRANS_LOGI(TRANS_TEST, "session closed, sessionId=%{public}d", sessionId); in OnSessionClosed()
112 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
114 TRANS_LOGI(TRANS_TEST, "session bytes received, sessionId=%{public}d", sessionId); in OnBytesReceived()
117 static void OnMessageReceived(int32_t sessionId, cons argument
122 OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument
128 OnQosEvent(int32_t sessionId, int32_t eventId, int32_t tvCount, const QosTv *tvList) OnQosEvent() argument
209 int32_t sessionId = 0; AddSessionServerAndSession() local
219 DeleteSessionServerAndSession(const char *sessionName, int32_t sessionId) DeleteSessionServerAndSession() argument
251 int32_t sessionId = HWTEST_F() local
295 int32_t sessionId = HWTEST_F() local
350 int32_t sessionId = HWTEST_F() local
395 int32_t sessionId = HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/demo/transport/
H A Dsendbytes_message_demo.c42 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
44 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
49 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
51 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
55 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
57 printf("session bytes received, session id = %d\r\n", sessionId); in OnBytesReceived()
61 static void OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnMessageReceived() argument
63 printf("session msg received, session id = %d\r\n", sessionId); in OnMessageReceived()
89 int32_t sessionId = OpenSession(g_sessionNameA, g_sessionNameB, g_networkidB, g_groupid, &g_sessionAttr); in main() local
90 printf("open session result = %d\n", sessionId); in main()
120 OnSessionOpened(int32_t sessionId, int32_t result) OnSessionOpened() argument
126 OnSessionClosed(int32_t sessionId) OnSessionClosed() argument
131 OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) OnBytesReceived() argument
136 OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) OnMessageReceived() argument
[all...]
H A Dsendfile_demo.c44 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
46 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
51 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
53 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
62 static int32_t OnSendFileProcess(int32_t sessionId, uint64_t bytesUpload, uint64_t bytesTotal) in OnSendFileProcess() argument
64 printf("OnSendFileProcess sessionId = %d, bytesUpload = %llu, total = %llu\n", in OnSendFileProcess()
65 sessionId, bytesUpload, bytesTotal); in OnSendFileProcess()
69 static int32_t OnSendFileFinished(int32_t sessionId, const char *firstFile) in OnSendFileFinished() argument
71 printf("OnSendFileFinished sessionId = %d, first file = %s\n", sessionId, firstFil in OnSendFileFinished()
75 OnFileTransError(int32_t sessionId) OnFileTransError() argument
107 int32_t sessionId = OpenSession(g_sessionNameA, g_sessionNameB, g_networkidB, g_groupid, &g_sessionAttr); main() local
140 OnSessionOpened(int32_t sessionId, int32_t result) OnSessionOpened() argument
146 OnSessionClosed(int32_t sessionId) OnSessionClosed() argument
156 OnReceiveFileStarted(int32_t sessionId, const char *files, int32_t fileCnt) OnReceiveFileStarted() argument
162 OnReceiveFileProcess(int32_t sessionId, const char *firstFile, uint64_t bytesUpload, uint64_t bytesTotal) OnReceiveFileProcess() argument
169 OnReceiveFileFinished(int32_t sessionId, const char *files, int32_t fileCnt) OnReceiveFileFinished() argument
174 OnFileTransError(int32_t sessionId) OnFileTransError() argument
[all...]
H A Dopenauthsession_demo.c36 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
38 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
43 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
45 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
49 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
51 printf("session bytes received, session id = %d\r\n", sessionId); in OnBytesReceived()
55 static void OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnMessageReceived() argument
57 printf("session msg received, session id = %d\r\n", sessionId); in OnMessageReceived()
81 int32_t sessionId = OpenAuthSession(g_sessionNameA, &(g_addrInfo), 1, NULL); in main() local
82 printf("open auth session result = %d\n", sessionId); in main()
104 OnSessionOpened(int32_t sessionId, int32_t result) OnSessionOpened() argument
110 OnSessionClosed(int32_t sessionId) OnSessionClosed() argument
115 OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) OnBytesReceived() argument
120 OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) OnMessageReceived() argument
[all...]
H A Ddfs_demo.c44 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
46 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
51 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
53 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
57 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
59 printf("session bytes received, session id = %d\r\n", sessionId); in OnBytesReceived()
63 static void OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnMessageReceived() argument
65 printf("session msg received, session id = %d\r\n", sessionId); in OnMessageReceived()
69 static void OnStreamReceived(int32_t sessionId, const StreamData *data, in OnStreamReceived() argument
72 printf("session stream received, session id = %d\r\n", sessionId); in OnStreamReceived()
99 int32_t sessionId = OpenSession(g_sessionNameA, g_sessionNameB, g_networkidB, g_groupid, &g_sessionAttr); main() local
[all...]
H A Dgetsessioninfo_demo.c49 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
51 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
56 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
58 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
62 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
64 printf("session bytes received, session id = %d\r\n", sessionId); in OnBytesReceived()
68 static void OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnMessageReceived() argument
70 printf("session msg received, session id = %d\r\n", sessionId); in OnMessageReceived()
74 static void OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, in OnStreamReceived() argument
77 printf("session stream received, session id = %d\r\n", sessionId); in OnStreamReceived()
104 int32_t sessionId = OpenSession(g_sessionNameA, g_sessionNameB, g_networkidB, g_groupid, &g_sessionAttr); main() local
[all...]
H A Dsendstream_demo.c42 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
44 printf("session opened,sesison id = %d\r\n", sessionId); in OnSessionOpened()
49 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
51 printf("session closed, session id = %d\r\n", sessionId); in OnSessionClosed()
55 static void OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, in OnStreamReceived() argument
58 printf("session stream received, session id = %d\r\n", sessionId); in OnStreamReceived()
83 int32_t sessionId = OpenSession(g_sessionNameA, g_sessionNameB, g_networkidB, g_groupid, &g_sessionAttr); in main() local
84 printf("open session result = %d\n", sessionId); in main()
91 ret = SendStream(sessionId, &streamData, &ext, &param); in main()
97 CloseSession(sessionId); in main()
113 OnSessionOpened(int32_t sessionId, int32_t result) OnSessionOpened() argument
119 OnSessionClosed(int32_t sessionId) OnSessionClosed() argument
124 OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument
[all...]
/foundation/distributedhardware/distributed_input/services/sink/transport/test/sinktransunittest/
H A Ddistributed_input_sinktrans_test.cpp72 int32_t sessionId = 1; in HWTEST_F() local
74 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr1_.dump()); in HWTEST_F()
76 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr1_.dump()); in HWTEST_F()
79 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr8_.dump()); in HWTEST_F()
81 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr8_.dump()); in HWTEST_F()
83 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr8_.dump()); in HWTEST_F()
85 DistributedInputSinkTransport::GetInstance().HandleData(sessionId, jsonStr8_.dump()); in HWTEST_F()
86 sessionId = -1; in HWTEST_F()
88 int32_t ret = DistributedInputSinkTransport::GetInstance().RespPrepareRemoteInput(sessionId, smsg); in HWTEST_F()
94 int32_t sessionId in HWTEST_F() local
102 int32_t sessionId = 1; HWTEST_F() local
110 int32_t sessionId = 1; HWTEST_F() local
122 int32_t sessionId = 1; HWTEST_F() local
149 int32_t sessionId = 0; HWTEST_F() local
157 int32_t sessionId = 1; HWTEST_F() local
165 int32_t sessionId = 1; HWTEST_F() local
177 int32_t sessionId = 1; HWTEST_F() local
217 int32_t sessionId = 0; HWTEST_F() local
225 int32_t sessionId = 1; HWTEST_F() local
237 int32_t sessionId = 1; HWTEST_F() local
260 int32_t sessionId = 1; HWTEST_F() local
300 int32_t sessionId = 0; HWTEST_F() local
308 int32_t sessionId = 1; HWTEST_F() local
320 int32_t sessionId = 1; HWTEST_F() local
347 int32_t sessionId = 1000; HWTEST_F() local
355 int32_t sessionId = 1000; HWTEST_F() local
364 int32_t sessionId = 1002; HWTEST_F() local
371 int32_t sessionId = 1000; HWTEST_F() local
384 int32_t sessionId = 1000; HWTEST_F() local
394 int32_t sessionId = 1000; HWTEST_F() local
405 int32_t sessionId = 1000; HWTEST_F() local
415 int32_t sessionId = 1010; HWTEST_F() local
432 int32_t sessionId = 1013; HWTEST_F() local
441 int32_t sessionId = 0; HWTEST_F() local
453 int32_t sessionId = 1; HWTEST_F() local
472 int32_t sessionId = 1; HWTEST_F() local
480 int32_t sessionId = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/src/
H A Dclient_trans_session_callback.c38 int32_t *sessionId) in AcceptSessionAsServer()
78 *sessionId = session->sessionId; in AcceptSessionAsServer()
84 int32_t *sessionId, ISessionListener *listener) in GetSessionCallbackByChannelId()
86 if ((channelId < 0) || (sessionId == NULL) || (listener == NULL)) { in GetSessionCallbackByChannelId()
90 int32_t ret = ClientGetSessionIdByChannelId(channelId, channelType, sessionId, false); in GetSessionCallbackByChannelId()
92 TRANS_LOGE(TRANS_SDK, "get sessionId failed, channelId=%{public}d, ret=%{public}d", channelId, ret); in GetSessionCallbackByChannelId()
95 ret = ClientGetSessionCallbackById(*sessionId, listener); in GetSessionCallbackByChannelId()
103 static int32_t GetSocketCallbackAdapterByChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, in GetSocketCallbackAdapterByChannelId() argument
106 if ((channelId < 0) || (sessionId in GetSocketCallbackAdapterByChannelId()
37 AcceptSessionAsServer(const char *sessionName, const ChannelInfo *channel, uint32_t flag, int32_t *sessionId) AcceptSessionAsServer() argument
83 GetSessionCallbackByChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, ISessionListener *listener) GetSessionCallbackByChannelId() argument
126 GetSocketCallbackAdapterByUdpChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, SessionListenerAdapter *sessionCallback, bool *isServer) GetSocketCallbackAdapterByUdpChannelId() argument
148 TransOnBindSuccess(int32_t sessionId, const ISocketListener *socketCallback) TransOnBindSuccess() argument
167 TransOnBindFailed(int32_t sessionId, const ISocketListener *socketCallback, int32_t errCode) TransOnBindFailed() argument
200 HandleAsyncBindSuccess( int32_t sessionId, const ISocketListener *socketClient, const SocketLifecycleData *lifecycle) HandleAsyncBindSuccess() argument
259 HandleSyncBindSuccess(int32_t sessionId, const SocketLifecycleData *lifecycle) HandleSyncBindSuccess() argument
277 HandleOnBindSuccess(int32_t sessionId, SessionListenerAdapter sessionCallback, bool isServer) HandleOnBindSuccess() argument
332 int32_t sessionId = INVALID_SESSION_ID; TransOnSessionOpened() local
371 int32_t sessionId = INVALID_SESSION_ID; TransOnSessionOpenFailed() local
418 int32_t sessionId = INVALID_SESSION_ID; TransOnSessionClosed() local
452 ProcessReceivedFileData(int32_t sessionId, int32_t channelId, const char *data, uint32_t len, SessionPktType type) ProcessReceivedFileData() argument
473 int32_t sessionId; TransOnDataReceived() local
524 int32_t sessionId; TransOnOnStreamRecevied() local
555 int32_t sessionId; TransOnQosEvent() local
[all...]
H A Dclient_trans_message_service.c62 int SendBytes(int sessionId, const void *data, unsigned int len) in SendBytes() argument
69 int ret = CheckPermissionState(sessionId); in SendBytes()
72 "SendBytes no permission, sessionId=%{public}d, len=%{public}u, ret=%{public}d", sessionId, len, ret); in SendBytes()
79 ret = ClientGetChannelBySessionId(sessionId, &channelId, &channelType, &enableStatus); in SendBytes()
81 TRANS_BYTES, "ClientGetChannelBySessionId fail, sessionId=%{public}d", sessionId); in SendBytes()
85 ret = ClientGetChannelBusinessTypeBySessionId(sessionId, &businessType); in SendBytes()
87 TRANS_BYTES, "ClientGetChannelBusinessTypeBySessionId fail, sessionId=%{public}d", sessionId); in SendBytes()
113 SendMessage(int sessionId, const void *data, unsigned int len) SendMessage() argument
156 SendStream(int sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) SendStream() argument
195 SendFile(int sessionId, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) SendFile() argument
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_transport_softbus_adapter.cpp114 int32_t DSchedTransportSoftbusAdapter::ConnectDevice(const std::string &peerDeviceId, int32_t &sessionId) in ConnectDevice() argument
124 sessionId = iter->first; in ConnectDevice()
141 sessionId = INVALID_SESSION_ID; in ConnectDevice()
154 ret = AddNewPeerSession(peerDeviceId, sessionId); in ConnectDevice()
155 if (ret != ERR_OK || sessionId <= 0) { in ConnectDevice()
156 HILOGE("Add new peer connect session fail, ret: %{public}d, sessionId: %{public}d.", ret, sessionId); in ConnectDevice()
161 int32_t DSchedTransportSoftbusAdapter::AddNewPeerSession(const std::string &peerDeviceId, int32_t &sessionId) in AddNewPeerSession() argument
164 sessionId = CreateClientSocket(peerDeviceId); in AddNewPeerSession()
165 if (sessionId < in AddNewPeerSession()
216 int32_t sessionId = Socket(info); CreateClientSocket() local
221 CreateSessionRecord(int32_t sessionId, const std::string &peerDeviceId, bool isServer) CreateSessionRecord() argument
251 int32_t sessionId = 0; DisconnectDevice() local
270 ShutdownSession(const std::string &peerDeviceId, int32_t sessionId) ShutdownSession() argument
282 GetSessionIdByDeviceId(const std::string &peerDeviceId, int32_t &sessionId) GetSessionIdByDeviceId() argument
294 OnBind(int32_t sessionId, const std::string &peerDeviceId) OnBind() argument
303 OnShutdown(int32_t sessionId, bool isSelfcalled) OnShutdown() argument
320 NotifyListenersSessionShutdown(int32_t sessionId, bool isSelfcalled) NotifyListenersSessionShutdown() argument
362 SendData(int32_t sessionId, int32_t dataType, std::shared_ptr<DSchedDataBuffer> dataBuffer) SendData() argument
373 SendBytesBySoftbus(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer) SendBytesBySoftbus() argument
384 OnBytes(int32_t sessionId, const void *data, uint32_t dataLen) OnBytes() argument
409 OnDataReady(int32_t sessionId, std::shared_ptr<DSchedDataBuffer> dataBuffer, uint32_t dataType) OnDataReady() argument
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/
H A Dsession_mock.cpp48 void CloseSessionInner(int sessionId) in CloseSessionInner() argument
50 return CloseSession(sessionId); in CloseSessionInner()
63 int32_t SendBytesInner(int32_t sessionId, const void *data, uint32_t len) in SendBytesInner() argument
65 return SendBytes(sessionId, data, len); in SendBytesInner()
68 int32_t GetPeerUidInner(int32_t sessionId, int *data) in GetPeerUidInner() argument
70 return ClientGetSessionIntegerDataById(sessionId, data, KEY_PEER_UID); in GetPeerUidInner()
73 int32_t GetPeerPidInner(int32_t sessionId, int *data) in GetPeerPidInner() argument
75 return ClientGetSessionIntegerDataById(sessionId, data, KEY_PEER_PID); in GetPeerPidInner()
78 int32_t IsServerSideInner(int32_t sessionId, int *data) in IsServerSideInner() argument
80 return ClientGetSessionIntegerDataById(sessionId, dat in IsServerSideInner()
83 GetMySessionNameInner(int32_t sessionId, char *data, uint16_t len) GetMySessionNameInner() argument
88 GetPeerSessionNameInner(int32_t sessionId, char *data, uint16_t len) GetPeerSessionNameInner() argument
93 GetPeerDeviceIdInner(int32_t sessionId, char *data, uint16_t len) GetPeerDeviceIdInner() argument
98 GetPkgNameInner(int32_t sessionId, char *data, uint16_t len) GetPkgNameInner() argument
[all...]
/foundation/distributedhardware/distributed_input/services/sink/transport/src/
H A Ddistributed_input_sink_switch.cpp50 int32_t DistributedInputSinkSwitch::StartSwitch(int32_t sessionId) in StartSwitch() argument
54 DHLOGE("StartSwitch sessionId: %{public}d fail,switchVector_ is null.", sessionId); in StartSwitch()
59 if ((*it).sessionId == sessionId) { in StartSwitch()
67 DHLOGI("StartSwitch sessionId: %{public}d is find.", sessionId); in StartSwitch()
70 DHLOGE("StartSwitch sessionId: %{public}d fail, not found.", sessionId); in StartSwitch()
76 void DistributedInputSinkSwitch::StopSwitch(int32_t sessionId) in StopSwitch() argument
112 AddSession(int32_t sessionId) AddSession() argument
138 RemoveSession(int32_t sessionId) RemoveSession() argument
[all...]
H A Ddistributed_input_sink_transport.cpp91 int32_t sessionId = DistributedInputSinkSwitch::GetInstance().GetSwitchOpenedSession(); in ProcessEvent() local
92 if (sessionId > 0) { in ProcessEvent()
93 DistributedInputSinkTransport::GetInstance().SendMessage(sessionId, smsg); in ProcessEvent()
133 const int32_t sessionId, std::string &smsg) in RespPrepareRemoteInput()
135 if (sessionId > 0) { in RespPrepareRemoteInput()
136 DHLOGI("RespPrepareRemoteInput sessionId: %{public}d, smsg:%{public}s.", sessionId, SetAnonyId(smsg).c_str()); in RespPrepareRemoteInput()
137 int32_t ret = SendMessage(sessionId, smsg); in RespPrepareRemoteInput()
144 DHLOGE("RespPrepareRemoteInput error, sessionId <= 0."); in RespPrepareRemoteInput()
149 int32_t DistributedInputSinkTransport::RespUnprepareRemoteInput(const int32_t sessionId, st argument
132 RespPrepareRemoteInput( const int32_t sessionId, std::string &smsg) RespPrepareRemoteInput() argument
165 RespStartRemoteInput(const int32_t sessionId, std::string &smsg) RespStartRemoteInput() argument
181 RespStopRemoteInput(const int32_t sessionId, std::string &smsg) RespStopRemoteInput() argument
197 RespLatency(const int32_t sessionId, std::string &smsg) RespLatency() argument
213 SendKeyStateNodeMsg(const int32_t sessionId, const std::string &dhId, uint32_t type, const uint32_t btnCode, int32_t value) SendKeyStateNodeMsg() argument
235 SendKeyStateNodeMsgBatch(const int32_t sessionId, const std::vector<struct RawEvent> &events) SendKeyStateNodeMsgBatch() argument
261 DoSendMsgBatch(const int32_t sessionId, const std::vector<struct RawEvent> &events) DoSendMsgBatch() argument
316 SendMessage(int32_t sessionId, std::string &message) SendMessage() argument
334 NotifyPrepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyPrepareRemoteInput() argument
351 NotifyUnprepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyUnprepareRemoteInput() argument
367 NotifyStartRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyStartRemoteInput() argument
385 NotifyStopRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyStopRemoteInput() argument
403 NotifyLatency(int32_t sessionId, const nlohmann::json &recMsg) NotifyLatency() argument
417 NotifyStartRemoteInputDhid(int32_t sessionId, const nlohmann::json &recMsg) NotifyStartRemoteInputDhid() argument
435 NotifyStopRemoteInputDhid(int32_t sessionId, const nlohmann::json &recMsg) NotifyStopRemoteInputDhid() argument
453 NotifyRelayPrepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayPrepareRemoteInput() argument
471 NotifyRelayUnprepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayUnprepareRemoteInput() argument
489 NotifyRelayStartDhidRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayStartDhidRemoteInput() argument
509 NotifyRelayStopDhidRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayStopDhidRemoteInput() argument
529 NotifyRelayStartTypeRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayStartTypeRemoteInput() argument
549 NotifyRelayStopTypeRemoteInput(int32_t sessionId, const nlohmann::json &recMsg) NotifyRelayStopTypeRemoteInput() argument
569 NotifySessionClosed(int32_t sessionId) NotifySessionClosed() argument
574 HandleSessionData(int32_t sessionId, const std::string &message) HandleSessionData() argument
580 HandleEventInner(int32_t sessionId, const nlohmann::json &recMsg) HandleEventInner() argument
607 HandleData(int32_t sessionId, const std::string &message) HandleData() argument
[all...]
/foundation/ai/ai_engine/services/client/client_executor/source/
H A Dclient_factory.cpp47 if (clientInfo.sessionId != INVALID_SESSION_ID) { in ClientInit()
49 // Valid sessionId tells it has been already INIT successfully before in ClientInit()
53 clientInfo.sessionId = GenerateSessionId(); in ClientInit()
59 HILOGE("[ClientFactory][clientId:%d,sessionId:%d]Fail to connect and init server, retCode[%d].", in ClientInit()
60 clientId_, clientInfo.sessionId, retCode); in ClientInit()
70 return RegisterDeadCb(clientInfo.sessionId, cb); in ClientInit()
77 if (clientInfo.sessionId == INVALID_SESSION_ID) { in ClientPrepare()
78 HILOGI("[ClientFactory][clientId:%d, sessionId:%d]SessionId is invalid,"\ in ClientPrepare()
80 clientId_, clientInfo.sessionId); in ClientPrepare()
86 HILOGE("[ClientFactory][clientId:%d,sessionId in ClientPrepare()
261 EraseSessionInfo(int sessionId) EraseSessionInfo() argument
271 GetSessionInfo(int sessionId, int &algorithmType) GetSessionInfo() argument
280 RegisterCb(int sessionId, IClientCb *cb) RegisterCb() argument
296 UnRegisterCb(const int sessionId) UnRegisterCb() argument
309 RegisterDeadCb(int sessionId, IServiceDeadCb *cb) RegisterDeadCb() argument
325 UnRegisterDeadCb(const int sessionId) UnRegisterDeadCb() argument
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/softbus/
H A Dsoftbus_connection.cpp78 int SoftBusConnection::OnConnectionSessionOpened(int sessionId, int result) in OnConnectionSessionOpened() argument
80 CLOGI("In, sessionId = %{public}d, result = %{public}d.", sessionId, result); in OnConnectionSessionOpened()
81 auto ret = GetConnection(sessionId); in OnConnectionSessionOpened()
83 CLOGE("Get Connection Failed, sessionId = %{public}d, result = %{public}d.", sessionId, result); in OnConnectionSessionOpened()
94 softBusConn->GetSoftBus().SetSessionId(sessionId); in OnConnectionSessionOpened()
98 CLOGE("Open Session Failed, sessionName = %{public}s, sessionId = %{public}d, result = %{public}d.", in OnConnectionSessionOpened()
99 sessionName.c_str(), sessionId, result); in OnConnectionSessionOpened()
102 CLOGD("Open Session Succ, sessionName = %{public}s, sessionId in OnConnectionSessionOpened()
110 OnConnectionSessionClosed(int sessionId) OnConnectionSessionClosed() argument
126 OnConnectionMessageReceived(int sessionId, const void *data, unsigned int dataLen) OnConnectionMessageReceived() argument
131 OnConnectionBytesReceived(int sessionId, const void *data, unsigned int dataLen) OnConnectionBytesReceived() argument
157 OnConnectionStreamReceived(int sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnConnectionStreamReceived() argument
184 OnConnectionSessionEvent(int sessionId, int eventId, int tvCount, const QosTv *tvList) OnConnectionSessionEvent() argument
190 GetConnection(int sessionId) GetConnection() argument
217 OnSendFileProcess(int sessionId, uint64_t bytesUpload, uint64_t bytesTotal) OnSendFileProcess() argument
238 OnSendFileFinished(int sessionId, const char *firstFile) OnSendFileFinished() argument
258 OnFileTransError(int sessionId) OnFileTransError() argument
279 OnReceiveFileStarted(int sessionId, const char *files, int fileCnt) OnReceiveFileStarted() argument
285 OnReceiveFileProcess(int sessionId, const char *firstFile, uint64_t bytesUpload, uint64_t bytesTotal) OnReceiveFileProcess() argument
293 OnReceiveFileFinished(int sessionId, const char *files, int fileCnt) OnReceiveFileFinished() argument
362 int sessionId = -1; SetupSession() local
430 CreateSessionName(ModuleType moduleType, int sessionId) CreateSessionName() argument
[all...]
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/softbus/
H A Dsoftbus_connection.cpp78 int SoftBusConnection::OnConnectionSessionOpened(int sessionId, int result) in OnConnectionSessionOpened() argument
80 CLOGI("In, sessionId = %{public}d, result = %{public}d.", sessionId, result); in OnConnectionSessionOpened()
81 auto ret = GetConnection(sessionId); in OnConnectionSessionOpened()
83 CLOGE("Get Connection Failed, sessionId = %{public}d, result = %{public}d.", sessionId, result); in OnConnectionSessionOpened()
94 softBusConn->GetSoftBus().SetSessionId(sessionId); in OnConnectionSessionOpened()
98 CLOGE("Open Session Failed, sessionName = %{public}s, sessionId = %{public}d, result = %{public}d.", in OnConnectionSessionOpened()
99 sessionName.c_str(), sessionId, result); in OnConnectionSessionOpened()
102 CLOGD("Open Session Succ, sessionName = %{public}s, sessionId in OnConnectionSessionOpened()
110 OnConnectionSessionClosed(int sessionId) OnConnectionSessionClosed() argument
126 OnConnectionMessageReceived(int sessionId, const void *data, unsigned int dataLen) OnConnectionMessageReceived() argument
131 OnConnectionBytesReceived(int sessionId, const void *data, unsigned int dataLen) OnConnectionBytesReceived() argument
157 OnConnectionStreamReceived(int sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnConnectionStreamReceived() argument
184 OnConnectionSessionEvent(int sessionId, int eventId, int tvCount, const QosTv *tvList) OnConnectionSessionEvent() argument
190 GetConnection(int sessionId) GetConnection() argument
217 OnSendFileProcess(int sessionId, uint64_t bytesUpload, uint64_t bytesTotal) OnSendFileProcess() argument
237 OnSendFileFinished(int sessionId, const char *firstFile) OnSendFileFinished() argument
257 OnFileTransError(int sessionId) OnFileTransError() argument
278 OnReceiveFileStarted(int sessionId, const char *files, int fileCnt) OnReceiveFileStarted() argument
284 OnReceiveFileProcess(int sessionId, const char *firstFile, uint64_t bytesUpload, uint64_t bytesTotal) OnReceiveFileProcess() argument
290 OnReceiveFileFinished(int sessionId, const char *files, int fileCnt) OnReceiveFileFinished() argument
359 int sessionId = -1; SetupSession() local
427 CreateSessionName(ModuleType moduleType, int sessionId) CreateSessionName() argument
[all...]
/foundation/distributedhardware/distributed_input/services/sink/transport/include/
H A Ddistributed_input_sink_transport.h46 void HandleSessionData(int32_t sessionId, const std::string &messageData) override;
47 void NotifySessionClosed(int32_t sessionId) override;
56 int32_t RespPrepareRemoteInput(const int32_t sessionId, std::string &smsg);
57 int32_t RespUnprepareRemoteInput(const int32_t sessionId, std::string &smsg);
58 int32_t RespStartRemoteInput(const int32_t sessionId, std::string &smsg);
59 int32_t RespStopRemoteInput(const int32_t sessionId, std::string &smsg);
60 int32_t RespLatency(const int32_t sessionId, std::string &smsg);
61 void SendKeyStateNodeMsg(const int32_t sessionId, const std::string &dhId, uint32_t type, const uint32_t btnCode,
63 void SendKeyStateNodeMsgBatch(const int32_t sessionId, const std::vector<struct RawEvent> &events);
78 int32_t SendMessage(int32_t sessionId, st
[all...]
/foundation/distributedhardware/device_manager/test/unittest/mock/
H A Dsession.h127 int (*OnSessionOpened)(int sessionId, int result);
128 void (*OnSessionClosed)(int sessionId);
129 void (*OnBytesReceived)(int sessionId, const void *data, unsigned int dataLen);
130 void (*OnMessageReceived)(int sessionId, const void *data, unsigned int dataLen);
131 void (*OnStreamReceived)(int sessionId, const StreamData *data, const StreamData *ext, const FrameInfo *param);
135 int (*OnReceiveFileStarted)(int sessionId, const char *files, int fileCnt);
136 int (*OnReceiveFileProcess)(int sessionId, const char *firstFile, uint64_t bytesUpload, uint64_t bytesTotal);
137 void (*OnReceiveFileFinished)(int sessionId, const char *files, int fileCnt);
138 void (*OnFileTransError)(int sessionId);
142 int (*OnSendFileProcess)(int sessionId, uint64_
[all...]
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dobject_store_test.cpp48 explicit TableWatcherImpl(const std::string &sessionId) : TableWatcher(sessionId) {} in TableWatcherImpl() argument
61 const std::string &sessionId, const std::string &networkId, const std::string &onlineStatus) override;
66 void StatusNotifierImpl::OnChanged(const std::string &sessionId, in OnChanged() argument
129 std::string sessionId = "123456"; in HWTEST_F() local
133 DistributedObject *object = objectStore->CreateObject(sessionId); in HWTEST_F()
136 uint32_t ret = objectStore->DeleteObject(sessionId); in HWTEST_F()
147 std::string sessionId = "123456"; in HWTEST_F() local
150 DistributedObject *object = objectStore->CreateObject(sessionId); in HWTEST_F()
163 std::string sessionId in HWTEST_F() local
185 std::string sessionId = "123456"; HWTEST_F() local
206 std::string sessionId = "123456"; HWTEST_F() local
221 std::string sessionId = "123456"; HWTEST_F() local
240 std::string sessionId = ""; HWTEST_F() local
261 std::string sessionId = "sessionId"; HWTEST_F() local
284 std::string sessionId = "sessionId"; HWTEST_F() local
312 std::string sessionId = "sessionId"; HWTEST_F() local
353 std::string sessionId = "123456"; HWTEST_F() local
377 std::string sessionId = "123456"; HWTEST_F() local
403 std::string sessionId = "123456"; HWTEST_F() local
426 std::string sessionId = "123456"; HWTEST_F() local
452 std::string sessionId = "123456"; HWTEST_F() local
475 std::string sessionId = "123456"; HWTEST_F() local
501 std::string sessionId = "123456"; HWTEST_F() local
524 std::string sessionId = "123456"; HWTEST_F() local
550 std::string sessionId = "123456"; HWTEST_F() local
573 std::string sessionId = "123456"; HWTEST_F() local
592 std::string sessionId = "123456"; HWTEST_F() local
613 std::string sessionId = "123456"; HWTEST_F() local
636 std::string sessionId = "123456"; HWTEST_F() local
657 std::string sessionId = "123456"; HWTEST_F() local
712 std::string sessionId = "123456"; HWTEST_F() local
749 std::string sessionId = "123456"; HWTEST_F() local
772 std::string sessionId = "123456"; HWTEST_F() local
839 std::string sessionId = "123456"; HWTEST_F() local
860 std::string sessionId = "123456"; HWTEST_F() local
881 std::string sessionId = "123456"; HWTEST_F() local
900 std::string sessionId = "123456"; HWTEST_F() local
921 std::string sessionId = "123456"; HWTEST_F() local
939 std::string sessionId = "session01"; HWTEST_F() local
955 std::string sessionId = "session02"; HWTEST_F() local
973 std::string sessionId = "session03"; HWTEST_F() local
995 std::string sessionId = "session04"; HWTEST_F() local
1020 std::string sessionId = "session06"; HWTEST_F() local
1040 std::string sessionId = "session07"; HWTEST_F() local
1080 std::string sessionId = "session07"; HWTEST_F() local
1098 std::string sessionId = "session05"; HWTEST_F() local
1115 std::string sessionId = "session001"; HWTEST_F() local
1132 std::string sessionId = "session001"; HWTEST_F() local
1146 std::string sessionId = "session002"; HWTEST_F() local
1164 std::string sessionId = "session003"; HWTEST_F() local
1182 std::string sessionId = "session004"; HWTEST_F() local
1202 std::string sessionId = "session005"; HWTEST_F() local
1223 std::string sessionId = ""; HWTEST_F() local
1239 std::string sessionId = ""; HWTEST_F() local
1253 std::string sessionId = ""; HWTEST_F() local
1269 std::string sessionId = ""; HWTEST_F() local
1285 std::string sessionId = ""; HWTEST_F() local
1311 std::string sessionId = "123456"; HWTEST_F() local
1331 std::string sessionId = "123456"; HWTEST_F() local
1364 std::string sessionId = "123456"; HWTEST_F() local
1386 std::string sessionId = "123456"; HWTEST_F() local
1408 std::string sessionId = "123456"; HWTEST_F() local
1432 std::string sessionId = "123456"; HWTEST_F() local
1453 std::string sessionId = "123456"; HWTEST_F() local
1473 std::string sessionId = "123456"; HWTEST_F() local
1489 std::string sessionId = "123456"; HWTEST_F() local
1505 std::string sessionId = "123456"; HWTEST_F() local
1524 std::string sessionId = "123456"; HWTEST_F() local
1545 std::string sessionId = "123456"; HWTEST_F() local
1574 std::string sessionId = "123456"; HWTEST_F() local
1607 std::string sessionId = "123456"; HWTEST_F() local
1631 std::string sessionId = "123456"; HWTEST_F() local
1661 std::string sessionId = "123456"; HWTEST_F() local
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_file_send_listener.cpp54 std::string SoftBusFileSendListener::GetLocalSessionName(int32_t sessionId) in GetLocalSessionName() argument
57 sessionName = SoftBusHandler::GetSessionName(sessionId); in GetLocalSessionName()
61 void SoftBusFileSendListener::OnSendFileProcess(int32_t sessionId, uint64_t bytesUpload, uint64_t bytesTotal) in OnSendFileProcess() argument
63 LOGI("OnSendFileProcess, sessionId = %{public}d bytesUpload = %{public}" PRIu64 "bytesTotal = %{public}" PRIu64 "", in OnSendFileProcess()
64 sessionId, bytesUpload, bytesTotal); in OnSendFileProcess()
67 void SoftBusFileSendListener::OnSendFileFinished(int32_t sessionId) in OnSendFileFinished() argument
69 LOGI("OnSendFileFinished, sessionId = %{public}d", sessionId); in OnSendFileFinished()
70 std::string sessionName = GetLocalSessionName(sessionId); in OnSendFileFinished()
75 SoftBusHandler::GetInstance().CloseSession(sessionId, sessionNam in OnSendFileFinished()
78 OnFileTransError(int32_t sessionId, int32_t errorCode) OnFileTransError() argument
89 OnSendFileReport(int32_t sessionId, FileStatusList statusList, int32_t errorCode) OnSendFileReport() argument
94 OnSendFileShutdown(int32_t sessionId, ShutdownReason reason) OnSendFileShutdown() argument
[all...]
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/
H A Dsoftbus_session.cpp95 int32_t sessionId = -1; in OpenAuthSession() local
99 LOGE("[SOFTBUS]addrInfo is nullptr. sessionId: %{public}d.", sessionId); in OpenAuthSession()
100 return sessionId; in OpenAuthSession()
102 sessionId = ::OpenAuthSession(DM_SESSION_NAME, addrInfo, 1, nullptr); in OpenAuthSession()
103 if (sessionId < 0) { in OpenAuthSession()
104 LOGE("[SOFTBUS]open session error, sessionId: %{public}d.", sessionId); in OpenAuthSession()
105 return sessionId; in OpenAuthSession()
108 LOGI("OpenAuthSession success. sessionId in OpenAuthSession()
112 CloseAuthSession(int32_t sessionId) CloseAuthSession() argument
119 GetPeerDeviceId(int32_t sessionId, std::string &peerDevId) GetPeerDeviceId() argument
134 SendData(int32_t sessionId, std::string &message) SendData() argument
158 SendHeartbeatData(int32_t sessionId, std::string &message) SendHeartbeatData() argument
168 OnSessionOpened(int sessionId, int result) OnSessionOpened() argument
176 OnSessionClosed(int sessionId) OnSessionClosed() argument
181 OnBytesReceived(int sessionId, const void *data, unsigned int dataLen) OnBytesReceived() argument
[all...]
/foundation/distributedhardware/distributed_input/services/source/transport/include/
H A Ddistributed_input_source_transport.h47 void HandleSessionData(int32_t sessionId, const std::string &messageData) override;
76 int32_t PrepareRemoteInput(int32_t sessionId, const std::string &deviceId);
77 int32_t UnprepareRemoteInput(int32_t sessionId, const std::string &deviceId);
92 int32_t SendMessage(int32_t sessionId, std::string &message);
93 void HandleData(int32_t sessionId, const std::string &message);
94 void HandleEventFirst(int32_t sessionId, const nlohmann::json &recMsg);
95 void HandleEventSecond(int32_t sessionId, const nlohmann::json &recMsg);
97 void NotifyResponsePrepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg);
98 void NotifyResponseUnprepareRemoteInput(int32_t sessionId, const nlohmann::json &recMsg);
99 void NotifyResponseStartRemoteInput(int32_t sessionId, cons
[all...]
/foundation/distributedhardware/device_manager/services/service/src/pinholder/
H A Dpin_holder_session.cpp54 int32_t sessionId = -1; in OpenSessionServer() local
58 LOGE("[SOFTBUS]open session error, sessionId: %{public}d.", sessionId); in OpenSessionServer()
61 sessionId = ::OpenAuthSession(DM_PIN_HOLDER_SESSION_NAME, &addrInfo, 1, nullptr); in OpenSessionServer()
62 if (sessionId < 0) { in OpenSessionServer()
63 LOGE("[SOFTBUS]open session error, sessionId: %{public}d.", sessionId); in OpenSessionServer()
64 return sessionId; in OpenSessionServer()
66 LOGI("OpenAuthSession success. sessionId: %{public}d.", sessionId); in OpenSessionServer()
70 CloseSessionServer(int32_t sessionId) CloseSessionServer() argument
77 OnSessionOpened(int sessionId, int result) OnSessionOpened() argument
89 OnSessionClosed(int sessionId) OnSessionClosed() argument
100 OnBytesReceived(int sessionId, const void *data, unsigned int dataLen) OnBytesReceived() argument
117 SendData(int32_t sessionId, const std::string &message) SendData() argument
[all...]
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
H A Dflat_object_store.h30 FlatObjectWatcher(const std::string &sessionId) : TableWatcher(sessionId) in FlatObjectWatcher() argument
34 const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) = 0;
40 uint32_t Save(const std::string &bundleName, const std::string &sessionId, const std::string &deviceId,
42 uint32_t RevokeSave(const std::string &bundleName, const std::string &sessionId);
43 int32_t ResumeObject(const std::string &bundleName, const std::string &sessionId,
45 int32_t SubscribeDataChange(const std::string &bundleName, const std::string &sessionId,
47 int32_t UnregisterDataChange(const std::string &bundleName, const std::string &sessionId);
48 int32_t DeleteSnapshot(const std::string &bundleName, const std::string &sessionId);
51 int32_t SaveObject(const std::string &bundleName, const std::string &sessionId,
[all...]

Completed in 13 milliseconds

12345678910>>...34