Remove "using ChainId".
This commit is contained in:
parent
8b92e8f978
commit
1ad5658aee
@ -250,7 +250,7 @@ void SequenceDispatcher::close_silent() {
|
|||||||
void MultiSequenceDispatcherOld::send(NetQueryPtr query) {
|
void MultiSequenceDispatcherOld::send(NetQueryPtr query) {
|
||||||
auto callback = query->move_callback();
|
auto callback = query->move_callback();
|
||||||
CHECK(!callback.empty());
|
CHECK(!callback.empty());
|
||||||
Span<ChainId> chains = query->chains();
|
auto chains = query->chains();
|
||||||
query->set_in_sequence_dispatcher(true);
|
query->set_in_sequence_dispatcher(true);
|
||||||
CHECK(all_of(chains, [](auto chain_id) { return chain_id != 0; }));
|
CHECK(all_of(chains, [](auto chain_id) { return chain_id != 0; }));
|
||||||
CHECK(!chains.empty());
|
CHECK(!chains.empty());
|
||||||
@ -287,7 +287,7 @@ class MultiSequenceDispatcherImpl final : public MultiSequenceDispatcher {
|
|||||||
void send(NetQueryPtr query) final {
|
void send(NetQueryPtr query) final {
|
||||||
auto callback = query->move_callback();
|
auto callback = query->move_callback();
|
||||||
CHECK(!callback.empty());
|
CHECK(!callback.empty());
|
||||||
Span<ChainId> chains = query->chains();
|
auto chains = query->chains();
|
||||||
query->set_in_sequence_dispatcher(true);
|
query->set_in_sequence_dispatcher(true);
|
||||||
CHECK(all_of(chains, [](auto chain_id) { return chain_id != 0; }));
|
CHECK(all_of(chains, [](auto chain_id) { return chain_id != 0; }));
|
||||||
Node node;
|
Node node;
|
||||||
@ -311,8 +311,8 @@ class MultiSequenceDispatcherImpl final : public MultiSequenceDispatcher {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
ChainScheduler<Node> scheduler_;
|
ChainScheduler<Node> scheduler_;
|
||||||
|
|
||||||
using TaskId = ChainScheduler<NetQueryPtr>::TaskId;
|
using TaskId = ChainScheduler<NetQueryPtr>::TaskId;
|
||||||
using ChainId = ChainScheduler<NetQueryPtr>::ChainId;
|
|
||||||
|
|
||||||
bool check_timeout(TaskId task_id) {
|
bool check_timeout(TaskId task_id) {
|
||||||
auto &node = *scheduler_.get_task_extra(task_id);
|
auto &node = *scheduler_.get_task_extra(task_id);
|
||||||
|
@ -92,8 +92,6 @@ class MultiSequenceDispatcherOld final : public SequenceDispatcher::Parent {
|
|||||||
void ready_to_close() final;
|
void ready_to_close() final;
|
||||||
};
|
};
|
||||||
|
|
||||||
using ChainId = uint64;
|
|
||||||
using ChainIds = vector<ChainId>;
|
|
||||||
class MultiSequenceDispatcher : public NetQueryCallback {
|
class MultiSequenceDispatcher : public NetQueryCallback {
|
||||||
public:
|
public:
|
||||||
virtual void send(NetQueryPtr query) = 0;
|
virtual void send(NetQueryPtr query) = 0;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user