X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?p=netatalk.git;a=blobdiff_plain;f=test%2Fnetalockd%2Ftest.c;fp=test%2Fnetalockd%2Ftest.c;h=0000000000000000000000000000000000000000;hp=a73961a4ddef1677007cfcbd4fe72e5678fd5019;hb=4bd04174ada685a5d7516e6eac84866d04b748a5;hpb=056d3ef4c88ba09eabb1fcbf06bdd9fe6e7af4cf diff --git a/test/netalockd/test.c b/test/netalockd/test.c deleted file mode 100644 index a73961a4..00000000 --- a/test/netalockd/test.c +++ /dev/null @@ -1,123 +0,0 @@ -/* - * Copyright (c) 2010 Frank Lahm - * All Rights Reserved. See COPYRIGHT. - */ - -#ifdef HAVE_CONFIG_H -#include "config.h" -#endif /* HAVE_CONFIG_H */ - -#include -#include -#include -#include -#include - -#include -#include -#include -#include -#include -#include - -#include "event2/event-config.h" -#include "event2/event.h" -#include "event2/http.h" -#include "event2/event_compat.h" -#include "event2/http_compat.h" -#include "event2/rpc.h" -#include "event2/rpc_struct.h" - -#include - -#define NUM_RPCS 10000 -int count = NUM_RPCS; - -EVRPC_HEADER(lock_msg, lock_req, lock_rep) -EVRPC_GENERATE(lock_msg, lock_req, lock_rep) - -static struct event_base *ev_base; -static struct evrpc_pool *rpc_pool; - -static void ev_log_cb(int severity, const char *msg) -{ - LOG(log_warning, logtype_default, (char *)msg); -} - -static void do_one_rpc(const char *name); - -static void msg_rep_cb(struct evrpc_status *status, - struct lock_req *req, - struct lock_rep *rep, - void *arg) -{ - char buf[32]; - - if (status->error != EVRPC_STATUS_ERR_NONE) { - LOG(log_warning, logtype_default, "msg_rep_cb: RPC error: %i", status->error); - event_base_loopexit(ev_base, NULL); - goto exit; - } - - if (--count == 0) { - LOG(log_warning, logtype_default, "msg_rep_cb: count: %i", count); - event_base_loopexit(ev_base, NULL); - goto exit; - } - - LOG(log_warning, logtype_default, "msg_rep_cb: count: %i", count); - - snprintf(buf, 32, "count: %i", count); - do_one_rpc(buf); - -exit: - return; -} - -static void do_one_rpc(const char *name) -{ - static struct lock *lock = NULL; - static struct lock_req *lock_req = NULL; - static struct lock_rep *lock_rep = NULL; - - if (lock == NULL) { - lock = lock_new(); - lock_req = lock_req_new(); - lock_rep = lock_rep_new(); - } else { - lock_clear(lock); - lock_req_clear(lock_req); - lock_rep_clear(lock_rep); - } - - EVTAG_ASSIGN(lock_req, req_lock, lock); - EVTAG_ASSIGN(lock_req, req_filename, name); - - EVRPC_MAKE_REQUEST(lock_msg, rpc_pool, lock_req, lock_rep, msg_rep_cb, NULL); -} - -static int my_rpc_init(const char *addr, unsigned short port) -{ - EC_INIT; - struct evhttp_connection *evcon; - - EC_NULL_LOG(ev_base = event_init()); - event_set_log_callback(ev_log_cb); - EC_NULL_LOG(rpc_pool = evrpc_pool_new(NULL)); - EC_NULL_LOG(evcon = evhttp_connection_new(addr, port)); - evrpc_pool_add_connection(rpc_pool, evcon); - -EC_CLEANUP: - EC_EXIT; -} - -int main(int argc, char **argv) -{ - set_processname("test"); - setuplog("default log_maxdebug test.log"); - if (my_rpc_init("127.0.0.1", 4702) != 0) - return 1; - do_one_rpc("test"); - event_dispatch(); - return 0; -}