Skip to content
GitLab
Commit a249bbf7 authored by Uwe Schulzweida's avatar Uwe Schulzweida
Browse files

taxis: mt safe version

parent d5372ea1
Hide whitespace changes
Inline Side-by-side
ChangeLog
View file @ a249bbf7
......@@ -2,6 +2,7 @@
* stream: mt safe version
* zaxis: mt safe version
* taxis: mt safe version
* model: mt safe version
* remove H5 test version
* stream_srv: bug fix for codes > 999 [report: Simon Blessing]
......
src/cdi_limits.h
View file @ a249bbf7
......@@ -5,6 +5,7 @@
#define MAX_VLISTS 4096 /* maximum number of vlists */
#define MAX_GRIDS 1024 /* maximum number of grids */
#define MAX_ZAXIS 1024 /* maximum number of zaxis */
#define MAX_TAXIS 4096 /* maximum number of taxis */
#define MAX_INSTS 1024 /* maximum number of instituts */
#define MAX_MODELS 1024 /* maximum number of models */
#define MAX_GRIDS_PS 128 /* maximum number of different grids per stream */
......
src/taxis.c
View file @ a249bbf7
......@@ -13,10 +13,6 @@ int DefaultTimeType = TAXIS_ABSOLUTE;
int DefaultTimeUnit = TUNIT_HOUR;
int DefaultCalendar = CALENDAR_STANDARD;
static int TimeTableInit = 0;
TAXIS *taxisTable;
int taxisTableSize = 0;
char *Timeunits[] = {
"undefined",
......@@ -43,9 +39,9 @@ char *tunitNamePtr(int unitID)
}
void taxisTableInit(void)
void taxis_defaults(void)
{
static char func[] = "taxisTableInit";
static char func[] = "taxis_defaults";
char *timeunit;
timeunit = getenv("TIMEUNIT");
......@@ -64,116 +60,240 @@ void taxisTableInit(void)
else
Warning(func, "Unsupported TIMEUNIT %s!", timeunit);
}
}
static int TAXIS_Debug = 0; /* If set to 1, debugging */
static int _taxis_max = MAX_TAXIS;
static void taxis_initialize(void);
static int _taxis_init = FALSE;
#if defined (HAVE_LIBPTHREAD)
# include <pthread.h>
static pthread_once_t _taxis_init_thread = PTHREAD_ONCE_INIT;
static pthread_mutex_t _taxis_mutex;
# define TAXIS_LOCK pthread_mutex_lock(&_taxis_mutex);
# define TAXIS_UNLOCK pthread_mutex_unlock(&_taxis_mutex);
# define TAXIS_INIT \
if ( _taxis_init == FALSE ) pthread_once(&_taxis_init_thread, taxis_initialize);
#else
# define TAXIS_LOCK
# define TAXIS_UNLOCK
# define TAXIS_INIT \
if ( _taxis_init == FALSE ) taxis_initialize();
#endif
TimeTableInit = 1;
typedef struct _taxisPtrToIdx {
int idx;
TAXIS *ptr;
struct _taxisPtrToIdx *next;
} taxisPtrToIdx;
static taxisPtrToIdx *_taxisList = NULL;
static taxisPtrToIdx *_taxisAvail = NULL;
static void taxis_list_new(void)
{
static char func[] = "taxis_list_new";
assert(_taxisList == NULL);
_taxisList = (taxisPtrToIdx *) malloc(_taxis_max*sizeof(taxisPtrToIdx));
}
void ptaxisInit(TAXIS *taxis)
static void taxis_list_delete(void)
{
if ( ! TimeTableInit ) taxisTableInit();
static char func[] = "taxis_list_delete";
taxis->used = FALSE;
taxis->type = DefaultTimeType;
taxis->vdate = 0;
taxis->vtime = 0;
taxis->rdate = CDI_UNDEFID;
taxis->rtime = 0;
taxis->calendar = DefaultCalendar;
taxis->unit = DefaultTimeUnit;
taxis->numavg = 0;
taxis->has_bounds = FALSE;
taxis->vdate_lb = 0;
taxis->vtime_lb = 0;
taxis->vdate_ub = 0;
taxis->vtime_ub = 0;
if ( _taxisList ) free(_taxisList);
}
void ptaxisCopy(TAXIS *dest, TAXIS *source)
static void taxis_init_pointer(void)
{
memcpy(dest, source, sizeof(TAXIS));
int i;
for ( i = 0; i < _taxis_max; i++ )
{
_taxisList[i].next = _taxisList + i + 1;
_taxisList[i].idx = i;
_taxisList[i].ptr = 0;
}
_taxisList[_taxis_max-1].next = 0;
_taxisAvail = _taxisList;
}
int taxisTableNewEntry(int timetype)
TAXIS *taxis_to_pointer(int idx)
{
static char func[] = "taxisTableNewEntry";
int taxisID = 0;
static char func[] = "taxis_to_pointer";
TAXIS *taxisptr = NULL;
if ( ! TimeTableInit ) taxisTableInit();
TAXIS_INIT
/*
Look for a free slot in taxisTable.
(Create the table the first time through).
*/
if ( ! taxisTableSize )
if ( idx >= 0 && idx < _taxis_max )
{
int i;
TAXIS_LOCK
taxisTableSize = 2;
taxisTable = (TAXIS *) malloc(taxisTableSize*sizeof(TAXIS));
if ( taxisTable == NULL )
{
Message(func, "taxisTableSize = %d", taxisTableSize);
SysError(func, "Allocation of TAXISTABLE failed");
}
taxisptr = _taxisList[idx].ptr;
for ( i = 0; i < taxisTableSize; i++ )
{
taxisTable[i].used = FALSE;
ptaxisInit(&taxisTable[i]);
}
TAXIS_UNLOCK
}
else
Error(func, "taxis index %d undefined!", idx);
return (taxisptr);
}
/* Create an index from a pointer */
static int taxis_from_pointer(TAXIS *ptr)
{
static char func[] = "taxis_from_pointer";
int idx = -1;
taxisPtrToIdx *newptr;
if ( ptr )
{
while ( taxisID < taxisTableSize )
TAXIS_LOCK
if ( _taxisAvail )
{
if ( ! taxisTable[taxisID].used ) break;
taxisID++;
newptr = _taxisAvail;
_taxisAvail = _taxisAvail->next;
newptr->next = 0;
idx = newptr->idx;
newptr->ptr = ptr;
if ( TAXIS_Debug )
Message(func, "Pointer %p has idx %d from taxis list", ptr, idx);
}
else
Warning(func, "Too many open taxis (limit is %d)!", _taxis_max);
TAXIS_UNLOCK
}
/*
If the table overflows, double its size.
*/
if ( taxisID == taxisTableSize )
{
int i;
else
Error(func, "Internal problem (pointer %p undefined)", ptr);
taxisTableSize = 2*taxisTableSize;
taxisTable = (TAXIS *) realloc(taxisTable, taxisTableSize*sizeof(TAXIS));
if ( taxisTable == NULL )
{
Message(func, "taxisTableSize = %d", taxisTableSize);
SysError(func, "Reallocation of TAXISTABLE failed");
}
return (idx);
}
taxisID = taxisTableSize/2;
for ( i = taxisID; i < taxisTableSize; i++ )
{
taxisTable[i].used = FALSE;
ptaxisInit(&taxisTable[i]);
}
}
void taxis_init_ptr(TAXIS *taxisptr)
{
taxisptr->self = -1;
taxisptr->used = FALSE;
taxisptr->type = DefaultTimeType;
taxisptr->vdate = 0;
taxisptr->vtime = 0;
taxisptr->rdate = CDI_UNDEFID;
taxisptr->rtime = 0;
taxisptr->calendar = DefaultCalendar;
taxisptr->unit = DefaultTimeUnit;
taxisptr->numavg = 0;
taxisptr->has_bounds = FALSE;
taxisptr->vdate_lb = 0;
taxisptr->vtime_lb = 0;
taxisptr->vdate_ub = 0;
taxisptr->vtime_ub = 0;
}
taxisTable[taxisID].type = timetype;
taxisTable[taxisID].used = TRUE;
void taxis_init_entry(TAXIS *taxisptr)
{
taxis_init_ptr(taxisptr);
return (taxisID);
taxisptr->self = taxis_from_pointer(taxisptr);
}
static void taxisCheckID(const char *func, int taxisID)
static TAXIS *taxis_new_entry(void)
{
if ( taxisID == CDI_UNDEFID )
Error(func, "taxisID undefined!");
static char func[] = "taxis_new_entry";
TAXIS *taxisptr;
taxisptr = (TAXIS *) malloc(sizeof(TAXIS));
if ( taxisID < 0 || taxisID >= taxisTableSize )
Error(func, "taxisID %d undefined!", taxisID);
if ( taxisptr ) taxis_init_entry(taxisptr);
if ( taxisTable[taxisID].type == CDI_UNDEFID )
Error(func, "taxisID %d type undefined!", taxisID);
return (taxisptr);
}
static void taxis_delete_entry(TAXIS *taxisptr)
{
static char func[] = "taxis_delete_entry";
int idx;
idx = taxisptr->self;
TAXIS_LOCK
free(taxisptr);
_taxisList[idx].next = _taxisAvail;
_taxisList[idx].ptr = 0;
_taxisAvail = &_taxisList[idx];
TAXIS_UNLOCK
if ( TAXIS_Debug )
Message(func, "Removed idx %d from taxis list", idx);
}
static void taxis_initialize(void)
{
char *env;
#if defined (HAVE_LIBPTHREAD)
/* initialize global API mutex lock */
pthread_mutex_init(&_taxis_mutex, NULL);
#endif
env = getenv("TAXIS_DEBUG");
if ( env ) TAXIS_Debug = atoi(env);
taxis_list_new();
atexit(taxis_list_delete);
taxis_init_pointer();
_taxis_init = TRUE;
taxis_defaults();
}
static void taxis_copy(TAXIS *taxisptr2, TAXIS *taxisptr1)
{
int taxisID2;
taxisID2 = taxisptr2->self;
memcpy(taxisptr2, taxisptr1, sizeof(TAXIS));
taxisptr2->self = taxisID2;
}
static void taxis_check_ptr(const char *func, TAXIS *taxisptr)
{
if ( taxisptr == NULL )
Error(func, "taxis undefined!");
}
......@@ -213,12 +333,18 @@ int taxisCreate(int taxistype)
{
static char func[] = "taxisCreate";
int taxisID;
TAXIS *taxisptr;
if ( CDI_Debug )
Message(func, "taxistype: %d", taxistype);
/* get next free time entry */
taxisID = taxisTableNewEntry(taxistype);
TAXIS_INIT
taxisptr = taxis_new_entry();
if ( ! taxisptr ) Error(func, "No memory");
taxisID = taxisptr->self;
taxisptr->type = taxistype;
if ( CDI_Debug )
Message(func, "taxisID: %d", taxisID);
......@@ -246,13 +372,20 @@ int taxisDuplicate(int taxisID1)
{
static char func[] = "taxisDuplicate";
int taxisID2;
/* get next free time entry */
taxisID2 = taxisTableNewEntry(taxisInqType(taxisID1));
TAXIS *taxisptr1;
TAXIS *taxisptr2;
taxisptr1 = taxis_to_pointer(taxisID1);
taxisptr2 = taxis_new_entry();
if ( ! taxisptr2 ) Error(func, "No memory");
taxisID2 = taxisptr2->self;
if ( CDI_Debug )
Message(func, "taxisID: %d", taxisID2);
Message(func, "taxisID2: %d", taxisID2);
ptaxisCopy(taxisPtr(taxisID2), taxisPtr(taxisID1));
ptaxisCopy(taxisptr2, taxisptr1);
return (taxisID2);
}
......@@ -261,10 +394,13 @@ int taxisDuplicate(int taxisID1)
void taxisDefType(int taxisID, int type)
{
static char func[] = "taxisDefType";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
taxisTable[taxisID].type = type;
taxisptr->type = type;
}
......@@ -285,10 +421,13 @@ The function @func{taxisDefVdate} defines the verification date of a Time axis.
void taxisDefVdate(int taxisID, int vdate)
{
static char func[] = "taxisDefVdate";
TAXIS *taxisptr;
taxisCheckID(func, taxisID);
taxisptr = taxis_to_pointer(taxisID);
taxisTable[taxisID].vdate = vdate;
taxis_check_ptr(func, taxisptr);
taxisptr->vdate = vdate;
}
......@@ -309,10 +448,13 @@ The function @func{taxisDefVtime} defines the verification time of a Time axis.
void taxisDefVtime(int taxisID, int vtime)
{
static char func[] = "taxisDefVtime";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
taxisTable[taxisID].vtime = vtime;
taxisptr->vtime = vtime;
}
......@@ -333,10 +475,13 @@ The function @func{taxisDefVdate} defines the reference date of a Time axis.
void taxisDefRdate(int taxisID, int rdate)
{
static char func[] = "taxisDefRdate";
TAXIS *taxisptr;
taxisCheckID(func, taxisID);
taxisptr = taxis_to_pointer(taxisID);
taxisTable[taxisID].rdate = rdate;
taxis_check_ptr(func, taxisptr);
taxisptr->rdate = rdate;
}
......@@ -357,10 +502,13 @@ The function @func{taxisDefVdate} defines the reference time of a Time axis.
void taxisDefRtime(int taxisID, int rtime)
{
static char func[] = "taxisDefRtime";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
taxisTable[taxisID].rtime = rtime;
taxisptr->rtime = rtime;
}
......@@ -383,29 +531,38 @@ The function @func{taxisDefCalendar} defines the calendar of a Time axis.
void taxisDefCalendar(int taxisID, int calendar)
{
static char func[] = "taxisDefCalendar";
TAXIS *taxisptr;
taxisCheckID(func, taxisID);
taxisptr = taxis_to_pointer(taxisID);
taxisTable[taxisID].calendar = calendar;
taxis_check_ptr(func, taxisptr);
taxisptr->calendar = calendar;
}
void taxisDefTunit(int taxisID, int unit)
{
static char func[] = "taxisDefTunit";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
taxisTable[taxisID].unit = unit;
taxisptr->unit = unit;
}
void taxisDefNumavg(int taxisID, int numavg)
{
static char func[] = "taxisDefNumavg";
TAXIS *taxisptr;
taxisCheckID(func, taxisID);
taxisptr = taxis_to_pointer(taxisID);
taxisTable[taxisID].numavg = numavg;
taxis_check_ptr(func, taxisptr);
taxisptr->numavg = numavg;
}
......@@ -416,29 +573,37 @@ The valid CDI time types are TAXIS_ABSOLUTE and TAXIS_RELATIVE.
int taxisInqType(int taxisID)
{
static char func[] = "taxisInqType";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
return (taxisTable[taxisID].type);
return (taxisptr->type);
}
void taxisCopyTimestep(int taxisIDdes, int taxisIDsrc)
void taxisCopyTimestep(int taxisID2, int taxisID1)
{
static char func[] = "taxisCopyTimestep";
TAXIS *taxisptr1;
TAXIS *taxisptr2;
taxisCheckID(func, taxisIDsrc);
taxisCheckID(func, taxisIDdes);
taxisptr1 = taxis_to_pointer(taxisID1);
taxisptr2 = taxis_to_pointer(taxisID2);
taxisTable[taxisIDdes].vdate = taxisTable[taxisIDsrc].vdate;
taxisTable[taxisIDdes].vtime = taxisTable[taxisIDsrc].vtime;
taxis_check_ptr(func, taxisptr1);
taxis_check_ptr(func, taxisptr2);
if ( taxisTable[taxisIDdes].has_bounds )
taxisptr2->vdate = taxisptr1->vdate;
taxisptr2->vtime = taxisptr1->vtime;
if ( taxisptr2->has_bounds )
{
taxisTable[taxisIDdes].vdate_lb = taxisTable[taxisIDsrc].vdate_lb;
taxisTable[taxisIDdes].vtime_lb = taxisTable[taxisIDsrc].vtime_lb;
taxisTable[taxisIDdes].vdate_ub = taxisTable[taxisIDsrc].vdate_ub;
taxisTable[taxisIDdes].vtime_ub = taxisTable[taxisIDsrc].vtime_ub;
taxisptr2->vdate_lb = taxisptr1->vdate_lb;
taxisptr2->vtime_lb = taxisptr1->vtime_lb;
taxisptr2->vdate_ub = taxisptr1->vdate_ub;
taxisptr2->vtime_ub = taxisptr1->vtime_ub;
}
}
......@@ -462,10 +627,13 @@ The function @func{taxisInqVdate} returns the verification date of a Time axis.
int taxisInqVdate(int taxisID)
{
static char func[] = "taxisInqVdate";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
return (taxisTable[taxisID].vdate);
return (taxisptr->vdate);
}
......@@ -488,10 +656,13 @@ The function @func{taxisInqVtime} returns the verification time of a Time axis.
int taxisInqVtime(int taxisID)
{
static char func[] = "taxisInqVtime";
TAXIS *taxisptr;
taxisCheckID(func, taxisID);
taxisptr = taxis_to_pointer(taxisID);
return (taxisTable[taxisID].vtime);
taxis_check_ptr(func, taxisptr);
return (taxisptr->vtime);
}
......@@ -514,16 +685,19 @@ The function @func{taxisInqRdate} returns the reference date of a Time axis.
int taxisInqRdate(int taxisID)
{
static char func[] = "taxisInqRdate";
TAXIS *taxisptr;
taxisptr = taxis_to_pointer(taxisID);
taxisCheckID(func, taxisID);
taxis_check_ptr(func, taxisptr);
if ( taxisTable[taxisID].rdate == -1 )
if ( taxisptr->rdate == -1 )
{
taxisTable[taxisID].rdate = taxisTable[taxisID].vdate;
taxisTable[taxisID].rtime = taxisTable[taxisID].vtime;
taxisptr->rdate = taxisptr->vdate;
taxisptr->rtime = taxisptr->vtime;
}
return (taxisTable[taxisID].rdate);
return (taxisptr->rdate);
}
......@@ -546,16 +720,19 @@ The function @func{taxisInqRtime} returns the reference time of a Time axis.
int taxisInqRtime(int taxisID)
{
static char func[] = "taxisInqRtime";
TAXIS *taxisptr;