Home
last modified time | relevance | path

Searched refs:sessionLock (Results 1 - 7 of 7) sorted by relevance

/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_transport_softbus_adapter.cpp118 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in ConnectDevice()
231 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in CreateSessionRecord()
252 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in DisconnectDevice()
284 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in GetSessionIdByDeviceId()
306 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in OnShutdown()
340 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in ReleaseChannel()
365 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in SendData()
392 std::lock_guard<std::mutex> sessionLock(sessionMutex_); in OnBytes()
/foundation/distributedhardware/distributed_input/services/transportbase/src/
H A Ddistributed_input_transport_base.cpp164 std::unique_lock<std::mutex> sessionLock(operationMutex_); in Release()
189 std::unique_lock<std::mutex> sessionLock(operationMutex_); in CheckDeviceSessionState()
199 std::unique_lock<std::mutex> sessionLock(operationMutex_); in GetDevIdBySessionId()
281 std::unique_lock<std::mutex> sessionLock(operationMutex_); in StopAllSession()
296 std::unique_lock<std::mutex> sessionLock(operationMutex_); in StopSession()
389 std::unique_lock<std::mutex> sessionLock(operationMutex_); in OnSessionOpened()
412 std::unique_lock<std::mutex> sessionLock(operationMutex_); in OnSessionClosed()
550 std::unique_lock<std::mutex> sessionLock(operationMutex_); in GetSessionIdByDevId()
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_file_manager.c163 ProxyFileMutexLock *sessionLock = NULL; in GetSessionFileLock() local
166 sessionLock = item; in GetSessionFileLock()
170 if (sessionLock != NULL) { in GetSessionFileLock()
171 sessionLock->count++; in GetSessionFileLock()
173 return sessionLock; in GetSessionFileLock()
175 sessionLock = (ProxyFileMutexLock *)SoftBusCalloc(sizeof(ProxyFileMutexLock)); in GetSessionFileLock()
176 if (sessionLock == NULL) { in GetSessionFileLock()
180 if (SoftBusMutexInit(&sessionLock->sendLock, NULL) != SOFTBUS_OK) { in GetSessionFileLock()
182 SoftBusFree(sessionLock); in GetSessionFileLock()
185 ListInit(&sessionLock in GetSessionFileLock()
194 DelSessionFileLock(ProxyFileMutexLock *sessionLock) DelSessionFileLock() argument
1003 ProxyFileMutexLock *sessionLock = GetSessionFileLock(channelId); ProxyChannelSendFile() local
[all...]
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/src/fuse_manager/
H A Dfuse_manager.cpp156 std::shared_mutex sessionLock; member
169 std::shared_lock lock(sessionLock); in SetReadCacheFlag()
180 std::shared_lock lock(sessionLock); in IsReadAhead()
191 std::shared_lock lock(sessionLock); in IsReadFinished()
775 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, std::defer_lock); in CloudOpenHelper()
848 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, std::defer_lock); in CloudRelease()
966 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, std::defer_lock); in CancelRead()
1071 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, std::defer_lock); in CloudReadOnCloudFile()
1129 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, std::defer_lock); in CloudReadOnCacheFile()
1239 std::unique_lock<std::shared_mutex> wSesLock(cInode->sessionLock, st in WaitData()
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/
H A Dclient_trans_proxy_file_manager_test.cpp417 ProxyFileMutexLock *sessionLock = GetSessionFileLock(channelId); in HWTEST_F() local
418 EXPECT_NE(nullptr, sessionLock); in HWTEST_F()
420 sessionLock = GetSessionFileLock(channelId); in HWTEST_F()
421 EXPECT_NE(nullptr, sessionLock); in HWTEST_F()
424 sessionLock->count = 1; in HWTEST_F()
425 DelSessionFileLock(sessionLock); in HWTEST_F()
427 sessionLock->count = 2; in HWTEST_F()
428 DelSessionFileLock(sessionLock); in HWTEST_F()
/foundation/distributedhardware/distributed_input/services/source/transport/src/
H A Ddistributed_input_source_transport.cpp402 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginPrepareResult()
423 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginUnprepareResult()
445 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginStartDhidResult()
468 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginStopDhidResult()
491 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginStartTypeResult()
514 std::unique_lock<std::mutex> sessionLock(operationMutex_); in NotifyOriginStopTypeResult()
/foundation/distributedhardware/distributed_screen/services/softbusadapter/src/
H A Dsoftbus_adapter.cpp310 std::lock_guard<std::mutex> sessionLock(idMapMutex_); in OnSoftbusSessionOpened()

Completed in 13 milliseconds