summaryrefslogtreecommitdiffstats
path: root/libglusterfsclient
diff options
context:
space:
mode:
Diffstat (limited to 'libglusterfsclient')
-rw-r--r--libglusterfsclient/Makefile.am3
-rw-r--r--libglusterfsclient/src/Makefile.am16
-rwxr-xr-xlibglusterfsclient/src/libglusterfsclient-internals.h144
-rwxr-xr-xlibglusterfsclient/src/libglusterfsclient.c3146
-rwxr-xr-xlibglusterfsclient/src/libglusterfsclient.h279
5 files changed, 3588 insertions, 0 deletions
diff --git a/libglusterfsclient/Makefile.am b/libglusterfsclient/Makefile.am
new file mode 100644
index 00000000000..d471a3f9243
--- /dev/null
+++ b/libglusterfsclient/Makefile.am
@@ -0,0 +1,3 @@
+SUBDIRS = src
+
+CLEANFILES =
diff --git a/libglusterfsclient/src/Makefile.am b/libglusterfsclient/src/Makefile.am
new file mode 100644
index 00000000000..8382b2561b1
--- /dev/null
+++ b/libglusterfsclient/src/Makefile.am
@@ -0,0 +1,16 @@
+lib_LTLIBRARIES = libglusterfsclient.la
+noinst_HEADERS = libglusterfsclient-internals.h
+libglusterfsclient_HEADERS = libglusterfsclient.h
+libglusterfsclientdir = $(includedir)
+
+libglusterfsclient_la_SOURCES = libglusterfsclient.c
+libglusterfsclient_la_CFLAGS = -fPIC -Wall -pthread
+libglusterfsclient_la_LIBADD = $(top_builddir)/libglusterfs/src/libglusterfs.la
+libglusterfsclient_la_CPPFLAGS = -D_FILE_OFFSET_BITS=64 -D$(GF_HOST_OS) -D__USE_FILE_OFFSET64 -D_GNU_SOURCE -I$(top_srcdir)/libglusterfs/src -DDATADIR=\"$(localstatedir)\" -DCONFDIR=\"$(sysconfdir)/glusterfs\" $(GF_CFLAGS)
+libglusterfsclient_la_LDFLAGS = -shared -nostartfiles
+
+CLEANFILES =
+
+$(top_builddir)/libglusterfs/src/libglusterfs.la:
+ $(MAKE) -C $(top_builddir)/libglusterfs/src/ all
+
diff --git a/libglusterfsclient/src/libglusterfsclient-internals.h b/libglusterfsclient/src/libglusterfsclient-internals.h
new file mode 100755
index 00000000000..c07da818018
--- /dev/null
+++ b/libglusterfsclient/src/libglusterfsclient-internals.h
@@ -0,0 +1,144 @@
+/*
+ Copyright (c) 2008 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
diff --git a/libglusterfsclient/src/libglusterfsclient.c b/libglusterfsclient/src/libglusterfsclient.c
new file mode 100755
index 00000000000..51098a065eb
--- /dev/null
+++ b/libglusterfsclient/src/libglusterfsclient.c
@@ -0,0 +1,3146 @@
+/*
+ Copyright (c) 2008 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 _GNU_SOURCE
+#define _GNU_SOURCE
+#endif
+
+#include <stdio.h>
+#include <errno.h>
+#include <libgen.h>
+#include <stddef.h>
+
+#include <sys/time.h>
+#include <sys/stat.h>
+#include <unistd.h>
+#include <xlator.h>
+#include <timer.h>
+#include "defaults.h"
+#include <time.h>
+#include <poll.h>
+#include "transport.h"
+#include "event.h"
+#include "libglusterfsclient.h"
+#include "libglusterfsclient-internals.h"
+#include "compat.h"
+#include "compat-errno.h"
+
+#define XLATOR_NAME "libglusterfsclient"
+#define LIBGLUSTERFS_INODE_TABLE_LRU_LIMIT 14057
+
+typedef struct {
+ pthread_cond_t init_con_established;
+ pthread_mutex_t lock;
+ char complete;
+}libglusterfs_client_private_t;
+
+typedef struct {
+ pthread_mutex_t lock;
+ uint32_t previous_lookup_time;
+ uint32_t previous_stat_time;
+ struct stat stbuf;
+} libglusterfs_client_inode_ctx_t;
+
+typedef struct {
+ pthread_mutex_t lock;
+ off_t offset;
+ libglusterfs_client_ctx_t *ctx;
+} libglusterfs_client_fd_ctx_t;
+
+typedef struct libglusterfs_client_async_local {
+ void *cbk_data;
+ union {
+ struct {
+ fd_t *fd;
+ glusterfs_readv_cbk_t cbk;
+ }readv_cbk;
+
+ struct {
+ fd_t *fd;
+ glusterfs_writev_cbk_t cbk;
+ }writev_cbk;
+
+ struct {
+ fd_t *fd;
+ }close_cbk;
+
+ struct {
+ void *buf;
+ size_t size;
+ loc_t *loc;
+ char is_revalidate;
+ glusterfs_lookup_cbk_t cbk;
+ }lookup_cbk;
+ }fop;
+}libglusterfs_client_async_local_t;
+
+static inline xlator_t *
+libglusterfs_graph (xlator_t *graph);
+
+static int first_init = 1;
+static int first_fini = 1;
+
+
+char *
+zr_build_process_uuid ()
+{
+ char tmp_str[1024] = {0,};
+ char hostname[256] = {0,};
+ struct timeval tv = {0,};
+ struct tm now = {0, };
+ char now_str[32];
+
+ if (-1 == gettimeofday(&tv, NULL)) {
+ gf_log ("", GF_LOG_ERROR,
+ "gettimeofday: failed %s",
+ strerror (errno));
+ }
+
+ if (-1 == gethostname (hostname, 256)) {
+ gf_log ("", GF_LOG_ERROR,
+ "gethostname: failed %s",
+ strerror (errno));
+ }
+
+ localtime_r (&tv.tv_sec, &now);
+ strftime (now_str, 32, "%Y/%m/%d-%H:%M:%S", &now);
+ snprintf (tmp_str, 1024, "%s-%d-%s:%ld",
+ hostname, getpid(), now_str, tv.tv_usec);
+
+ return strdup (tmp_str);
+}
+
+
+int32_t
+libgf_client_forget (xlator_t *this,
+ inode_t *inode)
+{
+ libglusterfs_client_inode_ctx_t *ctx = NULL;
+
+ inode_ctx_del (inode, this, (uint64_t *)ctx);
+ FREE (ctx);
+
+ return 0;
+}
+
+
+int32_t
+libgf_client_release (xlator_t *this,
+ fd_t *fd)
+{
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (fd->ctx, XLATOR_NAME);
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ pthread_mutex_destroy (&fd_ctx->lock);
+
+ return 0;
+}
+
+
+int32_t
+libgf_client_releasedir (xlator_t *this,
+ fd_t *fd)
+{
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (fd->ctx, XLATOR_NAME);
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ pthread_mutex_destroy (&fd_ctx->lock);
+
+ return 0;
+}
+
+
+void *poll_proc (void *ptr)
+{
+ glusterfs_ctx_t *ctx = ptr;
+
+ event_dispatch (ctx->event_pool);
+
+ return NULL;
+}
+
+
+int32_t
+xlator_graph_init (xlator_t *xl)
+{
+ xlator_t *trav = xl;
+ int32_t ret = -1;
+
+ while (trav->prev)
+ trav = trav->prev;
+
+ while (trav) {
+ if (!trav->ready) {
+ ret = xlator_tree_init (trav);
+ if (ret < 0)
+ break;
+ }
+ trav = trav->next;
+ }
+
+ return ret;
+}
+
+
+void
+xlator_graph_fini (xlator_t *xl)
+{
+ xlator_t *trav = xl;
+ while (trav->prev)
+ trav = trav->prev;
+
+ while (trav) {
+ if (!trav->init_succeeded) {
+ break;
+ }
+
+ xlator_tree_fini (trav);
+ trav = trav->next;
+ }
+}
+
+
+static void
+libgf_client_loc_wipe (loc_t *loc)
+{
+ if (loc->path) {
+ FREE (loc->path);
+ }
+
+ if (loc->parent) {
+ inode_unref (loc->parent);
+ loc->parent = NULL;
+ }
+
+ if (loc->inode) {
+ inode_unref (loc->inode);
+ loc->inode = NULL;
+ }
+}
+
+
+static int32_t
+libgf_client_loc_fill (loc_t *loc, const char *path,
+ ino_t ino, libglusterfs_client_ctx_t *ctx)
+{
+ int32_t op_ret = -1;
+ int32_t ret = 0;
+ char *dentry_path = NULL;
+
+ loc->inode = NULL;
+ /* directory structure is flat. All files are immediate children of root */
+ if (path) {
+ /* libglusterfsclient accepts only absolute paths */
+ if (path[0] != '/') {
+ asprintf ((char **) &loc->path, "/%s", path);
+ } else {
+ loc->path = strdup (path);
+ }
+
+ loc->inode = inode_search (ctx->itable, 1, path);
+ } else {
+ loc->inode = inode_search (ctx->itable, ino, NULL);
+ if (loc->inode == NULL) {
+ gf_log ("libglusterfsclient", GF_LOG_ERROR,
+ "cannot find inode for ino %"PRId64,
+ ino);
+ goto out;
+ }
+
+ ret = inode_path (loc->inode, NULL, &dentry_path);
+ if (ret <= 0) {
+ gf_log ("libglusterfsclient", GF_LOG_ERROR,
+ "inode_path failed for %"PRId64,
+ loc->inode->ino);
+ inode_unref (loc->inode);
+ op_ret = ret;
+ goto out;
+ } else {
+ loc->path = dentry_path;
+ }
+ }
+
+ loc->name = strrchr (loc->path, '/');
+ if (loc->name) {
+ loc->name++;
+ }
+
+ loc->parent = inode_ref (ctx->itable->root);
+
+ if (loc->inode) {
+ loc->ino = loc->inode->ino;
+ }
+
+ op_ret = 0;
+out:
+ return op_ret;
+}
+
+
+static call_frame_t *
+get_call_frame_for_req (libglusterfs_client_ctx_t *ctx, char d)
+{
+ call_pool_t *pool = ctx->gf_ctx.pool;
+ xlator_t *this = ctx->gf_ctx.graph;
+ call_frame_t *frame = NULL;
+
+
+ frame = create_frame (this, pool);
+
+ frame->root->uid = geteuid ();
+ frame->root->gid = getegid ();
+ frame->root->pid = getpid ();
+ frame->root->unique = ctx->counter++;
+
+ if (d) {
+ frame->root->req_refs = dict_ref (get_new_dict ());
+ /*
+ TODO
+ dict_set (frame->root->req_refs, NULL, priv->buf);
+ */
+ }
+
+ return frame;
+}
+
+void
+libgf_client_fini (xlator_t *this)
+{
+ FREE (this->private);
+ return;
+}
+
+
+int32_t
+libgf_client_notify (xlator_t *this,
+ int32_t event,
+ void *data,
+ ...)
+{
+ libglusterfs_client_private_t *priv = this->private;
+
+ switch (event)
+ {
+ case GF_EVENT_CHILD_UP:
+ pthread_mutex_lock (&priv->lock);
+ {
+ priv->complete = 1;
+ pthread_cond_broadcast (&priv->init_con_established);
+ }
+ pthread_mutex_unlock (&priv->lock);
+ break;
+
+ default:
+ default_notify (this, event, data);
+ }
+
+ return 0;
+}
+
+int32_t
+libgf_client_init (xlator_t *this)
+{
+ return 0;
+}
+
+
+libglusterfs_handle_t
+glusterfs_init (glusterfs_init_ctx_t *init_ctx)
+{
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_private_t *priv = NULL;
+ FILE *specfp = NULL;
+ xlator_t *graph = NULL, *trav = NULL;
+ call_pool_t *pool = NULL;
+ int32_t ret = 0;
+ struct rlimit lim;
+ uint32_t xl_count = 0;
+
+ if (!init_ctx || (!init_ctx->specfile && !init_ctx->specfp)) {
+ errno = EINVAL;
+ return NULL;
+ }
+
+ ctx = CALLOC (1, sizeof (*ctx));
+ if (!ctx) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: out of memory\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__);
+
+ errno = ENOMEM;
+ return NULL;
+ }
+
+ ctx->lookup_timeout = init_ctx->lookup_timeout;
+ ctx->stat_timeout = init_ctx->stat_timeout;
+
+ pthread_mutex_init (&ctx->gf_ctx.lock, NULL);
+
+ pool = ctx->gf_ctx.pool = CALLOC (1, sizeof (call_pool_t));
+ if (!pool) {
+ errno = ENOMEM;
+ FREE (ctx);
+ return NULL;
+ }
+
+ LOCK_INIT (&pool->lock);
+ INIT_LIST_HEAD (&pool->all_frames);
+
+ ctx->gf_ctx.event_pool = event_pool_new (16384);
+
+ lim.rlim_cur = RLIM_INFINITY;
+ lim.rlim_max = RLIM_INFINITY;
+ setrlimit (RLIMIT_CORE, &lim);
+ setrlimit (RLIMIT_NOFILE, &lim);
+
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_WARNING;
+
+ if (init_ctx->logfile)
+ ctx->gf_ctx.cmd_args.log_file = strdup (init_ctx->logfile);
+ else
+ ctx->gf_ctx.cmd_args.log_file = strdup ("/dev/stderr");
+
+ if (init_ctx->loglevel) {
+ if (!strncasecmp (init_ctx->loglevel, "DEBUG", strlen ("DEBUG"))) {
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_DEBUG;
+ } else if (!strncasecmp (init_ctx->loglevel, "WARNING", strlen ("WARNING"))) {
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_WARNING;
+ } else if (!strncasecmp (init_ctx->loglevel, "CRITICAL", strlen ("CRITICAL"))) {
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_CRITICAL;
+ } else if (!strncasecmp (init_ctx->loglevel, "NONE", strlen ("NONE"))) {
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_NONE;
+ } else if (!strncasecmp (init_ctx->loglevel, "ERROR", strlen ("ERROR"))) {
+ ctx->gf_ctx.cmd_args.log_level = GF_LOG_ERROR;
+ } else {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: Unrecognized log-level \"%s\", possible values are \"DEBUG|WARNING|[ERROR]|CRITICAL|NONE\"\n", __FILE__, __PRETTY_FUNCTION__,
+ __LINE__, init_ctx->loglevel);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ errno = EINVAL;
+ return NULL;
+ }
+ }
+
+ if (first_init)
+ {
+ ret = gf_log_init (ctx->gf_ctx.cmd_args.log_file);
+ if (ret == -1) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: failed to open logfile \"%s\"\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__,
+ ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ return NULL;
+ }
+
+ gf_log_set_loglevel (ctx->gf_ctx.cmd_args.log_level);
+ }
+
+ if (init_ctx->specfp) {
+ specfp = init_ctx->specfp;
+ if (fseek (specfp, 0L, SEEK_SET)) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: fseek on volume file stream failed (%s)\n", __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ return NULL;
+ }
+ } else if (init_ctx->specfile) {
+ specfp = fopen (init_ctx->specfile, "r");
+ ctx->gf_ctx.cmd_args.volume_file = strdup (init_ctx->specfile);
+ }
+
+ if (!specfp) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: could not open volfile: %s\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ return NULL;
+ }
+
+ if (init_ctx->volume_name) {
+ ctx->gf_ctx.cmd_args.volume_name = strdup (init_ctx->volume_name);
+ }
+
+ graph = file_to_xlator_tree (&ctx->gf_ctx, specfp);
+ if (!graph) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: cannot create configuration graph (%s)\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ return NULL;
+ }
+
+ if (init_ctx->volume_name) {
+ trav = graph;
+ while (trav) {
+ if (strcmp (trav->name, init_ctx->volume_name) == 0) {
+ graph = trav;
+ break;
+ }
+ trav = trav->next;
+ }
+ }
+
+ ctx->gf_ctx.graph = libglusterfs_graph (graph);
+ if (!ctx->gf_ctx.graph) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: graph creation failed (%s)\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ FREE (ctx);
+ return NULL;
+ }
+ graph = ctx->gf_ctx.graph;
+
+ trav = graph;
+ while (trav) {
+ xl_count++; /* Getting this value right is very important */
+ trav = trav->next;
+ }
+
+ ctx->gf_ctx.xl_count = xl_count + 1;
+
+ priv = CALLOC (1, sizeof (*priv));
+ if (!priv) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: cannot allocate memory (%s)\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ /* inode_table_destroy (ctx->itable); */
+ FREE (ctx);
+
+ return NULL;
+ }
+
+ pthread_cond_init (&priv->init_con_established, NULL);
+ pthread_mutex_init (&priv->lock, NULL);
+
+ graph->private = priv;
+ ctx->itable = inode_table_new (LIBGLUSTERFS_INODE_TABLE_LRU_LIMIT, graph);
+ if (!ctx->itable) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: cannot create inode table\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__);
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ xlator_tree_free (graph);
+ /* TODO: destroy graph */
+ /* inode_table_destroy (ctx->itable); */
+ FREE (ctx);
+
+ return NULL;
+ }
+
+ if (xlator_graph_init (graph) == -1) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: graph initialization failed\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__);
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ /* TODO: destroy graph */
+ /* inode_table_destroy (ctx->itable); */
+ FREE (ctx);
+ return NULL;
+ }
+
+ /* Send notify to all translator saying things are ready */
+ graph->notify (graph, GF_EVENT_PARENT_UP, graph);
+
+ if (gf_timer_registry_init (&ctx->gf_ctx) == NULL) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: timer init failed (%s)\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__, strerror (errno));
+
+ xlator_graph_fini (graph);
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ /* TODO: destroy graph */
+ /* inode_table_destroy (ctx->itable); */
+ FREE (ctx);
+ return NULL;
+ }
+
+ if ((ret = pthread_create (&ctx->reply_thread, NULL, poll_proc, (void *)&ctx->gf_ctx))) {
+ fprintf (stderr,
+ "libglusterfsclient: %s:%s():%d: reply thread creation failed\n",
+ __FILE__, __PRETTY_FUNCTION__, __LINE__);
+ xlator_graph_fini (graph);
+ xlator_tree_free (graph);
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ /* TODO: destroy graph */
+ /* inode_table_destroy (ctx->itable); */
+ FREE (ctx);
+ return NULL;
+ }
+
+ set_global_ctx_ptr (&ctx->gf_ctx);
+ ctx->gf_ctx.process_uuid = zr_build_process_uuid ();
+
+ pthread_mutex_lock (&priv->lock);
+ {
+ while (!priv->complete) {
+ pthread_cond_wait (&priv->init_con_established, &priv->lock);
+ }
+ }
+ pthread_mutex_unlock (&priv->lock);
+
+ first_init = 0;
+
+ return ctx;
+}
+
+
+void
+glusterfs_reset (void)
+{
+ first_fini = first_init = 1;
+}
+
+
+void
+glusterfs_log_lock (void)
+{
+ gf_log_lock ();
+}
+
+
+void glusterfs_log_unlock (void)
+{
+ gf_log_unlock ();
+}
+
+
+int
+glusterfs_fini (libglusterfs_client_ctx_t *ctx)
+{
+ FREE (ctx->gf_ctx.cmd_args.log_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_file);
+ FREE (ctx->gf_ctx.cmd_args.volume_name);
+ FREE (ctx->gf_ctx.pool);
+ FREE (ctx->gf_ctx.event_pool);
+ ((gf_timer_registry_t *)ctx->gf_ctx.timer)->fin = 1;
+ /* inode_table_destroy (ctx->itable); */
+
+ xlator_graph_fini (ctx->gf_ctx.graph);
+ xlator_tree_free (ctx->gf_ctx.graph);
+ ctx->gf_ctx.graph = NULL;
+
+ /* FREE (ctx->gf_ctx.specfile); */
+
+ /* TODO complete cleanup of timer */
+ /*TODO
+ * destroy the reply thread
+ * destroy inode table
+ * FREE (ctx)
+ */
+
+ FREE (ctx);
+
+ if (first_fini) {
+ ;
+ //gf_log_cleanup ();
+ }
+
+ return 0;
+}
+
+
+int32_t
+libgf_client_lookup_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ inode_t *inode,
+ struct stat *buf,
+ dict_t *dict)
+{
+ libgf_client_local_t *local = frame->local;
+ libglusterfs_client_ctx_t *ctx = frame->root->state;
+ dict_t *xattr_req = NULL;
+
+ if (op_ret == 0) {
+ /* flat directory structure */
+ inode_t *parent = inode_search (ctx->itable, 1, NULL);
+
+ inode_link (inode, parent, local->fop.lookup.loc->path, buf);
+ inode_lookup (inode);
+ inode_unref (parent);
+ } else {
+ if (local->fop.lookup.is_revalidate == 0 && op_errno == ENOENT) {
+ gf_log ("libglusterfsclient", GF_LOG_DEBUG,
+ "%"PRId64": (op_num=%d) %s => -1 (%s)",
+ frame->root->unique, frame->root->op,
+ local->fop.lookup.loc->path,
+ strerror (op_errno));
+ } else {
+ gf_log ("libglusterfsclient", GF_LOG_ERROR,
+ "%"PRId64": (op_num=%d) %s => -1 (%s)",
+ frame->root->unique, frame->root->op,
+ local->fop.lookup.loc->path,
+ strerror (op_errno));
+ }
+
+ if (local->fop.lookup.is_revalidate == 1) {
+ int32_t ret = 0;
+ inode_unref (local->fop.lookup.loc->inode);
+ local->fop.lookup.loc->inode = inode_new (ctx->itable);
+ local->fop.lookup.is_revalidate = 2;
+
+ if (local->fop.lookup.size > 0) {
+ xattr_req = dict_new ();
+ ret = dict_set (xattr_req, "glusterfs.content",
+ data_from_uint64 (local->fop.lookup.size));
+ if (ret == -1) {
+ op_ret = -1;
+ /* TODO: set proper error code */
+ op_errno = errno;
+ inode = NULL;
+ buf = NULL;
+ dict = NULL;
+ dict_unref (xattr_req);
+ goto out;
+ }
+ }
+
+ STACK_WIND (frame, libgf_client_lookup_cbk,
+ FIRST_CHILD (this), FIRST_CHILD (this)->fops->lookup,
+ local->fop.lookup.loc, xattr_req);
+
+ if (xattr_req) {
+ dict_unref (xattr_req);
+ xattr_req = NULL;
+ }
+
+ return 0;
+ }
+ }
+
+out:
+ local->reply_stub = fop_lookup_cbk_stub (frame, NULL, op_ret, op_errno, inode, buf, dict);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int32_t
+libgf_client_lookup (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ struct stat *stbuf,
+ dict_t **dict,
+ dict_t *xattr_req)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret;
+ libgf_client_local_t *local = NULL;
+ xlator_t *this = NULL;
+ int32_t ret = -1;
+
+ local = CALLOC (1, sizeof (*local));
+ if (loc->inode) {
+ local->fop.lookup.is_revalidate = 1;
+ loc->ino = loc->inode->ino;
+ }
+ else
+ loc->inode = inode_new (ctx->itable);
+
+ local->fop.lookup.loc = loc;
+
+ LIBGF_CLIENT_FOP(ctx, stub, lookup, local, loc, xattr_req);
+
+ op_ret = stub->args.lookup_cbk.op_ret;
+ errno = stub->args.lookup_cbk.op_errno;
+
+ if (!op_ret) {
+ time_t current = 0;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ inode_t *inode = stub->args.lookup_cbk.inode;
+ uint64_t ptr = 0;
+
+ this = ctx->gf_ctx.graph;
+ ret = inode_ctx_get (inode, this, &ptr);
+ if (ret == -1) {
+ inode_ctx = CALLOC (1, sizeof (*inode_ctx));
+ ERR_ABORT (inode_ctx);
+ pthread_mutex_init (&inode_ctx->lock, NULL);
+ } else {
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ }
+
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ inode_ctx->previous_lookup_time = current;
+ inode_ctx->previous_stat_time = current;
+ memcpy (&inode_ctx->stbuf, &stub->args.lookup_cbk.buf,
+ sizeof (inode_ctx->stbuf));
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ ret = inode_ctx_get (inode, this, NULL);
+ if (ret == -1) {
+ inode_ctx_put (inode, this, (uint64_t)(long)inode_ctx);
+ }
+
+ if (stbuf)
+ *stbuf = stub->args.lookup_cbk.buf;
+
+ if (dict)
+ *dict = dict_ref (stub->args.lookup_cbk.dict);
+ }
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+int
+glusterfs_lookup (libglusterfs_handle_t handle,
+ const char *path,
+ void *buf,
+ size_t size,
+ struct stat *stbuf)
+{
+ int32_t op_ret = 0;
+ loc_t loc = {0, };
+ libglusterfs_client_ctx_t *ctx = handle;
+ dict_t *dict = NULL;
+ dict_t *xattr_req = NULL;
+
+ op_ret = libgf_client_loc_fill (&loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ if (size < 0)
+ size = 0;
+
+ if (size > 0) {
+ xattr_req = dict_new ();
+ op_ret = dict_set (xattr_req, "glusterfs.content", data_from_uint64 (size));
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "setting requested content size dictionary failed");
+ goto out;
+ }
+ }
+
+ op_ret = libgf_client_lookup (ctx, &loc, stbuf, &dict, xattr_req);
+
+ if (!op_ret && size && stbuf && stbuf->st_size && dict && buf) {
+ data_t *mem_data = NULL;
+ void *mem = NULL;
+
+ mem_data = dict_get (dict, "glusterfs.content");
+ if (mem_data) {
+ mem = data_to_ptr (mem_data);
+ }
+
+ if (mem && stbuf->st_size <= size) {
+ memcpy (buf, mem, stbuf->st_size);
+ }
+ }
+
+ if (dict) {
+ dict_unref (dict);
+ }
+
+ libgf_client_loc_wipe (&loc);
+out:
+ if (xattr_req) {
+ dict_unref (xattr_req);
+ }
+
+ return op_ret;
+}
+
+int
+libgf_client_lookup_async_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ inode_t *inode,
+ struct stat *buf,
+ dict_t *dict)
+{
+ libglusterfs_client_async_local_t *local = frame->local;
+ glusterfs_lookup_cbk_t lookup_cbk = local->fop.lookup_cbk.cbk;
+ libglusterfs_client_ctx_t *ctx = frame->root->state;
+ dict_t *xattr_req = NULL;
+ int32_t ret = 0;
+
+ if (op_ret == 0) {
+ time_t current = 0;
+ data_t *inode_ctx_data = NULL;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+
+ /* flat directory structure */
+ inode_t *parent = inode_search (ctx->itable, 1, NULL);
+
+ inode_link (inode, parent, local->fop.lookup_cbk.loc->path, buf);
+
+ inode_ctx_data = dict_get (inode->ctx, XLATOR_NAME);
+ if (inode_ctx_data) {
+ inode_ctx = data_to_ptr (inode_ctx_data);
+ }
+
+ if (!inode_ctx) {
+ inode_ctx = CALLOC (1, sizeof (*inode_ctx));
+ pthread_mutex_init (&inode_ctx->lock, NULL);
+ }
+
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ inode_ctx->previous_lookup_time = current;
+ inode_ctx->previous_stat_time = current;
+ memcpy (&inode_ctx->stbuf, buf, sizeof (inode_ctx->stbuf));
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ ret = inode_ctx_get (inode, this, NULL);
+ if (ret == -1) {
+ inode_ctx_put (inode, this, (uint64_t)(long)inode_ctx);
+ }
+
+ inode_lookup (inode);
+ inode_unref (parent);
+ } else {
+ if (local->fop.lookup_cbk.is_revalidate == 0 && op_errno == ENOENT) {
+ gf_log ("libglusterfsclient", GF_LOG_DEBUG,
+ "%"PRId64": (op_num=%d) %s => -1 (%s)",
+ frame->root->unique, frame->root->op,
+ local->fop.lookup_cbk.loc->path,
+ strerror (op_errno));
+ } else {
+ gf_log ("libglusterfsclient", GF_LOG_ERROR,
+ "%"PRId64": (op_num=%d) %s => -1 (%s)",
+ frame->root->unique, frame->root->op,
+ local->fop.lookup_cbk.loc->path,
+ strerror (op_errno));
+ }
+
+ if (local->fop.lookup_cbk.is_revalidate == 1) {
+ int32_t ret = 0;
+ inode_unref (local->fop.lookup_cbk.loc->inode);
+ local->fop.lookup_cbk.loc->inode = inode_new (ctx->itable);
+ local->fop.lookup_cbk.is_revalidate = 2;
+
+ if (local->fop.lookup_cbk.size > 0) {
+ xattr_req = dict_new ();
+ ret = dict_set (xattr_req, "glusterfs.content",
+ data_from_uint64 (local->fop.lookup_cbk.size));
+ if (ret == -1) {
+ op_ret = -1;
+ /* TODO: set proper error code */
+ op_errno = errno;
+ inode = NULL;
+ buf = NULL;
+ dict = NULL;
+ dict_unref (xattr_req);
+ goto out;
+ }
+ }
+
+
+ STACK_WIND (frame, libgf_client_lookup_async_cbk,
+ FIRST_CHILD (this), FIRST_CHILD (this)->fops->lookup,
+ local->fop.lookup_cbk.loc, xattr_req);
+
+ if (xattr_req) {
+ dict_unref (xattr_req);
+ xattr_req = NULL;
+ }
+
+ return 0;
+ }
+
+ }
+
+out:
+ if (!op_ret && local->fop.lookup_cbk.size && dict && local->fop.lookup_cbk.buf) {
+ data_t *mem_data = NULL;
+ void *mem = NULL;
+
+ mem_data = dict_get (dict, "glusterfs.content");
+ if (mem_data) {
+ mem = data_to_ptr (mem_data);
+ }
+
+ if (mem && buf->st_size <= local->fop.lookup_cbk.size) {
+ memcpy (local->fop.lookup_cbk.buf, mem, buf->st_size);
+ }
+ }
+
+ lookup_cbk(op_ret, op_errno, local->fop.lookup_cbk.buf, buf, local->cbk_data);
+
+ libgf_client_loc_wipe (local->fop.lookup_cbk.loc);
+ free (local->fop.lookup_cbk.loc);
+
+ free (local);
+ frame->local = NULL;
+ STACK_DESTROY (frame->root);
+
+ return 0;
+}
+
+int
+glusterfs_lookup_async (libglusterfs_handle_t handle,
+ const char *path,
+ void *buf,
+ size_t size,
+ glusterfs_lookup_cbk_t cbk,
+ void *cbk_data)
+{
+ loc_t *loc = NULL;
+ libglusterfs_client_ctx_t *ctx = handle;
+ libglusterfs_client_async_local_t *local = NULL;
+ int32_t op_ret = 0;
+ dict_t *xattr_req = NULL;
+
+ local = CALLOC (1, sizeof (*local));
+ local->fop.lookup_cbk.is_revalidate = 1;
+
+ loc = CALLOC (1, sizeof (*loc));
+ op_ret = libgf_client_loc_fill (loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ if (!loc->inode) {
+ loc->inode = inode_new (ctx->itable);
+ local->fop.lookup_cbk.is_revalidate = 0;
+ }
+
+ local->fop.lookup_cbk.cbk = cbk;
+ local->fop.lookup_cbk.buf = buf;
+ local->fop.lookup_cbk.size = size;
+ local->fop.lookup_cbk.loc = loc;
+ local->cbk_data = cbk_data;
+
+ if (size < 0)
+ size = 0;
+
+ if (size > 0) {
+ xattr_req = dict_new ();
+ op_ret = dict_set (xattr_req, "glusterfs.content", data_from_uint64 (size));
+ if (op_ret < 0) {
+ dict_unref (xattr_req);
+ xattr_req = NULL;
+ goto out;
+ }
+ }
+
+ LIBGF_CLIENT_FOP_ASYNC (ctx,
+ local,
+ libgf_client_lookup_async_cbk,
+ lookup,
+ loc,
+ xattr_req);
+ if (xattr_req) {
+ dict_unref (xattr_req);
+ xattr_req = NULL;
+ }
+
+out:
+ return op_ret;
+}
+
+int32_t
+libgf_client_getxattr_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ dict_t *dict)
+{
+
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_getxattr_cbk_stub (frame, NULL, op_ret, op_errno, dict);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+size_t
+libgf_client_getxattr (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ const char *name,
+ void *value,
+ size_t size)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, getxattr, local, loc, name);
+
+ op_ret = stub->args.getxattr_cbk.op_ret;
+ errno = stub->args.getxattr_cbk.op_errno;
+
+ if (op_ret >= 0) {
+ /*
+ gf_log ("LIBGF_CLIENT", GF_LOG_DEBUG,
+ "%"PRId64": %s => %d", frame->root->unique,
+ state->fuse_loc.loc.path, op_ret);
+ */
+
+ data_t *value_data = dict_get (stub->args.getxattr_cbk.dict, (char *)name);
+
+ if (value_data) {
+ int32_t copy_len = 0;
+ op_ret = value_data->len; /* Don't return the value for '\0' */
+
+ copy_len = size < value_data->len ? size : value_data->len;
+ memcpy (value, value_data->data, copy_len);
+ } else {
+ errno = ENODATA;
+ op_ret = -1;
+ }
+ }
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+ssize_t
+glusterfs_getxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name,
+ void *value,
+ size_t size)
+{
+ int32_t op_ret = 0;
+ loc_t loc = {0, };
+ dict_t *dict = NULL;
+
+ op_ret = libgf_client_loc_fill (&loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ op_ret = libgf_client_lookup (ctx, &loc, NULL, &dict, NULL);
+ if (op_ret == 0) {
+ data_t *value_data = dict_get (dict, (char *)name);
+
+ if (value_data) {
+ int32_t copy_len = 0;
+ op_ret = value_data->len; /* Don't return the value for '\0' */
+
+ copy_len = size < value_data->len ? size : value_data->len;
+ memcpy (value, value_data->data, copy_len);
+ } else {
+ errno = ENODATA;
+ op_ret = -1;
+ }
+ }
+
+ if (dict) {
+ dict_unref (dict);
+ }
+
+ libgf_client_loc_wipe (&loc);
+
+out:
+ return op_ret;
+}
+
+static int32_t
+libgf_client_open_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ fd_t *fd)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_open_cbk_stub (frame, NULL, op_ret, op_errno, fd);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+
+int
+libgf_client_open (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ fd_t *fd,
+ int flags)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, open, local, loc, flags, fd);
+
+ op_ret = stub->args.open_cbk.op_ret;
+ errno = stub->args.open_cbk.op_errno;
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+static int32_t
+libgf_client_create_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ fd_t *fd,
+ inode_t *inode,
+ struct stat *buf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_create_cbk_stub (frame, NULL, op_ret, op_errno, fd, inode, buf);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int
+libgf_client_creat (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ fd_t *fd,
+ int flags,
+ mode_t mode)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ libgf_client_local_t *local = NULL;
+ xlator_t *this = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, create, local, loc, flags, mode, fd);
+
+ if (stub->args.create_cbk.op_ret == 0) {
+ inode_t *libgf_inode = NULL;
+ time_t current = 0;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+
+ /* flat directory structure */
+ inode_t *parent = inode_search (ctx->itable, 1, NULL);
+ libgf_inode = stub->args.create_cbk.inode;
+ inode_link (libgf_inode, parent,
+ loc->path, &stub->args.create_cbk.buf);
+
+ inode_lookup (libgf_inode);
+ inode_unref (parent);
+
+ inode_ctx = CALLOC (1, sizeof (*inode_ctx));
+ ERR_ABORT (inode_ctx);
+ pthread_mutex_init (&inode_ctx->lock, NULL);
+
+ current = time (NULL);
+
+ inode_ctx->previous_lookup_time = current;
+ inode_ctx->previous_stat_time = current;
+ memcpy (&inode_ctx->stbuf, &stub->args.lookup_cbk.buf,
+ sizeof (inode_ctx->stbuf));
+
+ this = ctx->gf_ctx.graph;
+ inode_ctx_put (libgf_inode, this, (uint64_t)(long)inode_ctx);
+ }
+
+ op_ret = stub->args.create_cbk.op_ret;
+ errno = stub->args.create_cbk.op_errno;
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+int32_t
+libgf_client_opendir_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ fd_t *fd)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_opendir_cbk_stub (frame, NULL, op_ret, op_errno, fd);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int
+libgf_client_opendir (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ fd_t *fd)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, opendir, local, loc, fd);
+
+ op_ret = stub->args.opendir_cbk.op_ret;
+ errno = stub->args.opendir_cbk.op_errno;
+
+ call_stub_destroy (stub);
+ return 0;
+}
+
+unsigned long
+glusterfs_open (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ int flags,
+ mode_t mode)
+{
+ loc_t loc = {0, };
+ long op_ret = 0;
+ fd_t *fd = NULL;
+ struct stat stbuf;
+ char lookup_required = 1;
+ int32_t ret = -1;
+ xlator_t *this = NULL;
+
+ if (!ctx || !path || path[0] != '/') {
+ errno = EINVAL;
+ return 0;
+ }
+
+ this = ctx->gf_ctx.graph;
+
+ op_ret = libgf_client_loc_fill (&loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ fd = NULL;
+ goto out;
+ }
+
+ if (loc.inode) {
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ time_t current, prev;
+ uint64_t ptr = 0;
+
+ ret = inode_ctx_get (loc.inode, this, &ptr);
+ if (ret == 0) {
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ memset (&current, 0, sizeof (current));
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ current = time (NULL);
+ if (prev >= 0 && ctx->lookup_timeout >= (current - prev)) {
+ lookup_required = 0;
+ }
+ }
+ }
+
+ if (lookup_required) {
+ op_ret = libgf_client_lookup (ctx, &loc, &stbuf, NULL, NULL);
+ if (!op_ret && ((flags & O_CREAT) == O_CREAT) && ((flags & O_EXCL) == O_EXCL)) {
+ errno = EEXIST;
+ op_ret = -1;
+ }
+ }
+
+ if (!op_ret || (op_ret == -1 && errno == ENOENT && ((flags & O_CREAT) == O_CREAT))) {
+ fd = fd_create (loc.inode, 0);
+ fd->flags = flags;
+
+ if (!op_ret) {
+ if (S_ISDIR (loc.inode->st_mode)) {
+ if (((flags & O_RDONLY) == O_RDONLY) &&
+ ((flags & O_WRONLY) == 0) &&
+ ((flags & O_RDWR) == 0)) {
+ op_ret = libgf_client_opendir (ctx, &loc, fd);
+ } else {
+ op_ret = -1;
+ errno = EISDIR;
+ }
+ } else {
+ op_ret = libgf_client_open (ctx, &loc, fd, flags);
+ }
+ } else {
+ op_ret = libgf_client_creat (ctx, &loc, fd, flags, mode);
+ }
+
+ if (op_ret == -1) {
+ fd_unref (fd);
+ fd = NULL;
+ } else {
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ data_t *ctx_data = NULL;
+
+ ctx_data = dict_get (fd->ctx, XLATOR_NAME);
+ if (!ctx_data) {
+ fd_ctx = CALLOC (1, sizeof (*fd_ctx));
+ ERR_ABORT (fd_ctx);
+ pthread_mutex_init (&fd_ctx->lock, NULL);
+ }
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->ctx = ctx;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ if (!ctx_data) {
+ dict_set (fd->ctx, XLATOR_NAME, data_from_dynptr (fd_ctx, sizeof (*fd_ctx)));
+ }
+
+ if ((flags & O_TRUNC) && ((flags & O_RDWR) || (flags & O_WRONLY))) {
+ uint64_t ptr = 0;
+ ret = inode_ctx_get (fd->inode, this, &ptr);
+ if (ret == 0) {
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ if (S_ISREG (inode_ctx->stbuf.st_mode)) {
+ inode_ctx->stbuf.st_size = inode_ctx->stbuf.st_blocks = 0;
+ }
+ } else {
+ gf_log ("libglusterfsclient", GF_LOG_WARNING,
+ "inode_ctx is NULL for inode (%p) belonging to fd (%p)",
+ fd->inode, fd);
+ }
+ }
+ }
+ }
+
+ libgf_client_loc_wipe (&loc);
+
+out:
+ return (long)fd;
+}
+
+
+unsigned long
+glusterfs_creat (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ mode_t mode)
+{
+ return glusterfs_open (ctx, path,
+ (O_CREAT | O_WRONLY | O_TRUNC), mode);
+}
+
+
+int32_t
+libgf_client_flush_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_flush_cbk_stub (frame, NULL, op_ret, op_errno);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+
+int
+libgf_client_flush (libglusterfs_client_ctx_t *ctx, fd_t *fd)
+{
+ call_stub_t *stub;
+ int32_t op_ret;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, flush, local, fd);
+
+ op_ret = stub->args.flush_cbk.op_ret;
+ errno = stub->args.flush_cbk.op_errno;
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+
+int
+glusterfs_close (unsigned long fd)
+{
+ int32_t op_ret = -1;
+ data_t *fd_ctx_data = NULL;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ op_ret = libgf_client_flush (ctx, (fd_t *)fd);
+
+ fd_unref ((fd_t *)fd);
+
+out:
+ return op_ret;
+}
+
+int32_t
+libgf_client_setxattr_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_setxattr_cbk_stub (frame, NULL, op_ret, op_errno);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int
+libgf_client_setxattr (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ dict_t *dict;
+ libgf_client_local_t *local = NULL;
+
+ dict = get_new_dict ();
+
+ dict_set (dict, (char *)name,
+ bin_to_data ((void *)value, size));
+ dict_ref (dict);
+
+
+ LIBGF_CLIENT_FOP (ctx, stub, setxattr, local, loc, dict, flags);
+
+ op_ret = stub->args.setxattr_cbk.op_ret;
+ errno = stub->args.setxattr_cbk.op_errno;
+
+ dict_unref (dict);
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+int
+glusterfs_setxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags)
+{
+ int32_t op_ret = 0;
+ loc_t loc = {0, };
+ char lookup_required = 1;
+ xlator_t *this = NULL;
+
+ op_ret = libgf_client_loc_fill (&loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ this = ctx->gf_ctx.graph;
+ if (loc.inode) {
+ time_t current, prev;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ uint64_t ptr = 0;
+
+ op_ret = inode_ctx_get (loc.inode, this, &ptr);
+ if (op_ret == -1) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ memset (&current, 0, sizeof (current));
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if ((prev >= 0) && ctx->lookup_timeout >= (current - prev)) {
+ lookup_required = 0;
+ }
+ }
+
+ if (lookup_required) {
+ op_ret = libgf_client_lookup (ctx, &loc, NULL, NULL, NULL);
+ }
+
+ if (!op_ret)
+ op_ret = libgf_client_setxattr (ctx, &loc, name, value, size, flags);
+
+ libgf_client_loc_wipe (&loc);
+
+out:
+ return op_ret;
+}
+
+int
+glusterfs_lsetxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name,
+ const void *value,
+ size_t size, int flags)
+{
+ return ENOSYS;
+}
+
+int
+glusterfs_fsetxattr (unsigned long fd,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags)
+{
+ int32_t op_ret = 0;
+ fd_t *__fd ;
+ char lookup_required = 1;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+ loc_t loc = {0, };
+ xlator_t *this = NULL;
+
+ __fd = (fd_t *)fd;
+ fd_ctx_data = dict_get (__fd->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ op_ret = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ op_ret = libgf_client_loc_fill (&loc, NULL, __fd->inode->ino, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ this = ctx->gf_ctx.graph;
+ if (loc.inode) {
+ time_t current, prev;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ uint64_t ptr = 0;
+
+ op_ret = inode_ctx_get (loc.inode, this, &ptr);
+ if (op_ret == -1) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ memset (&current, 0, sizeof (current));
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if ( (prev >= 0) && ctx->lookup_timeout >= (current - prev)) {
+ lookup_required = 0;
+ }
+ }
+
+ if (lookup_required) {
+ op_ret = libgf_client_lookup (ctx, &loc, NULL, NULL, NULL);
+ }
+
+ if (!op_ret)
+ op_ret = libgf_client_setxattr (ctx, &loc, name, value, size, flags);
+
+ libgf_client_loc_wipe (&loc);
+out:
+ return op_ret;
+}
+
+ssize_t
+glusterfs_lgetxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name,
+ void *value,
+ size_t size)
+{
+ return ENOSYS;
+}
+
+ssize_t
+glusterfs_fgetxattr (unsigned long fd,
+ const char *name,
+ void *value,
+ size_t size)
+{
+ int32_t op_ret = 0;
+ libglusterfs_client_ctx_t *ctx;
+ fd_t *__fd = (fd_t *)fd;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+ loc_t loc = {0, };
+ dict_t *dict = NULL;
+
+ fd_ctx_data = dict_get (__fd->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ op_ret = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ op_ret = libgf_client_loc_fill (&loc, NULL, __fd->inode->ino, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ op_ret = libgf_client_lookup (ctx, &loc, NULL, &dict, NULL);
+ if (op_ret == 0) {
+ data_t *value_data = dict_get (dict, (char *)name);
+
+ if (value_data) {
+ int32_t copy_len = 0;
+ op_ret = value_data->len; /* Don't return the value for '\0' */
+
+ copy_len = size < value_data->len ? size : value_data->len;
+ memcpy (value, value_data->data, copy_len);
+ } else {
+ errno = ENODATA;
+ op_ret = -1;
+ }
+ }
+
+ if (dict) {
+ dict_unref (dict);
+ }
+
+ libgf_client_loc_wipe (&loc);
+
+out:
+ return op_ret;
+}
+
+ssize_t
+glusterfs_listxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ char *list,
+ size_t size)
+{
+ return ENOSYS;
+}
+
+ssize_t
+glusterfs_llistxattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ char *list,
+ size_t size)
+{
+ return ENOSYS;
+}
+
+ssize_t
+glusterfs_flistxattr (unsigned long fd,
+ char *list,
+ size_t size)
+{
+ return ENOSYS;
+}
+
+int
+glusterfs_removexattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name)
+{
+ return ENOSYS;
+}
+
+int
+glusterfs_lremovexattr (libglusterfs_client_ctx_t *ctx,
+ const char *path,
+ const char *name)
+{
+ return ENOSYS;
+}
+
+int
+glusterfs_fremovexattr (unsigned long fd,
+ const char *name)
+{
+ return ENOSYS;
+}
+
+int32_t
+libgf_client_readv_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct iovec *vector,
+ int32_t count,
+ struct stat *stbuf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_readv_cbk_stub (frame, NULL, op_ret, op_errno, vector, count, stbuf);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int
+libgf_client_read (libglusterfs_client_ctx_t *ctx,
+ fd_t *fd,
+ void *buf,
+ size_t size,
+ off_t offset)
+{
+ call_stub_t *stub;
+ struct iovec *vector;
+ int32_t op_ret = -1;
+ int count = 0;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, readv, local, fd, size, offset);
+
+ op_ret = stub->args.readv_cbk.op_ret;
+ errno = stub->args.readv_cbk.op_errno;
+ count = stub->args.readv_cbk.count;
+ vector = stub->args.readv_cbk.vector;
+ if (op_ret > 0) {
+ int i = 0;
+ op_ret = 0;
+ while (size && (i < count)) {
+ int len = (size < vector[i].iov_len) ? size : vector[i].iov_len;
+ memcpy (buf, vector[i++].iov_base, len);
+ buf += len;
+ size -= len;
+ op_ret += len;
+ }
+ }
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+ssize_t
+glusterfs_read (unsigned long fd,
+ void *buf,
+ size_t nbytes)
+{
+ int32_t op_ret = -1;
+ off_t offset = 0;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (fd == 0) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ ctx = fd_ctx->ctx;
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ op_ret = libgf_client_read (ctx, (fd_t *)fd, buf, nbytes, offset);
+
+ if (op_ret > 0) {
+ offset += op_ret;
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+out:
+ return op_ret;
+}
+
+
+ssize_t
+libgf_client_readv (libglusterfs_client_ctx_t *ctx,
+ fd_t *fd,
+ const struct iovec *dst_vector,
+ int dst_count,
+ off_t offset)
+{
+ call_stub_t *stub = NULL;
+ struct iovec *src_vector;
+ int src_count = 0;
+ int32_t op_ret = -1;
+ libgf_client_local_t *local = NULL;
+ size_t size = 0;
+ int32_t i = 0;
+
+ for (i = 0; i < dst_count; i++)
+ {
+ size += dst_vector[i].iov_len;
+ }
+
+ LIBGF_CLIENT_FOP (ctx, stub, readv, local, fd, size, offset);
+
+ op_ret = stub->args.readv_cbk.op_ret;
+ errno = stub->args.readv_cbk.op_errno;
+ src_count = stub->args.readv_cbk.count;
+ src_vector = stub->args.readv_cbk.vector;
+ if (op_ret > 0) {
+ int src = 0, dst = 0;
+ off_t src_offset = 0, dst_offset = 0;
+ op_ret = 0;
+
+ while ((size != 0) && (dst < dst_count) && (src < src_count)) {
+ int len = 0, src_len, dst_len;
+
+ src_len = src_vector[src].iov_len - src_offset;
+ dst_len = dst_vector[dst].iov_len - dst_offset;
+
+ len = (src_len < dst_len) ? src_len : dst_len;
+ if (len > size) {
+ len = size;
+ }
+
+ memcpy (dst_vector[dst].iov_base + dst_offset,
+ src_vector[src].iov_base + src_offset, len);
+
+ size -= len;
+ src_offset += len;
+ dst_offset += len;
+
+ if (src_offset == src_vector[src].iov_len) {
+ src_offset = 0;
+ src++;
+ }
+
+ if (dst_offset == dst_vector[dst].iov_len) {
+ dst_offset = 0;
+ dst++;
+ }
+ }
+ }
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+
+ssize_t
+glusterfs_readv (unsigned long fd, const struct iovec *vec, int count)
+{
+ int32_t op_ret = -1;
+ off_t offset = 0;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ ctx = fd_ctx->ctx;
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ op_ret = libgf_client_readv (ctx, (fd_t *)fd, vec, count, offset);
+
+ if (op_ret > 0) {
+ offset += op_ret;
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+out:
+ return op_ret;
+}
+
+
+ssize_t
+glusterfs_pread (unsigned long fd,
+ void *buf,
+ size_t count,
+ off_t offset)
+{
+ int32_t op_ret = -1;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ ctx = fd_ctx->ctx;
+
+ op_ret = libgf_client_read (ctx, (fd_t *)fd, buf, count, offset);
+
+out:
+ return op_ret;
+}
+
+
+int
+libgf_client_writev_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct stat *stbuf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_writev_cbk_stub (frame, NULL, op_ret, op_errno, stbuf);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+ return 0;
+}
+
+int
+libgf_client_writev (libglusterfs_client_ctx_t *ctx,
+ fd_t *fd,
+ struct iovec *vector,
+ int count,
+ off_t offset)
+{
+ call_stub_t *stub = NULL;
+ int op_ret = -1;
+ libgf_client_local_t *local = NULL;
+
+ LIBGF_CLIENT_FOP (ctx, stub, writev, local, fd, vector, count, offset);
+
+ op_ret = stub->args.writev_cbk.op_ret;
+ errno = stub->args.writev_cbk.op_errno;
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+
+ssize_t
+glusterfs_write (unsigned long fd,
+ const void *buf,
+ size_t n)
+{
+ int32_t op_ret = -1;
+ off_t offset = 0;
+ struct iovec vector;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ ctx = fd_ctx->ctx;
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ vector.iov_base = (void *)buf;
+ vector.iov_len = n;
+
+ op_ret = libgf_client_writev (ctx,
+ (fd_t *)fd,
+ &vector,
+ 1,
+ offset);
+
+ if (op_ret >= 0) {
+ offset += op_ret;
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+out:
+ return op_ret;
+}
+
+ssize_t
+glusterfs_writev (unsigned long fd,
+ const struct iovec *vector,
+ size_t count)
+{
+ int32_t op_ret = -1;
+ off_t offset = 0;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ ctx = fd_ctx->ctx;
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+
+ op_ret = libgf_client_writev (ctx,
+ (fd_t *)fd,
+ (struct iovec *)vector,
+ count,
+ offset);
+
+ if (op_ret >= 0) {
+ offset += op_ret;
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+out:
+ return op_ret;
+}
+
+
+ssize_t
+glusterfs_pwrite (unsigned long fd,
+ const void *buf,
+ size_t count,
+ off_t offset)
+{
+ int32_t op_ret = -1;
+ struct iovec vector;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ if (!fd) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ ctx = fd_ctx->ctx;
+
+ vector.iov_base = (void *)buf;
+ vector.iov_len = count;
+
+ op_ret = libgf_client_writev (ctx,
+ (fd_t *)fd,
+ &vector,
+ 1,
+ offset);
+
+out:
+ return op_ret;
+}
+
+
+int32_t
+libgf_client_readdir_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ gf_dirent_t *entries)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_readdir_cbk_stub (frame, NULL, op_ret, op_errno, entries);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+ return 0;
+}
+
+int
+libgf_client_readdir (libglusterfs_client_ctx_t *ctx,
+ fd_t *fd,
+ struct dirent *dirp,
+ size_t size,
+ off_t *offset,
+ int32_t num_entries)
+{
+ call_stub_t *stub = NULL;
+ int op_ret = -1;
+ libgf_client_local_t *local = NULL;
+ gf_dirent_t *entry = NULL;
+ int32_t count = 0;
+ size_t entry_size = 0;
+
+ LIBGF_CLIENT_FOP (ctx, stub, readdir, local, fd, size, *offset);
+
+ op_ret = stub->args.readdir_cbk.op_ret;
+ errno = stub->args.readdir_cbk.op_errno;
+
+ if (op_ret > 0) {
+ list_for_each_entry (entry, &stub->args.readdir_cbk.entries.list, list) {
+ entry_size = offsetof (struct dirent, d_name) + strlen (entry->d_name) + 1;
+
+ if ((size < entry_size) || (count == num_entries)) {
+ break;
+ }
+
+ size -= entry_size;
+
+ dirp->d_ino = entry->d_ino;
+ /*
+ #ifdef GF_DARWIN_HOST_OS
+ dirp->d_off = entry->d_seekoff;
+ #endif
+ #ifdef GF_LINUX_HOST_OS
+ dirp->d_off = entry->d_off;
+ #endif
+ */
+
+ *offset = dirp->d_off = entry->d_off;
+ /* dirp->d_type = entry->d_type; */
+ dirp->d_reclen = entry->d_len;
+ strncpy (dirp->d_name, entry->d_name, dirp->d_reclen);
+ dirp->d_name[dirp->d_reclen] = '\0';
+
+ dirp = (struct dirent *) (((char *) dirp) + entry_size);
+ count++;
+ }
+ }
+
+ call_stub_destroy (stub);
+ return op_ret;
+}
+
+int
+glusterfs_readdir (unsigned long fd,
+ struct dirent *dirp,
+ unsigned int count)
+{
+ int op_ret = -1;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ off_t offset = 0;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ ctx = fd_ctx->ctx;
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ op_ret = libgf_client_readdir (ctx, (fd_t *)fd, dirp, sizeof (*dirp), &offset, 1);
+
+ if (op_ret > 0) {
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ op_ret = 1;
+ }
+
+out:
+ return op_ret;
+}
+
+
+int
+glusterfs_getdents (unsigned long fd, struct dirent *dirp, unsigned int count)
+{
+ int op_ret = -1;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ off_t offset = 0;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ ctx = fd_ctx->ctx;
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ op_ret = libgf_client_readdir (ctx, (fd_t *)fd, dirp, count, &offset, -1);
+
+ if (op_ret > 0) {
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+out:
+ return op_ret;
+}
+
+
+static int32_t
+libglusterfs_readv_async_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct iovec *vector,
+ int32_t count,
+ struct stat *stbuf)
+{
+ glusterfs_read_buf_t *buf;
+ libglusterfs_client_async_local_t *local = frame->local;
+ fd_t *__fd = local->fop.readv_cbk.fd;
+ glusterfs_readv_cbk_t readv_cbk = local->fop.readv_cbk.cbk;
+
+ buf = CALLOC (1, sizeof (*buf));
+ ERR_ABORT (buf);
+
+ if (vector) {
+ buf->vector = iov_dup (vector, count);
+ }
+
+ buf->count = count;
+ buf->op_ret = op_ret;
+ buf->op_errno = op_errno;
+
+ if (frame->root->rsp_refs) {
+ buf->ref = dict_ref (frame->root->rsp_refs);
+ }
+
+ if (op_ret > 0) {
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (__fd->ctx, XLATOR_NAME);
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset += op_ret;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+ readv_cbk (buf, local->cbk_data);
+
+ FREE (local);
+ frame->local = NULL;
+ STACK_DESTROY (frame->root);
+
+ return 0;
+}
+
+void
+glusterfs_free (glusterfs_read_buf_t *buf)
+{
+ //iov_free (buf->vector, buf->count);
+ FREE (buf->vector);
+ dict_unref ((dict_t *) buf->ref);
+ FREE (buf);
+}
+
+int
+glusterfs_read_async (unsigned long fd,
+ size_t nbytes,
+ off_t offset,
+ glusterfs_readv_cbk_t readv_cbk,
+ void *cbk_data)
+{
+ libglusterfs_client_ctx_t *ctx;
+ fd_t *__fd = (fd_t *)fd;
+ libglusterfs_client_async_local_t *local = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+ int32_t op_ret = 0;
+
+ local = CALLOC (1, sizeof (*local));
+ ERR_ABORT (local);
+ local->fop.readv_cbk.fd = __fd;
+ local->fop.readv_cbk.cbk = readv_cbk;
+ local->cbk_data = cbk_data;
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ op_ret = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ ctx = fd_ctx->ctx;
+
+ if (offset < 0) {
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+ LIBGF_CLIENT_FOP_ASYNC (ctx,
+ local,
+ libglusterfs_readv_async_cbk,
+ readv,
+ __fd,
+ nbytes,
+ offset);
+
+out:
+ return op_ret;
+}
+
+static int32_t
+libglusterfs_writev_async_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct stat *stbuf)
+{
+ libglusterfs_client_async_local_t *local = frame->local;
+ fd_t *fd = NULL;
+ glusterfs_writev_cbk_t writev_cbk;
+
+ writev_cbk = local->fop.writev_cbk.cbk;
+ fd = local->fop.writev_cbk.fd;
+
+ if (op_ret > 0) {
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+
+ fd_ctx_data = dict_get (fd->ctx, XLATOR_NAME);
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset += op_ret;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+ writev_cbk (op_ret, op_errno, local->cbk_data);
+
+ STACK_DESTROY (frame->root);
+ return 0;
+}
+
+int32_t
+glusterfs_write_async (unsigned long fd,
+ const void *buf,
+ size_t nbytes,
+ off_t offset,
+ glusterfs_writev_cbk_t writev_cbk,
+ void *cbk_data)
+{
+ fd_t *__fd = (fd_t *)fd;
+ struct iovec vector;
+ off_t __offset = offset;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ libglusterfs_client_async_local_t *local = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+ int32_t op_ret = 0;
+
+ local = CALLOC (1, sizeof (*local));
+ ERR_ABORT (local);
+ local->fop.writev_cbk.fd = __fd;
+ local->fop.writev_cbk.cbk = writev_cbk;
+ local->cbk_data = cbk_data;
+
+ vector.iov_base = (void *)buf;
+ vector.iov_len = nbytes;
+
+ fd_ctx_data = dict_get (__fd->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ op_ret = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ if (offset < 0) {
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ __offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+ }
+
+ LIBGF_CLIENT_FOP_ASYNC (ctx,
+ local,
+ libglusterfs_writev_async_cbk,
+ writev,
+ __fd,
+ &vector,
+ 1,
+ __offset);
+
+out:
+ return op_ret;
+}
+
+off_t
+glusterfs_lseek (unsigned long fd, off_t offset, int whence)
+{
+ off_t __offset = 0;
+ int32_t op_ret = -1;
+ fd_t *__fd = (fd_t *)fd;
+ data_t *fd_ctx_data = NULL;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ libglusterfs_client_ctx_t *ctx = NULL;
+ xlator_t *this = NULL;
+
+ fd_ctx_data = dict_get (__fd->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADFD;
+ __offset = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ switch (whence)
+ {
+ case SEEK_SET:
+ __offset = offset;
+ break;
+
+ case SEEK_CUR:
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ __offset = fd_ctx->offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+ __offset += offset;
+ break;
+
+ case SEEK_END:
+ {
+ char cache_valid = 0;
+ off_t end = 0;
+ time_t prev, current;
+ loc_t loc = {0, };
+ struct stat stbuf = {0, };
+ int32_t ret = -1;
+ uint64_t ptr = 0;
+
+ ret = inode_ctx_get (__fd->inode, this, &ptr);
+ if (ret == 0) {
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ memset (&current, 0, sizeof (current));
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if (prev >= 0 && ctx->lookup_timeout >= (current - prev)) {
+ cache_valid = 1;
+ }
+ }
+
+ if (cache_valid) {
+ end = inode_ctx->stbuf.st_size;
+ } else {
+ op_ret = libgf_client_loc_fill (&loc, NULL, __fd->inode->ino, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ __offset = -1;
+ goto out;
+ }
+
+ op_ret = libgf_client_lookup (ctx, &loc, &stbuf, NULL, NULL);
+ if (op_ret < 0) {
+ __offset = -1;
+ goto out;
+ }
+
+ end = stbuf.st_size;
+ }
+
+ __offset = end + offset;
+ }
+ break;
+
+ default:
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "invalid value for whence");
+ __offset = -1;
+ errno = EINVAL;
+ goto out;
+ }
+
+ pthread_mutex_lock (&fd_ctx->lock);
+ {
+ fd_ctx->offset = __offset;
+ }
+ pthread_mutex_unlock (&fd_ctx->lock);
+
+out:
+ return __offset;
+}
+
+
+int32_t
+libgf_client_stat_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct stat *buf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_stat_cbk_stub (frame,
+ NULL,
+ op_ret,
+ op_errno,
+ buf);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+}
+
+int32_t
+libgf_client_stat (libglusterfs_client_ctx_t *ctx,
+ loc_t *loc,
+ struct stat *stbuf)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ time_t prev, current;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ libgf_client_local_t *local = NULL;
+ xlator_t *this = NULL;
+ uint64_t ptr = 0;
+
+ this = ctx->gf_ctx.graph;
+ op_ret = inode_ctx_get (loc->inode, this, &ptr);
+ if (op_ret == -1) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ current = time (NULL);
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if ((current - prev) <= ctx->stat_timeout) {
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ memcpy (stbuf, &inode_ctx->stbuf, sizeof (*stbuf));
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+ op_ret = 0;
+ goto out;
+ }
+
+ LIBGF_CLIENT_FOP (ctx, stub, stat, local, loc);
+
+ op_ret = stub->args.stat_cbk.op_ret;
+ errno = stub->args.stat_cbk.op_errno;
+ *stbuf = stub->args.stat_cbk.buf;
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ memcpy (&inode_ctx->stbuf, stbuf, sizeof (*stbuf));
+ current = time (NULL);
+ inode_ctx->previous_stat_time = current;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ call_stub_destroy (stub);
+
+out:
+ return op_ret;
+}
+
+int32_t
+glusterfs_stat (libglusterfs_handle_t handle,
+ const char *path,
+ struct stat *buf)
+{
+ int32_t op_ret = 0;
+ loc_t loc = {0, };
+ char lookup_required = 1;
+ libglusterfs_client_ctx_t *ctx = handle;
+ xlator_t *this = NULL;
+
+ op_ret = libgf_client_loc_fill (&loc, path, 0, ctx);
+ if (op_ret < 0) {
+ gf_log ("libglusterfsclient",
+ GF_LOG_ERROR,
+ "libgf_client_loc_fill returned -1, returning EINVAL");
+ errno = EINVAL;
+ goto out;
+ }
+
+ this = ctx->gf_ctx.graph;
+ if (loc.inode) {
+ time_t current, prev;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ uint64_t ptr = 0;
+
+ op_ret = inode_ctx_get (loc.inode, this, &ptr);
+ if (op_ret == -1) {
+ inode_unref (loc.inode);
+ errno = EINVAL;
+ goto out;
+ }
+
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ memset (&current, 0, sizeof (current));
+ current = time (NULL);
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_lookup_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if (prev >= 0 && ctx->lookup_timeout >= (current - prev)) {
+ lookup_required = 0;
+ }
+ }
+
+ if (lookup_required) {
+ op_ret = libgf_client_lookup (ctx, &loc, buf, NULL, NULL);
+ }
+
+ if (!op_ret) {
+ op_ret = libgf_client_stat (ctx, &loc, buf);
+ }
+
+ libgf_client_loc_wipe (&loc);
+
+out:
+ return op_ret;
+}
+
+static int32_t
+libgf_client_fstat_cbk (call_frame_t *frame,
+ void *cookie,
+ xlator_t *this,
+ int32_t op_ret,
+ int32_t op_errno,
+ struct stat *buf)
+{
+ libgf_client_local_t *local = frame->local;
+
+ local->reply_stub = fop_fstat_cbk_stub (frame,
+ NULL,
+ op_ret,
+ op_errno,
+ buf);
+
+ pthread_mutex_lock (&local->lock);
+ {
+ local->complete = 1;
+ pthread_cond_broadcast (&local->reply_cond);
+ }
+ pthread_mutex_unlock (&local->lock);
+
+ return 0;
+
+}
+
+int32_t
+libgf_client_fstat (libglusterfs_client_ctx_t *ctx,
+ fd_t *fd,
+ struct stat *buf)
+{
+ call_stub_t *stub = NULL;
+ int32_t op_ret = 0;
+ fd_t *__fd = fd;
+ time_t current, prev;
+ libglusterfs_client_inode_ctx_t *inode_ctx = NULL;
+ libgf_client_local_t *local = NULL;
+ xlator_t *this = NULL;
+ uint64_t ptr = 0;
+
+ current = time (NULL);
+ op_ret = inode_ctx_get (fd->inode, this, &ptr);
+ if (op_ret == -1) {
+ errno = EINVAL;
+ goto out;
+ }
+
+ inode_ctx = (libglusterfs_client_inode_ctx_t *)(long)ptr;
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ prev = inode_ctx->previous_stat_time;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ if ((current - prev) <= ctx->stat_timeout) {
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ memcpy (buf, &inode_ctx->stbuf, sizeof (*buf));
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+ op_ret = 0;
+ goto out;
+ }
+
+ LIBGF_CLIENT_FOP (ctx, stub, fstat, local, __fd);
+
+ op_ret = stub->args.fstat_cbk.op_ret;
+ errno = stub->args.fstat_cbk.op_errno;
+ *buf = stub->args.fstat_cbk.buf;
+
+ pthread_mutex_lock (&inode_ctx->lock);
+ {
+ memcpy (&inode_ctx->stbuf, buf, sizeof (*buf));
+ current = time (NULL);
+ inode_ctx->previous_stat_time = current;
+ }
+ pthread_mutex_unlock (&inode_ctx->lock);
+
+ call_stub_destroy (stub);
+
+out:
+ return op_ret;
+}
+
+int32_t
+glusterfs_fstat (unsigned long fd, struct stat *buf)
+{
+ libglusterfs_client_ctx_t *ctx;
+ fd_t *__fd = (fd_t *)fd;
+ libglusterfs_client_fd_ctx_t *fd_ctx = NULL;
+ data_t *fd_ctx_data = NULL;
+ int32_t op_ret = -1;
+
+ fd_ctx_data = dict_get (((fd_t *) fd)->ctx, XLATOR_NAME);
+ if (!fd_ctx_data) {
+ errno = EBADF;
+ op_ret = -1;
+ goto out;
+ }
+
+ fd_ctx = data_to_ptr (fd_ctx_data);
+ ctx = fd_ctx->ctx;
+
+ op_ret = libgf_client_fstat (ctx, __fd, buf);
+
+out:
+ return op_ret;
+}
+
+static struct xlator_fops libgf_client_fops = {
+};
+
+static struct xlator_mops libgf_client_mops = {
+};
+
+static struct xlator_cbks libgf_client_cbks = {
+ .forget = libgf_client_forget,
+ .release = libgf_client_release,
+ .releasedir = libgf_client_releasedir,
+};
+
+static inline xlator_t *
+libglusterfs_graph (xlator_t *graph)
+{
+ xlator_t *top = NULL;
+ xlator_list_t *xlchild, *xlparent;
+
+ top = CALLOC (1, sizeof (*top));
+ ERR_ABORT (top);
+
+ xlchild = CALLOC (1, sizeof(*xlchild));
+ ERR_ABORT (xlchild);
+ xlchild->xlator = graph;
+ top->children = xlchild;
+ top->ctx = graph->ctx;
+ top->next = graph;
+ top->name = strdup (XLATOR_NAME);
+
+ xlparent = CALLOC (1, sizeof(*xlparent));
+ xlparent->xlator = top;
+ graph->parents = xlparent;
+ asprintf (&top->type, XLATOR_NAME);
+
+ top->init = libgf_client_init;
+ top->fops = &libgf_client_fops;
+ top->mops = &libgf_client_mops;
+ top->cbks = &libgf_client_cbks;
+ top->notify = libgf_client_notify;
+ top->fini = libgf_client_fini;
+ // fill_defaults (top);
+
+ return top;
+}
diff --git a/libglusterfsclient/src/libglusterfsclient.h b/libglusterfsclient/src/libglusterfsclient.h
new file mode 100755
index 00000000000..19b7ea0361c
--- /dev/null
+++ b/libglusterfsclient/src/libglusterfsclient.h
@@ -0,0 +1,279 @@
+/*
+ Copyright (c) 2008 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_H
+#define __LIBGLUSTERFSCLIENT_H
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <sys/types.h>
+#include <sys/stat.h>
+ //#include <unistd.h>
+#include <dirent.h>
+#include <errno.h>
+/* #include <logging.h> */
+
+typedef struct {
+ int op_ret;
+ int op_errno;
+ struct iovec *vector;
+ int count;
+ void *ref;
+}glusterfs_read_buf_t;
+
+
+typedef struct {
+ char *logfile;
+ char *loglevel;
+ struct {
+ char *specfile;
+ FILE *specfp;
+ };
+ char *volume_name;
+ unsigned long lookup_timeout;
+ unsigned long stat_timeout;
+}glusterfs_init_ctx_t;
+
+typedef struct libglusterfs_client_ctx *libglusterfs_handle_t;
+
+typedef int (*glusterfs_readv_cbk_t) (glusterfs_read_buf_t *buf,
+ void *cbk_data);
+
+typedef int (*glusterfs_writev_cbk_t) (int op_ret,
+ int op_errno,
+ void *cbk_data);
+
+typedef int (*glusterfs_lookup_cbk_t) (int op_ret,
+ int op_errno,
+ void *buf,
+ struct stat *st,
+ void *cbk_data);
+
+/* Used to free the glusterfs_read_buf passed to the application from glusterfs_read_async_cbk */
+void
+glusterfs_free (glusterfs_read_buf_t *buf);
+
+/* libglusterfsclient initialization function */
+libglusterfs_handle_t
+glusterfs_init (glusterfs_init_ctx_t *ctx);
+
+int
+glusterfs_fini (libglusterfs_handle_t handle);
+
+/* added for log related initialization for fork implementation in booster */
+void
+glusterfs_reset (void);
+
+void
+glusterfs_log_lock (void);
+
+void
+glusterfs_log_unlock (void);
+
+/* For smaller files, application can use just glusterfs_lookup/glusterfs_lookup_async to read
+ * the whole content. Limit of the file-sizes to be read in
+ * glusterfs_lookup/glusterfs_lookup_async is passed in the size argument */
+
+/* glusterfs_lookup:
+ * @handle: glusterfs handle
+ * @path: path to be looked upon
+ * @buf: pointer to pre-allocated buf, in which the file content is returned for files with sizes * less than the size argument.
+ * @size: upper limit of file-sizes to be read in lookup
+ * @stbuf: stat buffer
+ */
+
+int
+glusterfs_lookup (libglusterfs_handle_t handle,
+ const char *path,
+ void *buf,
+ size_t size,
+ struct stat *stbuf);
+
+int
+glusterfs_lookup_async (libglusterfs_handle_t handle,
+ const char *path,
+ void *buf,
+ size_t size,
+ glusterfs_lookup_cbk_t cbk,
+ void *cbk_data);
+
+unsigned long
+glusterfs_open (libglusterfs_handle_t handle,
+ const char *path,
+ int flags,
+ mode_t mode);
+
+unsigned long
+glusterfs_creat (libglusterfs_handle_t handle,
+ const char *path,
+ mode_t mode);
+
+int
+glusterfs_close (unsigned long fd);
+
+int
+glusterfs_stat (libglusterfs_handle_t handle,
+ const char *path,
+ struct stat *buf);
+
+int
+glusterfs_fstat (unsigned long fd,
+ struct stat *buf) ;
+
+int
+glusterfs_setxattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags);
+
+int
+glusterfs_lsetxattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags);
+
+int
+glusterfs_fsetxattr (unsigned long fd,
+ const char *name,
+ const void *value,
+ size_t size,
+ int flags);
+
+ssize_t
+glusterfs_getxattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name,
+ void *value,
+ size_t size);
+
+ssize_t
+glusterfs_lgetxattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name,
+ void *value,
+ size_t size);
+
+ssize_t
+glusterfs_fgetxattr (unsigned long fd,
+ const char *name,
+ void *value,
+ size_t size);
+
+ssize_t
+glusterfs_listxattr (libglusterfs_handle_t handle,
+ const char *path,
+ char *list,
+ size_t size);
+
+ssize_t
+glusterfs_llistxattr (libglusterfs_handle_t handle,
+ const char *path,
+ char *list,
+ size_t size);
+
+ssize_t
+glusterfs_flistxattr (unsigned long fd,
+ char *list,
+ size_t size);
+
+int
+glusterfs_removexattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name);
+
+int
+glusterfs_lremovexattr (libglusterfs_handle_t handle,
+ const char *path,
+ const char *name);
+
+int
+glusterfs_fremovexattr (unsigned long fd,
+ const char *name);
+
+ssize_t
+glusterfs_read (unsigned long fd,
+ void *buf,
+ size_t nbytes);
+
+ssize_t
+glusterfs_readv (unsigned long fd,
+ const struct iovec *vec,
+ int count);
+
+int
+glusterfs_read_async (unsigned long fd,
+ size_t nbytes,
+ off_t offset,
+ glusterfs_readv_cbk_t readv_cbk,
+ void *cbk_data);
+
+ssize_t
+glusterfs_write (unsigned long fd,
+ const void *buf,
+ size_t n);
+
+ssize_t
+glusterfs_writev (unsigned long fd,
+ const struct iovec *vector,
+ size_t count);
+
+int
+glusterfs_write_async (unsigned long fd,
+ const void *buf,
+ size_t nbytes,
+ off_t offset,
+ glusterfs_writev_cbk_t writev_cbk,
+ void *cbk_data);
+
+int
+glusterfs_readdir (unsigned long fd,
+ struct dirent *dirp,
+ unsigned int count);
+
+int
+glusterfs_getdents (unsigned long fd,
+ struct dirent *dirp,
+ unsigned int count);
+
+ssize_t
+glusterfs_pread (unsigned long fd,
+ void *buf,
+ size_t count,
+ off_t offset);
+
+ssize_t
+glusterfs_pwrite (unsigned long fd,
+ const void *buf,
+ size_t count,
+ off_t offset);
+
+off_t
+glusterfs_lseek (unsigned long fd, off_t offset, int whence);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif
generated by cgit (git 2.34.1) at 2024-12-28 05:58:25 +0000