Home
last modified time | relevance | path

Searched refs:rv (Results 1 - 25 of 770) sorted by relevance

12345678910>>...31

/6.0.3/subjson/tests/
H A Dt_ops.cc81 int rv = Validator::validate(ret, op.parser()); in getNewDoc() local
83 if (rv != JSONSL_ERROR_SUCCESS) { in getNewDoc()
86 EXPECT_EQ(JSONSL_ERROR_SUCCESS, rv) in getNewDoc()
87 << Util::jsonerr(static_cast<jsonsl_error_t>(rv)); in getNewDoc()
122 Error rv = runOp(Command::REMOVE, "address"); in TEST_F() local
123 ASSERT_TRUE(rv.success()); in TEST_F()
130 rv = runOp(Command::DICT_ADD, "address", "\"123 Main St.\""); in TEST_F()
131 ASSERT_TRUE(rv.success()); in TEST_F()
138 rv = runOp(Command::REPLACE, "address", "\"33 Marginal Rd.\""); in TEST_F()
139 ASSERT_TRUE(rv in TEST_F()
160 Error rv; TEST_F() local
206 Error rv = runOp(Command::GET, one_minus_max_path.c_str()); TEST_F() local
238 Error rv = runOp(Command::DICT_UPSERT, "array", "[]"); TEST_F() local
330 Error rv; TEST_F() local
362 Error rv; TEST_F() local
381 Error rv; TEST_F() local
411 Error rv; TEST_F() local
428 Error rv; TEST_F() local
466 Error rv; TEST_F() local
486 Error rv; TEST_F() local
574 Error rv = runOp(Command::COUNTER, "counter", "1"); TEST_F() local
604 Error rv; TEST_F() local
660 Error rv = runOp(Command::GET, "[-1]"); TEST_F() local
702 Error rv; TEST_F() local
724 Error rv; TEST_F() local
753 Error rv; TEST_F() local
772 Error rv = runOp(Command::GET, "dummy.path"); TEST_F() local
806 Error rv = runOp(Command::GET, max_valid_path.c_str()); TEST_F() local
826 Error rv = runOp(Command::ARRAY_INSERT, "[2]", "3"); TEST_F() local
891 Error rv; TEST_F() local
907 Error rv; TEST_F() local
943 Error rv; TEST_F() local
966 Error rv; TEST_F() local
995 Error rv; TEST_F() local
1201 Error rv = runOp(opinfo.code, path.c_str(), "123"); TEST_F() local
[all...]
H A Dt_validate.cc14 int rv = Validator::validate(txt, NULL); in TEST_F() local
15 ASSERT_EQ(0, rv) << "Simple validation works OK"; in TEST_F()
18 rv = Validator::validate(txt, NULL); in TEST_F()
19 ASSERT_EQ(Validator::EPARTIAL, rv); in TEST_F()
25 int rv = Validator::validate(txt, NULL); in TEST_F() local
26 ASSERT_NE(0, rv) << "Basic mode does not accept primitives (should fail)"; in TEST_F()
28 rv = Validator::validate(txt, NULL, -1, Validator::PARENT_ARRAY); in TEST_F()
29 ASSERT_EQ(0, rv) << "primitive in context of array (ok)"; in TEST_F()
31 rv = Validator::validate(txt, NULL, -1, Validator::PARENT_DICT); in TEST_F()
32 ASSERT_EQ(0, rv) << "primitiv in TEST_F()
64 int rv; TEST_F() local
[all...]
H A Dt_uescape.cc31 auto rv = UescapeConverter::convert(in, out); in TEST_F() local
33 ASSERT_TRUE(rv); in TEST_F()
37 rv = UescapeConverter::convert(in, out); in TEST_F()
38 ASSERT_TRUE(rv); in TEST_F()
43 rv = UescapeConverter::convert(in, out); in TEST_F()
44 ASSERT_FALSE(rv); in TEST_F()
45 ASSERT_EQ(Status::EMBEDDED_NUL, rv.code()); in TEST_F()
54 auto rv = UescapeConverter::convert(in, out); in TEST_F() local
55 ASSERT_TRUE(rv); in TEST_F()
60 rv in TEST_F()
73 auto rv = UescapeConverter::convert(in, out); TEST_F() local
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/search/query/
H A Dquery.go77 var rv FuzzyQuery var
78 err := json.Unmarshal(input, &rv)
82 return &rv, nil
86 var rv TermQuery var
87 err := json.Unmarshal(input, &rv)
91 return &rv, nil
94 var rv MatchQuery var
95 err := json.Unmarshal(input, &rv)
99 return &rv, nil
103 var rv MatchPhraseQuer var
114 var rv BooleanQuery global() var
123 var rv PhraseQuery global() var
138 var rv ConjunctionQuery global() var
147 var rv DisjunctionQuery global() var
157 var rv QueryStringQuery global() var
167 var rv NumericRangeQuery global() var
177 var rv TermRangeQuery global() var
187 var rv DateRangeQuery global() var
196 var rv PrefixQuery global() var
205 var rv RegexpQuery global() var
214 var rv WildcardQuery global() var
223 var rv MatchAllQuery global() var
232 var rv MatchNoneQuery global() var
241 var rv DocIDQuery global() var
250 var rv BoolFieldQuery global() var
260 var rv GeoBoundingBoxQuery global() var
269 var rv GeoDistanceQuery global() var
[all...]
/6.0.3/goproj/src/github.com/couchbase/query/value/
H A Dset.go199 rv := len(this.booleans) + len(this.floats) + len(this.ints) + len(this.strings) +
203 rv++
207 rv++
211 rv++
214 return rv
222 rv := make([]Value, 0, this.Len())
225 rv = append(rv, nil)
229 rv = append(rv, thi
[all...]
/6.0.3/testrunner/pytests/subdoc/
H A Dsubdoc_xattr_sdk.py71 rv = self.client.mutate_in(k, SD.upsert('my.attr', 'value',
74 self.assertTrue(rv.success)
81 rv = self.client.retrieve_in(k, 'my.attr')
82 self.assertFalse(rv.success)
83 self.assertFalse(rv.exists('my.attr'))
86 rv = self.client.lookup_in(k, SD.get('my.attr', xattr=True))
87 self.assertTrue(rv.exists('my.attr'))
88 self.assertEqual('value', rv['my.attr'])
98 rv = self.client.mutate_in(k, SD.upsert('new_my.new_attr', 'new_value',
102 self.assertTrue(rv
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/index/scorch/segment/zap/
H A Ddict.go47 func (d *Dictionary) postingsList(term []byte, except *roaring.Bitmap, rv *PostingsList) (*PostingsList, error) {
49 if rv == nil || rv == emptyPostingsList {
52 return d.postingsListInit(rv, except), nil
60 if rv == nil || rv == emptyPostingsList {
63 return d.postingsListInit(rv, except), nil
66 return d.postingsListFromOffset(postingsOffset, except, rv)
69 func (d *Dictionary) postingsListFromOffset(postingsOffset uint64, except *roaring.Bitmap, rv *PostingsList) (*PostingsList, error) {
70 rv
[all...]
H A Dposting.go156 rv *PostingsIterator) *PostingsIterator {
157 if rv == nil {
158 rv = &PostingsIterator{}
160 freqNormReader := rv.freqNormReader
165 locReader := rv.locReader
170 freqChunkOffsets := rv.freqChunkOffsets[:0]
171 locChunkOffsets := rv.locChunkOffsets[:0]
173 nextLocs := rv.nextLocs[:0]
174 nextSegmentLocs := rv.nextSegmentLocs[:0]
176 buf := rv
[all...]
/6.0.3/godeps/src/github.com/couchbase/dparval/
H A Dvalue.go53 rv := Value{
67 rv.parsedValue = newParsedVal
73 rv.parsedValue = newParsedVal
75 rv.parsedValue = this.parsedValue
80 rv.attachments = make(map[string]interface{}, len(this.attachments))
82 rv.attachments[k] = v
86 return &rv
114 rv := Value{
122 rv.parsedType = NOT_JSON
124 rv
318 var rv interface{} global() var
[all...]
/6.0.3/ns_server/priv/public/ui/app/components/
H A Dmn_tasks_details.js16 // if (!rv.rebalancing) {
32 var rv = {};
35 rv.tasks = tasks;
36 rv.tasksXDCR = _.filter(tasks, detectXDCRTask);
37 rv.tasksRecovery = _.detect(tasks, detectRecoveryTasks);
38 rv.tasksRebalance = _.detect(tasks, detectRebalanceTasks);
39 rv.tasksWarmingUp = _.filter(tasks, detectWarmupTask);
40 rv.inRebalance = !!(rv.tasksRebalance && rv
[all...]
/6.0.3/couchstore/tests/
H A Dtest_fileops.cc73 auto rv = wrapped_ops->constructor(errinfo); in constructor() local
74 std::cerr << "@constructor(" << errinfo << ") -> " << rv << std::endl; in constructor()
75 return rv; in constructor()
81 auto rv = wrapped_ops->open(errinfo, handle, path, oflag); in open() local
83 << oflag << ") -> " << rv << std::endl; in open()
84 return rv; in open()
89 auto rv = wrapped_ops->close(errinfo, handle); in close() local
91 << rv << std::endl; in close()
92 return rv; in close()
98 auto rv in pread() local
107 auto rv = wrapped_ops->pwrite(errinfo, handle, buf, nbytes, offset); pwrite() local
115 auto rv = wrapped_ops->goto_eof(errinfo, handle); goto_eof() local
123 auto rv = wrapped_ops->sync(errinfo, handle); sync() local
133 auto rv = wrapped_ops->advise(errinfo, handle, offset, len, advice); advise() local
140 auto rv = wrapped_ops->set_tracing_enabled(handle); set_tracing_enabled() local
148 auto rv = wrapped_ops->set_write_validation_enabled(handle); set_write_validation_enabled() local
155 auto rv = wrapped_ops->set_mprotect_enabled(handle); set_mprotect_enabled() local
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/search/searcher/
H A Dsearch_numeric_range.go79 terms [][]byte, field string) (rv [][]byte, err error) {
89 rv = append(rv, []byte(tfd.Term))
96 return rv, err
110 rv = append(rv, terms[i])
120 return rv, err
129 var rv [][]byte var
132 rv = append(rv, nex
154 var rv [][]byte global() var
[all...]
/6.0.3/ns_server/priv/public/ui/app/mn_admin/mn_servers/
H A Dmn_servers_service.js193 var rv = _.clone(node);
194 rv.confirmation = false;
195 rv.down = node.status != 'healthy';
196 rv.backfill = node.replication < 1;
197 rv.failOver = rv.down ? "failOver" : node.gracefulFailoverPossible ? "startGracefulFailover" : "failOver";
198 rv.gracefulFailoverPossible = node.gracefulFailoverPossible;
199 rv.down && (rv.failOver = 'failOver');
200 !rv
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/index/upsidedown/
H A Ddump.go29 func dumpPrefix(kvreader store.KVReader, rv chan interface{}, prefix []byte) {
38 rv <- cerr
49 rv <- err
52 rv <- row
59 func dumpRange(kvreader store.KVReader, rv chan interface{}, start, end []byte) {
64 rv <- cerr
75 rv <- err
78 rv <- row
86 rv := make(chan interface{})
88 defer close(rv)
[all...]
/6.0.3/goproj/src/github.com/couchbase/query/expression/
H A Dfunc_comp.go33 rv := &Greatest{
37 rv.expr = rv
38 return rv
55 rv := value.NULL_VALUE
59 } else if rv == value.NULL_VALUE {
60 rv = a
61 } else if a.Collate(rv) > 0 {
62 rv = a
66 return rv, ni
[all...]
H A Dfunc_num.go34 rv := &Abs{
38 rv.expr = rv
39 return rv
97 rv := &Acos{
101 rv.expr = rv
102 return rv
157 rv := &Asin{
161 rv
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/document/
H A Dindexing_options.go43 rv := ""
45 rv += "INDEXED"
48 if rv != "" {
49 rv += ", "
51 rv += "STORE"
54 if rv != "" {
55 rv += ", "
57 rv += "TV"
60 if rv != "" {
61 rv
[all...]
/6.0.3/ns_server/priv/public/ui/app/mn_admin/mn_security/mn_user_roles/
H A Dmn_user_roles_service.js47 var rv = new Array(8);
51 case "admin": rv[0] = role; break;
52 case "cluster_admin": rv[1] = role; break;
53 case "security_admin": rv[2] = role; break;
54 case "ro_admin": rv[3] = role; break;
55 case "replication_admin": rv[4] = role; break;
56 case "query_external_access": rv[5] = role; break;
57 case "query_system_catalog": rv[6] = role; break;
58 case "analytics_reader": rv[7] = role; break;
59 default: rv
[all...]
/6.0.3/godeps/src/github.com/blevesearch/blevex/rocksdb/
H A Dstore.go52 rv := Store{
59 rv.opts.SetMergeOperator(mo)
62 _, err := applyConfig(rv.opts, config)
69 rv.db, err = gorocksdb.OpenDbForReadOnly(rv.opts, rv.path, false)
71 rv.db, err = gorocksdb.OpenDb(rv.opts, rv.path)
80 rv
[all...]
/6.0.3/godeps/src/github.com/couchbase/moss/
H A Dcollection_stats.go23 rv := &CollectionStats{}
25 m.stats.AtomicCopyTo(rv)
28 m.statsSegmentsLOCKED(rv)
31 return rv, nil
41 func (m *collection) statsSegmentsLOCKED(rv *CollectionStats) {
68 rv.CurDirtyOps = sssDirty.CurOps
69 rv.CurDirtyBytes = sssDirty.CurBytes
70 rv.CurDirtySegments = sssDirty.CurSegments
73 rv.CurDirtyTopOps = sssDirtyTop.CurOps
74 rv
[all...]
/6.0.3/goproj/src/github.com/couchbase/query/planner/
H A Dbuild_indexgroup.go26 rv := &PartialAggCoverer{
31 rv.SetMapper(rv)
32 rv.SetMapFunc(func(expr expression.Expression) (expression.Expression, error) {
34 if rv.matchCover != nil {
35 return rv.matchCover, nil
42 prevMatchCover := rv.matchCover
44 rv.matchCover = prevMatchCover
46 rv.matchCover = nil
51 return indexPartialAggregateAvg2DivisionRewrite(agg, rv
[all...]
/6.0.3/moxi/src/
H A Dgenhash.c24 int rv=0; in estimate_table_size() local
31 rv=prime_size_table[magn]; in estimate_table_size()
32 return rv; in estimate_table_size()
37 genhash_t* rv=NULL; in genhash_init() local
51 rv=calloc(1, sizeof(genhash_t) in genhash_init()
53 cb_assert(rv != NULL); in genhash_init()
54 rv->size=size; in genhash_init()
55 rv->ops=ops; in genhash_init()
57 return rv; in genhash_init()
125 void *rv in genhash_find() local
139 enum update_type rv=0; genhash_update() local
168 enum update_type rv=0; genhash_fun_update() local
200 int rv=0; genhash_delete() local
235 int rv=0; genhash_delete_all() local
288 int rv=0; genhash_size() local
297 int rv=0; genhash_size_for_key() local
325 int rv=5381; genhash_string_hash() local
[all...]
/6.0.3/platform/src/
H A Dcb_pthreads.cc184 int rv = pthread_mutex_init(mutex, NULL); in cb_mutex_initialize() local
185 if (rv != 0) { in cb_mutex_initialize()
186 throw std::system_error(rv, std::system_category(), in cb_mutex_initialize()
193 int rv = pthread_mutex_destroy(mutex); in cb_mutex_destroy() local
194 if (rv != 0) { in cb_mutex_destroy()
195 throw std::system_error(rv, std::system_category(), in cb_mutex_destroy()
202 int rv = pthread_mutex_lock(mutex); in cb_mutex_enter() local
203 if (rv != 0) { in cb_mutex_enter()
204 throw std::system_error(rv, std::system_category(), in cb_mutex_enter()
215 int rv in cb_mutex_exit() local
224 int rv = pthread_cond_init(cond, NULL); cb_cond_initialize() local
233 int rv = pthread_cond_destroy(cond); cb_cond_destroy() local
242 int rv = pthread_cond_wait(cond, mutex); cb_cond_wait() local
251 int rv = pthread_cond_signal(cond); cb_cond_signal() local
260 int rv = pthread_cond_broadcast(cond); cb_cond_broadcast() local
290 int rv = pthread_cond_timedwait(cond, mutex, &ts); cb_cond_timedwait() local
383 int rv = pthread_rwlock_init(rw, NULL); cb_rw_lock_initialize() local
392 int rv = pthread_rwlock_destroy(rw); cb_rw_lock_destroy() local
[all...]
/6.0.3/goproj/src/github.com/couchbase/cbft/
H A Dunmarshal.go387 var rv query.FuzzyQuery var
388 err := jsoniter.Unmarshal(input, &rv)
392 return &rv, nil
396 var rv query.TermQuery var
397 err := jsoniter.Unmarshal(input, &rv)
401 return &rv, nil
404 var rv query.MatchQuery var
405 err := jsoniter.Unmarshal(input, &rv)
409 return &rv, nil
413 var rv quer var
424 var rv query.BooleanQuery global() var
433 var rv query.PhraseQuery global() var
448 var rv query.ConjunctionQuery global() var
457 var rv query.DisjunctionQuery global() var
467 var rv query.QueryStringQuery global() var
477 var rv query.NumericRangeQuery global() var
487 var rv query.TermRangeQuery global() var
497 var rv query.DateRangeQuery global() var
506 var rv query.PrefixQuery global() var
515 var rv query.RegexpQuery global() var
524 var rv query.WildcardQuery global() var
533 var rv query.MatchAllQuery global() var
542 var rv query.MatchNoneQuery global() var
551 var rv query.DocIDQuery global() var
560 var rv query.BoolFieldQuery global() var
570 var rv query.GeoBoundingBoxQuery global() var
579 var rv query.GeoDistanceQuery global() var
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/analysis/
H A Dfreq.go46 rv := reflectStaticSizeTokenLocation
47 rv += len(tl.ArrayPositions) * size.SizeOfUint64
48 return rv
60 rv := reflectStaticSizeTokenFreq
61 rv += len(tf.Term)
63 rv += loc.Size()
65 return rv
77 rv := size.SizeOfMap
78 rv += len(tfs) * (size.SizeOfString + size.SizeOfPtr)
80 rv
[all...]

Completed in 34 milliseconds

12345678910>>...31