DABC (Data Acquisition Backbone Core)
2.9.9
|
Go to the source code of this file.
Data Structures | |
struct | srawArchiveList |
struct | srawComm |
struct | srawCopyCache |
struct | srawDataMover |
struct | srawDataMoverAttr |
struct | srawFileList |
struct | srawFileSystem |
struct | srawGlobalNotice |
struct | srawGlobalSocket |
struct | srawGlobalSocketData |
struct | srawObjAttr |
struct | srawObjAttrOld |
struct | srawObjNameList |
struct | srawPoolStatus |
struct | srawPoolStatusData |
struct | srawPoolStatusDMData |
struct | srawQueryResult |
struct | srawRequest |
struct | srawStatus |
struct | srawWorkSpace |
Macros | |
#define | ATLSERVER_ARCHIVE 1 /* API write: 1: IBM 3494, 2: SANLB2 */ |
#define | CUR_QUERY_LIMIT 0 |
#define | DEF_FILESIZE 2044000000 /* assume <2GByte, if unavailable */ |
#define | HEAD_LEN 12 /* length common pre-header (bytes) */ |
#define | HEAD_OFFSET 3 /* offset common pre-header (ints) */ |
#define | IDENT_ARCHIVE_FILE -16 /* archive file data (write cache) */ |
#define | IDENT_ARCHIVE_LIST -22 /* list of archive names */ |
#define | IDENT_CACHE_STATUS -20 /* request query/set cache status */ |
#define | IDENT_CACHEFS_ACTION -26 /* action request for cache FS */ |
#define | IDENT_CLEAN_REQUEST -12 /* clean request for stage pool */ |
#define | IDENT_COMM -1 /* communication control buffer */ |
#define | IDENT_COPY_CACHE -21 /* copy DAQ stream data from cache */ |
#define | IDENT_FILELIST_REQUEST -13 /* filelist request for stage FS */ |
#define | IDENT_FILESIZE_REQUEST -31 /* request object filesize on DM */ |
#define | IDENT_FULL_ARCHDISK -15 /* buffer describing full disk */ |
#define | IDENT_GLOBAL_SOCKET -25 /* global socket data for CacheMgr */ |
#define | IDENT_MIGR_LIMIT -28 /* info/action for migr limit WC pool */ |
#define | IDENT_MOVER_ATTR -7 /* data mover attributes */ |
#define | IDENT_NEXT_BUFFER -6 /* request next data buffer */ |
#define | IDENT_POOL -4 /* stage pool info buffer */ |
#define | IDENT_PROC_INFO -23 /* get/update proc no. in cacheDB */ |
#define | IDENT_PURGE_INFO -10 /* purge request for data mover */ |
#define | IDENT_QUERY -3 /* query result buffer */ |
#define | IDENT_QUERY_ARCHDB -14 /* query result buffer archDB */ |
#define | IDENT_QUERY_DONE -19 /* last query result buffer */ |
#define | IDENT_QUERY_FILEDB -18 /* query result buffer fileDB */ |
#define | IDENT_RETRIEVE_PARALLEL -30 /* DMs and filelists par retr */ |
#define | IDENT_SPACE_INFO -9 /* data mover space info */ |
#define | IDENT_SPACE_LOOK -11 /* meta data DB space info */ |
#define | IDENT_SPACE_TREE1 -32 /* metadataDB space info + 1 fill tree */ |
#define | IDENT_SPACE_TREE2 -33 /* metadataDB space info + 2 fill trees*/ |
#define | IDENT_STAGE_FILE -8 /* stage file data (read cache) */ |
#define | IDENT_STAGE_LIST -17 /* list of read cache object data */ |
#define | IDENT_STAGE_PARALLEL -24 /* DMs and filelists for par stage */ |
#define | IDENT_STAGE_SEQUENTIAL -27 /* DMs + filelists for sequ stage */ |
#define | IDENT_STATUS -2 /* status buffer from/to client */ |
#define | IDENT_TAPE_STATUS_DM -29 /* pool DM tape connect status */ |
#define | IDENT_WORKSPACE -5 /* work space info buffer */ |
#define | MAX_APPLTYPE 28 /* max length application type */ |
#define | MAX_ATLSERVER 1 /* max no. of ATL servers */ |
#define | MAX_DATE 20 /* max length archive date and time */ |
#define | MAX_FILE 128 /* max length rel. file name */ |
#define | MAX_FILE_NO 1024 /* max number of file names in list */ |
#define | MAX_FILE_SIZE 2147483647 |
#define | MAX_FILE_SIZE_U 4294967295 |
#define | MAX_FULL_FILE 256 /* max length full file name */ |
#define | MAX_ITEM 32 /* max length of process item */ |
#define | MAX_MC 30 |
#define | MAX_MC_O 12 /* max length Management class name */ |
#define | MAX_NODE 16 /* max length node name */ |
#define | MAX_NUM_DM 20 /* max no. of DMs for RC + GRC or WC + GWC */ |
#define | MAX_NUM_DM_NO 20 /* max digits in DM name */ |
#define | MAX_NUM_POOL 5 /* sum for all ATL servers */ |
#define | MAX_NUM_TAPE 8 /* max no. of available tapes in ATL */ |
#define | MAX_OBJ_FS 32 |
#define | MAX_OBJ_HL 112 /* max length object high level name */ |
#define | MAX_OBJ_HL_LEVEL 14 |
#define | MAX_OBJ_HL_O 92 /* max length object high level name */ |
#define | MAX_OBJ_LL 52 /* max length object low level name */ |
#define | MAX_OBJ_LL_O 36 /* max length object low level name */ |
#define | MAX_OS 8 /* max length operating system name */ |
#define | MAX_OWNER 16 /* max length object owner */ |
#define | MAX_POOL_ATLSERVER 10 /* max no. of pools in ATL servers */ |
#define | MAX_SIZE_CACHE_FILE 4096000 /* max size cache file (MByte) */ |
#define | MAX_TAPE_FILE 17 /* max length file name on tape */ |
#define | MAXLOOP_CACHE_FULL 3 /* max no of iter, if write cache full */ |
#define | MBUF_ADSM 32768 /* default buffer size ADSM */ |
#define | MBUF_RFIO 32768 /* max currently possible in MBS */ |
#define | MBUF_SOCK 32768 /* default buffer size sockets */ |
#define | MIN_DATAFS_PATH 12 /* min path length in lustre */ |
#define | MIN_SEQUENTIAL_FILES 20 |
#define | PORT_ARCHIVE_MGR 1993 /* default port number ArchiveManager */ |
#define | PORT_MASTER 1996 /* default port number master server */ |
#define | PORT_MOVER 1994 /* default port number data mover */ |
#define | PORT_MOVER_DATAFS 1998 /* port number DM for lustre (root) */ |
#define | PORT_RFIO_SERV 1974 /* default port number RFIO server */ |
#define | PORT_STAGE_MGR 1991 /* default port number StageManager */ |
#define | SIZE_CACHE_METADATA_4 344 /* old size of cacheDB entry */ |
#define | SIZE_CACHE_METADATA_5 424 /* cur size of cacheDB entry */ |
#define | SLEEP_CACHE_FULL 600 /* wait time/iter, if write cache full */ |
#define | STATUS_LEN 512 /* max length status/error message */ |
#define | STATUS_LEN_LONG 4096 /* max length long status/error msg */ |
#define | VERSION_SRAWOBJATTR 5 /* cur version of struct srawObjAttr */ |
Variables | |
static char | cAdminUser [MAX_OWNER] = "goeri" |
static char | cDataFSHigh1 [16] = "/hera/" |
static char | cDataFSHigh2 [16] = "/lustre/" |
static char | cDataFSType [16] = "lustre" |
static char | cForceMigPath [32] = "/ArchiveNow" |
static char | cNodeArchiveMgr [MAX_NODE] = "lxgstore" |
static char | cNodeMaster0 [MAX_NODE] = "lxgstore" |
static char | cNodeMasterE1 [MAX_NODE] = "lxha05" |
static char | cNodeMasterE2 [MAX_NODE] = "lxha04" |
static char | cNodeStageMgr [MAX_NODE] = "lxgstore" |
static const char | cTooBig [8] = "(>=4GB)" |
static char * | pcOS |
#define PORT_STAGE_MGR 1991 /* default port number StageManager */ |
Definition at line 251 of file rawcommn.h.
#define PORT_ARCHIVE_MGR 1993 /* default port number ArchiveManager */ |
Definition at line 253 of file rawcommn.h.
#define PORT_MOVER 1994 /* default port number data mover */ |
Definition at line 254 of file rawcommn.h.
#define PORT_MASTER 1996 /* default port number master server */ |
Definition at line 256 of file rawcommn.h.
#define PORT_MOVER_DATAFS 1998 /* port number DM for lustre (root) */ |
Definition at line 258 of file rawcommn.h.
#define PORT_RFIO_SERV 1974 /* default port number RFIO server */ |
Definition at line 260 of file rawcommn.h.
#define ATLSERVER_ARCHIVE 1 /* API write: 1: IBM 3494, 2: SANLB2 */ |
Definition at line 262 of file rawcommn.h.
#define MAX_ATLSERVER 1 /* max no. of ATL servers */ |
Definition at line 263 of file rawcommn.h.
#define MAX_POOL_ATLSERVER 10 /* max no. of pools in ATL servers */ |
Definition at line 264 of file rawcommn.h.
#define MAX_NUM_POOL 5 /* sum for all ATL servers */ |
Definition at line 265 of file rawcommn.h.
#define MAX_NUM_TAPE 8 /* max no. of available tapes in ATL */ |
Definition at line 266 of file rawcommn.h.
#define MAX_NUM_DM 20 /* max no. of DMs for RC + GRC or WC + GWC */ |
Definition at line 267 of file rawcommn.h.
#define MAX_NUM_DM_NO 20 /* max digits in DM name */ |
Definition at line 268 of file rawcommn.h.
#define MBUF_SOCK 32768 /* default buffer size sockets */ |
Definition at line 269 of file rawcommn.h.
#define MBUF_ADSM 32768 /* default buffer size ADSM */ |
Definition at line 270 of file rawcommn.h.
#define MBUF_RFIO 32768 /* max currently possible in MBS */ |
Definition at line 271 of file rawcommn.h.
#define CUR_QUERY_LIMIT 0 |
Definition at line 272 of file rawcommn.h.
#define SLEEP_CACHE_FULL 600 /* wait time/iter, if write cache full */ |
Definition at line 277 of file rawcommn.h.
#define MAXLOOP_CACHE_FULL 3 /* max no of iter, if write cache full */ |
Definition at line 278 of file rawcommn.h.
#define DEF_FILESIZE 2044000000 /* assume <2GByte, if unavailable */ |
Definition at line 280 of file rawcommn.h.
#define MAX_FILE_SIZE 2147483647 |
Definition at line 281 of file rawcommn.h.
#define MAX_FILE_SIZE_U 4294967295 |
Definition at line 283 of file rawcommn.h.
#define MAX_SIZE_CACHE_FILE 4096000 /* max size cache file (MByte) */ |
Definition at line 285 of file rawcommn.h.
#define MAX_FILE_NO 1024 /* max number of file names in list */ |
Definition at line 287 of file rawcommn.h.
#define MIN_SEQUENTIAL_FILES 20 |
Definition at line 289 of file rawcommn.h.
#define MAX_NODE 16 /* max length node name */ |
Definition at line 295 of file rawcommn.h.
#define MIN_DATAFS_PATH 12 /* min path length in lustre */ |
Definition at line 302 of file rawcommn.h.
#define MAX_OWNER 16 /* max length object owner */ |
Definition at line 307 of file rawcommn.h.
#define MAX_OS 8 /* max length operating system name */ |
Definition at line 312 of file rawcommn.h.
#define MAX_FULL_FILE 256 /* max length full file name */ |
Definition at line 327 of file rawcommn.h.
#define MAX_FILE 128 /* max length rel. file name */ |
Definition at line 328 of file rawcommn.h.
#define MAX_TAPE_FILE 17 /* max length file name on tape */ |
Definition at line 329 of file rawcommn.h.
#define VERSION_SRAWOBJATTR 5 /* cur version of struct srawObjAttr */ |
Definition at line 331 of file rawcommn.h.
#define SIZE_CACHE_METADATA_5 424 /* cur size of cacheDB entry */ |
Definition at line 332 of file rawcommn.h.
#define SIZE_CACHE_METADATA_4 344 /* old size of cacheDB entry */ |
Definition at line 333 of file rawcommn.h.
#define MAX_OBJ_FS 32 |
Definition at line 335 of file rawcommn.h.
#define MAX_OBJ_HL 112 /* max length object high level name */ |
Definition at line 337 of file rawcommn.h.
#define MAX_OBJ_LL 52 /* max length object low level name */ |
Definition at line 338 of file rawcommn.h.
#define MAX_OBJ_HL_O 92 /* max length object high level name */ |
Definition at line 339 of file rawcommn.h.
#define MAX_OBJ_LL_O 36 /* max length object low level name */ |
Definition at line 340 of file rawcommn.h.
#define MAX_OBJ_HL_LEVEL 14 |
Definition at line 341 of file rawcommn.h.
#define MAX_MC 30 |
Definition at line 344 of file rawcommn.h.
#define MAX_MC_O 12 /* max length Management class name */ |
Definition at line 348 of file rawcommn.h.
#define MAX_DATE 20 /* max length archive date and time */ |
Definition at line 350 of file rawcommn.h.
#define MAX_APPLTYPE 28 /* max length application type */ |
Definition at line 351 of file rawcommn.h.
#define MAX_ITEM 32 /* max length of process item */ |
Definition at line 352 of file rawcommn.h.
#define HEAD_OFFSET 3 /* offset common pre-header (ints) */ |
Definition at line 354 of file rawcommn.h.
#define HEAD_LEN 12 /* length common pre-header (bytes) */ |
Definition at line 355 of file rawcommn.h.
#define STATUS_LEN 512 /* max length status/error message */ |
Definition at line 356 of file rawcommn.h.
#define STATUS_LEN_LONG 4096 /* max length long status/error msg */ |
Definition at line 357 of file rawcommn.h.
#define IDENT_COMM -1 /* communication control buffer */ |
Definition at line 361 of file rawcommn.h.
#define IDENT_STATUS -2 /* status buffer from/to client */ |
Definition at line 362 of file rawcommn.h.
#define IDENT_QUERY -3 /* query result buffer */ |
Definition at line 363 of file rawcommn.h.
#define IDENT_POOL -4 /* stage pool info buffer */ |
Definition at line 364 of file rawcommn.h.
#define IDENT_WORKSPACE -5 /* work space info buffer */ |
Definition at line 365 of file rawcommn.h.
#define IDENT_NEXT_BUFFER -6 /* request next data buffer */ |
Definition at line 366 of file rawcommn.h.
#define IDENT_MOVER_ATTR -7 /* data mover attributes */ |
Definition at line 367 of file rawcommn.h.
#define IDENT_STAGE_FILE -8 /* stage file data (read cache) */ |
Definition at line 368 of file rawcommn.h.
#define IDENT_SPACE_INFO -9 /* data mover space info */ |
Definition at line 369 of file rawcommn.h.
#define IDENT_PURGE_INFO -10 /* purge request for data mover */ |
Definition at line 370 of file rawcommn.h.
#define IDENT_SPACE_LOOK -11 /* meta data DB space info */ |
Definition at line 371 of file rawcommn.h.
#define IDENT_CLEAN_REQUEST -12 /* clean request for stage pool */ |
Definition at line 372 of file rawcommn.h.
#define IDENT_FILELIST_REQUEST -13 /* filelist request for stage FS */ |
Definition at line 373 of file rawcommn.h.
#define IDENT_QUERY_ARCHDB -14 /* query result buffer archDB */ |
Definition at line 374 of file rawcommn.h.
#define IDENT_FULL_ARCHDISK -15 /* buffer describing full disk */ |
Definition at line 375 of file rawcommn.h.
#define IDENT_ARCHIVE_FILE -16 /* archive file data (write cache) */ |
Definition at line 376 of file rawcommn.h.
#define IDENT_STAGE_LIST -17 /* list of read cache object data */ |
Definition at line 377 of file rawcommn.h.
#define IDENT_QUERY_FILEDB -18 /* query result buffer fileDB */ |
Definition at line 378 of file rawcommn.h.
#define IDENT_QUERY_DONE -19 /* last query result buffer */ |
Definition at line 379 of file rawcommn.h.
#define IDENT_CACHE_STATUS -20 /* request query/set cache status */ |
Definition at line 380 of file rawcommn.h.
#define IDENT_COPY_CACHE -21 /* copy DAQ stream data from cache */ |
Definition at line 381 of file rawcommn.h.
#define IDENT_ARCHIVE_LIST -22 /* list of archive names */ |
Definition at line 382 of file rawcommn.h.
#define IDENT_PROC_INFO -23 /* get/update proc no. in cacheDB */ |
Definition at line 383 of file rawcommn.h.
#define IDENT_STAGE_PARALLEL -24 /* DMs and filelists for par stage */ |
Definition at line 384 of file rawcommn.h.
#define IDENT_GLOBAL_SOCKET -25 /* global socket data for CacheMgr */ |
Definition at line 385 of file rawcommn.h.
#define IDENT_CACHEFS_ACTION -26 /* action request for cache FS */ |
Definition at line 386 of file rawcommn.h.
#define IDENT_STAGE_SEQUENTIAL -27 /* DMs + filelists for sequ stage */ |
Definition at line 387 of file rawcommn.h.
#define IDENT_MIGR_LIMIT -28 /* info/action for migr limit WC pool */ |
Definition at line 388 of file rawcommn.h.
#define IDENT_TAPE_STATUS_DM -29 /* pool DM tape connect status */ |
Definition at line 389 of file rawcommn.h.
#define IDENT_RETRIEVE_PARALLEL -30 /* DMs and filelists par retr */ |
Definition at line 390 of file rawcommn.h.
#define IDENT_FILESIZE_REQUEST -31 /* request object filesize on DM */ |
Definition at line 391 of file rawcommn.h.
#define IDENT_SPACE_TREE1 -32 /* metadataDB space info + 1 fill tree */ |
Definition at line 392 of file rawcommn.h.
#define IDENT_SPACE_TREE2 -33 /* metadataDB space info + 2 fill trees*/ |
Definition at line 393 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 395 of file rawcommn.h.
enum RETR_DEVICE |
Enumerator | |
---|---|
RETR_CLIENT | |
RETR_STAGE_TEMP | |
RETR_STAGE_PERM | |
RETR_FILESYSTEM |
Definition at line 405 of file rawcommn.h.
enum FILETYPE |
Enumerator | |
---|---|
FIXED_INTS4 | |
STREAM |
Definition at line 413 of file rawcommn.h.
enum ACTION |
Definition at line 419 of file rawcommn.h.
enum STATUS |
Definition at line 545 of file rawcommn.h.
|
static |
Definition at line 292 of file rawcommn.h.
|
static |
Definition at line 296 of file rawcommn.h.
|
static |
Definition at line 297 of file rawcommn.h.
|
static |
Definition at line 298 of file rawcommn.h.
|
static |
Definition at line 299 of file rawcommn.h.
|
static |
Definition at line 300 of file rawcommn.h.
|
static |
Definition at line 303 of file rawcommn.h.
|
static |
Definition at line 304 of file rawcommn.h.
|
static |
Definition at line 305 of file rawcommn.h.
|
static |
Definition at line 308 of file rawcommn.h.
|
static |
Definition at line 309 of file rawcommn.h.
|
static |
Definition at line 313 of file rawcommn.h.