Function run_http_work

perro_source/api_modules/perro_networking/src/http.rs:435–485

(
    config: &HttpConfig,
    shared_agent: Option<&ureq::Agent>,
    work: HttpWork,
)

                .name(format!("perro-http-{worker_index}"))
                .spawn(move || http_worker(worker_config, worker_rx, worker_event_tx, worker_agent))
                .expect("failed to spawn HTTP worker");
        }
        drop(event_tx);

        Self {
            config,
            queue_config,
            next_id: 0,
            tx: work_tx,
            rx: event_rx,
            local_events: VecDeque::new(),
            rejected_requests: 0,
        }
    }

    pub fn request(&mut self, request: HttpRequest) -> HttpID {
        match self.try_request(request) {
            Ok(id) => id,
            Err(error) => {
                let id = error.id;
                self.local_events
                    .push_back(HttpEvent::Failed(error.into_http_error()));
                id
            }
        }
    }

    pub fn try_request(&mut self, request: HttpRequest) -> Result<HttpID, HttpSubmitError> {
        let id = self.next_http_id();
        let url = request.url.clone();
        if url.is_empty() {
            self.rejected_requests = self.rejected_requests.saturating_add(1);
            return Err(HttpSubmitError::new(
                id,
                url,
                HttpSubmitErrorKind::InvalidRequest,
                "empty url",
            ));
        }
        match self.tx.try_send(HttpWork { id, request }) {
            Ok(()) => Ok(id),
            Err(TrySendError::Full(work)) => {
                self.rejected_requests = self.rejected_requests.saturating_add(1);
                Err(HttpSubmitError::new(
                    id,
                    work.request.url,
                    HttpSubmitErrorKind::QueueFull,
                    "http request queue full",
                ))
            }
            Err(TrySendError::Disconnected(work)) => {
                self.rejected_requests = self.rejected_requests.saturating_add(1);
                Err(HttpSubmitError::new(
                    id,