summaryrefslogtreecommitdiffstats
path: root/libglusterfs/src/globals.c
diff options
context:
space:
mode:
authorGluster Ant <bugzilla-bot@gluster.org>2018-09-12 17:52:45 +0530
committerNigel Babu <nigelb@redhat.com>2018-09-12 17:52:45 +0530
commite16868dede6455cab644805af6fe1ac312775e13 (patch)
tree15aebdb4fff2d87cf8a72f836816b3aa634da58d /libglusterfs/src/globals.c
parent45a71c0548b6fd2c757aa2e7b7671a1411948894 (diff)
Land part 2 of clang-format changes
Change-Id: Ia84cc24c8924e6d22d02ac15f611c10e26db99b4 Signed-off-by: Nigel Babu <nigelb@redhat.com>
Diffstat (limited to 'libglusterfs/src/globals.c')
-rw-r--r--libglusterfs/src/globals.c669
1 files changed, 330 insertions, 339 deletions
diff --git a/libglusterfs/src/globals.c b/libglusterfs/src/globals.c
index 3506d482bda..98990460c86 100644
--- a/libglusterfs/src/globals.c
+++ b/libglusterfs/src/globals.c
@@ -19,75 +19,75 @@
#include "upcall-utils.h"
const char *gf_fop_list[GF_FOP_MAXVALUE] = {
- [GF_FOP_NULL] = "NULL",
- [GF_FOP_STAT] = "STAT",
- [GF_FOP_READLINK] = "READLINK",
- [GF_FOP_MKNOD] = "MKNOD",
- [GF_FOP_MKDIR] = "MKDIR",
- [GF_FOP_UNLINK] = "UNLINK",
- [GF_FOP_RMDIR] = "RMDIR",
- [GF_FOP_SYMLINK] = "SYMLINK",
- [GF_FOP_RENAME] = "RENAME",
- [GF_FOP_LINK] = "LINK",
- [GF_FOP_TRUNCATE] = "TRUNCATE",
- [GF_FOP_OPEN] = "OPEN",
- [GF_FOP_READ] = "READ",
- [GF_FOP_WRITE] = "WRITE",
- [GF_FOP_STATFS] = "STATFS",
- [GF_FOP_FLUSH] = "FLUSH",
- [GF_FOP_FSYNC] = "FSYNC",
- [GF_FOP_SETXATTR] = "SETXATTR",
- [GF_FOP_GETXATTR] = "GETXATTR",
- [GF_FOP_REMOVEXATTR] = "REMOVEXATTR",
- [GF_FOP_OPENDIR] = "OPENDIR",
- [GF_FOP_FSYNCDIR] = "FSYNCDIR",
- [GF_FOP_ACCESS] = "ACCESS",
- [GF_FOP_CREATE] = "CREATE",
- [GF_FOP_FTRUNCATE] = "FTRUNCATE",
- [GF_FOP_FSTAT] = "FSTAT",
- [GF_FOP_LK] = "LK",
- [GF_FOP_LOOKUP] = "LOOKUP",
- [GF_FOP_READDIR] = "READDIR",
- [GF_FOP_INODELK] = "INODELK",
- [GF_FOP_FINODELK] = "FINODELK",
- [GF_FOP_ENTRYLK] = "ENTRYLK",
- [GF_FOP_FENTRYLK] = "FENTRYLK",
- [GF_FOP_XATTROP] = "XATTROP",
- [GF_FOP_FXATTROP] = "FXATTROP",
- [GF_FOP_FSETXATTR] = "FSETXATTR",
- [GF_FOP_FGETXATTR] = "FGETXATTR",
- [GF_FOP_RCHECKSUM] = "RCHECKSUM",
- [GF_FOP_SETATTR] = "SETATTR",
- [GF_FOP_FSETATTR] = "FSETATTR",
- [GF_FOP_READDIRP] = "READDIRP",
- [GF_FOP_GETSPEC] = "GETSPEC",
- [GF_FOP_FORGET] = "FORGET",
- [GF_FOP_RELEASE] = "RELEASE",
- [GF_FOP_RELEASEDIR] = "RELEASEDIR",
- [GF_FOP_FREMOVEXATTR]= "FREMOVEXATTR",
- [GF_FOP_FALLOCATE] = "FALLOCATE",
- [GF_FOP_DISCARD] = "DISCARD",
- [GF_FOP_ZEROFILL] = "ZEROFILL",
- [GF_FOP_IPC] = "IPC",
- [GF_FOP_SEEK] = "SEEK",
- [GF_FOP_LEASE] = "LEASE",
- [GF_FOP_COMPOUND] = "COMPOUND",
- [GF_FOP_GETACTIVELK] = "GETACTIVELK",
- [GF_FOP_SETACTIVELK] = "SETACTIVELK",
- [GF_FOP_PUT] = "PUT",
- [GF_FOP_ICREATE] = "ICREATE",
- [GF_FOP_NAMELINK] = "NAMELINK",
+ [GF_FOP_NULL] = "NULL",
+ [GF_FOP_STAT] = "STAT",
+ [GF_FOP_READLINK] = "READLINK",
+ [GF_FOP_MKNOD] = "MKNOD",
+ [GF_FOP_MKDIR] = "MKDIR",
+ [GF_FOP_UNLINK] = "UNLINK",
+ [GF_FOP_RMDIR] = "RMDIR",
+ [GF_FOP_SYMLINK] = "SYMLINK",
+ [GF_FOP_RENAME] = "RENAME",
+ [GF_FOP_LINK] = "LINK",
+ [GF_FOP_TRUNCATE] = "TRUNCATE",
+ [GF_FOP_OPEN] = "OPEN",
+ [GF_FOP_READ] = "READ",
+ [GF_FOP_WRITE] = "WRITE",
+ [GF_FOP_STATFS] = "STATFS",
+ [GF_FOP_FLUSH] = "FLUSH",
+ [GF_FOP_FSYNC] = "FSYNC",
+ [GF_FOP_SETXATTR] = "SETXATTR",
+ [GF_FOP_GETXATTR] = "GETXATTR",
+ [GF_FOP_REMOVEXATTR] = "REMOVEXATTR",
+ [GF_FOP_OPENDIR] = "OPENDIR",
+ [GF_FOP_FSYNCDIR] = "FSYNCDIR",
+ [GF_FOP_ACCESS] = "ACCESS",
+ [GF_FOP_CREATE] = "CREATE",
+ [GF_FOP_FTRUNCATE] = "FTRUNCATE",
+ [GF_FOP_FSTAT] = "FSTAT",
+ [GF_FOP_LK] = "LK",
+ [GF_FOP_LOOKUP] = "LOOKUP",
+ [GF_FOP_READDIR] = "READDIR",
+ [GF_FOP_INODELK] = "INODELK",
+ [GF_FOP_FINODELK] = "FINODELK",
+ [GF_FOP_ENTRYLK] = "ENTRYLK",
+ [GF_FOP_FENTRYLK] = "FENTRYLK",
+ [GF_FOP_XATTROP] = "XATTROP",
+ [GF_FOP_FXATTROP] = "FXATTROP",
+ [GF_FOP_FSETXATTR] = "FSETXATTR",
+ [GF_FOP_FGETXATTR] = "FGETXATTR",
+ [GF_FOP_RCHECKSUM] = "RCHECKSUM",
+ [GF_FOP_SETATTR] = "SETATTR",
+ [GF_FOP_FSETATTR] = "FSETATTR",
+ [GF_FOP_READDIRP] = "READDIRP",
+ [GF_FOP_GETSPEC] = "GETSPEC",
+ [GF_FOP_FORGET] = "FORGET",
+ [GF_FOP_RELEASE] = "RELEASE",
+ [GF_FOP_RELEASEDIR] = "RELEASEDIR",
+ [GF_FOP_FREMOVEXATTR] = "FREMOVEXATTR",
+ [GF_FOP_FALLOCATE] = "FALLOCATE",
+ [GF_FOP_DISCARD] = "DISCARD",
+ [GF_FOP_ZEROFILL] = "ZEROFILL",
+ [GF_FOP_IPC] = "IPC",
+ [GF_FOP_SEEK] = "SEEK",
+ [GF_FOP_LEASE] = "LEASE",
+ [GF_FOP_COMPOUND] = "COMPOUND",
+ [GF_FOP_GETACTIVELK] = "GETACTIVELK",
+ [GF_FOP_SETACTIVELK] = "SETACTIVELK",
+ [GF_FOP_PUT] = "PUT",
+ [GF_FOP_ICREATE] = "ICREATE",
+ [GF_FOP_NAMELINK] = "NAMELINK",
};
const char *gf_upcall_list[GF_UPCALL_FLAGS_MAXVALUE] = {
- [GF_UPCALL_NULL] = "NULL",
- [GF_UPCALL] = "UPCALL",
- [GF_UPCALL_CI_STAT] = "CI_IATT",
- [GF_UPCALL_CI_XATTR] = "CI_XATTR",
- [GF_UPCALL_CI_RENAME] = "CI_RENAME",
- [GF_UPCALL_CI_NLINK] = "CI_UNLINK",
- [GF_UPCALL_CI_FORGET] = "CI_FORGET",
- [GF_UPCALL_LEASE_RECALL] = "LEASE_RECALL",
+ [GF_UPCALL_NULL] = "NULL",
+ [GF_UPCALL] = "UPCALL",
+ [GF_UPCALL_CI_STAT] = "CI_IATT",
+ [GF_UPCALL_CI_XATTR] = "CI_XATTR",
+ [GF_UPCALL_CI_RENAME] = "CI_RENAME",
+ [GF_UPCALL_CI_NLINK] = "CI_UNLINK",
+ [GF_UPCALL_CI_FORGET] = "CI_FORGET",
+ [GF_UPCALL_LEASE_RECALL] = "LEASE_RECALL",
};
/* THIS */
@@ -101,461 +101,452 @@ xlator_t global_xlator;
static pthread_key_t this_xlator_key;
static pthread_key_t synctask_key;
static pthread_key_t uuid_buf_key;
-static char global_uuid_buf[GF_UUID_BUF_SIZE];
+static char global_uuid_buf[GF_UUID_BUF_SIZE];
static pthread_key_t lkowner_buf_key;
-static char global_lkowner_buf[GF_LKOWNER_BUF_SIZE];
+static char global_lkowner_buf[GF_LKOWNER_BUF_SIZE];
static pthread_key_t leaseid_buf_key;
static int gf_global_mem_acct_enable = 1;
static pthread_once_t globals_inited = PTHREAD_ONCE_INIT;
-
int
-gf_global_mem_acct_enable_get (void)
+gf_global_mem_acct_enable_get(void)
{
- return gf_global_mem_acct_enable;
+ return gf_global_mem_acct_enable;
}
int
-gf_global_mem_acct_enable_set (int val)
+gf_global_mem_acct_enable_set(int val)
{
- gf_global_mem_acct_enable = val;
- return 0;
+ gf_global_mem_acct_enable = val;
+ return 0;
}
void
-glusterfs_this_destroy (void *ptr)
+glusterfs_this_destroy(void *ptr)
{
- FREE (ptr);
+ FREE(ptr);
}
static struct xlator_cbks global_cbks = {
- .forget = NULL,
- .release = NULL,
- .releasedir = NULL,
- .invalidate = NULL,
- .client_destroy = NULL,
- .client_disconnect = NULL,
- .ictxmerge = NULL,
- .ictxsize = NULL,
- .fdctxsize = NULL,
+ .forget = NULL,
+ .release = NULL,
+ .releasedir = NULL,
+ .invalidate = NULL,
+ .client_destroy = NULL,
+ .client_disconnect = NULL,
+ .ictxmerge = NULL,
+ .ictxsize = NULL,
+ .fdctxsize = NULL,
};
/* This is required to get through the check in graph.c */
-static struct xlator_fops global_fops = {
-};
+static struct xlator_fops global_fops = {};
static int
-global_xl_reconfigure (xlator_t *this, dict_t *options)
+global_xl_reconfigure(xlator_t *this, dict_t *options)
{
- int ret = -1;
- gf_boolean_t bool_opt = _gf_false;
+ int ret = -1;
+ gf_boolean_t bool_opt = _gf_false;
- /* This is not added in volume dump, hence adding the options in log
- would be helpful for debugging later */
- dict_dump_to_log (options);
+ /* This is not added in volume dump, hence adding the options in log
+ would be helpful for debugging later */
+ dict_dump_to_log(options);
- GF_OPTION_RECONF ("measure-latency", bool_opt, options, bool, out);
- this->ctx->measure_latency = bool_opt;
+ GF_OPTION_RECONF("measure-latency", bool_opt, options, bool, out);
+ this->ctx->measure_latency = bool_opt;
- GF_OPTION_RECONF ("metrics-dump-path", this->ctx->config.metrics_dumppath,
- options, str, out);
+ GF_OPTION_RECONF("metrics-dump-path", this->ctx->config.metrics_dumppath,
+ options, str, out);
- /* TODO: add more things here */
- ret = 0;
+ /* TODO: add more things here */
+ ret = 0;
out:
- return ret;
+ return ret;
}
static int
-global_xl_init (xlator_t *this)
+global_xl_init(xlator_t *this)
{
- int ret = -1;
- gf_boolean_t bool_opt = false;
+ int ret = -1;
+ gf_boolean_t bool_opt = false;
- GF_OPTION_INIT ("measure-latency", bool_opt, bool, out);
- this->ctx->measure_latency = bool_opt;
+ GF_OPTION_INIT("measure-latency", bool_opt, bool, out);
+ this->ctx->measure_latency = bool_opt;
- GF_OPTION_INIT ("metrics-dump-path", this->ctx->config.metrics_dumppath,
- str, out);
+ GF_OPTION_INIT("metrics-dump-path", this->ctx->config.metrics_dumppath, str,
+ out);
- ret = 0;
+ ret = 0;
out:
- return ret;
+ return ret;
}
static void
-global_xl_fini (xlator_t *this)
+global_xl_fini(xlator_t *this)
{
- return;
+ return;
}
struct volume_options global_xl_options[] = {
- { .key = {"measure-latency"},
- .type = GF_OPTION_TYPE_BOOL,
- .default_value = "no",
- .op_version = {GD_OP_VERSION_4_0_0},
- .flags = OPT_FLAG_SETTABLE,
- .tags = {"global", "context"},
- .description = "Use this option to toggle measuring latency"
- },
- { .key = {"metrics-dump-path"},
- .type = GF_OPTION_TYPE_STR,
- .default_value = "{{gluster_workdir}}/metrics",
- .op_version = {GD_OP_VERSION_4_0_0},
- .flags = OPT_FLAG_SETTABLE,
- .tags = {"global", "context"},
- .description = "Use this option to set the metrics dump path"
- },
-
- { .key = {NULL},},
+ {.key = {"measure-latency"},
+ .type = GF_OPTION_TYPE_BOOL,
+ .default_value = "no",
+ .op_version = {GD_OP_VERSION_4_0_0},
+ .flags = OPT_FLAG_SETTABLE,
+ .tags = {"global", "context"},
+ .description = "Use this option to toggle measuring latency"},
+ {.key = {"metrics-dump-path"},
+ .type = GF_OPTION_TYPE_STR,
+ .default_value = "{{gluster_workdir}}/metrics",
+ .op_version = {GD_OP_VERSION_4_0_0},
+ .flags = OPT_FLAG_SETTABLE,
+ .tags = {"global", "context"},
+ .description = "Use this option to set the metrics dump path"},
+
+ {
+ .key = {NULL},
+ },
};
static volume_opt_list_t global_xl_opt_list;
int
-glusterfs_this_init ()
+glusterfs_this_init()
{
- int ret = 0;
- ret = pthread_key_create (&this_xlator_key, glusterfs_this_destroy);
- if (ret != 0) {
- gf_msg ("", GF_LOG_WARNING, ret,
- LG_MSG_PTHREAD_KEY_CREATE_FAILED, "failed to create "
- "the pthread key");
- return ret;
- }
+ int ret = 0;
+ ret = pthread_key_create(&this_xlator_key, glusterfs_this_destroy);
+ if (ret != 0) {
+ gf_msg("", GF_LOG_WARNING, ret, LG_MSG_PTHREAD_KEY_CREATE_FAILED,
+ "failed to create "
+ "the pthread key");
+ return ret;
+ }
- global_xlator.name = "glusterfs";
- global_xlator.type = GF_GLOBAL_XLATOR_NAME;
- global_xlator.cbks = &global_cbks;
- global_xlator.fops = &global_fops;
- global_xlator.reconfigure = global_xl_reconfigure;
- global_xlator.init = global_xl_init;
- global_xlator.fini = global_xl_fini;
+ global_xlator.name = "glusterfs";
+ global_xlator.type = GF_GLOBAL_XLATOR_NAME;
+ global_xlator.cbks = &global_cbks;
+ global_xlator.fops = &global_fops;
+ global_xlator.reconfigure = global_xl_reconfigure;
+ global_xlator.init = global_xl_init;
+ global_xlator.fini = global_xl_fini;
- INIT_LIST_HEAD (&global_xlator.volume_options);
- INIT_LIST_HEAD (&global_xl_opt_list.list);
- global_xl_opt_list.given_opt = global_xl_options;
+ INIT_LIST_HEAD(&global_xlator.volume_options);
+ INIT_LIST_HEAD(&global_xl_opt_list.list);
+ global_xl_opt_list.given_opt = global_xl_options;
- list_add_tail (&global_xl_opt_list.list, &global_xlator.volume_options);
+ list_add_tail(&global_xl_opt_list.list, &global_xlator.volume_options);
- return ret;
+ return ret;
}
-
xlator_t **
-__glusterfs_this_location ()
+__glusterfs_this_location()
{
- xlator_t **this_location = NULL;
- int ret = 0;
-
- this_location = pthread_getspecific (this_xlator_key);
-
- if (!this_location) {
- this_location = CALLOC (1, sizeof (*this_location));
- if (!this_location)
- goto out;
-
- ret = pthread_setspecific (this_xlator_key, this_location);
- if (ret != 0) {
- FREE (this_location);
- this_location = NULL;
- goto out;
- }
+ xlator_t **this_location = NULL;
+ int ret = 0;
+
+ this_location = pthread_getspecific(this_xlator_key);
+
+ if (!this_location) {
+ this_location = CALLOC(1, sizeof(*this_location));
+ if (!this_location)
+ goto out;
+
+ ret = pthread_setspecific(this_xlator_key, this_location);
+ if (ret != 0) {
+ FREE(this_location);
+ this_location = NULL;
+ goto out;
}
+ }
out:
- if (this_location) {
- if (!*this_location)
- *this_location = &global_xlator;
- }
- return this_location;
+ if (this_location) {
+ if (!*this_location)
+ *this_location = &global_xlator;
+ }
+ return this_location;
}
-
xlator_t *
-glusterfs_this_get ()
+glusterfs_this_get()
{
- xlator_t **this_location = NULL;
+ xlator_t **this_location = NULL;
- this_location = __glusterfs_this_location ();
- if (!this_location)
- return &global_xlator;
+ this_location = __glusterfs_this_location();
+ if (!this_location)
+ return &global_xlator;
- return *this_location;
+ return *this_location;
}
-
int
-glusterfs_this_set (xlator_t *this)
+glusterfs_this_set(xlator_t *this)
{
- xlator_t **this_location = NULL;
+ xlator_t **this_location = NULL;
- this_location = __glusterfs_this_location ();
- if (!this_location)
- return -ENOMEM;
+ this_location = __glusterfs_this_location();
+ if (!this_location)
+ return -ENOMEM;
- *this_location = this;
+ *this_location = this;
- return 0;
+ return 0;
}
/* SYNCOPCTX */
static pthread_key_t syncopctx_key;
static void
-syncopctx_key_destroy (void *ptr)
+syncopctx_key_destroy(void *ptr)
{
- struct syncopctx *opctx = ptr;
+ struct syncopctx *opctx = ptr;
- if (opctx) {
- if (opctx->groups)
- GF_FREE (opctx->groups);
+ if (opctx) {
+ if (opctx->groups)
+ GF_FREE(opctx->groups);
- GF_FREE (opctx);
- }
+ GF_FREE(opctx);
+ }
- return;
+ return;
}
void *
-syncopctx_getctx ()
+syncopctx_getctx()
{
- void *opctx = NULL;
+ void *opctx = NULL;
- opctx = pthread_getspecific (syncopctx_key);
+ opctx = pthread_getspecific(syncopctx_key);
- return opctx;
+ return opctx;
}
int
-syncopctx_setctx (void *ctx)
+syncopctx_setctx(void *ctx)
{
- int ret = 0;
+ int ret = 0;
- ret = pthread_setspecific (syncopctx_key, ctx);
+ ret = pthread_setspecific(syncopctx_key, ctx);
- return ret;
+ return ret;
}
static int
-syncopctx_init (void)
+syncopctx_init(void)
{
- int ret;
+ int ret;
- ret = pthread_key_create (&syncopctx_key, syncopctx_key_destroy);
+ ret = pthread_key_create(&syncopctx_key, syncopctx_key_destroy);
- return ret;
+ return ret;
}
/* SYNCTASK */
int
-synctask_init ()
+synctask_init()
{
- int ret = 0;
+ int ret = 0;
- ret = pthread_key_create (&synctask_key, NULL);
+ ret = pthread_key_create(&synctask_key, NULL);
- return ret;
+ return ret;
}
void *
-synctask_get ()
+synctask_get()
{
- void *synctask = NULL;
+ void *synctask = NULL;
- synctask = pthread_getspecific (synctask_key);
+ synctask = pthread_getspecific(synctask_key);
- return synctask;
+ return synctask;
}
-
int
-synctask_set (void *synctask)
+synctask_set(void *synctask)
{
- int ret = 0;
+ int ret = 0;
- pthread_setspecific (synctask_key, synctask);
+ pthread_setspecific(synctask_key, synctask);
- return ret;
+ return ret;
}
-//UUID_BUFFER
+// UUID_BUFFER
void
-glusterfs_uuid_buf_destroy (void *ptr)
+glusterfs_uuid_buf_destroy(void *ptr)
{
- FREE (ptr);
+ FREE(ptr);
}
int
-glusterfs_uuid_buf_init ()
+glusterfs_uuid_buf_init()
{
- int ret = 0;
+ int ret = 0;
- ret = pthread_key_create (&uuid_buf_key,
- glusterfs_uuid_buf_destroy);
- return ret;
+ ret = pthread_key_create(&uuid_buf_key, glusterfs_uuid_buf_destroy);
+ return ret;
}
char *
-glusterfs_uuid_buf_get ()
+glusterfs_uuid_buf_get()
{
- char *buf;
- int ret = 0;
-
- buf = pthread_getspecific (uuid_buf_key);
- if(!buf) {
- buf = MALLOC (GF_UUID_BUF_SIZE);
- ret = pthread_setspecific (uuid_buf_key, (void *) buf);
- if (ret)
- buf = global_uuid_buf;
- }
- return buf;
+ char *buf;
+ int ret = 0;
+
+ buf = pthread_getspecific(uuid_buf_key);
+ if (!buf) {
+ buf = MALLOC(GF_UUID_BUF_SIZE);
+ ret = pthread_setspecific(uuid_buf_key, (void *)buf);
+ if (ret)
+ buf = global_uuid_buf;
+ }
+ return buf;
}
/* LKOWNER_BUFFER */
void
-glusterfs_lkowner_buf_destroy (void *ptr)
+glusterfs_lkowner_buf_destroy(void *ptr)
{
- FREE (ptr);
+ FREE(ptr);
}
int
-glusterfs_lkowner_buf_init ()
+glusterfs_lkowner_buf_init()
{
- int ret = 0;
+ int ret = 0;
- ret = pthread_key_create (&lkowner_buf_key,
- glusterfs_lkowner_buf_destroy);
- return ret;
+ ret = pthread_key_create(&lkowner_buf_key, glusterfs_lkowner_buf_destroy);
+ return ret;
}
char *
-glusterfs_lkowner_buf_get ()
+glusterfs_lkowner_buf_get()
{
- char *buf;
- int ret = 0;
-
- buf = pthread_getspecific (lkowner_buf_key);
- if(!buf) {
- buf = MALLOC (GF_LKOWNER_BUF_SIZE);
- ret = pthread_setspecific (lkowner_buf_key, (void *) buf);
- if (ret)
- buf = global_lkowner_buf;
- }
- return buf;
+ char *buf;
+ int ret = 0;
+
+ buf = pthread_getspecific(lkowner_buf_key);
+ if (!buf) {
+ buf = MALLOC(GF_LKOWNER_BUF_SIZE);
+ ret = pthread_setspecific(lkowner_buf_key, (void *)buf);
+ if (ret)
+ buf = global_lkowner_buf;
+ }
+ return buf;
}
/* Leaseid buffer */
void
-glusterfs_leaseid_buf_destroy (void *ptr)
+glusterfs_leaseid_buf_destroy(void *ptr)
{
- FREE (ptr);
+ FREE(ptr);
}
int
-glusterfs_leaseid_buf_init ()
+glusterfs_leaseid_buf_init()
{
- int ret = 0;
+ int ret = 0;
- ret = pthread_key_create (&leaseid_buf_key,
- glusterfs_leaseid_buf_destroy);
- return ret;
+ ret = pthread_key_create(&leaseid_buf_key, glusterfs_leaseid_buf_destroy);
+ return ret;
}
char *
-glusterfs_leaseid_buf_get ()
+glusterfs_leaseid_buf_get()
{
- char *buf = NULL;
- int ret = 0;
-
- buf = pthread_getspecific (leaseid_buf_key);
- if (!buf) {
- buf = CALLOC (1, GF_LEASE_ID_BUF_SIZE);
- ret = pthread_setspecific (leaseid_buf_key, (void *) buf);
- if (ret) {
- FREE (buf);
- buf = NULL;
- }
+ char *buf = NULL;
+ int ret = 0;
+
+ buf = pthread_getspecific(leaseid_buf_key);
+ if (!buf) {
+ buf = CALLOC(1, GF_LEASE_ID_BUF_SIZE);
+ ret = pthread_setspecific(leaseid_buf_key, (void *)buf);
+ if (ret) {
+ FREE(buf);
+ buf = NULL;
}
- return buf;
+ }
+ return buf;
}
char *
-glusterfs_leaseid_exist ()
+glusterfs_leaseid_exist()
{
- return pthread_getspecific (leaseid_buf_key);
+ return pthread_getspecific(leaseid_buf_key);
}
static void
-gf_globals_init_once ()
+gf_globals_init_once()
{
- int ret = 0;
-
- ret = glusterfs_this_init ();
- if (ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_TRANSLATOR_INIT_FAILED,
- "ERROR: glusterfs-translator init failed");
- goto out;
- }
-
- ret = glusterfs_uuid_buf_init ();
- if(ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_UUID_BUF_INIT_FAILED,
- "ERROR: glusterfs uuid buffer init failed");
- goto out;
- }
-
- ret = glusterfs_lkowner_buf_init ();
- if(ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_LKOWNER_BUF_INIT_FAILED,
- "ERROR: glusterfs lkowner buffer init failed");
- goto out;
- }
-
- ret = glusterfs_leaseid_buf_init ();
- if (ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_LEASEID_BUF_INIT_FAILED,
- "ERROR: glusterfs leaseid buffer init failed");
- goto out;
- }
-
- ret = synctask_init ();
- if (ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_SYNCTASK_INIT_FAILED,
- "ERROR: glusterfs synctask init failed");
- goto out;
- }
-
- ret = syncopctx_init ();
- if (ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_SYNCOPCTX_INIT_FAILED,
- "ERROR: glusterfs syncopctx init failed");
- goto out;
- }
+ int ret = 0;
+
+ ret = glusterfs_this_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_TRANSLATOR_INIT_FAILED,
+ "ERROR: glusterfs-translator init failed");
+ goto out;
+ }
+
+ ret = glusterfs_uuid_buf_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_UUID_BUF_INIT_FAILED,
+ "ERROR: glusterfs uuid buffer init failed");
+ goto out;
+ }
+
+ ret = glusterfs_lkowner_buf_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_LKOWNER_BUF_INIT_FAILED,
+ "ERROR: glusterfs lkowner buffer init failed");
+ goto out;
+ }
+
+ ret = glusterfs_leaseid_buf_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_LEASEID_BUF_INIT_FAILED,
+ "ERROR: glusterfs leaseid buffer init failed");
+ goto out;
+ }
+
+ ret = synctask_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_SYNCTASK_INIT_FAILED,
+ "ERROR: glusterfs synctask init failed");
+ goto out;
+ }
+
+ ret = syncopctx_init();
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_SYNCOPCTX_INIT_FAILED,
+ "ERROR: glusterfs syncopctx init failed");
+ goto out;
+ }
out:
- if (ret) {
- gf_msg ("", GF_LOG_CRITICAL, 0, LG_MSG_GLOBAL_INIT_FAILED,
- "Exiting as global initialization failed");
- exit (ret);
- }
+ if (ret) {
+ gf_msg("", GF_LOG_CRITICAL, 0, LG_MSG_GLOBAL_INIT_FAILED,
+ "Exiting as global initialization failed");
+ exit(ret);
+ }
}
int
-glusterfs_globals_init (glusterfs_ctx_t *ctx)
+glusterfs_globals_init(glusterfs_ctx_t *ctx)
{
- int ret = 0;
+ int ret = 0;
- gf_log_globals_init (ctx, GF_LOG_INFO);
+ gf_log_globals_init(ctx, GF_LOG_INFO);
- ret = pthread_once (&globals_inited, gf_globals_init_once);
+ ret = pthread_once(&globals_inited, gf_globals_init_once);
- if (ret)
- gf_msg ("", GF_LOG_CRITICAL, ret, LG_MSG_PTHREAD_FAILED,
- "pthread_once failed");
+ if (ret)
+ gf_msg("", GF_LOG_CRITICAL, ret, LG_MSG_PTHREAD_FAILED,
+ "pthread_once failed");
- return ret;
+ return ret;
}