apr-util/test/testmemcache.c

133   apr_status_t rv;
140   rv = apr_memcache_create(pool, max_servers, 0, &memcache);
141   ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
147     rv =
149     ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
151     rv = apr_memcache_add_server(memcache, server);
152     ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
157     rv = apr_memcache_disable_server(memcache, s);
158     ABTS_ASSERT(tc, "server disable failed", rv == APR_SUCCESS);
160     rv = apr_memcache_enable_server(memcache, s);
161     ABTS_ASSERT(tc, "server enable failed", rv == APR_SUCCESS);
170   rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
171   ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
173   rv = apr_memcache_add_server(memcache, server);
174   ABTS_ASSERT(tc, "server add should have failed", rv != APR_SUCCESS);
199   apr_status_t rv;
208   rv = apr_memcache_create(pool, max_servers, 0, &memcache);
209   ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
224     rv = apr_memcache_server_create(pool, HOST, i, 0, 1, 1, 60, &ms);
225     ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
227     rv = apr_memcache_add_server(memcache, ms);
228     ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
250     apr_status_t rv;
252     rv = apr_memcache_create(pool, 1, 0, &memcache);
253     ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
255     rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
256     ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
258     rv = apr_memcache_add_server(memcache, server);
259     ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
261     rv = apr_memcache_version(server, pool, &result);
264     rv = apr_memcache_stats(server, p, &stats);
308  apr_status_t rv;
316   rv = apr_memcache_create(pool, 1, 0, &memcache);
317   ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
319   rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
320   ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
322   rv = apr_memcache_add_server(memcache, server);
323   ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
337     rv = apr_memcache_replace(memcache, key, v, strlen(v) - 1, 0, 27);
338     ABTS_ASSERT(tc, "replace should have failed", rv != APR_SUCCESS);
341     rv = apr_memcache_add(memcache, key, v, strlen(v), 0, 27);
342     ABTS_ASSERT(tc, "add failed", rv == APR_SUCCESS);
345     rv = apr_memcache_replace(memcache, key, "new", sizeof("new") - 1, 0, 27);
346     ABTS_ASSERT(tc, "replace failed", rv == APR_SUCCESS);
349     rv = apr_memcache_getp(memcache, pool, key, &result, &len, NULL);
350     ABTS_ASSERT(tc, "get failed", rv == APR_SUCCESS);
354     rv = apr_memcache_add(memcache, key, v, strlen(v), 0, 27);
355     ABTS_ASSERT(tc, "add should have failed", rv != APR_SUCCESS);
358     rv = apr_memcache_delete(memcache, key, 0);
359     ABTS_ASSERT(tc, "delete failed", rv == APR_SUCCESS);
367  apr_status_t rv;
375   rv = apr_memcache_create(pool, 1, 0, &memcache);
376   ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
378   rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
379   ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
381   rv = apr_memcache_add_server(memcache, server);
382   ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
384   rv = apr_memcache_set(memcache, prefix, "271", sizeof("271") - 1, 0, 27);
385   ABTS_ASSERT(tc, "set failed", rv == APR_SUCCESS);
390     rv = apr_memcache_getp(memcache, pool, prefix, &result, &len, NULL);
391     ABTS_ASSERT(tc, "get failed", rv == APR_SUCCESS);
395     rv = apr_memcache_incr(memcache, prefix, i, &new);
396     ABTS_ASSERT(tc, "incr failed", rv == APR_SUCCESS);
400     rv = apr_memcache_decr(memcache, prefix, i, &new);
401     ABTS_ASSERT(tc, "decr failed", rv == APR_SUCCESS);
406   rv = apr_memcache_getp(memcache, pool, prefix, &result, &len, NULL);
407   ABTS_ASSERT(tc, "get failed", rv == APR_SUCCESS);
411   rv = apr_memcache_delete(memcache, prefix, 0);
412   ABTS_ASSERT(tc, "delete failed", rv == APR_SUCCESS);
420   apr_status_t rv;
427   rv = apr_memcache_create(pool, 1, 0, &memcache);
428   ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
430   rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
431   ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
433   rv = apr_memcache_add_server(memcache, server);
434   ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
449     rv = apr_memcache_set(memcache, key, v, strlen(v), 0, 27);
450     ABTS_ASSERT(tc, "set failed", rv == APR_SUCCESS);
453   rv = apr_pool_create(&tmppool, pool);
460   rv = apr_memcache_multgetp(memcache,
465   ABTS_ASSERT(tc, "multgetp failed", rv == APR_SUCCESS);
476     rv = apr_memcache_delete(memcache, key, 0);
477     ABTS_ASSERT(tc, "delete failed", rv == APR_SUCCESS);
487     apr_status_t rv;
495     rv = apr_memcache_create(pool, 1, 0, &memcache);
496     ABTS_ASSERT(tc, "memcache create failed", rv == APR_SUCCESS);
498     rv = apr_memcache_server_create(pool, HOST, PORT, 0, 1, 1, 60, &server);
499     ABTS_ASSERT(tc, "server create failed", rv == APR_SUCCESS);
501     rv = apr_memcache_add_server(memcache, server);
502     ABTS_ASSERT(tc, "server add failed", rv == APR_SUCCESS);
516 	rv = apr_memcache_set(memcache, key, v, strlen(v), 0, 27);
517 	ABTS_ASSERT(tc, "set failed", rv == APR_SUCCESS);
518 	rv = apr_memcache_getp(memcache, pool, key, &result, &len, NULL);
519 	ABTS_ASSERT(tc, "get failed", rv == APR_SUCCESS);
522     rv = apr_memcache_getp(memcache, pool, "nothere3423", &result, &len, NULL);
524     ABTS_ASSERT(tc, "get should have failed", rv != APR_SUCCESS);
533 	rv = apr_memcache_delete(memcache, key, 0);
534 	ABTS_ASSERT(tc, "delete failed", rv == APR_SUCCESS);
544   apr_status_t rv;
552   rv = apr_socket_create(&sock, APR_INET, SOCK_STREAM, 0, pool);
553   if(rv != APR_SUCCESS) {
554     return rv;
557   rv = apr_sockaddr_info_get(&sa, HOST, APR_INET, PORT, 0, pool);
558   if(rv != APR_SUCCESS) {
559     return rv;
562   rv = apr_socket_timeout_set(sock, 1 * APR_USEC_PER_SEC);
563   if (rv != APR_SUCCESS) {
564     return rv;
567   rv = apr_socket_connect(sock, sa);
568   if (rv != APR_SUCCESS) {
569     return rv;
572   rv = apr_socket_timeout_set(sock, -1);
573   if (rv != APR_SUCCESS) {
574     return rv;
583   rv = apr_socket_sendv(sock, vec, 2, &written);
584   if (rv != APR_SUCCESS) {
585     return rv;
589   rv = apr_socket_recv(sock, buf, &len);
590   if(rv != APR_SUCCESS) {
591     return rv;
595     rv = APR_EGENERAL;
599   return rv;
604     apr_status_t rv;
609     rv = check_mc();
610     if (rv == APR_SUCCESS) {
622                          rv, HOST, PORT);