Home
last modified time | relevance | path

Searched refs:ss (Results 1 - 25 of 146) sorted by relevance

123456

/6.0.3/subjson/tests/
H A Dt_path.cc46 Path ss; in TEST_F() local
49 ASSERT_EQ(0, ss.parse(pth1)); in TEST_F()
50 ASSERT_EQ(4, ss.size()); in TEST_F()
52 ASSERT_EQ(JSONSL_PATH_ROOT, ss[0].ptype); in TEST_F()
53 ASSERT_EQ(JSONSL_PATH_STRING, ss[1].ptype); in TEST_F()
54 ASSERT_EQ(JSONSL_PATH_STRING, ss[2].ptype); in TEST_F()
55 ASSERT_EQ(JSONSL_PATH_STRING, ss[3].ptype); in TEST_F()
58 ASSERT_EQ("foo", getComponentString(ss, 1)); in TEST_F()
59 ASSERT_EQ("bar", getComponentString(ss, 2)); in TEST_F()
60 ASSERT_EQ("baz", getComponentString(ss, in TEST_F()
68 Path ss; TEST_F() local
98 Path ss; TEST_F() local
130 Path ss; TEST_F() local
147 Path ss; TEST_F() local
163 Path ss; TEST_F() local
176 Path ss; TEST_F() local
[all...]
/6.0.3/godeps/src/github.com/couchbase/moss/
H A Dsegment_stack.go43 func (ss *segmentStack) addRef() {
44 ss.m.Lock()
45 ss.refs++
46 ss.m.Unlock()
49 func (ss *segmentStack) decRef() {
50 ss.m.Lock()
51 ss.refs--
52 if ss.refs <= 0 {
53 if ss.stats != nil { // Only update stats if snapshot is on collection.
54 atomic.AddUint64(&ss
[all...]
H A Dwrap.go23 ss Snapshot
30 func NewSnapshotWrapper(ss Snapshot, closer io.Closer) *SnapshotWrapper {
31 if ss == nil {
35 return &SnapshotWrapper{refCount: 1, ss: ss, closer: closer}
52 if w.ss != nil {
53 err = w.ss.Close()
54 w.ss = nil
69 if w.ss != nil {
70 return w.ss
[all...]
H A Dsegment_stack_merge.go16 func (ss *segmentStack) calcTargetTopLevel() int {
18 if ss.options != nil {
19 minMergePercentage = ss.options.MinMergePercentage
26 maxTopLevel := len(ss.a) - 2
29 numX0 := ss.a[newTopLevel].Len()
30 numX1 := ss.a[newTopLevel+1].Len()
45 func (ss *segmentStack) merge(mergeAll bool, base *segmentStack) (
52 newTopLevel = ss.calcTargetTopLevel()
63 for i := newTopLevel; i < len(ss.a); i++ {
64 totOps += ss
[all...]
/6.0.3/goproj/src/github.com/couchbase/indexing/secondary/indexer/
H A Dstream_state.go90 ss := &StreamState{
122 return ss
126 func (ss *StreamState) initNewStream(streamId common.StreamId) {
130 ss.streamBucketHWTMap[streamId] = bucketHWTMap
133 ss.streamBucketNeedsCommitMap[streamId] = bucketNeedsCommitMap
136 ss.streamBucketHasBuildCompTSMap[streamId] = bucketHasBuildCompTSMap
139 ss.streamBucketNewTsReqdMap[streamId] = bucketNewTsReqdMap
142 ss.streamBucketRestartTsMap[streamId] = bucketRestartTsMap
145 ss.streamBucketOpenTsMap[streamId] = bucketOpenTsMap
148 ss
[all...]
H A Dstats_manager.go528 scanDur := s.int64Stats(func(ss *IndexStats) int64 { return ss.scanDuration.Value() })
529 waitDur := s.int64Stats(func(ss *IndexStats) int64 { return ss.scanWaitDuration.Value() })
530 scanReqDur := s.int64Stats(func(ss *IndexStats) int64 { return ss.scanReqDuration.Value() })
531 scanReqInitDur := s.int64Stats(func(ss *IndexStats) int64 { return ss.scanReqInitDuration.Value() })
532 scanReqAllocDur := s.int64Stats(func(ss *IndexStats) int64 { return ss
[all...]
H A Dtimekeeper.go40 ss *StreamState
88 ss: InitStreamState(config),
239 if tk.ss.streamStatus[streamId] != STREAM_ACTIVE {
240 tk.ss.initNewStream(streamId)
246 status := tk.ss.streamBucketStatus[streamId][bucket]
251 tk.ss.initBucketInStream(streamId, bucket)
253 tk.ss.streamBucketRestartTsMap[streamId][bucket] = restartTs
254 tk.ss.setHWTFromRestartTs(streamId, bucket)
256 tk.ss.setRollbackTime(bucket, rollbackTime)
264 tk.ss
[all...]
H A Dindex_snapshot.go84 func (ss *sliceSnapshot) SliceId() SliceId {
85 return ss.id
88 func (ss *sliceSnapshot) Snapshot() Snapshot {
89 return ss.snap
97 for _, ss := range ps.Slices() {
98 ss.Snapshot().Close()
109 for _, ss := range ps.Slices() {
110 ss.Snapshot().Open()
/6.0.3/godeps/src/github.com/blevesearch/bleve/search/collector/
H A Dsearch_test.go30 func (ss *stubSearcher) Size() int {
31 sizeInBytes := int(reflect.TypeOf(*ss).Size())
33 for _, entry := range ss.matches {
42 func (ss *stubSearcher) Next(ctx *search.SearchContext) (*search.DocumentMatch, error) {
43 if ss.index < len(ss.matches) {
45 rv.IndexInternalID = ss.matches[ss.index].IndexInternalID
46 rv.Score = ss.matches[ss
[all...]
/6.0.3/kv_engine/auditd/src/
H A Dauditfile.cc97 std::stringstream ss; in open() local
98 ss << log_directory << DIRECTORY_SEPARATOR_CHARACTER << "audit.log"; in open()
99 open_file_name = ss.str(); in open()
162 std::stringstream ss; in cleanup_old_logfile()
163 ss << "Audit: Failed to read \"" << filename << "\""; in cleanup_old_logfile()
164 throw ss.str(); in cleanup_old_logfile()
169 std::stringstream ss; in cleanup_old_logfile() local
170 ss << "Audit: Failed to remove \"" << filename << "\": " in cleanup_old_logfile()
172 throw ss.str(); in cleanup_old_logfile()
186 std::stringstream ss; in cleanup_old_logfile() local
194 std::stringstream ss; cleanup_old_logfile() local
204 std::stringstream ss; cleanup_old_logfile() local
212 std::stringstream ss; cleanup_old_logfile() local
222 std::stringstream ss; cleanup_old_logfile() local
240 std::stringstream ss; cleanup_old_logfile() local
[all...]
H A Dauditconfig.cc51 std::stringstream ss; in getObject() local
52 ss << "Incorrect type for \"" << name << "\". Should be "; in getObject()
55 ss << "string"; in getObject()
58 ss << "number"; in getObject()
61 ss << type; in getObject()
64 throw ss.str(); in getObject()
67 std::stringstream ss; in getObject() local
68 ss << "Element \"" << name << "\" is not present."; in getObject()
69 throw ss.str(); in getObject()
120 std::stringstream ss; in AuditConfig() local
138 std::stringstream ss; set_rotate_size() local
154 std::stringstream ss; set_rotate_interval() local
208 std::stringstream ss; set_descriptors_path() local
223 std::stringstream ss; set_version() local
315 std::stringstream ss; set_buffered() local
339 std::stringstream ss; add_array() local
382 std::stringstream ss; add_pair_string_array() local
[all...]
H A Devent.cc33 std::stringstream ss; in filterEventByUserid() local
34 ss << "Incorrect type for \"" << userid_type in filterEventByUserid()
36 throw std::invalid_argument(ss.str()); in filterEventByUserid()
39 std::stringstream ss; in filterEventByUserid() local
40 ss << "Incorrect type for \"" << userid_type in filterEventByUserid()
42 throw std::invalid_argument(ss.str()); in filterEventByUserid()
48 std::stringstream ss; in filterEventByUserid() local
49 ss << "Incorrect type for \"" << userid_type in filterEventByUserid()
51 throw std::invalid_argument(ss.str()); in filterEventByUserid()
/6.0.3/third_party/spdlog/bench/latency/
H A Dutils.h19 std::stringstream ss; in format() local
20 ss.imbue(loc); in format()
21 ss << value; in format()
22 return ss.str(); in format()
29 std::stringstream ss; in format() local
30 ss.imbue(loc); in format()
31 ss << std::fixed << std::setprecision(1) << value; in format()
32 return ss.str(); in format()
/6.0.3/third_party/spdlog/bench/
H A Dutils.h19 std::stringstream ss; in format() local
20 ss.imbue(loc); in format()
21 ss << value; in format()
22 return ss.str(); in format()
29 std::stringstream ss; in format() local
30 ss.imbue(loc); in format()
31 ss << std::fixed << std::setprecision(1) << value; in format()
32 return ss.str(); in format()
/6.0.3/third_party/spdlog/example/
H A Dutils.h19 std::stringstream ss; in format() local
20 ss.imbue(loc); in format()
21 ss << value; in format()
22 return ss.str(); in format()
29 std::stringstream ss; in format() local
30 ss.imbue(loc); in format()
31 ss << std::fixed << std::setprecision(1) << value; in format()
32 return ss.str(); in format()
/6.0.3/kv_engine/engines/ep/src/
H A Ditem_compressor.cc48 std::stringstream ss; in run() local
49 ss << getDescription() << " for bucket '" << engine->getName() << "'"; in run()
51 ss << " starting. "; in run()
53 ss << " resuming from " << epstore_position << ", "; in run()
54 ss << prAdapter->getHashtablePosition() << "."; in run()
56 ss << " Using chunk_duration=" << getChunkDuration().count() << " ms." in run()
58 LOG(EXTENSION_LOG_INFO, "%s", ss.str().c_str()); in run()
83 ss.str(""); in run()
84 ss << getDescription() << " for bucket '" << engine->getName() << "'"; in run()
86 ss << " finishe in run()
[all...]
H A Ditem_freq_decayer.cc56 std::stringstream ss; in run() local
57 ss << getDescription() << " for bucket '" << engine->getName() in run()
60 ss << " starting. "; in run()
62 ss << " resuming from " << epstore_position << ", "; in run()
63 ss << prAdapter->getHashtablePosition() << "."; in run()
65 ss << " Using chunk_duration=" << getChunkDuration().count() << " ms."; in run()
66 LOG(EXTENSION_LOG_INFO, "%s", ss.str().c_str()); in run()
84 ss.str(""); in run()
85 ss << getDescription() << " for bucket '" << engine->getName() in run()
88 ss << " finishe in run()
[all...]
H A Ddefragmenter.cc52 std::stringstream ss; in run() local
53 ss << getDescription() << " for bucket '" in run()
56 ss << " starting. "; in run()
58 ss << " resuming from " << epstore_position << ", "; in run()
59 ss << prAdapter->getHashtablePosition() << "."; in run()
61 ss << " Using chunk_duration=" << getChunkDuration().count() << " ms." in run()
64 LOG(EXTENSION_LOG_INFO, "%s", ss.str().c_str()); in run()
104 ss.str(""); in run()
105 ss << getDescription() << " for bucket '" in run()
108 ss << " finishe in run()
[all...]
/6.0.3/godeps/src/github.com/blevesearch/bleve/index/store/moss/
H A Dreader.go25 ss moss.Snapshot
29 v, err = r.ss.Get(k, moss.ReadOptions{})
46 iter, err := r.ss.StartIterator(k, kEnd, moss.IteratorOptions{})
53 ss: r.ss,
65 iter, err := r.ss.StartIterator(start, end, moss.IteratorOptions{})
72 ss: r.ss,
84 return r.ss.Close()
/6.0.3/goproj/src/github.com/couchbase/cbft/
H A Dpindex_bleve_moss_rollback.go79 var ss, ssPrev moss.Snapshot var
82 ss, err = store.Snapshot()
83 for err == nil && ss != nil {
87 tryRevert, err = mossSnapshotAtOrBeforeSeq(t.path, ss, seqMaxKey,
90 ss.Close()
101 err = store.SnapshotRevert(ss)
103 ss.Close()
108 ssPrev, err = store.SnapshotPrevious(ss)
109 ss.Close()
110 ss
[all...]
/6.0.3/kv_engine/engines/ep/tests/
H A Dep_testsuite_common.h54 std::stringstream ss; in checkeqfn() local
55 ss << "Expected `" << exp << "', got `" << got << "' - " << msg; in checkeqfn()
56 abort_msg(ss.str().c_str(), "", file, linenum); in checkeqfn()
63 std::stringstream ss; in checknefn() local
64 ss << "Expected `" << exp << "' to not equal `" << got << "' - " << msg; in checknefn()
65 abort_msg(ss.str().c_str(), "", file, linenum); in checknefn()
73 std::stringstream ss; in checklefn() local
74 ss << "Expected `" << exp << "' to be less than or equal to `" << got in checklefn()
76 abort_msg(ss.str().c_str(), "", file, linenum); in checklefn()
84 std::stringstream ss; in checkgefn() local
95 std::stringstream ss; checkgtfn() local
[all...]
/6.0.3/goproj/src/github.com/couchbase/indexing/secondary/natsort/
H A Dsort.go126 func (ss stringSlice) Len() int {
127 return len(ss)
130 func (ss stringSlice) Less(i, j int) bool {
131 return Less(ss[i], ss[j])
134 func (ss stringSlice) Swap(i, j int) {
135 ss[i], ss[j] = ss[j], ss[
[all...]
/6.0.3/couchstore/tests/
H A Dcouchstoretest.cc36 std::stringstream ss; in couchstore_test_latency_callback() local
39 ss << " "; in couchstore_test_latency_callback()
40 ss << itr_hist->start() << " us"; in couchstore_test_latency_callback()
41 ss << " -- "; in couchstore_test_latency_callback()
42 ss << itr_hist->end() << " us"; in couchstore_test_latency_callback()
43 ss << ": "; in couchstore_test_latency_callback()
44 ss << itr_hist->count(); in couchstore_test_latency_callback()
45 ss << std::endl; in couchstore_test_latency_callback()
48 std::cout << ss.str(); in couchstore_test_latency_callback()
/6.0.3/testrunner/enginetests/
H A DBaseTest.cc149 std::stringstream ss; in insertItems() local
150 ss << i; in insertItems()
151 ss << "dexpire"; in insertItems()
152 std::string myString = ss.str(); in insertItems()
182 std::stringstream ss; in verifyReplication() local
183 ss << i; in verifyReplication()
184 ss << "replica"; in verifyReplication()
185 std::string myString = ss.str(); in verifyReplication()
203 std::stringstream ss; in verifyReplication() local
204 ss << in verifyReplication()
229 std::stringstream ss; insert_items_instances() local
[all...]
/6.0.3/kv_engine/auditd/generator/
H A Dauditevent_generator.cc70 std::stringstream ss; in load_file() local
71 ss << "Failed to open: " << fname; in load_file()
72 throw ss.str(); in load_file()
79 std::stringstream ss; in load_file() local
80 ss << fname << " contained no data"; in load_file()
81 throw ss.str(); in load_file()
86 std::stringstream ss; in load_file() local
87 ss << "Failed to parse " << fname << " containing: " << std::endl in load_file()
89 throw ss.str(); in load_file()
203 std::stringstream ss; in getMandatoryObject() local
220 std::stringstream ss; getOptionalObject() local
290 std::stringstream ss; validate_events() local
[all...]

Completed in 50 milliseconds

123456