X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3415111c9b5acc19a1df8352138fe56d02e35eea..10f9486dac2f7819d90fa72a022509ae4aa33908:/src/surf/gtnets/gtnets_simulator.h diff --git a/src/surf/gtnets/gtnets_simulator.h b/src/surf/gtnets/gtnets_simulator.h index 1b5f50efff..15faec73b4 100644 --- a/src/surf/gtnets/gtnets_simulator.h +++ b/src/surf/gtnets/gtnets_simulator.h @@ -15,16 +15,15 @@ #include //GTNetS include files -#include "simulator.h" // Definitions for the Simulator Object -#include "node.h" // Definitions for the Node Object -#include "linkp2p.h" // Definitions for point-to-point link objects -#include "ratetimeparse.h" // Definitions for Rate and Time objects -#include "application-tcpserver.h" // Definitions for TCPServer application -#include "application-tcpsend.h" // Definitions for TCP Sending application -#include "tcp-tahoe.h" // Definitions for TCP Tahoe +#include "simulator.h" // Definitions for the Simulator Object +#include "node.h" // Definitions for the Node Object +#include "linkp2p.h" // Definitions for point-to-point link objects +#include "ratetimeparse.h" // Definitions for Rate and Time objects +#include "application-tcpserver.h" // Definitions for TCPServer application +#include "application-tcpsend.h" // Definitions for TCP Sending application +#include "tcp-tahoe.h" // Definitions for TCP Tahoe #include "tcp-reno.h" #include "tcp-newreno.h" -#include "validation.h" #include "event.h" #include "routing-manual.h" @@ -36,43 +35,42 @@ class GTSim { public: GTSim(); ~GTSim(); -public: +public: int add_link(int id, double bandwidth, double latency); int add_onehop_route(int src, int dst, int link); - int add_route(int src, int dst, int* links, int nlink); + int add_route(int src, int dst, int *links, int nlink); int add_router(int id); - int create_flow(int src, int dst, long datasize, void* metadata); + int create_flow(int src, int dst, long datasize, void *metadata); double get_time_to_next_flow_completion(); - int run_until_next_flow_completion(void*** metadata, int* number_of_flows); + int run_until_next_flow_completion(void ***metadata, int *number_of_flows); int run(double deltat); - //added by pedro, returns the total received by the TCPServer peer of the given action + // returns the total received by the TCPServer peer of the given action double gtnets_get_flow_rx(void *metadata); void create_gtnets_topology(); + void print_topology(); private: void add_nodes(); void node_connect(); bool node_include(int); bool link_include(int); - Simulator* sim_; - GTNETS_Topology* topo_; - RoutingManual* rm_; + Simulator *sim_; + GTNETS_Topology *topo_; + RoutingManual *rm_; int nnode_; int is_topology_; int nflow_; - map gtnets_servers_; - map gtnets_clients_; - map gtnets_links_; - map gtnets_nodes_; + map < int, TCPServer * >gtnets_servers_; + map < int, TCPSend * >gtnets_clients_; + map < int, Linkp2p * >gtnets_links_; + map < int, Node * >gtnets_nodes_; //added by pedro in order to get statistics - map gtnets_action_to_flow_; + map < void *, int >gtnets_action_to_flow_; - map gtnets_metadata_; + map < int, void *>gtnets_metadata_; }; #endif /* __cplusplus */ #endif - -