gistfile1.txt

var util = require('util');
var cb = require("./lib/couchbase.js");
var MAX_CLIENTS = 1;
var MAX_OPERATIONS=10000000;
var MODE_SEQUENTIAL = 1;
var MODE_
var CurrentOperations = 0;

var key = "keybase";
var value = "valbase";

for (var i = 0; i < 10; i++) {
    value += "***";
}

/* How many operations are remaining */
var remaining=MAX_OPERATIONS;
var BEGIN_TIME = Date.now();

//setInterval(function(arg) {
//    // Get time elapsed
//    var elapsedTime = (Date.now() - BEGIN_TIME) / 1000;
//    var opsPerSecond = CurrentOperations / elapsedTime;
//    var s = util.format("Elapsed: %d; Ops=%d [%d]/S",
//        elapsedTime,
//        CurrentOperations,
//        Math.round(opsPerSecond));
//    for (var i = 0; i < 20; i++) {
//        s+= ' ';
//    }
//    process.stdout.write(s + "\r");
//}, null, 500);

function schedule_one(cb, suffix) {
    var kv = {};
    kv[key] = { value : value };

    cb.setMultiEx(kv, null, function(err, meta) {
        if (err) {
            console.log("Got Error: " + err);
            process.exit(1);
        }
        CurrentOperations++;
        process.nextTick(function() {
            schedule_one(cb, remaining);
        });
    });
}


for (var i = 0; i < MAX_CLIENTS; i++) {
    cb.connect(
            { hosts: [ "10.0.0.99:18091" ], bucket: "default" },
            function(err, cb) {
                if (err) {
                    console.log("Got error!");
                    process.exit(1);
                }
                console.log("Connected!");
                schedule_one(cb, remaining);
            }
    );
}