bat_insert.stable.out

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

stdout of test 'bat_insert` in directory 'tests/gdkTests` itself:


# 20:34:11 >  
# 20:34:11 >  Mtimeout -timeout 60 mserver5 "--config=/ufs/mk/monet5/Linux/etc/MonetDB5.conf" --debug=10 --set "monet_mod_path=/ufs/mk/monet5/Linux/lib/MonetDB5:/ufs/mk/opensource/MonetDB/Linux/lib/MonetDB" --set "gdk_dbfarm=/ufs/mk/monet5/Linux/var/MonetDB5/dbfarm" --set "sql_logdir=/ufs/mk/monet5/Linux/var/MonetDB5/dblogs" --set mapi_port=38345 --set monet_prompt= --trace --dbname=mTests_tests_gdkTests  bat_insert.mal < /dev/null
# 20:34:11 >  

# MonetDB Server v4.99.19
# Copyright (c) 1993-2006 CWI, all rights reserved
# Compiled for x86_64-redhat-linux-gnu/64bit with 64bit OIDs dynamically linked
# config:/ufs/mk/monet5/Linux/etc/MonetDB5.conf
# dbfarm:/ufs/mk/monet5/Linux/var/MonetDB5/dbfarm
# dbname:mTests_tests_gdkTests
# Visit http://monetdb.cwi.nl/ for further information
#function check_cap(b:bat[:any_1,:any_2]) :void;
#	inserted := aggr.count(b);
#	d:= bat.getDelta(b);
#	d1 := aggr.count(d);
#	deleted := calc.lng(d1);
#	cap := bat.getCapacity(b);
#	overflow := inserted + deleted;
#	overflow := overflow - cap;
#barrier errors:= overflow > 0:lng;
#		io.printf("!ERROR: wrote %d BUNs beyond capacity\n",overflow);
#exit errors;
#end check_cap;
function user.check_cap(b:bat[:any_1,:any_2]):void;	# 0  (check_cap:void)<-(b:bat[:any_1,:any_2])
    inserted := aggr.count(b);	# 1 ALGcount_bat (inserted:int)<-(b:bat[:any_1,:any_2])
    d := bat.getDelta(b);	# 2 BKCgetDelta (d:bat[:any,:any])<-(b:bat[:any_1,:any_2])
    d1 := aggr.count(d);	# 3 ALGcount_bat (d1:int)<-(d:bat[:any,:any])
    deleted := calc.lng(d1);	# 4 CALCint2lng (deleted:lng)<-(d1:int)
    cap := bat.getCapacity(b);	# 5 BKCgetCapacity (cap:lng)<-(b:bat[:any_1,:any_2])
    overflow := calc.+(inserted,deleted);	# 6 CALCbinaryADDintlng (overflow:lng)<-(inserted:int)(deleted:lng)
    overflow := calc.-(overflow,cap);	# 7 CALCbinarySUBlnglng (overflow:lng)<-(overflow:lng)(cap:lng)
barrier errors := calc.>(overflow,0:lng);	# 8 CALCcompGTlnglng (errors:bit)<-(overflow:lng)(_9:lng) jump 10
    io.printf("!ERROR: wrote %d BUNs beyond capacity\n",overflow);	# 9 IOprint_formatted_lng (_10:void)<-(_11:str)(overflow:lng)
exit errors;	# 10  (errors:bit)
end check_cap;	# 11  
#
#b := bat.new(:oid,:oid);
#bat.setName(b,"b");
#bat.setPersistent(b,true);
#
#cap := bat.getCapacity(b);
#cap := cap/4;
#ci  := calc.int(cap);
#ci := ci+ 1;
#
#i := ci * 3;
#barrier go:= i>0;
#	o:= calc.oid(i);
#	bat.insert(b,o,o);
#	i:= i -1;
#	redo go:= i>0;
#exit go;
#
#transaction.commit();
#
#i := ci * 2;
#barrier go:= i>0;
#	o:= calc.oid(i);
#	bat.delete(b,o);
#	i:= i -1;
#	redo go:= i>0;
#exit go;
#
#c := bat.new(:oid,:oid);
#i := ci * 2;
#barrier go:= i>0;
#	o:= calc.oid(i);
#	bat.insert(c,o,o);
#	i:= i -1;
#	redo go:= i>0;
#exit go;
#
#bat.insert(b,c);
#check_cap(b);
#
#bat.setPersistent(b,false);
#
#transaction.commit();
#
#clients.quit();
#
function user.main():void;	# 0  (main:void)
    b := bat.new(:oid,:oid);	# 1 CMDBATnew (b:bat[:oid,:oid])<-(_2:oid)(_2:oid)
    bat.setName(b,"b");	# 2 BKCsetName (_3:void)<-(b:bat[:oid,:oid])(_4:str)
    bat.setPersistent(b,true);	# 3 BKCpersists (_5:void)<-(b:bat[:oid,:oid])(_6:bit)
    cap := bat.getCapacity(b);	# 4 BKCgetCapacity (cap:lng)<-(b:bat[:oid,:oid])
    cap := calc./(cap,4);	# 5 CALCbinarycheckDIVlngint (cap:lng)<-(cap:lng)(_8:int)
    ci := calc.int(cap);	# 6 CALClng2int (ci:int)<-(cap:lng)
    ci := calc.+(ci,1);	# 7 CALCbinaryADDintint (ci:int)<-(ci:int)(_10:int)
    i := calc.*(ci,3);	# 8 CALCbinaryMULintint (i:int)<-(ci:int)(_12:int)
barrier go := calc.>(i,0);	# 9 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 14
    o := calc.oid(i);	# 10 CALCint2oid (o:oid)<-(i:int)
    bat.insert(b,o,o);	# 11 BKCinsert_bun (_16:void)<-(b:bat[:oid,:oid])(o:oid)(o:oid)
    i := calc.-(i,1);	# 12 CALCbinarySUBintint (i:int)<-(i:int)(_10:int)
    redo go := calc.>(i,0);	# 13 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 10
exit go;	# 14  (go:bit)
    transaction.commit();	# 15 TRNglobal_commit (_17:bit)
    i := calc.*(ci,2);	# 16 CALCbinaryMULintint (i:int)<-(ci:int)(_18:int)
barrier go := calc.>(i,0);	# 17 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 22
    o := calc.oid(i);	# 18 CALCint2oid (o:oid)<-(i:int)
    bat.delete(b,o);	# 19 BKCdelete (_19:void)<-(b:bat[:oid,:oid])(o:oid)
    i := calc.-(i,1);	# 20 CALCbinarySUBintint (i:int)<-(i:int)(_10:int)
    redo go := calc.>(i,0);	# 21 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 18
exit go;	# 22  (go:bit)
    c := bat.new(:oid,:oid);	# 23 CMDBATnew (c:bat[:oid,:oid])<-(_2:oid)(_2:oid)
    i := calc.*(ci,2);	# 24 CALCbinaryMULintint (i:int)<-(ci:int)(_18:int)
barrier go := calc.>(i,0);	# 25 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 30
    o := calc.oid(i);	# 26 CALCint2oid (o:oid)<-(i:int)
    bat.insert(c,o,o);	# 27 BKCinsert_bun (_21:void)<-(c:bat[:oid,:oid])(o:oid)(o:oid)
    i := calc.-(i,1);	# 28 CALCbinarySUBintint (i:int)<-(i:int)(_10:int)
    redo go := calc.>(i,0);	# 29 CALCcompGTintint (go:bit)<-(i:int)(_14:int) jump 26
exit go;	# 30  (go:bit)
    bat.insert(b,c);	# 31 BKCinsert_bat (_22:void)<-(b:bat[:oid,:oid])(c:bat[:oid,:oid])
    user.check_cap(b);	# 32  (_23:void)<-(b:bat[:oid,:oid])
    bat.setPersistent(b,false);	# 33 BKCpersists (_24:void)<-(b:bat[:oid,:oid])(_25:bit)
    transaction.commit();	# 34 TRNglobal_commit (_26:bit)
    clients.quit();	# 35 CLTquitDefault (_27:void)
end main;	# 36  

# 20:34:11 >  
# 20:34:11 >  Done.
# 20:34:11 >