00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019 #ifndef __GAS_NetFetchData__
00020 #define __GAS_NetFetchData__
00021
00022 #include "GAS_API.h"
00023
00024 #include "GAS_SubSolver.h"
00025 #include "GAS_Utils.h"
00026
00027 class UT_NetExchange;
00028 class UT_NetMessage;
00029
00030 class GAS_API GAS_NetFetchData : public GAS_SubSolver
00031 {
00032 public:
00033 GET_DATA_FUNC_S(GAS_NAME_GEOMETRY, GeometryName);
00034
00035 GET_DATA_FUNC_S(GAS_NAME_TRACKERADDR, TrackerAddress);
00036 GET_DATA_FUNC_I(GAS_NAME_TRACKERPORT, TrackerPort);
00037 GET_DATA_FUNC_S(GAS_NAME_JOBNAME, JobName);
00038
00039 GET_DATA_FUNC_I("peer", Peer);
00040 GET_DATA_FUNC_I("npeer", NPeer);
00041 GET_DATA_FUNC_S("srcobject", SourceObject);
00042 GET_DATA_FUNC_S("srcdataname", SourceDataName);
00043 GET_DATA_FUNC_I("srcpeer", SourcePeer);
00044
00045 GET_DATA_FUNC_S("dstdataname", DestDataName);
00046 protected:
00047 explicit GAS_NetFetchData(const SIM_DataFactory *factory);
00048 virtual ~GAS_NetFetchData();
00049
00050
00051
00052 virtual bool solveGasSubclass(SIM_Engine &engine,
00053 SIM_Object *obj,
00054 SIM_Time time,
00055 SIM_Time timestep);
00056
00057 void processRequest(UT_NetExchange &netxchg,
00058 UT_NetMessage *msg,
00059 SIM_Engine &engine);
00060
00061 void postDataError(UT_NetExchange &netxchg,
00062 int dstpeer, const char *errmsg);
00063
00064 void attachData(SIM_Engine &engine,
00065 SIM_Object *obj,
00066 SIM_Time time,
00067 const char *dstdataname,
00068 const char *data,
00069 int len);
00070
00071 private:
00072 static const SIM_DopDescription *getDopDescription();
00073
00074 DECLARE_STANDARD_GETCASTTOTYPE();
00075 DECLARE_DATAFACTORY(GAS_NetFetchData,
00076 GAS_SubSolver,
00077 "Gas Net Fetch Data",
00078 getDopDescription());
00079 };
00080
00081 #endif
00082