mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-13 16:32:56 +00:00
a22be5af72
Migrates the remaining crates to edition 2024. We like to stay on the latest edition if possible. There is no functional changes, however some code changes had to be done to accommodate the edition's breaking changes. Like the previous migration PRs, this is comprised of three commits: * the first does the edition update and makes `cargo check`/`cargo clippy` pass. we had to update bindgen to make its output [satisfy the requirements of edition 2024](https://doc.rust-lang.org/edition-guide/rust-2024/unsafe-extern.html) * the second commit does a `cargo fmt` for the new style edition. * the third commit reorders imports as a one-off change. As before, it is entirely optional. Part of #10918
52 lines
1.2 KiB
Rust
52 lines
1.2 KiB
Rust
use std::sync::Arc;
|
|
|
|
use rand::Rng;
|
|
|
|
use super::chan::Chan;
|
|
use super::network::TCP;
|
|
use super::world::{Node, NodeId, World};
|
|
use crate::proto::NodeEvent;
|
|
|
|
/// Abstraction with all functions (aka syscalls) available to the node.
|
|
#[derive(Clone)]
|
|
pub struct NodeOs {
|
|
world: Arc<World>,
|
|
internal: Arc<Node>,
|
|
}
|
|
|
|
impl NodeOs {
|
|
pub fn new(world: Arc<World>, internal: Arc<Node>) -> NodeOs {
|
|
NodeOs { world, internal }
|
|
}
|
|
|
|
/// Get the node id.
|
|
pub fn id(&self) -> NodeId {
|
|
self.internal.id
|
|
}
|
|
|
|
/// Opens a bidirectional connection with the other node. Always successful.
|
|
pub fn open_tcp(&self, dst: NodeId) -> TCP {
|
|
self.world.open_tcp(dst)
|
|
}
|
|
|
|
/// Returns a channel to receive node events (socket Accept and internal messages).
|
|
pub fn node_events(&self) -> Chan<NodeEvent> {
|
|
self.internal.node_events()
|
|
}
|
|
|
|
/// Get current time.
|
|
pub fn now(&self) -> u64 {
|
|
self.world.now()
|
|
}
|
|
|
|
/// Generate a random number in range [0, max).
|
|
pub fn random(&self, max: u64) -> u64 {
|
|
self.internal.rng.lock().gen_range(0..max)
|
|
}
|
|
|
|
/// Append a new event to the world event log.
|
|
pub fn log_event(&self, data: String) {
|
|
self.internal.log_event(data)
|
|
}
|
|
}
|