Annotation of embedaddon/istgt/src/istgt.h, revision 1.1
1.1 ! misho 1: /*
! 2: * Copyright (C) 2008-2011 Daisuke Aoyama <aoyama@peach.ne.jp>.
! 3: * All rights reserved.
! 4: *
! 5: * Redistribution and use in source and binary forms, with or without
! 6: * modification, are permitted provided that the following conditions
! 7: * are met:
! 8: * 1. Redistributions of source code must retain the above copyright
! 9: * notice, this list of conditions and the following disclaimer.
! 10: * 2. Redistributions in binary form must reproduce the above copyright
! 11: * notice, this list of conditions and the following disclaimer in the
! 12: * documentation and/or other materials provided with the distribution.
! 13: *
! 14: * THIS SOFTWARE IS PROVIDED BY AUTHOR AND CONTRIBUTORS ``AS IS'' AND
! 15: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
! 16: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
! 17: * ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
! 18: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
! 19: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
! 20: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
! 21: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
! 22: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
! 23: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
! 24: * SUCH DAMAGE.
! 25: *
! 26: */
! 27:
! 28: #ifndef ISTGT_H
! 29: #define ISTGT_H
! 30:
! 31: #ifdef HAVE_CONFIG_H
! 32: #include "config.h"
! 33: #endif
! 34:
! 35: #ifdef USE_ATOMIC
! 36: #ifdef HAVE_SYS_TYPES_H
! 37: #include <sys/types.h>
! 38: #endif
! 39: #ifdef HAVE_MACHINE_ATOMIC_H
! 40: #include <machine/atomic.h>
! 41: #endif
! 42: #ifdef HAVE_SYS_ATOMIC_H
! 43: #include <sys/atomic.h>
! 44: #endif
! 45: #endif /* USE_ATOMIC */
! 46:
! 47: #include "build.h"
! 48:
! 49: #include <pthread.h>
! 50: #include <signal.h>
! 51: #include "istgt_log.h"
! 52: #include "istgt_conf.h"
! 53:
! 54: #define MAX_TMPBUF 1024
! 55: #define MAX_ADDRBUF 64
! 56: #define MAX_INITIATOR_ADDR (MAX_ADDRBUF)
! 57: #define MAX_INITIATOR_NAME 256
! 58: #define MAX_TARGET_ADDR (MAX_ADDRBUF)
! 59: #define MAX_TARGET_NAME 256
! 60: #define MAX_ISCSI_NAME 256
! 61:
! 62: #define MAX_UCPORTAL 16
! 63: #define MAX_PORTAL 1024
! 64: #define MAX_INITIATOR 256
! 65: #define MAX_NETMASK 256
! 66: #define MAX_INITIATOR_GROUP 4096
! 67: #define MAX_LOGICAL_UNIT 4096
! 68: #define MAX_R2T 256
! 69:
! 70: #define DEFAULT_CONFIG BUILD_ETC_ISTGT "/istgt.conf"
! 71: #define DEFAULT_PIDFILE "/var/run/istgt.pid"
! 72: #define DEFAULT_AUTHFILE BUILD_ETC_ISTGT "/auth.conf"
! 73: #if 0
! 74: #define DEFAULT_MEDIAFILE BUILD_ETC_ISTGT "/media.conf"
! 75: #define DEFAULT_LIVEFILE BUILD_ETC_ISTGT "/istgt.live"
! 76: #endif
! 77: #define DEFAULT_MEDIADIRECTORY BUILD_VAR_ISTGT
! 78: #define DEFAULT_NODEBASE "iqn.2007-09.jp.ne.peach.istgt"
! 79: #define DEFAULT_PORT 3260
! 80: #define DEFAULT_MAX_SESSIONS 16
! 81: #define DEFAULT_MAX_CONNECTIONS 4
! 82: #define DEFAULT_MAXOUTSTANDINGR2T 16
! 83: #define DEFAULT_DEFAULTTIME2WAIT 2
! 84: #define DEFAULT_DEFAULTTIME2RETAIN 20
! 85: #define DEFAULT_FIRSTBURSTLENGTH 65536
! 86: #define DEFAULT_MAXBURSTLENGTH 262144
! 87: #define DEFAULT_MAXRECVDATASEGMENTLENGTH 8192
! 88: #define DEFAULT_INITIALR2T 1
! 89: #define DEFAULT_IMMEDIATEDATA 1
! 90: #define DEFAULT_DATAPDUINORDER 1
! 91: #define DEFAULT_DATASEQUENCEINORDER 1
! 92: #define DEFAULT_ERRORRECOVERYLEVEL 0
! 93: #define DEFAULT_TIMEOUT 30
! 94: #define DEFAULT_NOPININTERVAL 20
! 95: #define DEFAULT_MAXR2T 16
! 96:
! 97: #define ISTGT_PG_TAG_MAX 0x0000ffffU
! 98: #define ISTGT_LU_TAG_MAX 0x0000ffffU
! 99: #define ISTGT_UC_TAG 0x00010000U
! 100: #define ISTGT_IOBUFSIZE (2 * 1024 * 1024)
! 101: #define ISTGT_SNSBUFSIZE 4096
! 102: #define ISTGT_SHORTDATASIZE 8192
! 103: #define ISTGT_SHORTPDUSIZE (48+4+ISTGT_SHORTDATASIZE+4)
! 104: #define ISTGT_CONDWAIT (50 * 1000) /* ms */
! 105: #define ISTGT_CONDWAIT_MIN (5 * 1000) /* ms */
! 106: #define ISTGT_STACKSIZE (2 * 1024 * 1024)
! 107:
! 108: #if defined (SIGRTMIN)
! 109: #define ISTGT_SIGWAKEUP (SIGRTMIN + 1)
! 110: #define ISTGT_USE_SIGRT
! 111: #elif defined (SIGIO)
! 112: #define ISTGT_SIGWAKEUP (SIGIO)
! 113: #else
! 114: #error "no signal for internal"
! 115: #endif
! 116: #if defined (__FreeBSD__) || defined (__NetBSD__) || defined (__OpenBSD__)
! 117: #define ISTGT_USE_KQUEUE
! 118: #endif
! 119:
! 120: #define MTX_LOCK(MTX) \
! 121: do { \
! 122: if (pthread_mutex_lock((MTX)) != 0) { \
! 123: ISTGT_ERRLOG("lock error\n"); \
! 124: pthread_exit(NULL); \
! 125: } \
! 126: } while (0)
! 127: #define MTX_UNLOCK(MTX) \
! 128: do { \
! 129: if (pthread_mutex_unlock((MTX)) != 0) { \
! 130: ISTGT_ERRLOG("unlock error\n"); \
! 131: pthread_exit(NULL); \
! 132: } \
! 133: } while (0)
! 134: #define SPIN_LOCK(SPIN) \
! 135: do { \
! 136: if (pthread_spin_lock((SPIN)) != 0) { \
! 137: ISTGT_ERRLOG("lock error\n"); \
! 138: pthread_exit(NULL); \
! 139: } \
! 140: } while (0)
! 141: #define SPIN_UNLOCK(SPIN) \
! 142: do { \
! 143: if (pthread_spin_unlock((SPIN)) != 0) { \
! 144: ISTGT_ERRLOG("unlock error\n"); \
! 145: pthread_exit(NULL); \
! 146: } \
! 147: } while (0)
! 148:
! 149: typedef struct istgt_portal_t {
! 150: char *label;
! 151: char *host;
! 152: char *port;
! 153: int idx;
! 154: int tag;
! 155: int sock;
! 156: } PORTAL;
! 157: typedef PORTAL *PORTAL_Ptr;
! 158:
! 159: typedef struct istgt_initiator_group_t {
! 160: int ninitiators;
! 161: char **initiators;
! 162: int nnetmasks;
! 163: char **netmasks;
! 164: int idx;
! 165: int tag;
! 166: } INITIATOR_GROUP;
! 167: typedef INITIATOR_GROUP *INITIATOR_GROUP_Ptr;
! 168:
! 169: typedef enum {
! 170: ISTGT_STATE_INVALID = 0,
! 171: ISTGT_STATE_INITIALIZED = 1,
! 172: ISTGT_STATE_RUNNING = 2,
! 173: ISTGT_STATE_EXITING = 3,
! 174: ISTGT_STATE_SHUTDOWN = 4,
! 175: } ISTGT_STATE;
! 176:
! 177: #define DEFAULT_ISTGT_SWMODE ISTGT_SWMODE_NORMAL
! 178: typedef enum {
! 179: ISTGT_SWMODE_TRADITIONAL = 0,
! 180: ISTGT_SWMODE_NORMAL = 1,
! 181: ISTGT_SWMODE_EXPERIMENTAL = 2,
! 182: } ISTGT_SWMODE;
! 183:
! 184: typedef struct istgt_t {
! 185: CONFIG *config;
! 186: char *pidfile;
! 187: char *authfile;
! 188: #if 0
! 189: char *mediafile;
! 190: char *livefile;
! 191: #endif
! 192: char *mediadirectory;
! 193: char *nodebase;
! 194:
! 195: pthread_attr_t attr;
! 196: pthread_mutex_t mutex;
! 197:
! 198: ISTGT_STATE state;
! 199: ISTGT_SWMODE swmode;
! 200:
! 201: int nuctl_portal;
! 202: PORTAL uctl_portal[MAX_UCPORTAL];
! 203: int nuctl_netmasks;
! 204: char **uctl_netmasks;
! 205:
! 206: int nportal;
! 207: PORTAL portal[MAX_PORTAL];
! 208: int ninitiator_group;
! 209: INITIATOR_GROUP initiator_group[MAX_INITIATOR_GROUP];
! 210: int nlogical_unit;
! 211: struct istgt_lu_t *logical_unit[MAX_LOGICAL_UNIT];
! 212:
! 213: int timeout;
! 214: int nopininterval;
! 215: int maxr2t;
! 216: int no_discovery_auth;
! 217: int req_discovery_auth;
! 218: int req_discovery_auth_mutual;
! 219: int discovery_auth_group;
! 220: int no_uctl_auth;
! 221: int req_uctl_auth;
! 222: int req_uctl_auth_mutual;
! 223: int uctl_auth_group;
! 224:
! 225: int MaxSessions;
! 226: int MaxConnections;
! 227: int MaxOutstandingR2T;
! 228: int DefaultTime2Wait;
! 229: int DefaultTime2Retain;
! 230: int FirstBurstLength;
! 231: int MaxBurstLength;
! 232: int MaxRecvDataSegmentLength;
! 233: int InitialR2T;
! 234: int ImmediateData;
! 235: int DataPDUInOrder;
! 236: int DataSequenceInOrder;
! 237: int ErrorRecoveryLevel;
! 238: } ISTGT;
! 239: typedef ISTGT *ISTGT_Ptr;
! 240:
! 241: char *istgt_get_nmval(CF_SECTION *sp, const char *key, int idx1, int idx2);
! 242: char *istgt_get_nval(CF_SECTION *sp, const char *key, int idx);
! 243: char *istgt_get_val(CF_SECTION *sp, const char *key);
! 244: int istgt_get_nintval(CF_SECTION *sp, const char *key, int idx);
! 245: int istgt_get_intval(CF_SECTION *sp, const char *key);
! 246:
! 247: #ifdef USE_ATOMIC
! 248: static inline int
! 249: istgt_get_state(ISTGT_Ptr istgt)
! 250: {
! 251: ISTGT_STATE state;
! 252: #if defined HAVE_ATOMIC_LOAD_ACQ_INT
! 253: state = atomic_load_acq_int((unsigned int *)&istgt->state);
! 254: #elif defined HAVE_ATOMIC_OR_UINT_NV
! 255: state = (int)atomic_or_uint_nv((unsigned int *)&istgt->state, 0);
! 256: #else
! 257: #error "no atomic operation"
! 258: #endif
! 259: return state;
! 260: }
! 261: static inline void
! 262: istgt_set_state(ISTGT_Ptr istgt, ISTGT_STATE state)
! 263: {
! 264: #if defined HAVE_ATOMIC_STORE_REL_INT
! 265: atomic_store_rel_int((unsigned int *)&istgt->state, state);
! 266: #elif defined HAVE_ATOMIC_SWAP_UINT
! 267: (void)atomic_swap_uint((unsigned int *)&istgt->state, state);
! 268: #if defined HAVE_MEMBAR_PRODUCER
! 269: membar_producer();
! 270: #endif
! 271: #else
! 272: #error "no atomic operation"
! 273: #endif
! 274: }
! 275: #else
! 276: static inline int
! 277: istgt_get_state(ISTGT_Ptr istgt)
! 278: {
! 279: ISTGT_STATE state;
! 280: MTX_LOCK(&istgt->mutex);
! 281: state = istgt->state;
! 282: MTX_UNLOCK(&istgt->mutex);
! 283: return state;
! 284: }
! 285:
! 286: static inline void
! 287: istgt_set_state(ISTGT_Ptr istgt, ISTGT_STATE state)
! 288: {
! 289: MTX_LOCK(&istgt->mutex);
! 290: istgt->state = state;
! 291: MTX_UNLOCK(&istgt->mutex);
! 292: }
! 293: #endif /* USE_ATOMIC */
! 294:
! 295: #endif /* ISTGT_H */
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to istgt.h CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / istgt / src