[certi-cvs] applications/HLA_TestsSuite CMakeLists.txt COPY...

[certi-cvs]

CVSROOT:        /sources/certi
Module name:    applications
Changes by:     Christian Stenzel <approx>      08/05/03 16:17:26

Modified files:
        HLA_TestsSuite : CMakeLists.txt COPYING 
Added files:
        HLA_TestsSuite : test_HugeAVPV.cc test_HugeAVPV.fed 

Log message:
        new program for HLA_TestsSuite

CVSWeb URLs:
http://cvs.savannah.gnu.org/viewcvs/applications/HLA_TestsSuite/CMakeLists.txt?cvsroot=certi&r1=1.4&r2=1.5
http://cvs.savannah.gnu.org/viewcvs/applications/HLA_TestsSuite/COPYING?cvsroot=certi&r1=1.1&r2=1.2
http://cvs.savannah.gnu.org/viewcvs/applications/HLA_TestsSuite/test_HugeAVPV.cc?cvsroot=certi&rev=1.1
http://cvs.savannah.gnu.org/viewcvs/applications/HLA_TestsSuite/test_HugeAVPV.fed?cvsroot=certi&rev=1.1

Patches:
Index: CMakeLists.txt
===================================================================
RCS file: /sources/certi/applications/HLA_TestsSuite/CMakeLists.txt,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -b -r1.4 -r1.5
--- CMakeLists.txt      3 May 2008 10:22:42 -0000       1.4
+++ CMakeLists.txt      3 May 2008 16:17:24 -0000       1.5
@@ -22,11 +22,8 @@
 # You should set CERTI_HOME env var to appropriate value
 # or put here the full path to the directory
 # containing FindCERTI.cmake
-FILE(TO_CMAKE_PATH "$ENV{CERTI_HOME}" CERTI_HOME_TEMP)
-SET(CERTI_HOME ${CERTI_HOME_TEMP} CACHE PATH "The CERTI install directory")
-LIST(APPEND CMAKE_MODULE_PATH "${CERTI_HOME}/share/scripts")
-LIST(APPEND CMAKE_MODULE_PATH "${HLA_TestsSuite_SOURCE_DIR}")
-MESSAGE(STATUS "CMAKE_MODULE_PATH = ${CMAKE_MODULE_PATH}")
+SET(CERTI_HOME $ENV{CERTI_HOME} CACHE PATH "The CERTI install directory")
+SET(CMAKE_MODULE_PATH ${CERTI_HOME}/share/scripts)
 
 # You should uncomment the following line
 # if you want VERBOSE build
@@ -94,26 +91,44 @@
 
 INCLUDE(CPack)
 
-INCLUDE(HLATestsSuiteTools)
+#INCLUDE(HLATestSuiteTools)
 #########################################################################
 # ADD TEST ELEMENTARY PROGRAM
 #########################################################################
-HLATestsSuite_ADD_TEST(test_CreateJoinResignDestroy
-                       FED_FILE test_CreateJoinResignDestroy.fed
-                       SOURCE_FILES test_CreateJoinResignDestroy.cc)
+#HLATestSuite_ADD_TEST(test_CreateJoinResignDestroy
+#                      FEDFILE test_CreateJoinResignDestroy.fed
+#                      SOURCE_FILES test_CreateJoinResignDestroy.cc)
+
+SET(TESTNAME test_CreateJoinResignDestroy)
+ADD_EXECUTABLE(${TESTNAME} ${TESTNAME}.cc)
+TARGET_LINK_LIBRARIES(${TESTNAME} ${CERTI_LIBRARIES})
+INSTALL(TARGETS ${TESTNAME} RUNTIME DESTINATION bin)
+INSTALL(FILES ${TESTNAME}.fed DESTINATION share/federations)
 
 #########################################################################
 # ADD TEST CREATE-JOIN-RESIGN-SAVE-RESTORE-PUBLISH.... PROGRAM
 #########################################################################
-HLATestsSuite_ADD_TEST(create_destroy
-                       FED_FILE create-destroy.fed
-                       SOURCE_FILES create_destroy.cc create_destroy.hh)
-
-#########################################################################
-# ADD TEST FedTime PROGRAM
-#########################################################################
-HLATestsSuite_ADD_TEST(test_FedTime
-                       FED_FILE create-destroy.fed
-                       SOURCE_FILES test_FedTime.cc)
+#HLATestSuite_ADD_TEST(create_destroy
+#                      FEDFILE create-destroy.fed
+#                      SOURCE_FILES create_destroy.cc create_destroy.hh)
+
+SET(TESTNAME create_destroy)
+ADD_EXECUTABLE(${TESTNAME} ${TESTNAME}.cc)
+TARGET_LINK_LIBRARIES(${TESTNAME} ${CERTI_LIBRARIES})
+INSTALL(TARGETS ${TESTNAME} RUNTIME DESTINATION bin)
+INSTALL(FILES ${TESTNAME}.fed DESTINATION share/federations)
+
+#########################################################################
+# ADD TEST HUGE ATTRIBUTE AND PARAMETER VALUES.... PROGRAM
+#########################################################################
+#HLATestSuite_ADD_TEST(test_HugeAVPV
+#                      FEDFILE test_HugeAVPV.fed
+#                      SOURCE_FILES test_HugeAVPV.cc) 
+
+SET(TESTNAME test_HugeAVPV)
+ADD_EXECUTABLE(${TESTNAME} ${TESTNAME}.cc)
+TARGET_LINK_LIBRARIES(${TESTNAME} ${CERTI_LIBRARIES})
+INSTALL(TARGETS ${TESTNAME} RUNTIME DESTINATION bin)
+INSTALL(FILES ${TESTNAME}.fed DESTINATION share/federations)
 
 MESSAGE(STATUS "*** ${CMAKE_PROJECT_NAME} has been successfully configured 
***")

Index: COPYING
===================================================================
RCS file: /sources/certi/applications/HLA_TestsSuite/COPYING,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -b -r1.1 -r1.2
--- COPYING     27 Apr 2008 13:16:39 -0000      1.1
+++ COPYING     3 May 2008 16:17:25 -0000       1.2
@@ -1,8 +1,7 @@
-
-CERTI_TUTORIAL is free software; you can redistribute it and/or
-modify it under the terms of the GNU General Public License as 
-published by the Free Software Foundation; either version 2 of 
-the License, or (at your option) any later version.
+All components of the HLA_TestsSuite are free software; you can 
+redistribute it and/or modify it under the terms of the GNU General 
+Public License as published by the Free Software Foundation; either 
+version 2 of the License, or (at your option) any later version.
 
 This program is distributed in the hope that it will be useful, but
 WITHOUT ANY WARRANTY; without even the implied warranty of

Index: test_HugeAVPV.cc
===================================================================
RCS file: test_HugeAVPV.cc
diff -N test_HugeAVPV.cc
--- /dev/null   1 Jan 1970 00:00:00 -0000
+++ test_HugeAVPV.cc    3 May 2008 16:17:25 -0000       1.1
@@ -0,0 +1,713 @@
+#include <RTI.hh>
+#include <fedtime.hh>
+#include <NullFederateAmbassador.hh>
+
+#include <iostream>
+#include <sstream>
+#include <memory>
+#include <string>
+
+using std::string;
+using std::cout;
+using std::cerr;
+using std::endl;
+using std::auto_ptr;
+
+#define MAX_FEDERATES 10
+
+class HugeAVPVFed : public NullFederateAmbassador {
+
+private:
+    string federationName;
+    string fedFile;
+    unsigned int payloadSize;
+    unsigned int rav_ri_counter;
+    bool creator;
+    struct hdls {
+        struct objclass {
+            RTI::ObjectClassHandle och;
+            RTI::ObjectHandle oh;
+            RTI::AttributeHandle a0;
+            RTI::AttributeHandle a1;
+            RTI::AttributeHandle a2;
+            RTI::AttributeHandle a3;
+        } TestAttribute;
+        struct intClass {
+            RTI::InteractionClassHandle ich;
+            RTI::ParameterHandle p;
+        } TestParameter0, TestParameter1, TestParameter2, TestParameter3;
+    } myhdls;
+    bool SYNCPOINTREGSUCC, SYNCPOINTREGFAIL, ANNOUNCESYNCPOINT, FEDSYNC,
+        TIMEADVANCEGRANT;
+    string SYNCPOINTLABEL, SYNCPOINTTAG;
+
+public:
+    HugeAVPVFed(unsigned int size) {
+        federationName = "TestHugeAVPV";
+        fedFile = "test_HugeAVPV.fed";
+        creator = false;
+        SYNCPOINTREGSUCC = false;
+        SYNCPOINTREGFAIL = false;
+        ANNOUNCESYNCPOINT = false;
+        FEDSYNC = false;
+        TIMEADVANCEGRANT = false;
+        payloadSize = size;
+        rav_ri_counter = 0;
+    };
+
+    virtual ~HugeAVPVFed() throw (RTI::FederateInternalError) {
+    };
+
+    int
+    main(void) {
+        this->create_and_join();
+        this->getHandles();
+        if (creator) {
+            cout << "Press ENTER to start execution ..." << endl;
+            getchar();
+
+            this->synchronizeFederation("sync1", "test");
+           cout << "Sync (1) done" << endl;
+
+            this->publishAttributesAndParameters();
+            this->registerObjectInst();
+
+            // not time regulating
+            this->synchronizeFederation("sync2", "test");
+           cout << "Sync (2) done" << endl;
+
+           cout << "(1) Send Attributes and Parameters" << endl;
+            this->updateAttributeVals(false);
+            this->sendInteractions(false);
+            this->updateAttributeVals(true);
+            this->sendInteractions(true);
+           cout << "(1) Done" << endl;
+
+            // time regulating, receivers are not time constrained
+            this->enableTimeReg();
+            this->synchronizeFederation("sync3", "test");
+           cout << "Sync (3) done" << endl;
+
+           cout << "(2) Send Attributes and Parameters" << endl;
+            this->updateAttributeVals(false);
+            this->sendInteractions(false);
+            this->updateAttributeVals(true);
+            this->sendInteractions(true);
+           cout << "(2) Done." << endl;
+
+            // time regulating, receivers are time constrained
+            this->synchronizeFederation("sync4", "test");
+           cout << "Sync (4) done" << endl;
+
+           cout << "(3) Send Attributes and Parameters" << endl;
+            this->updateAttributeVals(false);
+            this->sendInteractions(false);
+            this->updateAttributeVals(true);
+            this->sendInteractions(true);
+           cout << "(3) Done." << endl;
+
+           this->advanceTime(10.0);
+            
+            // stay active until all federates reach end of execution
+            this->synchronizeFederation("sync6", "test");
+           cout << "Sync (6) done" << endl;
+        } else {
+            this->subscribeAttributesAndParameters();
+            // initial sync point
+            this->waitForSyncPoint();
+
+            // second sync point -> afterwards have to get rav and ri wo ts
+            this->waitForSyncPoint();
+            while (rav_ri_counter!=10) this->tickRTI();
+            rav_ri_counter = 0;
+
+            // third sync point -> afterwards have to get rav and ri wo ts
+            this->waitForSyncPoint();
+            while (rav_ri_counter!=10) this->tickRTI();
+            rav_ri_counter = 0;
+
+            // fourth sync point -> afterwards have to get rav and ri wo/w ts
+            this->enableTimeCon();
+            this->waitForSyncPoint();
+
+           this->advanceTime(10.0);
+
+            while (rav_ri_counter!=10) this->tickRTI();
+            rav_ri_counter = 0;
+
+            // final sync point
+            this->waitForSyncPoint();
+        }
+        this->resign_and_destroy();
+        return 0;
+    };
+
+private:
+
+    void
+    create_and_join(void) {
+        try {
+            rtiamb.createFederationExecution(federationName.c_str(),
+                                             fedFile.c_str());
+            creator = true;
+        } catch ( RTI::FederationExecutionAlreadyExists& e) {
+            cout << "--> Federation already created by another federate."
+            << endl;
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+        string federateName = "hugeAVPVFed0";
+        for (int i=1;i<=MAX_FEDERATES;i++) {
+            cout << "Try to join joining federation: " << i << endl;
+            try {
+                cout << "Try to join federation as " << federateName << "." <<
+                endl;
+                rtiamb.joinFederationExecution(federateName.c_str(),
+                                               federationName.c_str(),
+                                               this);
+                cout << "Joined federation as " << federateName << "." <<
+                endl;
+                break;
+            } catch (RTI::FederateAlreadyExecutionMember& e) {
+                cout << "Federate already execution member" << endl;
+                federateName[11] = i+'0';
+                if (i==MAX_FEDERATES) {
+                    cout << "More than " << MAX_FEDERATES << " out there." <<
+                    endl;
+                    exit(-1);
+                }
+                continue;
+            } catch ( RTI::Exception &e ) {
+                cerr << "RTI exception: " << e._name << " ["
+                << (e._reason ? e._reason : "undefined") << "]." << endl;
+            } catch ( ... ) {
+                cerr << "Error: Unknown non-RTI exception." << endl;
+            }
+        }
+
+    }
+
+    void
+    resign_and_destroy(void) {
+        try {
+            rtiamb.resignFederationExecution(
+                RTI::DELETE_OBJECTS_AND_RELEASE_ATTRIBUTES);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+        try {
+            rtiamb.destroyFederationExecution(federationName.c_str());
+        } catch (RTI::FederatesCurrentlyJoined) {
+            cout << "Federates currently joined." << endl;
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    getHandles(void) {
+
+        // get object class handle
+        try {
+            myhdls.TestAttribute.och =
+                rtiamb.getObjectClassHandle("TestAttribute");
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+        // get attribute handles
+        try {
+            myhdls.TestAttribute.a0 =
+                rtiamb.getAttributeHandle("Payload_A_0",
+                                          myhdls.TestAttribute.och);
+            myhdls.TestAttribute.a1 =
+                rtiamb.getAttributeHandle("Payload_A_1",
+                                          myhdls.TestAttribute.och);
+            myhdls.TestAttribute.a2 =
+                rtiamb.getAttributeHandle("Payload_A_2",
+                                          myhdls.TestAttribute.och);
+            myhdls.TestAttribute.a3 =
+                rtiamb.getAttributeHandle("Payload_A_3",
+                                          myhdls.TestAttribute.och);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+        // get interaction class handle
+        try {
+            myhdls.TestParameter0.ich =
+                rtiamb.getInteractionClassHandle("TestParameter_P_0");
+            myhdls.TestParameter1.ich =
+                rtiamb.getInteractionClassHandle("TestParameter_P_1");
+            myhdls.TestParameter2.ich =
+                rtiamb.getInteractionClassHandle("TestParameter_P_2");
+            myhdls.TestParameter3.ich =
+                rtiamb.getInteractionClassHandle("TestParameter_P_3");
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+        // get parameter handles
+        try {
+            myhdls.TestParameter0.p =
+                rtiamb.getParameterHandle("Payload", 
myhdls.TestParameter0.ich);
+            myhdls.TestParameter1.p =
+                rtiamb.getParameterHandle("Payload", 
myhdls.TestParameter1.ich);
+            myhdls.TestParameter2.p =
+                rtiamb.getParameterHandle("Payload", 
myhdls.TestParameter2.ich);
+            myhdls.TestParameter3.p =
+                rtiamb.getParameterHandle("Payload", 
myhdls.TestParameter3.ich);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: Unknown non-RTI exception." << endl;
+        }
+
+    }
+
+    void
+    publishAttributesAndParameters(void) {
+
+        auto_ptr<RTI::AttributeHandleSet>
+        attrs(RTI::AttributeHandleSetFactory::create(4));
+
+        attrs->add(myhdls.TestAttribute.a0);
+        attrs->add(myhdls.TestAttribute.a1);
+        attrs->add(myhdls.TestAttribute.a2);
+        attrs->add(myhdls.TestAttribute.a3);
+
+        try {
+            rtiamb.publishObjectClass(myhdls.TestAttribute.och, *attrs);
+            rtiamb.publishInteractionClass(myhdls.TestParameter0.ich);
+            rtiamb.publishInteractionClass(myhdls.TestParameter1.ich);
+            rtiamb.publishInteractionClass(myhdls.TestParameter2.ich);
+            rtiamb.publishInteractionClass(myhdls.TestParameter3.ich);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+
+        attrs->empty();
+    }
+
+    void
+    subscribeAttributesAndParameters(void) {
+
+        auto_ptr<RTI::AttributeHandleSet>
+        attrs(RTI::AttributeHandleSetFactory::create(4));
+
+        attrs->add(myhdls.TestAttribute.a0);
+        attrs->add(myhdls.TestAttribute.a1);
+        attrs->add(myhdls.TestAttribute.a2);
+        attrs->add(myhdls.TestAttribute.a3);
+
+        try {
+            rtiamb.subscribeObjectClassAttributes(myhdls.TestAttribute.och,
+                                                  *attrs);
+            rtiamb.subscribeInteractionClass(myhdls.TestParameter0.ich);
+            rtiamb.subscribeInteractionClass(myhdls.TestParameter1.ich);
+            rtiamb.subscribeInteractionClass(myhdls.TestParameter2.ich);
+            rtiamb.subscribeInteractionClass(myhdls.TestParameter3.ich);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+
+        attrs->empty();
+    }
+
+    void
+    registerObjectInst(void) {
+
+        try {
+            myhdls.TestAttribute.oh = rtiamb.registerObjectInstance
+                                      (myhdls.TestAttribute.och);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+
+    }
+
+    void
+    synchronizeFederation(string label, string tag) {
+
+        for (;;) {
+            this->registerFedSyncPoint(label, tag);
+
+            while (!(SYNCPOINTREGSUCC || SYNCPOINTREGFAIL)) this->tickRTI();
+
+            if (SYNCPOINTREGFAIL) {
+                SYNCPOINTREGFAIL = false;
+               sleep(1);
+                continue;
+            } else {
+                SYNCPOINTREGSUCC = false;
+                break;
+            }
+        }
+
+        while (!ANNOUNCESYNCPOINT) this->tickRTI();
+        ANNOUNCESYNCPOINT = false;
+
+        this->indicateSynchronization(label);
+    }
+
+    void
+    indicateSynchronization(string label) {
+        this->syncPointAchieved(label);
+        while (!FEDSYNC) this->tickRTI(0,1);
+        FEDSYNC=false;
+    }
+
+    void
+    waitForSyncPoint(void) {
+        while (!ANNOUNCESYNCPOINT) this->tickRTI();
+        ANNOUNCESYNCPOINT = false;
+        cout << "Synchronization Point " << SYNCPOINTLABEL <<
+        " reached, press ENTER ..." << endl;
+        getchar();
+        this->indicateSynchronization(SYNCPOINTLABEL);
+    }
+
+    void
+    registerFedSyncPoint(string label, string tag) {
+        try {
+            rtiamb.registerFederationSynchronizationPoint(label.c_str(),
+                    tag.c_str());
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    syncPointAchieved(string label) {
+        try {
+            rtiamb.synchronizationPointAchieved(label.c_str());
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    advanceTime(double time) {
+       try {
+           rtiamb.timeAdvanceRequest(RTIfedTime(time));
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+       while (!TIMEADVANCEGRANT) this->tickRTI();
+       TIMEADVANCEGRANT = false;
+    }
+
+    void
+    updateAttributeVals(bool ts) {
+
+        auto_ptr<RTI::AttributeHandleValuePairSet>
+        ahvps(RTI::AttributeSetFactory::create(4));
+
+        char *payload = new char[payloadSize];
+
+        memset(payload, 0, payloadSize);
+
+        ahvps->add(myhdls.TestAttribute.a0, payload, payloadSize);
+        ahvps->add(myhdls.TestAttribute.a1, payload, payloadSize);
+        ahvps->add(myhdls.TestAttribute.a2, payload, payloadSize);
+        ahvps->add(myhdls.TestAttribute.a3, payload, payloadSize);
+
+        try {
+            if (ts)
+                rtiamb.updateAttributeValues(myhdls.TestAttribute.oh, *ahvps,
+                                             RTIfedTime(0), "a");
+            else
+                rtiamb.updateAttributeValues(myhdls.TestAttribute.oh,
+                                             *ahvps, "a");
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+
+        ahvps->empty();
+        delete [] payload;
+
+    }
+
+    void
+    sendInteractions(bool ts) {
+
+        auto_ptr<RTI::ParameterHandleValuePairSet>
+        phvps0(RTI::ParameterSetFactory::create(1));
+        auto_ptr<RTI::ParameterHandleValuePairSet>
+        phvps1(RTI::ParameterSetFactory::create(1));
+        auto_ptr<RTI::ParameterHandleValuePairSet>
+        phvps2(RTI::ParameterSetFactory::create(1));
+        auto_ptr<RTI::ParameterHandleValuePairSet>
+        phvps3(RTI::ParameterSetFactory::create(1));
+
+        char *payload = new char[payloadSize];
+
+        memset(payload, 0, payloadSize);
+
+        phvps0->add(myhdls.TestParameter0.p, payload, payloadSize);
+        phvps1->add(myhdls.TestParameter1.p, payload, payloadSize);
+        phvps2->add(myhdls.TestParameter2.p, payload, payloadSize);
+        phvps3->add(myhdls.TestParameter3.p, payload, payloadSize);
+
+        try {
+            if (ts) {
+                rtiamb.sendInteraction(myhdls.TestParameter0.ich, *phvps0,
+                                       RTIfedTime(0), "p0");
+                rtiamb.sendInteraction(myhdls.TestParameter1.ich, *phvps1,
+                                       RTIfedTime(0), "p1");
+                rtiamb.sendInteraction(myhdls.TestParameter2.ich, *phvps2,
+                                       RTIfedTime(0), "p2");
+                rtiamb.sendInteraction(myhdls.TestParameter3.ich, *phvps3,
+                                       RTIfedTime(0), "p3");
+            } else {
+                rtiamb.sendInteraction(myhdls.TestParameter0.ich, *phvps0, 
"p");
+                rtiamb.sendInteraction(myhdls.TestParameter1.ich, *phvps1, 
"p");
+                rtiamb.sendInteraction(myhdls.TestParameter2.ich, *phvps2, 
"p");
+                rtiamb.sendInteraction(myhdls.TestParameter3.ich, *phvps3, 
"p");
+            }
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+
+        phvps0->empty();
+        phvps1->empty();
+        phvps2->empty();
+        phvps3->empty();
+        delete [] payload;
+
+    }
+
+    void
+    enableTimeReg(void) {
+        try {
+            rtiamb.enableTimeRegulation(RTIfedTime(0), RTIfedTime(5));
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    enableTimeCon(void) {
+        try {
+            rtiamb.enableTimeConstrained();
+            rtiamb.enableAsynchronousDelivery();
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    tickRTI(void) {
+        try {
+            rtiamb.tick();
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    void
+    tickRTI(double min, double max) {
+        try {
+            rtiamb.tick(min, max);
+        } catch ( RTI::Exception &e ) {
+            cerr << "RTI exception: " << e._name << " ["
+            << (e._reason ? e._reason : "undefined") << "]." << endl;
+        } catch ( ... ) {
+            cerr << "Error: unknown non-RTI exception." << endl;
+        }
+    }
+
+    /* Federate Ambassador services */
+    void
+    synchronizationPointRegistrationSucceeded(const char* label)
+    throw ( RTI::FederateInternalError) {
+        cout << "syncPointRegSucc: " << label << endl;
+        SYNCPOINTREGSUCC = true;
+    }
+
+    void
+    synchronizationPointRegistrationFailed(const char* label)
+    throw ( RTI::FederateInternalError) {
+        cout << "syncPointRegSucc: " << label << endl;
+        SYNCPOINTREGFAIL = true;
+    }
+
+    void
+    announceSynchronizationPoint(const char* label, const char* tag)
+    throw ( RTI::FederateInternalError) {
+        cout << "announceSyncPoint: " << label << ", " << tag << endl;
+        SYNCPOINTLABEL = label;
+        SYNCPOINTTAG = tag;
+        ANNOUNCESYNCPOINT = true;
+    }
+
+    void
+    federationSynchronized(const char* label)
+    throw (RTI::FederateInternalError) {
+        cout << "fedSync: " << label << endl;
+        FEDSYNC = true;
+    }
+
+    void
+    discoverObjectInstance (RTI::ObjectHandle theObject,
+                            RTI::ObjectClassHandle theObjectClass,
+                            const char *theObjectName)
+    throw ( RTI::CouldNotDiscover,
+            RTI::ObjectClassNotKnown,
+            RTI::FederateInternalError) {
+        cout << "discoverObjInst " << theObjectName << endl;
+    }
+
+    void
+    reflectAttributeValues (RTI::ObjectHandle theObject,
+                            const RTI::AttributeHandleValuePairSet& 
+                                 theAttributes,
+                            const char *theTag)
+    throw ( RTI::ObjectNotKnown,
+            RTI::AttributeNotKnown,
+            RTI::FederateOwnsAttributes,
+            RTI::FederateInternalError) {
+        rav_ri_counter += 1;
+        cout << "rav wo ts" << endl;
+    }
+
+    void
+    reflectAttributeValues (RTI::ObjectHandle theObject,
+                            const RTI::AttributeHandleValuePairSet& 
+                                 theAttributes,
+                            const RTI::FedTime& theTime,
+                            const char *theTag,
+                            RTI::EventRetractionHandle erhdl)
+    throw ( RTI::ObjectNotKnown,
+            RTI::AttributeNotKnown,
+            RTI::FederateOwnsAttributes,
+            RTI::InvalidFederationTime,
+            RTI::FederateInternalError) {
+        rav_ri_counter += 1;
+        cout << "rav w ts" << endl;
+    }
+
+    void
+    receiveInteraction (RTI::InteractionClassHandle theHandle,
+                        const RTI::ParameterHandleValuePairSet
+                        &theParameters,
+                        const char *theTag)
+    throw ( RTI::InteractionClassNotKnown,
+            RTI::InteractionParameterNotKnown,
+            RTI::FederateInternalError ) {
+        rav_ri_counter += 1;
+        cout << "ri wo ts" << endl;
+    }
+
+    void
+    receiveInteraction (RTI::InteractionClassHandle theHandle,
+                        const RTI::ParameterHandleValuePairSet
+                        &theParameters,
+                        const RTI::FedTime& theTime,
+                        const char *theTag,
+                        RTI::EventRetractionHandle erhdl)
+    throw ( RTI::InteractionClassNotKnown,
+            RTI::InteractionParameterNotKnown,
+            RTI::InvalidFederationTime,
+            RTI::FederateInternalError ) {
+        rav_ri_counter += 1;
+        cout << "ri w ts" << endl;
+    }
+
+    void
+    timeRegulationEnabled(const RTI::FedTime& theTime) 
+    throw (RTI::InvalidFederationTime, 
+          RTI::EnableTimeRegulationWasNotPending, 
+           RTI::FederateInternalError) {
+        cout << "Time Regulation Enabled, press ENTER to continue..." << endl;
+       getchar();
+    }
+
+    void
+    timeConstrainedEnabled(const RTI::FedTime& theTime) 
+    throw (RTI::InvalidFederationTime, 
+          RTI::EnableTimeConstrainedWasNotPending, 
+           RTI::FederateInternalError) {
+        cout << "Time Constrained Enabled, press ENTER to continue..." << endl;
+       getchar();
+    }
+
+    void 
+    timeAdvanceGrant(const RTI::FedTime &)
+    throw (RTI::InvalidFederationTime, 
+           RTI::TimeAdvanceWasNotInProgress, 
+           RTI::FederateInternalError) { 
+       TIMEADVANCEGRANT = true;
+       cout << "Time Advance Grant, press ENTER to continue..." << endl;
+       getchar();
+    }
+       
+
+protected:
+    RTI::RTIambassador rtiamb;
+};
+
+int main(int argc, char **argv) {
+
+    if (argc<2) {
+        cout << "Usage: " << argv[0] << " payload size [bytes]" << endl;
+        return -1;
+    }
+
+    HugeAVPVFed testFed(atoi(argv[1]));
+    return testFed.main();
+}

Index: test_HugeAVPV.fed
===================================================================
RCS file: test_HugeAVPV.fed
diff -N test_HugeAVPV.fed
--- /dev/null   1 Jan 1970 00:00:00 -0000
+++ test_HugeAVPV.fed   3 May 2008 16:17:26 -0000       1.1
@@ -0,0 +1,47 @@
+;; TwoLevelController 
+
+(Fed
+  (Federation HugeAVPVTest)
+  (FedVersion v1.3)
+  (Federate "hugeAVPVFed0" "Public")
+  (Federate "hugeAVPVFed1" "Public")
+  (Federate "hugeAVPVFed2" "Public")
+  (Federate "hugeAVPVFed3" "Public")
+  (Federate "hugeAVPVFed4" "Public")
+  (Federate "hugeAVPVFed5" "Public")
+  (Federate "hugeAVPVFed6" "Public")
+  (Federate "hugeAVPVFed7" "Public")
+  (Federate "hugeAVPVFed8" "Public")
+  (Federate "hugeAVPVFed9" "Public")
+  (Spaces
+  )
+  (Objects
+    (Class ObjectRoot
+      (Attribute privilegeToDelete reliable timestamp)
+      (Class RTIprivate)
+       (Class TestAttribute
+               (Attribute Payload_A_0 RELIABLE RECEIVE)
+               (Attribute Payload_A_1 BEST_EFFORT RECEIVE)
+               (Attribute Payload_A_2 RELIABLE TIMESTAMP)
+               (Attribute Payload_A_3 BEST_EFFORT TIMESTAMP)
+       )
+    )
+  )
+  (Interactions
+    (Class InteractionRoot BEST_EFFORT RECEIVE
+      (Class RTIprivate BEST_EFFORT RECEIVE)
+       (Class TestParameter_P_0 RELIABLE RECEIVE
+               (Parameter Payload)
+       )
+       (Class TestParameter_P_1 BEST_EFFORT RECEIVE 
+               (Parameter Payload)
+       )
+       (Class TestParameter_P_2 RELIABLE TIMESTAMP 
+               (Parameter Payload)
+       )
+       (Class TestParameter_P_3 BEST_EFFORT TIMESTAMP 
+               (Parameter Payload)
+       )
+    )
+  )
+)