summaryrefslogtreecommitdiffstats
path: root/libglusterfs/src/xlator.c
diff options
context:
space:
mode:
authorMohamed Ashiq <ashiq333@gmail.com>2015-05-19 15:40:30 +0530
committerNiels de Vos <ndevos@redhat.com>2015-07-13 06:10:58 -0700
commit1e4cc18362df17f87001ec42605b51daf251e0db (patch)
tree3e948e6a44979b7316b73a8f931e7e537716bf03 /libglusterfs/src/xlator.c
parent0497fb6090d1ed34ac1bdcaaff49847025d13e9e (diff)
defaults,globals,iobuf,latency,logging,options,xlator/libglusterfs : porting to a new logging framework
Backport of http://review.gluster.org/10826 Cherry picked from ef374774b8727b2f76915a1f88b26c83c77dde43 >Change-Id: If6a55186cddc3d1c4d22e3d56b45358b84feeb49 >BUG: 1194640 >Signed-off-by: Mohamed Ashiq <ashiq333@gmail.com> >Reviewed-on: http://review.gluster.org/10826 >Tested-by: NetBSD Build System <jenkins@build.gluster.org> >Reviewed-by: Pranith Kumar Karampuri <pkarampu@redhat.com> Change-Id: If6a55186cddc3d1c4d22e3d56b45358b84feeb49 BUG: 1217722 Signed-off-by: Mohamed Ashiq <ashiq333@gmail.com> Reviewed-on: http://review.gluster.org/11405 Tested-by: Gluster Build System <jenkins@build.gluster.com> Tested-by: NetBSD Build System <jenkins@build.gluster.org> Reviewed-by: Niels de Vos <ndevos@redhat.com>
Diffstat (limited to 'libglusterfs/src/xlator.c')
-rw-r--r--libglusterfs/src/xlator.c85
1 files changed, 45 insertions, 40 deletions
diff --git a/libglusterfs/src/xlator.c b/libglusterfs/src/xlator.c
index 628f3499956..52f96c94a50 100644
--- a/libglusterfs/src/xlator.c
+++ b/libglusterfs/src/xlator.c
@@ -18,6 +18,7 @@
#include <netdb.h>
#include <fnmatch.h>
#include "defaults.h"
+#include "libglusterfs-messages.h"
#define SET_DEFAULT_FOP(fn) do { \
if (!xl->fops->fn) \
@@ -34,7 +35,8 @@ static void
fill_defaults (xlator_t *xl)
{
if (xl == NULL) {
- gf_log_callingfn ("xlator", GF_LOG_WARNING, "invalid argument");
+ gf_msg_callingfn ("xlator", GF_LOG_WARNING, EINVAL,
+ LG_MSG_INVALID_ARG, "invalid argument");
return;
}
@@ -128,23 +130,23 @@ xlator_volopt_dynload (char *xlator_type, void **dl_handle,
ret = gf_asprintf (&name, "%s/%s.so", XLATORDIR, xlator_type);
if (-1 == ret) {
- gf_log ("xlator", GF_LOG_ERROR, "asprintf failed");
goto out;
}
ret = -1;
- gf_log ("xlator", GF_LOG_TRACE, "attempt to load file %s", name);
+ gf_msg_trace ("xlator", 0, "attempt to load file %s", name);
handle = dlopen (name, RTLD_NOW|RTLD_GLOBAL);
if (!handle) {
- gf_log ("xlator", GF_LOG_WARNING, "%s", dlerror ());
+ gf_msg ("xlator", GF_LOG_WARNING, 0, LG_MSG_DLOPEN_FAILED,
+ "%s", dlerror ());
goto out;
}
if (!(opt_list->given_opt = dlsym (handle, "options"))) {
dlerror ();
- gf_log ("xlator", GF_LOG_ERROR,
+ gf_msg ("xlator", GF_LOG_ERROR, 0, LG_MSG_LOAD_FAILED,
"Failed to load xlator opt table");
goto out;
}
@@ -158,7 +160,7 @@ xlator_volopt_dynload (char *xlator_type, void **dl_handle,
if (handle)
dlclose (handle);
- gf_log ("xlator", GF_LOG_DEBUG, "Returning %d", ret);
+ gf_msg_debug ("xlator", 0, "Returning %d", ret);
return ret;
}
@@ -179,30 +181,30 @@ xlator_dynload (xlator_t *xl)
ret = gf_asprintf (&name, "%s/%s.so", XLATORDIR, xl->type);
if (-1 == ret) {
- gf_log ("xlator", GF_LOG_ERROR, "asprintf failed");
goto out;
}
ret = -1;
- gf_log ("xlator", GF_LOG_TRACE, "attempt to load file %s", name);
+ gf_msg_trace ("xlator", 0, "attempt to load file %s", name);
handle = dlopen (name, RTLD_NOW|RTLD_GLOBAL);
if (!handle) {
- gf_log ("xlator", GF_LOG_WARNING, "%s", dlerror ());
+ gf_msg ("xlator", GF_LOG_WARNING, 0, LG_MSG_DLOPEN_FAILED,
+ "%s", dlerror ());
goto out;
}
xl->dlhandle = handle;
if (!(xl->fops = dlsym (handle, "fops"))) {
- gf_log ("xlator", GF_LOG_WARNING, "dlsym(fops) on %s",
- dlerror ());
+ gf_msg ("xlator", GF_LOG_WARNING, 0, LG_MSG_DLSYM_ERROR,
+ "dlsym(fops) on %s", dlerror ());
goto out;
}
if (!(xl->cbks = dlsym (handle, "cbks"))) {
- gf_log ("xlator", GF_LOG_WARNING, "dlsym(cbks) on %s",
- dlerror ());
+ gf_msg ("xlator", GF_LOG_WARNING, 0, LG_MSG_DLSYM_ERROR,
+ "dlsym(cbks) on %s", dlerror ());
goto out;
}
@@ -220,39 +222,38 @@ xlator_dynload (xlator_t *xl)
}
else {
if (!(*VOID(&xl->init) = dlsym (handle, "init"))) {
- gf_log ("xlator", GF_LOG_WARNING, "dlsym(init) on %s",
+ gf_msg ("xlator", GF_LOG_WARNING, 0,
+ LG_MSG_DLSYM_ERROR, "dlsym(init) on %s",
dlerror ());
goto out;
}
if (!(*VOID(&(xl->fini)) = dlsym (handle, "fini"))) {
- gf_log ("xlator", GF_LOG_WARNING, "dlsym(fini) on %s",
+ gf_msg ("xlator", GF_LOG_WARNING, 0,
+ LG_MSG_DLSYM_ERROR, "dlsym(fini) on %s",
dlerror ());
goto out;
}
if (!(*VOID(&(xl->reconfigure)) = dlsym (handle,
"reconfigure"))) {
- gf_log ("xlator", GF_LOG_TRACE,
- "dlsym(reconfigure) on %s -- neglecting",
- dlerror());
+ gf_msg_trace ("xlator", 0, "dlsym(reconfigure) on %s "
+ "-- neglecting", dlerror());
}
if (!(*VOID(&(xl->notify)) = dlsym (handle, "notify"))) {
- gf_log ("xlator", GF_LOG_TRACE,
- "dlsym(notify) on %s -- neglecting",
- dlerror ());
+ gf_msg_trace ("xlator", 0, "dlsym(notify) on %s -- "
+ "neglecting", dlerror ());
}
}
if (!(xl->dumpops = dlsym (handle, "dumpops"))) {
- gf_log ("xlator", GF_LOG_TRACE,
- "dlsym(dumpops) on %s -- neglecting", dlerror ());
+ gf_msg_trace ("xlator", 0, "dlsym(dumpops) on %s -- "
+ "neglecting", dlerror ());
}
if (!(*VOID(&(xl->mem_acct_init)) = dlsym (handle, "mem_acct_init"))) {
- gf_log (xl->name, GF_LOG_TRACE,
- "dlsym(mem_acct_init) on %s -- neglecting",
- dlerror ());
+ gf_msg_trace (xl->name, 0, "dlsym(mem_acct_init) on %s -- "
+ "neglecting", dlerror ());
}
vol_opt = GF_CALLOC (1, sizeof (volume_opt_list_t),
@@ -264,8 +265,8 @@ xlator_dynload (xlator_t *xl)
if (!(vol_opt->given_opt = dlsym (handle, "options"))) {
dlerror ();
- gf_log (xl->name, GF_LOG_TRACE,
- "Strict option validation not enforced -- neglecting");
+ gf_msg_trace (xl->name, 0, "Strict option validation not "
+ "enforced -- neglecting");
}
INIT_LIST_HEAD (&vol_opt->list);
list_add_tail (&vol_opt->list, &xl->volume_options);
@@ -299,8 +300,9 @@ xlator_set_inode_lru_limit (xlator_t *this, void *data)
if (this->itable) {
if (!data) {
- gf_log (this->name, GF_LOG_WARNING, "input data is "
- "NULL. Cannot update the lru limit of the inode"
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ LG_MSG_INVALID_ENTRY, "input data is NULL. "
+ "Cannot update the lru limit of the inode"
" table. Continuing with older value");
goto out;
}
@@ -413,17 +415,17 @@ xlator_init (xlator_t *xl)
xl->mem_acct_init (xl);
if (!xl->init) {
- gf_log (xl->name, GF_LOG_WARNING, "No init() found");
+ gf_msg (xl->name, GF_LOG_WARNING, 0, LG_MSG_INIT_FAILED,
+ "No init() found");
goto out;
}
ret = __xlator_init (xl);
if (ret) {
- gf_log (xl->name, GF_LOG_ERROR,
+ gf_msg (xl->name, GF_LOG_ERROR, 0, LG_MSG_VOLUME_ERROR,
"Initialization of volume '%s' failed,"
- " review your volfile again",
- xl->name);
+ " review your volfile again", xl->name);
goto out;
}
@@ -451,7 +453,7 @@ xlator_fini_rec (xlator_t *xl)
}
xlator_fini_rec (trav->xlator);
- gf_log (trav->xlator->name, GF_LOG_DEBUG, "fini done");
+ gf_msg_debug (trav->xlator->name, 0, "fini done");
trav = trav->next;
}
@@ -467,7 +469,7 @@ xlator_fini_rec (xlator_t *xl)
THIS = old_THIS;
} else {
- gf_log (xl->name, GF_LOG_DEBUG, "No fini() found");
+ gf_msg_debug (xl->name, 0, "No fini() found");
}
xl->init_succeeded = 0;
}
@@ -646,7 +648,8 @@ xlator_tree_free_members (xlator_t *tree)
xlator_t *prev = tree;
if (!tree) {
- gf_log ("parser", GF_LOG_ERROR, "Translator tree not found");
+ gf_msg ("parser", GF_LOG_ERROR, 0, LG_MSG_TREE_NOT_FOUND,
+ "Translator tree not found");
return -1;
}
@@ -666,7 +669,8 @@ xlator_tree_free_memacct (xlator_t *tree)
xlator_t *prev = tree;
if (!tree) {
- gf_log ("parser", GF_LOG_ERROR, "Translator tree not found");
+ gf_msg ("parser", GF_LOG_ERROR, 0, LG_MSG_TREE_NOT_FOUND,
+ "Translator tree not found");
return -1;
}
@@ -1042,8 +1046,9 @@ glusterd_check_log_level (const char *value)
}
if (log_level == -1)
- gf_log (THIS->name, GF_LOG_ERROR, "Invalid log-level. possible values "
- "are DEBUG|WARNING|ERROR|CRITICAL|NONE|TRACE");
+ gf_msg (THIS->name, GF_LOG_ERROR, 0, LG_MSG_INIT_FAILED,
+ "Invalid log-level. possible values are "
+ "DEBUG|WARNING|ERROR|CRITICAL|NONE|TRACE");
return log_level;
}