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

Automated Code Change

Browse Source 
PiperOrigin-RevId: 793110622
This commit is contained in:
hai007
2025-08-09 16:13:50 -07:00
committed by Copybara-Service
parent ff6e506c0e
commit dcfb83f68b
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/weave/sockets/client_socket_test.cc
+3 -3
View File
@@ -60,7 +60,7 @@ class FakeConnection : public Connection {
int GetMaxPacketSize() const override { return max_packet_size_; }
void Transmit(std::string packet) override {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
packets_written_.push_back(packet);
if (instant_transmit_) {
callback_.on_transmit_cb(absl::OkStatus());
@@ -71,7 +71,7 @@ class FakeConnection : public Connection {
bool IsOpen() { return open_; }
std::string PollWrittenPacket() {
if (!NoMorePackets()) {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
auto front = packets_written_.front();
packets_written_.erase(packets_written_.begin());
return front;
@@ -80,7 +80,7 @@ class FakeConnection : public Connection {
return "";
}
bool NoMorePackets() {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
return packets_written_.empty();
}
void SetInstantTransmit(bool instant_transmit) {
internal/weave/sockets/server_socket_test.cc
+3 -3
View File
@@ -53,7 +53,7 @@ class FakeConnection : public Connection {
int GetMaxPacketSize() const override { return max_packet_size_; }
void Transmit(std::string packet) override {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
packets_written_.push_back(packet);
if (instant_transmit_) {
callback_.on_transmit_cb(absl::OkStatus());
@@ -65,7 +65,7 @@ class FakeConnection : public Connection {
std::string PollWrittenPacket() {
absl::SleepFor(absl::Milliseconds(10));
if (!NoMorePackets()) {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
auto front = packets_written_.front();
packets_written_.erase(packets_written_.begin());
return front;
@@ -74,7 +74,7 @@ class FakeConnection : public Connection {
return "";
}
bool NoMorePackets() {
absl::MutexLock lock(&mutex_);
absl::MutexLock lock(mutex_);
return packets_written_.empty();
}
void SetInstantTransmit(bool instant_transmit) {