summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJordi Llonch <llonchj@gmail.com>2013-07-15 07:26:58 +1000
committerJordi Llonch <llonchj@gmail.com>2013-07-15 07:26:58 +1000
commit9ca4733d9073a26d48794be7d8cc3ab0391d7569 (patch)
tree16718435d15bd050ef3c982ef00dd182c0d51073
parent8e83a3bea2fea4c2a1dcc4a4fd427542a1c6ae79 (diff)
downloadceph-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.cc4
-rw-r--r--src/client/hypertable/CephBroker.h5
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);