Update of /cvsroot/monetdb/MonetDB5/src/optimizer
In directory sc8-pr-cvs16.sourceforge.net:/tmp/cvs-serv11396/optimizer
Modified Files:
opt_replicator.mx
Log Message:
Collect statistics for executions of select
Index: opt_replicator.mx
===================================================================
RCS file: /cvsroot/monetdb/MonetDB5/src/optimizer/opt_replicator.mx,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -d -r1.5 -r1.6
--- opt_replicator.mx 29 Jan 2008 09:09:43 -0000 1.5
+++ opt_replicator.mx 30 Jan 2008 17:29:05 -0000 1.6
@@ -51,6 +51,15 @@
pattern
replicator.uselect(dst:bat[:any_1,:any_2],low:any_2,hgh:any_2):bat[:any_1,:any_2]
address REPuselect
comment "The overloaded uselect operator for replicated operations";
+
+command init():void
+address REPinit
+comment "Initialize replica table"
+
+command dump():void
+address REPdump
+comment "Dump summary of replica table for potential re-use benefits"
+
@h
#ifndef _OPT_REPLICATOR_
#define _OPT_REPLICATOR_
@@ -62,12 +71,54 @@
opt_export str REPuselect(MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
opt_export str REPprelude(MalBlkPtr mb, MalStkPtr stk, InstrPtr pci);
+opt_export str REPinit(void);
+opt_export str REPdump(void);
+
/* #define DEBUG_OPT_REPLICATOR */
@-
@c
#include "mal_config.h"
#include "opt_replicator.h"
+typedef struct REPLICAREC {
+ bat srcbid, resbid; /* partition BAT, back into BBP */
+
+ ValRecord low,hgh; /* selected tail range */
+ bit li, hi; /* inclusive bits */
+ size_t cnt; /* how many tuples */
+ dbl cost; /* how much time was spent to produce */
+ MalBlkPtr malblk; /* mal instruction block*/
+} *Replica, ReplicaRec;
+
+static Replica repltable = NULL;
+static int replsz = 0; /* alloc. mem */
+static int replnr = 0; /* number of replicas */
+
+static void assureSpace(){
+ if ( replsz == 0){
+ replsz = 16;
+ repltable = (ReplicaRec*)GDKzalloc((replsz)*sizeof(ReplicaRec));
+ }
+ else if( replnr == replsz){
+ replsz <<=1;
+ repltable = (ReplicaRec*) GDKrealloc((void*)repltable,
+ sizeof(ReplicaRec) * replsz);
+ }
+}
+
+str
+REPinit(){
+ str msg= MAL_SUCCEED;
+
+ if ( repltable != NULL){
+ GDKfree(repltable);
+ replsz = replnr = 0;
+ }
+ assureSpace();
+ return msg;
+}
+
+
static int
OPTreplicatorImplementation(MalBlkPtr mb, MalStkPtr stk, InstrPtr p)
{
@@ -148,6 +199,7 @@
bit t=TRUE,*li=&t,*hi=&t;
BAT *b;
lng cnt,clk;
+ Replica r;
str msg= MAL_SUCCEED;
(void) mb;
@@ -165,11 +217,21 @@
clk= GDKusec()-clk;
/* time for the decision */
- if ( (b=BATdescriptor(*bid)) == NULL)
+ if ( (b=BATdescriptor(*ret)) == NULL)
throw(MAL,"replicator.select","can not access BAT");
cnt= BATcount(b);
- (void) cnt;
- (void) clk;
+ /* keep stat */
+ assureSpace();
+ r = repltable + replnr;
+ r->srcbid = *bid;
+ r->resbid = *ret;
+ VALset(&r->low,b->ttype,(ValPtr) low);
+ VALset(&r->hgh,b->ttype,(ValPtr) hgh);
+ r->li = *li;
+ r->hi = *hi;
+ r->cnt = cnt;
+ r->cost = clk;
+ replnr++;
BBPunfix(b->batCacheid);
return msg;
-------------------------------------------------------------------------
This SF.net email is sponsored by: Microsoft
Defy all challenges. Microsoft(R) Visual Studio 2008.
http://clk.atdmt.com/MRT/go/vse0120000070mrt/direct/01/
_______________________________________________
Monetdb-checkins mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/monetdb-checkins
