Lines Matching defs:ms
32 apr_memcache_server_t *ms;
104 apr_memcache_server_t* ms;
112 static apr_status_t make_server_dead(apr_memcache_t *mc, apr_memcache_server_t *ms)
115 apr_thread_mutex_lock(ms->lock);
117 ms->status = APR_MC_SERVER_DEAD;
118 ms->btime = apr_time_now();
120 apr_thread_mutex_unlock(ms->lock);
125 static apr_status_t make_server_live(apr_memcache_t *mc, apr_memcache_server_t *ms)
127 ms->status = APR_MC_SERVER_LIVE;
132 APU_DECLARE(apr_status_t) apr_memcache_add_server(apr_memcache_t *mc, apr_memcache_server_t *ms)
140 mc->live_servers[mc->ntotal] = ms;
142 make_server_live(mc, ms);
146 static apr_status_t mc_version_ping(apr_memcache_server_t *ms);
163 apr_memcache_server_t *ms = NULL;
173 ms = mc->live_servers[h % mc->ntotal];
174 if(ms->status == APR_MC_SERVER_LIVE) {
182 apr_thread_mutex_lock(ms->lock);
185 if (curtime - ms->btime > apr_time_from_sec(5)) {
186 ms->btime = curtime;
187 if (mc_version_ping(ms) == APR_SUCCESS) {
188 make_server_live(mc, ms);
190 apr_thread_mutex_unlock(ms->lock);
196 apr_thread_mutex_unlock(ms->lock);
204 ms = NULL;
207 return ms;
225 static apr_status_t ms_find_conn(apr_memcache_server_t *ms, apr_memcache_conn_t **conn)
232 rv = apr_reslist_acquire(ms->conns, (void **)conn);
234 *conn = ms->conn;
252 static apr_status_t ms_bad_conn(apr_memcache_server_t *ms, apr_memcache_conn_t *conn)
255 return apr_reslist_invalidate(ms->conns, conn);
261 static apr_status_t ms_release_conn(apr_memcache_server_t *ms, apr_memcache_conn_t *conn)
265 return apr_reslist_release(ms->conns, conn);
271 APU_DECLARE(apr_status_t) apr_memcache_enable_server(apr_memcache_t *mc, apr_memcache_server_t *ms)
275 if (ms->status == APR_MC_SERVER_LIVE) {
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);
293 apr_int32_t family = conn->ms->host[0] != '/' ? APR_INET : APR_UNIX;
298 rv = apr_sockaddr_info_get(&sa, conn->ms->host, family, conn->ms->port, 0, conn->p);
329 apr_memcache_server_t *ms = params;
331 apr_int32_t family = ms->host[0] != '/' ? APR_INET : APR_UNIX;
361 conn->ms = ms;
403 apr_memcache_server_t **ms)
443 *ms = server;
611 apr_memcache_server_t *ms;
622 ms = apr_memcache_find_server_hash(mc, hash);
624 if (ms == NULL)
627 rv = ms_find_conn(ms, &conn);
630 apr_memcache_disable_server(mc, ms);
657 ms_bad_conn(ms, conn);
658 apr_memcache_disable_server(mc, ms);
665 ms_bad_conn(ms, conn);
666 apr_memcache_disable_server(mc, ms);
680 ms_release_conn(ms, conn);
740 apr_memcache_server_t *ms;
748 ms = apr_memcache_find_server_hash(mc, hash);
749 if (ms == NULL)
752 rv = ms_find_conn(ms, &conn);
755 apr_memcache_disable_server(mc, ms);
772 ms_bad_conn(ms, conn);
773 apr_memcache_disable_server(mc, ms);
779 ms_bad_conn(ms, conn);
780 apr_memcache_disable_server(mc, ms);
815 ms_bad_conn(ms, conn);
816 apr_memcache_disable_server(mc, ms);
825 ms_bad_conn(ms, conn);
826 apr_memcache_disable_server(mc, ms);
832 ms_bad_conn(ms, conn);
833 apr_memcache_disable_server(mc, ms);
845 ms_bad_conn(ms, conn);
846 apr_memcache_disable_server(mc, ms);
861 ms_release_conn(ms, conn);
872 apr_memcache_server_t *ms;
880 ms = apr_memcache_find_server_hash(mc, hash);
881 if (ms == NULL)
884 rv = ms_find_conn(ms, &conn);
887 apr_memcache_disable_server(mc, ms);
906 ms_bad_conn(ms, conn);
907 apr_memcache_disable_server(mc, ms);
913 ms_bad_conn(ms, conn);
914 apr_memcache_disable_server(mc, ms);
928 ms_release_conn(ms, conn);
941 apr_memcache_server_t *ms;
949 ms = apr_memcache_find_server_hash(mc, hash);
950 if (ms == NULL)
953 rv = ms_find_conn(ms, &conn);
956 apr_memcache_disable_server(mc, ms);
975 ms_bad_conn(ms, conn);
976 apr_memcache_disable_server(mc, ms);
982 ms_bad_conn(ms, conn);
983 apr_memcache_disable_server(mc, ms);
1000 ms_release_conn(ms, conn);
1037 apr_memcache_version(apr_memcache_server_t *ms,
1046 rv = ms_find_conn(ms, &conn);
1062 ms_bad_conn(ms, conn);
1068 ms_bad_conn(ms, conn);
1081 ms_release_conn(ms, conn);
1086 apr_status_t mc_version_ping(apr_memcache_server_t *ms)
1093 rv = ms_find_conn(ms, &conn);
1109 ms_bad_conn(ms, conn);
1114 ms_release_conn(ms, conn);
1145 apr_memcache_server_t *ms,
1154 apr_hash_set(server_queries, &ms, sizeof(ms), NULL);
1157 ms_release_conn(ms, conn);
1159 ms_bad_conn(ms, conn);
1162 apr_memcache_disable_server(mc, ms);
1185 apr_memcache_server_t* ms;
1221 ms = apr_memcache_find_server_hash(mc, hash);
1222 if (ms == NULL) {
1226 server_query = apr_hash_get(server_queries, &ms, sizeof(ms));
1229 rv = ms_find_conn(ms, &conn);
1232 apr_memcache_disable_server(mc, ms);
1239 apr_hash_set(server_queries, &ms, sizeof(ms), server_query);
1241 server_query->ms = ms;
1290 mget_conn_result(TRUE, TRUE, rv, mc, server_query->ms, server_query->conn,
1308 ms = server_query->ms;
1316 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1342 ms = server_query->ms;
1348 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1385 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1397 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1406 mget_conn_result(FALSE, FALSE, rv, mc, ms, conn,
1434 ms_release_conn(ms, conn);
1435 apr_hash_set(server_queries, &ms, sizeof(ms), NULL);
1455 ms = server_query->ms;
1457 mget_conn_result(TRUE, (rv == APR_SUCCESS), rv, mc, ms, conn,
1647 apr_memcache_stats(apr_memcache_server_t *ms,
1657 rv = ms_find_conn(ms, &conn);
1673 ms_bad_conn(ms, conn);
1682 ms_bad_conn(ms, conn);
1701 ms_release_conn(ms, conn);