batcast.c

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

}
batcast_export str CMDconvert_void_str_int(int *ret, int *bid);
str CMDconvert_void_str_int(int *ret, int *bid){
	return CMDconvert_str_int(ret,bid);
}


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

	
#line 203 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
batcast_export str CMDconvert_lng_str(int *ret, int *bid);
str CMDconvert_lng_str(int *ret, int *bid){
	BAT *b,*bn;
	size_t xx;
	char *p,*q,*h;
	str dst=0;
	int len=0;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_str, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_str, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char*) BUNhead(b,BUNfirst(b));
	p= (char*) BUNfirst(b);
	q= (char*) BUNlast(b);
	xx= BUNsize(b);

	while(p<q){
		lng *r = (lng*)BUNtail(b,p);
		
#line 193 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		lngToStr(&dst,&len, (ptr) r);
		bunfastins(bn, h, (ptr)dst);
		if( dst) GDKfree(dst);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}
batcast_export str CMDconvert_void_lng_str(int *ret, int *bid);
str CMDconvert_void_lng_str(int *ret, int *bid){
	return CMDconvert_lng_str(ret,bid);
}

batcast_export str CMDconvert_str_lng(int *ret, int *bid);
str CMDconvert_str_lng(int *ret, int *bid){
	BAT *b,*bn;
	int xx;
	char *p,*q,*h;
	ptr v;
	int len;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.lng", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_lng, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_lng, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.lng", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char *) BUNhead(b,BUNfirst(b));
	p= (ptr) BUNtloc(b,BUNfirst(b));
	q= (char *) BUNtloc(b,BUNlast(b));
	xx= BUNsize(b);

	while(p<q){
		
#line 197 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		v= NULL; len=0;
		ATOMfromstr( TYPE_lng, &v, &len, (char*)Tbase(b)+*(var_t*)p);
		bunfastins(bn, h, v);
		if(ATOMextern(TYPE_lng) )
			GDKfree(v);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}
batcast_export str CMDconvert_void_str_lng(int *ret, int *bid);
str CMDconvert_void_str_lng(int *ret, int *bid){
	return CMDconvert_str_lng(ret,bid);
}


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

	
#line 203 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
batcast_export str CMDconvert_flt_str(int *ret, int *bid);
str CMDconvert_flt_str(int *ret, int *bid){
	BAT *b,*bn;
	size_t xx;
	char *p,*q,*h;
	str dst=0;
	int len=0;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_str, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_str, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char*) BUNhead(b,BUNfirst(b));
	p= (char*) BUNfirst(b);
	q= (char*) BUNlast(b);
	xx= BUNsize(b);

	while(p<q){
		flt *r = (flt*)BUNtail(b,p);
		
#line 193 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		fltToStr(&dst,&len, (ptr) r);
		bunfastins(bn, h, (ptr)dst);
		if( dst) GDKfree(dst);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}
batcast_export str CMDconvert_void_flt_str(int *ret, int *bid);
str CMDconvert_void_flt_str(int *ret, int *bid){
	return CMDconvert_flt_str(ret,bid);
}

batcast_export str CMDconvert_str_flt(int *ret, int *bid);
str CMDconvert_str_flt(int *ret, int *bid){
	BAT *b,*bn;
	int xx;
	char *p,*q,*h;
	ptr v;
	int len;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.flt", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_flt, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_flt, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.flt", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char *) BUNhead(b,BUNfirst(b));
	p= (ptr) BUNtloc(b,BUNfirst(b));
	q= (char *) BUNtloc(b,BUNlast(b));
	xx= BUNsize(b);

	while(p<q){
		
#line 197 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		v= NULL; len=0;
		ATOMfromstr( TYPE_flt, &v, &len, (char*)Tbase(b)+*(var_t*)p);
		bunfastins(bn, h, v);
		if(ATOMextern(TYPE_flt) )
			GDKfree(v);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}
batcast_export str CMDconvert_void_str_flt(int *ret, int *bid);
str CMDconvert_void_str_flt(int *ret, int *bid){
	return CMDconvert_str_flt(ret,bid);
}


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

	
#line 203 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
batcast_export str CMDconvert_dbl_str(int *ret, int *bid);
str CMDconvert_dbl_str(int *ret, int *bid){
	BAT *b,*bn;
	size_t xx;
	char *p,*q,*h;
	str dst=0;
	int len=0;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_str, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_str, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char*) BUNhead(b,BUNfirst(b));
	p= (char*) BUNfirst(b);
	q= (char*) BUNlast(b);
	xx= BUNsize(b);

	while(p<q){
		dbl *r = (dbl*)BUNtail(b,p);
		
#line 193 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		dblToStr(&dst,&len, (ptr) r);
		bunfastins(bn, h, (ptr)dst);
		if( dst) GDKfree(dst);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}
batcast_export str CMDconvert_void_dbl_str(int *ret, int *bid);
str CMDconvert_void_dbl_str(int *ret, int *bid){
	return CMDconvert_dbl_str(ret,bid);
}

batcast_export str CMDconvert_str_dbl(int *ret, int *bid);
str CMDconvert_str_dbl(int *ret, int *bid){
	BAT *b,*bn;
	int xx;
	char *p,*q,*h;
	ptr v;
	int len;

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if( ( b= BATdescriptor(*bid)) == NULL ){ ;
		 throw(MAL,  "batcalc.dbl", "cannot access descriptor");
   }


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

	
#line 96 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
    if (BAThvoid(b)) {
        bn = BATnew(TYPE_void, TYPE_dbl, BATcount(b));
        BATseqbase(bn, b->hseqbase);
    } else
        bn = BATnew(b->htype, TYPE_dbl, BATcount(b));
	if( bn== NULL) {
		
		throw(MAL, "batcalc.dbl", "can not create bat");
	}
    bn->hsorted = b->hsorted;
    bn->tsorted = b->tsorted;



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

	h= (char *) BUNhead(b,BUNfirst(b));
	p= (ptr) BUNtloc(b,BUNfirst(b));
	q= (char *) BUNtloc(b,BUNlast(b));
	xx= BUNsize(b);

	while(p<q){
		
#line 197 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
		v= NULL; len=0;
		ATOMfromstr( TYPE_dbl, &v, &len, (char*)Tbase(b)+*(var_t*)p);
		bunfastins(bn, h, v);
		if(ATOMextern(TYPE_dbl) )
			GDKfree(v);


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

		p+=xx; h+= xx;
	}
bunins_failed:
	
#line 133 "/export/scratch0/monet/monet.GNU.64.64.d.14791/MonetDB5/src/modules/kernel/batcast.mx"
	if (!(bn->batDirty&2)) bn = BATsetaccess(bn, BAT_READ);
	*ret= bn->batCacheid;
	BATkey(BATmirror(bn), FALSE);
	bn->tsorted = 0;
	BBPkeepref(*ret);
	BBPreleaseref(b->batCacheid);
	return MAL_SUCCEED;


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

}