[deliverable/linux.git] / drivers / staging / lustre / lustre / obdclass / class_obd.c

/*
 * 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 <asm/atomic.h>

#include <obd_support.h>
#include <obd_class.h>
#include <linux/lnet/lnetctl.h>
#include <lustre_debug.h>
#include <lprocfs_status.h>
#include <lustre/lustre_build_version.h>
#include <linux/list.h>
#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;
__u64 obd_max_alloc = 0;
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);

/* Get jobid of current process by reading the environment variable
 * stored in between the "env_start" & "env_end" of task struct.
 *
 * TODO:
 * It's better to cache the jobid for later use if there is any
 * efficient way, the cl_env code probably could be reused for this
 * purpose.
 *
 * If some job scheduler doesn't store jobid in the "env_start/end",
 * then an upcall could be issued here to get the jobid by utilizing
 * the userspace tools/api. Then, the jobid must be cached.
 */
int lustre_get_jobid(char *jobid)
{
	int jobid_len = JOBSTATS_JOBID_SIZE;
	int rc = 0;

	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;
	}

	rc = cfs_get_environ(obd_jobid_var, jobid, &jobid_len);
	if (rc) {
		if (rc == -EOVERFLOW) {
			/* For the PBS_JOBID and LOADL_STEP_ID keys (which are
			 * variable length strings instead of just numbers), it
			 * might make sense to keep the unique parts for JobID,
			 * instead of just returning an error.  That means a
			 * larger temp buffer for cfs_get_environ(), then
			 * truncating the string at some separator to fit into
			 * the specified jobid_len.  Fix later if needed. */
			static bool printed;
			if (unlikely(!printed)) {
				LCONSOLE_ERROR_MSG(0x16b, "%s value too large "
						   "for JobID buffer (%d)\n",
						   obd_jobid_var, jobid_len);
				printed = true;
			}
		} else {
			CDEBUG((rc == -ENOENT || rc == -EINVAL ||
				rc == -EDEADLK) ? D_INFO : D_ERROR,
			       "Get jobid for (%s) failed: rc = %d\n",
			       obd_jobid_var, rc);
		}
	}
	return rc;
}
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 ("LPU64" bytes) failed at %s:%d\n",
		       ptr ? "force " :"", type, name, (__u64)size, file,
		       line);
		CERROR(LPU64" total bytes and "LPU64" total pages "
		       "("LPU64" 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");
		GOTO(out, rc = -EINVAL);
	}
	if (name[len - 1] != 0) {
		CERROR("Name not nul terminated!\n");
		GOTO(out, rc = -EINVAL);
	}

	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);
		GOTO(out, rc = -EINVAL);
	}

	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");
			GOTO(out, err = -EINVAL);
		}
		OBD_ALLOC(lcfg, data->ioc_plen1);
		if (lcfg == NULL)
			GOTO(out, err = -ENOMEM);
		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, err);
	}

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

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

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

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

	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)
			GOTO(out, err = -EINVAL);

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

	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");
			GOTO(out, err = -EINVAL);
		}
		if (data->ioc_inlbuf1[data->ioc_inllen1 - 1] != 0) {
			CERROR("UUID not NUL terminated!\n");
			GOTO(out, err = -EINVAL);
		}

		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);
			GOTO(out, err = -EINVAL);
		}

		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, err);
	}

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

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

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

		obd = class_num2obd(index);
		if (!obd)
			GOTO(out, err = -ENOENT);

		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);

		GOTO(out, err = 0);
	}

	}

	if (data->ioc_dev == OBD_DEV_BY_DEVNAME) {
		if (data->ioc_inllen4 <= 0 || data->ioc_inlbuf4 == NULL)
			GOTO(out, err = -EINVAL);
		if (strnlen(data->ioc_inlbuf4, MAX_OBD_NAME) >= MAX_OBD_NAME)
			GOTO(out, err = -EINVAL);
		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");
		GOTO(out, err = -EINVAL);
	}

	if (obd == NULL) {
		CERROR("OBD ioctl : No Device %d\n", data->ioc_dev);
		GOTO(out, err = -EINVAL);
	}
	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);
		GOTO(out, err = -EINVAL);
	}

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

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

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

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

extern struct miscdevice obd_psdev;

#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", LPU64, LPD64, LPX64);

	CDEBUG(D_INFO, "OBD_OBJECT_EOF = "LPX64"\n", (__u64)OBD_OBJECT_EOF);

	u64val = OBD_OBJECT_EOF;
	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = "LPX64"\n", u64val);
	if (u64val != OBD_OBJECT_EOF) {
		CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
		       u64val, (int)sizeof(u64val));
		ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), LPX64, 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 = "LPX64"\n", u64val);
	if (u64val != OBD_OBJECT_EOF) {
		CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
		       u64val, (int)sizeof(u64val));
		ret = -EOVERFLOW;
	}
	if (u64val >> 8 != OBD_OBJECT_EOF >> 8) {
		CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
		       u64val, (int)sizeof(u64val));
		return -EOVERFLOW;
	}
	if (do_div(div64val, 256) != (u64val & 255)) {
		CERROR("do_div("LPX64",256) != "LPU64"\n", u64val, u64val &255);
		return -EOVERFLOW;
	}
	if (u64val >> 8 != div64val) {
		CERROR("do_div("LPX64",256) "LPU64" != "LPU64"\n",
		       u64val, div64val, u64val >> 8);
		return -EOVERFLOW;
	}
	len = snprintf(buf, sizeof(buf), LPX64, u64val);
	if (len != 18) {
		CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
		ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), LPU64, u64val);
	if (len != 20) {
		CWARN("LPU64 wrong length! strlen(%s)=%d != 20\n", buf, len);
		ret = -EINVAL;
	}
	len = snprintf(buf, sizeof(buf), LPD64, 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 "LPU64" >= "LPU64"\n", u64val,
		      (__u64)PAGE_CACHE_SIZE);
		ret = -EINVAL;
	}

	return ret;
}

extern spinlock_t obd_types_lock;
extern int class_procfs_init(void);
extern int class_procfs_clean(void);

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();
#ifdef LPROCFS
	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");
#endif
	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;
	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);

#ifdef LPROCFS
__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: "LPU64", leaked: "LPU64"\n",
	       memory_max, memory_leaked);
	CDEBUG((pages_leaked) ? D_ERROR : D_INFO,
	       "obd_memory_pages max: "LPU64", leaked: "LPU64"\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");

cfs_module(obdclass, LUSTRE_VERSION_STRING, init_obdclass, cleanup_obdclass);
Commit	Line	Data
d7e09d03 PT	1	/*
	2	* GPL HEADER START
	3	*
	4	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
	5	*
	6	* This program is free software; you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License version 2 only,
	8	* as published by the Free Software Foundation.
	9	*
	10	* This program is distributed in the hope that it will be useful, but
	11	* WITHOUT ANY WARRANTY; without even the implied warranty of
	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	13	* General Public License version 2 for more details (a copy is included
	14	* in the LICENSE file that accompanied this code).
	15	*
	16	* You should have received a copy of the GNU General Public License
	17	* version 2 along with this program; If not, see
	18	* http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
	19	*
	20	* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
	21	* CA 95054 USA or visit www.sun.com if you need additional information or
	22	* have any questions.
	23	*
	24	* GPL HEADER END
	25	*/
	26	/*
	27	* Copyright (c) 1999, 2010, Oracle and/or its affiliates. All rights reserved.
	28	* Use is subject to license terms.
	29	*
	30	* Copyright (c) 2011, 2012, Intel Corporation.
	31	*/
	32	/*
	33	* This file is part of Lustre, http://www.lustre.org/
	34	* Lustre is a trademark of Sun Microsystems, Inc.
	35	*/
	36
	37	#define DEBUG_SUBSYSTEM S_CLASS
	38	# include <asm/atomic.h>
	39
	40	#include <obd_support.h>
	41	#include <obd_class.h>
	42	#include <linux/lnet/lnetctl.h>
	43	#include <lustre_debug.h>
	44	#include <lprocfs_status.h>
	45	#include <lustre/lustre_build_version.h>
	46	#include <linux/list.h>
	47	#include <cl_object.h>
	48	#include "llog_internal.h"
	49
	50
	51	struct obd_device *obd_devs[MAX_OBD_DEVICES];
	52	EXPORT_SYMBOL(obd_devs);
	53	struct list_head obd_types;
	54	DEFINE_RWLOCK(obd_dev_lock);
	55
	56	__u64 obd_max_pages = 0;
	57	__u64 obd_max_alloc = 0;
	58	DEFINE_SPINLOCK(obd_updatemax_lock);
	59
	60	/* The following are visible and mutable through /proc/sys/lustre/. */
	61	unsigned int obd_alloc_fail_rate = 0;
	62	EXPORT_SYMBOL(obd_alloc_fail_rate);
	63	unsigned int obd_debug_peer_on_timeout;
	64	EXPORT_SYMBOL(obd_debug_peer_on_timeout);
65	unsigned int obd_dump_on_timeout;
66	EXPORT_SYMBOL(obd_dump_on_timeout);
67	unsigned int obd_dump_on_eviction;
68	EXPORT_SYMBOL(obd_dump_on_eviction);
69	unsigned int obd_max_dirty_pages = 256;
70	EXPORT_SYMBOL(obd_max_dirty_pages);
d7e09d03 PT	71	atomic_t obd_dirty_pages;
	72	EXPORT_SYMBOL(obd_dirty_pages);
	73	unsigned int obd_timeout = OBD_TIMEOUT_DEFAULT; /* seconds */
	74	EXPORT_SYMBOL(obd_timeout);
	75	unsigned int ldlm_timeout = LDLM_TIMEOUT_DEFAULT; /* seconds */
	76	EXPORT_SYMBOL(ldlm_timeout);
	77	unsigned int obd_timeout_set;
	78	EXPORT_SYMBOL(obd_timeout_set);
	79	unsigned int ldlm_timeout_set;
	80	EXPORT_SYMBOL(ldlm_timeout_set);
	81	/* Adaptive timeout defs here instead of ptlrpc module for /proc/sys/ access */
	82	unsigned int at_min = 0;
	83	EXPORT_SYMBOL(at_min);
	84	unsigned int at_max = 600;
	85	EXPORT_SYMBOL(at_max);
	86	unsigned int at_history = 600;
	87	EXPORT_SYMBOL(at_history);
	88	int at_early_margin = 5;
	89	EXPORT_SYMBOL(at_early_margin);
	90	int at_extra = 30;
	91	EXPORT_SYMBOL(at_extra);
	92
	93	atomic_t obd_dirty_transit_pages;
	94	EXPORT_SYMBOL(obd_dirty_transit_pages);
	95
	96	char obd_jobid_var[JOBSTATS_JOBID_VAR_MAX_LEN + 1] = JOBSTATS_DISABLE;
	97	EXPORT_SYMBOL(obd_jobid_var);
	98
	99	/* Get jobid of current process by reading the environment variable
	100	* stored in between the "env_start" & "env_end" of task struct.
	101	*
	102	* TODO:
	103	* It's better to cache the jobid for later use if there is any
	104	* efficient way, the cl_env code probably could be reused for this
	105	* purpose.
	106	*
	107	* If some job scheduler doesn't store jobid in the "env_start/end",
	108	* then an upcall could be issued here to get the jobid by utilizing
	109	* the userspace tools/api. Then, the jobid must be cached.
	110	*/
	111	int lustre_get_jobid(char *jobid)
	112	{
	113	int jobid_len = JOBSTATS_JOBID_SIZE;
	114	int rc = 0;
d7e09d03 PT	115
	116	memset(jobid, 0, JOBSTATS_JOBID_SIZE);
	117	/* Jobstats isn't enabled */
	118	if (strcmp(obd_jobid_var, JOBSTATS_DISABLE) == 0)
0a3bdb00	119	return 0;
d7e09d03 PT	120
	121	/* Use process name + fsuid as jobid */
	122	if (strcmp(obd_jobid_var, JOBSTATS_PROCNAME_UID) == 0) {
	123	snprintf(jobid, JOBSTATS_JOBID_SIZE, "%s.%u",
4b1a25f0 PT	124	current_comm(),
4b1a25f0 PT	125	from_kuid(&init_user_ns, current_fsuid()));
0a3bdb00	126	return 0;
d7e09d03 PT	127	}
	128
	129	rc = cfs_get_environ(obd_jobid_var, jobid, &jobid_len);
	130	if (rc) {
	131	if (rc == -EOVERFLOW) {
	132	/* For the PBS_JOBID and LOADL_STEP_ID keys (which are
	133	* variable length strings instead of just numbers), it
	134	* might make sense to keep the unique parts for JobID,
	135	* instead of just returning an error. That means a
	136	* larger temp buffer for cfs_get_environ(), then
	137	* truncating the string at some separator to fit into
	138	* the specified jobid_len. Fix later if needed. */
	139	static bool printed;
	140	if (unlikely(!printed)) {
	141	LCONSOLE_ERROR_MSG(0x16b, "%s value too large "
	142	"for JobID buffer (%d)\n",
	143	obd_jobid_var, jobid_len);
	144	printed = true;
	145	}
	146	} else {
	147	CDEBUG((rc == -ENOENT \|\| rc == -EINVAL \|\|
	148	rc == -EDEADLK) ? D_INFO : D_ERROR,
	149	"Get jobid for (%s) failed: rc = %d\n",
	150	obd_jobid_var, rc);
	151	}
	152	}
0a3bdb00	153	return rc;
d7e09d03 PT	154	}
	155	EXPORT_SYMBOL(lustre_get_jobid);
	156
	157	int obd_alloc_fail(const void ptr, const char name, const char *type,
	158	size_t size, const char *file, int line)
	159	{
	160	if (ptr == NULL \|\|
	161	(cfs_rand() & OBD_ALLOC_FAIL_MASK) < obd_alloc_fail_rate) {
	162	CERROR("%s%salloc of %s ("LPU64" bytes) failed at %s:%d\n",
	163	ptr ? "force " :"", type, name, (__u64)size, file,
	164	line);
	165	CERROR(LPU64" total bytes and "LPU64" total pages "
	166	"("LPU64" bytes) allocated by Lustre, "
	167	"%d total bytes by LNET\n",
	168	obd_memory_sum(),
	169	obd_pages_sum() << PAGE_CACHE_SHIFT,
	170	obd_pages_sum(),
	171	atomic_read(&libcfs_kmemory));
	172	return 1;
	173	}
	174	return 0;
	175	}
	176	EXPORT_SYMBOL(obd_alloc_fail);
	177
	178	static inline void obd_data2conn(struct lustre_handle *conn,
	179	struct obd_ioctl_data *data)
	180	{
	181	memset(conn, 0, sizeof *conn);
	182	conn->cookie = data->ioc_cookie;
	183	}
	184
	185	static inline void obd_conn2data(struct obd_ioctl_data *data,
	186	struct lustre_handle *conn)
	187	{
	188	data->ioc_cookie = conn->cookie;
	189	}
	190
	191	int class_resolve_dev_name(__u32 len, const char *name)
	192	{
	193	int rc;
	194	int dev;
	195
d7e09d03 PT	196	if (!len \|\| !name) {
	197	CERROR("No name passed,!\n");
	198	GOTO(out, rc = -EINVAL);
	199	}
	200	if (name[len - 1] != 0) {
	201	CERROR("Name not nul terminated!\n");
	202	GOTO(out, rc = -EINVAL);
	203	}
	204
	205	CDEBUG(D_IOCTL, "device name %s\n", name);
	206	dev = class_name2dev(name);
	207	if (dev == -1) {
	208	CDEBUG(D_IOCTL, "No device for name %s!\n", name);
	209	GOTO(out, rc = -EINVAL);
	210	}
	211
	212	CDEBUG(D_IOCTL, "device name %s, dev %d\n", name, dev);
	213	rc = dev;
	214
	215	out:
0a3bdb00	216	return rc;
d7e09d03 PT	217	}
	218
	219	int class_handle_ioctl(unsigned int cmd, unsigned long arg)
	220	{
	221	char *buf = NULL;
	222	struct obd_ioctl_data *data;
	223	struct libcfs_debug_ioctl_data *debug_data;
	224	struct obd_device *obd = NULL;
	225	int err = 0, len = 0;
d7e09d03 PT	226
	227	/* only for debugging */
	228	if (cmd == LIBCFS_IOC_DEBUG_MASK) {
	229	debug_data = (struct libcfs_debug_ioctl_data*)arg;
	230	libcfs_subsystem_debug = debug_data->subs;
	231	libcfs_debug = debug_data->debug;
	232	return 0;
	233	}
	234
	235	CDEBUG(D_IOCTL, "cmd = %x\n", cmd);
	236	if (obd_ioctl_getdata(&buf, &len, (void *)arg)) {
	237	CERROR("OBD ioctl: data error\n");
0a3bdb00	238	return -EINVAL;
d7e09d03 PT	239	}
	240	data = (struct obd_ioctl_data *)buf;
	241
	242	switch (cmd) {
	243	case OBD_IOC_PROCESS_CFG: {
	244	struct lustre_cfg *lcfg;
	245
	246	if (!data->ioc_plen1 \|\| !data->ioc_pbuf1) {
	247	CERROR("No config buffer passed!\n");
	248	GOTO(out, err = -EINVAL);
	249	}
	250	OBD_ALLOC(lcfg, data->ioc_plen1);
	251	if (lcfg == NULL)
	252	GOTO(out, err = -ENOMEM);
	253	err = copy_from_user(lcfg, data->ioc_pbuf1,
	254	data->ioc_plen1);
	255	if (!err)
	256	err = lustre_cfg_sanity_check(lcfg, data->ioc_plen1);
	257	if (!err)
	258	err = class_process_config(lcfg);
	259
	260	OBD_FREE(lcfg, data->ioc_plen1);
	261	GOTO(out, err);
	262	}
	263
	264	case OBD_GET_VERSION:
	265	if (!data->ioc_inlbuf1) {
	266	CERROR("No buffer passed in ioctl\n");
	267	GOTO(out, err = -EINVAL);
	268	}
	269
	270	if (strlen(BUILD_VERSION) + 1 > data->ioc_inllen1) {
	271	CERROR("ioctl buffer too small to hold version\n");
	272	GOTO(out, err = -EINVAL);
	273	}
	274
	275	memcpy(data->ioc_bulk, BUILD_VERSION,
	276	strlen(BUILD_VERSION) + 1);
	277
	278	err = obd_ioctl_popdata((void *)arg, data, len);
	279	if (err)
	280	err = -EFAULT;
	281	GOTO(out, err);
	282
	283	case OBD_IOC_NAME2DEV: {
	284	/* Resolve a device name. This does not change the
	285	* currently selected device.
	286	*/
	287	int dev;
	288
	289	dev = class_resolve_dev_name(data->ioc_inllen1,
	290	data->ioc_inlbuf1);
	291	data->ioc_dev = dev;
	292	if (dev < 0)
	293	GOTO(out, err = -EINVAL);
	294
	295	err = obd_ioctl_popdata((void )arg, data, sizeof(data));
	296	if (err)
	297	err = -EFAULT;
	298	GOTO(out, err);
	299	}
	300
	301	case OBD_IOC_UUID2DEV: {
	302	/* Resolve a device uuid. This does not change the
303	* currently selected device.
304	*/
305	int dev;
306	struct obd_uuid uuid;
307
308	if (!data->ioc_inllen1 \|\| !data->ioc_inlbuf1) {
309	CERROR("No UUID passed!\n");
310	GOTO(out, err = -EINVAL);
311	}
312	if (data->ioc_inlbuf1[data->ioc_inllen1 - 1] != 0) {
313	CERROR("UUID not NUL terminated!\n");
314	GOTO(out, err = -EINVAL);
315	}
316
317	CDEBUG(D_IOCTL, "device name %s\n", data->ioc_inlbuf1);
318	obd_str2uuid(&uuid, data->ioc_inlbuf1);
319	dev = class_uuid2dev(&uuid);
320	data->ioc_dev = dev;
321	if (dev == -1) {
322	CDEBUG(D_IOCTL, "No device for UUID %s!\n",
323	data->ioc_inlbuf1);
324	GOTO(out, err = -EINVAL);
325	}
326
327	CDEBUG(D_IOCTL, "device name %s, dev %d\n", data->ioc_inlbuf1,
328	dev);
329	err = obd_ioctl_popdata((void )arg, data, sizeof(data));
330	if (err)
331	err = -EFAULT;
332	GOTO(out, err);
333	}
334
335	case OBD_IOC_CLOSE_UUID: {
336	CDEBUG(D_IOCTL, "closing all connections to uuid %s (NOOP)\n",
337	data->ioc_inlbuf1);
338	GOTO(out, err = 0);
339	}
340
341	case OBD_IOC_GETDEVICE: {
342	int index = data->ioc_count;
343	char status, str;
344
345	if (!data->ioc_inlbuf1) {
346	CERROR("No buffer passed in ioctl\n");
347	GOTO(out, err = -EINVAL);
348	}
349	if (data->ioc_inllen1 < 128) {
350	CERROR("ioctl buffer too small to hold version\n");
351	GOTO(out, err = -EINVAL);
352	}
353
354	obd = class_num2obd(index);
355	if (!obd)
356	GOTO(out, err = -ENOENT);
357
358	if (obd->obd_stopping)
359	status = "ST";
360	else if (obd->obd_set_up)
361	status = "UP";
362	else if (obd->obd_attached)
363	status = "AT";
364	else
365	status = "--";
366	str = (char *)data->ioc_bulk;
367	snprintf(str, len - sizeof(*data), "%3d %s %s %s %s %d",
368	(int)index, status, obd->obd_type->typ_name,
369	obd->obd_name, obd->obd_uuid.uuid,
370	atomic_read(&obd->obd_refcount));
371	err = obd_ioctl_popdata((void *)arg, data, len);
372
373	GOTO(out, err = 0);
374	}
375
376	}
377
378	if (data->ioc_dev == OBD_DEV_BY_DEVNAME) {
379	if (data->ioc_inllen4 <= 0 \|\| data->ioc_inlbuf4 == NULL)
380	GOTO(out, err = -EINVAL);
381	if (strnlen(data->ioc_inlbuf4, MAX_OBD_NAME) >= MAX_OBD_NAME)
382	GOTO(out, err = -EINVAL);
383	obd = class_name2obd(data->ioc_inlbuf4);
384	} else if (data->ioc_dev < class_devno_max()) {
385	obd = class_num2obd(data->ioc_dev);
386	} else {
387	CERROR("OBD ioctl: No device\n");
388	GOTO(out, err = -EINVAL);
389	}
390
391	if (obd == NULL) {
392	CERROR("OBD ioctl : No Device %d\n", data->ioc_dev);
393	GOTO(out, err = -EINVAL);
394	}
395	LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
396
397	if (!obd->obd_set_up \|\| obd->obd_stopping) {
398	CERROR("OBD ioctl: device not setup %d \n", data->ioc_dev);
399	GOTO(out, err = -EINVAL);
400	}
401
402	switch(cmd) {
403	case OBD_IOC_NO_TRANSNO: {
404	if (!obd->obd_attached) {
405	CERROR("Device %d not attached\n", obd->obd_minor);
406	GOTO(out, err = -ENODEV);
407	}
408	CDEBUG(D_HA, "%s: disabling committed-transno notification\n",
409	obd->obd_name);
410	obd->obd_no_transno = 1;
411	GOTO(out, err = 0);
412	}
413
414	default: {
415	err = obd_iocontrol(cmd, obd->obd_self_export, len, data, NULL);
416	if (err)
417	GOTO(out, err);
418
419	err = obd_ioctl_popdata((void *)arg, data, len);
420	if (err)
421	err = -EFAULT;
422	GOTO(out, err);
423	}
424	}
425
426	out:
427	if (buf)
428	obd_ioctl_freedata(buf, len);
0a3bdb00	429	return err;
d7e09d03 PT	430	} /* class_handle_ioctl */
d7e09d03 PT	431
c0426cf7	432	extern struct miscdevice obd_psdev;
d7e09d03 PT	433
	434	#define OBD_INIT_CHECK
	435	int obd_init_checks(void)
	436	{
	437	__u64 u64val, div64val;
	438	char buf[64];
	439	int len, ret = 0;
	440
	441	CDEBUG(D_INFO, "LPU64=%s, LPD64=%s, LPX64=%s\n", LPU64, LPD64, LPX64);
	442
	443	CDEBUG(D_INFO, "OBD_OBJECT_EOF = "LPX64"\n", (__u64)OBD_OBJECT_EOF);
	444
	445	u64val = OBD_OBJECT_EOF;
	446	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = "LPX64"\n", u64val);
	447	if (u64val != OBD_OBJECT_EOF) {
	448	CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
	449	u64val, (int)sizeof(u64val));
	450	ret = -EINVAL;
	451	}
	452	len = snprintf(buf, sizeof(buf), LPX64, u64val);
	453	if (len != 18) {
	454	CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
	455	ret = -EINVAL;
	456	}
	457
	458	div64val = OBD_OBJECT_EOF;
	459	CDEBUG(D_INFO, "u64val OBD_OBJECT_EOF = "LPX64"\n", u64val);
	460	if (u64val != OBD_OBJECT_EOF) {
	461	CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
	462	u64val, (int)sizeof(u64val));
	463	ret = -EOVERFLOW;
	464	}
	465	if (u64val >> 8 != OBD_OBJECT_EOF >> 8) {
	466	CERROR("__u64 "LPX64"(%d) != 0xffffffffffffffff\n",
	467	u64val, (int)sizeof(u64val));
	468	return -EOVERFLOW;
	469	}
	470	if (do_div(div64val, 256) != (u64val & 255)) {
	471	CERROR("do_div("LPX64",256) != "LPU64"\n", u64val, u64val &255);
	472	return -EOVERFLOW;
	473	}
	474	if (u64val >> 8 != div64val) {
	475	CERROR("do_div("LPX64",256) "LPU64" != "LPU64"\n",
	476	u64val, div64val, u64val >> 8);
	477	return -EOVERFLOW;
	478	}
	479	len = snprintf(buf, sizeof(buf), LPX64, u64val);
	480	if (len != 18) {
	481	CWARN("LPX64 wrong length! strlen(%s)=%d != 18\n", buf, len);
	482	ret = -EINVAL;
	483	}
	484	len = snprintf(buf, sizeof(buf), LPU64, u64val);
	485	if (len != 20) {
	486	CWARN("LPU64 wrong length! strlen(%s)=%d != 20\n", buf, len);
	487	ret = -EINVAL;
	488	}
	489	len = snprintf(buf, sizeof(buf), LPD64, u64val);
	490	if (len != 2) {
	491	CWARN("LPD64 wrong length! strlen(%s)=%d != 2\n", buf, len);
	492	ret = -EINVAL;
	493	}
	494	if ((u64val & ~CFS_PAGE_MASK) >= PAGE_CACHE_SIZE) {
	495	CWARN("mask failed: u64val "LPU64" >= "LPU64"\n", u64val,
	496	(__u64)PAGE_CACHE_SIZE);
497	ret = -EINVAL;
498	}
499
500	return ret;
501	}
502
503	extern spinlock_t obd_types_lock;
504	extern int class_procfs_init(void);
505	extern int class_procfs_clean(void);
506
507	static int __init init_obdclass(void)
508	{
509	int i, err;
510	int lustre_register_fs(void);
511
512	for (i = CAPA_SITE_CLIENT; i < CAPA_SITE_MAX; i++)
513	INIT_LIST_HEAD(&capa_list[i]);
514
515	LCONSOLE_INFO("Lustre: Build Version: "BUILD_VERSION"\n");
516
517	spin_lock_init(&obd_types_lock);
518	obd_zombie_impexp_init();
519	#ifdef LPROCFS
520	obd_memory = lprocfs_alloc_stats(OBD_STATS_NUM,
521	LPROCFS_STATS_FLAG_NONE \|
522	LPROCFS_STATS_FLAG_IRQ_SAFE);
523	if (obd_memory == NULL) {
524	CERROR("kmalloc of 'obd_memory' failed\n");
0a3bdb00	525	return -ENOMEM;
d7e09d03 PT	526	}
	527
	528	lprocfs_counter_init(obd_memory, OBD_MEMORY_STAT,
	529	LPROCFS_CNTR_AVGMINMAX,
	530	"memused", "bytes");
	531	lprocfs_counter_init(obd_memory, OBD_MEMORY_PAGES_STAT,
	532	LPROCFS_CNTR_AVGMINMAX,
	533	"pagesused", "pages");
	534	#endif
	535	err = obd_init_checks();
	536	if (err == -EOVERFLOW)
	537	return err;
	538
	539	class_init_uuidlist();
	540	err = class_handle_init();
	541	if (err)
	542	return err;
	543
	544	INIT_LIST_HEAD(&obd_types);
	545
	546	err = misc_register(&obd_psdev);
	547	if (err) {
	548	CERROR("cannot register %d err %d\n", OBD_DEV_MINOR, err);
	549	return err;
	550	}
	551
	552	/* This struct is already zeroed for us (static global) */
	553	for (i = 0; i < class_devno_max(); i++)
	554	obd_devs[i] = NULL;
	555
	556	/* Default the dirty page cache cap to 1/2 of system memory.
	557	* For clients with less memory, a larger fraction is needed
	558	* for other purposes (mostly for BGL). */
4f6cc9ab PT	559	if (totalram_pages <= 512 << (20 - PAGE_CACHE_SHIFT))
4f6cc9ab PT	560	obd_max_dirty_pages = totalram_pages / 4;
d7e09d03	561	else
4f6cc9ab	562	obd_max_dirty_pages = totalram_pages / 2;
d7e09d03 PT	563
	564	err = obd_init_caches();
	565	if (err)
	566	return err;
	567	err = class_procfs_init();
	568	if (err)
	569	return err;
	570
	571	err = lu_global_init();
	572	if (err)
	573	return err;
	574
	575	err = cl_global_init();
	576	if (err != 0)
	577	return err;
	578
	579
	580	err = llog_info_init();
	581	if (err)
	582	return err;
	583
	584	err = lustre_register_fs();
	585
	586	return err;
	587	}
	588
	589	void obd_update_maxusage(void)
	590	{
	591	__u64 max1, max2;
	592
	593	max1 = obd_pages_sum();
	594	max2 = obd_memory_sum();
	595
	596	spin_lock(&obd_updatemax_lock);
	597	if (max1 > obd_max_pages)
	598	obd_max_pages = max1;
	599	if (max2 > obd_max_alloc)
	600	obd_max_alloc = max2;
	601	spin_unlock(&obd_updatemax_lock);
	602	}
	603	EXPORT_SYMBOL(obd_update_maxusage);
	604
	605	#ifdef LPROCFS
	606	__u64 obd_memory_max(void)
	607	{
	608	__u64 ret;
	609
	610	spin_lock(&obd_updatemax_lock);
	611	ret = obd_max_alloc;
	612	spin_unlock(&obd_updatemax_lock);
	613
	614	return ret;
	615	}
	616	EXPORT_SYMBOL(obd_memory_max);
	617
	618	__u64 obd_pages_max(void)
	619	{
	620	__u64 ret;
	621
	622	spin_lock(&obd_updatemax_lock);
	623	ret = obd_max_pages;
	624	spin_unlock(&obd_updatemax_lock);
	625
	626	return ret;
627	}
628	EXPORT_SYMBOL(obd_pages_max);
629	#endif
630
631	/* liblustre doesn't call cleanup_obdclass, apparently. we carry on in this
632	* ifdef to the end of the file to cover module and versioning goo.*/
633	static void cleanup_obdclass(void)
634	{
635	int i;
636	int lustre_unregister_fs(void);
637	__u64 memory_leaked, pages_leaked;
638	__u64 memory_max, pages_max;
d7e09d03 PT	639
	640	lustre_unregister_fs();
	641
	642	misc_deregister(&obd_psdev);
	643	for (i = 0; i < class_devno_max(); i++) {
	644	struct obd_device *obd = class_num2obd(i);
	645	if (obd && obd->obd_set_up &&
	646	OBT(obd) && OBP(obd, detach)) {
	647	/* XXX should this call generic detach otherwise? */
	648	LASSERT(obd->obd_magic == OBD_DEVICE_MAGIC);
	649	OBP(obd, detach)(obd);
	650	}
	651	}
	652	llog_info_fini();
	653	cl_global_fini();
	654	lu_global_fini();
	655
	656	obd_cleanup_caches();
	657	obd_sysctl_clean();
	658
	659	class_procfs_clean();
	660
	661	class_handle_cleanup();
	662	class_exit_uuidlist();
	663	obd_zombie_impexp_stop();
	664
	665	memory_leaked = obd_memory_sum();
	666	pages_leaked = obd_pages_sum();
	667
	668	memory_max = obd_memory_max();
	669	pages_max = obd_pages_max();
	670
	671	lprocfs_free_stats(&obd_memory);
	672	CDEBUG((memory_leaked) ? D_ERROR : D_INFO,
	673	"obd_memory max: "LPU64", leaked: "LPU64"\n",
	674	memory_max, memory_leaked);
	675	CDEBUG((pages_leaked) ? D_ERROR : D_INFO,
	676	"obd_memory_pages max: "LPU64", leaked: "LPU64"\n",
	677	pages_max, pages_leaked);
d7e09d03 PT	678	}
	679
	680	MODULE_AUTHOR("Sun Microsystems, Inc. <http://www.lustre.org/>");
	681	MODULE_DESCRIPTION("Lustre Class Driver Build Version: " BUILD_VERSION);
	682	MODULE_LICENSE("GPL");
	683
	684	cfs_module(obdclass, LUSTRE_VERSION_STRING, init_obdclass, cleanup_obdclass);