if (length == 0) {
return -EINVAL;
}
- if (sync) {
+ if (true || sync) {
/* if write is stable, the epilogue is waiting on
* flock */
onack = new C_NoopContext;
/* if write is unstable, we just place a barrier for
* future commits to wait on */
onack = new C_NoopContext;
- onsafe = new C_Block_Sync(this, vino.ino,
+ /*onsafe = new C_Block_Sync(this, vino.ino,
barrier_interval(offset, offset + length), &r);
+ */
done = true;
}
object_t oid = file_object_t(vino.ino, blockid);
uint64_t length)
{
Mutex::Locker lock(client_lock);
+ /*
BarrierContext *bctx;
vinodeno_t vino = ll_get_vino(in);
uint64_t ino = vino.ino;
barrier_interval civ(offset, offset + length);
p->second->commit_barrier(civ);
}
-
+ */
return 0;
}
#include "include/interval_set.h"
#include "include/lru.h"
-#include "barrier.h"
+//#include "barrier.h"
#include "mds/mdstypes.h"
ceph::unordered_map<inodeno_t,SnapRealm*> snap_realms;
/* async block write barrier support */
- map<uint64_t, BarrierContext* > barriers;
+ //map<uint64_t, BarrierContext* > barriers;
SnapRealm *get_snap_realm(inodeno_t r);
SnapRealm *get_snap_realm_maybe(inodeno_t r);
libclient_la_SOURCES = \
client/Client.cc \
- client/barrier.cc \
client/Inode.cc \
client/Dentry.cc \
client/MetaRequest.cc \
client/ClientSnapRealm.h \
client/SyntheticClient.h \
client/Trace.h \
- client/barrier.h \
client/ioctl.h \
client/ObjecterWriteback.h