@@ -226,11 +226,9 @@ class DataQueueImpl final : public DataQueue,
226226 };
227227
228228 void
229- reader_destructed (NotifyReader* reader) {
230- readers_.erase (reader);
231- }
229+ reader_destructed (NotifyReader* reader) { readers_.erase (reader); }
232230
233- void SetEnvironment (Environment* env) override { env_ = env;}
231+ void SetEnvironment (Environment* env) override { env_ = env; }
234232
235233 std::shared_ptr<Reader> get_reader () override ;
236234 SET_MEMORY_INFO_NAME (DataQueue)
@@ -1198,8 +1196,7 @@ class FdEntry final : public EntryImpl {
11981196// ============================================================================
11991197
12001198std::shared_ptr<DataQueue> DataQueue::CreateIdempotent (
1201- Environment * env,
1202- std::vector<std::unique_ptr<Entry>> list) {
1199+ Environment * env, std::vector<std::unique_ptr<Entry>> list) {
12031200 // Any entry is invalid for an idempotent DataQueue if any of the entries
12041201 // are nullptr or is not idempotent.
12051202 uint64_t size = 0 ;
@@ -1258,7 +1255,7 @@ DataQueue::CreateInMemoryEntryFromBackingStore(
12581255 if (offset + length > store->ByteLength ()) {
12591256 return nullptr ;
12601257 }
1261- return std::make_unique<InMemoryEntry>(std::move (store), offset, length);
1258+ return std::make_unique<InMemoryEntry>(std::move (store), offset, length);
12621259}
12631260
12641261std::unique_ptr<DataQueue::Entry> DataQueue::CreateDataQueueEntry (
@@ -1289,7 +1286,6 @@ void DataQueueFeeder::setDataQueue(std::shared_ptr<DataQueue> queue) {
12891286 queue->SetEnvironment (env ());
12901287 dataQueue_ = queue;
12911288
1292-
12931289 // Allows us to be notified when data is actually read from the
12941290 // queue so that we can limit the data hold in DataQueueFeeder
12951291 dataQueue_->addBackpressureListener (this );
0 commit comments