|
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.