]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
hypertable recent version prototyping includes bool verify in length and read functions
authorJordi Llonch <llonchj@gmail.com>
Sun, 14 Jul 2013 21:26:58 +0000 (07:26 +1000)
committerJordi Llonch <llonchj@gmail.com>
Sun, 14 Jul 2013 21:26:58 +0000 (07:26 +1000)
Signed-off-by: Jordi Llonch <llonchj@gmail.com>
src/client/hypertable/CephBroker.cc
src/client/hypertable/CephBroker.h

index a6cf6da1daacf7248bb0dcd50e4c53b14174d90e..7008f30bb3cd1c9e0ddc2f5e8d08543808957044 100644 (file)
@@ -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);
index 6924103221c160beea7b7efbad623a0eab349eb4..542ff668f155c50a45b6531eece16ab4be652e0c 100644 (file)
@@ -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);