1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// Copyright (c) Clifton Labs, Inc.
// All rights reserved.
// CLIFTON LABS MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE
// SUITABILITY OF THE SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT
// NOT LIMITED TO THE IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
// PARTICULAR PURPOSE, OR NON-INFRINGEMENT. CLIFTON LABS SHALL NOT BE
// LIABLE FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, RESULT
// OF USING, MODIFYING OR DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES.
// By using or copying this Software, Licensee agrees to abide by the
// intellectual property laws, and all other applicable laws of the
// U.S., and the terms of this license.
// Authors: Malolan Chetlur mal@ececs.uc.edu
// Jorgen Dahl dahlj@ececs.uc.edu
// Dale E. Martin dmartin@ececs.uc.edu
// Radharamanan Radhakrishnan ramanan@ececs.uc.edu
// Dhananjai Madhava Rao dmadhava@ececs.uc.edu
// Philip A. Wilsey phil.wilsey@uc.edu
//---------------------------------------------------------------------------
//
// $Id: PingPongApplication.cpp,v 1.9 2003/02/18 21:31:06 dmartin Exp $
//
//---------------------------------------------------------------------------
#include "PingPongApplication.h"
#include "PingObject.h"
#include "PingEvent.h"
#include <warped/PartitionInfo.h>
#include <warped/RoundRobinPartitioner.h>
#include <warped/DeserializerManager.h>
#include <clutils/ArgumentParser.h>
#include <vector>
using std::string;
PingPongApplication::PingPongApplication( unsigned int initNumObjects,
unsigned int initNumEventsPerObject,
unsigned int initNumBallsAtOnce,
bool initRandomDelays )
: numObjects( initNumObjects ),
numEventsPerObject( initNumEventsPerObject ),
numBallsAtOnce( initNumBallsAtOnce ),
randomDelays( initRandomDelays ){}
int
PingPongApplication::initialize( vector<string> &arguments ){
getArgumentParser().checkArgs( arguments );
return 0;
}
int
PingPongApplication::getNumberOfSimulationObjects(int mgrId) const {
return numObjects;
}
vector<SimulationObject *> *
PingPongApplication::getSimulationObjects(){
vector<SimulationObject *> *retval = new vector<SimulationObject *>;
retval->reserve( numObjects );
// The first and last objects are special...
int mastersLeft = numBallsAtOnce;
bool master = false;
for( unsigned int i = 0; i < numObjects - 1; i++ ){
if( mastersLeft-- > 0 ){
master = true;
}
else{
master = false;
}
retval->push_back( new PingObject( i,
PingObject::getName( i + 1 ),
numEventsPerObject,
master,
randomDelays
) );
}
if( mastersLeft-- > 0 ){
master = true;
}
else{
master = false;
}
retval->push_back( new PingObject( numObjects - 1,
PingObject::getName( 0 ),
numEventsPerObject,
master,
randomDelays ) );
return retval;
}
const PartitionInfo *
PingPongApplication::getPartitionInfo( unsigned int numberOfProcessorsAvailable ){
const PartitionInfo *retval = 0;
Partitioner *myPartitioner = new RoundRobinPartitioner();
// Now we'll create some simulation objects...
vector<SimulationObject *> *objects = getSimulationObjects();
retval = myPartitioner->partition( objects, numberOfProcessorsAvailable );
delete objects;
return retval;
}
int
PingPongApplication::finalize(){
return 0;
}
void
PingPongApplication::registerDeserializers(){
DeserializerManager::instance()->registerDeserializer( PingEvent::getPingEventDataType(),
&PingEvent::deserialize );
}
ArgumentParser &
PingPongApplication::getArgumentParser(){
static ArgumentParser::ArgRecord args[] = {
{ "-numBalls", "number of balls", &numEventsPerObject, ArgumentParser::INTEGER, false },
{ "-numPlayers", "number of simulation objects to pass the balls", &numObjects, ArgumentParser::INTEGER, false },
{ "-numAtOnce", "number of balls circulating at once", &numBallsAtOnce, ArgumentParser::INTEGER, false },
{ "-randomDelays", "should the simulation objects wait random amounts of time", &randomDelays, ArgumentParser::BOOLEAN, false },
{ "", "", 0 }
};
static ArgumentParser *myArgParser = new ArgumentParser( args );
return *myArgParser;
}
|
