TySS-Dev/nearby
1
0
Fork 0
mirror of https://github.com/kidfromjupiter/nearby.git synced 2026-09-16 15:36:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

Automated Code Change

Browse Source 
PiperOrigin-RevId: 795390731
This commit is contained in:
hai007
2025-08-15 01:51:15 -07:00
committed by Copybara-Service
parent cff660eacf
commit 18d2a065bf
2 changed files with 21 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sharing/fake_nearby_connections_manager.cc
+15 -15
View File
@@ -57,7 +57,7 @@ void FakeNearbyConnectionsManager::StartAdvertising(
DCHECK(!IsAdvertising());
is_shutdown_ = false;
{
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
advertising_listener_ = listener;
}
advertising_data_usage_ = data_usage;
@@ -76,7 +76,7 @@ void FakeNearbyConnectionsManager::StopAdvertising(
DCHECK(IsAdvertising());
DCHECK(!is_shutdown());
{
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
advertising_listener_ = nullptr;
}
advertising_data_usage_ = DataUsage::UNKNOWN_DATA_USAGE;
@@ -95,7 +95,7 @@ void FakeNearbyConnectionsManager::StartDiscovery(
std::optional<uint16_t> alternate_service_uuid,
ConnectionsCallback callback) {
is_shutdown_ = false;
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
discovery_listener_ = listener;
std::move(callback)(Status::kSuccess);
}
@@ -103,7 +103,7 @@ void FakeNearbyConnectionsManager::StartDiscovery(
void FakeNearbyConnectionsManager::StopDiscovery() {
DCHECK(IsDiscovering());
DCHECK(!is_shutdown());
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
discovery_listener_ = nullptr;
}
@@ -116,7 +116,7 @@ void FakeNearbyConnectionsManager::Connect(
connected_data_usage_ = data_usage;
transport_type_ = transport_type;
{
absl::MutexLock lock(&endpoints_mutex_);
absl::MutexLock lock(endpoints_mutex_);
connection_endpoint_infos_.emplace(endpoint_id, std::move(endpoint_info));
}
std::move(callback)(endpoint_id, connection_, Status::kUnknown);
@@ -125,13 +125,13 @@ void FakeNearbyConnectionsManager::Connect(
void FakeNearbyConnectionsManager::AcceptConnection(
std::vector<uint8_t> endpoint_info, absl::string_view endpoint_id,
NearbyConnection* connection) {
absl::MutexLock lock(&endpoints_mutex_);
absl::MutexLock lock(endpoints_mutex_);
connection_endpoint_infos_.emplace(endpoint_id, std::move(endpoint_info));
}
void FakeNearbyConnectionsManager::Disconnect(absl::string_view endpoint_id) {
DCHECK(!is_shutdown());
absl::MutexLock lock(&endpoints_mutex_);
absl::MutexLock lock(endpoints_mutex_);
connection_endpoint_infos_.erase(std::string(endpoint_id));
}
@@ -153,7 +153,7 @@ void FakeNearbyConnectionsManager::RegisterPayloadStatusListener(
const Payload* FakeNearbyConnectionsManager::GetIncomingPayload(
int64_t payload_id) const {
DCHECK(!is_shutdown());
absl::MutexLock lock(&incoming_payloads_mutex_);
absl::MutexLock lock(incoming_payloads_mutex_);
auto it = incoming_payloads_.find(payload_id);
if (it == incoming_payloads_.end()) return nullptr;
@@ -178,7 +178,7 @@ void FakeNearbyConnectionsManager::Cancel(int64_t payload_id) {
}
void FakeNearbyConnectionsManager::ClearIncomingPayloads() {
absl::MutexLock lock(&incoming_payloads_mutex_);
absl::MutexLock lock(incoming_payloads_mutex_);
incoming_payloads_.clear();
payload_status_listeners_.clear();
}
@@ -209,7 +209,7 @@ void FakeNearbyConnectionsManager::OnEndpointFound(
std::unique_ptr<DiscoveredEndpointInfo> info) {
DiscoveryListener* listener = nullptr;
{
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
listener = discovery_listener_;
}
if (listener == nullptr) return;
@@ -220,7 +220,7 @@ void FakeNearbyConnectionsManager::OnEndpointLost(
absl::string_view endpoint_id) {
DiscoveryListener* listener = nullptr;
{
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
listener = discovery_listener_;
}
if (listener == nullptr) return;
@@ -228,12 +228,12 @@ void FakeNearbyConnectionsManager::OnEndpointLost(
}
bool FakeNearbyConnectionsManager::IsAdvertising() const {
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
return advertising_listener_ != nullptr;
}
bool FakeNearbyConnectionsManager::IsDiscovering() const {
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
return discovery_listener_ != nullptr;
}
@@ -254,7 +254,7 @@ FakeNearbyConnectionsManager::GetRegisteredPayloadStatusListener(
void FakeNearbyConnectionsManager::SetIncomingPayload(
int64_t payload_id, std::unique_ptr<Payload> payload) {
absl::MutexLock lock(&incoming_payloads_mutex_);
absl::MutexLock lock(incoming_payloads_mutex_);
incoming_payloads_[payload_id] = std::move(payload);
}
@@ -264,7 +264,7 @@ bool FakeNearbyConnectionsManager::WasPayloadCanceled(
}
void FakeNearbyConnectionsManager::CleanupForProcessStopped() {
absl::MutexLock lock(&listener_mutex_);
absl::MutexLock lock(listener_mutex_);
advertising_listener_ = nullptr;
advertising_data_usage_ = DataUsage::UNKNOWN_DATA_USAGE;
advertising_power_level_ = PowerLevel::kUnknown;
sharing/incoming_frames_reader.cc
+6 -6
View File
@@ -83,7 +83,7 @@ void IncomingFramesReader::ProcessReadRequest(
absl::Duration timeout) {
std::unique_ptr<V1Frame> cached_frame;
{
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
if (!read_frame_info_queue_.empty()) {
// There are already outstanding read requests, just queue this up.
ReadFrameInfo read_fame_info{frame_type, std::move(callback), timeout};
@@ -100,7 +100,7 @@ void IncomingFramesReader::ProcessReadRequest(
}
{
// No matching cached frame, queue this request, then read more frames.
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
ReadFrameInfo read_frame_info{frame_type, std::move(callback), timeout};
read_frame_info_queue_.push(std::move(read_frame_info));
@@ -156,7 +156,7 @@ void IncomingFramesReader::OnDataReadFromConnection(
FrameType frame_type = frame->type();
bool cached_frame = false;
{
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
if (read_frame_info_queue_.empty()) {
return;
}
@@ -180,7 +180,7 @@ void IncomingFramesReader::OnDataReadFromConnection(
void IncomingFramesReader::CloseAllPendingReads() {
std::queue<ReadFrameInfo> queue;
{
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
queue.swap(read_frame_info_queue_);
}
while (!queue.empty()) {
@@ -193,7 +193,7 @@ void IncomingFramesReader::CloseAllPendingReads() {
void IncomingFramesReader::Done(std::unique_ptr<V1Frame> frame) {
ReadFrameInfo read_frame_info;
{
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
timeout_timer_.reset();
read_frame_info = std::move(read_frame_info_queue_.front());
read_frame_info_queue_.pop();
@@ -201,7 +201,7 @@ void IncomingFramesReader::Done(std::unique_ptr<V1Frame> frame) {
read_frame_info.callback(*frame);
{
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
if (read_frame_info_queue_.empty()) {
return;
}