Package: inet.applications.tcpapp
TelnetApp
simple moduleModels Telnet sessions with a specific user behaviour. The server app should be TcpGenericServerApp. Compatible with both Ipv4 and Ipv6.
NOTE: This module emulates a very specific user behaviour, and as such, it should be viewed as an example rather than a generic Telnet model. If you want to model realistic Telnet traffic, you are encouraged to gather statistics from packet traces on a real network, and write your model accordingly.
Inheritance diagram
The following diagram shows inheritance relationships for this type. Unresolved types are missing from the diagram.
Parameters
Name | Type | Default value | Description |
---|---|---|---|
localAddress | string | "" |
local address or empty ("") |
localPort | int |
local port number |
|
connectAddress | string |
server address (may be symbolic) |
|
connectPort | int | 1000 |
port number to connect to |
startTime | double | 1s |
time first session begins |
stopTime | double | -1s |
time of finishing sending, negative values mean forever |
numCommands | int | int(exponential(10)) |
user types this many commands in a session |
commandLength | int | 10B |
commands are this many characters (plus Enter) |
keyPressDelay | double | exponential(0.1s) |
delay between keypresses |
commandOutputLength | int | intWithUnit(exponential(1000B)) |
commands produce this much output |
thinkTime | double | exponential(10s) |
user waits this much before starting to type new command |
idleInterval | double | exponential(300s) |
time gap between sessions |
reconnectInterval | double | 30s |
if connection breaks, user waits this much before trying to reconnect |
timeToLive | int | -1 |
if not -1, set the TTL (IPv4) or Hop Limit (IPv6) field of sent packets to this value |
dscp | int | -1 |
if not -1, set the ToS (IPv4) or Traffic Class (IPv6) field of sent packets to this value |
tos | int | -1 |
if not -1, set the Type Of Service (IPv4) / Traffic Class (IPv6) field of sent packets to this value |
stopOperationExtraTime | double | -1s |
extra time after lifecycle stop operation finished |
stopOperationTimeout | double | 2s |
timeout value for lifecycle stop operation |
Properties
Name | Value | Description |
---|---|---|
display | i=block/telnet | |
lifecycleSupport |
Gates
Name | Direction | Size | Description |
---|---|---|---|
socketIn | input | ||
socketOut | output |
Signals
Name | Type | Unit |
---|---|---|
packetReceived | inet::Packet | |
packetSent | inet::Packet | |
connect | long |
Statistics
Name | Title | Source | Record | Unit | Interpolation Mode |
---|---|---|---|---|---|
packetReceived | packets received | packetReceived | count, sum(packetBytes), vector(packetBytes) | none | |
numSessions | total number of sessions | sum(connect+1)/2 | last | ||
packetSent | packets sent | packetSent | count, sum(packetBytes), vector(packetBytes) | none | |
numActiveSessions | number of active sessions | warmup(sum(connect)) | max, timeavg, vector | sample-hold | |
endToEndDelay | end-to-end delay | dataAge(packetReceived) | histogram, weightedHistogram, vector | s | none |
Scheduled messages (observed)
msg | kind | ctrl | tags | msgname | context |
---|---|---|---|---|---|
omnetpp::cMessage | 0 | timer | |||
omnetpp::cMessage | 1 | timer | |||
omnetpp::cMessage | 2 | timer |
Direct method calls (observed)
call to | function | info |
---|---|---|
MessageDispatcher | inet::MessageDispatcher::arrived | arrived |
ScenarioManager | inet::ScenarioManager::moduleOperationStageCompleted | moduleOperationStageCompleted |
Called methods (observed)
function | info | call from |
---|---|---|
inet::TelnetApp::handleOperationStage | handleOperationStage | ScenarioManager |
Incoming messages (observed)
gate | msg | kind | ctrl | srcModule | tags |
---|---|---|---|---|---|
socketIn | Indication | 4 (TcpStatusInd::TCP_I_ESTABLISHED) | TcpConnectInfo | Tcp | SocketInd |
socketIn | Indication | 4 (TcpStatusInd::TCP_I_ESTABLISHED) | TcpConnectInfo | TcpLwip | SocketInd, TransportProtocolInd |
socketIn | Indication | 6 (TcpStatusInd::TCP_I_CLOSED) | TcpCommand | Tcp | SocketInd |
socketIn | Packet | 1 (TcpStatusInd::TCP_I_DATA) | Tcp | SocketInd |
Outgoing messages (observed)
gate | msg | kind | ctrl | destModule | tags |
---|---|---|---|---|---|
socketOut | Packet | 4 (TcpCommandCode::TCP_C_SEND) | Tcp | DispatchProtocolReq, SocketReq | |
socketOut | Packet | 4 (TcpCommandCode::TCP_C_SEND) | TcpLwip | DispatchProtocolReq, SocketReq | |
socketOut | Request | 1 (TcpCommandCode::TCP_C_OPEN_ACTIVE) | TcpOpenCommand | Tcp | DispatchProtocolReq, SocketReq |
socketOut | Request | 1 (TcpCommandCode::TCP_C_OPEN_ACTIVE) | TcpOpenCommand | TcpLwip | DispatchProtocolReq, SocketReq |
socketOut | Request | 5 (TcpCommandCode::TCP_C_CLOSE) | TcpCommand | Tcp | DispatchProtocolReq, SocketReq |
Packet operations (observed)
chunkType | packetAction |
---|---|
peekData | |
GenericAppMsg | insertAtBack |
Shared Tagging operations (observed)
tagType | tagAction |
---|---|
DispatchProtocolReq | addTagIfAbsent |
SocketInd | findTag |
SocketReq | addTagIfAbsent |
Region Tagging operations (observed)
tagType | tagAction |
---|---|
CreationTimeTag | addTag, getAllTags |
Tagging operations (observed)
tagType | tagAction |
---|---|
inet::Ipv4InterfaceData | findTag |
inet::Ipv6InterfaceData | findTag |
Source code
// // Models Telnet sessions with a specific user behaviour. // The server app should be ~TcpGenericServerApp. // Compatible with both ~Ipv4 and ~Ipv6. // // NOTE: This module emulates a very specific user behaviour, and as such, // it should be viewed as an example rather than a generic Telnet model. // If you want to model realistic Telnet traffic, you are encouraged // to gather statistics from packet traces on a real network, and // write your model accordingly. // simple TelnetApp like IApp { parameters: string localAddress = default(""); // local address or empty ("") int localPort; // local port number string connectAddress; // 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 numCommands = default(int(exponential(10))); // user types this many commands in a session volatile int commandLength @unit(B) = default(10B); // commands are this many characters (plus Enter) volatile double keyPressDelay @unit(s) = default(exponential(0.1s)); // delay between keypresses volatile int commandOutputLength @unit(B) = default(intWithUnit(exponential(1000B))); // commands produce this much output volatile double thinkTime @unit(s) = default(exponential(10s)); // user waits this much before starting to type new command volatile double idleInterval @unit(s) = default(exponential(300s)); // time gap between sessions volatile double reconnectInterval @unit(s) = default(30s); // if connection breaks, user 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 ToS (IPv4) or Traffic Class (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/telnet"); @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); }File: src/inet/applications/tcpapp/TelnetApp.ned