pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-12 08:51:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add logging for worker spawn failures (#3827)

Browse Source
This commit is contained in:
Sergei Shulepov
2021-09-10 15:40:53 +02:00
committed by GitHub
parent 6a383ff875
commit 3693eb8744
1 changed files with 28 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/core/pvf/src/worker_common.rs
+28 -4
View File
@@ -47,14 +47,38 @@ pub async fn spawn_with_program_path(
with_transient_socket_path(debug_id, |socket_path| {
let socket_path = socket_path.to_owned();
async move {
let listener = UnixListener::bind(&socket_path).await.map_err(|_| SpawnErr::Bind)?;
let listener = UnixListener::bind(&socket_path).await.map_err(|err| {
tracing::warn!(
target: LOG_TARGET,
%debug_id,
"cannot bind unix socket: {:?}",
err,
);
SpawnErr::Bind
})?;
let handle = WorkerHandle::spawn(program_path, extra_args, socket_path)
.map_err(|_| SpawnErr::ProcessSpawn)?;
let handle =
WorkerHandle::spawn(program_path, extra_args, socket_path).map_err(|err| {
tracing::warn!(
target: LOG_TARGET,
%debug_id,
"cannot spawn a worker: {:?}",
err,
);
SpawnErr::ProcessSpawn
})?;
futures::select! {
accept_result = listener.accept().fuse() => {
let (stream, _) = accept_result.map_err(|_| SpawnErr::Accept)?;
let (stream, _) = accept_result.map_err(|err| {
tracing::warn!(
target: LOG_TARGET,
%debug_id,
"cannot accept a worker: {:?}",
err,
);
SpawnErr::Accept
})?;
Ok((IdleWorker { stream, pid: handle.id() }, handle))
}
_ = Delay::new(spawn_timeout).fuse() => {