| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/ble/board/ |
| H A D | ble_auth_channel_test.cpp | 113 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
123 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
131 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
142 static void OnMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnMessageReceived() argument
[all...] |
| /foundation/communication/dsoftbus/core/transmission/common/include/ |
| H A D | softbus_trans_def.h | 41 int32_t sessionId; member
|
| /foundation/communication/dsoftbus/sdk/frame/standard/src/ |
| H A D | if_softbus_client.cpp | 59 int32_t ISoftBusClient::SetChannelInfo(const char *sessionName, int32_t sessionId, in SetChannelInfo() argument
|
| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| H A D | client_trans_session_callback.c | 103 static int32_t GetSocketCallbackAdapterByChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, in GetSocketCallbackAdapterByChannelId() argument
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...] |
| /foundation/communication/dsoftbus/tests/core/transmission/ipc/ |
| H A D | trans_client_proxy_test.cpp | 403 int32_t sessionId = TEST_PID; in HWTEST_F() local
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/ |
| H A D | trans_sdk_tcp_direct_test.cpp | 64 static int32_t OnServerSessionOpened(int32_t sessionId, int32_t result) in OnServerSessionOpened() argument
70 static void OnServerSessionClosed(int32_t sessionId) in OnServerSessionClosed() argument
75 static void OnServerBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnServerBytesReceived() argument
80 static void OnServerMessageReceived(int32_t sessionId, const void *data, unsigned int len) in OnServerMessageReceived() argument
[all...] |
| H A D | trans_tdc_sdk_test.c | 148 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
158 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
163 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
171 static void OnMessageReceived(int32_t sessionId, cons argument
[all...] |
| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/common/mock/ |
| H A D | trans_lane_pending_test_mock.cpp | 95 int32_t ClientIpcSetChannelInfo(const char *pkgName, const char *sessionName, int32_t sessionId, in ClientIpcSetChannelInfo() argument
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/session/ |
| H A D | client_trans_session_service_test.cpp | 96 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
102 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
107 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
112 static void OnMessageReceived(int32_t sessionId, cons argument
192 int32_t sessionId = 0; AddSessionServerAndSession() local
205 DeleteSessionServerAndSession(const char *sessionName, int32_t sessionId) DeleteSessionServerAndSession() argument
297 int32_t sessionId = 0; HWTEST_F() local
327 int32_t sessionId = 0; HWTEST_F() local
369 int32_t sessionId = AddSessionServerAndSession(g_sessionName, CHANNEL_TYPE_TCP_DIRECT, false); HWTEST_F() local
394 int32_t sessionId = AddSessionServerAndSession(g_sessionName, CHANNEL_TYPE_BUTT, false); HWTEST_F() local
420 int32_t sessionId = AddSessionServerAndSession(g_sessionName, CHANNEL_TYPE_BUTT, false); HWTEST_F() local
438 int32_t sessionId = 1; HWTEST_F() local
[all...] |
| H A D | client_trans_session_callback_test.cpp | 98 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
104 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
109 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
114 static void OnMessageReceived(int32_t sessionId, cons argument
119 OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument
125 OnQosEvent(int32_t sessionId, int32_t eventId, int32_t tvCount, const QosTv *tvList) OnQosEvent() argument
234 int32_t sessionId = 0; HWTEST_F() local
266 int32_t sessionId = 0; HWTEST_F() local
403 int32_t sessionId = 0; HWTEST_F() local
[all...] |
| H A D | client_trans_message_service_test.cpp | 101 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
107 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
112 static void OnBytesReceived(int32_t sessionId, const void *data, unsigned int len) in OnBytesReceived() argument
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/trans_channel/auth/ |
| H A D | auth_session_test.c | 55 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
71 static void OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
78 static void OnBytesReceived(int32_t sessionId, const void *data, uint32_t len) in OnBytesReceived() argument
87 static void OnMessageReceived(int32_t sessionId, cons argument
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/ |
| H A D | session_service_impl.cpp | 88 int32_t sessionId = in OpenSession() local
112 int32_t sessionId = session->GetSessionId(); in CloseSession() local
144 CreateSession(int32_t sessionId, const std::shared_ptr<Session> &session) CreateSession() argument
181 OpenSessionCallback(int32_t sessionId) OpenSessionCallback() argument
215 CloseSessionCallback(int32_t sessionId) CloseSessionCallback() argument
225 BytesReceivedCallback(int32_t sessionId, const void *data, uint32_t len) BytesReceivedCallback() argument
237 MessageReceivedCallback(int32_t sessionId, const void *data, uint32_t len) MessageReceivedCallback() argument
249 GetSessionListener( int32_t sessionId, std::shared_ptr<ISessionListener> &listener, std::shared_ptr<Session> &session) GetSessionListener() argument
266 GetSessionListenerOnSessionOpened( int32_t sessionId, std::shared_ptr<ISessionListener> &listener, std::shared_ptr<Session> &session) GetSessionListenerOnSessionOpened() argument
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
| H A D | stream_encrypt_client_mt.cpp | 215 void EnableSessionId(int32_t sessionId) in EnableSessionId() argument
227 void UnenableSessionId(int32_t sessionId) in UnenableSessionId() argument
237 bool WaitEnableSession(int32_t sessionId, uint32_t timeout) in WaitEnableSession() argument
265 static int32_t OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
277 OnSessionClosed(int32_t sessionId) OnSessionClosed() argument
318 int32_t sessionId = OpenSession(TEST_SESSION_NAME, TEST_SESSION_NAME_SRV, WaitOnLineAndGetNetWorkId(), "reserved", HWTEST_F() local
[all...] |
| /foundation/communication/dsoftbus/core/transmission/ipc/standard/src/ |
| H A D | trans_client_proxy_standard.cpp | 342 SetChannelInfo( const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType) SetChannelInfo() argument
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/ipc/ |
| H A D | trans_ipc_test.cpp | 476 int32_t sessionId = INVALID_SESSION_ID; in HWTEST_F() local
|
| /foundation/communication/ipc/ipc/test/rpc/socket_trans/src/ |
| H A D | rpc_mini_socket_trans.c | 278 int32_t *sessionId = (int32_t *)malloc(sizeof(int32_t)); in HandleConnect() local
347 static int32_t Disconnect(int32_t sessionId) in Disconnect() argument
353 static int32_t Send(int32_t sessionId, const void *data, uint32_t len) in Send() argument
[all...] |
| H A D | rpc_socket_trans.c | 269 int32_t *sessionId = (int32_t *)malloc(sizeof(int32_t)); in Connect() local
286 static int32_t Disconnect(int32_t sessionId) in Disconnect() argument
291 static int32_t Send(int32_t sessionId, const void *data, uint32_t len) in Send() argument
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/ |
| H A D | client_trans_file.c | 34 static void NotifySendResult(int32_t sessionId, DFileMsgType msgType, in NotifySendResult() argument
260 int32_t sessionId = -1; in FileSendListener() local
209 FileSendErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, DFileMsgType msgType, int32_t sessionId) FileSendErrorEvent() argument
279 NotifyRecvResult(int32_t sessionId, DFileMsgType msgType, const DFileMsg *msgData, FileListener *listener) NotifyRecvResult() argument
357 FileRecvErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, DFileMsgType msgType, int32_t sessionId) FileRecvErrorEvent() argument
401 int32_t sessionId = -1; FileReceiveListener() local
420 int32_t sessionId = -1; UpdateFileRecvPath() local
590 int32_t sessionId = INVALID_SESSION_ID; NotifyTransLimitChanged() local
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/fuzztest/objectstore_fuzzer/ |
| H A D | objectstore_fuzzer.cpp | 33 explicit TableWatcherImpl(const std::string &sessionId) : TableWatcher(sessionId) {} in TableWatcherImpl() argument
|
| /foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/ |
| H A D | js_distributedobjectstore.cpp | 160 std::string sessionId;
in JSCreateObjectSync() local
205 std::string sessionId;
in JSDestroyObjectSync() local
90 DelCallback(napi_env env, ConcurrentMap<std::string, std::list<napi_ref>> &callbacks, const std::string &sessionId, napi_value callback) DelCallback() argument
[all...] |
| H A D | js_distributedobject.cpp | 335 napi_value JSDistributedObject::GetRevokeSaveResultCons(napi_env env, std::string &sessionId)
in GetRevokeSaveResultCons() argument
310 GetSaveResultCons( napi_env env, std::string &sessionId, double version, std::string deviceId) GetSaveResultCons() argument
|
| H A D | js_watcher.cpp | 93 void JSWatcher::Emit(const char *type, const std::string &sessionId, const std::vector<std::string> &changeData)
in Emit() argument
371 StatusEventListener::StatusEventListener(std::weak_ptr<JSWatcher> watcher, const std::string &sessionId)
in StatusEventListener() argument
162 Emit( const char *type, const std::string &sessionId, const std::string &networkId, const std::string &status) Emit() argument
376 ChangeArgs( const napi_ref callback, const std::string &sessionId, const std::vector<std::string> &changeData) ChangeArgs() argument
382 StatusArgs( const napi_ref callback, const std::string &sessionId, const std::string &networkId, const std::string &status) StatusArgs() argument
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
| H A D | flat_object_storage_engine.cpp | 387 uint32_t FlatObjectStorageEngine::SyncAllData(const std::string &sessionId, const std::vector<std::string> &deviceIds, in SyncAllData() argument
436 void FlatObjectStorageEngine::NotifyStatus(const std::string &sessionId, const std::string &deviceId, in NotifyStatus() argument
446 void FlatObjectStorageEngine::NotifyChange(const std::string &sessionId, in NotifyChange() argument
487 Watcher(const std::string &sessionId) Watcher() argument
[all...] |
| H A D | distributed_object_store_impl.cpp | 51 void DistributedObjectStoreImpl::RemoveCacheObject(const std::string &sessionId) in RemoveCacheObject() argument
66 DistributedObject *DistributedObjectStoreImpl::CreateObject(const std::string &sessionId) in CreateObject() argument
87 DistributedObject *DistributedObjectStoreImpl::CreateObject(const std::string &sessionId, uint32_ argument
39 CacheObject( const std::string &sessionId, FlatObjectStore *flatObjectStore) CacheObject() argument
110 DeleteObject(const std::string &sessionId) DeleteObject() argument
126 Get(const std::string &sessionId, DistributedObject **object) Get() argument
203 NotifyCachedStatus(const std::string &sessionId) NotifyCachedStatus() argument
208 WatcherProxy(const std::shared_ptr<ObjectWatcher> objectWatcher, const std::string &sessionId) WatcherProxy() argument
213 OnChanged( const std::string &sessionId, const std::vector<std::string> &changedData, bool enableTransfer) OnChanged() argument
290 OnChanged( const std::string &sessionId, const std::string &networkId, const std::string &onlineStatus) OnChanged() argument
[all...] |