Skip to content

Commit 6649700

Browse files
committed
quic: format-cpp
1 parent 9cf8533 commit 6649700

File tree

2 files changed

+11
-27
lines changed

2 files changed

+11
-27
lines changed

src/dataqueue/queue.cc

Lines changed: 7 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -481,10 +481,8 @@ class NonIdempotentDataQueueReader final
481481
waited_next_ = std::move(next);
482482
return bob::STATUS_WAIT;
483483
} else {
484-
std::move(next)(bob::Status::STATUS_BLOCK,
485-
nullptr,
486-
0,
487-
[](uint64_t) {});
484+
std::move(next)(
485+
bob::Status::STATUS_BLOCK, nullptr, 0, [](uint64_t) {});
488486
return bob::STATUS_BLOCK;
489487
}
490488
}
@@ -503,10 +501,8 @@ class NonIdempotentDataQueueReader final
503501
waited_next_ = std::move(next);
504502
return bob::STATUS_WAIT;
505503
} else {
506-
std::move(next)(bob::Status::STATUS_BLOCK,
507-
nullptr,
508-
0,
509-
[](uint64_t) {});
504+
std::move(next)(
505+
bob::Status::STATUS_BLOCK, nullptr, 0, [](uint64_t) {});
510506
return bob::STATUS_BLOCK;
511507
}
512508
}
@@ -559,17 +555,12 @@ class NonIdempotentDataQueueReader final
559555
} else {
560556
if (!(options & bob::OPTIONS_SYNC)) {
561557
assert(!waited_next_);
562-
next(bob::Status::STATUS_WAIT,
563-
nullptr,
564-
0,
565-
[](uint64_t) {});
558+
next(bob::Status::STATUS_WAIT, nullptr, 0, [](uint64_t) {});
566559
waited_next_ = std::move(next);
567560
return;
568561
} else {
569-
std::move(next)(bob::Status::STATUS_BLOCK,
570-
nullptr,
571-
0,
572-
[](uint64_t) {});
562+
std::move(next)(
563+
bob::Status::STATUS_BLOCK, nullptr, 0, [](uint64_t) {});
573564
return;
574565
}
575566
}

src/node_blob.cc

Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -378,10 +378,7 @@ void Blob::Reader::Pull(const FunctionCallbackInfo<Value>& args) {
378378
}
379379

380380
if (count > 0) {
381-
impl->vecs.insert(
382-
impl->vecs.end(),
383-
vecs,
384-
vecs + count);
381+
impl->vecs.insert(impl->vecs.end(), vecs, vecs + count);
385382
impl->dones.push_back(std::move(doneCb));
386383
}
387384
if (impl->innext) {
@@ -403,10 +400,8 @@ void Blob::Reader::Pull(const FunctionCallbackInfo<Value>& args) {
403400
impl->dones.push_back(std::move(doneCb));
404401
}
405402
};
406-
status = impl->reader->inner_->Pull(std::move(snext),
407-
node::bob::OPTIONS_SYNC,
408-
nullptr,
409-
0);
403+
status = impl->reader->inner_->Pull(
404+
std::move(snext), node::bob::OPTIONS_SYNC, nullptr, 0);
410405
}
411406
}
412407
// otherwise we commit and call
@@ -429,9 +424,7 @@ void Blob::Reader::Pull(const FunctionCallbackInfo<Value>& args) {
429424
// Since we copied the data buffers, signal that we're done with them.
430425
std::for_each(impl->dones.begin(),
431426
impl->dones.end(),
432-
[](bob::Done& done) {
433-
std::move(done)(0);
434-
});
427+
[](bob::Done& done) { std::move(done)(0); });
435428
Local<Value> argv[2] = {Uint32::New(env->isolate(), bob::STATUS_CONTINUE),
436429
ArrayBuffer::New(env->isolate(), store)};
437430
impl->reader->MakeCallback(fn, arraysize(argv), argv);

0 commit comments

Comments
 (0)