diff options
author | Jordi Llonch <llonchj@gmail.com> | 2013-07-15 07:26:58 +1000 |
---|---|---|
committer | Jordi Llonch <llonchj@gmail.com> | 2013-07-15 07:26:58 +1000 |
commit | 9ca4733d9073a26d48794be7d8cc3ab0391d7569 (patch) | |
tree | 16718435d15bd050ef3c982ef00dd182c0d51073 | |
parent | 8e83a3bea2fea4c2a1dcc4a4fd427542a1c6ae79 (diff) | |
download | ceph-9ca4733d9073a26d48794be7d8cc3ab0391d7569.tar.gz |
hypertable recent version prototyping includes bool verify in length and read functions
Signed-off-by: Jordi Llonch <llonchj@gmail.com>
-rw-r--r-- | src/client/hypertable/CephBroker.cc | 4 | ||||
-rw-r--r-- | src/client/hypertable/CephBroker.h | 5 |
2 files changed, 5 insertions, 4 deletions
diff --git a/src/client/hypertable/CephBroker.cc b/src/client/hypertable/CephBroker.cc index a6cf6da1daa..7008f30bb3c 100644 --- a/src/client/hypertable/CephBroker.cc +++ b/src/client/hypertable/CephBroker.cc @@ -308,7 +308,7 @@ void CephBroker::remove(ResponseCallback *cb, const char *fname) { cb->response_ok(); } -void CephBroker::length(ResponseCallbackLength *cb, const char *fname) { +void CephBroker::length(ResponseCallbackLength *cb, const char *fname, bool) { int r; struct stat statbuf; @@ -326,7 +326,7 @@ void CephBroker::length(ResponseCallbackLength *cb, const char *fname) { } void CephBroker::pread(ResponseCallbackRead *cb, uint32_t fd, uint64_t offset, - uint32_t amount) { + uint32_t amount, bool) { OpenFileDataCephPtr fdata; ssize_t nread; StaticBuffer buf(new uint8_t [amount], amount); diff --git a/src/client/hypertable/CephBroker.h b/src/client/hypertable/CephBroker.h index 6924103221c..542ff668f15 100644 --- a/src/client/hypertable/CephBroker.h +++ b/src/client/hypertable/CephBroker.h @@ -34,6 +34,7 @@ extern "C" { #include "DfsBroker/Lib/Broker.h" +#include <cephfs/libcephfs.h> namespace Hypertable { using namespace DfsBroker; @@ -80,9 +81,9 @@ namespace Hypertable { uint32_t amount, const void *data, bool sync); virtual void seek(ResponseCallback *cb, uint32_t fd, uint64_t offset); virtual void remove(ResponseCallback *cb, const char *fname); - virtual void length(ResponseCallbackLength *cb, const char *fname); + virtual void length(ResponseCallbackLength *cb, const char *fname, bool); virtual void pread(ResponseCallbackRead *cb, uint32_t fd, uint64_t offset, - uint32_t amount); + uint32_t amount, bool); virtual void mkdirs(ResponseCallback *cb, const char *dname); virtual void rmdir(ResponseCallback *cb, const char *dname); virtual void flush(ResponseCallback *cb, uint32_t fd); |