Classes
struct	srawFileList

struct	srawComm

struct	srawStatus

struct	srawRequest

struct	srawObjAttrOld

struct	srawObjAttr

struct	srawQueryResult

struct	srawPoolStatusDMData

struct	srawPoolStatusData

struct	srawPoolStatus

struct	srawWorkSpace

struct	srawDataMoverAttr

struct	srawDataMover

struct	srawFileSystem

struct	srawCopyCache

struct	srawArchiveList

Macros
#define	PORT_MASTER 1996 /* default port number master server */

#define	PORT_MOVER 1994 /* default port number data mover */

#define	PORT_MOVER_DATAFS 1998

#define	PORT_RFIO_SERV 1974 /* default port number RFIO server */

#define	ATLSERVER_ARCHIVE 1 /* API write: 1: IBM 3494, 2: SANLB2 */

#define	MAX_ATLSERVER 1 /* max no. of ATL servers */

#define	MAX_MASTER 1 /* max number of master servers */

#define	MAX_NUM_DM 10 /* max no. of data movers on platform */

#define	MBUF_SOCK 32768 /* default buffer size sockets */

#define	MBUF_ADSM 32768 /* default buffer size ADSM */

#define	MBUF_RFIO 32768 /* max currently possible in MBS */

#define	CUR_QUERY_LIMIT 0

#define	SLEEP_CACHE_FULL 600 /* wait time/iter, if write cache full */

#define	MAXLOOP_CACHE_FULL 3 /* max no of iter, if write cache full */

#define	DEF_FILESIZE 2044000000 /* assume <2GByte, if unavailable */

#define	MAX_FILE_SIZE 2147483647 /* max filesize 2GByte-1 (signed) */

#define	MAX_FILE_SIZE_U 4294967295 /* max size 4GByte-1 (unsigned) */

#define	MAX_FILE_NO 1024 /* max number of file names in list */

#define	MAX_NODE 16 /* max length node name */

#define	MIN_DATAFS_PATH 12 /* min path length in lustre */

#define	MAX_OWNER 16 /* max length object owner */

#define	MAX_OS 8 /* max length operating system name */

#define	MAX_FULL_FILE 256 /* max length full file name */

#define	MAX_FILE 128 /* max length rel. file name */

#define	MAX_TAPE_FILE 17 /* max length file name on tape */

#define	VERSION_SRAWOBJATTR 5 /* cur version of struct srawObjAttr */

#define	SIZE_CACHE_METADATA_5 424 /* cur size of cacheDB entry */

#define	SIZE_CACHE_METADATA_4 344 /* old size of cacheDB entry */

#define	MAX_OBJ_FS 32

#define	MAX_OBJ_HL 112 /* max length object high level name */

#define	MAX_OBJ_LL 52 /* max length object low level name */

#define	MAX_OBJ_HL_O 92 /* max length object high level name */

#define	MAX_OBJ_LL_O 36 /* max length object low level name */

#define	MAX_OBJ_HL_LEVEL 14

#define	MAX_MC 30

#define	MAX_MC_O 12 /* max length Management class name */

#define	MAX_DATE 20 /* max length archive date and time */

#define	MAX_APPLTYPE 28 /* max length application type */

#define	MAX_ITEM 32 /* max length of process item */

#define	HEAD_OFFSET 3 /* offset common pre-header (ints) */

#define	HEAD_LEN 12 /* length common pre-header (bytes) */

#define	STATUS_LEN 512 /* max length status/error message */

#define	WORK_LEN 20 /* length work space info */

#define	IDENT_COMM -1 /* communication control buffer */

#define	IDENT_STATUS -2 /* status buffer from/to client */

#define	IDENT_QUERY -3 /* query result buffer */

#define	IDENT_POOL -4 /* stage pool info buffer */

#define	IDENT_WORKSPACE -5 /* work space info buffer */

#define	IDENT_NEXT_BUFFER -6 /* request next data buffer */

#define	IDENT_MOVER_ATTR -7 /* data mover attributes */

#define	IDENT_STAGE_FILE -8 /* stage file data (read cache) */

#define	IDENT_SPACE_INFO -9 /* data mover space info */

#define	IDENT_PURGE_INFO -10 /* purge request for data mover */

#define	IDENT_SPACE_LOOK -11 /* meta data DB space info */

#define	IDENT_CLEAN_REQUEST -12 /* clean request for stage pool */

#define	IDENT_FILELIST_REQUEST -13 /* filelist request for stage FS */

#define	IDENT_QUERY_ARCHDB -14 /* query result buffer archDB */

#define	IDENT_FULL_ARCHDISK -15 /* buffer describing full disk */

#define	IDENT_ARCHIVE_FILE -16 /* archive file data (write cache) */

#define	IDENT_STAGE_LIST -17 /* list of read cache object data */

#define	IDENT_QUERY_FILEDB -18 /* query result buffer fileDB */

#define	IDENT_QUERY_DONE -19 /* last query result buffer */

#define	IDENT_CACHE_STATUS -20 /* request query/set cache status */

#define	IDENT_COPY_CACHE -21 /* copy DAQ stream data from cache */

#define	IDENT_ARCHIVE_LIST -22 /* list of archive names */

#define	IDENT_PROC_INFO -23 /* get/update proc no. in cacheDB */

#define	IDENT_COMM64 -24 /* communication control buffer */

Enumerations
enum	ARCH_DEVICE { ARCH_ANY, ARCH_TAPE, ARCH_TAPE_MC, MGR_TAPE, ARCH_DISK, ARCH_DAQ_DISK }

enum	RETR_DEVICE { RETR_CLIENT, RETR_STAGE_TEMP, RETR_STAGE_PERM, RETR_FILESYSTEM }

enum	FILETYPE { FIXED_INTS4, STREAM }

enum	ACTION { ARCHIVE, ARCHIVE_MGR, ARCHIVE_RECORD, ARCHIVE_OVER, CREATE_ARCHIVE, CLOSE, REMOVE, REMOVE_MGR, FILE_CHECK, OPEN, QUERY, QUERY_ARCHIVE, QUERY_ARCHIVE_MGR, QUERY_REMOVE, QUERY_REMOVE_MGR, RETRIEVE, RETRIEVE_RECORD, RETRIEVE_STAGE, STAGE, QUERY_UNSTAGE, UNSTAGE, QUERY_POOL, QUERY_WORKSPACE, QUERY_STAGE, ARCHIVE_TO_CACHE, ARCHIVE_FROM_CACHE, QUERY_RETRIEVE, QUERY_ARCHIVE_OVER, QUERY_ARCHIVE_TO_CACHE, SPM_REQUEST_MOVER, QUERY_RETRIEVE_RECORD, QUERY_ARCHIVE_FROM_CACHE, END_SESSION, QUERY_ARCHIVE_RECORD, STAGE_FROM_CACHE, RETRIEVE_FROM_CACHE, SEND_FROM_CACHE, QUERY_RETRIEVE_STAGE, COPY_RC_TO_FILESYSTEM, RETRIEVE_TO_FILESYSTEM, ARCHIVE_FROM_FILESYSTEM, COPY_WC_TO_FILESYSTEM, MIGRATE_CACHE_PATH, QUERY_FILESERVER, SEND_TO_FILESERVER, RECEIVE_FROM_DM, SHOW_ARCHIVES }

enum	STATUS { STA_BEGIN_TRANS, STA_NEXT_BUFFER, STA_END_OF_FILE, STA_END_OF_SESSION, STA_ERROR, STA_ERROR_EOF, STA_FILE_STAGED, STA_END_OF_FILE_NOT_STAGED, STA_SEEK_BUFFER, STA_ARCHIVE_AVAIL, STA_SWITCH_SERVER, STA_INFO, STA_PURGED, STA_NOT_PURGED, STA_CACHE_FULL, STA_CACHE_FILE_AWAY, STA_ARCHIVE_NOT_AVAIL, STA_NO_ACCESS, STA_SWITCH_ENTRY, STA_ENTRY_INFO, STA_FILE_CACHED, STA_CACHE_COPY, STA_CACHE_COPY_ERROR }

Variables
static const char	cTooBig [8] = "(>=4GB)"

static char	cNodeMaster0 [MAX_NODE] = "lxgstore"

static char	cNodeMasterE1 [MAX_NODE] = "lxha05"

static char	cNodeMasterE2 [MAX_NODE] = "lxha04"

static char	cDataFSType [16] = "lustre"

static char	cDataFSHigh1 [16] = "/lustre_alpha/"

static char	cDataFSHigh2 [16] = "/lustre/"

static char	cAdminUser [MAX_OWNER] = "goeri"

static char	cForceMigPath [32] = "/ArchiveNow"

static char *	pcOS

Macro Definition Documentation

#define ATLSERVER_ARCHIVE 1 /* API write: 1: IBM 3494, 2: SANLB2 */

Definition at line 201 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define CUR_QUERY_LIMIT 0

Definition at line 209 of file rawcommn.h.

#define DEF_FILESIZE 2044000000 /* assume <2GByte, if unavailable */

Definition at line 217 of file rawcommn.h.

#define HEAD_LEN 12 /* length common pre-header (bytes) */

Definition at line 283 of file rawcommn.h.

Referenced by rawDelFile(), rawGetWSInfo(), rawQueryFile(), rawRecvHead(), rawRecvHeadC(), rawRecvRequest(), rawRecvStatus(), rawSendRequest(), rawSendStatus(), rfio_close(), rfio_endfile(), rfio_newfile(), rfio_open_gsidaq(), and rfio_read().

#define HEAD_OFFSET 3 /* offset common pre-header (ints) */

Definition at line 282 of file rawcommn.h.

#define IDENT_ARCHIVE_FILE -16 /* archive file data (write cache) */

Definition at line 304 of file rawcommn.h.

#define IDENT_ARCHIVE_LIST -22 /* list of archive names */

Definition at line 310 of file rawcommn.h.

#define IDENT_CACHE_STATUS -20 /* request query/set cache status */

Definition at line 308 of file rawcommn.h.

#define IDENT_CLEAN_REQUEST -12 /* clean request for stage pool */

Definition at line 300 of file rawcommn.h.

#define IDENT_COMM -1 /* communication control buffer */

Definition at line 289 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define IDENT_COMM64 -24 /* communication control buffer */

Definition at line 312 of file rawcommn.h.

#define IDENT_COPY_CACHE -21 /* copy DAQ stream data from cache */

Definition at line 309 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define IDENT_FILELIST_REQUEST -13 /* filelist request for stage FS */

Definition at line 301 of file rawcommn.h.

#define IDENT_FULL_ARCHDISK -15 /* buffer describing full disk */

Definition at line 303 of file rawcommn.h.

#define IDENT_MOVER_ATTR -7 /* data mover attributes */

Definition at line 295 of file rawcommn.h.

#define IDENT_NEXT_BUFFER -6 /* request next data buffer */

Definition at line 294 of file rawcommn.h.

Referenced by rawRecvRequest(), and rawSendRequest().

#define IDENT_POOL -4 /* stage pool info buffer */

Definition at line 292 of file rawcommn.h.

Referenced by rawGetWSInfo().

#define IDENT_PROC_INFO -23 /* get/update proc no. in cacheDB */

Definition at line 311 of file rawcommn.h.

#define IDENT_PURGE_INFO -10 /* purge request for data mover */

Definition at line 298 of file rawcommn.h.

#define IDENT_QUERY -3 /* query result buffer */

Definition at line 291 of file rawcommn.h.

Referenced by rawQueryFile().

#define IDENT_QUERY_ARCHDB -14 /* query result buffer archDB */

Definition at line 302 of file rawcommn.h.

Referenced by rawQueryFile().

#define IDENT_QUERY_DONE -19 /* last query result buffer */

Definition at line 307 of file rawcommn.h.

Referenced by rawQueryFile().

#define IDENT_QUERY_FILEDB -18 /* query result buffer fileDB */

Definition at line 306 of file rawcommn.h.

#define IDENT_SPACE_INFO -9 /* data mover space info */

Definition at line 297 of file rawcommn.h.

#define IDENT_SPACE_LOOK -11 /* meta data DB space info */

Definition at line 299 of file rawcommn.h.

#define IDENT_STAGE_FILE -8 /* stage file data (read cache) */

Definition at line 296 of file rawcommn.h.

#define IDENT_STAGE_LIST -17 /* list of read cache object data */

Definition at line 305 of file rawcommn.h.

#define IDENT_STATUS -2 /* status buffer from/to client */

Definition at line 290 of file rawcommn.h.

Referenced by rawGetWSInfo(), rawQueryFile(), rawRecvHead(), rawRecvHeadC(), rawRecvRequest(), rawRecvStatus(), rawSendStatus(), and rfio_read().

#define IDENT_WORKSPACE -5 /* work space info buffer */

Definition at line 293 of file rawcommn.h.

Referenced by rawGetWSInfo().

#define MAX_APPLTYPE 28 /* max length application type */

Definition at line 279 of file rawcommn.h.

#define MAX_ATLSERVER 1 /* max no. of ATL servers */

Definition at line 202 of file rawcommn.h.

Referenced by rawQueryPrint(), rawQueryString(), and rfio_open_gsidaq().

#define MAX_DATE 20 /* max length archive date and time */

Definition at line 278 of file rawcommn.h.

#define MAX_FILE 128 /* max length rel. file name */

Definition at line 256 of file rawcommn.h.

#define MAX_FILE_NO 1024 /* max number of file names in list */

Definition at line 220 of file rawcommn.h.

Referenced by rawCheckObjlist(), rawGetDirEntryList(), rawGetFileList(), and rawSortValues().

#define MAX_FILE_SIZE 2147483647 /* max filesize 2GByte-1 (signed) */

Definition at line 218 of file rawcommn.h.

Referenced by rawGetFileAttr().

#define MAX_FILE_SIZE_U 4294967295 /* max size 4GByte-1 (unsigned) */

Definition at line 219 of file rawcommn.h.

#define MAX_FULL_FILE 256 /* max length full file name */

Definition at line 255 of file rawcommn.h.

Referenced by rawCheckClientFile(), rawGetDirEntryList(), rawGetFileList(), rawGetFilelistEntries(), rawGetFSfree(), rawGetFullFile(), rawGetWSInfo(), rfio_cache_stat(), rfio_open_gsidaq(), and rfio_stat().

#define MAX_ITEM 32 /* max length of process item */

Definition at line 280 of file rawcommn.h.

#define MAX_MASTER 1 /* max number of master servers */

Definition at line 203 of file rawcommn.h.

#define MAX_MC 30

Definition at line 272 of file rawcommn.h.

#define MAX_MC_O 12 /* max length Management class name */

Definition at line 276 of file rawcommn.h.

#define MAX_NODE 16 /* max length node name */

Definition at line 225 of file rawcommn.h.

Referenced by rawGetHostConn(), rfio_newfile(), and rfio_open_gsidaq().

#define MAX_NUM_DM 10 /* max no. of data movers on platform */

Definition at line 204 of file rawcommn.h.

#define MAX_OBJ_FS 32

Definition at line 263 of file rawcommn.h.

Referenced by rfio_newfile(), and rfio_open_gsidaq().

#define MAX_OBJ_HL 112 /* max length object high level name */

Definition at line 265 of file rawcommn.h.

Referenced by rawGetHLName(), rawQueryPrint(), rawQueryString(), rfio_newfile(), and rfio_open_gsidaq().

#define MAX_OBJ_HL_LEVEL 14

Definition at line 269 of file rawcommn.h.

#define MAX_OBJ_HL_O 92 /* max length object high level name */

Definition at line 267 of file rawcommn.h.

#define MAX_OBJ_LL 52 /* max length object low level name */

Definition at line 266 of file rawcommn.h.

Referenced by rawCheckClientFile(), rawCheckFilelist(), rawGetLLName(), rfio_newfile(), and rfio_open_gsidaq().

#define MAX_OBJ_LL_O 36 /* max length object low level name */

Definition at line 268 of file rawcommn.h.

#define MAX_OS 8 /* max length operating system name */

Definition at line 240 of file rawcommn.h.

#define MAX_OWNER 16 /* max length object owner */

Definition at line 235 of file rawcommn.h.

#define MAX_TAPE_FILE 17 /* max length file name on tape */

Definition at line 257 of file rawcommn.h.

Referenced by rawCheckClientFile().

#define MAXLOOP_CACHE_FULL 3 /* max no of iter, if write cache full */

Definition at line 215 of file rawcommn.h.

#define MBUF_ADSM 32768 /* default buffer size ADSM */

Definition at line 207 of file rawcommn.h.

#define MBUF_RFIO 32768 /* max currently possible in MBS */

Definition at line 208 of file rawcommn.h.

#define MBUF_SOCK 32768 /* default buffer size sockets */

Definition at line 206 of file rawcommn.h.

#define MIN_DATAFS_PATH 12 /* min path length in lustre */

Definition at line 230 of file rawcommn.h.

#define PORT_MASTER 1996 /* default port number master server */

Definition at line 195 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define PORT_MOVER 1994 /* default port number data mover */

Definition at line 196 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define PORT_MOVER_DATAFS 1998

Definition at line 197 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define PORT_RFIO_SERV 1974 /* default port number RFIO server */

Definition at line 199 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

#define SIZE_CACHE_METADATA_4 344 /* old size of cacheDB entry */

Definition at line 261 of file rawcommn.h.

#define SIZE_CACHE_METADATA_5 424 /* cur size of cacheDB entry */

Definition at line 260 of file rawcommn.h.

#define SLEEP_CACHE_FULL 600 /* wait time/iter, if write cache full */

Definition at line 214 of file rawcommn.h.

#define STATUS_LEN 512 /* max length status/error message */

Definition at line 284 of file rawcommn.h.

Referenced by rawAddStrings(), rawCheckObjlist(), rawDelFile(), rawGetFilelistEntries(), rawGetWSInfo(), rawRecvHeadC(), rawRecvRequest(), rfio_newfile(), and rfio_open_gsidaq().

#define VERSION_SRAWOBJATTR 5 /* cur version of struct srawObjAttr */

Definition at line 259 of file rawcommn.h.

Referenced by rawQueryFile(), rawQueryPrint(), and rawQueryString().

#define WORK_LEN 20 /* length work space info */

Definition at line 285 of file rawcommn.h.

Enumeration Type Documentation

enum ACTION

Enumerator
ARCHIVE
ARCHIVE_MGR
ARCHIVE_RECORD
ARCHIVE_OVER
CREATE_ARCHIVE
CLOSE
REMOVE
REMOVE_MGR
FILE_CHECK
OPEN
QUERY
QUERY_ARCHIVE
QUERY_ARCHIVE_MGR
QUERY_REMOVE
QUERY_REMOVE_MGR
RETRIEVE
RETRIEVE_RECORD
RETRIEVE_STAGE
STAGE
QUERY_UNSTAGE
UNSTAGE
QUERY_POOL
QUERY_WORKSPACE
QUERY_STAGE
ARCHIVE_TO_CACHE
ARCHIVE_FROM_CACHE
QUERY_RETRIEVE
QUERY_ARCHIVE_OVER
QUERY_ARCHIVE_TO_CACHE
SPM_REQUEST_MOVER
QUERY_RETRIEVE_RECORD
QUERY_ARCHIVE_FROM_CACHE
END_SESSION
QUERY_ARCHIVE_RECORD
STAGE_FROM_CACHE
RETRIEVE_FROM_CACHE
SEND_FROM_CACHE
QUERY_RETRIEVE_STAGE
COPY_RC_TO_FILESYSTEM
RETRIEVE_TO_FILESYSTEM
ARCHIVE_FROM_FILESYSTEM
COPY_WC_TO_FILESYSTEM
MIGRATE_CACHE_PATH
QUERY_FILESERVER
SEND_TO_FILESERVER
RECEIVE_FROM_DM
SHOW_ARCHIVES

Definition at line 338 of file rawcommn.h.

enum ARCH_DEVICE

Enumerator
ARCH_ANY
ARCH_TAPE
ARCH_TAPE_MC
MGR_TAPE
ARCH_DISK
ARCH_DAQ_DISK

Definition at line 314 of file rawcommn.h.

enum FILETYPE

Enumerator
FIXED_INTS4
STREAM

Definition at line 332 of file rawcommn.h.

enum RETR_DEVICE

Enumerator
RETR_CLIENT
RETR_STAGE_TEMP
RETR_STAGE_PERM
RETR_FILESYSTEM

Definition at line 324 of file rawcommn.h.

enum STATUS

Enumerator
STA_BEGIN_TRANS
STA_NEXT_BUFFER
STA_END_OF_FILE
STA_END_OF_SESSION
STA_ERROR
STA_ERROR_EOF
STA_FILE_STAGED
STA_END_OF_FILE_NOT_STAGED
STA_SEEK_BUFFER
STA_ARCHIVE_AVAIL
STA_SWITCH_SERVER
STA_INFO
STA_PURGED
STA_NOT_PURGED
STA_CACHE_FULL
STA_CACHE_FILE_AWAY
STA_ARCHIVE_NOT_AVAIL
STA_NO_ACCESS
STA_SWITCH_ENTRY
STA_ENTRY_INFO
STA_FILE_CACHED
STA_CACHE_COPY
STA_CACHE_COPY_ERROR

Definition at line 439 of file rawcommn.h.

Variable Documentation

char cAdminUser[MAX_OWNER] = "goeri"

static

Definition at line 236 of file rawcommn.h.

char cDataFSHigh1[16] = "/lustre_alpha/"

static

Definition at line 232 of file rawcommn.h.

Referenced by rawGetFilelistEntries(), and rfio_open_gsidaq().

char cDataFSHigh2[16] = "/lustre/"

static

Definition at line 233 of file rawcommn.h.

Referenced by rawGetFilelistEntries(), and rfio_open_gsidaq().

char cDataFSType[16] = "lustre"

static

Definition at line 231 of file rawcommn.h.

char cForceMigPath[32] = "/ArchiveNow"

static

Definition at line 237 of file rawcommn.h.

char cNodeMaster0[MAX_NODE] = "lxgstore"

static

Definition at line 226 of file rawcommn.h.

Referenced by rfio_open_gsidaq().

char cNodeMasterE1[MAX_NODE] = "lxha05"

static

Definition at line 227 of file rawcommn.h.

char cNodeMasterE2[MAX_NODE] = "lxha04"

static

Definition at line 228 of file rawcommn.h.

const char cTooBig[8] = "(>=4GB)"

static

Definition at line 222 of file rawcommn.h.

Referenced by rawQueryPrint(), and rawQueryString().

char* pcOS

static

Definition at line 241 of file rawcommn.h.

Classes

Macros

Enumerations

Variables

Macro Definition Documentation

Enumeration Type Documentation

Variable Documentation