Changeset: 934dbfa3c66b for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=934dbfa3c66b
Added Files:
sql/test/BugTracker-2016/Tests/RELEASE_SAVEPOINT_after_ALTER_TABLE_crash.Bug-4010.sql
sql/test/BugTracker-2016/Tests/RELEASE_SAVEPOINT_after_ALTER_TABLE_crash.Bug-4010.stable.err
sql/test/BugTracker-2016/Tests/RELEASE_SAVEPOINT_after_ALTER_TABLE_crash.Bug-4010.stable.out
Modified Files:
monetdb5/mal/mal_instruction.c
monetdb5/mal/mal_namespace.c
sql/backends/monet5/sql_decimal.mal
sql/backends/monet5/sql_decimal.mal.sh
sql/backends/monet5/sql_decimal_hge.mal
sql/backends/monet5/sql_decimal_hge.mal.sh
sql/test/BugTracker-2016/Tests/All
Branch: default
Log Message:
Merge with Jun2016 branch.
diffs (truncated from 2005 to 300 lines):
diff --git a/monetdb5/mal/mal_instruction.c b/monetdb5/mal/mal_instruction.c
--- a/monetdb5/mal/mal_instruction.c
+++ b/monetdb5/mal/mal_instruction.c
@@ -929,7 +929,7 @@ cloneVariable(MalBlkPtr tm, MalBlkPtr mb
return res;
}
-/* generate a new variable name based on a patter with 1 %d argument*/
+/* generate a new variable name based on a pattern with 1 %d argument*/
void
renameVariable(MalBlkPtr mb, int id, str pattern, int newid)
{
diff --git a/monetdb5/mal/mal_namespace.c b/monetdb5/mal/mal_namespace.c
--- a/monetdb5/mal/mal_namespace.c
+++ b/monetdb5/mal/mal_namespace.c
@@ -19,57 +19,49 @@
#define HASHMASK 4095
/* taken from gdk_atoms */
-#define NME_HASH(x,y,K) \
- do { \
- const char *_key = (const char *) (x); \
- size_t _i; \
- for (_i = y = 0; K-- && _key[_i]; _i++) { \
- y += _key[_i]; \
- y += (y << 10); \
- y ^= (y >> 6); \
- } \
- y += (y << 3); \
- y ^= (y >> 11); \
- y += (y << 15); \
- y = y & HASHMASK; \
+#define NME_HASH(_key,y,K)
\
+ do {
\
+ size_t _i;
\
+ for (_i = y = 0; _i < K && _key[_i]; _i++) { \
+ y += _key[_i];
\
+ y += (y << 10);
\
+ y ^= (y >> 6);
\
+ }
\
+ y += (y << 3);
\
+ y ^= (y >> 11);
\
+ y += (y << 15);
\
+ y = y & HASHMASK;
\
} while (0)
typedef struct NAME{
- size_t length;
struct NAME *next;
- char nme[FLEXIBLE_ARRAY_MEMBER];
+ char nme[IDLENGTH + 1];
+ unsigned short length;
} *NamePtr;
-static NamePtr *hash= NULL, *ehash = NULL;
+static NamePtr hash[MAXIDENTIFIERS];
+
+static struct namespace {
+ struct namespace *next;
+ int count;
+ struct NAME data[4096];
+} *namespace;
void initNamespace(void) {
- if(hash == NULL) hash= (NamePtr *) GDKzalloc(sizeof(NamePtr) *
MAXIDENTIFIERS);
- if(ehash == NULL) ehash= (NamePtr *) GDKzalloc(sizeof(NamePtr) *
MAXIDENTIFIERS);
- if ( hash == NULL || ehash == NULL){
- /* absolute an error we can not recover from */
- showException(GDKout, MAL,"initNamespace",MAL_MALLOC_FAIL);
- mal_exit();
- }
}
void mal_namespace_reset(void) {
- int i;
- NamePtr n,m;
+ struct namespace *ns;
/* assume we are at the end of the server session */
MT_lock_set(&mal_namespaceLock);
- for ( i =0; i < HASHMASK; i++){
- n = hash[i];
- hash[i] = ehash[i] = 0;
- for( ; n; n = m){
- m = n->next;
- GDKfree(n);
- }
+ memset(hash, 0, sizeof(hash));
+ while (namespace) {
+ ns = namespace->next;
+ GDKfree(namespace);
+ namespace = ns;
}
- GDKfree(hash);
- GDKfree(ehash);
- hash = ehash = 0;
MT_lock_unset(&mal_namespaceLock);
}
@@ -80,29 +72,76 @@ void mal_namespace_reset(void) {
* is conflict free.
*/
+static str findName(const char *nme, size_t len, int allocate)
+{
+ NamePtr *n, m;
+ size_t key;
+
+ assert(len == 0 || nme != NULL);
+ if (len == 0 || nme == NULL)
+ return NULL;
+ if (len > IDLENGTH) {
+ len = IDLENGTH;
+ }
+ NME_HASH(nme, key, len);
+ MT_lock_set(&mal_namespaceLock);
+ for (n = &hash[key]; *n; n = &(*n)->next) {
+#ifdef KEEP_SORTED
+ /* keep each list sorted on length, then name */
+ if (len < (*n)->length)
+ continue;
+ if (len == (*n)->length) {
+ int c;
+ if ((c = strncmp(nme, (*n)->nme, len)) < 0)
+ continue;
+ if (c == 0) {
+ MT_lock_unset(&mal_namespaceLock);
+ return (*n)->nme;
+ }
+ break;
+ }
+ break;
+#else
+ /* append entries to list */
+ if (len == (*n)->length && strncmp(nme, (*n)->nme, len) == 0) {
+ MT_lock_unset(&mal_namespaceLock);
+ return (*n)->nme;
+ }
+#endif
+ }
+ /* item not found */
+ if (!allocate) {
+ MT_lock_unset(&mal_namespaceLock);
+ return NULL;
+ }
+ if (namespace == NULL || namespace->count == 4096) {
+ struct namespace *ns = GDKmalloc(sizeof(struct namespace));
+ if (ns == NULL) {
+ /* error we cannot recover from */
+ showException(GDKout, MAL, "findName", MAL_MALLOC_FAIL);
+ mal_exit();
+ }
+ ns->next = namespace;
+ ns->count = 0;
+ namespace = ns;
+ }
+ m = &namespace->data[namespace->count++];
+ strncpy(m->nme, nme, len);
+ m->nme[len] = 0;
+ m->length = (unsigned short) len;
+ m->next = *n;
+ *n = m;
+ MT_lock_unset(&mal_namespaceLock);
+ return (*n)->nme;
+}
+
str getName(const char *nme) {
- return getNameLen(nme, strlen(nme));
+ return findName(nme, strlen(nme), 0);
}
str getNameLen(const char *nme, size_t len)
{
- NamePtr n;
- size_t l = len, key;
-
- if(len == 0 || nme== NULL || *nme==0)
- return NULL;
- if(len>=MAXIDENTLEN)
- len = MAXIDENTLEN - 1;
- NME_HASH(nme, key, l);
- if ( ( n = hash[(int)key]) == 0)
- return NULL;
-
- do {
- if (len == n->length && strncmp(nme,n->nme,len)==0)
- return n->nme;
- n = n->next;
- } while (n);
- return NULL;
+ return findName(nme, len, 0);
}
/*
* Name deletion from the namespace is tricky, because there may
@@ -121,48 +160,10 @@ void delName(const char *nme, size_t len
}
str putName(const char *nme) {
- return putNameLen(nme, strlen(nme));
+ return findName(nme, strlen(nme), 1);
}
str putNameLen(const char *nme, size_t len)
{
- size_t l,k;
- int key;
- str fnd;
- NamePtr n;
-
- fnd = getNameLen(nme,len);
- if ( fnd )
- return fnd;
-
- if( nme == NULL || len == 0)
- return NULL;
-
- /* construct a new entry */
- if(len>=MAXIDENTLEN)
- len = MAXIDENTLEN - 1;
- n = GDKmalloc(offsetof(struct NAME, nme) + len + 1);
- if ( n == NULL) {
- /* absolute an error we can not recover from */
- showException(GDKout, MAL,"initNamespace",MAL_MALLOC_FAIL);
- mal_exit();
- }
- memcpy(n->nme, nme, len);
- n->nme[len]=0;
- n->length = len;
- n->next = NULL;
- l = len;
- NME_HASH(nme, k, l);
- key = (int) k;
-
- MT_lock_set(&mal_namespaceLock);
- /* add new elements to the end of the list */
- if ( ehash[key] == 0)
- hash[key] = ehash[key] = n;
- else {
- ehash[key]->next = n;
- ehash[key] = n;
- }
- MT_lock_unset(&mal_namespaceLock);
- return putNameLen(nme, len); /* just to be sure */
+ return findName(nme, len, 1);
}
diff --git a/sql/backends/monet5/sql_decimal.mal
b/sql/backends/monet5/sql_decimal.mal
--- a/sql/backends/monet5/sql_decimal.mal
+++ b/sql/backends/monet5/sql_decimal.mal
@@ -6,853 +6,853 @@
# This file was generated by using the script sql_decimal.mal.sh.
-command calc.bte( v:flt, digits:int, scale:int ) :bte
+command calc.bte(v:flt, digits:int, scale:int) :bte
address flt_num2dec_bte
comment "cast number to decimal(bte) and check for overflow";
-command batcalc.bte( v:bat[:flt], digits:int, scale:int ) :bat[:bte]
+command batcalc.bte(v:bat[:flt], digits:int, scale:int) :bat[:bte]
address batflt_num2dec_bte
comment "cast number to decimal(bte) and check for overflow";
-command calc.bte( v:dbl, digits:int, scale:int ) :bte
+command calc.bte(v:dbl, digits:int, scale:int) :bte
address dbl_num2dec_bte
comment "cast number to decimal(bte) and check for overflow";
-command batcalc.bte( v:bat[:dbl], digits:int, scale:int ) :bat[:bte]
+command batcalc.bte(v:bat[:dbl], digits:int, scale:int) :bat[:bte]
address batdbl_num2dec_bte
comment "cast number to decimal(bte) and check for overflow";
-command calc.sht( v:flt, digits:int, scale:int ) :sht
+command calc.sht(v:flt, digits:int, scale:int) :sht
address flt_num2dec_sht
comment "cast number to decimal(sht) and check for overflow";
-command batcalc.sht( v:bat[:flt], digits:int, scale:int ) :bat[:sht]
+command batcalc.sht(v:bat[:flt], digits:int, scale:int) :bat[:sht]
address batflt_num2dec_sht
comment "cast number to decimal(sht) and check for overflow";
-command calc.sht( v:dbl, digits:int, scale:int ) :sht
+command calc.sht(v:dbl, digits:int, scale:int) :sht
address dbl_num2dec_sht
comment "cast number to decimal(sht) and check for overflow";
-command batcalc.sht( v:bat[:dbl], digits:int, scale:int ) :bat[:sht]
+command batcalc.sht(v:bat[:dbl], digits:int, scale:int) :bat[:sht]
address batdbl_num2dec_sht
comment "cast number to decimal(sht) and check for overflow";
-command calc.int( v:flt, digits:int, scale:int ) :int
+command calc.int(v:flt, digits:int, scale:int) :int
address flt_num2dec_int
comment "cast number to decimal(int) and check for overflow";
-command batcalc.int( v:bat[:flt], digits:int, scale:int ) :bat[:int]
+command batcalc.int(v:bat[:flt], digits:int, scale:int) :bat[:int]
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list
