mirror of https://gitee.com/bigwinds/arangodb
added waitUnload as a test helper function
This commit is contained in:
parent
9e19e0c6ca
commit
9e03189fb0
|
@ -40,11 +40,6 @@ var processCsvFile = internal.processCsvFile;
|
||||||
// --SECTION-- public variables
|
// --SECTION-- public variables
|
||||||
// -----------------------------------------------------------------------------
|
// -----------------------------------------------------------------------------
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
|
||||||
/// @addtogroup ArangoShell
|
|
||||||
/// @{
|
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
/// @brief array query
|
/// @brief array query
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
////////////////////////////////////////////////////////////////////////////////
|
||||||
|
@ -56,13 +51,22 @@ exports.Helper = {
|
||||||
processor(raw_row.toString().split(","));
|
processor(raw_row.toString().split(","));
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
},
|
||||||
|
|
||||||
|
waitUnload: function (collection) {
|
||||||
|
var arangodb = require("org/arangodb");
|
||||||
|
var internal = require("internal");
|
||||||
|
|
||||||
|
collection.unload();
|
||||||
|
internal.flushWal();
|
||||||
|
|
||||||
|
while (collection.status() !== arangodb.ArangoCollection.STATUS_UNLOADED) {
|
||||||
|
collection.unload();
|
||||||
|
internal.wait(1);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
|
||||||
/// @}
|
|
||||||
////////////////////////////////////////////////////////////////////////////////
|
|
||||||
|
|
||||||
// -----------------------------------------------------------------------------
|
// -----------------------------------------------------------------------------
|
||||||
// --SECTION-- END-OF-FILE
|
// --SECTION-- END-OF-FILE
|
||||||
// -----------------------------------------------------------------------------
|
// -----------------------------------------------------------------------------
|
||||||
|
|
|
@ -32,23 +32,7 @@ var arangodb = require("org/arangodb");
|
||||||
var ERRORS = arangodb.errors;
|
var ERRORS = arangodb.errors;
|
||||||
var db = arangodb.db;
|
var db = arangodb.db;
|
||||||
var wait = require("internal").wait;
|
var wait = require("internal").wait;
|
||||||
var flushWal = require("internal").flushWal;
|
var testHelper = require("org/arangodb/test-helper").Helper;
|
||||||
|
|
||||||
// -----------------------------------------------------------------------------
|
|
||||||
// --SECTION-- helper functions
|
|
||||||
// -----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
function waitUnload (collection) {
|
|
||||||
collection.unload();
|
|
||||||
flushWal();
|
|
||||||
|
|
||||||
while (collection.status() != arangodb.ArangoCollection.STATUS_UNLOADED) {
|
|
||||||
collection.unload();
|
|
||||||
wait(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
assertEqual(arangodb.ArangoCollection.STATUS_UNLOADED, collection.status());
|
|
||||||
}
|
|
||||||
|
|
||||||
// -----------------------------------------------------------------------------
|
// -----------------------------------------------------------------------------
|
||||||
// --SECTION-- collection methods
|
// --SECTION-- collection methods
|
||||||
|
@ -383,7 +367,7 @@ function CollectionDocumentSuite () {
|
||||||
d1 = null;
|
d1 = null;
|
||||||
d2 = null;
|
d2 = null;
|
||||||
|
|
||||||
waitUnload(collection);
|
testHelper.waitUnload(collection);
|
||||||
|
|
||||||
collection.load();
|
collection.load();
|
||||||
|
|
||||||
|
@ -416,7 +400,7 @@ function CollectionDocumentSuite () {
|
||||||
d1 = null;
|
d1 = null;
|
||||||
d2 = null;
|
d2 = null;
|
||||||
|
|
||||||
waitUnload(collection);
|
testHelper.waitUnload(collection);
|
||||||
|
|
||||||
collection.load();
|
collection.load();
|
||||||
|
|
||||||
|
@ -444,7 +428,7 @@ function CollectionDocumentSuite () {
|
||||||
|
|
||||||
assertEqual(0, collection.count());
|
assertEqual(0, collection.count());
|
||||||
|
|
||||||
waitUnload(collection);
|
testHelper.waitUnload(collection);
|
||||||
|
|
||||||
collection.load();
|
collection.load();
|
||||||
|
|
||||||
|
@ -480,7 +464,7 @@ function CollectionDocumentSuite () {
|
||||||
|
|
||||||
assertEqual(1, collection.count());
|
assertEqual(1, collection.count());
|
||||||
|
|
||||||
waitUnload(collection);
|
testHelper.waitUnload(collection);
|
||||||
|
|
||||||
collection.load();
|
collection.load();
|
||||||
|
|
||||||
|
@ -521,7 +505,7 @@ function CollectionDocumentSuite () {
|
||||||
assertEqual(0, doc.value);
|
assertEqual(0, doc.value);
|
||||||
doc = null;
|
doc = null;
|
||||||
|
|
||||||
waitUnload(collection);
|
testHelper.waitUnload(collection);
|
||||||
|
|
||||||
collection.load();
|
collection.load();
|
||||||
|
|
||||||
|
|
|
@ -30,6 +30,7 @@ var jsunity = require("jsunity");
|
||||||
var wait = require("internal").wait;
|
var wait = require("internal").wait;
|
||||||
var console = require("console");
|
var console = require("console");
|
||||||
var arangodb = require("org/arangodb");
|
var arangodb = require("org/arangodb");
|
||||||
|
var testHelper = require("org/arangodb/test-helper").Helper;
|
||||||
|
|
||||||
var ArangoCollection = arangodb.ArangoCollection;
|
var ArangoCollection = arangodb.ArangoCollection;
|
||||||
var db = arangodb.db;
|
var db = arangodb.db;
|
||||||
|
@ -282,10 +283,7 @@ function AutoIncrementSuite () {
|
||||||
var d4 = c.save({ });
|
var d4 = c.save({ });
|
||||||
assertEqual("13", d4._key);
|
assertEqual("13", d4._key);
|
||||||
|
|
||||||
c.unload();
|
testHelper.waitUnload(c);
|
||||||
console.log("waiting for collection to unload");
|
|
||||||
wait(5);
|
|
||||||
assertEqual(ArangoCollection.STATUS_UNLOADED, c.status());
|
|
||||||
|
|
||||||
d1 = c.save({ });
|
d1 = c.save({ });
|
||||||
assertEqual("17", d1._key);
|
assertEqual("17", d1._key);
|
||||||
|
@ -319,10 +317,7 @@ function AutoIncrementSuite () {
|
||||||
var d4 = c.save({ });
|
var d4 = c.save({ });
|
||||||
assertEqual("8", d4._key);
|
assertEqual("8", d4._key);
|
||||||
|
|
||||||
c.unload();
|
testHelper.waitUnload(c);
|
||||||
console.log("waiting for collection to unload");
|
|
||||||
wait(5);
|
|
||||||
assertEqual(ArangoCollection.STATUS_UNLOADED, c.status());
|
|
||||||
|
|
||||||
d1 = c.save({ });
|
d1 = c.save({ });
|
||||||
assertEqual("10", d1._key);
|
assertEqual("10", d1._key);
|
||||||
|
@ -338,10 +333,7 @@ function AutoIncrementSuite () {
|
||||||
d4 = c.save({ _key: "19567" });
|
d4 = c.save({ _key: "19567" });
|
||||||
assertEqual("19567", d4._key);
|
assertEqual("19567", d4._key);
|
||||||
|
|
||||||
c.unload();
|
testHelper.waitUnload(c);
|
||||||
console.log("waiting for collection to unload");
|
|
||||||
wait(5);
|
|
||||||
assertEqual(ArangoCollection.STATUS_UNLOADED, c.status());
|
|
||||||
|
|
||||||
d1 = c.save({ });
|
d1 = c.save({ });
|
||||||
assertEqual("19568", d1._key);
|
assertEqual("19568", d1._key);
|
||||||
|
|
Loading…
Reference in New Issue