NED File src/inet/applications/tcpapp/TcpBasicClientApp.ned
Name | Type | Description |
---|---|---|
TcpBasicClientApp | simple module |
Client for a generic request-response style protocol over TCP. May be used as a rough model of HTTP or FTP users. Compatible with both IPv4 (Ipv4) and IPv6 (Ipv6). |
Source code
// // Copyright (C) 2004 OpenSim Ltd. // // SPDX-License-Identifier: LGPL-3.0-or-later // package inet.applications.tcpapp; import inet.applications.contract.IApp; // // Client for a generic request-response style protocol over TCP. // May be used as a rough model of HTTP or FTP users. // Compatible with both IPv4 (~Ipv4) and IPv6 (~Ipv6). // // The model communicates with the server in sessions. During a session, // the client opens a single TCP connection to the server, sends several // requests (always waiting for the complete reply to arrive before // sending a new request), and closes the connection. // // The server app should be ~TcpGenericServerApp; the model sends ~GenericAppMsg // messages. // // Example settings: // // FTP: // <pre> // numRequestsPerSession = exponential(3) // requestLength = 1B*int(truncnormal(20,5)) // replyLength = 1B*int(exponential(1000000)) // </pre> // // Note that this module doesn't open separate TCP connections for commands // and data transfer as the FTP protocol. // // HTTP: // <pre> // numRequestsPerSession = 1 <i>(HTTP 1.0)</i> // numRequestsPerSession = exponential(5) <i>(HTTP 1.1, with keepalive)</i> // requestLength = 1B*int(truncnormal(350,20)) // replyLength = 1B*int(exponential(2000)) // </pre> // // Note that since most web pages contain images and may contain frames, // applets etc, possibly from various servers, and browsers usually download // these items in parallel to the main HTML document, this module cannot // serve as a realistic web client. // // Also, with HTTP 1.0 it is the server that closes the connection after // sending the response, while in this model it is the client. // // @see ~TcpGenericServerApp, ~GenericAppMsg, ~TelnetApp // simple TcpBasicClientApp like IApp { parameters: string localAddress = default(""); // may be left empty ("") int localPort = default(-1); // port number to listen on string connectAddress = default(""); // server address (may be symbolic) int connectPort = default(1000); // port number to connect to double startTime @unit(s) = default(1s); // time first session begins double stopTime @unit(s) = default(-1s); // time of finishing sending, negative values mean forever volatile int numRequestsPerSession = default(1); // number of requests sent per session volatile int requestLength @unit(B) = default(200B); // length of a request volatile int replyLength @unit(B) = default(1MiB); // length of a reply volatile double thinkTime @unit(s); // time gap between requests volatile double idleInterval @unit(s); // time gap between sessions volatile double reconnectInterval @unit(s) = default(30s); // if connection breaks, waits this much before trying to reconnect int timeToLive = default(-1); // if not -1, set the TTL (IPv4) or Hop Limit (IPv6) field of sent packets to this value int dscp = default(-1); // if not -1, set the DSCP (IPv4/IPv6) field of sent packets to this value int tos = default(-1); // if not -1, set the Type Of Service (IPv4) / Traffic Class (IPv6) field of sent packets to this value @display("i=block/app"); @lifecycleSupport; double stopOperationExtraTime @unit(s) = default(-1s); // extra time after lifecycle stop operation finished double stopOperationTimeout @unit(s) = default(2s); // timeout value for lifecycle stop operation @signal[packetSent](type=inet::Packet); @signal[packetReceived](type=inet::Packet); @signal[connect](type=long); // 1 for open, -1 for close @statistic[packetReceived](title="packets received"; source=packetReceived; record=count,"sum(packetBytes)","vector(packetBytes)"; interpolationmode=none); @statistic[packetSent](title="packets sent"; source=packetSent; record=count,"sum(packetBytes)","vector(packetBytes)"; interpolationmode=none); @statistic[endToEndDelay](title="end-to-end delay"; source="dataAge(packetReceived)"; unit=s; record=histogram,weightedHistogram,vector; interpolationmode=none); @statistic[numActiveSessions](title="number of active sessions"; source=warmup(sum(connect)); record=max,timeavg,vector; interpolationmode=sample-hold; autoWarmupFilter=false); @statistic[numSessions](title="total number of sessions"; source="sum(connect+1)/2"; record=last); gates: input socketIn @labels(TcpCommand/up); output socketOut @labels(TcpCommand/down); }