Home
last modified time | relevance | path

Searched refs:it (Results 1 - 25 of 85) sorted by relevance

1234

/3.0.3-GA/moxi/src/
H A Ditems.c12 static void item_link_q(item *it);
13 static void item_unlink_q(item *it);
60 # define DEBUG_REFCNT(it,op) \
62 it, op, it->refcount, \
63 (it->it_flags & ITEM_LINKED) ? 'L' : ' ', \
64 (it->it_flags & ITEM_SLABBED) ? 'S' : ' ')
66 # define DEBUG_REFCNT(it,op) do {} while(0)
122 item *it = NULL; in do_item_alloc()
130 it in do_item_alloc()
230 item_free(item *it) item_free() argument
266 item_link_q(item *it) item_link_q() argument
287 item_unlink_q(item *it) item_unlink_q() argument
313 do_item_link(item *it) do_item_link() argument
339 do_item_unlink(item *it) do_item_unlink() argument
356 do_item_remove(item *it) do_item_remove() argument
372 do_item_update(item *it) do_item_update() argument
385 do_item_replace(item *it, item *new_it) do_item_replace() argument
399 item *it; do_item_cachedump() local
501 item *it = assoc_find(key, nkey); do_item_get() local
547 item *it = assoc_find(key, nkey); do_item_get_nocheck() local
[all...]
H A Dcproxy_front.c13 static char *item_key(void *it);
14 static int item_key_len(void *it);
15 static int item_len(void *it);
16 static void item_add_ref(void *it);
17 static void item_dec_ref(void *it);
18 static void *item_get_next(void *it);
19 static void item_set_next(void *it, void *next);
20 static void *item_get_prev(void *it);
21 static void item_set_prev(void *it, void *prev);
22 static uint64_t item_get_exptime(void *it);
179 void *it = genhash_find(m->map, key); mcache_get() local
230 mcache_set(mcache *m, void *it, uint64_t exptime, bool add_only, bool mod_exptime_if_exists) mcache_set() argument
401 mcache_item_unlink(mcache *m, void *it) mcache_item_unlink() argument
431 mcache_item_touch(mcache *m, void *it) mcache_item_touch() argument
471 item_key(void *it) item_key() argument
477 item_key_len(void *it) item_key_len() argument
483 item_len(void *it) item_len() argument
489 item_add_ref(void *it) item_add_ref() argument
496 item_dec_ref(void *it) item_dec_ref() argument
503 item_get_next(void *it) item_get_next() argument
509 item_set_next(void *it, void *next) item_set_next() argument
515 item_get_prev(void *it) item_get_prev() argument
521 item_set_prev(void *it, void *prev) item_set_prev() argument
527 item_get_exptime(void *it) item_get_exptime() argument
533 item_set_exptime(void *it, uint64_t exptime) item_set_exptime() argument
[all...]
H A Dassoc.c67 item *it; in assoc_find() local
73 it = old_hashtable[oldbucket]; in assoc_find()
75 it = primary_hashtable[hv & hashmask(hashpower)]; in assoc_find()
80 while (it) { in assoc_find()
81 if ((nkey == it->nkey) && (memcmp(key, ITEM_key(it), nkey) == 0)) { in assoc_find()
82 ret = it; in assoc_find()
85 it = it->h_next; in assoc_find()
133 int assoc_insert(item *it) { in assoc_insert() argument
196 item *it, *next; assoc_maintenance_thread() local
[all...]
H A Dcproxy_stats.c44 static char *key_stats_key(void *it);
45 static int key_stats_key_len(void *it);
46 static int key_stats_len(void *it);
47 static void *key_stats_get_next(void *it);
48 static void key_stats_set_next(void *it, void *next);
49 static void *key_stats_get_prev(void *it);
50 static void key_stats_set_prev(void *it, void *prev);
51 static uint64_t key_stats_get_exptime(void *it);
52 static void key_stats_set_exptime(void *it, uint64_t exptime);
302 item *it; in protocol_stats_foreach_write() local
518 key_stats_key(void *it) key_stats_key() argument
524 key_stats_key_len(void *it) key_stats_key_len() argument
530 key_stats_len(void *it) key_stats_len() argument
535 key_stats_add_ref(void *it) key_stats_add_ref() argument
542 key_stats_dec_ref(void *it) key_stats_dec_ref() argument
552 key_stats_get_next(void *it) key_stats_get_next() argument
558 key_stats_set_next(void *it, void *next) key_stats_set_next() argument
564 key_stats_get_prev(void *it) key_stats_get_prev() argument
570 key_stats_set_prev(void *it, void *prev) key_stats_set_prev() argument
576 key_stats_get_exptime(void *it) key_stats_get_exptime() argument
582 key_stats_set_exptime(void *it, uint64_t exptime) key_stats_set_exptime() argument
[all...]
H A Dcproxy_protocol_b2b.c65 item *it = uc->item; in cproxy_forward_b2b_downstream() local
70 assert(it != NULL); in cproxy_forward_b2b_downstream()
72 req = (protocol_binary_request_header *) ITEM_data(it); in cproxy_forward_b2b_downstream()
144 bool b2b_forward_item(conn *uc, downstream *d, item *it) { in b2b_forward_item() argument
155 assert(it != NULL); in b2b_forward_item()
157 req = (protocol_binary_request_header *) ITEM_data(it); in b2b_forward_item()
167 uc->sfd, it->nbytes, req->request.extlen, keylen, req->request.opcode, buf); in b2b_forward_item()
183 if (b2b_forward_item_vbucket(uc, d, it, c, vbucket) == true) { in b2b_forward_item()
201 bool b2b_forward_item_vbucket(conn *uc, downstream *d, item *it, in b2b_forward_item_vbucket() argument
219 req = (protocol_binary_request_header *) ITEM_data(it); in b2b_forward_item_vbucket()
283 item *it; cproxy_broadcast_b2b_downstream() local
384 item *it = c->item; cproxy_process_b2b_downstream() local
413 item *it; cproxy_process_b2b_downstream_nread() local
[all...]
H A Dcproxy_multiget.c206 item *it = NULL; in multiget_ascii_downstream() local
210 it = mcache_get(front_cache, key, key_len, in multiget_ascii_downstream()
214 if (it != NULL) { in multiget_ascii_downstream()
215 assert(it->nkey == key_len); in multiget_ascii_downstream()
216 assert(strncmp(ITEM_key(it), key, it->nkey) == 0); in multiget_ascii_downstream()
218 cproxy_upstream_ascii_item_response(it, uc_cur, 0); in multiget_ascii_downstream()
221 psc_get_key->write_bytes += it->nbytes; in multiget_ascii_downstream()
229 0, it->nbytes); in multiget_ascii_downstream()
234 item_remove(it); in multiget_ascii_downstream()
386 multiget_ascii_downstream_response(downstream *d, item *it) multiget_ascii_downstream_response() argument
[all...]
H A Dcproxy_protocol_a.c36 /* Snapshot rcurr, because the caller, try_read_command(), changes it. */ in cproxy_process_upstream_ascii()
47 * directly into it, then continue in nread_complete(). in cproxy_process_upstream_ascii()
183 item *it = c->item; in cproxy_process_upstream_ascii() local
184 if (it != NULL) { in cproxy_process_upstream_ascii()
185 SEEN(cmdx, false, cmd_len + it->nbytes); in cproxy_process_upstream_ascii()
202 item *it = c->item; in cproxy_process_upstream_ascii() local
203 if (it != NULL) { in cproxy_process_upstream_ascii()
204 SEEN(STATS_CMD_CAS, true, cmd_len + it->nbytes); in cproxy_process_upstream_ascii()
331 item *it = c->item; in cproxy_process_upstream_ascii_nread() local
333 assert(it ! in cproxy_process_upstream_ascii_nread()
355 cproxy_upstream_ascii_item_response(item *it, conn *uc, int cas_emit) cproxy_upstream_ascii_item_response() argument
[all...]
H A Dcproxy_protocol_a2a.c64 item *it = item_alloc(key, nkey, flags, 0, vlen + 2); in cproxy_process_a2a_downstream() local
65 if (it != NULL) { in cproxy_process_a2a_downstream()
68 ITEM_set_cas(it, cas); in cproxy_process_a2a_downstream()
70 c->item = it; in cproxy_process_a2a_downstream()
71 c->ritem = ITEM_data(it); in cproxy_process_a2a_downstream()
72 c->rlbytes = it->nbytes; in cproxy_process_a2a_downstream()
90 if (it != NULL) { in cproxy_process_a2a_downstream()
91 item_remove(it); in cproxy_process_a2a_downstream()
94 it = NULL; in cproxy_process_a2a_downstream()
135 /* Forward the line as-is if we couldn't merge it in cproxy_process_a2a_downstream()
139 item *it = item_alloc("s", 1, 0, 0, nline + 2); cproxy_process_a2a_downstream() local
214 item *it = c->item; cproxy_process_a2a_downstream_nread() local
525 cproxy_forward_a2a_item_downstream(downstream *d, short cmd, item *it, conn *uc) cproxy_forward_a2a_item_downstream() argument
[all...]
/3.0.3-GA/memcached/engines/default_engine/
H A Ditems.c14 static void item_link_q(struct default_engine *engine, hash_item *it);
15 static void item_unlink_q(struct default_engine *engine, hash_item *it);
24 static int do_item_link(struct default_engine *engine, hash_item *it);
25 static void do_item_unlink(struct default_engine *engine, hash_item *it);
26 static void do_item_release(struct default_engine *engine, hash_item *it);
27 static void do_item_update(struct default_engine *engine, hash_item *it);
29 hash_item *it, hash_item *new_it);
30 static void item_free(struct default_engine *engine, hash_item *it);
51 /* warning: don't use these macros with a function, as it evals its arg twice */
70 # define DEBUG_REFCNT(it,o
89 hash_item *it = NULL; do_item_alloc() local
231 item_free(struct default_engine *engine, hash_item *it) item_free() argument
247 item_link_q(struct default_engine *engine, hash_item *it) item_link_q() argument
265 item_unlink_q(struct default_engine *engine, hash_item *it) item_unlink_q() argument
288 do_item_link(struct default_engine *engine, hash_item *it) do_item_link() argument
312 do_item_unlink(struct default_engine *engine, hash_item *it) do_item_unlink() argument
330 do_item_release(struct default_engine *engine, hash_item *it) do_item_release() argument
341 do_item_update(struct default_engine *engine, hash_item *it) do_item_update() argument
355 do_item_replace(struct default_engine *engine, hash_item *it, hash_item *new_it) do_item_replace() argument
373 hash_item *it; do_item_cachedump() local
510 hash_item *it = assoc_find(engine, engine->server.core->hash(key, do_item_get() local
570 do_store_item(struct default_engine *engine, hash_item *it, uint64_t *cas, ENGINE_STORE_OPERATION operation, const void *cookie) do_store_item() argument
701 do_add_delta(struct default_engine *engine, hash_item *it, const bool incr, const int64_t delta, uint64_t *rcas, uint64_t *result, const void *cookie) do_add_delta() argument
770 hash_item *it; item_alloc() local
784 hash_item *it; item_get() local
1136 hash_item *it; global() member
[all...]
H A Dassoc.c37 hash_item *it; in assoc_find() local
45 it = engine->assoc.old_hashtable[oldbucket]; in assoc_find()
47 it = engine->assoc.primary_hashtable[hash & hashmask(engine->assoc.hashpower)]; in assoc_find()
50 while (it) { in assoc_find()
51 if ((nkey == it->nkey) && (memcmp(key, item_get_key(it), nkey) == 0)) { in assoc_find()
52 ret = it; in assoc_find()
55 it = it->h_next; in assoc_find()
121 int assoc_insert(struct default_engine *engine, uint32_t hash, hash_item *it) { in assoc_insert() argument
178 hash_item *it, *next; assoc_maintenance_thread() local
[all...]
/3.0.3-GA/ep-engine/tests/module_tests/
H A Dchunk_creation_test.cc32 std::list<std::pair<uint64_t, uint64_t> >::iterator it; in main() local
41 for (it = chunk_list.begin(); it != chunk_list.end(); ++it) { in main()
42 cb_assert(it->first == i && it->second == i); in main()
49 it = chunk_list.begin(); in main()
50 cb_assert(it->first == 0 && it->second == 3); in main()
51 ++it; in main()
[all...]
H A Dhash_table_test.cc87 std::vector<std::string>::iterator it; in storeMany() local
88 for (it = keys.begin(); it != keys.end(); ++it) { in storeMany()
89 std::string key = *it; in storeMany()
96 std::vector<std::string>::iterator it; in addMany() local
98 for (it = keys.begin(); it != keys.end(); ++it) { in addMany()
99 std::string k = *it; in addMany()
189 std::vector<std::string>::iterator it; testReverseDeletions() local
212 std::vector<std::string>::iterator it; testForwardDeletions() local
226 std::vector<std::string>::const_iterator it; verifyFound() local
301 std::vector<std::string>::iterator it; operator ()() local
360 std::vector<std::string>::iterator it; testAdd() local
[all...]
/3.0.3-GA/memcached/engines/bucket_engine/
H A Dtopkeys.c10 topkey_item_t *it = calloc(sizeof(topkey_item_t) + nkey, 1); in topkey_item_init() local
11 cb_assert(it); in topkey_item_init()
14 it->ti_nkey = nkey; in topkey_item_init()
15 it->ti_ctime = ct; in topkey_item_init()
16 it->ti_atime = ct; in topkey_item_init()
18 memcpy(it + 1, key, nkey); in topkey_item_init()
19 return it; in topkey_item_init()
22 static size_t topkey_item_size(const topkey_item_t *it) { in topkey_item_size() argument
23 return sizeof(topkey_item_t) + it->ti_nkey; in topkey_item_size()
98 static void topkeys_item_delete(topkeys_t *tk, topkey_item_t *it) { in topkeys_item_delete() argument
106 topkey_item_t *it = genhash_find(tk->hash, key, nkey); topkeys_item_get_or_create() local
136 topkey_item_t *it = (topkey_item_t*)list; tk_iterfunc() local
[all...]
H A Dmock_engine.c137 item **it, in mock_tap_iterator()
147 (void)it; (void)engine_specific; (void)nengine_specific; in mock_tap_iterator()
337 item **it, in mock_item_allocate()
348 *it = calloc(to_alloc, 1); in mock_item_allocate()
350 *it = NULL; in mock_item_allocate()
353 if (*it) { in mock_item_allocate()
354 mock_item* i = (mock_item*) *it; in mock_item_allocate()
421 mock_item* it = (mock_item*)itm; in mock_store() local
426 genhash_update(get_ht(handle), item_get_key(itm), it->nkey, itm, 0); in mock_store()
453 /* This is all int stuff, just to make it eas in mock_arithmetic()
135 mock_tap_iterator(ENGINE_HANDLE* handle, const void *cookie, item **it, void **engine_specific, uint16_t *nengine_specific, uint8_t *ttl, uint16_t *flags, uint32_t *seqno, uint16_t *vbucket) mock_tap_iterator() argument
335 mock_item_allocate(ENGINE_HANDLE* handle, const void* cookie, item **it, const void* key, const size_t nkey, const size_t nbytes, const int flags, const rel_time_t exptime, uint8_t datatype) mock_item_allocate() argument
517 const mock_item* it = (mock_item*)itm; item_get_cas() local
524 mock_item* it = (mock_item*)itm; item_set_cas() local
532 const mock_item* it = (mock_item*)itm; item_get_key() local
539 const mock_item* it = (mock_item*)itm; item_get_data() local
546 mock_item* it = (mock_item*)itm; get_item_info() local
[all...]
/3.0.3-GA/couchdb/share/www/spec/
H A Dcouch_js_class_methods_spec.js34 it 'should return ok true'
38 it 'should return the name of the logged in user'
42 it 'should return the roles of the logged in user'
46 it 'should post _session'
51 it 'should create a session'
62 it 'should return ok true'
66 it 'should delete _session'
71 it 'should result in an invalid session'
82 it 'should return ok true'
86 it 'shoul
[all...]
H A Dcouch_js_instance_methods_1_spec.js29 it 'should return a XMLHttpRequest'
39 it 'should set the options the CouchDB instance has got as httpHeaders'
44 it 'should pass through the options'
55 it 'should create the db'
60 it 'should return the ok true'
64 it 'should result in a created db'
73 it 'should have create a db with update sequence 0'
84 it 'should delete the db'
89 it 'should return the responseText of the request'
93 it 'shoul
[all...]
H A Dcouch_js_instance_methods_3_spec.js26 it 'should return no docs when there arent any'
37 it 'should return all docs'
48 it 'should pass through the options'
55 it 'should pass through the keys'
64 it 'should pass through the options and the keys'
79 it 'should return nothing when there arent any design docs'
84 it 'should return all design docs'
107 it 'should return no changes when there arent any'
118 it 'should return changes'
130 it 'shoul
[all...]
H A Djquery_couch_js_instance_methods_1_spec.js29 it 'should set the name'
33 it 'should set the uri'
48 it 'should return ok true'
57 it 'should trigger _compact'
68 it 'should return ok true'
77 it 'should trigger _view_cleanup'
101 it 'should return ok true'
110 it 'should trigger _compact_view with the groupname'
119 it 'should return raise a 404 error when the design name doesnt exist'
130 it 'shoul
[all...]
H A Dcouch_js_instance_methods_2_spec.js26 it 'should return ok true'
30 it 'should return the instance start time'
34 it 'should post _ensure_full_commit to the db'
49 it 'should apply the map function'
64 it 'should apply the reduce function'
72 it 'should pass through the options'
84 it 'should pass through the keys'
96 it 'should pass through the options and the keys'
107 it 'should apply a view in erlang also'
144 it 'shoul
[all...]
H A Djquery_couch_js_instance_methods_2_spec.js42 it 'should return the name of the database'
46 it 'should return the number of documents'
50 it 'should return the start time of the db instance'
56 it 'should return no docs when there arent any'
72 it 'should return all docs'
86 it 'should pass through the options'
101 it 'should return nothing when there arent any design docs'
111 it 'should return all design docs'
137 it 'should provide a custom function with appName, appPath and design document when there is an attachment with index.html'
161 it 'shoul
[all...]
/3.0.3-GA/ep-engine/src/
H A Dfailover-table.cc123 table_t::iterator it = table.begin(); in pruneEntries() local
124 for (; it != table.end(); ++it) { in pruneEntries()
125 if (it->by_seqno > seqno) { in pruneEntries()
126 it = table.erase(it); in pruneEntries()
140 table_t::iterator it; in cacheTableJSON() local
141 for(it = table.begin(); it != table.end(); it in cacheTableJSON()
160 table_t::iterator it; addStats() local
[all...]
H A Dconnmap.cc232 // it can notify the event to a given in notifyPausedConnection()
277 for (std::set<uint16_t>::const_iterator it = vset.begin(); it != vset.end(); ++it) { in updateVBConnections()
278 size_t lock_num = (*it) % vbConnLockNum; in updateVBConnections()
281 if (!tp->vbucketFilter.empty() && tp->vbucketFilter(*it)) { in updateVBConnections()
282 std::list<connection_t> &vb_conns = vbConns[*it]; in updateVBConnections()
291 std::list<connection_t> &vb_conns = vbConns[*it]; in updateVBConnections()
304 for (std::set<uint16_t>::const_iterator it = vset.begin(); it ! in removeVBConnections()
518 std::list<connection_t>::iterator it; manageConnections() local
546 std::list<connection_t>::iterator it = conns.begin(); notifyVBConnections() local
604 std::list<connection_t>::iterator it = all.begin(); resetReplicaChain() local
649 std::list<connection_t>::iterator it = all.begin(); scheduleBackfill() local
673 std::map<std::string, std::string>::const_iterator it = loadPrevSessionStats() local
739 std::map<const void*, connection_t>::iterator it; mapped() local
910 std::map<std::string, std::string>::const_iterator it = stats.find(backfill_stat); wasReplicationCompleted() local
1101 std::list<connection_t>::iterator it; manageConnections() local
1127 std::list<uint16_t>::iterator it = vblist.begin(); removeVBConnections() local
1149 std::list<connection_t>::iterator it = conns.begin(); notifyVBConnections() local
[all...]
H A Dhisto.h158 : it(input.begin()), end(input.end()) {} in FixedInputGenerator()
161 cb_assert(it != end); in operator ()()
162 T current = *it; in operator ()()
163 ++it; in operator ()()
164 cb_assert(it != end); in operator ()()
165 T next = *it; in operator ()()
169 typename std::vector<T>::iterator it; member in FixedInputGenerator
239 for (typename std::vector<HistogramBin<T>*>::iterator it = bins.begin(); in ~Histogram()
240 it != bins.end(); ++it) { in ~Histogram()
338 typename std::vector<HistogramBin<T>*>::iterator it; verify() local
358 typename std::vector<HistogramBin<T>*>::iterator it; findBin() local
427 out << **it; operator <<() local
[all...]
H A Dcheckpoint.cc92 checkpoint_index::iterator it = keyIndex.find(qi->getKey()); in queueDirty() local
94 if (it != keyIndex.end()) { in queueDirty()
96 std::list<queued_item>::iterator currPos = it->second.position; in queueDirty()
97 uint64_t currMutationId = it->second.mutation_id; in queueDirty()
139 // key, shift it left by 1 in queueDirty()
202 checkpoint_index::iterator it = keyIndex.find(key); in mergePrevCheckpoint() local
203 if (it == keyIndex.end()) { in mergePrevCheckpoint()
224 checkpoint_index::iterator it = keyIndex.find(key); in getMutationIdForKey() local
225 if (it != keyIndex.end()) { in getMutationIdForKey()
226 mid = it in getMutationIdForKey()
233 std::list<Checkpoint*>::iterator it = checkpointList.begin(); ~CheckpointManager() local
270 std::list<queued_item>::iterator it = setOpenCheckpointId_UNLOCKED() local
481 std::list<Checkpoint*>::iterator it = checkpointList.begin(); registerTAPCursor_UNLOCKED() local
566 cursor_index::iterator it = tapCursors.find(name); removeTAPCursor_UNLOCKED() local
595 cursor_index::iterator it = tapCursors.find(name); getCheckpointIdForTAPCursor() local
676 std::list<Checkpoint*>::iterator it = checkpointList.begin(); removeClosedUnrefCheckpoints() local
761 std::list<std::string>::iterator it = invalidCursorNames.begin(); removeInvalidCursorsOnCheckpoint() local
913 cursor_index::iterator it = tapCursors.find(name); getAllItemsForCursor() local
946 cursor_index::iterator it = tapCursors.find(name); nextItem() local
1000 std::list<Checkpoint*>::iterator it = checkpointList.begin(); clear() local
1040 std::list<std::string>::const_iterator it = cursors.begin(); resetTAPCursors() local
1123 std::list<Checkpoint*>::reverse_iterator it = checkpointList.rbegin(); eligibleForEviction() local
1141 cursor_index::iterator it = tapCursors.find(name); getNumItemsForTAPConnection() local
1193 cursor_index::iterator it = tapCursors.find(name); decrTapCursorFromCheckpointEnd() local
1214 std::list<queued_item>::iterator it = cursor.currentPos; isLastMutationItemInCheckpoint() local
1241 std::list<Checkpoint*>::iterator it = checkpointList.begin(); checkAndAddNewCheckpoint() local
1422 cursor_index::iterator it = tapCursors.find(name); hasNext() local
[all...]
/3.0.3-GA/couchdb/src/couch_view_parser/
H A Dcouch_view_parser_nif.cc340 row_list_t::reverse_iterator it = ctx->rows->rbegin(); in make_rows_list() local
342 for ( ; it != ctx->rows->rend(); ++it) { in make_rows_list()
349 bool hasDoc = ((*it)->doc.length() > 0); in make_rows_list()
350 bool hasPart = ((*it)->partition.length() > 0) || ((*it)->node.length() > 0); in make_rows_list()
352 if (!enif_alloc_binary_compat(env, (*it)->key.length(), &keyBin)) { in make_rows_list()
355 memcpy(keyBin.data, (*it)->key.data(), (*it)->key.length()); in make_rows_list()
357 if (!((*it) in make_rows_list()
473 error_entry_list_t::reverse_iterator it = ctx->error_entries->rbegin(); make_errors_list() local
518 debug_info_list_t::reverse_iterator it = ctx->debug_infos->rbegin(); make_debug_entries_list() local
[all...]

Completed in 68 milliseconds

1234