#include <math.h>
#include <float.h>
#include <limits.h>
#include <stdint.h>
#include "db.h"
#include "hcontainer.h"
#include "list.h"
#include "util.h"
#include "tagfifo.h"
#include "SUM.h"
#include "sum_rpc.h"
#include "drms_protocol.h"
Go to the source code of this file.
Data Structures | |
struct | CleanerData_struct |
struct | DRMS_Array_struct |
DRMS array struct. More... | |
struct | DRMS_Env_struct |
DRMS environment struct. More... | |
struct | DRMS_Keyword_struct |
struct | DRMS_KeywordInfo_struct |
struct | DRMS_Link_struct |
DRMS link struct. More... | |
struct | DRMS_LinkInfo_struct |
struct | DRMS_Record_struct |
DRMS record struct. More... | |
struct | DRMS_RecordSet_struct |
DRMS-Record-set container. More... | |
struct | DRMS_RecSetCursor_struct |
DRMS cursor struct. More... | |
struct | DRMS_Segment_struct |
DRMS segment struct. More... | |
struct | DRMS_SegmentDimInfo_struct |
DRMS segment dimension info struct. More... | |
struct | DRMS_SegmentInfo_struct |
DRMS segment info struct. More... | |
struct | DRMS_SeriesInfo_struct |
struct | DRMS_SeriesVersion_struct |
struct | DRMS_Session_struct |
DRMS Session struct. More... | |
struct | DRMS_StorageUnit_struct |
struct | DRMS_SuAndSeries_struct |
struct | DRMS_SumRequest_struct |
struct | DRMS_ThreadInfo_struct |
union | DRMS_Type_Value |
DRMS type value. More... | |
struct | DRMS_Value |
struct | DS_node_struct |
struct | ExportStrings_struct |
Defines | |
#define | _DRMS_IS_D_MISSING(v) |
#define | _DRMS_IS_F_MISSING(v) |
#define | _DRMS_IS_T_MISSING(v) |
#define | DRMS_DEFVAL_MAXLEN |
Max length of the string holding a keyword default value. | |
#define | DRMS_MAX_REQCNT |
#define | DRMS_MAXBIGQUERYLEN |
#define | DRMS_MAXCHUNKSIZE |
Maximum number of in-memory records - 16MB for now. | |
#define | DRMS_MAXCOMMENTLEN |
Maximum DRMS comment byte length. | |
#define | DRMS_MAXCPARMS |
Maximum byte length of a segment's compression-parameter string. | |
#define | DRMS_MAXCURSORNAMELEN |
#define | DRMS_MAXDBIDX |
Max number of keywords to make db index. | |
#define | DRMS_MAXFORMATLEN |
#define | DRMS_MAXHASHKEYLEN |
Maximum DRMS hash byte length. | |
#define | DRMS_MAXHOSTNAME |
#define | DRMS_MAXKEYNAMELEN |
#define | DRMS_MAXLINKDEPTH |
The maximal length we allow of a chain of links. If a chain longer than this is encountered we assume that there is a cyclic link. | |
#define | DRMS_MAXLINKNAMELEN |
#define | DRMS_MAXNAMELEN |
#define | DRMS_MAXOWNERLEN |
#define | DRMS_MAXPATHLEN |
#define | DRMS_MAXPRIMIDX |
Max number of keywords in the primary index. | |
#define | DRMS_MAXQUERYLEN |
#define | DRMS_MAXRANK |
Maximum dimension of DRMS data. | |
#define | DRMS_MAXSEGFILENAME |
Maximum byte length of DRMS segment file name. | |
#define | DRMS_MAXSEGMENTS |
Maximum number of DRMS segments per record. | |
#define | DRMS_MAXSEGNAMELEN |
#define | DRMS_MAXSERIESNAMELEN |
#define | DRMS_MAXSERIESVERSION |
#define | DRMS_MAXTYPENAMELEN |
#define | DRMS_MAXUNITLEN |
Maximum byte length of unit string. | |
#define | DRMS_MISSING_CHAR |
DRMS char missing value. | |
#define | DRMS_MISSING_DOUBLE |
DRMS double missing value. | |
#define | DRMS_MISSING_FLOAT |
DRMS float missing value. | |
#define | DRMS_MISSING_INT |
DRMS int missing value. | |
#define | DRMS_MISSING_LONGLONG |
DRMS longlong missing value. | |
#define | DRMS_MISSING_SHORT |
DRMS short missing value. | |
#define | DRMS_MISSING_STRING |
DRMS C string missing value. | |
#define | DRMS_MISSING_TIME |
DRMS time missing value. | |
#define | DRMS_READONLY |
#define | DRMS_READWRITE |
#define | DRMS_SUMABORT |
#define | DRMS_SUMALLOC |
#define | DRMS_SUMALLOC2 |
#define | DRMS_SUMCLOSE |
#define | DRMS_SUMDELETESERIES |
#define | DRMS_SUMEXPORT |
#define | DRMS_SUMGET |
#define | DRMS_SUMINFO |
#define | DRMS_SUMOPEN |
#define | DRMS_SUMPUT |
#define | DRMS_VAL_SET(T, IV, OV) |
#define | kRecScopeIndex_B |
#define | kRecScopeSlotted_B |
#define | kSlotAncKey_Base |
#define | kSlotAncKey_Base |
#define | kSlotAncKey_Epoch |
#define | kSlotAncKey_Index |
#define | kSlotAncKey_Round |
#define | kSlotAncKey_Step |
#define | kSlotAncKey_Unit |
#define | kSlotAncKey_Vals |
#define | SDO_EPOCH |
#define | SDO_EPOCH_F |
#define | SDO_EPOCH_S |
#define | TSEQ_EPOCH |
#define | TSEQ_EPOCH_F |
#define | TSEQ_EPOCH_S |
Typedefs | |
typedef struct CleanerData_struct | CleanerData_t |
typedef struct DRMS_Array_struct | DRMS_Array_t |
DRMS array struct reference. | |
typedef struct DRMS_Env_struct | DRMS_Env_t |
DRMS environment struct reference. | |
typedef enum DRMS_ExportKeyword_enum | DRMS_ExportKeyword_t |
typedef struct DRMS_Keyword_struct | DRMS_Keyword_t |
DRMS keyword struct reference. | |
typedef enum DRMS_KeywordClass_enum | DRMS_KeywordClass_t |
typedef enum DRMS_KeywordFlag_enum | DRMS_KeywordFlag_t |
typedef struct DRMS_KeywordInfo_struct | DRMS_KeywordInfo_t |
typedef struct DRMS_Link_struct | DRMS_Link_t |
DRMS link struct reference. | |
typedef struct DRMS_LinkInfo_struct | DRMS_LinkInfo_t |
typedef enum DRMS_PrimeKeyType_enum | DRMS_PrimeKeyType_t |
typedef struct DRMS_Record_struct | DRMS_Record_t |
typedef struct DRMS_RecordSet_struct | DRMS_RecordSet_t |
DRMS record struct reference. | |
typedef enum DRMS_RecordSetType_struct | DRMS_RecordSetType_t |
typedef int | DRMS_RecQueryInfo_t |
typedef enum DRMS_RecQueryInfoFlag_enum | DRMS_RecQueryInfoFlag_t |
typedef enum DRMS_RecScopeType_enum | DRMS_RecScopeType_t |
typedef struct DRMS_RecSetCursor_struct | DRMS_RecSetCursor_t |
DRMS cursor struct reference. | |
typedef enum DRMS_RecSetCursorSeek_enum | DRMS_RecSetCursorSeek_t |
typedef struct DRMS_Segment_struct | DRMS_Segment_t |
DRMS segment struct reference. | |
typedef struct DRMS_SegmentDimInfo_struct | DRMS_SegmentDimInfo_t |
DRMS segment dim info struct reference. | |
typedef struct DRMS_SegmentInfo_struct | DRMS_SegmentInfo_t |
DRMS segment info struct reference. | |
typedef struct DRMS_SeriesInfo_struct | DRMS_SeriesInfo_t |
typedef struct DRMS_SeriesVersion_struct | DRMS_SeriesVersion_t |
typedef struct DRMS_Session_struct | DRMS_Session_t |
typedef enum DRMS_Shutdown_State_enum | DRMS_Shutdown_State_t |
typedef enum DRMS_SlotKeyUnit_enum | DRMS_SlotKeyUnit_t |
typedef struct DRMS_StorageUnit_struct | DRMS_StorageUnit_t |
typedef struct DRMS_SuAndSeries_struct | DRMS_SuAndSeries_t |
typedef struct DRMS_SumRequest_struct | DRMS_SumRequest_t |
typedef struct DRMS_ThreadInfo_struct | DRMS_ThreadInfo_t |
typedef enum DRMS_TimeEpoch_enum | DRMS_TimeEpoch_t |
typedef union DRMS_Type_Value | DRMS_Type_Value_t |
DRMS type value reference. | |
typedef struct DRMS_Value | DRMS_Value_t |
typedef struct DS_node_struct | DS_node_t |
typedef struct ExportStrings_struct | ExportStrings_t |
typedef int(* | pFn_Cleaner_t )(void *) |
Enumerations | |
enum | DRMS_ExportKeyword_enum { kExport_ReqID, kExport_Request, kExport_SegList, kExport_Requestor, kExport_Notification, kExport_ReqTime, kExport_ExpTime, kExport_DataSize, kExport_Format, kExport_FileNameFormat, kExport_Status } |
enum | DRMS_KeywordClass_enum { kDRMS_KeyClass_All, kDRMS_KeyClass_Explicit, kDRMS_KeyClass_DRMSPrime, kDRMS_KeyClass_Persegment } |
DRMS Keyword Classes. More... | |
enum | DRMS_KeywordFlag_enum { kKeywordFlag_PerSegment, kKeywordFlag_Implicit, kKeywordFlag_InternalPrime, kKeywordFlag_ExternalPrime } |
enum | DRMS_Link_Type_t { STATIC_LINK, DYNAMIC_LINK } |
enum | DRMS_PrimeKeyType_enum { kPkeysDRMSInternal, kPkeysDRMSExternal } |
enum | DRMS_RecLifetime_t { DRMS_PERMANENT, DRMS_TRANSIENT } |
enum | DRMS_RecordSetType_struct { kRecordSetType_DRMS, kRecordSetType_DSDS, kRecordSetType_VOT, kRecordSetType_PlainFile, kRecordSetType_DSDSPort } |
enum | DRMS_RecQueryInfoFlag_enum { kFilters, kAtFile } |
enum | DRMS_RecScopeType_enum { kRecScopeType_Variable, kRecScopeType_Constant, kRecScopeType_Index, kRecScopeType_TS_EQ, kRecScopeType_SLOT, kRecScopeType_ENUM, kRecScopeType_CARR, kRecScopeType_TS_SLOT } |
enum | DRMS_RecSetCursorSeek_enum { kRSChunk_First, kRSChunk_Last, kRSChunk_Abs, kRSChunk_Next, kRSChunk_Prev } |
DRMS cursor seek. | |
enum | DRMS_Segment_Scope_t { DRMS_CONSTANT, DRMS_VARIABLE, DRMS_VARDIM } |
DRMS segment scope types. More... | |
enum | DRMS_Shutdown_State_enum { kSHUTDOWN_UNINITIATED, kSHUTDOWN_COMMITINITIATED, kSHUTDOWN_ABORTINITIATED, kSHUTDOWN_COMMIT, kSHUTDOWN_ABORT, kSHUTDOWN_BYMAIN } |
enum | DRMS_SlotKeyUnit_enum { kSlotKeyUnit_Invalid, kSlotKeyUnit_TSeconds, kSlotKeyUnit_Seconds, kSlotKeyUnit_Minutes, kSlotKeyUnit_Hours, kSlotKeyUnit_Days, kSlotKeyUnit_Degrees, kSlotKeyUnit_Arcminutes, kSlotKeyUnit_Arcseconds, kSlotKeyUnit_MAS, kSlotKeyUnit_Radians, kSlotKeyUnit_MicroRadians } |
enum | DRMS_TimeEpoch_enum { kTimeEpoch_Invalid, kTimeEpoch_DRMS, kTimeEpoch_MDI, kTimeEpoch_WSO, kTimeEpoch_TAI, kTimeEpoch_MJD, kTimeEpoch_TSEQ, kTimeEpoch_END } |
enum | DRMS_Type_t { DRMS_TYPE_CHAR, DRMS_TYPE_SHORT, DRMS_TYPE_INT, DRMS_TYPE_LONGLONG, DRMS_TYPE_FLOAT, DRMS_TYPE_DOUBLE, DRMS_TYPE_TIME, DRMS_TYPE_STRING, DRMS_TYPE_RAW, DRMS_TYPE_INT8, DRMS_TYPE_INT16, DRMS_TYPE_INT32, DRMS_TYPE_INT64, DRMS_TYPE_UINT8, DRMS_TYPE_UINT16, DRMS_TYPE_UINT32, DRMS_TYPE_UINT64, DRMS_TYPE_FLOAT, DRMS_TYPE_DOUBLE, DRMS_TYPE_TIME, DRMS_TYPE_STRING } |
DRMS Data types. More... | |
FunctionsTitleTestFour | |
long long | conv2longlong (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
char | drms2char (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
DB_Type_t | drms2dbtype (DRMS_Type_t type) |
double | drms2double (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
float | drms2float (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
int | drms2int (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
long long | drms2longlong (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
short | drms2short (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
char * | drms2string (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
double | drms2time (DRMS_Type_t type, DRMS_Type_Value_t *value, int *status) |
void * | drms_addr (DRMS_Type_t type, DRMS_Type_Value_t *val) |
void | drms_byteswap (DRMS_Type_t type, int n, char *val) |
int | drms_convert (DRMS_Type_t dsttype, DRMS_Type_Value_t *dst, DRMS_Type_t srctype, DRMS_Type_Value_t *src) |
int | drms_convert_array (DRMS_Type_t dsttype, char *dst, DRMS_Type_t srctype, char *src) |
int | drms_copy_db2drms (DRMS_Type_t drms_type, DRMS_Type_Value_t *drms_dst, DB_Type_t db_type, char *db_src) |
void | drms_copy_drms2drms (DRMS_Type_t type, DRMS_Type_Value_t *dst, DRMS_Type_Value_t *src) |
int | drms_daxpy (DRMS_Type_t type, const double alpha, DRMS_Type_Value_t *x, DRMS_Type_Value_t *y) |
int | drms_equal (DRMS_Type_t type, DRMS_Type_Value_t *x, DRMS_Type_Value_t *y) |
int | drms_fprintfval (FILE *keyfile, DRMS_Type_t type, DRMS_Type_Value_t *val) |
int | drms_fprintfval_raw (FILE *keyfile, DRMS_Type_t type, void *val) |
void | drms_memset (DRMS_Type_t type, int n, void *array, DRMS_Type_Value_t val) |
void | drms_missing (DRMS_Type_t type, DRMS_Type_Value_t *val) |
void | drms_missing_vp (DRMS_Type_t type, void *val) |
int | drms_printfval (DRMS_Type_t type, DRMS_Type_Value_t *val) |
int | drms_printfval_raw (DRMS_Type_t type, void *val) |
int | drms_sizeof (DRMS_Type_t type) |
int | drms_sprintfval (char *dst, DRMS_Type_t type, DRMS_Type_Value_t *val, int internal) |
int | drms_sprintfval_format (char *dst, DRMS_Type_t type, DRMS_Type_Value_t *val, char *format, int internal) |
int | drms_sscanf2 (const char *str, const char *delim, int silent, DRMS_Type_t dsttype, DRMS_Value_t *dst) |
int | drms_sscanf_str (const char *str, const char *delim, DRMS_Type_Value_t *dst) |
DRMS_Type_t | drms_str2type (const char *) |
int | drms_strval (DRMS_Type_t type, DRMS_Type_Value_t *val, char *str) |
const TIME * | drms_time_getepoch (const char *str, DRMS_TimeEpoch_t *epochenum, int *status) |
void | drms_time_term () |
const char * | drms_type2str (DRMS_Type_t type) |
Return a string representation of a DRMS_Type_t value. | |
long long | drms_types_strtoll (const char *str, DRMS_Type_t inttype, int *consumed, int *status) |
Variables | |
char * | drms_segmentscope_names [] |
char * | drms_type_names [] |
char * | drms_type_recsetnames [] |
ExportStrings_t | gExpStr [] |
const char * | kIndexKWFormat |
const DRMS_Type_t | kIndexKWType |
Definition in file drms_types.h.