Fix tsan issue.

PiperOrigin-RevId: 663399817
This commit is contained in:
Francis Tsui
2024-08-15 12:17:01 -07:00
committed by Copybara-Service
parent f0115df88b
commit f73a9120a8
+10
View File
@@ -86,6 +86,16 @@ void FakeNearbyConnection::SetDisconnectionListener(
void FakeNearbyConnection::AppendReadableData(std::vector<uint8_t> bytes) {
NL_DCHECK(!closed_);
if (task_runner_) {
task_runner_->PostTask([this, bytes = std::move(bytes)]() {
{
absl::MutexLock lock(&read_mutex_);
read_data_.push(std::move(bytes));
}
MaybeRunCallback();
});
return;
}
{
absl::MutexLock lock(&read_mutex_);
read_data_.push(std::move(bytes));