|
45 | 45 | #include "sector_storage/fetch_handler.hpp"
|
46 | 46 | #include "sector_storage/impl/manager_impl.hpp"
|
47 | 47 | #include "sector_storage/impl/scheduler_impl.hpp"
|
48 |
| -#include "sector_storage/impl/worker_estimator_impl.hpp" |
49 | 48 | #include "sector_storage/stores/impl/index_impl.hpp"
|
50 | 49 | #include "sector_storage/stores/impl/local_store.hpp"
|
51 | 50 | #include "sector_storage/stores/impl/remote_store.hpp"
|
@@ -96,7 +95,6 @@ namespace fc {
|
96 | 95 | boost::optional<RegisteredSealProof> seal_type;
|
97 | 96 | std::vector<Address> precommit_control;
|
98 | 97 | int api_port{};
|
99 |
| - uint64_t estimator_window{}; |
100 | 98 |
|
101 | 99 | /** Path to presealed sectors */
|
102 | 100 | boost::optional<boost::filesystem::path> preseal_path;
|
@@ -158,8 +156,6 @@ namespace fc {
|
158 | 156 | option("owner", po::value(&config.owner));
|
159 | 157 | option("worker", po::value(&config.worker));
|
160 | 158 | option("sector-size", po::value(&raw.sector_size));
|
161 |
| - option("estimator-window", |
162 |
| - po::value(&config.estimator_window)->default_value(10)); |
163 | 159 | option("precommit-control", po::value(&config.precommit_control));
|
164 | 160 | option("pre-sealed-sectors",
|
165 | 161 | po::value(&config.preseal_path),
|
@@ -428,12 +424,10 @@ namespace fc {
|
428 | 424 | local_store, std::move(auth_headers))};
|
429 | 425 |
|
430 | 426 | IoThread io_thread2;
|
| 427 | + // TODO(ortoymka): Use scheduler with estimator, when it will done |
431 | 428 | OUTCOME_TRY(wscheduler,
|
432 | 429 | sector_storage::SchedulerImpl::newScheduler(
|
433 |
| - io_thread2.io, |
434 |
| - prefixed("scheduler_works/"), |
435 |
| - std::make_shared<sector_storage::EstimatorImpl>( |
436 |
| - config.estimator_window))); |
| 430 | + io_thread2.io, prefixed("scheduler_works/"))); |
437 | 431 |
|
438 | 432 | IoThread io_thread3;
|
439 | 433 |
|
|
0 commit comments