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;
}
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);
#include "DfsBroker/Lib/Broker.h"
+#include <cephfs/libcephfs.h>
namespace Hypertable {
using namespace DfsBroker;
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);