Lines Matching refs:mc
112 static apr_status_t make_server_dead(apr_memcache_t *mc, apr_memcache_server_t *ms)
125 static apr_status_t make_server_live(apr_memcache_t *mc, apr_memcache_server_t *ms)
132 APU_DECLARE(apr_status_t) apr_memcache_add_server(apr_memcache_t *mc, apr_memcache_server_t *ms)
136 if(mc->ntotal >= mc->nalloc) {
140 mc->live_servers[mc->ntotal] = ms;
141 mc->ntotal++;
142 make_server_live(mc, ms);
149 apr_memcache_find_server_hash(apr_memcache_t *mc, const apr_uint32_t hash)
151 if (mc->server_func) {
152 return mc->server_func(mc->server_baton, mc, hash);
155 return apr_memcache_find_server_hash_default(NULL, mc, hash);
160 apr_memcache_find_server_hash_default(void *baton, apr_memcache_t *mc,
168 if(mc->ntotal == 0) {
173 ms = mc->live_servers[h % mc->ntotal];
188 make_server_live(mc, ms);
201 } while(i < mc->ntotal);
203 if (i == mc->ntotal) {
210 APU_DECLARE(apr_memcache_server_t *) apr_memcache_find_server(apr_memcache_t *mc, const char *host, apr_port_t port)
214 for (i = 0; i < mc->ntotal; i++) {
215 if (strcmp(mc->live_servers[i]->host, host) == 0
216 && mc->live_servers[i]->port == port) {
218 return mc->live_servers[i];
271 APU_DECLARE(apr_status_t) apr_memcache_enable_server(apr_memcache_t *mc, apr_memcache_server_t *ms)
279 rv = make_server_live(mc, ms);
283 APU_DECLARE(apr_status_t) apr_memcache_disable_server(apr_memcache_t *mc, apr_memcache_server_t *ms)
285 return make_server_dead(mc, ms);
443 apr_memcache_t *mc;
445 mc = apr_palloc(p, sizeof(apr_memcache_t));
446 mc->p = p;
447 mc->nalloc = max_servers;
448 mc->ntotal = 0;
449 mc->live_servers = apr_palloc(p, mc->nalloc * sizeof(struct apr_memcache_server_t *));
450 mc->hash_func = NULL;
451 mc->hash_baton = NULL;
452 mc->server_func = NULL;
453 mc->server_baton = NULL;
454 *memcache = mc;
556 APU_DECLARE(apr_uint32_t) apr_memcache_hash(apr_memcache_t *mc,
560 if (mc->hash_func) {
561 return mc->hash_func(mc->hash_baton, data, data_len);
591 static apr_status_t storage_cmd_write(apr_memcache_t *mc,
610 hash = apr_memcache_hash(mc, key, key_size);
612 ms = apr_memcache_find_server_hash(mc, hash);
620 apr_memcache_disable_server(mc, ms);
648 apr_memcache_disable_server(mc, ms);
656 apr_memcache_disable_server(mc, ms);
676 apr_memcache_set(apr_memcache_t *mc,
683 return storage_cmd_write(mc,
691 apr_memcache_add(apr_memcache_t *mc,
698 return storage_cmd_write(mc,
706 apr_memcache_replace(apr_memcache_t *mc,
713 return storage_cmd_write(mc,
722 apr_memcache_getp(apr_memcache_t *mc,
737 hash = apr_memcache_hash(mc, key, klen);
738 ms = apr_memcache_find_server_hash(mc, hash);
745 apr_memcache_disable_server(mc, ms);
763 apr_memcache_disable_server(mc, ms);
770 apr_memcache_disable_server(mc, ms);
806 apr_memcache_disable_server(mc, ms);
816 apr_memcache_disable_server(mc, ms);
823 apr_memcache_disable_server(mc, ms);
836 apr_memcache_disable_server(mc, ms);
857 apr_memcache_delete(apr_memcache_t *mc,
869 hash = apr_memcache_hash(mc, key, klen);
870 ms = apr_memcache_find_server_hash(mc, hash);
877 apr_memcache_disable_server(mc, ms);
897 apr_memcache_disable_server(mc, ms);
904 apr_memcache_disable_server(mc, ms);
923 static apr_status_t num_cmd_write(apr_memcache_t *mc,
938 hash = apr_memcache_hash(mc, key, klen);
939 ms = apr_memcache_find_server_hash(mc, hash);
946 apr_memcache_disable_server(mc, ms);
966 apr_memcache_disable_server(mc, ms);
973 apr_memcache_disable_server(mc, ms);
996 apr_memcache_incr(apr_memcache_t *mc,
1001 return num_cmd_write(mc,
1011 apr_memcache_decr(apr_memcache_t *mc,
1016 return num_cmd_write(mc,
1134 apr_memcache_t *mc,
1152 apr_memcache_disable_server(mc, ms);
1169 apr_memcache_multgetp(apr_memcache_t *mc,
1210 hash = apr_memcache_hash(mc, value->key, klen);
1211 ms = apr_memcache_find_server_hash(mc, hash);
1222 apr_memcache_disable_server(mc, ms);
1280 mget_conn_result(TRUE, TRUE, rv, mc, server_query->ms, server_query->conn,
1306 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1338 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1375 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1387 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1396 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1447 mget_conn_result(TRUE, (rv == APR_SUCCESS), rv, mc, ms, conn,