diff options
Diffstat (limited to 'libglusterfsclient/src/libglusterfsclient-internals.h')
| -rwxr-xr-x | libglusterfsclient/src/libglusterfsclient-internals.h | 144 |
1 files changed, 0 insertions, 144 deletions
diff --git a/libglusterfsclient/src/libglusterfsclient-internals.h b/libglusterfsclient/src/libglusterfsclient-internals.h deleted file mode 100755 index bf87f2a2319..00000000000 --- a/libglusterfsclient/src/libglusterfsclient-internals.h +++ /dev/null @@ -1,144 +0,0 @@ -/* - Copyright (c) 2008-2009 Z RESEARCH, Inc. <http://www.zresearch.com> - This file is part of GlusterFS. - - GlusterFS is free software; you can redistribute it and/or modify - it under the terms of the GNU General Public License as published - by the Free Software Foundation; either version 3 of the License, - or (at your option) any later version. - - GlusterFS is distributed in the hope that it will be useful, but - WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program. If not, see - <http://www.gnu.org/licenses/>. -*/ - -#ifndef __LIBGLUSTERFSCLIENT_INTERNALS_H -#define __LIBGLUSTERFSCLIENT_INTERNALS_H - -#include <glusterfs.h> -#include <logging.h> -#include <inode.h> -#include <pthread.h> -#include <stack.h> -#include <list.h> -#include <signal.h> -#include <call-stub.h> -#include <sys/time.h> -#include <sys/resource.h> -#include <fd.h> - -typedef void (*sighandler_t) (int); -typedef struct list_head list_head_t; - -typedef struct libglusterfs_client_ctx { - glusterfs_ctx_t gf_ctx; - inode_table_t *itable; - pthread_t reply_thread; - call_pool_t pool; - uint32_t counter; - time_t lookup_timeout; - time_t stat_timeout; -}libglusterfs_client_ctx_t; - -typedef struct signal_handler { - int signo; - sighandler_t handler; - list_head_t next; -}libgf_client_signal_handler_t ; - -typedef struct { - pthread_mutex_t lock; - pthread_cond_t reply_cond; - call_stub_t *reply_stub; - char complete; - union { - struct { - char is_revalidate; - loc_t *loc; - int32_t size; - } lookup; - }fop; -}libgf_client_local_t; - -#define LIBGF_STACK_WIND_AND_WAIT(frame, rfn, obj, fn, params ...) \ - do { \ - STACK_WIND (frame, rfn, obj, fn, params); \ - pthread_mutex_lock (&local->lock); \ - { \ - while (!local->complete) { \ - pthread_cond_wait (&local->reply_cond, &local->lock); \ - } \ - } \ - pthread_mutex_unlock (&local->lock); \ - } while (0) - - - -#define LIBGF_CLIENT_SIGNAL(signal_handler_list, signo, handler) \ - do { \ - libgf_client_signal_handler_t *libgf_handler = CALLOC (1, sizeof (*libgf_handler)); \ - ERR_ABORT (libgf_handler); \ - libgf_handler->signo = signo; \ - libgf_handler->handler = signal (signo, handler); \ - list_add (&libgf_handler->next, signal_handler_list); \ - } while (0) - -#define LIBGF_INSTALL_SIGNAL_HANDLERS(signal_handlers) \ - do { \ - INIT_LIST_HEAD (&signal_handlers); \ - /* Handle SIGABORT and SIGSEGV */ \ - LIBGF_CLIENT_SIGNAL (&signal_handlers, SIGSEGV, gf_print_trace); \ - LIBGF_CLIENT_SIGNAL (&signal_handlers, SIGABRT, gf_print_trace); \ - LIBGF_CLIENT_SIGNAL (&signal_handlers, SIGHUP, gf_log_logrotate); \ - /* LIBGF_CLIENT_SIGNAL (SIGTERM, glusterfs_cleanup_and_exit); */ \ - } while (0) - -#define LIBGF_RESTORE_SIGNAL_HANDLERS(local) \ - do { \ - libgf_client_signal_handler_t *ptr = NULL, *tmp = NULL; \ - list_for_each_entry_safe (ptr, tmp, &local->signal_handlers, next) { \ - signal (ptr->signo, ptr->handler); \ - FREE (ptr); \ - } \ - } while (0) - -#define LIBGF_CLIENT_FOP_ASYNC(ctx, local, ret_fn, op, args ...) \ - do { \ - call_frame_t *frame = get_call_frame_for_req (ctx, 1); \ - xlator_t *xl = frame->this->children ? \ - frame->this->children->xlator : NULL; \ - dict_t *refs = frame->root->req_refs; \ - frame->root->state = ctx; \ - frame->local = local; \ - STACK_WIND (frame, ret_fn, xl, xl->fops->op, args); \ - dict_unref (refs); \ - } while (0) - -#define LIBGF_CLIENT_FOP(ctx, stub, op, local, args ...) \ - do { \ - call_frame_t *frame = get_call_frame_for_req (ctx, 1); \ - xlator_t *xl = frame->this->children ? \ - frame->this->children->xlator : NULL; \ - dict_t *refs = frame->root->req_refs; \ - if (!local) { \ - local = CALLOC (1, sizeof (*local)); \ - } \ - ERR_ABORT (local); \ - frame->local = local; \ - frame->root->state = ctx; \ - pthread_cond_init (&local->reply_cond, NULL); \ - pthread_mutex_init (&local->lock, NULL); \ - LIBGF_STACK_WIND_AND_WAIT (frame, libgf_client_##op##_cbk, xl, xl->fops->op, args); \ - dict_unref (refs); \ - stub = local->reply_stub; \ - FREE (frame->local); \ - frame->local = NULL; \ - STACK_DESTROY (frame->root); \ - } while (0) - -#endif |