diff --git a/.gitattributes b/.gitattributes
index 9925b8b9cce44a6496073427b296302554ac644c..ef940629d6d6e361555745419b0fe9fc7b7c0efd 100644
--- a/.gitattributes
+++ b/.gitattributes
@@ -139,10 +139,12 @@ CEP/Imager/MWImager/test/tmwimager.in_ms2.vds -text
CEP/Imager/MWImager/test/tmwimager.in_vd -text
CEP/MS/test/tcombinevds.in_vds1 -text
CEP/MS/test/tcombinevds.in_vds2 -text
+CEP/ParmDB/src/parmdbremote-scr -text
CEP/ParmDB/src/setupparmdb -text
CEP/ParmDB/src/setupparmdb-part -text
CEP/ParmDB/src/setupsourcedb -text
CEP/ParmDB/src/setupsourcedb-part -text
+CEP/ParmDB/src/startparmdbdistr -text
CEP/ParmDB/test/tmakesourcedb.in_2 -text
CEP/ParmDB/test/tsetupparmdb.in_cd -text
CEP/ParmDB/test/tsetupparmdb.in_ms0.vds -text
diff --git a/CEP/ParmDB/include/ParmDB/ParmFacadeDistr.h b/CEP/ParmDB/include/ParmDB/ParmFacadeDistr.h
index 7f9e2c5ba70431c05f2313148fd472a85b0f420b..04da3873a52b04e5c9a5b2c305737b3c95b18c36 100644
--- a/CEP/ParmDB/include/ParmDB/ParmFacadeDistr.h
+++ b/CEP/ParmDB/include/ParmDB/ParmFacadeDistr.h
@@ -31,6 +31,11 @@
#include <MWCommon/SocketConnectionSet.h>
#include <Common/lofar_vector.h>
+//# Forward Declaration.
+namespace casa {
+ class Record;
+}
+
namespace LOFAR { namespace BBS {
@@ -114,7 +119,10 @@ namespace LOFAR { namespace BBS {
void freePort();
// </group>
- //# Data membe rs
+ // Read a Record from the BlobStream.
+ void getRecord (BlobIStream& bis, casa::Record& rec);
+
+ //# Data members
string itsPort; //# declare this before itsConn!!
mutable LOFAR::CEP::SocketConnectionSet itsConn;
static int theirNextPort;
diff --git a/CEP/ParmDB/src/Makefile.am b/CEP/ParmDB/src/Makefile.am
index 41369e2a3cca9dabd7e62a1553bf84d590affdc9..9eef613fbdf33cf12da315c11bd1cc58c8d7deba 100644
--- a/CEP/ParmDB/src/Makefile.am
+++ b/CEP/ParmDB/src/Makefile.am
@@ -15,15 +15,15 @@ SourceDB.cc SourceDBCasa.cc
# LEX_OUTPUT_ROOT = lex.KeyTokenize
bin_PROGRAMS = versionparmdb \
- parmdb parmdbclient makesourcedb
+ parmdb parmdbremote makesourcedb
parmdb_SOURCES = parmdb_main.cc
parmdb_LDADD = libparmdb.la
parmdb_DEPENDENCIES = libparmdb.la $(LOFAR_DEPEND)
-parmdbclient_SOURCES = parmdbclient.cc
-parmdbclient_LDADD = libparmdb.la
-parmdbclient_DEPENDENCIES = libparmdb.la $(LOFAR_DEPEND)
+parmdbremote_SOURCES = parmdbremote.cc
+parmdbremote_LDADD = libparmdb.la
+parmdbremote_DEPENDENCIES = libparmdb.la $(LOFAR_DEPEND)
makesourcedb_SOURCES = makesourcedb.cc
makesourcedb_LDADD = libparmdb.la
@@ -33,7 +33,9 @@ pythondir = $(bindir)
dist_python_SCRIPTS =
scriptdir = $(bindir)
-dist_script_SCRIPTS = setupparmdb setupparmdb-part
+dist_script_SCRIPTS = setupparmdb setupparmdb-part \
+ setupsourcedb setupsourcedb-part \
+ startparmdbdistr parmdbremote-scr
versionparmdb_SOURCES = versionparmdb.cc
versionparmdb_LDADD = libparmdb.la
diff --git a/CEP/ParmDB/src/ParmFacade.cc b/CEP/ParmDB/src/ParmFacade.cc
index 08f7d7dcc4e75cd80d18619a5bcbd88ec23fd004..b71752ca9acb0042656d507e025ba3679a16a641 100644
--- a/CEP/ParmDB/src/ParmFacade.cc
+++ b/CEP/ParmDB/src/ParmFacade.cc
@@ -23,6 +23,8 @@
#include <lofar_config.h>
#include <ParmDB/ParmFacade.h>
#include <ParmDB/ParmFacadeLocal.h>
+#include <ParmDB/ParmFacadeDistr.h>
+#include <tables/Tables/Table.h>
using namespace std;
using namespace casa;
@@ -37,8 +39,15 @@ namespace LOFAR {
namespace BBS {
ParmFacade::ParmFacade (const string& tableName)
- : itsRep(new ParmFacadeLocal(tableName))
- {}
+ {
+ // If it is a table, open it directly.
+ // Otherwise it is a distributed ParmDB.
+ if (Table::isReadable(tableName)) {
+ itsRep = ParmFacadeRep::ShPtr(new ParmFacadeLocal(tableName));
+ } else {
+ itsRep = ParmFacadeRep::ShPtr(new ParmFacadeDistr(tableName));
+ }
+ }
ParmFacade::~ParmFacade()
{}
diff --git a/CEP/ParmDB/src/ParmFacadeDistr.cc b/CEP/ParmDB/src/ParmFacadeDistr.cc
index 327fbf69c14546d1c5a0059f200d61606c434dd8..82acd3f8cfb9863e540dde52171ab7cf637694f1 100644
--- a/CEP/ParmDB/src/ParmFacadeDistr.cc
+++ b/CEP/ParmDB/src/ParmFacadeDistr.cc
@@ -28,6 +28,7 @@
#include <Blob/BlobAipsIO.h>
#include <Common/LofarLogger.h>
#include <casa/IO/AipsIO.h>
+#include <Common/lofar_iostream.h>
using namespace LOFAR::CEP;
using namespace casa;
@@ -50,23 +51,29 @@ namespace LOFAR {
: itsPort (getPort()),
itsConn (itsPort)
{
- VdsDesc vds(tableName);
- int nparts = vds.getParts().size();
- string cdescName = vds.getDesc().getClusterDescName();
- // Start all clients.
- string command("startdistproc -mode " + itsPort +
- " -nowait -nomasterhost -cdn " +
- cdescName + " parmdbclient");
+ // Get info from VDS. It is automatically closed thereafter.
+ int nparts;
+ string cdescName;
+ {
+ VdsDesc vds(tableName);
+ nparts = vds.getParts().size();
+ cdescName = vds.getDesc().getClusterDescName();
+ }
+ // Start all remote processes.
+ string command("startparmdbdistr " + itsPort + ' ' +
+ cdescName + ' ' + tableName);
+ ASSERT (system(command.c_str()) == 0);
// Accept a connection from the clients and check if they are
// initialized correctly.
itsConn.addConnections (nparts);
- ASSERT (system(command.c_str()) == 0);
BlobString buf;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
- bbi.finish();
ASSERT (bbi.getOperation() == 1); // ensure successful init
+ string fname;
+ bbi.blobStream() >> fname;
+ bbi.finish();
}
}
@@ -110,14 +117,23 @@ namespace LOFAR {
bbo.blobStream() << parmNamePattern;
bbo.finish();
itsConn.writeAll (buf);
+ vector<double> range, result;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
+ ASSERT (bbi.getOperation() == 1); // ensure success
+ if (i == 0) {
+ bbi.blobStream() >> result;
+ } else {
+ bbi.blobStream() >> range;
+ if (range[0] < result[0]) result[0] = range[0];
+ if (range[1] > result[1]) result[1] = range[1];
+ if (range[2] < result[2]) result[2] = range[2];
+ if (range[3] > result[3]) result[3] = range[3];
+ }
bbi.finish();
- ASSERT (bbi.getOperation() == 1); // ensure successful init
}
- vector<double> res(4);
- return res;
+ return result;
}
// Get all parameter names in the table.
@@ -128,14 +144,19 @@ namespace LOFAR {
bbo.blobStream() << parmNamePattern;
bbo.finish();
itsConn.writeAll (buf);
+ vector<string> names, result;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
+ ASSERT (bbi.getOperation() == 1); // ensure success
+ if (i == 0) {
+ bbi.blobStream() >> result;
+ } else {
+ bbi.blobStream() >> names;
+ }
bbi.finish();
- ASSERT (bbi.getOperation() == 1); // ensure successful init
}
- vector<string> res;
- return res;
+ return result;
}
Record ParmFacadeDistr::getValues (const string& parmNamePattern,
@@ -145,17 +166,24 @@ namespace LOFAR {
{
BlobString buf;
MWBlobOut bbo(buf, 3, 0);
- bbo.blobStream() << parmNamePattern;
+ bbo.blobStream() << parmNamePattern
+ << freqv1 << freqv2 << nfreq
+ << timev1 << timev2 << ntime << asStartEnd;
bbo.finish();
itsConn.writeAll (buf);
+ Record values, result;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
+ ASSERT (bbi.getOperation() == 1); // ensure success
+ if (i == 0) {
+ getRecord (bbi.blobStream(), result);
+ } else {
+ getRecord (bbi.blobStream(), values);
+ }
bbi.finish();
- ASSERT (bbi.getOperation() == 1); // ensure successful init
}
- Record res;
- return res;
+ return result;
}
Record ParmFacadeDistr::getValues (const string& parmNamePattern,
@@ -167,17 +195,23 @@ namespace LOFAR {
{
BlobString buf;
MWBlobOut bbo(buf, 4, 0);
- bbo.blobStream() << parmNamePattern;
+ bbo.blobStream() << parmNamePattern
+ << freqv1 << freqv2 << timev1 << timev2 << asStartEnd;
bbo.finish();
itsConn.writeAll (buf);
+ Record values, result;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
+ ASSERT (bbi.getOperation() == 1); // ensure success
+ if (i == 0) {
+ getRecord (bbi.blobStream(), result);
+ } else {
+ getRecord (bbi.blobStream(), values);
+ }
bbi.finish();
- ASSERT (bbi.getOperation() == 1); // ensure successful init
}
- Record res;
- return res;
+ return result;
}
Record ParmFacadeDistr::getValuesGrid (const string& parmNamePattern,
@@ -186,17 +220,30 @@ namespace LOFAR {
{
BlobString buf;
MWBlobOut bbo(buf, 5, 0);
- bbo.blobStream() << parmNamePattern;
+ bbo.blobStream() << parmNamePattern
+ << sfreq << efreq << stime << etime;
bbo.finish();
itsConn.writeAll (buf);
+ Record values, result;
for (int i=0; i<itsConn.size(); ++i) {
itsConn.read (i, buf);
MWBlobIn bbi(buf);
+ ASSERT (bbi.getOperation() == 1); // ensure success
+ if (i == 0) {
+ getRecord (bbi.blobStream(), result);
+ } else {
+ getRecord (bbi.blobStream(), values);
+ }
bbi.finish();
- ASSERT (bbi.getOperation() == 1); // ensure successful init
}
- Record res;
- return res;
+ return result;
+ }
+
+ void ParmFacadeDistr::getRecord (BlobIStream& bis, Record& rec)
+ {
+ BlobAipsIO baio(bis);
+ casa::AipsIO aio(&baio);
+ aio >> rec;
}
} // namespace ParmDB
diff --git a/CEP/ParmDB/src/parmdbremote-scr b/CEP/ParmDB/src/parmdbremote-scr
new file mode 100755
index 0000000000000000000000000000000000000000..c6ab01b07bfc568b89a62afce60d70b35ef0b259
--- /dev/null
+++ b/CEP/ParmDB/src/parmdbremote-scr
@@ -0,0 +1,23 @@
+#!/bin/sh
+
+if test $# != 10; then
+ echo "run as: parmdbremote-src 'socket' host port np rank"
+ echo " pdb-part filesys ms-part-vds"
+ echo " lofarroot wd"
+ exit 1
+fi
+lroot=$9
+wd=${10}
+
+# Source lofarinit to find parmdbremote in production environment.
+if test -e $lroot/lofarinit.sh; then
+ sh $lroot/lofarinit.sh
+fi
+# cd to work directory and add . to PATH for test purposes (make check).
+if test -d $wd; then
+ cd $wd
+ PATH=.:$PATH
+ export PATH
+fi
+
+parmdbremote $2 $3 $6 # host,port,parmdb-part
diff --git a/CEP/ParmDB/src/parmdbclient.cc b/CEP/ParmDB/src/parmdbremote.cc
similarity index 86%
rename from CEP/ParmDB/src/parmdbclient.cc
rename to CEP/ParmDB/src/parmdbremote.cc
index a197a51532d9de713ae7b0afb311048f184c1b37..d258d95926d370638ad6fd8471655ee97cdae8c8 100644
--- a/CEP/ParmDB/src/parmdbclient.cc
+++ b/CEP/ParmDB/src/parmdbremote.cc
@@ -1,4 +1,4 @@
-//# parmdbclient.cc: Client handling a distributed ParmDB part
+//# parmdbremote.cc: Remote handling a distributed ParmDB part
//#
//# Copyright (C) 2009
//# ASTRON (Netherlands Foundation for Research in Astronomy)
@@ -124,7 +124,7 @@ void doIt (SocketConnection& conn, ParmFacadeLocal& pdb)
getValuesGrid (pdb, bbi.blobStream(), bbo.blobStream());
break;
default:
- ASSERTSTR(false, "parmdbclient: unknown command-id "
+ ASSERTSTR(false, "parmdbremote: unknown command-id "
<< bbi.getOperation());
}
// Finish the blobstreams and write the result message.
@@ -134,41 +134,32 @@ void doIt (SocketConnection& conn, ParmFacadeLocal& pdb)
}
}
-int main (int argc, const char* argv[])
+int main (int argc, char* argv[])
{
const char* progName = basename(argv[0]);
INIT_LOGGER(progName);
SocketConnection::ShPtr conn;
try {
- ASSERTSTR (argc >= 7, "Use as: parmdbclient socket <host> "
- "<port> <#processes> <rank> <mspart>");
- string host (argv[2]);
- string port (argv[3]);
- istringstream iss(argv[4]);
- int nnode, rank;
- iss >> nnode;
- istringstream iss1(argv[5]);
- iss1 >> rank;
- string fname(argv[6]);
+ ASSERTSTR (argc >= 4, "Use as: parmdbremote <host> <port> <mspart>");
+ string host (argv[1]);
+ string port (argv[2]);
+ string fname(argv[3]);
// Setup the connection.
conn = SocketConnection::ShPtr(new SocketConnection(host, port));
- // Open the ParmDB after getting its name from the VDS file.
- {
- VdsPartDesc vds((ParameterSet(fname)));
- fname = vds.getFileName();
- }
+ // Open the ParmDB.
ParmFacadeLocal parmdb(fname);
{
- // Tell master init was successful.
+ // Tell master the MS-part to process.
BlobString bufout;
MWBlobOut bbo(bufout, 1, 0);
+ bbo.blobStream() << fname;
bbo.finish();
conn->write (bufout);
}
// Handle requests.
doIt (*conn, parmdb);
} catch (std::exception& x) {
- LOG_FATAL (string("Unexpected exception in parmdbclient: ") + x.what());
+ LOG_FATAL (string("Unexpected exception in parmdbremote: ") + x.what());
// Tell master there is an error.
BlobString bufout;
MWBlobOut bbo(bufout, 0, 0);
diff --git a/CEP/ParmDB/src/setupparmdb-part b/CEP/ParmDB/src/setupparmdb-part
index 8e2eb97ae4b4aa7a45ca96dfe6e6454efeed6788..ce7acc7d9ce35f7163773440676fe425ecbfb5dc 100755
--- a/CEP/ParmDB/src/setupparmdb-part
+++ b/CEP/ParmDB/src/setupparmdb-part
@@ -26,8 +26,9 @@
pgmpath=`dirname $0`
pgmpath=`cd $pgmpath > /dev/null 2>&1 && pwd`
-if test $# != 11; then
- echo "run as: setupparmdb-part dummy dummy dummy dummy rank ms-part filesys"
+if test $# != 12; then
+ echo "run as: setupparmdb-part dummy dummy dummy dummy rank"
+ " ms-part filesys ms-part-vds"
echo " lofarroot pdbfile pdbname dry"
exit 1
fi
@@ -37,12 +38,11 @@ shift
shift
shift
seqnr=$1
-msn=$2
-shift
-lroot=$3
-pdbfile=$4
-pdb=$5
-dry=$6
+msn=$4
+lroot=$5
+pdbfile=$6
+pdb=$7
+dry=$8
# Initialize lofar environment.
diff --git a/CEP/ParmDB/src/setupsourcedb-part b/CEP/ParmDB/src/setupsourcedb-part
index f0cd14236887f7a10653688db217644128112703..87d18d160a2cc44a709948f6c54338def58f5da8 100755
--- a/CEP/ParmDB/src/setupsourcedb-part
+++ b/CEP/ParmDB/src/setupsourcedb-part
@@ -26,8 +26,9 @@
pgmpath=`dirname $0`
pgmpath=`cd $pgmpath > /dev/null 2>&1 && pwd`
-if test $# != 12; then
- echo "run as: setupsourcedb-part dummy dummy dummy dummy rank ms-part filesys"
+if test $# != 13; then
+ echo "run as: setupsourcedb-part dummy dummy dummy dummy rank"
+ " ms-part filesys ms-part-vds"
echo " lofarroot pdbfile pdbname overwrite dry"
exit 1
fi
@@ -37,13 +38,12 @@ shift
shift
shift
seqnr=$1
-msn=$2
-shift
-lroot=$3
-srccat=$4
-pdb=$5
-overwrite=$6
-dry=$7
+msn=$4
+lroot=$5
+srccat=$6
+pdb=$7
+overwrite=$8
+dry=$9
# Initialize lofar environment.
diff --git a/CEP/ParmDB/src/startparmdbdistr b/CEP/ParmDB/src/startparmdbdistr
new file mode 100755
index 0000000000000000000000000000000000000000..3b2c23251571d719bd6ad2a7c88b4197c8e81c87
--- /dev/null
+++ b/CEP/ParmDB/src/startparmdbdistr
@@ -0,0 +1,17 @@
+#!/bin/sh
+
+# Find the path used to start the script.
+pgmpath=`dirname $0`
+pgmpath=`cd $pgmpath > /dev/null 2>&1 && pwd`
+
+# Find the hostname.
+host=`uname -n`
+# If we cannot connect to it, replace it by localhost.
+ssh $host date > /dev/null 2>&1
+if test $? != 0; then
+ host=localhost
+fi
+
+# Start parmdbremote for each part.
+startdistproc -mode "$1" -nowait -masterhost localhost -nostartmaster \
+ -cdn "$2" -dsn "$3" $pgmpath/parmdbremote-scr "$LOFARROOT" `pwd`
diff --git a/CEP/ParmDB/test/Makefile.am b/CEP/ParmDB/test/Makefile.am
index 28950e9cded621b80f0f0cc1f12fd4e46d5ece44..a6c1f0c3062f04f9fe38d960d79ecc4cf4145876 100644
--- a/CEP/ParmDB/test/Makefile.am
+++ b/CEP/ParmDB/test/Makefile.am
@@ -9,7 +9,8 @@ CHECKTOOLPROGS = $(check_PROGRAMS)
# scripts used to run tests
TESTSCRIPTS = tAxis.sh tAxisMapping.sh tBox.sh tGrid.sh \
tParmValue.sh tParmDBCasa.sh \
- tParmSet.sh tParmCache tParm.sh tParmFacade.sh \
+ tParmSet.sh tParmCache tParm.sh \
+ tParmFacade.sh tParmFacadeDistr.sh \
tparmdb.sh \
tSourceDBCasa.sh tmakesourcedb.sh \
tsetupparmdb.sh tsetupsourcedb.sh
@@ -71,6 +72,7 @@ tTimeAxis_DEPENDENCIES = ../src/libparmdb.la $(LOFAR_DEPEND)
EXTRA_DIST = $(TESTSCRIPTS) \
tparmdb.run tparmdb.in tparmdb.stdout \
tParmFacade.run tParmFacade.stdout \
+ tParmFacadeDistr.run tParmFacadeDistr.stdout \
tmakesourcedb.run tmakesourcedb.in \
tmakesourcedb.in_2 tmakesourcedb.stdout \
tsetupparmdb.run tsetupparmdb.stdout \
diff --git a/CEP/ParmDB/test/tParmFacade.run b/CEP/ParmDB/test/tParmFacade.run
index 8b64a76cadd19cd0203dc5dc04063ac9ea62c727..6dd5d00a93cbfc9d62b340573fd6b966af888707 100755
--- a/CEP/ParmDB/test/tParmFacade.run
+++ b/CEP/ParmDB/test/tParmFacade.run
@@ -11,6 +11,6 @@ if [ $? != 0 ]; then
exit 1
fi
-$LOFAR_CHECKTOOL tParmFacade tParmFacade_tmp.pdb
+$LOFAR_CHECKTOOL ./tParmFacade tParmFacade_tmp.pdb
echo ""
-$LOFAR_CHECKTOOL tParmFacade tParmFacade_tmp.pdb '*' 1
+$LOFAR_CHECKTOOL ./tParmFacade tParmFacade_tmp.pdb '*' 1
diff --git a/CEP/ParmDB/test/tParmFacadeDistr.run b/CEP/ParmDB/test/tParmFacadeDistr.run
new file mode 100755
index 0000000000000000000000000000000000000000..b94151ed0623684d746b486dac0e50952a95c4b0
--- /dev/null
+++ b/CEP/ParmDB/test/tParmFacadeDistr.run
@@ -0,0 +1,87 @@
+#!/bin/sh
+
+# If first argument is non-empty, only the files are created.
+# It makes it possible to run the debugger on tParmFacadeDistr.
+
+# The test uses 2 remote pdb-s, so create them.
+../src/parmdb <<EOF > tParmFacadeDistr_tmp.pdbout
+ create tablename='tParmFacadeDistr_tmp.pdb1'
+ add parm1 domain=[1,5,4,10],values=2
+ add parm2 type='polc', domain=[1,5,4,10], values=[2,0.1], nx=2
+ quit
+EOF
+if [ $? != 0 ]; then
+ cat tParmFacadeDistr_tmp.pdbout
+ exit 1
+fi
+../src/parmdb <<EOF > tParmFacadeDistr_tmp.pdbout
+ create tablename='tParmFacadeDistr_tmp.pdb2'
+ add parm1 domain=[1,5,10,15],values=2
+ add parm2 type='polc', domain=[1,5,10,15], values=[2,0.1], nx=2
+ quit
+EOF
+if [ $? != 0 ]; then
+ cat tParmFacadeDistr_tmp.pdbout
+ exit 1
+fi
+
+fname1=`pwd`/tParmFacadeDistr_tmp.pdb1
+fname2=`pwd`/tParmFacadeDistr_tmp.pdb2
+cdname=`pwd`/tParmFacadeDistr_tmp.cd
+
+cat > tParmFacadeDistr_tmp.cd <<EOF
+ClusterName = cl
+NNodes = 2
+Node0.NodeName = localhost
+Node0.NodeFileSys = [node1:/usr]
+Node0.NodeMountPoints = [/usr]
+Node1.NodeName = localhost
+Node1.NodeFileSys = [node1:/usr]
+Node1.NodeMountPoints = [/usr]
+EOF
+cat > tParmFacadeDistr_tmp.pdb.vd <<EOF
+Name = /usr/local/xyx
+FileSys =
+ClusterDesc = $cdname
+StartTime = 0
+EndTime = 2
+StepTime = 0.5
+NChan = [64,128]
+StartFreqs = [20,120]
+EndFreqs = [100,300]
+NParts = 2
+
+Part0.Name = /usr/local/xyx0.vds
+Part0.FileName = $fname1
+Part0.FileSys = node1:/usr
+Part0.StartTime = 0
+Part0.EndTime = 2
+Part0.StepTime = 0.5
+Part0.NChan = [64,128]
+Part0.StartFreqs = [20,120]
+Part0.EndFreqs = [100,300]
+Part1.Name = /usr/local/xyx0.vds
+Part1.FileName = $fname2
+Part1.FileSys = node1:/usr
+Part1.StartTime = 0
+Part1.EndTime = 2
+Part1.StepTime = 0.5
+Part1.NChan = [64,128]
+Part1.StartFreqs = [20,120]
+Part1.EndFreqs = [100,300]
+EOF
+
+# Make a symlink to scripts in src, so they can be found.
+# Make sure . is in PATH.
+rm -f startparmdbdistr parmdbremote-scr parmdbremote
+ln -s ../../../src/startparmdbdistr
+ln -s ../../../src/parmdbremote-scr
+ln -s ../src/parmdbremote
+PATH=.:$PATH
+export PATH
+
+if test "$1" = ""; then
+ $LOFAR_CHECKTOOL ./tParmFacade tParmFacadeDistr_tmp.pdb.vd
+ echo ""
+ $LOFAR_CHECKTOOL ./tParmFacade tParmFacadeDistr_tmp.pdb '*' 1
+fi
diff --git a/CEP/ParmDB/test/tParmFacadeDistr.sh b/CEP/ParmDB/test/tParmFacadeDistr.sh
new file mode 100755
index 0000000000000000000000000000000000000000..0904e8ab8d5f1dc3ad185951f48bfe94b1518d57
--- /dev/null
+++ b/CEP/ParmDB/test/tParmFacadeDistr.sh
@@ -0,0 +1,2 @@
+#!/bin/sh
+$lofar_sharedir/runtest.sh tParmFacadeDistr > tParmFacadeDistr.log 2>&1