mnunberg

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <assert.h>
#include <libcouchbase/couchbase.h>

static void
error_callback(
        libcouchbase_t instance,

mnunberg

void
Handle::cb_get(libcouchbase_t instance, ResultSet* rs,
               libcouchbase_error_t err,
               const void *key, libcouchbase_size_t nkey,
               const void *value, libcouchbase_size_t nvalue,
               libcouchbase_uint32_t flags, libcouchbase_cas_t cas)
{
    int myerr = mapError(err, Error::SUBSYSf_MEMD|Error::ERROR_GENERIC);
    rs->stats[myerr]++;
    if (rs->options.full) {

mnunberg

^Cmnunberg@csure:/sources/couchnode$ node tests/couchbase.js 
Created new handle Couchbase 0
Created new handle Couchbase 1
Created new handle Couchbase 2
Created new handle Couchbase 3
Created new handle Couchbase 4
Created new handle Couchbase 5
Created new handle Couchbase 6
Created new handle Couchbase 7
Created new handle Couchbase 8

mnunberg

    def getset_simple(self, nthreads = 10, rmcount = 2):
        
        self.log.info("Requesting to create new bucket..")
                
        self.log.info("Rebalance complete")
        begin = time.time()
        
        # Set up a four node cluster
        self.setupCluster(4)
        

mnunberg

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <limits.h>
#include <sys/time.h>
#include <unistd.h>
#include <sys/types.h>

#define PROCSCAN_XFLD(X) \
X(0, PID, pid,\

mnunberg

IPTC Notes
    This document outlines some of my experiences with IPTC, both for my own
    reference, and for anyone else wishing to use this library.                             
                                                                                            
    "libiptc" is an internal library to "iptables". It is available as a
    package on some distros, and is compiled with the "iptables" tarball as
    well. Depending in "libiptc" should be a fairly simple process.

    "libiptc" itself only provides the fairly high level functions used to
    actually insert/remove/update/append a rule, but does not actually

mnunberg

import memcacheConstants as MCC
import struct
import mc_bin_client
import logger
import time
import Queue

from threading import Thread, Lock
from membase.api.rest_client import RestConnection, RestHelper
from memcached.helper.data_helper import MemcachedClientHelper

mnunberg

# BEGIN BOILERPLATE
from sdk.sdkbasetestcase import SDKBaseTestCase, GetSetWorkload

from sdk.sdkbasetestcase import SDKBaseTestCase
import basetestcase

from cbsdk.dataset import DSSeed, DSInline
import cbsdk.driver
from cbsdk.constants import StatusCodes as _E
import cbsdk.constants as _C

mnunberg

#define pp_ev_allow_revent(l, e, revt_) \
	if ( ( (e)->events & revt_) != revt_ ) { \
		ev_io_stop(l, (e)); \
		ev_io_set( (e), (e)->fd, (e)->events | revt_); \
		ev_io_start(l, (e)); \
	}

#define pp_ev_ignore_revent(l, e, revt_) \
	if ((e)->events & revt_) { \
		ev_io_stop(l, (e)); \

mnunberg

#include "bufio.h"
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include "internal.h"
#include <ctype.h>

/**
 * Parse a chunk of data, splitting along message boundaries.
 *