mirror of
https://github.com/kidfromjupiter/nearby.git
synced 2026-09-14 14:46:12 -04:00
Automated Code Change
PiperOrigin-RevId: 806200253
This commit is contained in:
@@ -48,7 +48,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());
|
||||
@@ -58,7 +58,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;
|
||||
@@ -67,7 +67,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) {
|
||||
|
||||
Reference in New Issue
Block a user