tyler
/
proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/client/http_client.rs: add flow control for h2 upload

This commit is contained in:
Dietmar Maurer 2019-05-14 14:54:21 +02:00
parent 97f22ce57d
commit e3dbd41b20
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/client.rs
View File

@ -3,6 +3,8 @@
//! This library implements the client side to access the backups //! This library implements the client side to access the backups
//! server using https. //! server using https.
mod pipe_to_stream;
mod http_client; mod http_client;
pub use http_client::*; pub use http_client::*;

8
src/client/http_client.rs
View File

@ -16,6 +16,7 @@ use serde_json::{json, Value};
use url::percent_encoding::{percent_encode, DEFAULT_ENCODE_SET}; use url::percent_encoding::{percent_encode, DEFAULT_ENCODE_SET};
use crate::tools::{self, BroadcastFuture, tty}; use crate::tools::{self, BroadcastFuture, tty};
use super::pipe_to_stream::*;
#[derive(Clone)] #[derive(Clone)]
struct AuthInfo { struct AuthInfo {
@ -414,13 +415,14 @@ impl H2Client {
.ready() .ready()
.map_err(Error::from) .map_err(Error::from)
.and_then(move |mut send_request| { .and_then(move |mut send_request| {
let (response, mut stream) = send_request.send_request(request, false).unwrap(); let (response, stream) = send_request.send_request(request, false).unwrap();
// fixme: implement flow control PipeToSendStream::new(bytes::Bytes::from(data), stream)
stream.send_data(bytes::Bytes::from(data), true); .and_then(|_| {
response response
.map_err(Error::from) .map_err(Error::from)
.and_then(Self::h2api_response) .and_then(Self::h2api_response)
}) })
})
} }
fn request( fn request(