/* * Copyright (C) 2002-2003 Ardis Technolgies <roman@ardistech.com> * * Released under the terms of the GNU GPL v2.0. */#include "iscsi.h"#include "digest.h"#include "iscsi_dbg.h"#define	MAX_NR_TARGETS	(1UL << 30)static LIST_HEAD(target_list);static DECLARE_MUTEX(target_list_sem);static u32 next_target_id;static u32 nr_targets;static struct iscsi_sess_param default_session_param = {	.initial_r2t = 1,	.immediate_data = 1,	.max_connections = 1,	.max_recv_data_length = 8192,	.max_xmit_data_length = 8192,	.max_burst_length = 262144,	.first_burst_length = 65536,	.default_wait_time = 2,	.default_retain_time = 20,	.max_outstanding_r2t = 1,	.data_pdu_inorder = 1,	.data_sequence_inorder = 1,	.error_recovery_level = 0,	.header_digest = DIGEST_NONE,	.data_digest = DIGEST_NONE,	.ofmarker = 0,	.ifmarker = 0,	.ofmarkint = 2048,	.ifmarkint = 2048,};static struct iscsi_trgt_param default_target_param = {	.wthreads = DEFAULT_NR_WTHREADS,	.target_type = 0,	.queued_cmnds = DEFAULT_NR_QUEUED_CMNDS,};inline int target_lock(struct iscsi_target *target, int interruptible){	int err = 0;	if (interruptible)		err = down_interruptible(&target->target_sem);	else		down(&target->target_sem);	return err;}inline void target_unlock(struct iscsi_target *target){	up(&target->target_sem);}static struct iscsi_target *__target_lookup_by_id(u32 id){	struct iscsi_target *target;	list_for_each_entry(target, &target_list, t_list) {		if (target->tid == id)			return target;	}	return NULL;}static struct iscsi_target *__target_lookup_by_name(char *name){	struct iscsi_target *target;	list_for_each_entry(target, &target_list, t_list) {		if (!strcmp(target->name, name))			return target;	}	return NULL;}struct iscsi_target *target_lookup_by_id(u32 id){	struct iscsi_target *target;	down(&target_list_sem);	target = __target_lookup_by_id(id);	up(&target_list_sem);	return target;}static int target_thread_start(struct iscsi_target *target){	int err;	if ((err = nthread_start(target)) < 0)		return err;	if ((err = wthread_start(target)) < 0) {		nthread_stop(target);	}	return err;}static void target_thread_stop(struct iscsi_target *target){	wthread_stop(target);	nthread_stop(target);}static int iscsi_target_create(struct target_info *info, u32 tid){	int err = -EINVAL, len;	char *name = info->name;	struct iscsi_target *target;	dprintk(D_SETUP, "%u %s\n", tid, name);	if (!(len = strlen(name))) {		eprintk("The length of the target name is zero %u\n", tid);		return err;	}	if (!try_module_get(THIS_MODULE)) {		eprintk("Fail to get module %u\n", tid);		return err;	}	target = kzalloc(sizeof(*target), GFP_KERNEL);	if (!target) {		err = -ENOMEM;		goto out;	}	target->tid = info->tid = tid;	memcpy(&target->sess_param, &default_session_param, sizeof(default_session_param));	memcpy(&target->trgt_param, &default_target_param, sizeof(default_target_param));	strncpy(target->name, name, sizeof(target->name) - 1);	init_MUTEX(&target->target_sem);	INIT_LIST_HEAD(&target->session_list);	INIT_LIST_HEAD(&target->volumes);	atomic_set(&target->nr_volumes, 0);	list_add(&target->t_list, &target_list);	nthread_init(target);	wthread_init(target);	if ((err = target_thread_start(target)) < 0) {		target_thread_stop(target);		goto out;	}	return 0;out:	kfree(target);	module_put(THIS_MODULE);	return err;}int target_add(struct target_info *info){	int err = -EEXIST;	u32 tid = info->tid;	down(&target_list_sem);	if (nr_targets > MAX_NR_TARGETS) {		err = -EBUSY;		goto out;	}	if (__target_lookup_by_name(info->name))		goto out;	if (tid && __target_lookup_by_id(tid))		goto out;	if (!tid) {		do {			if (!++next_target_id)				++next_target_id;		} while (__target_lookup_by_id(next_target_id));		tid = next_target_id;	}	if (!(err = iscsi_target_create(info, tid)))		nr_targets++;out:	up(&target_list_sem);	return err;}static void target_destroy(struct iscsi_target *target){	dprintk(D_SETUP, "%u\n", target->tid);	target_thread_stop(target);	while (!list_empty(&target->volumes)) {		struct iet_volume *volume;		volume = list_entry(target->volumes.next, struct iet_volume, list);		volume->l_state = IDEV_DEL;		iscsi_volume_destroy(volume);	}	kfree(target);	module_put(THIS_MODULE);}int target_del(u32 id){	struct iscsi_target *target;	int err;	if ((err = down_interruptible(&target_list_sem)) < 0)		return err;	if (!(target = __target_lookup_by_id(id))) {		err = -ENOENT;		goto out;	}	target_lock(target, 0);	if (!list_empty(&target->session_list)) {		err = -EBUSY;		target_unlock(target);		goto out;	}	list_del(&target->t_list);	nr_targets--;	target_unlock(target);	up(&target_list_sem);	target_destroy(target);	return 0;out:	up(&target_list_sem);	return err;}int iet_info_show(struct seq_file *seq, iet_show_info_t *func){	int err;	struct iscsi_target *target;	if ((err = down_interruptible(&target_list_sem)) < 0)		return err;	list_for_each_entry(target, &target_list, t_list) {		seq_printf(seq, "tid:%u name:%s\n", target->tid, target->name);		if ((err = target_lock(target, 1)) < 0)			break;		func(seq, target);		target_unlock(target);	}	up(&target_list_sem);	return 0;}