batmtime.c

一个内存数据库的源代码这是服务器端还有客户端

	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 189 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"




#line 207 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 184 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_EQ(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.==");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.==");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.EQ","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_EQ(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_EQcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.==");
	prepareResult(bn,left,TYPE_bit,"batcalc.==");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.EQ","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_EQ(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 184 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_NEQ(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.!=");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.!=");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.NEQ","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_NEQ(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_NEQcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.!=");
	prepareResult(bn,left,TYPE_bit,"batcalc.!=");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.NEQ","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_NEQ(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 185 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_LT(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.<");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.<");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.LT","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_LT(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_LTcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.<");
	prepareResult(bn,left,TYPE_bit,"batcalc.<");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.LT","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_LT(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 186 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_LE(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.<=");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.<=");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.LE","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_LE(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_LEcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.<=");
	prepareResult(bn,left,TYPE_bit,"batcalc.<=");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.LE","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_LE(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 187 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_GT(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.>");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.>");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.GT","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_GT(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_GTcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.>");
	prepareResult(bn,left,TYPE_bit,"batcalc.>");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.GT","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_GT(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 188 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"


#line 113 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
str MTIMEtimestampbat_GE(int *ret, int *l, int *r)
{   BAT *bn, *left, *right;
	BUN o,p,q;
	bit *a;
	size_t xx,yy;

	prepareOperand2(left,l,right,r,"batcalc.>=");
	
#line 105 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"
	if( BATcount(left) != BATcount(right) )
	throw(MAL, "batcalc.CMDcomparetimestamp", "requires bats of identical size");



#line 120 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"

	prepareResult2(bn,left,right,TYPE_bit,"batcalc.>=");
	if( BUNsize(left) != sizeof(timestamp) || BUNsize(right)!= sizeof(timestamp) ){
		BBPreleaseref(right->batCacheid);
		BBPreleaseref(left->batCacheid);
		BBPreleaseref(bn->batCacheid);
		throw(MAL, "batmtime.GE","Unexpected input type");
	}

	o = BUNtail(left,BUNfirst(left));
	p = BUNtail(right,BUNfirst(right));
	q = BUNtail(right,BUNlast(right));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	yy= BUNsize(right);

	while(p<q) {
		MTIMEtimestamp_GE(a++, (timestamp*)o, (timestamp*)p);
		o+= xx;
		p+= yy;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	BBPreleaseref(right->batCacheid);
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}

str MTIMEtimestampbat_GEcst(int *ret, int *l, timestamp *cst)
{   BAT *bn, *left;
	BUN p,q;
	bit *a;
	size_t xx;

	prepareOperand(left,l,"batcalc.>=");
	prepareResult(bn,left,TYPE_bit,"batcalc.>=");
	if( BUNsize(left) != sizeof(timestamp))
		throw(MAL, "batmtime.GE","Unexpected input type");

	p = BUNtail(left,BUNfirst(left));
	q = BUNtail(left,BUNlast(left));
	a = (bit*)BUNtail(bn, BUNfirst(bn));
	xx= BUNsize(left);
	while(p<q) {
		MTIMEtimestamp_GE(a++, (timestamp*)p, cst);
		p+= xx;
	}
	BATsetcount(bn, BATcount(left));
 	bn->batBuns->free = ((char *)a) - bn->batBuns->base;
	finalizeResult(ret,bn,left);
	return MAL_SUCCEED;
}


#line 189 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"




#line 208 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"



#line 210 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batmtime.mx"