Home
last modified time | relevance | path

Searched refs:recvMutex_ (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dbuffer_object.cpp140 recvMutex_.lock(); in GetReceiveBufferAndLock()
144 recvMutex_.unlock(); in GetReceiveBufferAndLock()
152 recvMutex_.unlock(); in GetReceiveBufferAndLock()
173 recvMutex_.unlock(); in ReleaseReceiveBufferLock()
/ohos5.0/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dbuffer_object_unittest.cpp577 object.recvMutex_.lock();
579 EXPECT_EQ(object.recvMutex_.try_lock(), true);
580 object.recvMutex_.unlock();
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/include/
H A Dbuffer_object.h72 std::mutex recvMutex_; variable
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/
H A Dtmessenger.cpp282 std::unique_lock<std::mutex> lock(recvMutex_); in OnMessageRecv()
345 std::unique_lock<std::mutex> lock(recvMutex_); in WaitResponse()
H A Dtmessenger.h124 std::mutex recvMutex_; variable
/ohos5.0/foundation/multimedia/av_codec/services/engine/codec/video/fcodec/
H A Dfcodec.h173 std::mutex recvMutex_; variable
H A Dfcodec.cpp414 std::unique_lock<std::mutex> rLock(recvMutex_); in StopThread()
440 std::unique_lock<std::mutex> rLock(recvMutex_); in Stop()
469 std::unique_lock<std::mutex> rLock(recvMutex_); in Flush()
955 std::unique_lock<std::mutex> recvLock(recvMutex_); in SendFrame()
1117 std::unique_lock<std::mutex> recvLock(recvMutex_); in ReceiveFrame()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/tls_socket/include/
H A Dtls_socket.h659 std::mutex recvMutex_; variable
/ohos5.0/foundation/communication/netstack/frameworks/native/tls_socket/src/
H A Dtls_socket.cpp477 std::lock_guard<std::mutex> lock(recvMutex_); in ReadMessage()
822 std::lock_guard<std::mutex> lock(recvMutex_); in Close()