]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
*** empty log message ***
authorsage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Sat, 6 May 2006 02:03:15 +0000 (02:03 +0000)
committersage <sage@29311d96-e01e-0410-9327-a35deaab8ce9>
Sat, 6 May 2006 02:03:15 +0000 (02:03 +0000)
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@758 29311d96-e01e-0410-9327-a35deaab8ce9

ceph/osd/FakeStore.cc
ceph/osd/FakeStore.h

index 7aa7dff62b3fcc411232b7967ffd031f8b04ba13..ae4aeaa6bd411d70a5c21e11ea9f4afcdcf49ddf 100644 (file)
@@ -259,22 +259,29 @@ int FakeStore::stat(object_t oid,
  
  
 
-int FakeStore::remove(object_t oid) 
+int FakeStore::remove(object_t oid, Context *onsafe
 {
   dout(20) << "remove " << oid << endl;
   string fn;
   get_oname(oid,fn);
   int r = ::unlink(fn.c_str());
+  if (onsafe)
+       g_timer.add_event_after((float)g_conf.fakestore_fake_sync,
+                                                       onsafe);
   return r;
 }
 
-int FakeStore::truncate(object_t oid, off_t size)
+int FakeStore::truncate(object_t oid, off_t size, Context *onsafe)
 {
   dout(20) << "truncate " << oid << " size " << size << endl;
 
   string fn;
   get_oname(oid,fn);
-  return ::truncate(fn.c_str(), size);
+  int r = ::truncate(fn.c_str(), size);
+  if (onsafe)
+       g_timer.add_event_after((float)g_conf.fakestore_fake_sync,
+                                                       onsafe);
+  return r;
 }
 
 int FakeStore::read(object_t oid, 
index bb128dbef38216f2102f6b644aa985d35ab1ff7b..cc4a7bfff1d7c7ba65fb7f3b430c3155a47e8c0b 100644 (file)
@@ -74,8 +74,8 @@ class FakeStore : public ObjectStore,
   // objects
   bool exists(object_t oid);
   int stat(object_t oid, struct stat *st);
-  int remove(object_t oid);
-  int truncate(object_t oid, off_t size);
+  int remove(object_t oid, Context *onsafe);
+  int truncate(object_t oid, off_t size, Context *onsafe);
   int read(object_t oid, 
                   size_t len, off_t offset,
                   bufferlist& bl);