Changeset: ca15cab457b8 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=ca15cab457b8
Modified Files:
        monetdb5/modules/mal/Tests/All
        monetdb5/modules/mal/Tests/remote07.mal
        monetdb5/modules/mal/Tests/remote88.mal
Branch: default
Log Message:

Minor textual changes to remote tests


diffs (104 lines):

diff --git a/monetdb5/modules/mal/Tests/All b/monetdb5/modules/mal/Tests/All
--- a/monetdb5/modules/mal/Tests/All
+++ b/monetdb5/modules/mal/Tests/All
@@ -36,6 +36,7 @@ remote02
 HAVE_GEOM?remote03
 remote04
 remote06
+# should be run as 'mclient -d demo -l mal remote07.mal
 remote08
 remote09
 remote11
diff --git a/monetdb5/modules/mal/Tests/remote07.mal 
b/monetdb5/modules/mal/Tests/remote07.mal
--- a/monetdb5/modules/mal/Tests/remote07.mal
+++ b/monetdb5/modules/mal/Tests/remote07.mal
@@ -2,20 +2,20 @@
 uri := sabaoth.getLocalConnectionURI();
 conn:str := remote.connect(uri, "monetdb", "monetdb");
 
-d:bat[:str,:int] := bat.new(:str, :int);
-bat.insert(d, "bla", 1);
-bat.insert(d, nil:str, 2);
-bat.insert(d, "boe", nil:int);
-bat.insert(d, d); # 6
-bat.insert(d, d); # 12
-bat.insert(d, d); # 24
-bat.insert(d, d); # 48
-bat.insert(d, d); # 96
-bat.insert(d, d); # 192
-bat.insert(d, d); # 384
-bat.insert(d, d); # 768
-bat.insert(d, d); # 1536
-bat.insert(d, d); # 3072
+d:bat[:oid,:str] := bat.new(:oid,:str);
+bat.append(d, "bla");
+bat.append(d, nil:str);
+bat.append(d, "boe");
+bat.append(d, d); # 6
+bat.append(d, d); # 12
+bat.append(d, d); # 24
+bat.append(d, d); # 48
+bat.append(d, d); # 96
+bat.append(d, d); # 192
+bat.append(d, d); # 384
+bat.append(d, d); # 768
+bat.append(d, d); # 1536
+bat.append(d, d); # 3072
 
 # store the values
 t1 := alarm.time();
@@ -26,7 +26,7 @@ io.printf("# put: %d\n", t3);
 
 # retrieve the values
 t1 := alarm.time();
-u:bat[:str,:int] := remote.get(conn, l);
+u:bat[:oid,:str] := remote.get(conn, l);
 t2 := alarm.time();
 t3 := t2 - t1;
 io.printf("# get: %d\n", t3);
diff --git a/monetdb5/modules/mal/Tests/remote88.mal 
b/monetdb5/modules/mal/Tests/remote88.mal
--- a/monetdb5/modules/mal/Tests/remote88.mal
+++ b/monetdb5/modules/mal/Tests/remote88.mal
@@ -1,10 +1,8 @@
 # test octopus framework
-include sql;
+#include sql;
 # The script occassionally showed parallism errors.
-#profiler.activate("statement");
-#profiler.setFilter("*","*");
-#profiler.openStream("console");
-#profiler.start();
+
+module octopus;
 
 function octopus.bind(v:int):bat[:oid,:int];
        b:= bat.new(:oid,:int);
@@ -38,13 +36,14 @@ function octopus.exec(uri:str, query:str
        # this works with uri, because head and tentacle are the same */
        v:= remote.exec(conn,"octopus", query, m, u);
        res:bat[:oid,:int]:= remote.get(conn,v);
+       io.print(res);
        remote.disconnect(conn);
        return exec:=res;
 end exec;
 
 uri := sabaoth.getLocalConnectionURI();
 
-barrier (k,v):= language.newRange(0:int);
+barrier v:= 0:int;
        io.print(v);
 barrier go:= language.dataflow();
        v1:bat[:oid,:int] :=octopus.exec(uri, "tentacle", v);
@@ -52,8 +51,10 @@ barrier go:= language.dataflow();
        v3:bat[:oid,:int] :=octopus.exec(uri, "tentacle", v);
        v4:bat[:oid,:int] :=octopus.exec(uri, "tentacle", v);
        res:= mat.pack(v1,v2,v3,v4);
+       language.pass(uri);
+       language.pass(v);
 exit go;
-       redo (k,v) := language.nextElement(1:int,25:int);
-exit (k,v);
+       redo v := iterator.next(1:int,25:int);
+exit v;
 z:=clients.getUsers();
 io.print(z);
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list

Reply via email to