uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2025-01-02 21:55:41 +03:00
Code Issues Packages Projects Releases Wiki Activity

Format Rust code using rustfmt

Browse Source
This commit is contained in:
github-actions[bot] 2024-09-26 19:18:14 +00:00 committed by GitHub
parent c3e01d2800
commit bfaf63120f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
kinode/src/fd_manager.rs
View File

@ -1,6 +1,6 @@
use lib::types::core::{
Address, FdManagerError, FdManagerRequest, KernelMessage, Message, MessageReceiver, MessageSender,
PrintSender, Printout, ProcessId, Request, FD_MANAGER_PROCESS_ID,
Address, FdManagerError, FdManagerRequest, KernelMessage, Message, MessageReceiver,
MessageSender, PrintSender, Printout, ProcessId, Request, FD_MANAGER_PROCESS_ID,
};
use std::{collections::HashMap, sync::Arc};
@ -203,7 +203,11 @@ fn get_max_fd_limit() -> anyhow::Result<u64> {
}
}
pub async fn send_fd_manager_open(our: &Address, number_opened: u64, send_to_loop: &MessageSender) -> anyhow::Result<()> {
pub async fn send_fd_manager_open(
our: &Address,
number_opened: u64,
send_to_loop: &MessageSender,
) -> anyhow::Result<()> {
let message = Message::Request(Request {
inherit: false,
expects_response: None,
@ -215,7 +219,11 @@ pub async fn send_fd_manager_open(our: &Address, number_opened: u64, send_to_loo
Ok(())
}
pub async fn send_fd_manager_close(our: &Address, number_closed: u64, send_to_loop: &MessageSender) -> anyhow::Result<()> {
pub async fn send_fd_manager_close(
our: &Address,
number_closed: u64,
send_to_loop: &MessageSender,
) -> anyhow::Result<()> {
let message = Message::Request(Request {
inherit: false,
expects_response: None,
@ -227,7 +235,11 @@ pub async fn send_fd_manager_close(our: &Address, number_closed: u64, send_to_lo
Ok(())
}
async fn send_to_fd_manager(our: &Address, message: Message, send_to_loop: &MessageSender) -> anyhow::Result<()> {
async fn send_to_fd_manager(
our: &Address,
message: Message,
send_to_loop: &MessageSender,
) -> anyhow::Result<()> {
KernelMessage::builder()
.id(rand::random())
.source(our.clone())