diff options
| author | Yehuda Sadeh <yehuda@redhat.com> | 2017-09-04 14:15:11 +0200 |
|---|---|---|
| committer | Yehuda Sadeh <yehuda@redhat.com> | 2018-04-10 17:05:38 +0200 |
| commit | bd0ca81cdec8c648a3ebfac949ccbbd623ff3589 (patch) | |
| tree | 21efa1aa7e352e1268f73941e1d20d2739e5babe /src/rgw/rgw_rest_client.h | |
| parent | rgw: amend http client manager interface (diff) | |
| download | ceph-bd0ca81cdec8c648a3ebfac949ccbbd623ff3589.tar.xz ceph-bd0ca81cdec8c648a3ebfac949ccbbd623ff3589.zip | |
rgw: initial work for integrating streaming read/write with cr
Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
Diffstat (limited to 'src/rgw/rgw_rest_client.h')
| -rw-r--r-- | src/rgw/rgw_rest_client.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rgw/rgw_rest_client.h b/src/rgw/rgw_rest_client.h index 51a7ec4310b..990ca976912 100644 --- a/src/rgw/rgw_rest_client.h +++ b/src/rgw/rgw_rest_client.h @@ -70,7 +70,7 @@ public: class RGWHTTPStreamRWRequest : public RGWHTTPSimpleRequest { Mutex lock; Mutex write_lock; - RGWGetDataCB *cb; + RGWGetDataCB *cb{nullptr}; bufferlist outbl; bufferlist in_data; size_t chunk_ofs{0}; @@ -85,6 +85,10 @@ public: int send_data(void *ptr, size_t len, bool *pause) override; int receive_data(void *ptr, size_t len) override; + RGWHTTPStreamRWRequest(CephContext *_cct, const string& _method, const string& _url, + param_vec_t *_headers, param_vec_t *_params) : RGWHTTPSimpleRequest(_cct, _method, _url, _headers, _params), + lock("RGWHTTPStreamRWRequest"), write_lock("RGWHTTPStreamRWRequest::write_lock") { + } RGWHTTPStreamRWRequest(CephContext *_cct, const string& _method, const string& _url, RGWGetDataCB *_cb, param_vec_t *_headers, param_vec_t *_params) : RGWHTTPSimpleRequest(_cct, _method, _url, _headers, _params), lock("RGWHTTPStreamRWRequest"), write_lock("RGWHTTPStreamRWRequest::write_lock"), cb(_cb) { |