server_node::server

Struct Server

source
pub struct Server {
    config: Arc<Config>,
    tx: Sender<Event>,
    thread_pool: ThreadPool,
    coordinator_id: Option<Id>,
    dhcp_service: Service,
    peers: HashMap<Id, Peer>,
    election_state: ElectionState,
    majority: bool,
}
Expand description

The distributed DHCP server

Fields§

§config: Arc<Config>§tx: Sender<Event>§thread_pool: ThreadPool§coordinator_id: Option<Id>§dhcp_service: Service§peers: HashMap<Id, Peer>§election_state: ElectionState§majority: bool

Implementations§

source§

impl Server

source

pub fn start( config: Config, peer_listener: TcpListener, client_listener: TcpListener, )

Start listening to incoming connections from server peers and DHCP clients.

source

fn run_event_loop(&mut self, server_rx: &Receiver<Event>)

source

fn attempt_connect(&mut self)

source

fn become_coordinator(&mut self)

source

fn answer_handshake(&mut self, stream: TcpStream)

source

fn add_peer(&mut self, peer_id: Id, peer: Peer) -> Result<(), ()>

source

fn remove_peer(&mut self, peer_id: Id)

source

fn start_election(&mut self)

Send Message::Election to all server peers with higher ids than this server.

This function starts a timer thread which sleeps until the bully algorithm timeout expires. The timer triggers a Event::ElectionTimeout to the the server thread.

source

fn finish_election(&mut self)

Inspect current server role. Become leader and send Message::Coordinator to all peers if no event has reset the server role back to ElectionState::Follower.

source

fn handle_lease_request( &mut self, mac_address: MacAddr, tx: &Sender<LeaseOffer>, )

source

fn handle_confirm_request( &mut self, mac_address: MacAddr, ip: Ipv4Addr, tx: &Sender<bool>, )

source

fn handle_peer_message(&mut self, sender_id: Id, message: Message)

source

fn handle_election(&mut self, sender_id: Id)

source

fn handle_okay(&mut self, sender_id: Id)

source

fn handle_coordinator(&mut self, sender_id: Id, majority: bool)

source

fn handle_add_lease(&mut self, lease: Lease)

source

fn handle_set_pool(&mut self, pool: Ipv4Range)

source

fn handle_majority(&mut self, majority: bool)

Trait Implementations§

source§

impl Display for Server

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl Freeze for Server

§

impl !RefUnwindSafe for Server

§

impl Send for Server

§

impl Sync for Server

§

impl Unpin for Server

§

impl !UnwindSafe for Server

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToString for T
where T: Display + ?Sized,

source§

default fn to_string(&self) -> String

Converts the given value to a String. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.