uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2024-11-30 01:44:58 +03:00
Code Issues Packages Projects Releases Wiki Activity

factor out send_and_await_response()

Browse Source
This commit is contained in:
hosted-fornet 2023-10-02 22:59:45 -07:00
parent 1cc5287234
commit 08f53a6473
1 changed files with 28 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
src/kernel/mod.rs
View File

@ -484,25 +484,34 @@ impl UqProcessImports for ProcessWasi {
request: wit::Request,
payload: Option<wit::Payload>,
) -> Result<Result<(wit::Address, wit::Message), wit::SendError>> {
if request.expects_response.is_none() {
return Err(anyhow::anyhow!("kernel: got invalid send_and_await_response() Request from {:?}: must expect response", self.process.metadata.our.process));
}
let id = self
.process
.handle_request(target, request, None, payload)
.await;
match id {
Ok(id) => match self.process.get_specific_message_for_process(id).await {
Ok((address, wit::Message::Response(response))) => {
Ok(Ok((address, wit::Message::Response(response))))
}
Ok((_address, wit::Message::Request(_))) => Err(anyhow::anyhow!(
"fatal: received Request instead of Response"
)),
Err((net_err, _context)) => Ok(Err(net_err)),
},
Err(e) => Err(e),
}
send_and_await_response(self, target, request, payload).await
}
}
async fn send_and_await_response(
process: &mut ProcessWasi,
target: wit::Address,
request: wit::Request,
payload: Option<wit::Payload>,
) -> Result<Result<(wit::Address, wit::Message), wit::SendError>> {
if request.expects_response.is_none() {
return Err(anyhow::anyhow!("kernel: got invalid send_and_await_response() Request from {:?}: must expect response", process.process.metadata.our.process));
}
let id = process
.process
.handle_request(target, request, None, payload)
.await;
match id {
Ok(id) => match process.process.get_specific_message_for_process(id).await {
Ok((address, wit::Message::Response(response))) => {
Ok(Ok((address, wit::Message::Response(response))))
}
Ok((_address, wit::Message::Request(_))) => Err(anyhow::anyhow!(
"fatal: received Request instead of Response"
)),
Err((net_err, _context)) => Ok(Err(net_err)),
},
Err(e) => Err(e),
}
}