Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
38 commits
Select commit Hold shift + click to select a range
b79017a
Interleave writing and read data from storages
Sep 10, 2025
28c2ce6
Made it simpler
Sep 10, 2025
8c6bc25
nit
Sep 10, 2025
cfabdcd
fix wrong loop
Sep 11, 2025
aca79d6
nit
Sep 11, 2025
a38e43a
Merge remote-tracking branch 'origin/master' into interleaving-rw
Sep 11, 2025
6b100be
Use custom awaitable_operators
Sep 16, 2025
906d4a2
Added context propagation
Sep 16, 2025
4bcc659
Test double_buffered_writer_body
Sep 18, 2025
29e97eb
Optimized buffer size of cache's writer body
Sep 18, 2025
b9358d9
Test relay
Sep 18, 2025
a15339d
Test relay using coroutine
Sep 18, 2025
2fab9bf
Wrap ignoring need_buffer
Sep 18, 2025
fa0800f
Use async_stream instead sync
Sep 18, 2025
e7b47eb
Refactored for pipelining
Sep 18, 2025
893e865
Pipelining done
Sep 18, 2025
30e4ed2
Refactor relay function: take `relay header` out
Sep 18, 2025
b01913d
nit
Sep 18, 2025
949e27a
Move relay implementation and double_buffer_body under proxy/cache
Sep 18, 2025
26f9c60
Refactor cache body and finish relaying interleaving
Sep 19, 2025
e4b0738
Save header length in object_handle
Sep 19, 2025
1676cad
Relaying response of first get request: done
Sep 19, 2025
0fc0174
[tmp] use group rather than &&
Sep 19, 2025
6784dd0
Revert "[tmp] use group rather than &&"
Sep 20, 2025
0777daa
Pipelining first get request, without copying buffers
Sep 22, 2025
2df5e94
Parse/serialize header on cache
Sep 22, 2025
0526987
Clean up namespace complication & remove TODOs
Sep 22, 2025
dc26b46
Merge remote-tracking branch 'origin/master' into interleaving-first-…
Sep 22, 2025
23671f8
Handle when needed bytes are alread read when reading header
Sep 23, 2025
559f007
Set maximum size for flat_buffer
Sep 23, 2025
9b0e344
Refactoring
Sep 23, 2025
75327c1
Pipelined async_write_header
Sep 23, 2025
7096c5c
Apply review
Sep 23, 2025
86a4df8
Handle when buffer is filled more than chunk_size
Sep 23, 2025
b7ee8c0
Fix compile error
Sep 23, 2025
82e8e76
Move precursor's position to the first
Sep 24, 2025
75edccb
Merge remote-tracking branch 'origin/master' into interleaving-first-…
Sep 24, 2025
8c000e4
Reorder template functions
Sep 24, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion src/common/etcd/impl/hostports_observer.h
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,6 @@ class hostports_observer : public subscriber_observer {
service_factory<service_interface> m_service_factory;
std::vector<std::reference_wrapper<service_observer<service_interface>>>
m_observers;
// TODO: Modify this to vector and get num_storages on the constructor
std::map<std::size_t, std::shared_ptr<service_interface>> m_clients;
std::atomic<std::size_t> m_client_count{0};
};
Expand Down
Loading
Loading