core: remove the unused files - round 2

BUG: 764890
Change-Id: I3eb626eeaa2a09f0e248444f560c2a0eaf46c642
Signed-off-by: Amar Tumballi <amarts@redhat.com>
Reviewed-on: http://review.gluster.com/3660
Tested-by: Gluster Build System <jenkins@build.gluster.com>
Reviewed-by: Anand Avati <avati@redhat.com>

4 files changed, 0 insertions, 477 deletions

diff --git a/scheduler/nufa/Makefile.am b/scheduler/nufa/Makefile.am
deleted file mode 100644
index d471a3f9243..00000000000
--- a/scheduler/nufa/Makefile.am
+++ /dev/null
@@ -1,3 +0,0 @@
-SUBDIRS = src
-
-CLEANFILES = 
diff --git a/scheduler/nufa/src/Makefile.am b/scheduler/nufa/src/Makefile.am
deleted file mode 100644
index 6eb3d39f1e2..00000000000
--- a/scheduler/nufa/src/Makefile.am
+++ /dev/null
@@ -1,12 +0,0 @@
-sched_LTLIBRARIES = nufa.la
-scheddir = $(libdir)/glusterfs/$(PACKAGE_VERSION)/scheduler
-
-nufa_la_LDFLAGS = -module -avoidversion
-
-nufa_la_SOURCES = nufa.c
-nufa_la_LIBADD = $(top_builddir)/libglusterfs/src/libglusterfs.la
-
-AM_CFLAGS = -fPIC -D_FILE_OFFSET_BITS=64 -D_GNU_SOURCE -Wall -D$(GF_HOST_OS)\
-	-I$(top_srcdir)/libglusterfs/src -shared -nostartfiles $(GF_CFLAGS)
-
-CLEANFILES = 
diff --git a/scheduler/nufa/src/nufa-mem-types.h b/scheduler/nufa/src/nufa-mem-types.h
deleted file mode 100644
index 945dafa7c31..00000000000
--- a/scheduler/nufa/src/nufa-mem-types.h
+++ /dev/null
@@ -1,33 +0,0 @@
-/*
-   Copyright (c) 2008-2011 Gluster, Inc. <http://www.gluster.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 __NUFA_MEM_TYPES_H__
-#define __NUFA_MEM_TYPES_H__
-
-#include "mem-types.h"
-
-enum gf_locks_mem_types_ {
-        gf_nufa_mt_nufa_struct = gf_common_mt_end + 1,
-        gf_nufa_mt_nufa_sched_struct,
-        gf_nufa_mt_int32_t,
-        gf_nufa_mt_end
-};
-#endif
-
diff --git a/scheduler/nufa/src/nufa.c b/scheduler/nufa/src/nufa.c
deleted file mode 100644
index 1bf477bdc2c..00000000000
--- a/scheduler/nufa/src/nufa.c
+++ /dev/null
@@ -1,429 +0,0 @@
-/*
-  Copyright (c) 2006-2011 Gluster, Inc. <http://www.gluster.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 _CONFIG_H
-#define _CONFIG_H
-#include "config.h"
-#endif
-
-#include <sys/time.h>
-
-#include "scheduler.h"
-#include "common-utils.h"
-#include "nufa-mem-types.h"
-
-struct nufa_sched_struct {
-	xlator_t *xl;
-	struct timeval last_stat_fetch;
-	int64_t free_disk;
-	int32_t refresh_interval;
-	unsigned char eligible;
-};
-
-struct nufa_struct {
-	struct nufa_sched_struct *array;
-	struct timeval last_stat_fetch;
-
-	int32_t *local_array; /* Used to keep the index of the local xlators */
-	int32_t local_xl_index; /* index in the above array */
-	int32_t local_xl_count; /* Count of the local subvolumes */
-
-	uint32_t refresh_interval;
-	uint32_t min_free_disk;
-  
-	gf_lock_t nufa_lock;
-	int32_t child_count;
-	int32_t sched_index;  
-};
-
-#define NUFA_LIMITS_MIN_FREE_DISK_DEFAULT    15
-#define NUFA_REFRESH_INTERVAL_DEFAULT        30
-
-static int32_t
-nufa_init (xlator_t *xl)
-{
-	int32_t index = 0;
-	data_t *local_name = NULL;
-	data_t *data = NULL;
-	xlator_list_t *trav_xl = xl->children;
-	struct nufa_struct *nufa_buf = NULL;
-
-	nufa_buf = GF_CALLOC (1, sizeof (struct nufa_struct),
-                              gf_nufa_mt_nufa_struct);
-	ERR_ABORT (nufa_buf);
-
-	data = dict_get (xl->options, "scheduler.limits.min-free-disk");
-	if (data) {
-		if (gf_string2percent (data->data, 
-				       &nufa_buf->min_free_disk) != 0) {
-			gf_log ("nufa", GF_LOG_ERROR, 
-				"invalid number format \"%s\" of "
-				"\"option scheduler.limits.min-free-disk\"", 
-				data->data);
-			return -1;
-		}
-		if (nufa_buf->min_free_disk >= 100) {
-			gf_log ("nufa", GF_LOG_ERROR,
-				"check \"option scheduler.limits.min-free-disk"
-				"\", it should be percentage value");
-			return -1;
-		}
-	} else {
-		gf_log ("nufa", GF_LOG_WARNING, 
-			"No option for limit min-free-disk given, "
-			"defaulting it to 15%%");
-		nufa_buf->min_free_disk = NUFA_LIMITS_MIN_FREE_DISK_DEFAULT;
-	}
-	data = dict_get (xl->options, "scheduler.refresh-interval");
-	if (data != NULL) {
-                if (gf_string2time (data->data, 
-				    &nufa_buf->refresh_interval) != 0) {
-                        gf_log ("nufa", GF_LOG_ERROR, 
-                                "invalid number format \"%s\" of "
-                                "\"option scheduler.refresh-interval\"", 
-                                data->data);
-                        return -1;
-                }
-        } else {
-		gf_log ("nufa", GF_LOG_WARNING, 
-			"No option for scheduler.refresh-interval given, "
-			"defaulting it to 30");
-		nufa_buf->refresh_interval = NUFA_REFRESH_INTERVAL_DEFAULT;
-	}
-  
-	/* Get the array built */
-	while (trav_xl) {
-		index++;
-		trav_xl = trav_xl->next;
-	}
-	nufa_buf->child_count = index;
-	nufa_buf->sched_index = 0;
-	nufa_buf->array = GF_CALLOC (index, sizeof (struct nufa_sched_struct),
-                                     gf_nufa_mt_nufa_sched_struct);
-	ERR_ABORT (nufa_buf->array);
-	nufa_buf->local_array = GF_CALLOC (index, sizeof (int32_t),
-                                           gf_nufa_mt_int32_t);
-	ERR_ABORT (nufa_buf->array);
-	trav_xl = xl->children;
-	
-	local_name = dict_get (xl->options, "scheduler.local-volume-name");
-	if (!local_name) {
-		/* Error */
-		gf_log ("nufa", GF_LOG_ERROR, 
-			"No 'local-volume-name' option given in volume file");
-		GF_FREE (nufa_buf->array);
-		GF_FREE (nufa_buf->local_array);
-		GF_FREE (nufa_buf);
-		return -1;
-	}
-
-	/* Get the array properly */
-	index = 0;
-	trav_xl = xl->children;
-	while (trav_xl) {
-		nufa_buf->array[index].xl = trav_xl->xlator;
-		nufa_buf->array[index].eligible = 1;
-		nufa_buf->array[index].free_disk = nufa_buf->min_free_disk;
-		nufa_buf->array[index].refresh_interval = 
-			nufa_buf->refresh_interval;
-
-		trav_xl = trav_xl->next;
-		index++;
-	}
-  
-	{ 
-		int32_t array_index = 0;
-		char *child = NULL;
-		char *tmp = NULL;
-		char *childs_data = gf_strdup (local_name->data);
-		
-		child = strtok_r (childs_data, ",", &tmp);
-		while (child) {
-			/* Check if the local_volume specified is proper 
-			   subvolume of unify */
-			trav_xl = xl->children;
-			index=0;
-			while (trav_xl) {
-				if (strcmp (child, trav_xl->xlator->name) == 0)
-					break;
-				trav_xl = trav_xl->next;
-				index++;
-			}
-
-			if (!trav_xl) {
-				/* entry for 'local-volume-name' is wrong, 
-				   not present in subvolumes */
-				gf_log ("nufa", GF_LOG_ERROR, 
-					"option 'scheduler.local-volume-name' "
-					"%s is wrong", child);
-				GF_FREE (nufa_buf->array);
-				GF_FREE (nufa_buf->local_array);
-				GF_FREE (nufa_buf);
-				return -1;
-			} else {
-				nufa_buf->local_array[array_index++] = index;
-				nufa_buf->local_xl_count++;
-			}
-			child = strtok_r (NULL, ",", &tmp);
-		}
-		GF_FREE (childs_data);
-	}
-
-	LOCK_INIT (&nufa_buf->nufa_lock);
-	*((long *)xl->private) = (long)nufa_buf; // put it at the proper place
-	return 0;
-}
-
-static void
-nufa_fini (xlator_t *xl)
-{
-	struct nufa_struct *nufa_buf = 
-		(struct nufa_struct *)*((long *)xl->private);
-
-	LOCK_DESTROY (&nufa_buf->nufa_lock);
-	GF_FREE (nufa_buf->local_array);
-	GF_FREE (nufa_buf->array);
-	GF_FREE (nufa_buf);
-}
-
-static int32_t 
-update_stat_array_cbk (call_frame_t *frame,
-		       void *cookie,
-		       xlator_t *xl,
-		       int32_t op_ret,
-		       int32_t op_errno,
-		       struct xlator_stats *trav_stats)
-{
-	struct nufa_struct *nufa_struct = NULL; 
-	int32_t idx = 0;
-	int32_t percent = 0;
-
-	nufa_struct = (struct nufa_struct *)*((long *)xl->private);
-	LOCK (&nufa_struct->nufa_lock);
-	for (idx = 0; idx < nufa_struct->child_count; idx++) {
-		if (nufa_struct->array[idx].xl->name == (char *)cookie)
-			break;
-	}
-	UNLOCK (&nufa_struct->nufa_lock);
-
-	if (op_ret == 0) {
-		percent = ((trav_stats->free_disk * 100) / 
-			   trav_stats->total_disk_size);
-		if (nufa_struct->array[idx].free_disk > percent) {
-			if (nufa_struct->array[idx].eligible)
-				gf_log ("nufa", GF_LOG_CRITICAL,
-					"node \"%s\" is _almost_ (%d %%) full",
-					nufa_struct->array[idx].xl->name, 
-					100 - percent);
-			nufa_struct->array[idx].eligible = 0;
-		} else {
-			nufa_struct->array[idx].eligible = 1;
-		}
-	} else {
-		nufa_struct->array[idx].eligible = 0;
-	}
-
-	STACK_DESTROY (frame->root);
-	return 0;
-}
-
-static void 
-update_stat_array (xlator_t *xl)
-{
-	/* This function schedules the file in one of the child nodes */
-	int32_t idx;
-	struct nufa_struct *nufa_buf = 
-		(struct nufa_struct *)*((long *)xl->private);
-	call_frame_t *frame = NULL;
-	call_pool_t *pool = xl->ctx->pool;
-
-	for (idx = 0; idx < nufa_buf->child_count; idx++) {
-		frame = create_frame (xl, pool);
-
-		STACK_WIND_COOKIE (frame,
-				   update_stat_array_cbk, 
-				   nufa_buf->array[idx].xl->name,
-				   nufa_buf->array[idx].xl, 
-				   (nufa_buf->array[idx].xl)->mops->stats,
-				   0); //flag
-	}
-
-	return;
-}
-
-static void 
-nufa_update (xlator_t *xl)
-{
-	struct nufa_struct *nufa_buf = 
-		(struct nufa_struct *)*((long *)xl->private);
-	struct timeval tv;
-	gettimeofday (&tv, NULL);
-	if (tv.tv_sec > (nufa_buf->refresh_interval 
-			 + nufa_buf->last_stat_fetch.tv_sec)) {
-		/* Update the stats from all the server */
-		update_stat_array (xl);
-		nufa_buf->last_stat_fetch.tv_sec = tv.tv_sec;
-	}
-}
-
-static xlator_t *
-nufa_schedule (xlator_t *xl, const void *path)
-{
-	struct nufa_struct *nufa_buf = 
-		(struct nufa_struct *)*((long *)xl->private);
-	int32_t nufa_orig = nufa_buf->local_xl_index;  
-	int32_t rr;
-  
-	nufa_update (xl);
-  
-	while (1) {
-		LOCK (&nufa_buf->nufa_lock);
-		rr = nufa_buf->local_xl_index++;
-		nufa_buf->local_xl_index %= nufa_buf->local_xl_count;
-		UNLOCK (&nufa_buf->nufa_lock);
-    
-		/* if 'eligible' or there are _no_ eligible nodes */
-		if (nufa_buf->array[nufa_buf->local_array[rr]].eligible) {
-			/* Return the local node */
-			return nufa_buf->array[nufa_buf->local_array[rr]].xl;
-		}
-		if ((rr + 1) % nufa_buf->local_xl_count == nufa_orig) {
-			gf_log ("nufa", GF_LOG_CRITICAL, 
-				"No free space available on any local "
-				"volumes, using RR scheduler");
-			LOCK (&nufa_buf->nufa_lock);
-			nufa_buf->local_xl_index++;
-			nufa_buf->local_xl_index %= nufa_buf->local_xl_count;
-			UNLOCK (&nufa_buf->nufa_lock);
-			break;
-		}
-	}
-
-	nufa_orig = nufa_buf->sched_index;  
-	while (1) {
-		LOCK (&nufa_buf->nufa_lock);
-		rr = nufa_buf->sched_index++;
-		nufa_buf->sched_index = (nufa_buf->sched_index % 
-					 nufa_buf->child_count);
-		UNLOCK (&nufa_buf->nufa_lock);
-    
-		/* if 'eligible' or there are _no_ eligible nodes */
-		if (nufa_buf->array[rr].eligible) {
-			break;
-		}
-		if ((rr + 1) % nufa_buf->child_count == nufa_orig) {
-			gf_log ("nufa", GF_LOG_CRITICAL, 
-				"No free space available on any server, "
-				"using RR scheduler.");
-			LOCK (&nufa_buf->nufa_lock);
-			nufa_buf->sched_index++;
-			nufa_buf->sched_index = (nufa_buf->sched_index % 
-						 nufa_buf->child_count);
-			UNLOCK (&nufa_buf->nufa_lock);
-			break;
-		}
-	}
-	return nufa_buf->array[rr].xl;
-}
-
-
-/**
- * notify
- */
-void
-nufa_notify (xlator_t *xl, int32_t event, void *data)
-{
-	struct nufa_struct *nufa_buf = 
-		(struct nufa_struct *)*((long *)xl->private);
-	int32_t idx = 0;
-  
-	if (!nufa_buf)
-		return;
-
-	for (idx = 0; idx < nufa_buf->child_count; idx++) {
-		if (strcmp (nufa_buf->array[idx].xl->name, 
-			    ((xlator_t *)data)->name) == 0)
-			break;
-	}
-
-	switch (event)
-	{
-	case GF_EVENT_CHILD_UP:
-	{
-		//nufa_buf->array[idx].eligible = 1;
-	}
-	break;
-	case GF_EVENT_CHILD_DOWN:
-	{
-		nufa_buf->array[idx].eligible = 0;
-	}
-	break;
-	default:
-	{
-		;
-	}
-	break;
-	}
-
-}
-
-int32_t
-nufa_mem_acct_init (xlator_t *this)
-{
-        int     ret = -1;
-
-        if (!this)
-                return ret;
-
-        ret = xlator_mem_acct_init (this, gf_nufa_mt_end + 1);
-        
-        if (ret != 0) {
-                gf_log (this->name, GF_LOG_ERROR, "Memory accounting init"
-                                "failed");
-                return ret;
-        }
-
-        return ret;
-}
-
-struct sched_ops sched = {
-	.init     = nufa_init,
-	.fini     = nufa_fini,
-	.update   = nufa_update,
-	.schedule = nufa_schedule,
-	.notify   = nufa_notify,
-        .mem_acct_init = nufa_mem_acct_init,
-};
-
-struct volume_options options[] = {
-	{ .key   = { "scheduler.refresh-interval", 
-		     "nufa.refresh-interval" },  
-	  .type  = GF_OPTION_TYPE_TIME
-	},
-	{ .key   = { "scheduler.limits.min-free-disk", 
-		     "nufa.limits.min-free-disk" },  
-	  .type  = GF_OPTION_TYPE_PERCENT
-	},
-	{ .key   = { "scheduler.local-volume-name",
-		     "nufa.local-volume-name" },
-	  .type  = GF_OPTION_TYPE_XLATOR
-	},	
-	{ .key = {NULL} }
-};
-