| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357 |
- <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN"
- "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
- <html xmlns="http://www.w3.org/1999/xhtml">
- <head>
- <meta http-equiv="X-UA-Compatible" content="IE=Edge" />
- <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
- <title>pypdevsbbl.tracers.StatisticsTracer — Python(P)DEVS-BBL documentation</title>
- <link rel="stylesheet" href="../../../_static/nature.css" type="text/css" />
- <link rel="stylesheet" href="../../../_static/pygments.css" type="text/css" />
- <link rel="stylesheet" type="text/css" href="../../../_static/custom.css" />
- <script type="text/javascript" id="documentation_options" data-url_root="../../../" src="../../../_static/documentation_options.js"></script>
- <script type="text/javascript" src="../../../_static/jquery.js"></script>
- <script type="text/javascript" src="../../../_static/underscore.js"></script>
- <script type="text/javascript" src="../../../_static/doctools.js"></script>
- <script type="text/javascript" src="../../../_static/language_data.js"></script>
- <script async="async" type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/mathjax/2.7.5/latest.js?config=TeX-AMS-MML_HTMLorMML"></script>
- <link rel="index" title="Index" href="../../../genindex.html" />
- <link rel="search" title="Search" href="../../../search.html" />
- </head><body>
- <div class="related" role="navigation" aria-label="related navigation">
- <h3>Navigation</h3>
- <ul>
- <li class="right" style="margin-right: 10px">
- <a href="../../../genindex.html" title="General Index"
- accesskey="I">index</a></li>
- <li class="right" >
- <a href="../../../py-modindex.html" title="Python Module Index"
- >modules</a> |</li>
- <li class="nav-item nav-item-0"><a href="../../../index.html">Python(P)DEVS-BBL documentation</a> »</li>
- <li class="nav-item nav-item-1"><a href="../../index.html" >Module code</a> »</li>
- <li class="nav-item nav-item-2"><a href="../tracers.html" accesskey="U">pypdevsbbl.tracers</a> »</li>
- </ul>
- </div>
- <div class="document">
- <div class="documentwrapper">
- <div class="bodywrapper">
- <div class="body" role="main">
-
- <h1>Source code for pypdevsbbl.tracers.StatisticsTracer</h1><div class="highlight"><pre>
- <span></span><span class="c1"># Copyright 2020 Modelling, Simulation and Design Lab (MSDL) at</span>
- <span class="c1"># McGill University and the University of Antwerp (http://msdl.cs.mcgill.ca/)</span>
- <span class="c1">#</span>
- <span class="c1"># Licensed under the Apache License, Version 2.0 (the "License");</span>
- <span class="c1"># you may not use this file except in compliance with the License.</span>
- <span class="c1"># You may obtain a copy of the License at</span>
- <span class="c1">#</span>
- <span class="c1"># http://www.apache.org/licenses/LICENSE-2.0</span>
- <span class="c1">#</span>
- <span class="c1"># Unless required by applicable law or agreed to in writing, software</span>
- <span class="c1"># distributed under the License is distributed on an "AS IS" BASIS,</span>
- <span class="c1"># WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span>
- <span class="c1"># See the License for the specific language governing permissions and</span>
- <span class="c1"># limitations under the License.</span>
- <span class="sd">"""This file contains the tracer for statistical data."""</span>
- <span class="kn">from</span> <span class="nn">pypdevsbbl.tracers</span> <span class="kn">import</span> <span class="n">BaseTracer</span>
- <span class="kn">import</span> <span class="nn">numpy</span> <span class="k">as</span> <span class="nn">np</span>
- <span class="kn">from</span> <span class="nn">pypdevs.DEVS</span> <span class="kn">import</span> <span class="n">CoupledDEVS</span>
- <span class="kn">from</span> <span class="nn">pypdevs.minimal</span> <span class="kn">import</span> <span class="n">CoupledDEVS</span> <span class="k">as</span> <span class="n">minCoupledDEVS</span>
- <div class="viewcode-block" id="StatisticsTracer"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer">[docs]</a><span class="k">class</span> <span class="nc">StatisticsTracer</span><span class="p">(</span><span class="n">BaseTracer</span><span class="p">):</span>
- <span class="sd">"""Gathers information about the messages in a (sub)model.</span>
- <span class="sd"> It can compute:</span>
- <span class="sd"> - The average time of messages in the system.</span>
- <span class="sd"> - The average amount of messages in the system for a certain</span>
- <span class="sd"> time period.</span>
- <span class="sd"> - The (amount of) messages that entered the system.</span>
- <span class="sd"> - The (amount of) messages that left the system.</span>
- <span class="sd"> - The (amount of) messages that were newly generated.</span>
- <span class="sd"> - The (amount of) messages that were discarded or left behind.</span>
- <span class="sd"> The internal depiction of a message is a tiplet:</span>
- <span class="sd"> ``(message, arrival time, departure time)``.</span>
- <span class="sd"> Note:</span>
- <span class="sd"> The tracer makes use of the :meth:`id` function to determine</span>
- <span class="sd"> which message entered and left. When your messages may change</span>
- <span class="sd"> order (when using a different queueing discipline or so), make</span>
- <span class="sd"> sure the messages can be uniquely identified afterwards.</span>
- <span class="sd"> It would also be non-sensical to have a</span>
- <span class="sd"> :class:`pypdevsbbl.generic.generators.ConstantGenerator` generate a</span>
- <span class="sd"> single value and change the order in which they arrive. All</span>
- <span class="sd"> messages are the same, so how would you determine they have</span>
- <span class="sd"> a different order of arrival?</span>
- <span class="sd"> Args:</span>
- <span class="sd"> uid: A unique identifier for distributed simulation.</span>
- <span class="sd"> Will be set automatically.</span>
- <span class="sd"> server: The server that runs the distributed simulation.</span>
- <span class="sd"> Will be set automatically.</span>
- <span class="sd"> filename (str): The name of the file to write the results to.</span>
- <span class="sd"> When ``None``, all results will be written to the</span>
- <span class="sd"> standard output.</span>
- <span class="sd"> inports (list): A list of the input ports to listen on for events</span>
- <span class="sd"> that enter the system. These may be ports of a</span>
- <span class="sd"> coupled DEVS.</span>
- <span class="sd"> outports (list): A list of the output ports to listen on for events</span>
- <span class="sd"> that leave the system. These may be ports of a</span>
- <span class="sd"> coupled DEVS.</span>
- <span class="sd"> """</span>
- <span class="k">def</span> <span class="fm">__init__</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">uid</span><span class="p">,</span> <span class="n">server</span><span class="p">,</span> <span class="n">filename</span><span class="p">,</span> <span class="n">inports</span><span class="p">,</span> <span class="n">outports</span><span class="p">):</span>
- <span class="nb">super</span><span class="p">(</span><span class="n">StatisticsTracer</span><span class="p">,</span> <span class="bp">self</span><span class="p">)</span><span class="o">.</span><span class="fm">__init__</span><span class="p">(</span><span class="n">uid</span><span class="p">,</span> <span class="n">server</span><span class="p">,</span> <span class="n">filename</span><span class="p">)</span>
- <span class="k">for</span> <span class="n">p</span> <span class="ow">in</span> <span class="n">inports</span><span class="p">:</span>
- <span class="k">if</span> <span class="ow">not</span> <span class="n">p</span><span class="o">.</span><span class="n">is_input</span><span class="p">:</span>
- <span class="k">raise</span> <span class="ne">TypeError</span><span class="p">(</span><span class="s2">"Inport must be an input port in </span><span class="si">%s</span><span class="s2">.</span><span class="si">%s</span><span class="s2">"</span> <span class="o">%</span> <span class="p">(</span><span class="n">p</span><span class="o">.</span><span class="n">host_DEVS</span><span class="o">.</span><span class="n">name</span><span class="p">,</span> <span class="n">p</span><span class="o">.</span><span class="n">name</span><span class="p">))</span>
- <span class="k">for</span> <span class="n">p</span> <span class="ow">in</span> <span class="n">outports</span><span class="p">:</span>
- <span class="k">if</span> <span class="n">p</span><span class="o">.</span><span class="n">is_input</span><span class="p">:</span>
- <span class="k">raise</span> <span class="ne">TypeError</span><span class="p">(</span><span class="s2">"Outport must be an output port in </span><span class="si">%s</span><span class="s2">.</span><span class="si">%s</span><span class="s2">"</span> <span class="o">%</span> <span class="p">(</span><span class="n">p</span><span class="o">.</span><span class="n">host_DEVS</span><span class="o">.</span><span class="n">name</span><span class="p">,</span> <span class="n">p</span><span class="o">.</span><span class="n">name</span><span class="p">))</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="o">=</span> <span class="p">{}</span>
- <span class="c1"># Internally solve coupled DEVS</span>
- <span class="c1"># This is needed because of the flattening the DEVS simulator applies.</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inports</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inDEVS</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="k">for</span> <span class="n">port</span> <span class="ow">in</span> <span class="n">inports</span><span class="p">:</span>
- <span class="k">if</span> <span class="n">port</span><span class="o">.</span><span class="n">type</span><span class="p">()</span> <span class="o">!=</span> <span class="s1">'INPORT'</span><span class="p">:</span>
- <span class="k">raise</span> <span class="ne">TypeError</span><span class="p">(</span><span class="s2">"Can only listen on inports for messages that enter the submodel."</span><span class="p">)</span>
- <span class="n">dvs</span> <span class="o">=</span> <span class="n">port</span><span class="o">.</span><span class="n">host_DEVS</span>
- <span class="k">if</span> <span class="nb">issubclass</span><span class="p">(</span><span class="nb">type</span><span class="p">(</span><span class="n">dvs</span><span class="p">),</span> <span class="p">(</span><span class="n">CoupledDEVS</span><span class="p">,</span> <span class="n">minCoupledDEVS</span><span class="p">)):</span>
- <span class="k">if</span> <span class="nb">len</span><span class="p">(</span><span class="n">port</span><span class="o">.</span><span class="n">outline</span><span class="p">)</span> <span class="o">></span> <span class="mi">0</span><span class="p">:</span> <span class="c1"># Useless to listen on a port that's not connected</span>
- <span class="c1"># The message will be inputted to all connected ports, so only listening on one port</span>
- <span class="c1"># should be sufficient.</span>
- <span class="c1"># All ports in the port.outline list are INPORTs by definition.</span>
- <span class="n">p</span> <span class="o">=</span> <span class="n">port</span><span class="o">.</span><span class="n">outline</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inports</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">p</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inDEVS</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">p</span><span class="o">.</span><span class="n">host_DEVS</span><span class="p">)</span>
- <span class="k">else</span><span class="p">:</span> <span class="c1"># Default fuctionality</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inports</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">port</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inDEVS</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">dvs</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">outports</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">outDEVS</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="k">for</span> <span class="n">port</span> <span class="ow">in</span> <span class="n">outports</span><span class="p">:</span>
- <span class="k">if</span> <span class="n">port</span><span class="o">.</span><span class="n">type</span><span class="p">()</span> <span class="o">!=</span> <span class="s1">'OUTPORT'</span><span class="p">:</span>
- <span class="k">raise</span> <span class="ne">TypeError</span><span class="p">(</span><span class="s2">"Can only listen on outports for messages that leave the submodel."</span><span class="p">)</span>
- <span class="n">dvs</span> <span class="o">=</span> <span class="n">port</span><span class="o">.</span><span class="n">host_DEVS</span>
- <span class="k">if</span> <span class="nb">issubclass</span><span class="p">(</span><span class="nb">type</span><span class="p">(</span><span class="n">dvs</span><span class="p">),</span> <span class="p">(</span><span class="n">CoupledDEVS</span><span class="p">,</span> <span class="n">minCoupledDEVS</span><span class="p">)):</span>
- <span class="c1"># All messages arriving on this port will be outputted, so we have a set of outputs</span>
- <span class="c1"># All ports in the port.inline list are OUTPORTs by definition.</span>
- <span class="k">for</span> <span class="n">p</span> <span class="ow">in</span> <span class="n">port</span><span class="o">.</span><span class="n">inline</span><span class="p">:</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">outports</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">p</span><span class="p">)</span>
- <span class="k">if</span> <span class="n">p</span><span class="o">.</span><span class="n">host_DEVS</span> <span class="ow">not</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">outDEVS</span><span class="p">:</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">outDEVS</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">p</span><span class="o">.</span><span class="n">host_DEVS</span><span class="p">)</span>
- <span class="k">else</span><span class="p">:</span> <span class="c1"># Default functionality</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">outports</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">port</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">inDEVS</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">dvs</span><span class="p">)</span>
- <div class="viewcode-block" id="StatisticsTracer.startTracer"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.startTracer">[docs]</a> <span class="k">def</span> <span class="nf">startTracer</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">recover</span><span class="p">):</span>
- <span class="nb">super</span><span class="p">(</span><span class="n">StatisticsTracer</span><span class="p">,</span> <span class="bp">self</span><span class="p">)</span><span class="o">.</span><span class="n">startTracer</span><span class="p">(</span><span class="n">recover</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">file</span><span class="o">.</span><span class="n">write</span><span class="p">(</span><span class="s2">"STATISTICS:</span><span class="se">\n</span><span class="s2">"</span><span class="p">)</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">file</span><span class="o">.</span><span class="n">write</span><span class="p">(</span><span class="s2">"===========</span><span class="se">\n\t</span><span class="s2">RUNNING..."</span><span class="p">)</span></div>
- <div class="viewcode-block" id="StatisticsTracer.stopTracer"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.stopTracer">[docs]</a> <span class="k">def</span> <span class="nf">stopTracer</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">file</span><span class="o">.</span><span class="n">write</span><span class="p">(</span><span class="s2">"</span><span class="se">\r\t</span><span class="s2">SUMMARY:</span><span class="se">\t\n</span><span class="s2">"</span> <span class="o">+</span> <span class="bp">self</span><span class="o">.</span><span class="n">summary</span><span class="p">(</span><span class="s1">'</span><span class="se">\t\t</span><span class="s1">'</span><span class="p">)</span> <span class="o">+</span> <span class="s2">"</span><span class="se">\n</span><span class="s2">"</span><span class="p">)</span>
- <span class="nb">super</span><span class="p">(</span><span class="n">StatisticsTracer</span><span class="p">,</span> <span class="bp">self</span><span class="p">)</span><span class="o">.</span><span class="n">stopTracer</span><span class="p">()</span></div>
- <div class="viewcode-block" id="StatisticsTracer.traceExternal"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.traceExternal">[docs]</a> <span class="k">def</span> <span class="nf">traceExternal</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">aDEVS</span><span class="p">):</span>
- <span class="sd">"""Trace messages that enter the system."""</span>
- <span class="n">dvs</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">model</span>
- <span class="k">if</span> <span class="n">dvs</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">inDEVS</span><span class="p">:</span>
- <span class="n">inps</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">my_input</span>
- <span class="k">for</span> <span class="n">port</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">inports</span><span class="p">:</span>
- <span class="k">if</span> <span class="n">port</span> <span class="ow">in</span> <span class="n">inps</span><span class="p">:</span>
- <span class="k">for</span> <span class="n">p</span> <span class="ow">in</span> <span class="n">inps</span><span class="p">[</span><span class="n">port</span><span class="p">]:</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="o">.</span><span class="n">setdefault</span><span class="p">(</span><span class="nb">id</span><span class="p">(</span><span class="n">p</span><span class="p">),</span> <span class="p">[</span><span class="n">p</span><span class="p">,</span> <span class="kc">None</span><span class="p">,</span> <span class="kc">None</span><span class="p">])[</span><span class="mi">1</span><span class="p">]</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">time_last</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.traceInternal"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.traceInternal">[docs]</a> <span class="k">def</span> <span class="nf">traceInternal</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">aDEVS</span><span class="p">):</span>
- <span class="sd">"""Trace messages that leave the system."""</span>
- <span class="n">dvs</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">model</span>
- <span class="k">if</span> <span class="n">dvs</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">outDEVS</span><span class="p">:</span>
- <span class="n">outs</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">my_output</span>
- <span class="k">for</span> <span class="n">port</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">outports</span><span class="p">:</span>
- <span class="k">if</span> <span class="n">port</span> <span class="ow">in</span> <span class="n">outs</span><span class="p">:</span>
- <span class="k">for</span> <span class="n">p</span> <span class="ow">in</span> <span class="n">outs</span><span class="p">[</span><span class="n">port</span><span class="p">]:</span>
- <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="o">.</span><span class="n">setdefault</span><span class="p">(</span><span class="nb">id</span><span class="p">(</span><span class="n">p</span><span class="p">),</span> <span class="p">[</span><span class="n">p</span><span class="p">,</span> <span class="kc">None</span><span class="p">,</span> <span class="kc">None</span><span class="p">])[</span><span class="mi">2</span><span class="p">]</span> <span class="o">=</span> <span class="n">aDEVS</span><span class="o">.</span><span class="n">time_last</span><span class="p">[</span><span class="mi">0</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.summary"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.summary">[docs]</a> <span class="k">def</span> <span class="nf">summary</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">prefix</span><span class="o">=</span><span class="s1">'</span><span class="se">\t</span><span class="s1">'</span><span class="p">):</span>
- <span class="sd">"""Gets the current stats as a string."""</span>
- <span class="n">summ</span> <span class="o">=</span> <span class="p">[</span>
- <span class="s2">"Average Time in System: </span><span class="si">%.5f</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">average_time_in_system</span><span class="p">(),</span>
- <span class="s2">"Average Num of Messages per Time Unit: </span><span class="si">%.5f</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">average_num</span><span class="p">(),</span>
- <span class="s2">"Total Throughput: </span><span class="si">%i</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">n_passed</span><span class="p">(),</span>
- <span class="s2">"Total Amount of Arrivals: </span><span class="si">%i</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">n_entries</span><span class="p">(),</span>
- <span class="s2">"Total Amount of Departures: </span><span class="si">%i</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">n_exits</span><span class="p">(),</span>
- <span class="s2">"Amount of Newly Generated Messages: </span><span class="si">%i</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">n_new</span><span class="p">(),</span>
- <span class="s2">"Amount of Bequeathed Messages: </span><span class="si">%i</span><span class="s2">"</span> <span class="o">%</span> <span class="bp">self</span><span class="o">.</span><span class="n">n_bequeathed</span><span class="p">()</span>
- <span class="p">]</span>
- <span class="k">return</span> <span class="n">prefix</span> <span class="o">+</span> <span class="p">(</span><span class="s2">"</span><span class="se">\n</span><span class="s2">"</span> <span class="o">+</span> <span class="n">prefix</span><span class="p">)</span><span class="o">.</span><span class="n">join</span><span class="p">(</span><span class="n">summ</span><span class="p">)</span></div>
- <div class="viewcode-block" id="StatisticsTracer.average_time_in_system"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.average_time_in_system">[docs]</a> <span class="k">def</span> <span class="nf">average_time_in_system</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the average time a message remained in the system.</span>
- <span class="sd"> Note:</span>
- <span class="sd"> This ignores all newly created and bequeathed messages.</span>
- <span class="sd"> """</span>
- <span class="n">msgs</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">passed</span><span class="p">()</span>
- <span class="k">if</span> <span class="nb">len</span><span class="p">(</span><span class="n">msgs</span><span class="p">)</span> <span class="o">==</span> <span class="mi">0</span><span class="p">:</span>
- <span class="k">return</span> <span class="mi">0</span>
- <span class="n">avg</span> <span class="o">=</span> <span class="mi">0</span>
- <span class="k">for</span> <span class="n">_</span><span class="p">,</span> <span class="n">a</span><span class="p">,</span> <span class="n">d</span> <span class="ow">in</span> <span class="n">msgs</span><span class="p">:</span>
- <span class="n">avg</span> <span class="o">+=</span> <span class="n">d</span> <span class="o">-</span> <span class="n">a</span>
- <span class="k">return</span> <span class="nb">float</span><span class="p">(</span><span class="n">avg</span><span class="p">)</span> <span class="o">/</span> <span class="nb">len</span><span class="p">(</span><span class="n">msgs</span><span class="p">)</span></div>
- <div class="viewcode-block" id="StatisticsTracer.average_num"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.average_num">[docs]</a> <span class="k">def</span> <span class="nf">average_num</span><span class="p">(</span><span class="bp">self</span><span class="p">,</span> <span class="n">dx</span><span class="o">=</span><span class="mf">1.0</span><span class="p">,</span> <span class="n">start</span><span class="o">=</span><span class="mi">0</span><span class="p">,</span> <span class="n">end</span><span class="o">=</span><span class="kc">None</span><span class="p">):</span>
- <span class="sd">"""Reports the average amount of messages for a certain time period.</span>
- <span class="sd"> Note:</span>
- <span class="sd"> This ignores all newly created and bequeathed messages.</span>
- <span class="sd"> Args:</span>
- <span class="sd"> dx (numeric): The time period to look over. Defaults to 1.</span>
- <span class="sd"> start (numeric): The point in time to start measuring from.</span>
- <span class="sd"> When ``None``, it will use the first seen</span>
- <span class="sd"> arrival as a starting point. Defaults to 0</span>
- <span class="sd"> (= usually the start of the simulation).</span>
- <span class="sd"> end (numeric): The point in time to end measuring at. When</span>
- <span class="sd"> ``None``, it will use the last seen departure</span>
- <span class="sd"> as an end point. This point is inclusive in</span>
- <span class="sd"> the range. Defaults to ``None``.</span>
- <span class="sd"> """</span>
- <span class="c1"># Create dictionaries for all arrival and departures</span>
- <span class="n">msgs</span> <span class="o">=</span> <span class="bp">self</span><span class="o">.</span><span class="n">passed</span><span class="p">()</span>
- <span class="k">if</span> <span class="nb">len</span><span class="p">(</span><span class="n">msgs</span><span class="p">)</span> <span class="o">==</span> <span class="mi">0</span><span class="p">:</span>
- <span class="k">return</span> <span class="mi">0</span>
- <span class="n">arr</span> <span class="o">=</span> <span class="p">{}</span>
- <span class="n">dep</span> <span class="o">=</span> <span class="p">{}</span>
- <span class="k">for</span> <span class="n">v</span><span class="p">,</span> <span class="n">a</span><span class="p">,</span> <span class="n">d</span> <span class="ow">in</span> <span class="n">msgs</span><span class="p">:</span>
- <span class="n">arr</span><span class="o">.</span><span class="n">setdefault</span><span class="p">(</span><span class="n">a</span><span class="p">,</span> <span class="p">[])</span><span class="o">.</span><span class="n">append</span><span class="p">((</span><span class="n">v</span><span class="p">,</span> <span class="n">a</span><span class="p">,</span> <span class="n">d</span><span class="p">))</span>
- <span class="n">dep</span><span class="o">.</span><span class="n">setdefault</span><span class="p">(</span><span class="n">d</span><span class="p">,</span> <span class="p">[])</span><span class="o">.</span><span class="n">append</span><span class="p">((</span><span class="n">v</span><span class="p">,</span> <span class="n">a</span><span class="p">,</span> <span class="n">d</span><span class="p">))</span>
- <span class="c1"># Dicts are not sorted</span>
- <span class="n">sarr</span> <span class="o">=</span> <span class="nb">sorted</span><span class="p">(</span><span class="n">arr</span><span class="o">.</span><span class="n">keys</span><span class="p">())</span>
- <span class="n">sdep</span> <span class="o">=</span> <span class="nb">sorted</span><span class="p">(</span><span class="n">dep</span><span class="o">.</span><span class="n">keys</span><span class="p">())</span>
- <span class="n">times</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="n">prev</span> <span class="o">=</span> <span class="p">[]</span>
- <span class="n">last</span> <span class="o">=</span> <span class="nb">min</span><span class="p">(</span><span class="n">arr</span><span class="o">.</span><span class="n">keys</span><span class="p">())</span> <span class="k">if</span> <span class="n">start</span> <span class="ow">is</span> <span class="kc">None</span> <span class="k">else</span> <span class="n">start</span>
- <span class="k">for</span> <span class="n">t</span> <span class="ow">in</span> <span class="n">np</span><span class="o">.</span><span class="n">arange</span><span class="p">(</span><span class="n">last</span> <span class="o">+</span> <span class="n">dx</span><span class="p">,</span> <span class="p">(</span><span class="nb">max</span><span class="p">(</span><span class="n">dep</span><span class="o">.</span><span class="n">keys</span><span class="p">())</span> <span class="k">if</span> <span class="n">end</span> <span class="ow">is</span> <span class="kc">None</span> <span class="k">else</span> <span class="n">end</span><span class="p">)</span> <span class="o">+</span> <span class="mi">2</span> <span class="o">*</span> <span class="n">dx</span><span class="p">,</span> <span class="n">dx</span><span class="p">):</span>
- <span class="n">curr</span> <span class="o">=</span> <span class="n">prev</span>
- <span class="c1"># Add all arriving messages in the time period</span>
- <span class="k">for</span> <span class="n">sa</span> <span class="ow">in</span> <span class="p">(</span><span class="n">x</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="n">sarr</span> <span class="k">if</span> <span class="n">last</span> <span class="o"><=</span> <span class="n">x</span> <span class="o"><</span> <span class="n">t</span><span class="p">):</span>
- <span class="n">curr</span> <span class="o">+=</span> <span class="n">arr</span><span class="p">[</span><span class="n">sa</span><span class="p">]</span>
- <span class="c1"># Remove all departing messages in the time period</span>
- <span class="k">for</span> <span class="n">sd</span> <span class="ow">in</span> <span class="p">(</span><span class="n">x</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="n">sdep</span> <span class="k">if</span> <span class="n">last</span> <span class="o"><=</span> <span class="n">x</span> <span class="o"><</span> <span class="n">t</span><span class="p">):</span>
- <span class="k">for</span> <span class="n">m</span> <span class="ow">in</span> <span class="n">dep</span><span class="p">[</span><span class="n">sd</span><span class="p">]:</span>
- <span class="n">curr</span><span class="o">.</span><span class="n">remove</span><span class="p">(</span><span class="n">m</span><span class="p">)</span>
- <span class="n">prev</span> <span class="o">=</span> <span class="n">curr</span><span class="p">[:]</span>
- <span class="n">times</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">curr</span><span class="p">)</span>
- <span class="n">last</span> <span class="o">=</span> <span class="n">t</span>
- <span class="k">return</span> <span class="nb">sum</span><span class="p">(</span><span class="nb">map</span><span class="p">(</span><span class="nb">len</span><span class="p">,</span> <span class="n">times</span><span class="p">))</span> <span class="o">/</span> <span class="nb">len</span><span class="p">(</span><span class="n">times</span><span class="p">)</span></div>
- <div class="viewcode-block" id="StatisticsTracer.entries"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.entries">[docs]</a> <span class="k">def</span> <span class="nf">entries</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports all messages that entered the system."""</span>
- <span class="k">return</span> <span class="p">[</span><span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">]</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">1</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.n_entries"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.n_entries">[docs]</a> <span class="k">def</span> <span class="nf">n_entries</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the amount of messages that entered the system."""</span>
- <span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">entries</span><span class="p">())</span></div>
- <div class="viewcode-block" id="StatisticsTracer.exits"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.exits">[docs]</a> <span class="k">def</span> <span class="nf">exits</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports all messages that left the system."""</span>
- <span class="k">return</span> <span class="p">[</span><span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">]</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">2</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.n_exits"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.n_exits">[docs]</a> <span class="k">def</span> <span class="nf">n_exits</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the amount of messages that left the system."""</span>
- <span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">exits</span><span class="p">())</span></div>
- <div class="viewcode-block" id="StatisticsTracer.passed"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.passed">[docs]</a> <span class="k">def</span> <span class="nf">passed</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports all messages that passed through the system."""</span>
- <span class="k">return</span> <span class="p">[</span><span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">]</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">1</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span> <span class="ow">and</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">2</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.n_passed"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.n_passed">[docs]</a> <span class="k">def</span> <span class="nf">n_passed</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the amount of messages that passed through the system."""</span>
- <span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">passed</span><span class="p">())</span></div>
- <div class="viewcode-block" id="StatisticsTracer.new"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.new">[docs]</a> <span class="k">def</span> <span class="nf">new</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports all messages that were generated in the submodel."""</span>
- <span class="k">return</span> <span class="p">[</span><span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">]</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">1</span><span class="p">]</span> <span class="ow">is</span> <span class="kc">None</span> <span class="ow">and</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">2</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.n_new"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.n_new">[docs]</a> <span class="k">def</span> <span class="nf">n_new</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the amount of messages that were generated in the submodel."""</span>
- <span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">new</span><span class="p">())</span></div>
- <div class="viewcode-block" id="StatisticsTracer.bequeathed"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.bequeathed">[docs]</a> <span class="k">def</span> <span class="nf">bequeathed</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports all messages that were dropped or left behind in the submodel."""</span>
- <span class="k">return</span> <span class="p">[</span><span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">]</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span> <span class="k">if</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">1</span><span class="p">]</span> <span class="ow">is</span> <span class="ow">not</span> <span class="kc">None</span> <span class="ow">and</span> <span class="bp">self</span><span class="o">.</span><span class="n">table</span><span class="p">[</span><span class="n">x</span><span class="p">][</span><span class="mi">2</span><span class="p">]</span> <span class="ow">is</span> <span class="kc">None</span><span class="p">]</span></div>
- <div class="viewcode-block" id="StatisticsTracer.n_bequeathed"><a class="viewcode-back" href="../../../pypdevsbbl.tracers.StatisticsTracer.html#pypdevsbbl.tracers.StatisticsTracer.StatisticsTracer.n_bequeathed">[docs]</a> <span class="k">def</span> <span class="nf">n_bequeathed</span><span class="p">(</span><span class="bp">self</span><span class="p">):</span>
- <span class="sd">"""Reports the amount of messages that were dropped or left behind in the submodel."""</span>
- <span class="k">return</span> <span class="nb">len</span><span class="p">(</span><span class="bp">self</span><span class="o">.</span><span class="n">bequeathed</span><span class="p">())</span></div>
- <span class="n">forgotten</span> <span class="o">=</span> <span class="n">bequeathed</span>
- <span class="sd">"""Alias for :meth:`bequeathed`, because, although less accurate, it is easier to remember."""</span>
- <span class="n">n_forgotten</span> <span class="o">=</span> <span class="n">n_bequeathed</span>
- <span class="sd">"""Alias for :meth:`n_bequeathed`, because, although less accurate, it is easier to remember."""</span></div>
- </pre></div>
- </div>
- </div>
- </div>
- <div class="sphinxsidebar" role="navigation" aria-label="main navigation">
- <div class="sphinxsidebarwrapper">
- <div id="searchbox" style="display: none" role="search">
- <h3>Quick search</h3>
- <div class="searchformwrapper">
- <form class="search" action="../../../search.html" method="get">
- <input type="text" name="q" />
- <input type="submit" value="Go" />
- <input type="hidden" name="check_keywords" value="yes" />
- <input type="hidden" name="area" value="default" />
- </form>
- </div>
- </div>
- <script type="text/javascript">$('#searchbox').show(0);</script>
- </div>
- </div>
- <div class="clearer"></div>
- </div>
- <div class="related" role="navigation" aria-label="related navigation">
- <h3>Navigation</h3>
- <ul>
- <li class="right" style="margin-right: 10px">
- <a href="../../../genindex.html" title="General Index"
- >index</a></li>
- <li class="right" >
- <a href="../../../py-modindex.html" title="Python Module Index"
- >modules</a> |</li>
- <li class="nav-item nav-item-0"><a href="../../../index.html">Python(P)DEVS-BBL documentation</a> »</li>
- <li class="nav-item nav-item-1"><a href="../../index.html" >Module code</a> »</li>
- <li class="nav-item nav-item-2"><a href="../tracers.html" >pypdevsbbl.tracers</a> »</li>
- </ul>
- </div>
- <div class="footer" role="contentinfo">
- © Copyright 2020, Randy Paredis.
- Created using <a href="http://sphinx-doc.org/">Sphinx</a> 1.8.5.
- </div>
- </body>
- </html>
|