Home
last modified time | relevance | path

Searched refs:id (Results 1 - 25 of 880) sorted by relevance

12345678910>>...36

/6.6.0/godeps/src/github.com/etcd-io/bbolt/
H A Dfreelist_test.go14 f.free(100, &page{id: 12})
23 f.free(100, &page{id: 12, overflow: 3})
32 f.free(100, &page{id: 12, overflow: 1})
33 f.free(100, &page{id: 9})
34 f.free(102, &page{id: 39})
54 id pgid
68 pagesIn: []testPage{{id: 3, n: 1, allocTxn: 100, freeTxn: 200}},
74 pagesIn: []testPage{{id: 3, n: 1, allocTxn: 100, freeTxn: 200}},
80 pagesIn: []testPage{{id: 3, n: 1, allocTxn: 100, freeTxn: 200}},
86 pagesIn: []testPage{{id
[all...]
H A Dfreelist.go75 // allocate returns the starting page id of a contiguous list of pages of a given size.
83 for i, id := range f.ids {
84 if id <= 1 {
85 panic(fmt.Sprintf("invalid page allocation: %d", id))
89 if previd == 0 || id-previd != 1 {
90 initial = id
94 if (id-initial)+1 == pgid(n) {
114 previd = id
119 // free releases a page and its overflow for a given transaction id.
122 if p.id <
[all...]
/6.6.0/godeps/src/google.golang.org/grpc/internal/channelz/
H A Dfuncs.go96 // NewChannelzStorage initializes channelz data storage and id generator.
115 // The arg id specifies that only top channel with id at or above it will be included
117 // sorted in ascending id order.
118 func GetTopChannels(id int64) ([]*ChannelMetric, bool) {
119 return db.get().GetTopChannels(id)
125 // The arg id specifies that only server with id at or above it will be included
127 // sorted in ascending id order.
128 func GetServers(id int6
[all...]
H A Dtypes.go34 // addChild adds a child e, whose channelz id is id to child list
35 addChild(id int64, e entry)
36 // deleteChild deletes a child with channelz id to be id from child list
37 deleteChild(id int64)
54 func (d *dummyEntry) addChild(id int64, e entry) {
63 grpclog.Infof("attempt to add child of type %T with id %d to a parent (id=%d) that doesn't currently exist", e, id,
[all...]
/6.6.0/goproj/src/github.com/couchbase/query/planner/
H A Dprivileges_test.go10 func verifyPrivs(t *testing.T, id string, expectedPrivs *auth.Privileges, gotPrivs *auth.Privileges) {
12 t.Fatalf("Case %s: Unexpected nil in expectedPrivs", id)
15 t.Fatalf("Case %s: Unexpected nil in gotPrivs", id)
18 t.Fatalf("Case %s: privileges are wrong length. Expected %v, got %v.", id, *expectedPrivs, *gotPrivs)
27 t.Fatalf("Case %s: Expected pair %v does not appear in received value %v", id, pair, *gotPrivs)
33 id string
41 t.Fatalf("Case %s: Unable to parse text: %v", c.id, err)
46 t.Fatalf("Case %s: Unable to get privileges of statement: %v", c.id, err)
49 verifyPrivs(t, c.id, c.expectedPrivs, privs)
57 testCase{id
[all...]
/6.6.0/kv_engine/include/memcached/
H A Ddcp_stream_id.h38 explicit DcpStreamId(uint16_t value) : id(value){}; in DcpStreamId()
41 return htons(id); in to_network()
45 if (id != 0) { in to_string()
46 return "sid:" + std::to_string(id); in to_string()
52 return id != 0; in operator bool()
56 return (id < other.id); in operator <()
60 return (id <= other.id); in operator <=()
64 return (id > othe in operator >()
[all...]
/6.6.0/godeps/src/golang.org/x/tools/go/internal/gccgoimporter/
H A Dparser_test.go19 id, typ, want, underlying, methods string
21 {id: "foo", typ: "<type -1>", want: "int8"},
22 {id: "foo", typ: "<type 1 *<type -19>>", want: "*error"},
23 {id: "foo", typ: "<type 1 *any>", want: "unsafe.Pointer"},
24 {id: "foo", typ: "<type 1 \"Bar\" <type 2 *<type 1>>>", want: "foo.Bar", underlying: "*foo.Bar"},
25 {id: "foo", typ: "<type 1 \"bar.Foo\" \"bar\" <type -1> func (? <type 1>) M (); >", want: "bar.Foo", underlying: "int8", methods: "func (bar.Foo).M()"},
26 {id: "foo", typ: "<type 1 \".bar.foo\" \"bar\" <type -1>>", want: "bar.foo", underlying: "int8"},
27 {id: "foo", typ: "<type 1 []<type -1>>", want: "[]int8"},
28 {id: "foo", typ: "<type 1 [42]<type -1>>", want: "[42]int8"},
29 {id
[all...]
/6.6.0/godeps/src/github.com/blevesearch/bleve/index/upsidedown/
H A Dreader_test.go257 t.Errorf("Error accessing doc id reader: %v", err)
266 id, err := reader.Next()
268 for id != nil {
270 id, err = reader.Next()
279 t.Errorf("Error accessing doc id reader: %v", err)
288 id, err = reader2.Advance(index.IndexInternalID("2"))
292 if !id.Equals(index.IndexInternalID("2")) {
293 t.Errorf("expected to find id '2', got '%s'", id)
296 id, er
[all...]
/6.6.0/godeps/src/golang.org/x/tools/godoc/
H A Dsnippet.go24 func (p *Presentation) newSnippet(fset *token.FileSet, decl ast.Decl, id *ast.Ident) *Snippet {
31 FormatText(&buf2, buf1.Bytes(), -1, true, id.Name, nil)
33 return &Snippet{fset.Position(id.Pos()).Line, buf2.String()}
36 func findSpec(list []ast.Spec, id *ast.Ident) ast.Spec {
40 if s.Name == id {
45 if n == id {
50 if s.Name == id {
58 func (p *Presentation) genSnippet(fset *token.FileSet, d *ast.GenDecl, id *ast.Ident) *Snippet {
59 s := findSpec(d.Specs, id)
61 return nil // declaration doesn't contain id
[all...]
/6.6.0/godeps/src/github.com/aws/aws-sdk-go/aws/endpoints/
H A Dendpoints.go255 id: serviceID,
282 id, dnsSuffix string
290 func (p Partition) ID() string { return p.id }
321 for id, r := range p.p.Regions {
322 rs[id] = Region{
323 id: id,
336 for id := range p.p.Services {
337 ss[id] = Service{
338 id
[all...]
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/common/
H A Dkey_partition_container.go68 func (pc *KeyPartitionContainer) AddPartition(id PartitionId, p PartitionDefn) {
69 pc.PartitionMap[id] = p.(KeyPartitionDefn)
73 func (pc *KeyPartitionContainer) UpdatePartition(id PartitionId, p PartitionDefn) {
74 pc.PartitionMap[id] = p.(KeyPartitionDefn)
78 func (pc *KeyPartitionContainer) RemovePartition(id PartitionId) {
79 delete(pc.PartitionMap, id)
87 id := pc.GetPartitionIdByPartitionKey(key)
88 return pc.GetEndpointsByPartitionId(id)
105 func (pc *KeyPartitionContainer) GetEndpointsByPartitionId(id PartitionId) []Endpoint {
107 if p, ok := pc.PartitionMap[id]; o
[all...]
/6.6.0/godeps/src/golang.org/x/tools/go/pointer/
H A Dhvn.go241 func (h *hvn) ref(id onodeid) onodeid {
242 return id + onodeid(len(h.a.nodes))
270 for id := range a.nodes {
271 id := onodeid(id)
272 h.onodes[id] = &onode{}
273 h.onodes[h.ref(id)] = &onode{indirect: true}
277 for id, o := range h.onodes {
278 o.rep = onodeid(id)
302 for id,
[all...]
/6.6.0/godeps/src/golang.org/x/tools/internal/jsonrpc2/
H A Dwire.go41 // The id of this request, used to tie the Response back to the request.
44 ID *ID `json:"id,omitempty"`
59 ID *ID `json:"id,omitempty"`
116 func (id *ID) String() string {
117 if id == nil {
120 if id.Name != "" {
121 return strconv.Quote(id.Name)
123 return "#" + strconv.FormatInt(id.Number, 10)
126 func (id *ID) MarshalJSON() ([]byte, error) {
127 if id
[all...]
/6.6.0/goproj/src/github.com/couchbase/query/datastore/
H A Dcollections_ds.go14 id string
15 keyspaces map[string]*CollectionsKeyspace // keyspaces by id
16 buckets map[string]*CollectionsBucket // buckets by id
19 func NewCollectionsNamespace(id string) *CollectionsNamespace {
21 id: id,
63 return ns.id
67 return ns.id
90 func (ns *CollectionsNamespace) KeyspaceById(id string) (Keyspace, errors.Error) {
91 ks := ns.keyspaces[id]
[all...]
/6.6.0/couchstore/python/
H A Dcouchstore.py94 _fields_ = [("id", SizedBuf), ("data", SizedBuf)]
98 _fields_ = [("id", SizedBuf),
109 _fields_ = [("id", SizedBuf),
136 def __init__(self, id):
137 self.id = id
144 self = DocumentInfo(str(info.id))
157 struct = DocInfoStruct(SizedBuf(self.id))
177 return "DocumentInfo('%s', %d bytes)" % (self.id, self.physSize)
180 return "DocumentInfo('%s', %d bytes)" % (self.id, sel
[all...]
/6.6.0/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/
H A Dbandwidth_throttler.go31 id string
63 throttler.id = pipeline_utils.GetElementIdFromName(pipeline, base.BANDWIDTH_THROTTLER_SVC)
78 throttler.logger.Infof("%v attached to pipeline", throttler.id)
89 throttler.logger.Infof("%v starting...", throttler.id)
98 throttler.logger.Infof("%v stopping...", throttler.id)
99 defer throttler.logger.Infof("%v stopped...", throttler.id)
109 throttler.logger.Infof("%v reset routine starting", throttler.id)
110 defer throttler.logger.Infof("%v reset routine stopped...", throttler.id)
123 throttler.logger.Infof("%v received finish signal and is exitting", throttler.id)
244 return throttler.id
[all...]
/6.6.0/kv_engine/engines/ep/src/
H A Dkvshard.cc35 KVShard::KVShard(id_type numShards, id_type id, Configuration& config) in KVShard() argument
44 kvConfig = std::make_unique<KVStoreConfig>(config, numShards, id); in KVShard()
54 kvConfig = std::make_unique<MagmaKVStoreConfig>(config, numShards, id); in KVShard()
62 std::make_unique<RocksDBKVStoreConfig>(config, numShards, id); in KVShard()
92 VBucketPtr KVShard::getBucket(Vbid id) const { in getBucket()
93 if (id.get() < kvConfig->getMaxVBuckets()) { in getBucket()
94 auto element = getElement(id); in getBucket()
95 Expects(element.get() == nullptr || element.get()->getId() == id); in getBucket()
103 Vbid id) { in getElement()
104 Expects(id in getElement()
102 getElement( Vbid id) getElement() argument
123 dropVBucketAndSetupDeferredDeletion(Vbid id, const void* cookie) dropVBucketAndSetupDeferredDeletion() argument
[all...]
H A Dvbucketmap.cc41 VBucketPtr VBucketMap::getBucket(Vbid id) const { in getBucket()
42 if (id.get() < size) { in getBucket()
43 return getShardByVbId(id)->getBucket(id); in getBucket()
68 void VBucketMap::dropVBucketAndSetupDeferredDeletion(Vbid id, in dropVBucketAndSetupDeferredDeletion() argument
70 if (id.get() < size) { in dropVBucketAndSetupDeferredDeletion()
71 getShardByVbId(id)->dropVBucketAndSetupDeferredDeletion(id, cookie); in dropVBucketAndSetupDeferredDeletion()
143 KVShard* VBucketMap::getShardByVbId(Vbid id) const { in getShardByVbId()
144 return shards[id in getShardByVbId()
[all...]
/6.6.0/kv_engine/auditd/src/
H A Devent.cc32 auto id = eventPayload[userid_type]; in filterEventByUserid() local
34 auto sourceIt = id.find("source"); in filterEventByUserid()
35 if (sourceIt != id.end() && !sourceIt->is_string()) { in filterEventByUserid()
42 auto domainIt = id.find("domain"); in filterEventByUserid()
43 if (domainIt != id.end() && !domainIt->is_string()) { in filterEventByUserid()
50 if (sourceIt != id.end() || domainIt != id.end()) { in filterEventByUserid()
51 auto userIt = id.find("user"); in filterEventByUserid()
52 if (userIt != id.end() && !userIt->is_string()) { in filterEventByUserid()
59 if (userIt != id in filterEventByUserid()
[all...]
/6.6.0/ns_server/priv/public/ui/app/components/directives/
H A Dmn_user_roles_list_controller.js44 function hasGroups(id) {
45 if (vm.selectedGroupsRoles && vm.selectedGroupsRoles[id]) {
46 return !!Object.keys(vm.selectedGroupsRoles[id]).length;
52 function getGroupsList(id) {
53 return Object.keys(vm.selectedGroupsRoles[id]).join(", ");
67 var id = vm.getUIID(role);
68 vm.selectedRoles[id] = true;
69 onCheckChange(role, id);
75 function onCheckChange(role, id) {
77 if (vm.selectedRoles[id]) {
[all...]
/6.6.0/testrunner/pytests/eventing/handler_code/curl/
H A Dn1ql_op_curl_get.js15 var id=meta.id;
17 var query= UPSERT into dst_bucket (KEY, VALUE) VALUES ($id, $status);
20 var id=meta.id;
22 var query= UPSERT into dst_bucket (KEY, VALUE) VALUES ($id, $status);
46 var id=meta.id;
47 delete from dst_bucket where META().id=$id;
[all...]
/6.6.0/goproj/src/github.com/couchbase/query/datastore/couchbase/
H A Dauth_test.go29 func (asi *authSourceImpl) auth(id, pwd string) (cbauth.Creds, error) {
31 if user.id == id {
35 return nil, fmt.Errorf("Invalid password %s supplied for user %s.", pwd, id)
38 return nil, fmt.Errorf("Could not find user %s.", id)
47 id string
53 return a.id
82 authUser{id: "bob", password: "pwbob",
88 authUser{id: "nancy", password: "pwnancy",
109 authUser{id
[all...]
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/indexer/
H A Dslice_container.go62 func (sc *HashedSliceContainer) AddSlice(id SliceId, s Slice) {
63 sc.SliceMap[id] = s
68 func (sc *HashedSliceContainer) UpdateSlice(id SliceId, s Slice) {
69 sc.SliceMap[id] = s
73 func (sc *HashedSliceContainer) RemoveSlice(id SliceId) {
74 delete(sc.SliceMap, id)
84 id := sc.GetSliceIdByIndexKey(key)
85 return sc.GetSliceById(id)
92 //run hash function on index key and return slice id
100 func (sc *HashedSliceContainer) GetSliceById(id SliceI
[all...]
/6.6.0/goproj/src/github.com/couchbase/goxdcr/component/
H A Dasync_listener.go21 id string
31 func NewAsyncComponentEventListenerImpl(id, topic string, logger_context *log.LoggerContext,
34 id: id,
44 func NewDefaultAsyncComponentEventListenerImpl(id, topic string,
46 return NewAsyncComponentEventListenerImpl(id, topic, logger_context, base.EventChanSize)
60 l.logger.Infof("%v started processing events\n", l.id)
85 l.logger.Infof("%v stopping processing events\n", l.id)
88 l.logger.Infof("%v stopped processing events\n", l.id)
90 l.logger.Infof("%v failed to stop processing events. Leaving it alone to die. err=%v\n", l.id, er
[all...]
/6.6.0/testrunner/pytests/failover/
H A Dnegative_failover_tests.py22 status = self.rest.rebalance(otpNodes=[node.id for node in nodes],
23 ejectedNodes=[node.id for node in nodes[1:]])
25 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=True)
35 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=True)
37 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=True)
47 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=True)
49 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=False)
77 success_failed_over = self.rest.fail_over(chosen[0].id, graceful=False)
79 fail_failed_over = self.rest.fail_over(chosen[0].id, graceful=False)
90 success_failed_over = self.rest.fail_over(chosen[0].id, gracefu
[all...]

Completed in 49 milliseconds

12345678910>>...36