Home
last modified time | relevance | path

Searched defs:cas (Results 1 – 25 of 174) sorted by relevance

1234567

/trunk/kv_engine/daemon/
H A Dsession_cas.cc16 cb::engine_errc SessionCas::cas(uint64_t newValue, in cas() function in SessionCas
51 bool SessionCas::increment_session_counter(const uint64_t cas) { in increment_session_counter()
66 bool SessionCas::execute(uint64_t cas, std::function<void()> func) { in execute()
H A Dmcbp.cc29 uint64_t cas, in mcbp_response_handler()
/trunk/testrunner/lib/
H A Dmc_bin_server.py76 def processCommand(self, cmd, keylen, vb, cas, data): argument
91 def handle_noop(self, cmd, hdrs, key, cas, data): argument
96 def handle_unknown(self, cmd, hdrs, key, cas, data): argument
124 def handle_get(self, cmd, hdrs, key, cas, data): argument
133 def handle_set(self, cmd, hdrs, key, cas, data): argument
142 def handle_getq(self, cmd, hdrs, key, cas, data): argument
180 def handle_incr(self, cmd, hdrs, key, cas, data): argument
183 def handle_decr(self, cmd, hdrs, key, cas, data): argument
197 def handle_add(self, cmd, hdrs, key, cas, data): argument
209 def handle_flush(self, cmd, hdrs, key, cas, data): argument
[all …]
H A Dsdk_client.py103 …def counter_in(self, key, path, delta, create_parents=True, cas=0, ttl=0, persist_to=0, replicate_… argument
142 def remove_in(self, key, path, cas=0, ttl=0, collection=None): argument
173 …def replace_in(self, key, path, value, cas=0, ttl=0, persist_to=0, replicate_to=0, collection=None… argument
196 def append(self, key, value, cas=0, format=None, persist_to=0, replicate_to=0, collection=None): argument
206 def append_multi(self, keys, cas=0, format=None, persist_to=0, replicate_to=0, collection=None): argument
216 … def prepend(self, key, value, cas=0, format=None, persist_to=0, replicate_to=0, collection=None): argument
225 … def prepend_multi(self, keys, cas=0, format=None, persist_to=0, replicate_to=0, collection=None): argument
259 def cas(self, key, value, cas=0, ttl=0, format=None, collection=None): argument
262 def delete(self, key, cas=0, quiet=True, persist_to=0, replicate_to=0, collection=None): argument
265 def remove(self, key, cas=0, quiet=True, persist_to=0, replicate_to=0, collection=None): argument
[all …]
H A Dmc_bin_client.py128 def _sendMsg(self, cmd, key, val, opaque, extraHeader='', cas=0, argument
223 def _doCmd(self, cmd, key, val, extraHeader='', cas=0, scope=None, collection=None, argument
290 def _cat(self, cmd, key, cas, val, scope=None, collection=None): argument
294 def append(self, key, value, cas=0, vbucket=-1, scope=None, collection=None): argument
299 def prepend(self, key, value, cas=0, vbucket=-1, scope=None, collection=None): argument
368 def setWithMetaLWW(self, key, value, exp, flags, cas, scope=None, collection=None): argument
387 def delWithMetaLWW(self, key, exp, flags, cas, scope=None, collection=None): argument
438 def del_with_meta(self, key, exp, flags, seqno, cas, vbucket=-1, argument
605 def cas(self, key, exp, flags, oldVal, val, vbucket=-1, scope=None, collection=None): member in MemcachedClient
807 def delete(self, key, cas=0, vbucket=-1, scope=None, collection=None): argument
[all …]
H A Dsdk_client3.py119 …def counter_in(self, key, path, delta, create_parents=True, cas=0, ttl=0, persist_to=0, replicate_… argument
132 …def arrayappend_in(self, key, path, value, create_parents=True, cas=0, ttl=0, persist_to=0, replic… argument
145 …def arrayprepend_in(self, key, path, value, create_parents=True, cas=0, ttl=0, persist_to=0, repli… argument
184 def remove_in(self, key, path, cas=0, ttl=0, scope=None, collection=None): argument
248 …def insert_in(self, key, path, value, create_parents=True, cas=0, ttl=0, persist_to=0, replicate_t… argument
261 …def upsert_in(self, key, path, value, create_parents=True, cas=0, ttl=0, persist_to=0, replicate_t… argument
274 …def append(self, key, value, cas=0, format=None, persist_to=0, replicate_to=0, scope=None, collect… argument
399 def cas(self, key, value, cas=0, ttl=0, format=None, scope=None, collection=None): member in SDKClient
406 …def delete(self, key, cas=0, quiet=True, persist_to=0, replicate_to=0, scope=None, collection=None… argument
409 …def remove(self, key, cas=0, quiet=True, persist_to=0, replicate_to=0, scope=None, collection=None… argument
[all …]
H A Dmc_ascii_client.py128 def append(self, key, value, cas=0): argument
133 def prepend(self, key, value, cas=0): argument
184 def cas(self, key, exp, flags, oldVal, val): member in MemcachedAsciiClient
232 def delete(self, key, cas=0, scope=None, collection=None): argument
/trunk/kv_engine/engines/ep/management/
H A Dmc_bin_server.py80 def processCommand(self, cmd, keylen, vb, cas, data): argument
95 def handle_noop(self, cmd, hdrs, key, cas, data): argument
100 def handle_unknown(self, cmd, hdrs, key, cas, data): argument
127 def handle_get(self, cmd, hdrs, key, cas, data): argument
136 def handle_set(self, cmd, hdrs, key, cas, data): argument
144 def handle_getq(self, cmd, hdrs, key, cas, data): argument
182 def handle_incr(self, cmd, hdrs, key, cas, data): argument
185 def handle_decr(self, cmd, hdrs, key, cas, data): argument
199 def handle_add(self, cmd, hdrs, key, cas, data): argument
211 def handle_flush(self, cmd, hdrs, key, cas, data): argument
[all …]
/trunk/kv_engine/testsuite/basic/
H A Dbasic_engine_testsuite.cc139 uint64_t cas; in TEST_F() local
177 uint64_t cas = 0; in TEST_F() local
205 uint64_t cas = 0; in TEST_F() local
226 uint64_t cas = 0; in TEST_F() local
248 uint64_t cas = 0; in TEST_F() local
284 uint64_t cas = 0; in TEST_F() local
314 uint64_t cas = 0; in TEST_F() local
334 uint64_t cas = 0; in TEST_F() local
361 uint64_t cas = 0; in TEST_F() local
388 uint64_t cas = 0; in TEST_F() local
[all …]
/trunk/testrunner/pytests/eventing/handler_code/ABO/
H A Dreplace.js8 var meta_data={"id": meta.id,"cas":result.meta.cas}; property in OnUpdate.meta_data
24 var meta_data={"id": meta.id,"cas":result.meta.cas}; property in OnDelete.meta_data
H A Dexpiry_replace.js7 var meta_data={"id": meta.id,"expiry_date": expiry,"cas":result.meta.cas}; property in OnUpdate.meta_data
H A Dcas_key_not_found_insert.js17 var meta_data = {"id": meta.id,"cas":"1234"}; property in OnDelete.meta_data
H A Dcas_key_not_found_replace.js16 var meta_data = {"id": meta.id,"cas":"12324"}; property in OnDelete.meta_data
/trunk/testrunner/lib/backup_service_client/models/
H A Dexamine_metadata.py49 …def __init__(self, flags=None, expiry=None, locktime=None, cas=None, revseqno=None, datatype=None)… argument
135 def cas(self): member in ExamineMetadata
145 def cas(self, cas): argument
/trunk/kv_engine/engines/ep/src/
H A Dpre_link_document_context.cc19 void PreLinkDocumentContext::preLink(uint64_t cas, uint64_t seqno) { in preLink()
/trunk/kv_engine/daemon/protocol/mcbp/
H A Dunlock_context.h60 const uint64_t cas; variable
H A Ddcp_deletion.cc25 const auto cas = request.getCas(); in dcp_deletion_v1_executor() local
74 const auto cas = request.getCas(); in dcp_deletion_v2_executor() local
/trunk/couchbase-cli/test/
H A Dtest_txn.py21 …def __init__(self, key, val=b'rawbytes', cas=0, expiry=0, data_type=0x00, revid=struct.pack('>Q', … argument
37 def set_expected(self, val=None, cas=None, expiry=None, data_type=None, revid=None): argument
49 def match(self, skip, val, cas, expiry, data_type, revid): argument
/trunk/libcouchbase/example/minimal/
H A Dminimal.c48 uint64_t cas; in store_callback() local
65 uint64_t cas; in get_callback() local
H A Dg3cp.c59 uint64_t cas; in store_callback() local
72 uint64_t cas; in get_callback() local
H A Dg3cp-async.c53 uint64_t cas; in get_callback() local
70 uint64_t cas; in store_callback() local
/trunk/goproj/src/github.com/couchbase/query/test/filestore/json/default/couchbase_cases/
Dcase_meta.json9 "cas":2, number
/trunk/godeps/src/gopkg.in/couchbase/gocb.v1/
Dbucket_internal.go68 …options, flags uint32, expiry uint32, cas, revseqno uint64) (casOut Cas, mtOut MutationToken, errO… argument
95 …options, flags uint32, expiry uint32, cas, revseqno uint64) (casOut Cas, mtOut MutationToken, errO… argument
/trunk/testrunner/lib/perf_engines/libobserve/
H A Dobs_req.py46 cas = 0x0000000000000000 variable in ObserveRequest
49 def __init__(self, keys, opaque=0x00000000, cas=0x0000000000000000): argument
/trunk/kv_engine/engines/ep/tests/
H A Dep_request_utils.cc20 uint64_t cas, in createPacket()

1234567