iscsi_target_tq.h

Go to the documentation of this file.

#ifndef ISCSI_THREAD_QUEUE_H
#define ISCSI_THREAD_QUEUE_H

/*
 * Defines for thread sets.
 */
extern int iscsi_thread_set_force_reinstatement(struct iscsi_conn *);
extern int iscsi_allocate_thread_sets(u32);
extern void iscsi_deallocate_thread_sets(void);
extern void iscsi_activate_thread_set(struct iscsi_conn *, struct iscsi_thread_set *);
extern struct iscsi_thread_set *iscsi_get_thread_set(void);
extern void iscsi_set_thread_clear(struct iscsi_conn *, u8);
extern void iscsi_set_thread_set_signal(struct iscsi_conn *, u8);
extern int iscsi_release_thread_set(struct iscsi_conn *);
extern struct iscsi_conn *iscsi_rx_thread_pre_handler(struct iscsi_thread_set *);
extern struct iscsi_conn *iscsi_tx_thread_pre_handler(struct iscsi_thread_set *);
extern int iscsi_thread_set_init(void);
extern void iscsi_thread_set_free(void);

extern int iscsi_target_tx_thread(void *);
extern int iscsi_target_rx_thread(void *);

#define TARGET_THREAD_SET_COUNT         4

#define ISCSI_RX_THREAD                         1
#define ISCSI_TX_THREAD                         2
#define ISCSI_RX_THREAD_NAME            "iscsi_trx"
#define ISCSI_TX_THREAD_NAME            "iscsi_ttx"
#define ISCSI_BLOCK_RX_THREAD           0x1
#define ISCSI_BLOCK_TX_THREAD           0x2
#define ISCSI_CLEAR_RX_THREAD           0x1
#define ISCSI_CLEAR_TX_THREAD           0x2
#define ISCSI_SIGNAL_RX_THREAD          0x1
#define ISCSI_SIGNAL_TX_THREAD          0x2

/* struct iscsi_thread_set->status */
#define ISCSI_THREAD_SET_FREE           1
#define ISCSI_THREAD_SET_ACTIVE         2
#define ISCSI_THREAD_SET_DIE            3
#define ISCSI_THREAD_SET_RESET          4
#define ISCSI_THREAD_SET_DEALLOCATE_THREADS 5

/* By default allow a maximum of 32K iSCSI connections */
#define ISCSI_TS_BITMAP_BITS            32768

struct iscsi_thread_set {
    /* flags used for blocking and restarting sets */
    int blocked_threads;
    /* flag for creating threads */
    int create_threads;
    /* flag for delaying readding to inactive list */
    int delay_inactive;
    /* status for thread set */
    int status;
    /* which threads have had signals sent */
    int signal_sent;
    /* flag for which threads exited first */
    int thread_clear;
    /* Active threads in the thread set */
    int thread_count;
    /* Unique thread ID */
    u32 thread_id;
    /* pointer to connection if set is active */
    struct iscsi_conn   *conn;
    /* used for controlling ts state accesses */
    spinlock_t  ts_state_lock;
    /* Used for rx side post startup */
    struct completion   rx_post_start_comp;
    /* Used for tx side post startup */
    struct completion   tx_post_start_comp;
    /* used for restarting thread queue */
    struct completion   rx_restart_comp;
    /* used for restarting thread queue */
    struct completion   tx_restart_comp;
    /* used for normal unused blocking */
    struct completion   rx_start_comp;
    /* used for normal unused blocking */
    struct completion   tx_start_comp;
    /* OS descriptor for rx thread */
    struct task_struct  *rx_thread;
    /* OS descriptor for tx thread */
    struct task_struct  *tx_thread;
    /* struct iscsi_thread_set in list list head*/
    struct list_head    ts_list;
};

#endif   /*** ISCSI_THREAD_QUEUE_H ***/