drivers/staging/lustre/lustre/obdclass/class_obd.c - nest-learning-thermostat/5.7.1/linux-imx-ul - Git at Google

 /*
  * GPL HEADER START
  *
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License version 2 only,
  * as published by the Free Software Foundation.
  *
  * This program 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 version 2 for more details (a copy is included
  * in the LICENSE file that accompanied this code).
  *
  * You should have received a copy of the GNU General Public License
  * version 2 along with this program; If not, see
  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  *
  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  * CA 95054 USA or visit www.sun.com if you need additional information or
  * have any questions.
  *
  * GPL HEADER END
  */
 /*
  * Copyright (c) 1999, 2010, Oracle and/or its affiliates. All rights reserved.
  * Use is subject to license terms.
  *
  * Copyright (c) 2011, 2012, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
  * Lustre is a trademark of Sun Microsystems, Inc.
  */

 #define DEBUG_SUBSYSTEM S_CLASS
 # include <linux/atomic.h>

 #include "../include/obd_support.h"
 #include "../include/obd_class.h"
 #include "../../include/linux/lnet/lnetctl.h"
 #include "../include/lustre_debug.h"
 #include "../include/lprocfs_status.h"
 #include "../include/lustre/lustre_build_version.h"
 #include <linux/list.h>
 #include "../include/cl_object.h"
 #include "llog_internal.h"


 struct obd_device *obd_devs[MAX_OBD_DEVICES];
 EXPORT_SYMBOL(obd_devs);
 struct list_head obd_types;
 DEFINE_RWLOCK(obd_dev_lock);

 __u64 obd_max_pages = 0;
 EXPORT_SYMBOL(obd_max_pages);
 __u64 obd_max_alloc = 0;
 EXPORT_SYMBOL(obd_max_alloc);
 __u64 obd_alloc;
 EXPORT_SYMBOL(obd_alloc);
 __u64 obd_pages;
 EXPORT_SYMBOL(obd_pages);
 static DEFINE_SPINLOCK(obd_updatemax_lock);

 /* The following are visible and mutable through /proc/sys/lustre/. */
 unsigned int obd_alloc_fail_rate = 0;
 EXPORT_SYMBOL(obd_alloc_fail_rate);
 unsigned int obd_debug_peer_on_timeout;
 EXPORT_SYMBOL(obd_debug_peer_on_timeout);
 unsigned int obd_dump_on_timeout;
 EXPORT_SYMBOL(obd_dump_on_timeout);
 unsigned int obd_dump_on_eviction;
 EXPORT_SYMBOL(obd_dump_on_eviction);
 unsigned int obd_max_dirty_pages = 256;
 EXPORT_SYMBOL(obd_max_dirty_pages);
 atomic_t obd_dirty_pages;
 EXPORT_SYMBOL(obd_dirty_pages);
 unsigned int obd_timeout = OBD_TIMEOUT_DEFAULT;   /* seconds */
 EXPORT_SYMBOL(obd_timeout);
 unsigned int ldlm_timeout = LDLM_TIMEOUT_DEFAULT; /* seconds */
 EXPORT_SYMBOL(ldlm_timeout);
 unsigned int obd_timeout_set;
 EXPORT_SYMBOL(obd_timeout_set);
 unsigned int ldlm_timeout_set;
 EXPORT_SYMBOL(ldlm_timeout_set);
 /* Adaptive timeout defs here instead of ptlrpc module for /proc/sys/ access */
 unsigned int at_min = 0;
 EXPORT_SYMBOL(at_min);
 unsigned int at_max = 600;
 EXPORT_SYMBOL(at_max);
 unsigned int at_history = 600;
 EXPORT_SYMBOL(at_history);
 int at_early_margin = 5;
 EXPORT_SYMBOL(at_early_margin);
 int at_extra = 30;
 EXPORT_SYMBOL(at_extra);

 atomic_t obd_dirty_transit_pages;
 EXPORT_SYMBOL(obd_dirty_transit_pages);

 char obd_jobid_var[JOBSTATS_JOBID_VAR_MAX_LEN + 1] = JOBSTATS_DISABLE;
 EXPORT_SYMBOL(obd_jobid_var);

 char obd_jobid_node[JOBSTATS_JOBID_SIZE + 1];

 /* Get jobid of current process from stored variable or calculate
  * it from pid and user_id.
  *
  * Historically this was also done by reading the environment variable
  * stored in between the "env_start" & "env_end" of task struct.
  * This is now deprecated.
  */
 int lustre_get_jobid(char *jobid)
 {
 	memset(jobid, 0, JOBSTATS_JOBID_SIZE);
 	/* Jobstats isn't enabled */
 	if (strcmp(obd_jobid_var, JOBSTATS_DISABLE) == 0)
 		return 0;

 	/* Use process name + fsuid as jobid */
 	if (strcmp(obd_jobid_var, JOBSTATS_PROCNAME_UID) == 0) {
 		snprintf(jobid, JOBSTATS_JOBID_SIZE, "%s.%u",
 			 current_comm(),
 			 from_kuid(&init_user_ns, current_fsuid()));
 		return 0;
 	}

 	/* Whole node dedicated to single job */
 	if (strcmp(obd_jobid_var, JOBSTATS_NODELOCAL) == 0) {
 		strcpy(jobid, obd_jobid_node);
 		return 0;
 	}

 	return -ENOENT;
 }
 EXPORT_SYMBOL(lustre_get_jobid);

 int obd_alloc_fail(const void *ptr, const char *name, const char *type,
 		   size_t size, const char *file, int line)
 {
 	if (ptr == NULL ||
 	    (cfs_rand() & OBD_ALLOC_FAIL_MASK) < obd_alloc_fail_rate) {
 		CERROR("%s%salloc of %s (%llu bytes) failed at %s:%d\n",
 		       ptr ? "force " :"", type, name, (__u64)size, file,
 		       line);
 		CERROR("%llu total bytes and %llu total pages (%llu bytes) allocated by Lustre, %d total bytes by LNET\n",
 		       obd_memory_sum(),
 		       obd_pages_sum() << PAGE_CACHE_SHIFT,
 		       obd_pages_sum(),
 		       atomic_read(&libcfs_kmemory));
 		return 1;
 	}
 	return 0;
 }
 EXPORT_SYMBOL(obd_alloc_fail);

 static inline void obd_data2conn(struct lustre_handle *conn,
 				 struct obd_ioctl_data *data)
 {
 	memset(conn, 0, sizeof(*conn));
 	conn->cookie = data->ioc_cookie;
 }

 static inline void obd_conn2data(struct obd_ioctl_data *data,
 				 struct lustre_handle *conn)
 {
 	data->ioc_cookie = conn->cookie;
 }

 int class_resolve_dev_name(__u32 len, const char *name)
 {
 	int rc;
 	int dev;

 	if (!len || !name) {
 		CERROR("No name passed,!\n");
 		rc = -EINVAL;
 		goto out;
 	}
 	if (name[len - 1] != 0) {
 		CERROR("Name not nul terminated!\n");
 		rc = -EINVAL;
 		goto out;
 	}

 	CDEBUG(D_IOCTL, "device name %s\n", name);
 	dev = class_name2dev(name);
 	if (dev == -1) {
 		CDEBUG(D_IOCTL, "No device for name %s!\n", name);
 		rc = -EINVAL;
 		goto out;
 	}

 	CDEBUG(D_IOCTL, "device name %s, dev %d\n", name, dev);
 	rc = dev;

 out:
 	return rc;
 }

 int class_handle_ioctl(unsigned int cmd, unsigned long arg)
 {
 	char *buf = NULL;
 	struct obd_ioctl_data *data;
 	struct libcfs_debug_ioctl_data *debug_data;
 	struct obd_device *obd = NULL;
 	int err = 0, len = 0;

 	/* only for debugging */
 	if (cmd == LIBCFS_IOC_DEBUG_MASK) {
 		debug_data = (struct libcfs_debug_ioctl_data *)arg;
 		libcfs_subsystem_debug = debug_data->subs;
 		libcfs_debug = debug_data->debug;
 		return 0;
 	}

 	CDEBUG(D_IOCTL, "cmd = %x\n", cmd);
 	if (obd_ioctl_getdata(&buf, &len, (void *)arg)) {
 		CERROR("OBD ioctl: data error\n");
 		return -EINVAL;
 	}
 	data = (struct obd_ioctl_data *)buf;

 	switch (cmd) {
 	case OBD_IOC_PROCESS_CFG: {
 		struct lustre_cfg *lcfg;

 		if (!data->ioc_plen1 || !data->ioc_pbuf1) {
 			CERROR("No config buffer passed!\n");
 			err = -EINVAL;
 			goto out;
 		}
 		OBD_ALLOC(lcfg, data->ioc_plen1);
 		if (lcfg == NULL) {
 			err = -ENOMEM;
 			goto out;
 		}
 		err = copy_from_user(lcfg, data->ioc_pbuf1,
 					 data->ioc_plen1);
 		if (!err)
 			err = lustre_cfg_sanity_check(lcfg, data->ioc_plen1);
 		if (!err)
 			err = class_process_config(lcfg);

 		OBD_FREE(lcfg, data->ioc_plen1);
 		goto out;
 	}

 	case OBD_GET_VERSION:
 		if (!data->ioc_inlbuf1) {
 			CERROR("No buffer passed in ioctl\n");
 			err = -EINVAL;
 			goto out;
 		}

 		if (strlen(BUILD_VERSION) + 1 > data->ioc_inllen1) {
 			CERROR("ioctl buffer too small to hold version\n");
 			err = -EINVAL;
 			goto out;
 		}

 		memcpy(data->ioc_bulk, BUILD_VERSION,
 		       strlen(BUILD_VERSION) + 1);

 		err = obd_ioctl_popdata((void *)arg, data, len);
 		if (err)
 			err = -EFAULT;
 		goto out;

 	case OBD_IOC_NAME2DEV: {
 		/* Resolve a device name.  This does not change the
 		 * currently selected device.
 		 */
 		int dev;

 		dev = class_resolve_dev_name(data->ioc_inllen1,
 					     data->ioc_inlbuf1);
 		data->ioc_dev = dev;
 		if (dev < 0) {
 			err = -EINVAL;
 			goto out;
 		}

 		err = obd_ioctl_popdata((void *)arg, data, sizeof(*data));
 		if (err)
 			err = -EFAULT;
 		goto out;
 	}

 	case OBD_IOC_UUID2DEV: {
 		/* Resolve a device uuid.  This does not change the
 		 * currently selected device.
 		 */
 		int dev;
 		struct obd_uuid uuid;

 		if (!data->ioc_inllen1 || !data->ioc_inlbuf1) {
 			CERROR("No UUID passed!\n");
 			err = -EINVAL;
 			goto out;
 		}
 		if (data->ioc_inlbuf1[data->ioc_inllen1 - 1] != 0) {
 			CERROR("UUID not NUL terminated!\n");
 			err = -EINVAL;
 			goto out;
 		}

 		CDEBUG(D_IOCTL, "device name %s\n", data->ioc_inlbuf1);
 		obd_str2uuid(&uuid, data->ioc_inlbuf1);
 		dev = class_uuid2dev(&uuid);
 		data->ioc_dev = dev;
 		if (dev == -1) {
 			CDEBUG(D_IOCTL, "No device for UUID %s!\n",
 			       data->ioc_inlbuf1);
 			err = -EINVAL;
 			goto out;
 		}

 		CDEBUG(D_IOCTL, "device name %s, dev %d\n", data->ioc_inlbuf1,
 		       dev);
 		err = obd_ioctl_popdata((void *)arg, data, sizeof(*data));
 		if (err)
 			err = -EFAULT;
 		goto out;
 	}

 	case OBD_IOC_CLOSE_UUID: {
 		CDEBUG(D_IOCTL, "closing all connections to uuid %s (NOOP)\n",
 		       data->ioc_inlbuf1);
 		err = 0;
 		goto out;
 	}

 	case OBD_IOC_GETDEVICE: {
 		int     index = data->ioc_count;
 		char    *status, *str;

 		if (!data->ioc_inlbuf1) {
 			CERROR("No buffer passed in ioctl\n");
 			err = -EINVAL;
 			goto out;
 		}
 		if (data->ioc_inllen1 < 128) {
 			CERROR("ioctl buffer too small to hold version\n");
 			err = -EINVAL;
 			goto out;
 		}

 		obd = class_num2obd(index);
 		if (!obd) {
 			err = -ENOENT;
 			goto out;
 		}

 		if (obd->obd_stopping)
 			status = "ST";
 		else if (obd->obd_set_up)
 			status = "UP";
 		else if (obd->obd_attached)
 			status = "AT";
 		else
 			status = "--";
 		str = (char *)data->ioc_bulk;
 		snprintf(str, len - sizeof(*data), "%3d %s %s %s %s %d",
 			 (int)index, status, obd->obd_type->typ_name,
 			 obd->obd_name, obd->obd_uuid.uuid,
 			 atomic_read(&obd->obd_refcount));
 		err = obd_ioctl_popdata((void *)arg, data, len);

 		err = 0;
 		goto out;
 	}

 	}

 	if (data->ioc_dev == OBD_DEV_BY_DEVNAME) {
 		if (data->ioc_inllen4 <= 0 || data->ioc_inlbuf4 == NULL) {
 			err = -EINVAL;
 			goto out;
 		}
 		if (strnlen(data->ioc_inlbuf4, MAX_OBD_NAME) >= MAX_OBD_NAME) {
 			err = -EINVAL;
 			goto out;
 		}
 		obd = class_name2obd(data->ioc_inlbuf4);
 	} else if (data->ioc_dev < class_devno_max()) {
 		obd = class_num2obd(data->ioc_dev);
 	} else {
 		CERROR("OBD ioctl: No device\n");
 		err = -EINVAL;
 		goto out;
 	}

 	if (obd == NULL) {
 		CERROR("OBD ioctl : No Device %d\n", data->ioc_dev);
 		err = -EINVAL;
 		goto out;
 	}
 	LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);

 	if (!obd->obd_set_up || obd->obd_stopping) {
 		CERROR("OBD ioctl: device not setup %d\n", data->ioc_dev);
 		err = -EINVAL;
 		goto out;
 	}

 	switch (cmd) {
 	case OBD_IOC_NO_TRANSNO: {
 		if (!obd->obd_attached) {
 			CERROR("Device %d not attached\n", obd->obd_minor);
 			err = -ENODEV;
 			goto out;
 		}
 		CDEBUG(D_HA, "%s: disabling committed-transno notification\n",
 		       obd->obd_name);
 		obd->obd_no_transno = 1;
 		err = 0;
 		goto out;
 	}

 	default: {
 		err = obd_iocontrol(cmd, obd->obd_self_export, len, data, NULL);
 		if (err)
 			goto out;

 		err = obd_ioctl_popdata((void *)arg, data, len);
 		if (err)
 			err = -EFAULT;
 		goto out;
 	}
 	}

  out:
 	if (buf)
 		obd_ioctl_freedata(buf, len);
 	return err;
 } /* class_handle_ioctl */

 #define OBD_INIT_CHECK
 int obd_init_checks(void)
 {
 	__u64 u64val, div64val;
 	char buf[64];
 	int len, ret = 0;

 	CDEBUG(D_INFO, "LPU64=%s, LPD64=%s, LPX64=%s\n", "%llu", "%lld", "%#llx");

 	CDEBUG(D_INFO, "OBD_OBJECT_EOF = %#llx\n", (__u64)OBD_OBJECT_EOF);

 	u64val = OBD_OBJECT_EOF;
 	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = %#llx\n", u64val);
 	if (u64val != OBD_OBJECT_EOF) {
 		CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
 		       u64val, (int)sizeof(u64val));
 		ret = -EINVAL;
 	}
 	len = snprintf(buf, sizeof(buf), "%#llx", u64val);
 	if (len != 18) {
 		CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
 		ret = -EINVAL;
 	}

 	div64val = OBD_OBJECT_EOF;
 	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = %#llx\n", u64val);
 	if (u64val != OBD_OBJECT_EOF) {
 		CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
 		       u64val, (int)sizeof(u64val));
 		ret = -EOVERFLOW;
 	}
 	if (u64val >> 8 != OBD_OBJECT_EOF >> 8) {
 		CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
 		       u64val, (int)sizeof(u64val));
 		return -EOVERFLOW;
 	}
 	if (do_div(div64val, 256) != (u64val & 255)) {
 		CERROR("do_div(%#llx,256) != %llu\n", u64val, u64val &255);
 		return -EOVERFLOW;
 	}
 	if (u64val >> 8 != div64val) {
 		CERROR("do_div(%#llx,256) %llu != %llu\n",
 		       u64val, div64val, u64val >> 8);
 		return -EOVERFLOW;
 	}
 	len = snprintf(buf, sizeof(buf), "%#llx", u64val);
 	if (len != 18) {
 		CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
 		ret = -EINVAL;
 	}
 	len = snprintf(buf, sizeof(buf), "%llu", u64val);
 	if (len != 20) {
 		CWARN("LPU64 wrong length! strlen(%s)=%d != 20\n", buf, len);
 		ret = -EINVAL;
 	}
 	len = snprintf(buf, sizeof(buf), "%lld", u64val);
 	if (len != 2) {
 		CWARN("LPD64 wrong length! strlen(%s)=%d != 2\n", buf, len);
 		ret = -EINVAL;
 	}
 	if ((u64val & ~CFS_PAGE_MASK) >= PAGE_CACHE_SIZE) {
 		CWARN("mask failed: u64val %llu >= %llu\n", u64val,
 		      (__u64)PAGE_CACHE_SIZE);
 		ret = -EINVAL;
 	}

 	return ret;
 }

 #if defined (CONFIG_PROC_FS)
 extern int class_procfs_init(void);
 extern int class_procfs_clean(void);
 #else
 static inline int class_procfs_init(void)
 { return 0; }
 static inline int class_procfs_clean(void)
 { return 0; }
 #endif

 static int __init init_obdclass(void)
 {
 	int i, err;
 	int lustre_register_fs(void);

 	for (i = CAPA_SITE_CLIENT; i < CAPA_SITE_MAX; i++)
 		INIT_LIST_HEAD(&capa_list[i]);

 	LCONSOLE_INFO("Lustre: Build Version: "BUILD_VERSION"\n");

 	spin_lock_init(&obd_types_lock);
 	obd_zombie_impexp_init();

 	if (IS_ENABLED(CONFIG_PROC_FS)) {
 		obd_memory = lprocfs_alloc_stats(OBD_STATS_NUM,
 						 LPROCFS_STATS_FLAG_NONE |
 						 LPROCFS_STATS_FLAG_IRQ_SAFE);

 		if (obd_memory == NULL) {
 			CERROR("kmalloc of 'obd_memory' failed\n");
 			return -ENOMEM;
 		}

 		lprocfs_counter_init(obd_memory, OBD_MEMORY_STAT,
 				     LPROCFS_CNTR_AVGMINMAX,
 				     "memused", "bytes");
 		lprocfs_counter_init(obd_memory, OBD_MEMORY_PAGES_STAT,
 				     LPROCFS_CNTR_AVGMINMAX,
 				     "pagesused", "pages");
 	}

 	err = obd_init_checks();
 	if (err == -EOVERFLOW)
 		return err;

 	class_init_uuidlist();
 	err = class_handle_init();
 	if (err)
 		return err;

 	INIT_LIST_HEAD(&obd_types);

 	err = misc_register(&obd_psdev);
 	if (err) {
 		CERROR("cannot register %d err %d\n", OBD_DEV_MINOR, err);
 		return err;
 	}

 	/* This struct is already zeroed for us (static global) */
 	for (i = 0; i < class_devno_max(); i++)
 		obd_devs[i] = NULL;

 	/* Default the dirty page cache cap to 1/2 of system memory.
 	 * For clients with less memory, a larger fraction is needed
 	 * for other purposes (mostly for BGL). */
 	if (totalram_pages <= 512 << (20 - PAGE_CACHE_SHIFT))
 		obd_max_dirty_pages = totalram_pages / 4;
 	else
 		obd_max_dirty_pages = totalram_pages / 2;

 	err = obd_init_caches();
 	if (err)
 		return err;

 	obd_sysctl_init();

 	err = class_procfs_init();
 	if (err)
 		return err;

 	err = lu_global_init();
 	if (err)
 		return err;

 	err = cl_global_init();
 	if (err != 0)
 		return err;


 	err = llog_info_init();
 	if (err)
 		return err;

 	err = lustre_register_fs();

 	return err;
 }

 void obd_update_maxusage(void)
 {
 	__u64 max1, max2;

 	max1 = obd_pages_sum();
 	max2 = obd_memory_sum();

 	spin_lock(&obd_updatemax_lock);
 	if (max1 > obd_max_pages)
 		obd_max_pages = max1;
 	if (max2 > obd_max_alloc)
 		obd_max_alloc = max2;
 	spin_unlock(&obd_updatemax_lock);
 }
 EXPORT_SYMBOL(obd_update_maxusage);

 #if defined (CONFIG_PROC_FS)
 __u64 obd_memory_max(void)
 {
 	__u64 ret;

 	spin_lock(&obd_updatemax_lock);
 	ret = obd_max_alloc;
 	spin_unlock(&obd_updatemax_lock);

 	return ret;
 }
 EXPORT_SYMBOL(obd_memory_max);

 __u64 obd_pages_max(void)
 {
 	__u64 ret;

 	spin_lock(&obd_updatemax_lock);
 	ret = obd_max_pages;
 	spin_unlock(&obd_updatemax_lock);

 	return ret;
 }
 EXPORT_SYMBOL(obd_pages_max);
 #endif

 /* liblustre doesn't call cleanup_obdclass, apparently.  we carry on in this
  * ifdef to the end of the file to cover module and versioning goo.*/
 static void cleanup_obdclass(void)
 {
 	int i;
 	int lustre_unregister_fs(void);
 	__u64 memory_leaked, pages_leaked;
 	__u64 memory_max, pages_max;

 	lustre_unregister_fs();

 	misc_deregister(&obd_psdev);
 	for (i = 0; i < class_devno_max(); i++) {
 		struct obd_device *obd = class_num2obd(i);
 		if (obd && obd->obd_set_up &&
 		    OBT(obd) && OBP(obd, detach)) {
 			/* XXX should this call generic detach otherwise? */
 			LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
 			OBP(obd, detach)(obd);
 		}
 	}
 	llog_info_fini();
 	cl_global_fini();
 	lu_global_fini();

 	obd_cleanup_caches();
 	obd_sysctl_clean();

 	class_procfs_clean();

 	class_handle_cleanup();
 	class_exit_uuidlist();
 	obd_zombie_impexp_stop();

 	memory_leaked = obd_memory_sum();
 	pages_leaked = obd_pages_sum();

 	memory_max = obd_memory_max();
 	pages_max = obd_pages_max();

 	lprocfs_free_stats(&obd_memory);
 	CDEBUG((memory_leaked) ? D_ERROR : D_INFO,
 	       "obd_memory max: %llu, leaked: %llu\n",
 	       memory_max, memory_leaked);
 	CDEBUG((pages_leaked) ? D_ERROR : D_INFO,
 	       "obd_memory_pages max: %llu, leaked: %llu\n",
 	       pages_max, pages_leaked);
 }

 MODULE_AUTHOR("Sun Microsystems, Inc. <http://www.lustre.org/>");
 MODULE_DESCRIPTION("Lustre Class Driver Build Version: " BUILD_VERSION);
 MODULE_LICENSE("GPL");
 MODULE_VERSION(LUSTRE_VERSION_STRING);

 module_init(init_obdclass);
 module_exit(cleanup_obdclass);
	/*
	* GPL HEADER START
	*
	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
	*
	* This program is free software; you can redistribute it and/or modify
	* it under the terms of the GNU General Public License version 2 only,
	* as published by the Free Software Foundation.
	*
	* This program 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 version 2 for more details (a copy is included
	* in the LICENSE file that accompanied this code).
	*
	* You should have received a copy of the GNU General Public License
	* version 2 along with this program; If not, see
	* http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
	*
	* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
	* CA 95054 USA or visit www.sun.com if you need additional information or
	* have any questions.
	*
	* GPL HEADER END
	*/
	/*
	* Copyright (c) 1999, 2010, Oracle and/or its affiliates. All rights reserved.
	* Use is subject to license terms.
	*
	* Copyright (c) 2011, 2012, Intel Corporation.
	*/
	/*
	* This file is part of Lustre, http://www.lustre.org/
	* Lustre is a trademark of Sun Microsystems, Inc.
	*/

	#define DEBUG_SUBSYSTEM S_CLASS
	# include <linux/atomic.h>

	#include "../include/obd_support.h"
	#include "../include/obd_class.h"
	#include "../../include/linux/lnet/lnetctl.h"
	#include "../include/lustre_debug.h"
	#include "../include/lprocfs_status.h"
	#include "../include/lustre/lustre_build_version.h"
	#include <linux/list.h>
	#include "../include/cl_object.h"
	#include "llog_internal.h"


	struct obd_device *obd_devs[MAX_OBD_DEVICES];
	EXPORT_SYMBOL(obd_devs);
	struct list_head obd_types;
	DEFINE_RWLOCK(obd_dev_lock);

	__u64 obd_max_pages = 0;
	EXPORT_SYMBOL(obd_max_pages);
	__u64 obd_max_alloc = 0;
	EXPORT_SYMBOL(obd_max_alloc);
	__u64 obd_alloc;
	EXPORT_SYMBOL(obd_alloc);
	__u64 obd_pages;
	EXPORT_SYMBOL(obd_pages);
	static DEFINE_SPINLOCK(obd_updatemax_lock);

	/* The following are visible and mutable through /proc/sys/lustre/. */
	unsigned int obd_alloc_fail_rate = 0;
	EXPORT_SYMBOL(obd_alloc_fail_rate);
	unsigned int obd_debug_peer_on_timeout;
	EXPORT_SYMBOL(obd_debug_peer_on_timeout);
	unsigned int obd_dump_on_timeout;
	EXPORT_SYMBOL(obd_dump_on_timeout);
	unsigned int obd_dump_on_eviction;
	EXPORT_SYMBOL(obd_dump_on_eviction);
	unsigned int obd_max_dirty_pages = 256;
	EXPORT_SYMBOL(obd_max_dirty_pages);
	atomic_t obd_dirty_pages;
	EXPORT_SYMBOL(obd_dirty_pages);
	unsigned int obd_timeout = OBD_TIMEOUT_DEFAULT; /* seconds */
	EXPORT_SYMBOL(obd_timeout);
	unsigned int ldlm_timeout = LDLM_TIMEOUT_DEFAULT; /* seconds */
	EXPORT_SYMBOL(ldlm_timeout);
	unsigned int obd_timeout_set;
	EXPORT_SYMBOL(obd_timeout_set);
	unsigned int ldlm_timeout_set;
	EXPORT_SYMBOL(ldlm_timeout_set);
	/* Adaptive timeout defs here instead of ptlrpc module for /proc/sys/ access */
	unsigned int at_min = 0;
	EXPORT_SYMBOL(at_min);
	unsigned int at_max = 600;
	EXPORT_SYMBOL(at_max);
	unsigned int at_history = 600;
	EXPORT_SYMBOL(at_history);
	int at_early_margin = 5;
	EXPORT_SYMBOL(at_early_margin);
	int at_extra = 30;
	EXPORT_SYMBOL(at_extra);

	atomic_t obd_dirty_transit_pages;
	EXPORT_SYMBOL(obd_dirty_transit_pages);

	char obd_jobid_var[JOBSTATS_JOBID_VAR_MAX_LEN + 1] = JOBSTATS_DISABLE;
	EXPORT_SYMBOL(obd_jobid_var);

	char obd_jobid_node[JOBSTATS_JOBID_SIZE + 1];

	/* Get jobid of current process from stored variable or calculate
	* it from pid and user_id.
	*
	* Historically this was also done by reading the environment variable
	* stored in between the "env_start" & "env_end" of task struct.
	* This is now deprecated.
	*/
	int lustre_get_jobid(char *jobid)
	{
	memset(jobid, 0, JOBSTATS_JOBID_SIZE);
	/* Jobstats isn't enabled */
	if (strcmp(obd_jobid_var, JOBSTATS_DISABLE) == 0)
	return 0;

	/* Use process name + fsuid as jobid */
	if (strcmp(obd_jobid_var, JOBSTATS_PROCNAME_UID) == 0) {
	snprintf(jobid, JOBSTATS_JOBID_SIZE, "%s.%u",
	current_comm(),
	from_kuid(&init_user_ns, current_fsuid()));
	return 0;
	}

	/* Whole node dedicated to single job */
	if (strcmp(obd_jobid_var, JOBSTATS_NODELOCAL) == 0) {
	strcpy(jobid, obd_jobid_node);
	return 0;
	}

	return -ENOENT;
	}
	EXPORT_SYMBOL(lustre_get_jobid);

	int obd_alloc_fail(const void ptr, const char name, const char *type,
	size_t size, const char *file, int line)
	{
	if (ptr == NULL \|\|
	(cfs_rand() & OBD_ALLOC_FAIL_MASK) < obd_alloc_fail_rate) {
	CERROR("%s%salloc of %s (%llu bytes) failed at %s:%d\n",
	ptr ? "force " :"", type, name, (__u64)size, file,
	line);
	CERROR("%llu total bytes and %llu total pages (%llu bytes) allocated by Lustre, %d total bytes by LNET\n",
	obd_memory_sum(),
	obd_pages_sum() << PAGE_CACHE_SHIFT,
	obd_pages_sum(),
	atomic_read(&libcfs_kmemory));
	return 1;
	}
	return 0;
	}
	EXPORT_SYMBOL(obd_alloc_fail);

	static inline void obd_data2conn(struct lustre_handle *conn,
	struct obd_ioctl_data *data)
	{
	memset(conn, 0, sizeof(*conn));
	conn->cookie = data->ioc_cookie;
	}

	static inline void obd_conn2data(struct obd_ioctl_data *data,
	struct lustre_handle *conn)
	{
	data->ioc_cookie = conn->cookie;
	}

	int class_resolve_dev_name(__u32 len, const char *name)
	{
	int rc;
	int dev;

	if (!len \|\| !name) {
	CERROR("No name passed,!\n");
	rc = -EINVAL;
	goto out;
	}
	if (name[len - 1] != 0) {
	CERROR("Name not nul terminated!\n");
	rc = -EINVAL;
	goto out;
	}

	CDEBUG(D_IOCTL, "device name %s\n", name);
	dev = class_name2dev(name);
	if (dev == -1) {
	CDEBUG(D_IOCTL, "No device for name %s!\n", name);
	rc = -EINVAL;
	goto out;
	}

	CDEBUG(D_IOCTL, "device name %s, dev %d\n", name, dev);
	rc = dev;

	out:
	return rc;
	}

	int class_handle_ioctl(unsigned int cmd, unsigned long arg)
	{
	char *buf = NULL;
	struct obd_ioctl_data *data;
	struct libcfs_debug_ioctl_data *debug_data;
	struct obd_device *obd = NULL;
	int err = 0, len = 0;

	/* only for debugging */
	if (cmd == LIBCFS_IOC_DEBUG_MASK) {
	debug_data = (struct libcfs_debug_ioctl_data *)arg;
	libcfs_subsystem_debug = debug_data->subs;
	libcfs_debug = debug_data->debug;
	return 0;
	}

	CDEBUG(D_IOCTL, "cmd = %x\n", cmd);
	if (obd_ioctl_getdata(&buf, &len, (void *)arg)) {
	CERROR("OBD ioctl: data error\n");
	return -EINVAL;
	}
	data = (struct obd_ioctl_data *)buf;

	switch (cmd) {
	case OBD_IOC_PROCESS_CFG: {
	struct lustre_cfg *lcfg;

	if (!data->ioc_plen1 \|\| !data->ioc_pbuf1) {
	CERROR("No config buffer passed!\n");
	err = -EINVAL;
	goto out;
	}
	OBD_ALLOC(lcfg, data->ioc_plen1);
	if (lcfg == NULL) {
	err = -ENOMEM;
	goto out;
	}
	err = copy_from_user(lcfg, data->ioc_pbuf1,
	data->ioc_plen1);
	if (!err)
	err = lustre_cfg_sanity_check(lcfg, data->ioc_plen1);
	if (!err)
	err = class_process_config(lcfg);

	OBD_FREE(lcfg, data->ioc_plen1);
	goto out;
	}

	case OBD_GET_VERSION:
	if (!data->ioc_inlbuf1) {
	CERROR("No buffer passed in ioctl\n");
	err = -EINVAL;
	goto out;
	}

	if (strlen(BUILD_VERSION) + 1 > data->ioc_inllen1) {
	CERROR("ioctl buffer too small to hold version\n");
	err = -EINVAL;
	goto out;
	}

	memcpy(data->ioc_bulk, BUILD_VERSION,
	strlen(BUILD_VERSION) + 1);

	err = obd_ioctl_popdata((void *)arg, data, len);
	if (err)
	err = -EFAULT;
	goto out;

	case OBD_IOC_NAME2DEV: {
	/* Resolve a device name. This does not change the
	* currently selected device.
	*/
	int dev;

	dev = class_resolve_dev_name(data->ioc_inllen1,
	data->ioc_inlbuf1);
	data->ioc_dev = dev;
	if (dev < 0) {
	err = -EINVAL;
	goto out;
	}

	err = obd_ioctl_popdata((void )arg, data, sizeof(data));
	if (err)
	err = -EFAULT;
	goto out;
	}

	case OBD_IOC_UUID2DEV: {
	/* Resolve a device uuid. This does not change the
	* currently selected device.
	*/
	int dev;
	struct obd_uuid uuid;

	if (!data->ioc_inllen1 \|\| !data->ioc_inlbuf1) {
	CERROR("No UUID passed!\n");
	err = -EINVAL;
	goto out;
	}
	if (data->ioc_inlbuf1[data->ioc_inllen1 - 1] != 0) {
	CERROR("UUID not NUL terminated!\n");
	err = -EINVAL;
	goto out;
	}

	CDEBUG(D_IOCTL, "device name %s\n", data->ioc_inlbuf1);
	obd_str2uuid(&uuid, data->ioc_inlbuf1);
	dev = class_uuid2dev(&uuid);
	data->ioc_dev = dev;
	if (dev == -1) {
	CDEBUG(D_IOCTL, "No device for UUID %s!\n",
	data->ioc_inlbuf1);
	err = -EINVAL;
	goto out;
	}

	CDEBUG(D_IOCTL, "device name %s, dev %d\n", data->ioc_inlbuf1,
	dev);
	err = obd_ioctl_popdata((void )arg, data, sizeof(data));
	if (err)
	err = -EFAULT;
	goto out;
	}

	case OBD_IOC_CLOSE_UUID: {
	CDEBUG(D_IOCTL, "closing all connections to uuid %s (NOOP)\n",
	data->ioc_inlbuf1);
	err = 0;
	goto out;
	}

	case OBD_IOC_GETDEVICE: {
	int index = data->ioc_count;
	char status, str;

	if (!data->ioc_inlbuf1) {
	CERROR("No buffer passed in ioctl\n");
	err = -EINVAL;
	goto out;
	}
	if (data->ioc_inllen1 < 128) {
	CERROR("ioctl buffer too small to hold version\n");
	err = -EINVAL;
	goto out;
	}

	obd = class_num2obd(index);
	if (!obd) {
	err = -ENOENT;
	goto out;
	}

	if (obd->obd_stopping)
	status = "ST";
	else if (obd->obd_set_up)
	status = "UP";
	else if (obd->obd_attached)
	status = "AT";
	else
	status = "--";
	str = (char *)data->ioc_bulk;
	snprintf(str, len - sizeof(*data), "%3d %s %s %s %s %d",
	(int)index, status, obd->obd_type->typ_name,
	obd->obd_name, obd->obd_uuid.uuid,
	atomic_read(&obd->obd_refcount));
	err = obd_ioctl_popdata((void *)arg, data, len);

	err = 0;
	goto out;
	}

	}

	if (data->ioc_dev == OBD_DEV_BY_DEVNAME) {
	if (data->ioc_inllen4 <= 0 \|\| data->ioc_inlbuf4 == NULL) {
	err = -EINVAL;
	goto out;
	}
	if (strnlen(data->ioc_inlbuf4, MAX_OBD_NAME) >= MAX_OBD_NAME) {
	err = -EINVAL;
	goto out;
	}
	obd = class_name2obd(data->ioc_inlbuf4);
	} else if (data->ioc_dev < class_devno_max()) {
	obd = class_num2obd(data->ioc_dev);
	} else {
	CERROR("OBD ioctl: No device\n");
	err = -EINVAL;
	goto out;
	}

	if (obd == NULL) {
	CERROR("OBD ioctl : No Device %d\n", data->ioc_dev);
	err = -EINVAL;
	goto out;
	}
	LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);

	if (!obd->obd_set_up \|\| obd->obd_stopping) {
	CERROR("OBD ioctl: device not setup %d\n", data->ioc_dev);
	err = -EINVAL;
	goto out;
	}

	switch (cmd) {
	case OBD_IOC_NO_TRANSNO: {
	if (!obd->obd_attached) {
	CERROR("Device %d not attached\n", obd->obd_minor);
	err = -ENODEV;
	goto out;
	}
	CDEBUG(D_HA, "%s: disabling committed-transno notification\n",
	obd->obd_name);
	obd->obd_no_transno = 1;
	err = 0;
	goto out;
	}

	default: {
	err = obd_iocontrol(cmd, obd->obd_self_export, len, data, NULL);
	if (err)
	goto out;

	err = obd_ioctl_popdata((void *)arg, data, len);
	if (err)
	err = -EFAULT;
	goto out;
	}
	}

	out:
	if (buf)
	obd_ioctl_freedata(buf, len);
	return err;
	} /* class_handle_ioctl */

	#define OBD_INIT_CHECK
	int obd_init_checks(void)
	{
	__u64 u64val, div64val;
	char buf[64];
	int len, ret = 0;

	CDEBUG(D_INFO, "LPU64=%s, LPD64=%s, LPX64=%s\n", "%llu", "%lld", "%#llx");

	CDEBUG(D_INFO, "OBD_OBJECT_EOF = %#llx\n", (__u64)OBD_OBJECT_EOF);

	u64val = OBD_OBJECT_EOF;
	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = %#llx\n", u64val);
	if (u64val != OBD_OBJECT_EOF) {
	CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
	u64val, (int)sizeof(u64val));
	ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), "%#llx", u64val);
	if (len != 18) {
	CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
	ret = -EINVAL;
	}

	div64val = OBD_OBJECT_EOF;
	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = %#llx\n", u64val);
	if (u64val != OBD_OBJECT_EOF) {
	CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
	u64val, (int)sizeof(u64val));
	ret = -EOVERFLOW;
	}
	if (u64val >> 8 != OBD_OBJECT_EOF >> 8) {
	CERROR("__u64 %#llx(%d) != 0xffffffffffffffff\n",
	u64val, (int)sizeof(u64val));
	return -EOVERFLOW;
	}
	if (do_div(div64val, 256) != (u64val & 255)) {
	CERROR("do_div(%#llx,256) != %llu\n", u64val, u64val &255);
	return -EOVERFLOW;
	}
	if (u64val >> 8 != div64val) {
	CERROR("do_div(%#llx,256) %llu != %llu\n",
	u64val, div64val, u64val >> 8);
	return -EOVERFLOW;
	}
	len = snprintf(buf, sizeof(buf), "%#llx", u64val);
	if (len != 18) {
	CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
	ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), "%llu", u64val);
	if (len != 20) {
	CWARN("LPU64 wrong length! strlen(%s)=%d != 20\n", buf, len);
	ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), "%lld", u64val);
	if (len != 2) {
	CWARN("LPD64 wrong length! strlen(%s)=%d != 2\n", buf, len);
	ret = -EINVAL;
	}
	if ((u64val & ~CFS_PAGE_MASK) >= PAGE_CACHE_SIZE) {
	CWARN("mask failed: u64val %llu >= %llu\n", u64val,
	(__u64)PAGE_CACHE_SIZE);
	ret = -EINVAL;
	}

	return ret;
	}

	#if defined (CONFIG_PROC_FS)
	extern int class_procfs_init(void);
	extern int class_procfs_clean(void);
	#else
	static inline int class_procfs_init(void)
	{ return 0; }
	static inline int class_procfs_clean(void)
	{ return 0; }
	#endif

	static int __init init_obdclass(void)
	{
	int i, err;
	int lustre_register_fs(void);

	for (i = CAPA_SITE_CLIENT; i < CAPA_SITE_MAX; i++)
	INIT_LIST_HEAD(&capa_list[i]);

	LCONSOLE_INFO("Lustre: Build Version: "BUILD_VERSION"\n");

	spin_lock_init(&obd_types_lock);
	obd_zombie_impexp_init();

	if (IS_ENABLED(CONFIG_PROC_FS)) {
	obd_memory = lprocfs_alloc_stats(OBD_STATS_NUM,
	LPROCFS_STATS_FLAG_NONE \|
	LPROCFS_STATS_FLAG_IRQ_SAFE);

	if (obd_memory == NULL) {
	CERROR("kmalloc of 'obd_memory' failed\n");
	return -ENOMEM;
	}

	lprocfs_counter_init(obd_memory, OBD_MEMORY_STAT,
	LPROCFS_CNTR_AVGMINMAX,
	"memused", "bytes");
	lprocfs_counter_init(obd_memory, OBD_MEMORY_PAGES_STAT,
	LPROCFS_CNTR_AVGMINMAX,
	"pagesused", "pages");
	}

	err = obd_init_checks();
	if (err == -EOVERFLOW)
	return err;

	class_init_uuidlist();
	err = class_handle_init();
	if (err)
	return err;

	INIT_LIST_HEAD(&obd_types);

	err = misc_register(&obd_psdev);
	if (err) {
	CERROR("cannot register %d err %d\n", OBD_DEV_MINOR, err);
	return err;
	}

	/* This struct is already zeroed for us (static global) */
	for (i = 0; i < class_devno_max(); i++)
	obd_devs[i] = NULL;

	/* Default the dirty page cache cap to 1/2 of system memory.
	* For clients with less memory, a larger fraction is needed
	* for other purposes (mostly for BGL). */
	if (totalram_pages <= 512 << (20 - PAGE_CACHE_SHIFT))
	obd_max_dirty_pages = totalram_pages / 4;
	else
	obd_max_dirty_pages = totalram_pages / 2;

	err = obd_init_caches();
	if (err)
	return err;

	obd_sysctl_init();

	err = class_procfs_init();
	if (err)
	return err;

	err = lu_global_init();
	if (err)
	return err;

	err = cl_global_init();
	if (err != 0)
	return err;


	err = llog_info_init();
	if (err)
	return err;

	err = lustre_register_fs();

	return err;
	}

	void obd_update_maxusage(void)
	{
	__u64 max1, max2;

	max1 = obd_pages_sum();
	max2 = obd_memory_sum();

	spin_lock(&obd_updatemax_lock);
	if (max1 > obd_max_pages)
	obd_max_pages = max1;
	if (max2 > obd_max_alloc)
	obd_max_alloc = max2;
	spin_unlock(&obd_updatemax_lock);
	}
	EXPORT_SYMBOL(obd_update_maxusage);

	#if defined (CONFIG_PROC_FS)
	__u64 obd_memory_max(void)
	{
	__u64 ret;

	spin_lock(&obd_updatemax_lock);
	ret = obd_max_alloc;
	spin_unlock(&obd_updatemax_lock);

	return ret;
	}
	EXPORT_SYMBOL(obd_memory_max);

	__u64 obd_pages_max(void)
	{
	__u64 ret;

	spin_lock(&obd_updatemax_lock);
	ret = obd_max_pages;
	spin_unlock(&obd_updatemax_lock);

	return ret;
	}
	EXPORT_SYMBOL(obd_pages_max);
	#endif

	/* liblustre doesn't call cleanup_obdclass, apparently. we carry on in this
	* ifdef to the end of the file to cover module and versioning goo.*/
	static void cleanup_obdclass(void)
	{
	int i;
	int lustre_unregister_fs(void);
	__u64 memory_leaked, pages_leaked;
	__u64 memory_max, pages_max;

	lustre_unregister_fs();

	misc_deregister(&obd_psdev);
	for (i = 0; i < class_devno_max(); i++) {
	struct obd_device *obd = class_num2obd(i);
	if (obd && obd->obd_set_up &&
	OBT(obd) && OBP(obd, detach)) {
	/* XXX should this call generic detach otherwise? */
	LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
	OBP(obd, detach)(obd);
	}
	}
	llog_info_fini();
	cl_global_fini();
	lu_global_fini();

	obd_cleanup_caches();
	obd_sysctl_clean();

	class_procfs_clean();

	class_handle_cleanup();
	class_exit_uuidlist();
	obd_zombie_impexp_stop();

	memory_leaked = obd_memory_sum();
	pages_leaked = obd_pages_sum();

	memory_max = obd_memory_max();
	pages_max = obd_pages_max();

	lprocfs_free_stats(&obd_memory);
	CDEBUG((memory_leaked) ? D_ERROR : D_INFO,
	"obd_memory max: %llu, leaked: %llu\n",
	memory_max, memory_leaked);
	CDEBUG((pages_leaked) ? D_ERROR : D_INFO,
	"obd_memory_pages max: %llu, leaked: %llu\n",
	pages_max, pages_leaked);
	}

	MODULE_AUTHOR("Sun Microsystems, Inc. <http://www.lustre.org/>");
	MODULE_DESCRIPTION("Lustre Class Driver Build Version: " BUILD_VERSION);
	MODULE_LICENSE("GPL");
	MODULE_VERSION(LUSTRE_VERSION_STRING);

	module_init(init_obdclass);
	module_exit(cleanup_obdclass);