Home
last modified time | relevance | path

Searched defs:bytes (Results 1 – 25 of 79) sorted by relevance

1234

/trunk/couchbase-cli/
H A Dcb_bin_client.py129 …def _send_cmd(self, cmd: int, key: bytes, val: bytes, opaque: int, extra_header: bytes = b'', cas:…
134 …def _send_msg(self, cmd: int, key: bytes, val: bytes, opaque: int, extra_header: bytes = b'', cas:…
174 def _do_cmd(self, cmd: int, key: bytes, val: bytes, extra_header: bytes = b'',
187 def append(self, key: bytes, value: bytes, cas: int = 0) -> Tuple[int, int, bytes]:
221 value: bytes, rev: Tuple[int, bytes], cas: int = 0): argument
238 def set_with_rev(self, key: bytes, exp: int, flags: int, value: bytes, rev: Tuple[int, bytes]): argument
243 def add(self, key: bytes, exp: int, flags: int, val: bytes):
251 def add_with_rev(self, key: bytes, exp: int, flags: int, value: bytes, rev: Tuple[int, bytes]): argument
255 def replace(self, key: bytes, exp: int, flags: int, val: bytes):
293 def cas(self, key: bytes, exp: int, flags: int, old_val: int, val: bytes):
[all …]
H A Dpump_mc.py58 def __init__(self, start: int, length: int, body: bytes):
251 def filter_out_txn(key: bytes, val: bytes, cas: int, exp: int, revid: bytes,
356 …def format_multipath_mutation(key: bytes, value: bytes, vbucket_id: int, cas: int = 0, opaque: int…
392 …def format_multipath_lookup(key: bytes, value: bytes, vbucket_id: int, cas: int = 0, opaque: int =…
419 def join_str_and_bytes(lst: List[bytes]) -> bytes:
520 def append_req(self, m: List[bytes], req: couchbaseConstants.REQUEST):
580 key: bytes,
581 val: bytes,
585 meta: Optional[bytes],
646 …def cmd_header(self, cmd: int, vbucket_id: int, key: bytes, val: bytes, ext: bytes, cas: int, opaq…
[all …]
H A Dx509_adapter.py62 def __init__(self, cert: bytes, chain: bytes, key: bytes, **kwargs):
173 def _parse_certs_unencrypted(cls, data: bytes) -> Tuple[bytes, bytes]:
184 def _parse_certs_pkcs12(self, data: bytes) -> Tuple[bytes, bytes]:
210 def _parse_key_unencrypted(cls, data: bytes) -> bytes:
218 def _parse_key_pkcs8(self, data: bytes) -> bytes:
230 def _parse_key_pkcs12(self, data: bytes) -> bytes:
H A Dpump_cb.py18 def _to_string(str_or_bytes: Union[str, bytes]) -> str: argument
210 … source_map, source_design: Union[str, bytes]) -> couchbaseConstants.PUMP_ERROR: argument
236 … source_map, source_design: Union[str, bytes]) -> couchbaseConstants.PUMP_ERROR: argument
261 … source_map, source_design: Union[str, bytes]) -> couchbaseConstants.PUMP_ERROR: argument
288 … source_map, source_design: Union[str, bytes]) -> couchbaseConstants.PUMP_ERROR: argument
H A Dpump_json.py39 def save_doc(self, batch: pump.Batch, dockey: bytes, docvalue: bytes):
/trunk/kv_engine/tests/testapp/
H A Dsubdoc_encoder.cc30 char bytes[sizeof(protocol_binary_subdoc_multi_lookup_spec)]; in encode() member
58 char bytes[sizeof(protocol_binary_subdoc_multi_mutation_spec)]; in encode() member
94 char bytes[sizeof(uint32_t)]; in encode_common() member
H A Dtestapp_subdoc_common.cc57 char bytes[1024]; in recv_subdoc_response() member
143 char bytes[1024]; in recv_subdoc_response() member
/trunk/kv_engine/protocol/mcbp/
H A Dmcbp_dump_parser_test.cc24 const std::vector<uint8_t> bytes = { in TEST() local
48 const std::vector<uint8_t> bytes = { in TEST() local
/trunk/couchstore/src/views/
H A Dkeys.cc11 couchstore_error_t decode_view_btree_json_key(const char* bytes, in decode_view_btree_json_key()
33 couchstore_error_t decode_view_btree_key(const char *bytes, in decode_view_btree_key()
135 couchstore_error_t decode_view_id_btree_key(const char *bytes, in decode_view_id_btree_key()
H A Dvalues.cc18 couchstore_error_t decode_view_btree_value(const char* bytes, in decode_view_btree_value()
67 uint16_t decode_view_btree_partition(const char* bytes, size_t len) { in decode_view_btree_partition()
73 const char* bytes, size_t len) { in decode_view_btree_partition_and_num_values()
144 couchstore_error_t decode_view_id_btree_value(const char *bytes, in decode_view_id_btree_value()
H A Dreductions.cc19 const char* bytes, size_t len, bitmap_t& partitions_bitmap) { in decode_view_btree_reduction_partitions_bitmap()
30 couchstore_error_t decode_view_btree_reduction(const char* bytes, in decode_view_btree_reduction()
163 couchstore_error_t decode_view_id_btree_reduction(const char *bytes, in decode_view_id_btree_reduction()
/trunk/kv_engine/tests/dbgvar/
H A Ddbgvar_test.cc112 auto bytes = stackCapture([](auto& capture) { in TEST_F() local
126 auto bytes = stackCapture([&](auto& capture) { in TEST_F() local
137 auto bytes = stackCapture([](auto& capture) { in TEST_F() local
150 auto bytes = stackCapture([](auto& capture) { in TEST_F() local
/trunk/goproj/src/github.com/couchbase/gometa/message/
Dprotocol.proto25 required bytes content = 7; field
82 required bytes content = 5; field
90 required bytes content = 5; field
105 optional bytes content = 5; field
/trunk/libcouchbase/include/memcached/
H A Dprotocol_binary.h431 uint8_t bytes[24]; member
450 uint8_t bytes[24]; member
460 uint8_t bytes[sizeof(protocol_binary_request_header)]; member
470 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
506 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
622 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
648 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
674 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
700 uint8_t bytes[sizeof(protocol_binary_request_header) + 3]; member
709 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
[all …]
/trunk/couchstore/src/
H A Dutil.cc49 fatbuf *fatbuf_alloc(size_t bytes) in fatbuf_alloc()
64 void *fatbuf_get(fatbuf *fb, size_t bytes) in fatbuf_get()
/trunk/forestdb/tests/functional/
H A Dfunctional_util.cc36 int _disk_dump(const char *filepath, size_t pos, size_t bytes) { in _disk_dump()
/trunk/kv_engine/engines/ep/src/dcp/
H A Dflow-control.cc79 void FlowControl::incrFreedBytes(uint32_t bytes) in incrFreedBytes()
H A Dbackfill-manager.cc214 bool BackfillManager::bytesCheckAndRead(size_t bytes) { in bytesCheckAndRead()
246 void BackfillManager::bytesSent(size_t bytes) { in bytesSent()
H A Dproducer.cc81 bool DcpProducer::BufferLog::insert(size_t bytes) { in insert()
93 void DcpProducer::BufferLog::release_UNLOCKED(size_t bytes) { in release_UNLOCKED()
134 void DcpProducer::BufferLog::acknowledge(size_t bytes) { in acknowledge()
1486 bool DcpProducer::recordBackfillManagerBytesRead(size_t bytes) { in recordBackfillManagerBytesRead()
1490 void DcpProducer::recordBackfillManagerBytesSent(size_t bytes) { in recordBackfillManagerBytesSent()
2029 bool DcpProducer::bufferLogInsert(size_t bytes) { in bufferLogInsert()
/trunk/kv_engine/engines/ep/src/
H A Dserialised_dockey.h175 std::array<uint8_t, 1> bytes; variable
/trunk/libcouchbase/example/db/
H A Ddb.c97 void *bytes; in main() local
/trunk/libcouchbase/src/mc/
H A Dcompress.cc152 int mcreq_inflate_value(const void *compressed, size_t ncompressed, const void **bytes, size_t *nby… in mcreq_inflate_value()
/trunk/kv_engine/engines/ep/src/kvstore/
H A Dkvstore_config.h81 void setPeriodicSyncBytes(uint64_t bytes) { in setPeriodicSyncBytes()
/trunk/libcouchbase/contrib/snappy/
H A Dsnappy-sinksource.cc51 char* bytes, size_t n, in AppendAndTakeOwnership()
/trunk/kv_engine/include/memcached/
H A Dprotocol_binary.h58 uint8_t bytes[24]; member
67 uint8_t bytes[24]; member
77 uint8_t bytes[sizeof(protocol_binary_request_header)]; member
87 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
431 uint8_t bytes[sizeof(protocol_binary_request_header) + 3]; member
440 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
579 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
1895 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
1932 uint8_t bytes[sizeof(protocol_binary_request_header) + 8]; member
1992 uint8_t bytes[sizeof(protocol_binary_request_header) + member
[all …]

1234