MonetDB: default - Enable commit of the BBP.dir

[mk]

Changeset: baacec02c880 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=baacec02c880
Modified Files:
        MonetDB5/src/modules/mal/bbp.mx
Branch: default
Log Message:

Enable commit of the BBP.dir
This should be called when you want to pass a persitent BAT
to other servers on the same file system.


diffs (71 lines):

diff -r 357b11b1c034 -r baacec02c880 MonetDB5/src/modules/mal/bbp.mx
--- a/MonetDB5/src/modules/mal/bbp.mx   Sun Oct 03 20:16:24 2010 +0200
+++ b/MonetDB5/src/modules/mal/bbp.mx   Sun Oct 03 20:17:58 2010 +0200
@@ -61,6 +61,9 @@
 pattern deposit(name:str,loc:str) :bat[:any_1,:any_2]
 address CMDbbpbindDefinition
 comment "Relate a logical name to a physical BAT in the buffer pool.";
+command commit(b:bat[:any_1,:any_2]):void      
+address CMDbbpSubCommit
+comment "Commit updates for single BAT.";
 pattern commit():void  
 address CMDbbpReleaseAll
 comment "Commit updates for this client.";
@@ -146,6 +149,9 @@
 buffer pool
 @}
 @mal
+command getIndex(b:bat[:any_1,:any_2]):int
+address CMDbbpgetIndex
+comment "Retrieve the index in the BBP";
 command getHeadType() :bat[:int,:str]          
 address CMDbbpHeadType
 comment "Map a BAT into its head type";
@@ -248,6 +254,7 @@
 bbp_export str CMDbbpreleaseBAT(Client cntxt, MalBlkPtr mb, MalStkPtr stk, 
InstrPtr pci);
 bbp_export str CMDbbpdestroyBAT(Client cntxt, MalBlkPtr mb, MalStkPtr stk, 
InstrPtr pci);
 bbp_export str CMDbbpdestroyBAT1(Client cntxt, MalBlkPtr mb, MalStkPtr stk, 
InstrPtr pci);
+bbp_export str CMDbbpSubCommit(int *ret, int *bid);
 bbp_export str CMDbbpReleaseAll(Client cntxt, MalBlkPtr mb, MalStkPtr stk, 
InstrPtr pci);
 bbp_export str CMDbbpdiscard(Client cntxt, MalBlkPtr mb, MalStkPtr stk, 
InstrPtr pci);
 bbp_export str CMDbbptoStr(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr 
pci);
@@ -268,6 +275,7 @@
 bbp_export str CMDbbpKind(int *ret);
 bbp_export str CMDbbpRefCount(int *ret);
 bbp_export str CMDbbpLRefCount(int *ret);
+bbp_export str CMDbbpgetIndex(int *res, int *bid);
 bbp_export str CMDgetBATrefcnt(int *res, int *bid);
 bbp_export str CMDgetBATlrefcnt(int *res, int *bid);
 bbp_export str CMDbbpcompress(int *ret, int *bid, str *fnme);
@@ -891,6 +899,17 @@
 }
 
 str
+CMDbbpSubCommit(int *ret, int *bid)
+{
+       bat list[2];
+       list[0] = 0;    /* dummy */
+       list[1] = *bid;
+       BBPdir(2,list);
+       (void) ret;
+       return MAL_SUCCEED;
+}
+
+str
 CMDbbpReleaseAll(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci)
 {
        Box box;
@@ -1301,6 +1320,13 @@
 }
 
 str
+CMDbbpgetIndex(int *res, int *bid)
+{
+       *res= *bid;
+       return MAL_SUCCEED;
+}
+
+str
 CMDgetBATrefcnt(int *res, int *bid)
 {
        BAT *b;
_______________________________________________
Checkin-list mailing list
Checkin-list@monetdb.org
http://mail.monetdb.org/mailman/listinfo/checkin-list