| /memcached-1.6.32/ |
| D | cache.c | 23 free(ret); in cache_create()
28 ret->name = nm; in cache_create()
29 STAILQ_INIT(&ret->head); in cache_create()
34 ret->bufsize = bufsize; in cache_create()
38 return ret; in cache_create()
68 void *ret; in cache_alloc() local
72 return ret; in cache_alloc()
76 void *ret; in do_cache_alloc() local
85 if (ret != NULL) { in do_cache_alloc()
97 uint64_t *pre = ret; in do_cache_alloc()
[all …]
|
| D | slabs.c | 114 int ret; in alloc_large_chunk() local
366 return ret; in get_page_from_global_pool()
441 if (ret) { in do_slabs_alloc()
447 return ret; in do_slabs_alloc()
552 return ret; in global_page_pool_size()
611 void *ret; in memory_allocate() local
637 return ret; in memory_allocate()
658 void *ret; in slabs_alloc() local
663 return ret; in slabs_alloc()
690 bool ret; in slabs_adjust_mem_limit() local
[all …]
|
| D | proxy_request.c | 322 int ret = 0; in process_request() local
545 if (ret != 0) { in mcp_request_render()
546 return ret; in mcp_request_render()
584 if (ret != 0) { in mcp_request_append()
585 return ret; in mcp_request_append()
854 int ret = 1; in mcplib_request_flag_token() local
866 ret = 2; in mcplib_request_flag_token()
885 return ret; in mcplib_request_flag_token()
906 int ret = 1; in mcplib_request_flag_token_int() local
926 ret = 2; in mcplib_request_flag_token_int()
[all …]
|
| D | tls.c | 74 int ret = SSL_accept(ssl); in ssl_accept() local
75 if (ret <= 0) { in ssl_accept()
76 int err = SSL_get_error(ssl, ret); in ssl_accept()
168 if (ret <= 0) { in ssl_read()
169 int err = SSL_get_error(c->ssl, ret); in ssl_read()
179 } else if (ret != 0) { in ssl_read()
193 return ret; in ssl_read()
204 if (ret <= 0) { in ssl_write()
205 int err = SSL_get_error(c->ssl, ret); in ssl_write()
215 } else if (ret != 0) { in ssl_write()
[all …]
|
| D | proxy_tls.c | 103 int ret = MCP_TLS_OK; in mcp_tls_connect() local
107 return ret; in mcp_tls_connect()
114 ret = MCP_TLS_ERR; in mcp_tls_connect()
119 ret = MCP_TLS_OK; in mcp_tls_connect()
121 ret = MCP_TLS_ERR; in mcp_tls_connect()
126 return ret; in mcp_tls_connect()
|
| D | extstore.c | 594 int ret = -1; in extstore_write_request() local
596 return ret; in extstore_write_request()
606 return ret; in extstore_write_request()
622 return ret; in extstore_write_request()
645 return ret; in extstore_write_request()
728 int ret = 0; in extstore_delete() local
752 ret = -1; in extstore_delete()
755 return ret; in extstore_delete()
761 int ret = 0; in extstore_check() local
765 ret = -1; in extstore_check()
[all …]
|
| D | assoc.c | 82 item *ret = NULL; in assoc_find() local
88 ret = it; in assoc_find()
97 return ret; in assoc_find()
269 int ret; in start_assoc_maintenance_thread() local
278 if ((ret = pthread_create(&maintenance_tid, NULL, in start_assoc_maintenance_thread()
280 fprintf(stderr, "Can't create thread: %s\n", strerror(ret)); in start_assoc_maintenance_thread()
|
| D | crawler.c | 385 int ret = poll(to_poll, 1, 1000); in lru_crawler_write() local
387 if (ret < 0) { in lru_crawler_write()
393 if (ret == 0) return 0; in lru_crawler_write()
469 if (ret != 0) { in item_crawl_hash()
551 int ret = lru_crawler_write(c); in item_crawler_thread() local
552 if (ret != 0) { in item_crawler_thread()
648 int ret; in stop_item_crawler_thread() local
657 if (wait && (ret = pthread_join(item_crawler_tid, NULL)) != 0) { in stop_item_crawler_thread()
676 int ret; in start_item_crawler_thread() local
682 if ((ret = pthread_create(&item_crawler_tid, NULL, in start_item_crawler_thread()
[all …]
|
| D | thread.c | 377 int ret; in create_worker() local
381 if ((ret = pthread_create(&((LIBEVENT_THREAD*)arg)->thread_id, &attr, func, arg)) != 0) { in create_worker()
383 strerror(ret)); in create_worker()
949 enum delta_result_type ret; in add_delta() local
954 ret = do_add_delta(t, key, nkey, incr, delta, buf, cas, hv, NULL); in add_delta()
956 return ret; in add_delta()
963 enum store_item_type ret; in store_item() local
968 ret = do_store_item(item, comm, t, hv, nbytes, cas, cas_in, cas_stale); in store_item()
970 return ret; in store_item()
|
| D | proto_text.c | 61 switch (ret) { in _finalize_mset()
137 enum store_item_type ret; in complete_nread_ascii() local
215 _finalize_mset(c, nbytes, ret, cas); in complete_nread_ascii()
217 switch (ret) { in complete_nread_ascii()
852 if (ret == 0) { in process_meta_command()
857 nkey = ret; in process_meta_command()
865 size_t ret; in process_meta_command() local
891 resp->wbytes = total + ret; in process_meta_command()
934 size_t ret; in _meta_flag_preparse() local
952 if (ret == 0) { in _meta_flag_preparse()
[all …]
|
| D | items.c | 922 bool ret = false; in item_stats_sizes_status() local
924 ret = true; in item_stats_sizes_status()
925 return ret; in item_stats_sizes_status()
1315 bool ret = true; in lru_bump_async() local
1323 ret = false; in lru_bump_async()
1327 ret = false; in lru_bump_async()
1330 if (!ret) { in lru_bump_async()
1334 return ret; in lru_bump_async()
1709 int ret; in stop_lru_maintainer_thread() local
1723 int ret; in start_lru_maintainer_thread() local
[all …]
|
| D | proxy_config.c | 374 int ret; in _start_proxy_config_threads() local
377 if ((ret = pthread_create(&ctx->config_tid, NULL, in _start_proxy_config_threads()
380 strerror(ret)); in _start_proxy_config_threads()
390 if ((ret = pthread_create(&ctx->manager_tid, NULL, in _start_proxy_config_threads()
393 strerror(ret)); in _start_proxy_config_threads()
|
| D | testapp.c | 152 if (ret == TEST_PASS) { in test_issue_161()
153 ret = cache_bulkalloc(512); in test_issue_161()
156 return ret; in test_issue_161()
719 int ret = SSL_connect(c->ssl); in connect_server() local
720 if (ret < 0) { in connect_server()
2140 int ret; in test_binary_pipeline_hickup() local
2171 enum test_return ret = TEST_PASS; in test_issue_101() local
2206 ret = TEST_FAIL; in test_issue_101()
2225 ret = test_binary_noop(); in test_issue_101()
2250 return ret; in test_issue_101()
[all …]
|
| D | storage.c | 144 static void _storage_get_item_cb(void *e, obj_io *io, int ret) { in _storage_get_item_cb() argument
154 if (ret < 1) { in _storage_get_item_cb()
730 int ret; in start_storage_write_thread() local
733 if ((ret = pthread_create(&storage_write_tid, NULL, in start_storage_write_thread()
736 strerror(ret)); in start_storage_write_thread()
1041 static void _storage_compact_cb(void *e, obj_io *io, int ret) { in _storage_compact_cb() argument
1045 if (ret < 1) { in _storage_compact_cb()
1172 int ret; in start_storage_compact_thread() local
1176 if ((ret = pthread_create(&storage_compact_tid, NULL, in start_storage_compact_thread()
1179 strerror(ret)); in start_storage_compact_thread()
|
| D | logger.c | 740 enum logger_parse_entry_ret ret; in logger_thread_read() local
743 ret = logger_thread_parse_entry(e, ls, scratch, &scratch_len); in logger_thread_read()
744 if (ret != LOGGER_PARSE_ENTRY_OK) { in logger_thread_read()
811 int ret = poll(watchers_pollfds, nfd, 0); in logger_thread_poll_watchers() local
813 if (ret < 0) { in logger_thread_poll_watchers()
941 int ret; in start_logger_thread() local
943 if ((ret = pthread_create(&logger_tid, NULL, in start_logger_thread()
945 fprintf(stderr, "Can't start logger thread: %s\n", strerror(ret)); in start_logger_thread()
|
| D | proto_bin.c | 360 enum store_item_type ret = NOT_STORED; in complete_update_bin() local
386 …ret = store_item(it, c->cmd, c->thread, NULL, &cas, (settings.use_cas) ? get_cas_id() : 0, CAS_NO_… in complete_update_bin()
393 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
397 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
401 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
405 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
409 (ret == STORED) ? it->nbytes : -1, cas); in complete_update_bin()
414 switch (ret) { in complete_update_bin()
|
| D | extstore.h | 72 typedef void (*obj_io_cb)(void *e, obj_io *io, int ret);
|
| D | proxy_inspector.c | 597 int ret = 0; in mcp_ins_run() local
602 ret += mcp_ins_entries[s->type].r(L, ins, s, arg); in mcp_ins_run()
605 return ret; in mcp_ins_run()
|
| D | proxy_mutator.c | 993 int ret = 0; in mcp_mut_run() local
1071 return ret; in mcp_mut_run()
1137 int ret = mcp_mut_run(&run); in mcplib_mutator_call() local
1139 return ret; in mcplib_mutator_call()
|
| D | proxy_internal.c | 86 static void _storage_get_item_cb(void *e, obj_io *eio, int ret) { in _storage_get_item_cb() argument
93 if (ret < 1) { in _storage_get_item_cb()
398 …int ret = store_item(it, comm, t, NULL, NULL, (settings.use_cas) ? get_cas_id() : 0, CAS_NO_STALE); in process_update_cmd() local
399 switch (ret) { in process_update_cmd()
1190 …int ret = store_item(it, comm, t, &nbytes, &cas, of.has_cas_in ? of.cas_id_in : get_cas_id(), set_… in process_mset_cmd() local
1191 switch (ret) { in process_mset_cmd()
|
| D | memcached.c | 361 int ret; in start_conn_timeout_thread() local
370 strerror(ret)); in start_conn_timeout_thread()
2019 bool ret = true; in get_stats() local
2038 ret = false; in get_stats()
2041 ret = false; in get_stats()
2044 return ret; in get_stats()
3678 int ret = 0; local
3841 return ret;
4292 int ret = -1; local
4315 ret = 0;
[all …]
|
| /memcached-1.6.32/scripts/ |
| D | memcached.upstart | 8 ret=0
13 start memcached-server || ret=$?
19 start memcached-server SERVER=$i || ret=$?
22 exit $ret
|
| /memcached-1.6.32/t/ |
| D | proxymut.lua | 68 local ret = mut_mgreq(nreq)
71 local ret = mut_mgflagreq(nreq)
74 local ret = mut_mgres(nres)
77 local ret = mut_mgresval(nres, "example value\r\n")
81 local ret = mut_mgresflag(nres, res)
|
| D | misbehave.t | 25 my $ret = recv($sock, $buff, 1, MSG_PEEK | MSG_DONTWAIT);
27 ok($ret == 0, "did not allow misbehaving");
|
| D | udp.t | 245 my $ret = {};
264 $ret->{$seq} = $res;
267 return $ret;
|