mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 10:25:47 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

chore: update helio dependency (#1047)

Browse source 
Remove SocketSource because now FiberSocketBase implements the Source interface.

Signed-off-by: Roman Gershman <roman@dragonflydb.io>
This commit is contained in:
Roman Gershman 2023-04-07 14:32:32 +03:00 • committed by GitHub
parent 78d4aacd25
commit 64aacfa93e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
helio

@ -1 +1 @@
Subproject commit 154f9333637b956974d2f8835a086d9fb716e24d
Subproject commit 7927a743f3452c0fa645a1567c3d4202fd4ab9ef

9
src/server/replica.cc
View file

@ -454,8 +454,7 @@ error_code Replica::InitiatePSync() {
// Start full sync
state_mask_ |= R_SYNCING;
SocketSource ss{sock_.get()};
io::PrefixSource ps{io_buf.InputBuffer(), &ss};
io::PrefixSource ps{io_buf.InputBuffer(), sock_.get()};
// Set LOADING state.
CHECK(service_.SwitchState(GlobalState::ACTIVE, GlobalState::LOADING) == GlobalState::LOADING);
@ -806,8 +805,7 @@ error_code Replica::StartStableSyncFlow(Context* cntx) {
void Replica::FullSyncDflyFb(string eof_token, BlockingCounter bc, Context* cntx) {
DCHECK(leftover_buf_);
SocketSource ss{sock_.get()};
io::PrefixSource ps{leftover_buf_->InputBuffer(), &ss};
io::PrefixSource ps{leftover_buf_->InputBuffer(), sock_.get()};
RdbLoader loader(&service_);
loader.SetFullSyncCutCb([bc, ran = false]() mutable {
@ -857,8 +855,7 @@ void Replica::StableSyncDflyReadFb(Context* cntx) {
prefix = leftover_buf_->InputBuffer();
}
SocketSource ss{sock_.get()};
io::PrefixSource ps{prefix, &ss};
io::PrefixSource ps{prefix, sock_.get()};
JournalReader reader{&ps, 0};
TransactionReader tx_reader{};