Ошибка передачи изменяемой ссылки Arc на обработчик hyper service_fn - PullRequest
Новая
       101

Ошибка передачи изменяемой ссылки Arc на обработчик hyper service_fn

1 голос
/ 14 марта 2019

Я пробовал следующее

Соответствующие данные импорта и код 

use std::sync::{Arc, Mutex};
use std::thread;
use hyper::rt::{self, Future, Stream};
use hyper::service::service_fn;
use hyper::{Body, Request, Response, Server, StatusCode};

pub struct ChallengeState;
pub struct ChallengeResponse;

type BoxFut<'a> = Box<Future<Item = Response<Body>, Error = hyper::Error> + Send + 'a>;

fn handle_challengeproof<'a>(
    req: Request<Body>,
    challenge: &Arc<Mutex<ChallengeState>>,
) -> BoxFut<'a> {
    let resp = req.into_body().concat2().map(move |body| {
        let challenge_lock = challenge.lock().unwrap();
        Response::builder()
        .status(StatusCode::OK)
        .body(Body::from("test"))
        .unwrap()
    });
    Box::new(resp)
}

fn handle<'a>(
    req: Request<Body>,
    challenge: &Arc<Mutex<ChallengeState>>,
) -> BoxFut<'a> {
    handle_challengeproof(req, challenge)
}

pub fn run_listener(
    challenge: Arc<Mutex<ChallengeState>>,
) -> thread::JoinHandle<()> {
    let addr = ([127, 0, 0, 1], 9999).into();

    let listener_service = move || {
        let challenge = Arc::clone(&challenge);
        service_fn(move |req: Request<Body>| {
            handle(req, &challenge)
        })
    };

    let server = Server::bind(&addr)
        .serve(listener_service)
        .map_err(|_| () );

    thread::spawn(move || {
        rt::run(server);
    })
}

Я пытался избежать дополнительного клона Arc, передавая ссылку на метод handle, но, похоже, не могу обойти это. Избегая времени жизни на handle () получил другую ошибку в отношении фьючерсов, запрашивающих статическое время жизни.

Код обновлен только с соответствующими материалами @ https://play.rust -lang.org /? Version = stable & mode = debug & edition = 2018 & gist = 10ea31450e88a122455006760d7fcdd1

1 Ответ

0 голосов
/ 14 марта 2019

Смысл Arc в том, что он подсчитывает, сколько существует ссылок, что происходит при его клонировании.Передача ссылок на Arc побеждает точку.

Вместо передачи ссылок передайте сам Arc.Таким образом, подпись handle становится: 

fn handle<'a>(
    req: Request<Body>,
    challenge: Arc<Mutex<ChallengeState>>,
) -> BoxFut<'a>

Передача Arc по ссылкам из замыкания невозможна, потому что вы будете ссылаться на что-то, что сразу выходит из области видимости.Вместо этого переместите Arc в handle: 

let listener_service = move || {
    service_fn(move |req: Request<Body>| handle(req, challenge))
};
...