X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2FObjectMap%2Ftest_keyvaluedb_atomicity.cc;fp=src%2Fceph%2Fsrc%2Ftest%2FObjectMap%2Ftest_keyvaluedb_atomicity.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=6e7fc8d2fa775ca8ab48eaa7608d76c1142e9631;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/test/ObjectMap/test_keyvaluedb_atomicity.cc b/src/ceph/src/test/ObjectMap/test_keyvaluedb_atomicity.cc
deleted file mode 100644
index 6e7fc8d..0000000
--- a/src/ceph/src/test/ObjectMap/test_keyvaluedb_atomicity.cc
+++ /dev/null
@@ -1,110 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-#include <pthread.h>
-#include "include/buffer.h"
-#include "kv/KeyValueDB.h"
-#include <sys/types.h>
-#include <dirent.h>
-#include <string>
-#include <vector>
-#include "include/memory.h"
-#include <boost/scoped_ptr.hpp>
-#include <iostream>
-#include <sstream>
-#include "stdlib.h"
-#include "global/global_context.h"
-
-using namespace std;
-
-const string CONTROL_PREFIX = "CONTROL";
-const string PRIMARY_PREFIX = "PREFIX";
-const int NUM_COPIES = 100;
-const int NUM_THREADS = 30;
-
-string prefix_gen(int i) {
-  stringstream ss;
-  ss << PRIMARY_PREFIX << "_" << i << std::endl;
-  return ss.str();
-}
-
-int verify(KeyValueDB *db) {
-  // Verify
-  {
-    map<int, KeyValueDB::Iterator> iterators;
-    for (int i = 0; i < NUM_COPIES; ++i) {
-      iterators[i] = db->get_iterator(prefix_gen(i));
-      iterators[i]->seek_to_first();
-    }
-    while (iterators.rbegin()->second->valid()) {
-      for (map<int, KeyValueDB::Iterator>::iterator i = iterators.begin();
-	   i != iterators.end();
-	   ++i) {
-	assert(i->second->valid());
-	assert(i->second->key() == iterators.rbegin()->second->key());
-	bufferlist r = i->second->value();
-	bufferlist l = iterators.rbegin()->second->value();
-	i->second->next();
-      }
-    }
-    for (map<int, KeyValueDB::Iterator>::iterator i = iterators.begin();
-	 i != iterators.end();
-	 ++i) {
-      assert(!i->second->valid());
-    }
-  }
-  return 0;
-}
-
-void *write(void *_db) {
-  KeyValueDB *db = static_cast<KeyValueDB*>(_db);
-  std::cout << "Writing..." << std::endl;
-  for (int i = 0; i < 12000; ++i) {
-    if (!(i % 10)) {
-      std::cout << "Iteration: " << i << std::endl;
-    }
-    int key_num = rand();
-    stringstream key;
-    key << key_num << std::endl;
-    map<string, bufferlist> to_set;
-    stringstream val;
-    val << i << std::endl;
-    bufferptr bp(val.str().c_str(), val.str().size() + 1);
-    to_set[key.str()].push_back(bp);
-    
-    KeyValueDB::Transaction t = db->get_transaction();
-    for (int j = 0; j < NUM_COPIES; ++j) {
-      t->set(prefix_gen(j), to_set);
-    }
-    assert(!db->submit_transaction(t));
-  }
-  return 0;
-}
-
-int main() {
-  char *path = getenv("OBJECT_MAP_PATH");
-  boost::scoped_ptr< KeyValueDB > db;
-  if (!path) {
-    std::cerr << "No path found, OBJECT_MAP_PATH undefined" << std::endl;
-    return 0;
-  }
-  string strpath(path);
-  std::cerr << "Using path: " << strpath << std::endl;
-  KeyValueDB *store = KeyValueDB::create(g_ceph_context, "leveldb", strpath);
-  assert(!store->create_and_open(std::cerr));
-  db.reset(store);
-
-  verify(db.get());
-
-  vector<pthread_t> threads(NUM_THREADS);
-  for (vector<pthread_t>::iterator i = threads.begin();
-       i != threads.end();
-       ++i) {
-    pthread_create(&*i, 0, &write, static_cast<void *>(db.get()));
-  }
-  for (vector<pthread_t>::iterator i = threads.begin();
-       i != threads.end();
-       ++i) {
-    void *tmp;
-    pthread_join(*i, &tmp);
-  }
-  verify(db.get());
-}