Home
last modified time | relevance | path

Searched refs:bytes (Results 1 - 25 of 514) sorted by relevance

12345678910>>...21

/5.5.2/godeps/src/github.com/blevesearch/bleve/analysis/lang/hi/
H A Dhindi_stemmer_filter.go18 "bytes"
50 (bytes.HasSuffix(input, []byte("ाएंगी")) ||
51 bytes.HasSuffix(input, []byte("ाएंगे")) ||
52 bytes.HasSuffix(input, []byte("ाऊंगी")) ||
53 bytes.HasSuffix(input, []byte("ाऊंगा")) ||
54 bytes.HasSuffix(input, []byte("ाइयाँ")) ||
55 bytes.HasSuffix(input, []byte("ाइयों")) ||
56 bytes.HasSuffix(input, []byte("ाइयां"))) {
62 (bytes.HasSuffix(input, []byte("ाएगी")) ||
63 bytes
[all...]
/5.5.2/kv_engine/tests/testapp/
H A Dtestapp_tests.cc64 char bytes[1024]; in test_noop() member
67 size_t len = mcbp_raw_command(buffer.bytes, sizeof(buffer.bytes), in test_noop()
71 safe_send(buffer.bytes, len, false); in test_noop()
72 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_noop()
85 char bytes[1024]; in test_quit_impl() member
87 size_t len = mcbp_raw_command(buffer.bytes, sizeof(buffer.bytes), in test_quit_impl()
90 safe_send(buffer.bytes, le in test_quit_impl()
116 char bytes[1024]; test_set_impl() member
164 char bytes[1024]; test_add_impl() member
211 char bytes[1024]; test_replace_impl() member
260 char bytes[1024]; test_delete_impl() member
306 char bytes[1024]; test_delete_cas_impl() member
357 char bytes[1024]; test_get_impl() member
382 char bytes[1024]; test_get_impl() member
413 char bytes[1024]; test_getq_impl() member
457 char bytes[1024]; test_incr_impl() member
493 char bytes[1024]; test_incr_invalid_cas_impl() member
526 char bytes[1024]; test_decr_impl() member
582 char bytes[1024]; TEST_P() member
599 char bytes[1024]; TEST_P() member
638 char bytes[1024]; test_concat_impl() member
726 char bytes[1024]; TEST_P() member
746 char bytes[2048]; TEST_P() member
789 char bytes[65 * 1024]; test_pipeline_hickup_chunk() member
905 char bytes[1024]; TEST_P() member
926 char bytes[1024]; TEST_P() member
1037 char bytes[2048]; TEST_P() member
1062 char bytes[1024]; TEST_P() member
1082 char bytes[1024]; TEST_P() member
1103 char bytes[1024]; TEST_P() member
1130 char bytes[2048]; TEST_P() member
1161 char bytes[1024]; TEST_P() member
1295 char bytes[1024]; TEST_P() member
1333 char bytes[1024]; TEST_P() member
1354 char bytes[1024]; TEST_P() member
1374 char bytes[1024]; TEST_P() member
1398 char bytes[1024]; TEST_P() member
1491 char bytes[1024]; TEST_P() member
1642 char bytes[1024]; get_session_ctrl_token() member
1678 char bytes[1024]; TEST_P() member
1733 char bytes[100100]; TEST_P() member
1770 char bytes[1024]; TEST_P() member
1807 char bytes[1024]; TEST_P() member
1856 char bytes[1024]; TEST_P() member
1918 char bytes[1024]; test_expiry() member
2260 char bytes[1024]; TEST_P() member
2286 char bytes[8192]; get_topkeys_legacy_value() member
2365 char bytes[10000]; get_topkeys_json_value() member
2450 char bytes[1024]; test_set_topkeys() member
2489 char bytes[2048]; test_get_topkeys() member
2525 char bytes[1024]; test_delete_topkeys() member
2570 char bytes[1024]; TEST_P() member
2596 char bytes[1024]; TEST_P() member
[all...]
H A Dsaslauthd_mock.cc142 std::vector<uint8_t> bytes(2); in sendResult()
143 memcpy(bytes.data(), &length, sizeof(length)); in sendResult()
144 retrySend(client, bytes); in sendResult()
145 bytes.resize(msg.size()); in sendResult()
146 memcpy(bytes.data(), msg.data(), msg.size()); in sendResult()
147 retrySend(client, bytes); in sendResult()
151 void SaslauthdMock::retrySend(int client, const std::vector<uint8_t>& bytes) { in retrySend() argument
155 client, bytes.data() + offset, bytes.size() - offset, 0); in retrySend()
163 if (offset == bytes in retrySend()
[all...]
H A Dtestapp_audit.cc141 char bytes[1024]; in TEST_P() member
145 size_t len = mcbp_storage_command(send.bytes, sizeof(send.bytes), in TEST_P()
154 safe_send(send.bytes, len - diff, false); in TEST_P()
156 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in TEST_P()
177 char bytes[1024]; in TEST_P() member
184 size_t plen = mcbp_raw_command(buffer.bytes, sizeof(buffer.bytes), in TEST_P()
189 safe_send(buffer.bytes, ple in TEST_P()
[all...]
H A Dsubdoc_encoder.cc38 char bytes[sizeof(protocol_binary_subdoc_multi_lookup_spec)]; in encode() member
44 std::copy(&encoded.bytes[0], in encode()
45 &encoded.bytes[sizeof(encoded.spec)], in encode()
66 char bytes[sizeof(protocol_binary_subdoc_multi_mutation_spec)]; in encode() member
73 std::copy(&encoded.bytes[0], in encode()
74 &encoded.bytes[sizeof(encoded.spec)], in encode()
102 char bytes[sizeof(uint32_t)]; in encode_common() member
105 std::copy(&u.bytes[0], in encode_common()
106 &u.bytes[sizeof(uint32_t)], in encode_common()
H A Dtestapp.cc151 char bytes[1024]; in DeleteTestBucket() member
154 size_t plen = mcbp_raw_command(buffer.bytes, in DeleteTestBucket()
155 sizeof(buffer.bytes), in DeleteTestBucket()
162 safe_send(buffer.bytes, plen, false); in DeleteTestBucket()
234 char bytes[1024]; in get_sasl_mechs() member
237 size_t plen = mcbp_raw_command(buffer.bytes, sizeof(buffer.bytes), in get_sasl_mechs()
241 safe_send(buffer.bytes, plen, false); in get_sasl_mechs()
248 ret.assign(buffer.bytes + sizeof(buffer.response.bytes), in get_sasl_mechs()
329 char bytes[1024]; sasl_auth() member
865 char bytes[1024]; set_feature() member
915 char bytes[1024]; fetch_value() member
939 char bytes[1024]; validate_object() member
964 char bytes[1024]; validate_flags() member
987 char bytes[1024]; delete_object() member
1041 char bytes[1024]; store_object_w_datatype() member
1368 char bytes[1024]; ewouldblock_engine_configure() member
1637 char bytes[1024]; request_stats() member
1692 char bytes[1024]; adjust_memcached_clock() member
[all...]
/5.5.2/goproj/src/github.com/couchbase/cbft/
H A Dbindata_assetfs.go58 "bytes"
71 gz, err := gzip.NewReader(bytes.NewBuffer(data))
76 var buf bytes.Buffer
91 bytes []byte
131 bytes, err := staticxCssCbftCssBytes()
137 a := &asset{bytes: bytes, info: info}
151 bytes, err := staticxIndexFtHtmlBytes()
157 a := &asset{bytes: bytes, inf
[all...]
/5.5.2/goproj/src/github.com/couchbase/cbgt/rest/
H A Dbindata_assetfs.go107 "bytes"
120 gz, err := gzip.NewReader(bytes.NewBuffer(data))
125 var buf bytes.Buffer
140 bytes []byte
180 bytes, err := staticCssAppCssBytes()
186 a := &asset{bytes: bytes, info: info}
200 bytes, err := staticCssBootstrapThemeCssBytes()
206 a := &asset{bytes: bytes, inf
[all...]
/5.5.2/godeps/src/github.com/blevesearch/bleve/analysis/lang/ckb/
H A Dsorani_stemmer_filter.go18 "bytes"
49 if inputLen > 5 && bytes.HasSuffix(input, []byte("دا")) {
52 } else if inputLen > 4 && bytes.HasSuffix(input, []byte("نا")) {
55 } else if inputLen > 6 && bytes.HasSuffix(input, []byte("ەوە")) {
62 (bytes.HasSuffix(input, []byte("مان")) ||
63 bytes.HasSuffix(input, []byte("یان")) ||
64 bytes.HasSuffix(input, []byte("تان"))) {
70 if inputLen > 6 && bytes.HasSuffix(input, []byte("ێکی")) {
72 } else if inputLen > 7 && bytes.HasSuffix(input, []byte("یەکی")) {
76 if inputLen > 5 && bytes
[all...]
/5.5.2/godeps/src/github.com/blevesearch/bleve-mapping-ui/
H A Dbindata_assetfs.go46 "bytes"
59 gz, err := gzip.NewReader(bytes.NewBuffer(data))
64 var buf bytes.Buffer
79 bytes []byte
119 bytes, err := staticBleveMappingJsMappingAnalysisAnalyzerJsBytes()
125 a := &asset{bytes: bytes, info: info}
139 bytes, err := staticBleveMappingJsMappingAnalysisCharfilterJsBytes()
145 a := &asset{bytes: bytes, inf
[all...]
/5.5.2/godeps/src/github.com/couchbase/gocb/
H A Dtranscoding.go10 // from raw bytes for storage and retreival from Couchbase data storage.
12 // Decodes retrieved bytes into a Go type.
15 // Encodes a Go type into bytes for storage.
25 func (t DefaultTranscoder) Decode(bytes []byte, flags uint32, out interface{}) error {
37 *typedOut = bytes
40 *typedOut = bytes
48 *typedOut = string(bytes)
51 *typedOut = string(bytes)
57 err := json.Unmarshal(bytes, &out)
69 var bytes []byt var
[all...]
H A Dtranscoding_test.go28 func testDecode(t *testing.T, bytes []byte, flags uint32, out interface{}) {
29 err := defaultTranscoder.Decode(bytes, flags, out)
36 bytes, flags, err := defaultTranscoder.Encode(in)
40 return bytes, flags
123 bytes, flags := testEncode(t, &testIn)
127 testBytesEqual(t, bytes, jsonObjStr)
135 bytes, flags := testEncode(t, &testIn)
139 testBytesEqual(t, bytes, jsonObjStr)
144 bytes, flags := testEncode(t, &testIn)
148 testBytesEqual(t, bytes, jsonNumSt
[all...]
/5.5.2/kv_engine/daemon/protocol/mcbp/
H A Dship_dcp_log.cc72 return add_packet_to_pipe(c, {packet.bytes, sizeof(packet.bytes)}); in dcp_message_get_failover_log()
101 return add_packet_to_pipe(c, {packet.bytes, sizeof(packet.bytes)}); in dcp_message_stream_req()
121 return add_packet_to_pipe(c, {packet.bytes, sizeof(packet.bytes)}); in dcp_message_add_stream_response()
139 return add_packet_to_pipe(c, {packet.bytes, sizeof(packet.bytes)}); in dcp_message_marker_response()
157 return add_packet_to_pipe(c, {packet.bytes, sizeof(packet.bytes)}); in dcp_message_set_vbucket_state_response()
[all...]
/5.5.2/couchstore/src/views/
H A Dvalues.cc20 couchstore_error_t decode_view_btree_value(const char *bytes, in decode_view_btree_value() argument
38 v->partition = dec_uint16(bytes); in decode_view_btree_value()
39 bytes += 2; in decode_view_btree_value()
48 bs = bytes; in decode_view_btree_value()
84 sz = dec_raw24(bytes); in decode_view_btree_value()
85 bytes += 3; in decode_view_btree_value()
95 memcpy(v->values[i].buf, bytes, sz); in decode_view_btree_value()
96 bytes += sz; in decode_view_btree_value()
171 couchstore_error_t decode_view_id_btree_value(const char *bytes, in decode_view_id_btree_value() argument
188 v->partition = dec_uint16(bytes); in decode_view_id_btree_value()
[all...]
H A Dreductions.cc24 couchstore_error_t decode_view_btree_reduction(const char *bytes, in decode_view_btree_reduction() argument
40 r->kv_count = dec_uint40(bytes); in decode_view_btree_reduction()
41 bytes += 5; in decode_view_btree_reduction()
45 memcpy(&r->partitions_bitmap, bytes, BITMASK_BYTE_SIZE); in decode_view_btree_reduction()
46 bytes += BITMASK_BYTE_SIZE; in decode_view_btree_reduction()
49 bs = bytes; in decode_view_btree_reduction()
89 sz = dec_uint16(bytes); in decode_view_btree_reduction()
90 bytes += 2; in decode_view_btree_reduction()
100 memcpy(r->reduce_values[i].buf, bytes, sz); in decode_view_btree_reduction()
101 bytes in decode_view_btree_reduction()
175 decode_view_id_btree_reduction(const char *bytes, view_id_btree_reduction_t **reduction) decode_view_id_btree_reduction() argument
[all...]
H A Dkeys.cc16 couchstore_error_t decode_view_btree_key(const char *bytes, in decode_view_btree_key() argument
32 sz = dec_uint16(bytes); in decode_view_btree_key()
34 bytes += 2; in decode_view_btree_key()
45 memcpy(k->json_key.buf, bytes, sz); in decode_view_btree_key()
46 bytes += sz; in decode_view_btree_key()
59 memcpy(k->doc_id.buf, bytes, len); in decode_view_btree_key()
119 couchstore_error_t decode_view_id_btree_key(const char *bytes, in decode_view_id_btree_key() argument
133 k->partition = dec_uint16(bytes); in decode_view_id_btree_key()
134 bytes += 2; in decode_view_id_btree_key()
145 memcpy(k->doc_id.buf, bytes, le in decode_view_id_btree_key()
[all...]
/5.5.2/kv_engine/protocol/mcbp/libmcbp/
H A Ddump.cc74 McbpFrame(const uint8_t* bytes, size_t len) in McbpFrame() argument
75 : root(bytes), in McbpFrame()
102 << " bytes of binary data" << std::endl; in dumpExtras()
118 << " bytes of binary data" << std::endl; in dumpKey()
199 : McbpFrame(req.bytes, ntohl(req.request.bodylen) + sizeof(req.bytes)), in Request()
209 out << " Total " << sizeof(request) + bodylen << " bytes";
211 out << " (" << sizeof(request) << " bytes header";
217 out << ", " << keylen << " bytes key";
231 out << " Magic (0) : 0x" << (uint32_t(request.bytes[
[all...]
/5.5.2/goproj/src/github.com/couchbase/query/expression/
H A Dstringer.go13 "bytes"
44 var buf bytes.Buffer
60 var buf bytes.Buffer
70 var buf bytes.Buffer
80 var buf bytes.Buffer
96 var buf bytes.Buffer
104 var buf bytes.Buffer
116 var buf bytes.Buffer
136 var buf bytes.Buffer
159 var buf bytes
[all...]
/5.5.2/goproj/src/github.com/couchbase/query/server/http/
H A Dservice_buffer_pool.go13 "bytes"
17 // BufferPool provides an API for managing bytes.Buffer objects:
19 GetBuffer() *bytes.Buffer
20 PutBuffer(*bytes.Buffer)
36 var b bytes.Buffer
51 func (bp *syncPoolBufPool) GetBuffer() *bytes.Buffer {
52 return bp.pool.Get().(*bytes.Buffer)
55 func (bp *syncPoolBufPool) PutBuffer(b *bytes.Buffer) {
/5.5.2/couchstore/src/
H A Dutil.cc43 fatbuf *fatbuf_alloc(size_t bytes) in fatbuf_alloc() argument
45 fatbuf *fb = (fatbuf *) cb_malloc(sizeof(fatbuf) + bytes); in fatbuf_alloc()
47 memset(fb->buf, 0x44, bytes); in fatbuf_alloc()
53 fb->size = bytes; in fatbuf_alloc()
58 void *fatbuf_get(fatbuf *fb, size_t bytes) in fatbuf_get() argument
60 if (fb->pos + bytes > fb->size) { in fatbuf_get()
64 if (fb->buf[fb->pos] != 0x44 && bytes > 0) { in fatbuf_get()
69 fb->pos += bytes; in fatbuf_get()
/5.5.2/goproj/src/github.com/couchbase/indexing/secondary/indexer/
H A Dindex_entry_test.go4 "bytes"
20 if !bytes.Equal(pk1, buf) {
26 if !bytes.Equal(nil, buf) {
30 if !bytes.Equal(pk1, e.Bytes()) {
38 if !bytes.Equal(pk1, buf) {
44 if !bytes.Equal(nil, buf) {
48 if !bytes.Equal(pk1, e2.Bytes()) {
63 if !bytes.Equal(docid, buf) {
69 if !bytes.Equal(sk1, buf) {
77 if !bytes
[all...]
/5.5.2/kv_engine/engines/ep/src/dcp/
H A Dbackfill-manager.cc178 bool BackfillManager::bytesCheckAndRead(size_t bytes) { in bytesCheckAndRead() argument
186 if (scanBuffer.bytesRead + bytes <= scanBuffer.maxBytes || in bytesCheckAndRead()
188 scanBuffer.bytesRead += bytes; in bytesCheckAndRead()
194 if (buffer.bytesRead == 0 || buffer.bytesRead + bytes <= buffer.maxBytes) { in bytesCheckAndRead()
195 buffer.bytesRead += bytes; in bytesCheckAndRead()
197 scanBuffer.bytesRead -= bytes; in bytesCheckAndRead()
199 buffer.nextReadSize = bytes; in bytesCheckAndRead()
208 void BackfillManager::bytesForceRead(size_t bytes) { in bytesForceRead() argument
214 scanBuffer.bytesRead += bytes; in bytesForceRead()
215 buffer.bytesRead += bytes; in bytesForceRead()
226 bytesSent(size_t bytes) bytesSent() argument
[all...]
/5.5.2/goproj/src/github.com/couchbase/query/datastore/couchbase/
H A Dview_template.go10 var bytes = []; var
12 bytes.push(str.charCodeAt(i));
14 return bytes;
86 var bytes = []; var
88 bytes.push(str.charCodeAt(i));
90 return bytes;
/5.5.2/goproj/src/github.com/couchbase/goxdcr/metadata_svc/
H A Dreplication_settings_service.go40 bytes, rev, err := repl_settings_svc.metadata_svc.Get(DefaultReplicationSettingsKey)
48 err = json.Unmarshal(bytes, &defaultSettings)
61 bytes, err := json.Marshal(settings)
66 return repl_settings_svc.metadata_svc.Set(DefaultReplicationSettingsKey, bytes, settings.Revision)
68 return repl_settings_svc.metadata_svc.Add(DefaultReplicationSettingsKey, bytes)
/5.5.2/moxi/libmemcached/libmemcached/memcached/
H A Dprotocol_binary.h167 uint8_t bytes[24]; member
186 uint8_t bytes[24]; member
196 uint8_t bytes[sizeof(protocol_binary_request_header)]; member
206 uint8_t bytes[sizeof(protocol_binary_response_header)]; member
230 uint8_t bytes[sizeof(protocol_binary_response_header) + 4]; member
262 uint8_t bytes[sizeof(protocol_binary_request_header) + 4]; member
283 uint8_t bytes[sizeof(protocol_binary_request_header) + 8]; member
322 uint8_t bytes[sizeof(protocol_binary_request_header) + 20]; member
338 uint8_t bytes[sizeof(protocol_binary_response_header) + 8]; member
411 uint8_t bytes[sizeo member
[all...]

Completed in 81 milliseconds

12345678910>>...21