fork download
copy 
  1. /*
  2. http://t...content-available-to-author-only...h.net/test/read.cgi/tech/1339338438/639
  3.  
  4. 課題　ハブのシミュレーション
  5. ここではVirtual Output Queuing構成のハブをシミュレーションする。
  6. 設定は以下のようにする:
  7. ●ポート数は4
  8. ●パケットの入出力やスイッチにおけるパケット転送はクロック単位で同期している。
  9. ●入力ポートからスイッチへの、またスイッチから出力ポートへの転送は1クロックにつきPパケット。
  10. ●各入力ポートでは、パケットが平均時間間隔がTaの指数分布に従って到着する。
  11. ●各パケットの宛先ポートは、"入力ポートに対応する出力ポート以外のポート"から等確率でランダムに選ぶ。
  12. 　つまり、"入力ポート1からやってきたパケット"の宛先は、出力ポート0,2,3のいずれかから等確率で選ばれる。
  13. 　（これは"全てのポートが対称である"ことを意味する。）
  14. ●Tクロックの間動作をさせる。
  15.  
  16. Ta=2,T=1000,P=1として実行し、全てのパケットに対する転送遅延
  17. （入力ポートに入ってから出力ポートに出ていくまでの時間）の
  18. 最大値と平均値を求めよ。
  19. http://i...content-available-to-author-only...e.com/T3e0j を参考にしてプログラムを作成してもかまわない。
  20. ただし、このプログラムは何も表示しないので各クロックごとに
  21. どの入力ポートからパケットが到着したのか、あるいはどれだけのパケットを
  22. 転送したのかなどを表示させるとわかりやすいだろう。
  23. もちろん、必要な情報を収集することも忘れないこと。
  24.  
  25. 回答者注釈：
  26. ・インデントを直した
  27. ・追加した部分に関しては行頭にマークを付けた
  28. ・毎回実行結果が異なる
  29. ・if (0) の部分を if (1) にすると、振る舞いが表示される
  30. */
  31.  
  32. #include<cstdio>
  33. #include<cstdlib>
  34. #include<ctime>
  35. #include<cmath>
  36. #include<vector>
  37. #include<deque>
  38. using namespace std;
  39.  
  40. //隣接行列がgraphであるようなグラフにおいて、startからgoalまで幅優先探索を行う。
  41. //goalまでたどりつけばtrue、たどりつけなければfalseを返す。
  42. //trueが返るときには、prevに「直前の頂点」の情報が入っている。
  43. bool bfs(const vector<vector<int> > &graph, int start, int goal, vector<int> &prev)
  44. {
  45.     const int n = graph.size(); //n:グラフの頂点数
  46.  
  47.     //「直前の頂点」の情報をクリア
  48.     for(int i = 0; i < n; ++i){
  49.         prev[i] = -1;
  50.     }
  51.     //アルゴリズムの都合上、出発点の「直前」は出発点自身とする:
  52.     prev[start] = start;
  53.  
  54.     //「まだたどってない頂点」をキューで管理する。最初は出発点だけ。
  55.     deque<int> frontier;
  56.     frontier.push_back(start);
  57.  
  58.     //キューに頂点が残っていたらループ
  59.     while(! frontier.empty()){
  60.         int vertex = frontier[0];
  61.         frontier.pop_front();
  62.  
  63.         //目的地に到達していれば終わり
  64.         if(vertex == goal){
  65.             return true;
  66.         }
  67.  
  68.         //「次にたどるべき頂点」をキューに追加する
  69.         for(int next = 0; next < n; ++next){
  70.             //はじめて見る頂点で今の頂点から行けるものをキューに追加
  71.             if(prev[next] == -1 && graph[vertex][next] > 0){
  72.                 prev[next] = vertex;
  73.                 frontier.push_back(next);
  74.             }
  75.         }
  76.     }
  77.  
  78.     //目的地にたどりつかなかったのでfalse.
  79.     return false;
  80. }
  81.  
  82. //辺(i,j)の容量がgraph[i][j]であるようなグラフにおけるsourceからsinkへの最大フローを求める。
  83. //求めた最大フローはflowに入る。
  84. //最大フローの値を返す。
  85. int maxFlow(vector<vector<int> > graph, int source, int sink, vector<vector<int> > &flow)
  86. {
  87.     const int n = graph.size(); //n:グラフの頂点数
  88.  
  89.     //フローflowと値valueを初期化
  90.     for(int i = 0; i < n; ++i){
  91.         for(int j = 0; j < n; ++j){
  92.             flow[i][j] = 0;
  93.         }
  94.     }
  95.     int value = 0;
  96.  
  97.     //幅優先探索の準備
  98.     vector<int> prev(n);
  99.  
  100.     //経路が見付かる限りフローを更新
  101.     while(bfs(graph,source,sink,prev)){
  102.         //prevに従って,見付けた経路の容量の最小値を求める.
  103.         int capacity = graph[prev[sink]][sink];
  104.  
  105.         for(int v = sink; v != source; v = prev[v]){
  106.             if(capacity > graph[prev[v]][v]){
  107.                 capacity = graph[prev[v]][v];
  108.             }
  109.         }
  110.  
  111.         //フローと残余ネットワークを更新
  112.         for(int v = sink; v != source; v = prev[v]){
  113.             int pv = prev[v];
  114.             flow[pv][v] += capacity;
  115.             graph[pv][v] -= capacity;
  116.             graph[v][pv] += capacity;
  117.         }
  118.         value += capacity;
  119.     }
  120.  
  121.     return value;
  122. }
  123.  
  124. double exprand(double average)
  125. {
  126.     double r = rand() / (RAND_MAX + 1.0);
  127.     return -log(1-r) * average;
  128. }
  129.  
  130. struct Packet {
  131.     int source; //入力ポート
  132.     int dest; //出力ポート
  133.     int arriveTime; //ハブへの到着時刻
  134.     int deliverTime; //ハブからの排出時刻
  135. };
  136.  
  137. typedef deque<Packet> PacketQueue;
  138.  
  139. //ハブに届いたパケットを生成する.
  140. Packet makePacket(int in_port, int current, int ports)
  141. {
  142.     Packet packet;
  143.  
  144.     packet.source = in_port;
  145.     packet.dest = int(rand() / (RAND_MAX + 1.0) * (ports-1));
  146.     if(packet.dest >= packet.source){
  147.         ++packet.dest;
  148.     }
  149.     packet.arriveTime = current;
  150.     packet.deliverTime = -1;
  151.  
  152.     return packet;
  153. }
  154.  
  155. //ポート数Ports,スイッチ転送量xppcパケット/クロックのハブのシミュレーションを行う.
  156. //パケットの平均到着時間間隔はTa,シミュレーション時間はdurationとする.
  157. void runSimulation(int Ports, int xppc, double Ta, int duration)
  158. {
  159.     //入力バッファは入力ポートごとかつ出力ポートごと
  160.     vector<vector<PacketQueue> > inputBuffer(Ports, vector<PacketQueue>(Ports));
  161.  
  162.     //次に各入力ポートにパケットがくるタイミング
  163.     vector<int> nextPacketTime(Ports);
  164.  
  165.     //最初のパケットのタイミングを設定して....
  166.     for(int in_port = 0; in_port < Ports; ++in_port){
  167.         nextPacketTime[in_port] = int(exprand(Ta));
  168.     }
  169.  
  170.     //シミュレーション開始
  171. /**/int max =0, sum = 0, count = 0; // 情報収集用変数
  172.     printf("Simulation start\n");
  173.     for(int current = 0; current < duration; ++current){
  174.         //まず入力パケットをもらう
  175.         for(int in_port = 0; in_port < Ports; ++in_port){
  176.             while(current == nextPacketTime[in_port]){
  177.                 Packet packet = makePacket(in_port, current, Ports);
  178.                 inputBuffer[in_port][packet.dest].push_back(packet);
  179.                 nextPacketTime[in_port] += int(exprand(Ta));
  180.             }
  181.         }
  182.  
  183.         //グラフを作って
  184.         const int Vertices = 2*Ports+2;
  185.         const int Source = 2*Ports;
  186.         const int Sink = 2*Ports+1;
  187.         vector<vector<int> > graph(Vertices, vector<int>(Vertices));
  188.         for(int in_port = 0; in_port < Ports; ++in_port){
  189.             for(int out_port = 0; out_port < Ports; ++out_port){
  190.                 graph[in_port][Ports+out_port] = inputBuffer[in_port][out_port].size();
  191.             }
  192.         }
  193.         for(int in_port = 0; in_port < Ports; ++in_port){
  194.             graph[Source][in_port] = xppc;
  195.         }
  196.         for(int out_port = 0; out_port < Ports; ++out_port){
  197.             graph[Ports+out_port][Sink] = xppc;
  198.         }
  199.  
  200.         //最大フローを求め
  201.         vector<vector<int> > flow(Vertices, vector<int>(Vertices));
  202.         maxFlow(graph, Source, Sink, flow);
  203.  
  204.         //それに従ってパケットを送り出す
  205.         for(int in_port = 0; in_port < Ports; ++in_port){
  206.             for(int out_port = 0; out_port < Ports; ++out_port){
  207.                 for(int p = 0; p < flow[in_port][Ports+out_port]; ++p){
  208.                     inputBuffer[in_port][out_port][0].deliverTime = current;
  209. /**/                // 情報収集ここから
  210. /**/                Packet& x = inputBuffer[in_port][out_port][0]; // too long
  211. /**/                int delay = x.deliverTime - x.arriveTime;
  212. /**/                if (0) { // パケット到着時の情報表示
  213. /**/                    printf("src:%d dst:%d arr:%d del:%d delay:%d\n",
  214. /**/                           x.source, x.dest, x.arriveTime, x.deliverTime,
  215. /**/                           delay);
  216. /**/                }
  217. /**/                if (delay > max)
  218. /**/                    max = delay;
  219. /**/                sum += delay;
  220. /**/                ++count;
  221. /**/                // 情報収集ここまで
  222.                     inputBuffer[in_port][out_port].pop_front();
  223.                 }
  224.             }
  225.         }
  226.     }
  227.     //時間がきたのでシミュレーション終了
  228.     printf("Simulation finished\n");
  229. /**/// 設題の情報を表示
  230. /**/printf("max: %d\n", max);
  231. /**/printf("average: %f\n", (double) sum / count);
  232. }
  233.  
  234. //テスト用のmain
  235. int main()
  236. {
  237.     const int Ports = 4; //ポート数
  238.  
  239.     const double Ta = 2; //平均到着時間間隔
  240.     const int T = 1000; //シミュレートする時間数
  241.     const int P = 1; //1ポートあたり転送パケット数
  242.  
  243.     srand(time(NULL));
  244.     runSimulation(Ports, P, Ta, T);
  245.     return 0;
  246. }
  247.  
Success #stdin #stdout 0.02s 2820KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
Simulation start
Simulation finished
max: 37
average: 2.206685
https://ideone.com/NDH7E
language:
C++ (gcc 8.3)
created:
12 years ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!