Browse Source

fix actix-pg bench (#5350)

Nikolay Kim 5 years ago
parent
commit
c07009cd17
1 changed files with 5 additions and 3 deletions
  1. 5 3
      frameworks/Rust/actix/src/main_pg.rs

+ 5 - 3
frameworks/Rust/actix/src/main_pg.rs

@@ -117,16 +117,18 @@ async fn main() -> std::io::Result<()> {
     const DB_URL: &str =
     const DB_URL: &str =
         "postgres://benchmarkdbuser:benchmarkdbpass@tfb-database/hello_world";
         "postgres://benchmarkdbuser:benchmarkdbpass@tfb-database/hello_world";
 
 
+    let addr = PgConnection::connect(DB_URL).await?;
+
     // start http server
     // start http server
     Server::build()
     Server::build()
         .backlog(1024)
         .backlog(1024)
-        .workers(1)
-        .bind("techempower", "0.0.0.0:8080", || {
+        .bind("techempower", "0.0.0.0:8080", move || {
+            let addr = addr.clone();
             HttpService::build()
             HttpService::build()
                 .keep_alive(KeepAlive::Os)
                 .keep_alive(KeepAlive::Os)
                 .h1(map_config(
                 .h1(map_config(
                     App::new()
                     App::new()
-                        .data_factory(|| PgConnection::connect(DB_URL))
+                        .data(addr)
                         .service(web::resource("/db").to(world_row))
                         .service(web::resource("/db").to(world_row))
                         .service(web::resource("/queries").to(queries))
                         .service(web::resource("/queries").to(queries))
                         .service(web::resource("/fortune").to(fortune))
                         .service(web::resource("/fortune").to(fortune))