diff options
Diffstat (limited to 'test/javascript/replicator_db_inc.js')
-rw-r--r-- | test/javascript/replicator_db_inc.js | 97 |
1 files changed, 0 insertions, 97 deletions
diff --git a/test/javascript/replicator_db_inc.js b/test/javascript/replicator_db_inc.js deleted file mode 100644 index 46dcdd702..000000000 --- a/test/javascript/replicator_db_inc.js +++ /dev/null @@ -1,97 +0,0 @@ -// Licensed under the Apache License, Version 2.0 (the "License"); you may not -// use this file except in compliance with the License. You may obtain a copy of -// the License at -// -// http://www.apache.org/licenses/LICENSE-2.0 -// -// Unless required by applicable law or agreed to in writing, software -// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT -// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the -// License for the specific language governing permissions and limitations under -// the License. - -var replicator_db = {}; -replicator_db.wait_rep_doc = 500; // number of millisecs to wait after saving a Rep Doc -replicator_db.dbA = new CouchDB("test_suite_rep_db_a", {"X-Couch-Full-Commit":"false"}); -replicator_db.dbB = new CouchDB("test_suite_rep_db_b", {"X-Couch-Full-Commit":"false"}); -replicator_db.repDb = new CouchDB("test_suite_rep_db", {"X-Couch-Full-Commit":"false"}); -replicator_db.usersDb = new CouchDB("test_suite_auth", {"X-Couch-Full-Commit":"false"}); - -replicator_db.docs1 = [ - { - _id: "foo1", - value: 11 - }, - { - _id: "foo2", - value: 22 - }, - { - _id: "foo3", - value: 33 - } -]; - -replicator_db.waitForRep = function waitForSeq(repDb, repDoc, state, errorState) { - var newRep, - t0 = new Date(), - t1, - ms = 3000; - - do { - newRep = repDb.open(repDoc._id); - t1 = new Date(); - } while (((t1 - t0) <= ms) && newRep._replication_state !== state && (!errorState || newRep._replication_state !== errorState)); - return newRep ? newRep._replication_state : null; -} - -replicator_db.waitForSeq = function waitForSeq(sourceDb, targetDb) { - var targetSeq, - sourceSeq = sourceDb.info().update_seq, - t0 = new Date(), - t1, - ms = 3000; - - do { - targetSeq = targetDb.info().update_seq; - t1 = new Date(); - } while (((t1 - t0) <= ms) && targetSeq < sourceSeq); -} - -replicator_db.waitForDocPos = function waitForDocPos(db, docId, pos) { - var doc, curPos, t0, t1, - maxWait = 3000; - - doc = db.open(docId); - curPos = Number(doc._rev.split("-", 1)); - t0 = t1 = new Date(); - - while ((curPos < pos) && ((t1 - t0) <= maxWait)) { - doc = db.open(docId); - curPos = Number(doc._rev.split("-", 1)); - t1 = new Date(); - } - - return doc; -} - -replicator_db.wait = function wait(ms) { - var t0 = new Date(), t1; - do { - CouchDB.request("GET", "/"); - t1 = new Date(); - } while ((t1 - t0) <= ms); -} - - -replicator_db.populate_db = function populate_db(db, docs) { - if (db.name !== replicator_db.usersDb.name) { - db.deleteDb(); - db.createDb(); - } - for (var i = 0; i < docs.length; i++) { - var d = docs[i]; - delete d._rev; - T(db.save(d).ok); - } -} |