Package de.uni_kl.cs.discodnc.network

Class Network

java.lang.Object

de.uni_kl.cs.discodnc.network.Network

public class Network
extends java.lang.Object

Servers in a network object correspond to buffers that may be shared by different flows, i.e., a network corresponds to the server graph of a (physical) network.

That means the path of a flow is a sequence of buffers crossed by it and the analysis operating on a network handles Server objects as such.

Please consider this when modeling a network for analysis. E.g., assuming output buffering in a simple wireless sensor network with one transceiver per node there is a 1:1-relation between network graph connecting wireless sensor nodes and servers in the DiscoDNC network.

A flows path, however, is a sequence of crossed buffers. As a flow usually does not reach the output buffer of its sink, the path should not contain a link to it. Otherwise the flow interference pattern of the network will be too pessimistic, yet, the results remain valid.

In practice, on can model a sink explicitly by setting the server's service curve to be an infinite burst after without delay ( see ServiceCurve.createZeroDelayBurst() ).

Field Summary

Fields

Modifier and Type	Field	Description
private java.lang.String	flow_default_name_prefix
private int	flow_id_counter
private java.util.Set<Flow>	flows
private java.lang.String	link_default_name_prefix
private int	link_id_counter
private java.util.Set<Link>	links
private java.util.Map<java.lang.Integer,Server>	map__id__server
private java.util.Map<Link,java.util.Set<Flow>>	map__link__flows
private java.util.Map<Server,java.util.Set<Flow>>	map__server__flows
private java.util.Map<Server,java.util.Set<Link>>	map__server__in_links
private java.util.Map<Server,java.util.Set<Link>>	map__server__out_links
private java.util.Map<Server,java.util.Set<Flow>>	map__server__source_flows
private java.lang.String	server_default_name_prefix
private int	server_id_counter
private java.util.Set<Server>	servers

Constructor Summary

Constructors

Constructor	Description
Network()

Method Summary

Modifier and Type	Method	Description
protected Flow	addFlow(ArrivalCurve arrival_curve, Path path)
Flow	addFlow(ArrivalCurve arrival_curve, Server single_hop)	Creates a flow and adds it to the network.
Flow	addFlow(ArrivalCurve arrival_curve, Server source, Server sink)	Creates a flow and adds it to the network.
Flow	addFlow(ArrivalCurve arrival_curve, java.util.List path)
Flow	addFlow(java.lang.String alias, ArrivalCurve arrival_curve, Server single_hop)	Creates a flow and adds it to the network.
Flow	addFlow(java.lang.String alias, ArrivalCurve arrival_curve, Server source, Server sink)	Creates a flow and adds it to the network.
Flow	addFlow(java.lang.String alias, ArrivalCurve arrival_curve, java.util.List path)	Creates a flow and adds it to the network.
private Flow	addFlowToNetwork(java.lang.String alias, ArrivalCurve arrival_curve, Path path)
Link	addLink(Server source, Server destination)
Link	addLink(java.lang.String alias, Server source, Server destination)
Server	addServer(ServiceCurve service_curve)
Server	addServer(ServiceCurve service_curve, MaxServiceCurve max_service_curve)	By default the server's use_gamma and use_extra_gamma are enabled
Server	addServer(ServiceCurve service_curve, MaxServiceCurve max_service_curve, boolean use_gamma, boolean use_extra_gamma)
Server	addServer(ServiceCurve service_curve, MaxServiceCurve max_service_curve, AnalysisConfig.Multiplexing multiplexing)
Server	addServer(ServiceCurve service_curve, MaxServiceCurve max_service_curve, AnalysisConfig.Multiplexing multiplexing, boolean use_gamma, boolean use_extra_gamma)
Server	addServer(ServiceCurve service_curve, AnalysisConfig.Multiplexing multiplexing)
Server	addServer(java.lang.String alias, ServiceCurve service_curve)
Server	addServer(java.lang.String alias, ServiceCurve service_curve, MaxServiceCurve max_service_curve)	By default the server's use_gamma and use_extra_gamma are enabled
Server	addServer(java.lang.String alias, ServiceCurve service_curve, MaxServiceCurve max_service_curve, boolean use_gamma, boolean use_extra_gamma)
Server	addServer(java.lang.String alias, ServiceCurve service_curve, MaxServiceCurve max_service_curve, AnalysisConfig.Multiplexing multiplexing)
Server	addServer(java.lang.String alias, ServiceCurve service_curve, MaxServiceCurve max_service_curve, AnalysisConfig.Multiplexing multiplexing, boolean use_gamma, boolean use_extra_gamma)
Server	addServer(java.lang.String alias, ServiceCurve service_curve, AnalysisConfig.Multiplexing multiplexing)
Network	copy()	Creates a deep copy of this network.
Path	createPath(Link link)
Path	createPath(Server server)
Path	createPath(java.util.List path)
Path	createPath(java.util.List<Server> path_servers, java.util.List<Link> path_links)
private Path	createPathFromLinks(java.util.List<Link> path_links)
private Path	createPathFromServers(java.util.List<Server> path_servers)
int	degree(Server s)
Link	findLink(Server src, Server dest)
Server	findSplittingServer(Server server_common_dest, java.util.Set<Flow> flows_of_interest)	Returns the server at which the flows in flows_of_interest first all meet each other (when viewed from the source).
java.util.Set<Flow>	getFlows()
java.util.Set<Flow>	getFlows(Link l)
java.util.Set<Flow>	getFlows(Path p)
java.util.Set<Flow>	getFlows(Server s)
java.util.Set<Flow>	getFlows(java.util.Set<Link> links)
java.util.Map<Server,java.util.Set<Flow>>	getFlowsPerServer(Path p, java.util.Set<Flow> excluded_flows)	Do not confuse with getServerJoiningFlowsMap
java.util.Map<Path,java.util.Set<Flow>>	getFlowsPerSubPath(Path p)	For every distinct sub-path of p this method returns the flows taking it entirely.
java.util.Set<Link>	getIncidentLinks(Server s)	Returns a new set consisting of references to the links.
java.util.Set<Link>	getInLinks(Server s)	Returns a new set consisting of references to the servers.
java.util.Set<Server>	getInOutServers()	Returns the subsets of all nodes of the directed graph g that are neither sources nor sinks, i.e.
java.util.Set<Link>	getLinks()
java.util.Set<Server>	getNeighbors(Server s)	Returns a new set consisting of references to the servers.
java.util.Set<Link>	getOutLinks(Server s)	Returns a new set consisting of references to the servers.
java.util.Set<Server>	getPredecessors(Server s)	Returns a new set consisting of references to the servers.
Server	getServer(int id)
java.util.Map<Server,java.util.Set<Flow>>	getServerJoiningFlowsMap(Path path)
java.util.Map<Server,java.util.Set<Flow>>	getServerLeavingFlowsMap(Path path)
java.util.Set<Server>	getServers()
Path	getShortestPath(Server src, Server snk)	Calculates the shortest path between src and snk according to Dijkstra's algorithm
java.util.Set<Server>	getSinkSet()	Returns the subsets of all nodes of the directed graph g that are sinks, i.e.
ArrivalCurve	getSourceFlowArrivalCurve(Server source)	Returns an aggregate arrival curve for all flows originating in source.
ArrivalCurve	getSourceFlowArrivalCurve(Server source, java.util.Set<Flow> source_flows)	Returns an aggregate arrival curve for all flows originating in source and contained in the set outgoing_flows.
java.util.Set<Flow>	getSourceFlows(Server source)
java.util.Set<Server>	getSourceSet()	Returns the subsets of all nodes of the directed graph g that are sources, i.e.
java.util.Set<Server>	getSuccessors(Server s)	Returns a new set consisting of references to the servers.
java.util.Map<Path,java.util.Set<Flow>>	groupFlowsPerSubPath(Path p, java.util.Set<Flow> flows_to_group)
int	inDegree(Server s)
int	numFlows()
int	numLinks()
int	numServers()
int	outDegree(Server s)
private void	remove(java.util.Set<Server> servers_to_remove, java.util.Set<Link> links_to_remove, java.util.Set<Flow> flows_to_remove)
void	removeFlow(Flow f)	Removes a flow from the network.
void	removeLink(Link l)
void	removeServer(Server s)
void	saveAs(java.lang.String output_path, java.lang.String file_name)
void	saveAs(java.lang.String output_path, java.lang.String file_name, java.lang.String package_name)
java.lang.String	toString()
private void	updateServerAdditionInternally(Server new_server)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

servers

private java.util.Set<Server> servers

links

private java.util.Set<Link> links

flows

private java.util.Set<Flow> flows

map__server__in_links

private java.util.Map<Server,java.util.Set<Link>> map__server__in_links

map__server__out_links

private java.util.Map<Server,java.util.Set<Link>> map__server__out_links

map__server__flows

private java.util.Map<Server,java.util.Set<Flow>> map__server__flows

map__server__source_flows

private java.util.Map<Server,java.util.Set<Flow>> map__server__source_flows

map__link__flows

private java.util.Map<Link,java.util.Set<Flow>> map__link__flows

server_default_name_prefix

private java.lang.String server_default_name_prefix

server_id_counter

private int server_id_counter

map__id__server

private java.util.Map<java.lang.Integer,Server> map__id__server

link_default_name_prefix

private java.lang.String link_default_name_prefix

link_id_counter

private int link_id_counter

flow_default_name_prefix

private java.lang.String flow_default_name_prefix

flow_id_counter

private int flow_id_counter

Constructor Detail

Network

public Network()

Method Detail

remove

private void remove(java.util.Set<Server> servers_to_remove,
                    java.util.Set<Link> links_to_remove,
                    java.util.Set<Flow> flows_to_remove)

addServer

public Server addServer(ServiceCurve service_curve)

addServer

public Server addServer(ServiceCurve service_curve,
                        AnalysisConfig.Multiplexing multiplexing)

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve)

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve,
                        AnalysisConfig.Multiplexing multiplexing)

addServer

public Server addServer(ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve)

By default the server's use_gamma and use_extra_gamma are enabled

Parameters:

service_curve - The server's service curve.

max_service_curve - The server's maximum service curve.

Returns:

The added server.

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve)

By default the server's use_gamma and use_extra_gamma are enabled

Parameters:

alias - The server's user-defined alias.

service_curve - The server's service curve.

max_service_curve - The server's maximum service curve.

Returns:

The added server.

addServer

public Server addServer(ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        boolean use_gamma,
                        boolean use_extra_gamma)

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        AnalysisConfig.Multiplexing multiplexing)

addServer

public Server addServer(ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        AnalysisConfig.Multiplexing multiplexing)

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        boolean use_gamma,
                        boolean use_extra_gamma)

addServer

public Server addServer(ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        AnalysisConfig.Multiplexing multiplexing,
                        boolean use_gamma,
                        boolean use_extra_gamma)

addServer

public Server addServer(java.lang.String alias,
                        ServiceCurve service_curve,
                        MaxServiceCurve max_service_curve,
                        AnalysisConfig.Multiplexing multiplexing,
                        boolean use_gamma,
                        boolean use_extra_gamma)

updateServerAdditionInternally

private void updateServerAdditionInternally(Server new_server)

removeServer

public void removeServer(Server s)
                  throws java.lang.Exception

Throws:

java.lang.Exception

getSourceFlows

public java.util.Set<Flow> getSourceFlows(Server source)

getServer

public Server getServer(int id)
                 throws java.lang.Exception

Throws:

java.lang.Exception

getServers

public java.util.Set<Server> getServers()

numServers

public int numServers()

getInOutServers

public java.util.Set<Server> getInOutServers()

Returns the subsets of all nodes of the directed graph g that are neither sources nor sinks, i.e. who have both (a) predecessor(s) and (a) successor(s) (in-degree > 0 and out-degree > 0).

Returns:

the set of server nodes

getSourceSet

public java.util.Set<Server> getSourceSet()

Returns the subsets of all nodes of the directed graph g that are sources, i.e. whose predecessor set is empty (in-degree == 0).

Returns:

the set of source nodes

getSinkSet

public java.util.Set<Server> getSinkSet()

Returns the subsets of all nodes of the directed graph g that are sinks, i.e. whose successor set is empty (out-degree == 0).

Returns:

the set of sink nodes

degree

public int degree(Server s)

inDegree

public int inDegree(Server s)

outDegree

public int outDegree(Server s)

getInLinks

public java.util.Set<Link> getInLinks(Server s)

Returns a new set consisting of references to the servers.

Parameters:

s - The server whose inlinks are returned.

Returns:

The incoming links of s.

getOutLinks

public java.util.Set<Link> getOutLinks(Server s)

Returns a new set consisting of references to the servers.

Parameters:

s - The server whose outlinks are returned.

Returns:

The outgoing links of s.

getIncidentLinks

public java.util.Set<Link> getIncidentLinks(Server s)

Returns a new set consisting of references to the links.

Parameters:

s - The server whose inlinks and outlinks are returned.

Returns:

The incident links.

getNeighbors

public java.util.Set<Server> getNeighbors(Server s)

Returns a new set consisting of references to the servers.

Parameters:

s - The server whose inlink sources and outlink destinations are returned.

Returns:

The neighboring servers of s.

getPredecessors

public java.util.Set<Server> getPredecessors(Server s)

Returns a new set consisting of references to the servers.

Parameters:

s - The server whose inlink sources are returned.

Returns:

The source servers of incoming links of s

getSuccessors

public java.util.Set<Server> getSuccessors(Server s)

Returns a new set consisting of references to the servers.

Parameters:

s - The server whose outlink destinations are returned.

Returns:

The sink servers of outgoing links of s.

addLink

public Link addLink(Server source,
                    Server destination)
             throws java.lang.Exception

Throws:

java.lang.Exception

addLink

public Link addLink(java.lang.String alias,
                    Server source,
                    Server destination)
             throws java.lang.Exception

Throws:

java.lang.Exception

removeLink

public void removeLink(Link l)
                throws java.lang.Exception

Throws:

java.lang.Exception

getLinks

public java.util.Set<Link> getLinks()

numLinks

public int numLinks()

findLink

public Link findLink(Server src,
                     Server dest)
              throws java.lang.Exception

Parameters:

src - The link's source.

dest - The link's destination.

Returns:

The link from src to dest.

Throws:

java.lang.Exception - No link from src to snk found in this network.

addFlow

public Flow addFlow(ArrivalCurve arrival_curve,
                    java.util.List path)
             throws java.lang.Exception

Throws:

java.lang.Exception

addFlow

protected Flow addFlow(ArrivalCurve arrival_curve,
                       Path path)
                throws java.lang.Exception

Throws:

java.lang.Exception

addFlow

public Flow addFlow(ArrivalCurve arrival_curve,
                    Server source,
                    Server sink)
             throws java.lang.Exception

Creates a flow and adds it to the network.

Parameters:

arrival_curve - The flow's arrival curve.

source - Source for shortest path routing.

sink - Sink for shortest path routing.

Returns:

The flow created and added to the network.

Throws:

java.lang.Exception - Could not create a path from the given source/sink-pair.

addFlow

public Flow addFlow(java.lang.String alias,
                    ArrivalCurve arrival_curve,
                    Server source,
                    Server sink)
             throws java.lang.Exception

Creates a flow and adds it to the network.

Parameters:

alias - The flow's user defined-alias.

arrival_curve - The flow's arrival curve.

source - Source for shortest path routing.

sink - Sink for shortest path routing.

Returns:

The flow created and added to the network.

Throws:

java.lang.Exception - Could not create a path from the given source/sink-pair.

addFlow

public Flow addFlow(java.lang.String alias,
                    ArrivalCurve arrival_curve,
                    java.util.List path)
             throws java.lang.Exception

Creates a flow and adds it to the network.

Parameters:

alias - The flow's user defined-alias.

arrival_curve - The flow's arrival curve.

path - The flows path as a list of servers or links.

Returns:

The flow created and added to the network.

Throws:

java.lang.Exception - The given path is not entirely in the network.

addFlow

public Flow addFlow(ArrivalCurve arrival_curve,
                    Server single_hop)
             throws java.lang.Exception

Creates a flow and adds it to the network.

Parameters:

arrival_curve - The flow's arrival curve.

single_hop - The single hop the flow takes in the network.

Returns:

The flow created and added to the network.

Throws:

java.lang.Exception - The given server is not in the network.

addFlow

public Flow addFlow(java.lang.String alias,
                    ArrivalCurve arrival_curve,
                    Server single_hop)
             throws java.lang.Exception

Creates a flow and adds it to the network.

Parameters:

alias - The flow's user defined-alias.

arrival_curve - The flow's arrival curve.

single_hop - The single hop the flow takes in the network.

Returns:

The flow created and added to the network.

Throws:

java.lang.Exception - The given server is not in the network.

addFlowToNetwork

private Flow addFlowToNetwork(java.lang.String alias,
                              ArrivalCurve arrival_curve,
                              Path path)
                       throws java.lang.Exception

Throws:

java.lang.Exception

removeFlow

public void removeFlow(Flow f)
                throws java.lang.Exception

Removes a flow from the network.

Parameters:

f - The flow to be removed.

Throws:

java.lang.Exception - Flow to be removed is not in this network's list of flows.

getFlows

public java.util.Set<Flow> getFlows()

numFlows

public int numFlows()

getFlows

public java.util.Set<Flow> getFlows(Link l)

getFlows

public java.util.Set<Flow> getFlows(java.util.Set<Link> links)

getFlows

public java.util.Set<Flow> getFlows(Server s)

getFlows

public java.util.Set<Flow> getFlows(Path p)
                             throws java.lang.Exception

Throws:

java.lang.Exception

getFlowsPerServer

public java.util.Map<Server,java.util.Set<Flow>> getFlowsPerServer(Path p,
                                                                   java.util.Set<Flow> excluded_flows)
                                                            throws java.lang.Exception

Do not confuse with getServerJoiningFlowsMap

Parameters:

p - The path to split up into its hops and analyze for flows.

excluded_flows - Flows to omit in the sorting operation.

Returns:

Map from a server to the flows present at this servers.

Throws:

java.lang.Exception - Could not sort although there may be flows.

getFlowsPerSubPath

public java.util.Map<Path,java.util.Set<Flow>> getFlowsPerSubPath(Path p)
                                                           throws java.lang.Exception

For every distinct sub-path of p this method returns the flows taking it entirely.

Parameters:

p - The path to split up and analyze for flows.

Returns:

Map from a path to the flows taking exactly this tandem of servers.

Throws:

java.lang.Exception - Could not sort although there may be flows.

groupFlowsPerSubPath

public java.util.Map<Path,java.util.Set<Flow>> groupFlowsPerSubPath(Path p,
                                                                    java.util.Set<Flow> flows_to_group)
                                                             throws java.lang.Exception

Throws:

java.lang.Exception

getSourceFlowArrivalCurve

public ArrivalCurve getSourceFlowArrivalCurve(Server source)

Returns an aggregate arrival curve for all flows originating in source.

Returns a null curve if there are no source flows at source.

Parameters:

source - The source of all flows to be aggregated.

Returns:

An aggregate arrival curve.

getSourceFlowArrivalCurve

public ArrivalCurve getSourceFlowArrivalCurve(Server source,
                                              java.util.Set<Flow> source_flows)

Returns an aggregate arrival curve for all flows originating in source and contained in the set outgoing_flows.

Returns a null curve if the intersection of those sets of curves is empty.

Parameters:

source - The source of all flows to be aggregated.

source_flows - The set of all flows to be aggregated.

Returns:

An aggregate arrival curve.

createPath

public Path createPath(Server server)
                throws java.lang.Exception

Throws:

java.lang.Exception

createPath

public Path createPath(Link link)
                throws java.lang.Exception

Throws:

java.lang.Exception

createPath

public Path createPath(java.util.List path)
                throws java.lang.Exception

Throws:

java.lang.Exception

createPathFromServers

private Path createPathFromServers(java.util.List<Server> path_servers)
                            throws java.lang.Exception

Throws:

java.lang.Exception

createPathFromLinks

private Path createPathFromLinks(java.util.List<Link> path_links)
                          throws java.lang.Exception

Throws:

java.lang.Exception

createPath

public Path createPath(java.util.List<Server> path_servers,
                       java.util.List<Link> path_links)
                throws java.lang.Exception

Throws:

java.lang.Exception

getServerJoiningFlowsMap

public java.util.Map<Server,java.util.Set<Flow>> getServerJoiningFlowsMap(Path path)
                                                                   throws java.lang.Exception

Parameters:

path - The tandem of servers to check for flows.

flows_to_join - Flows not in the return set
null will be handled as empty set of flows.

Returns:

The joining flows.

Throws:

java.lang.Exception - Could not derive the joining flows even if there are.

getServerLeavingFlowsMap

public java.util.Map<Server,java.util.Set<Flow>> getServerLeavingFlowsMap(Path path)
                                                                   throws java.lang.Exception

Throws:

java.lang.Exception

getShortestPath

public Path getShortestPath(Server src,
                            Server snk)
                     throws java.lang.Exception

Calculates the shortest path between src and snk according to Dijkstra's algorithm

Parameters:

src - The path's source.

snk - The path's sink.

Returns:

Dijkstra shortest path from src to snk.

Throws:

java.lang.Exception - Could not find a shortest path for some reason.

findSplittingServer

public Server findSplittingServer(Server server_common_dest,
                                  java.util.Set<Flow> flows_of_interest)
                           throws java.lang.Exception

Returns the server at which the flows in flows_of_interest first all meet each other (when viewed from the source). When viewed from server towards the sink, this is the last server where all flows are still together.

Parameters:

server_common_dest - The common destination.

flows_of_interest - The flow of interest.

Returns:

the splitting point server The common source.

Throws:

java.lang.Exception - No splitting point prior to the common destination found.

copy

public Network copy()
             throws java.lang.Exception

Creates a deep copy of this network.

Returns:

The copy.

Throws:

java.lang.Exception - Signals problems while instantiating the copy.

saveAs

public void saveAs(java.lang.String output_path,
                   java.lang.String file_name)
            throws java.lang.Exception

Throws:

java.lang.Exception

saveAs

public void saveAs(java.lang.String output_path,
                   java.lang.String file_name,
                   java.lang.String package_name)
            throws java.lang.Exception

Throws:

java.lang.Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object