Struct WorkerServer 

struct WorkerServer {
    incoming_work: Receiver<Message>,
    multi: Multi,
    handles: HashMap<usize, (Easy2Handle<Collector>, Sender<Result<Response<Vec<u8>>, Error>>)>,
    token: usize,
    timeout: HttpTimeout,
    stats: Arc<Stats>,
    low_speed_window_start: Instant,
    low_speed_window_initial: u64,
}

Manages the cURL Multi. Processes incoming work sent over the channel, and returns responses.

Fields

incoming_work: Receiver<Message>

Channel to receive new work

multi: Multi

curl multi interface

handles: HashMap<usize, (Easy2Handle<Collector>, Sender<Result<Response<Vec<u8>>, Error>>)>

Map of token to curl handle and response channel

token: usize

Next token to use

timeout: HttpTimeout

Global timeout configuration

stats: Arc<Stats>

Global transfer statistics

low_speed_window_start: Instant

Instant when the current low speed window started

low_speed_window_initial: u64

Amount of total bytes transferred when the current low speed window started

Implementations

impl WorkerServer

fn run( incoming_work: Receiver<Message>, multiplex: bool, timeout: HttpTimeout, stats: Arc<Stats>, )

fn fail_and_drain(&mut self, e: &Error)

fn process_response(easy: Easy2<Collector>) -> Response<Vec<u8>>

fn reset_low_speed_timeout(&mut self)

Marks the start of a new timeout window.

fn check_low_speed_timeout(&mut self) -> Option<Error>

Return an error if we’re at the end of a timeout window, we haven’t made enough progress.

fn worker_loop(&mut self)

fn enqueue_request(&mut self, message: Message)

Adds the request to the Multi, or send an error back through the channel.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 144 bytes