File tree 3 files changed +6
-5
lines changed
3 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -320,7 +320,7 @@ namespace kagome::parachain {
320
320
WasmCb cb) const {
321
321
CB_TRY (auto executor_params,
322
322
sessionParams (*parachain_api_, receipt.descriptor .relay_parent ));
323
- const auto & context_params = executor_params.context_params ;
323
+ const auto & context_params = executor_params.context_params ;
324
324
325
325
constexpr auto name = " validate_block" ;
326
326
CB_TRYV (pvf_pool_->precompile (code_hash, code_zstd, context_params));
@@ -354,7 +354,9 @@ namespace kagome::parachain {
354
354
}
355
355
cb (scale::decode<ValidationResult>(r.value ()));
356
356
},
357
- .timeout = executor_params.pvf_exec_timeout_backing_ms ,
357
+ .timeout =
358
+ std::chrono::milliseconds{
359
+ executor_params.pvf_exec_timeout_backing_ms },
358
360
});
359
361
}
360
362
Original file line number Diff line number Diff line change @@ -219,8 +219,7 @@ namespace kagome::parachain {
219
219
timeout->reset ();
220
220
};
221
221
*timeout = scheduler_->scheduleWithHandle (
222
- [cb]() mutable { cb (std::errc::timed_out); },
223
- std::chrono::milliseconds{job.timeout });
222
+ [cb]() mutable { cb (std::errc::timed_out); }, job.timeout );
224
223
worker.process ->writeScale (PvfWorkerInput{job.args },
225
224
[cb](outcome::result<void > r) mutable {
226
225
if (not r) {
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ namespace kagome::parachain {
46
46
PvfWorkerInputCodePath code_path;
47
47
Buffer args;
48
48
Cb cb;
49
- uint64_t timeout = 0 ;
49
+ std::chrono::milliseconds timeout{ 0 } ;
50
50
};
51
51
void execute (Job &&job);
52
52
You can’t perform that action at this time.
0 commit comments