21ic电子技术开发论坛 › 个人版区 › 贝贝的实验室 › 两个进程通过fifo进行通信和解析
返回列表 发新帖我要提问

两个进程通过fifo进行通信和解析

[复制链接]
 楼主| keer_zu 发表于 2022-9-27 13:42 | 显示全部楼层 |阅读模式
#申请原创# #技术资源# 可以监控终端的输入和其他程序写在此FIFO的数据，并对特殊字段进行解析。
运行环境：qnx

复制
  1. #include <sys/types.h>
    

  2. #include <sys/stat.h>
    

  3. #include <fcntl.h>  
    

  4. #include <iostream>
    

  5. #include<regex>
    


  6. 


  7. 


  8. 

  9. //int mkfifo( const char* path, 
    

  10. //            mode_t mode );
    


  11. 

  12. using namespace std;
    


  13. 

  14. #include <string>
    

  15.  
    

  16. void test()
    

  17. {
    

  18.         std::regex reg("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))\\sMbits");
    

  19.         std::regex reg1("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  20.  
    

  21.         std::string str = "这是中文示例abc 1234.2  a 匹配浮点数值XX5678 2.6  5.789  -0.23411 +01.45";
    


  22. 

  23.         string row = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  24.  
    

  25.         const std::sregex_iterator end;
    

  26.         for (std::sregex_iterator iter(std::cbegin(str), std::cend(str), reg1); iter != end;++iter)
    

  27.                 std::cout << iter->str() << std::endl;
    


  28. 

  29.         for (std::sregex_iterator iter(std::cbegin(row), std::cend(row), reg); iter != end;++iter)
    

  30.                 std::cout << iter->str() << std::endl;
    


  31. 

  32. }
    


  33. 

  34. void test1(string str)
    

  35. {
    

  36.         
    

  37.         //string str = "Hello 2018, Bye 2017";
    

  38.         //string str = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  39.         smatch result;
    

  40.         regex Bandwidth("-?(([0-9]\\d*\\.[1-9]\\d*)|(0)|(0\\.[1-9]\\d*)|([0-9]\\d*))\\sMbits");//(".+(\\d Mbits/sec).+(\\(\\d%\\))");        //
    

  41.         //regex  Packageloss("\\(([0-9]+%)\\)");
    

  42.         regex  Packageloss("\\(-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*)|([0-9]\\d*))\\%\\)");
    

  43.         //regex Value("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  44.         
    

  45.         
    

  46.         
    

  47.         //迭代器声明
    

  48.         string::const_iterator iterStart = str.begin();
    

  49.         string::const_iterator iterEnd = str.end();
    

  50.         string temp,value;
    

  51.         cout << "==============================" << endl;
    

  52.         while (regex_search(iterStart, iterEnd, result, Bandwidth))
    

  53.         {
    

  54.                 temp = result[0];
    

  55.                 cout << "==== bandwidth: " << result[1] << endl;
    

  56.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  57.         }
    

  58.         cout << "----------------------------------" << endl;
    

  59.         while (regex_search(iterStart, iterEnd, result, Packageloss))
    

  60.         {
    

  61.                 temp = result[0];
    

  62.                 cout << "==== package loss: " << result[1] << endl;
    

  63.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  64.         }
    

  65.         cout << "-------+++------------------------" << endl;
    

  66. }
    


  67. 


  68. 

  69. int main(void)
    

  70. {
    

  71.         test();
    

  72.         int ret,fd,pid;
    

  73.         //regex Bandwidth("\\s\\s([1-9,\\\\.]+)\\sMbits");
    

  74.         regex Bandwidth(".+(\\d Mbits/sec).+(\\(\\d%\\))");
    

  75.         cout << "\\s\\s([1-9,\\\\.]+)\\sMbits" << endl;
    

  76.         //"MBytes  .* Mbits/sec"
    

  77.         regex Packageloss("\\(([0-9]+%)\\)");
    

  78.         
    

  79.         
    

  80.         ret = mkfifo("/var/fifo1",S_IRUSR | S_IWUSR);
    

  81.         cout << "ret: " << ret << endl;
    


  82. 

  83.         pid = fork();
    

  84.         if (pid > 0) {
    

  85.                 cout << "- parent -" << endl;
    

  86.                 fd = open("/var/fifo1",O_RDONLY,0);
    

  87.                 if(fd < 0){ 
    

  88.                         cout << "open error!\n" ;
    

  89.                         return -1;
    

  90.                 }
    

  91.                 char buf1[500];
    

  92.                 while(1) {
    

  93.                         cout << "please waiting...\n";
    

  94.                         ssize_t s = read(fd,buf1,sizeof(buf1)-1);
    

  95.                         if(s > 0) {
    

  96.                                 buf1[s-1] = 0;
    

  97.                                 string row = buf1;//"[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";//buf1;
    

  98.                                 cout << row << endl;
    

  99.                                 test1(row);
    

  100.                                 
    


  101. 

  102.                         } else if (s == 0) {
    

  103.                                 cout << "client quit,exit ..." << endl;
    

  104.                                 break;
    

  105.                         }
    

  106.                 }
    

  107.                 
    

  108.         } else if (pid == 0){
    

  109.                 cout << "- child -" << endl;
    

  110.                 fd = open("/var/fifo1",O_WRONLY,0);
    

  111.                 if(fd < 0){ 
    

  112.                         cout << "open error!\n" ;
    

  113.                         return -1;
    

  114.                 }
    

  115.                 char buf1[500];
    

  116.                 while(1) {
    

  117.                         cout << "client\n";
    

  118.                         fflush(stdout);
    

  119.                 ssize_t s = read(0,buf1,sizeof(buf1)-1);
    

  120.                 if(s > 0) {
    

  121.                                 buf1[s] = 0;
    

  122.                                 write(fd,buf1,strlen(buf1));
    

  123.                 }
    

  124.                 }
    

  125.         } else {
    

  126.                 cout << "fork error!\n" ;
    

  127.         }
    

  128.         
    

  129.                 cout << "file is exit!\n" ;
    

  130.                 close(ret);
    

  131.         
    


  132. 

  133.         
    

  134. }
    


  135.
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-27 13:44 | 显示全部楼层
部分运行结果日志：

复制
  1. ==============================
    

  2. ----------------------------------
    

  3. -------+++------------------------
    

  4. please waiting...
    

  5. a123 Mbits
    

  6. a123 Mbits
    

  7. client
    

  8. ==============================
    

  9. ==== bandwidth: 123
    

  10. ----------------------------------
    

  11. -------+++------------------------
    

  12. please waiting...
    

  13. 456 Mbits
    

  14. 456 Mbits
    

  15. client
    

  16. ==============================
    

  17. ==== bandwidth: 456
    

  18. ----------------------------------
    

  19. -------+++------------------------
    

  20. please waiting...
    

  21. [  3] local 192.168.0.1 port 1200 connected with 192.168.0.2 port 58812 (peer 2.1.8)
    

  22. ==============================
    

  23. ----------------------------------
    

  24. -------+++------------------------
    

  25. please waiting...
    

  26. [  3]  0.0-10.0 sec   114 MBytes  95.7 Mbits/sec   1.044 ms    1/81440 (0.0012%)
    

  27. ==============================
    

  28. ==== bandwidth: 95.7
    

  29. ----------------------------------
    

  30. ==== package loss: 0.0012
    

  31. -------+++------------------------
    

  32. please waiting...
    


  33.
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-27 13:54 | 显示全部楼层
监控另外一个程序日志的实现：

这里是iperf，一个网络带宽丢包率等测试工具。

复制
  1. # iperf2 -u -s -p 1200 > /var/fifo1
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-27 14:02 | 显示全部楼层
另一台机器上，iperf客户端启动：

复制
  1. iperf-2.1.8-win.exe -c 192.168.0.1  -b1000M -t 100 -B 192.168.0.2 -p 1200 -u -i 1 -t 10
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-27 14:06 | 显示全部楼层
@21ic小管家 @21小跑堂
原创，请给个编辑推荐
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-27 18:18 | 显示全部楼层
增加读取文件每一行并且解析：

复制
  1. #include <sys/types.h>
    

  2. #include <sys/stat.h>
    

  3. #include <fcntl.h>  
    

  4. #include <iostream>
    

  5. #include<regex>
    

  6. #include <fstream>
    


  7. 


  8. 


  9. 

  10. //int mkfifo( const char* path, 
    

  11. //            mode_t mode );
    


  12. 

  13. using namespace std;
    


  14. 

  15. #include <string>
    

  16.  
    

  17. void test()
    

  18. {
    

  19.         std::regex reg("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))\\sMbits");
    

  20.         std::regex reg1("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  21.  
    

  22.         std::string str = "这是中文示例abc 1234.2  a 匹配浮点数值XX5678 2.6  5.789  -0.23411 +01.45";
    


  23. 

  24.         string row = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  25.  
    

  26.         const std::sregex_iterator end;
    

  27.         for (std::sregex_iterator iter(std::cbegin(str), std::cend(str), reg1); iter != end;++iter)
    

  28.                 std::cout << iter->str() << std::endl;
    


  29. 

  30.         for (std::sregex_iterator iter(std::cbegin(row), std::cend(row), reg); iter != end;++iter)
    

  31.                 std::cout << iter->str() << std::endl;
    


  32. 

  33. }
    


  34. 

  35. void test1(string str)
    

  36. {
    

  37.         
    

  38.         //string str = "Hello 2018, Bye 2017";
    

  39.         //string str = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  40.         smatch result;
    

  41.         regex Bandwidth("-?(([0-9]\\d*\\.[1-9]\\d*)|(0)|(0\\.[1-9]\\d*)|([0-9]\\d*))\\sMbits");//(".+(\\d Mbits/sec).+(\\(\\d%\\))");        //
    

  42.         //regex  Packageloss("\\(([0-9]+%)\\)");
    

  43.         regex  Packageloss("\\(-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*)|([0-9]\\d*))\\%\\)");
    

  44.         //regex Value("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  45.         
    

  46.         
    

  47.         
    

  48.         //迭代器声明
    

  49.         string::const_iterator iterStart = str.begin();
    

  50.         string::const_iterator iterEnd = str.end();
    

  51.         string temp,value;
    

  52.         cout << "==============================" << endl;
    

  53.         while (regex_search(iterStart, iterEnd, result, Bandwidth))
    

  54.         {
    

  55.                 temp = result[0];
    

  56.                 cout << "==== bandwidth: " << result[1] << endl;
    

  57.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  58.         }
    

  59.         cout << "----------------------------------" << endl;
    

  60.         while (regex_search(iterStart, iterEnd, result, Packageloss))
    

  61.         {
    

  62.                 temp = result[0];
    

  63.                 cout << "==== package loss: " << result[1] << endl;
    

  64.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  65.         }
    

  66.         cout << "-------+++------------------------" << endl;
    

  67. }
    


  68. 


  69. 

  70. int main(void)
    

  71. {
    

  72.         string line;
    

  73.            
    

  74.            //打开文件data.txt
    

  75.         ifstream fin("ethernetTest.sh");
    

  76.         
    

  77.         string s;  
    

  78.     
    


  79. 

  80.         test();
    

  81.         int ret,fd,pid;
    

  82.         //regex Bandwidth("\\s\\s([1-9,\\\\.]+)\\sMbits");
    

  83.         regex Bandwidth(".+(\\d Mbits/sec).+(\\(\\d%\\))");
    

  84.         cout << "\\s\\s([1-9,\\\\.]+)\\sMbits" << endl;
    

  85.         //"MBytes  .* Mbits/sec"
    

  86.         regex Packageloss("\\(([0-9]+%)\\)");
    

  87.         regex filePath("/var/fifo\\d*");
    

  88.         string fp = "iperf2 -u -s -p 1200 > /var/fifo01 &";
    

  89.         string::const_iterator itStart;// = fp.begin();
    

  90.         string::const_iterator itEnd;// = fp.end();
    

  91.         
    

  92.         cout << "==============================" << endl;
    

  93.         
    

  94.         while( getline(fin,s) ){        
    

  95.                 itStart = s.begin();
    

  96.                 itEnd = s.end();
    

  97.                 smatch result;
    

  98.                 if (regex_search(itStart, itEnd, result, filePath)) {
    

  99.                         cout << "+++++ file path: " << result[0] << endl;
    

  100.                 } else {
    

  101.                         cout << "--- no search ---" << endl;
    

  102.                 }
    

  103.         }
    

  104.         
    

  105.         ret = mkfifo("/var/fifo1",S_IRUSR | S_IWUSR);
    

  106.         cout << "ret: " << ret << endl;
    


  107. 

  108.         pid = fork();
    

  109.         if (pid > 0) {
    

  110.                 cout << "- parent -" << endl;
    

  111.                 fd = open("/var/fifo1",O_RDONLY,0);
    

  112.                 if(fd < 0){ 
    

  113.                         cout << "open error!\n" ;
    

  114.                         return -1;
    

  115.                 }
    

  116.                 char buf1[500];
    

  117.                 while(1) {
    

  118.                         cout << "please waiting...\n";
    

  119.                         ssize_t s = read(fd,buf1,sizeof(buf1)-1);
    

  120.                         if(s > 0) {
    

  121.                                 buf1[s-1] = 0;
    

  122.                                 string row = buf1;//"[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";//buf1;
    

  123.                                 cout << row << endl;
    

  124.                                 test1(row);
    

  125.                                 
    


  126. 

  127.                         } else if (s == 0) {
    

  128.                                 cout << "client quit,exit ..." << endl;
    

  129.                                 break;
    

  130.                         }
    

  131.                 }
    

  132.                 
    

  133.         } else if (pid == 0){
    

  134.                 cout << "- child -" << endl;
    

  135.                 fd = open("/var/fifo1",O_WRONLY,0);
    

  136.                 if(fd < 0){ 
    

  137.                         cout << "open error!\n" ;
    

  138.                         return -1;
    

  139.                 }
    

  140.                 char buf1[500];
    

  141.                 while(1) {
    

  142.                         cout << "client\n";
    

  143.                         fflush(stdout);
    

  144.                 ssize_t s = read(0,buf1,sizeof(buf1)-1);
    

  145.                 if(s > 0) {
    

  146.                                 buf1[s] = 0;
    

  147.                                 write(fd,buf1,strlen(buf1));
    

  148.                 }
    

  149.                 }
    

  150.         } else {
    

  151.                 cout << "fork error!\n" ;
    

  152.         }
    

  153.         
    

  154.                 cout << "file is exit!\n" ;
    

  155.                 close(ret);
    

  156.         
    


  157. 

  158.         
    

  159. }
    


  160.
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-28 09:31 | 显示全部楼层
在正则表达式里面先找出fifo文件名和路径，然后找出端口号：

复制
  1. #include <sys/types.h>
    

  2. #include <sys/stat.h>
    

  3. #include <fcntl.h>  
    

  4. #include <iostream>
    

  5. #include<regex>
    

  6. #include <fstream>
    


  7. 


  8. 


  9. 

  10. //int mkfifo( const char* path, 
    

  11. //            mode_t mode );
    


  12. 

  13. using namespace std;
    


  14. 

  15. #include <string>
    

  16.  
    

  17. void test()
    

  18. {
    

  19.         std::regex reg("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))\\sMbits");
    

  20.         std::regex reg1("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  21.  
    

  22.         std::string str = "这是中文示例abc 1234.2  a 匹配浮点数值XX5678 2.6  5.789  -0.23411 +01.45";
    


  23. 

  24.         string row = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  25.  
    

  26.         const std::sregex_iterator end;
    

  27.         for (std::sregex_iterator iter(std::cbegin(str), std::cend(str), reg1); iter != end;++iter)
    

  28.                 std::cout << iter->str() << std::endl;
    


  29. 

  30.         for (std::sregex_iterator iter(std::cbegin(row), std::cend(row), reg); iter != end;++iter)
    

  31.                 std::cout << iter->str() << std::endl;
    


  32. 

  33. }
    


  34. 

  35. void test1(string str)
    

  36. {
    

  37.         
    

  38.         //string str = "Hello 2018, Bye 2017";
    

  39.         //string str = "[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";
    

  40.         smatch result;
    

  41.         regex Bandwidth("-?(([0-9]\\d*\\.[1-9]\\d*)|(0)|(0\\.[1-9]\\d*)|([0-9]\\d*))\\sMbits");//(".+(\\d Mbits/sec).+(\\(\\d%\\))");        //
    

  42.         //regex  Packageloss("\\(([0-9]+%)\\)");
    

  43.         regex  Packageloss("\\(-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*)|([0-9]\\d*))\\%\\)");
    

  44.         //regex Value("-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*))");
    

  45.         
    

  46.         
    

  47.         
    

  48.         //迭代器声明
    

  49.         string::const_iterator iterStart = str.begin();
    

  50.         string::const_iterator iterEnd = str.end();
    

  51.         string temp,value;
    

  52.         cout << "==============================" << endl;
    

  53.         while (regex_search(iterStart, iterEnd, result, Bandwidth))
    

  54.         {
    

  55.                 temp = result[0];
    

  56.                 cout << "==== bandwidth: " << result[1] << endl;
    

  57.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  58.         }
    

  59.         cout << "----------------------------------" << endl;
    

  60.         while (regex_search(iterStart, iterEnd, result, Packageloss))
    

  61.         {
    

  62.                 temp = result[0];
    

  63.                 cout << "==== package loss: " << result[1] << endl;
    

  64.                 iterStart = result[0].second;        //更新搜索起始位置,搜索剩下的字符串
    

  65.         }
    

  66.         cout << "-------+++------------------------" << endl;
    

  67. }
    


  68. 


  69. 

  70. int main(void)
    

  71. {
    

  72.         string line;
    

  73.            
    

  74.            //打开文件data.txt
    

  75.         ifstream fin("ethernetTest.sh");
    

  76.         
    

  77.         string s;  
    

  78.     
    


  79. 

  80.         test();
    

  81.         int ret,fd,pid;
    

  82.         //regex Bandwidth("\\s\\s([1-9,\\\\.]+)\\sMbits");
    

  83.         regex Bandwidth(".+(\\d Mbits/sec).+(\\(\\d%\\))");
    

  84.         cout << "\\s\\s([1-9,\\\\.]+)\\sMbits" << endl;
    

  85.         //"MBytes  .* Mbits/sec"
    

  86.         regex Packageloss("\\(([0-9]+%)\\)");
    

  87.         regex filePath("/var/fifo_([0-9]\\d*)");
    

  88.         
    

  89.         string::const_iterator itStart;// = fp.begin();
    

  90.         string::const_iterator itEnd;// = fp.end();
    

  91.         
    

  92.         cout << "==============================" << endl;
    

  93.         
    

  94.         while( getline(fin,s) ){        
    

  95.                 itStart = s.begin();
    

  96.                 itEnd = s.end();
    

  97.                 smatch result;
    

  98.                 if (regex_search(itStart, itEnd, result, filePath)) {
    

  99.                         cout << "+++++ file path: " << result[0] << " num: " << result[1] << endl;
    

  100.                 } else {
    

  101.                         cout << "--- no search ---" << endl;
    

  102.                 }
    

  103.         }
    

  104.         
    

  105.         ret = mkfifo("/var/fifo1",S_IRUSR | S_IWUSR);
    

  106.         cout << "ret: " << ret << endl;
    


  107. 

  108.         pid = fork();
    

  109.         if (pid > 0) {
    

  110.                 cout << "- parent -" << endl;
    

  111.                 fd = open("/var/fifo1",O_RDONLY,0);
    

  112.                 if(fd < 0){ 
    

  113.                         cout << "open error!\n" ;
    

  114.                         return -1;
    

  115.                 }
    

  116.                 char buf1[500];
    

  117.                 while(1) {
    

  118.                         cout << "please waiting...\n";
    

  119.                         ssize_t s = read(fd,buf1,sizeof(buf1)-1);
    

  120.                         if(s > 0) {
    

  121.                                 buf1[s-1] = 0;
    

  122.                                 string row = buf1;//"[  5] 38.0-39.0 sec  11.5 MBytes  96.4 Mbits/sec   0.294 ms   11/ 8208 (0.13%)";//buf1;
    

  123.                                 cout << row << endl;
    

  124.                                 test1(row);
    

  125.                                 
    


  126. 

  127.                         } else if (s == 0) {
    

  128.                                 cout << "client quit,exit ..." << endl;
    

  129.                                 break;
    

  130.                         }
    

  131.                 }
    

  132.                 
    

  133.         } else if (pid == 0){
    

  134.                 cout << "- child -" << endl;
    

  135.                 fd = open("/var/fifo1",O_WRONLY,0);
    

  136.                 if(fd < 0){ 
    

  137.                         cout << "open error!\n" ;
    

  138.                         return -1;
    

  139.                 }
    

  140.                 char buf1[500];
    

  141.                 while(1) {
    

  142.                         cout << "client\n";
    

  143.                         fflush(stdout);
    

  144.                 ssize_t s = read(0,buf1,sizeof(buf1)-1);
    

  145.                 if(s > 0) {
    

  146.                                 buf1[s] = 0;
    

  147.                                 write(fd,buf1,strlen(buf1));
    

  148.                 }
    

  149.                 }
    

  150.         } else {
    

  151.                 cout << "fork error!\n" ;
    

  152.         }
    

  153.         
    

  154.                 cout << "file is exit!\n" ;
    

  155.                 close(ret);
    

  156.         
    


  157. 

  158.         
    

  159. }
    


  160.


运行结果：

复制
  1. # ./fifo_test
    

  2. 1234.2
    

  3. 2.6
    

  4. 5.789
    

  5. -0.23411
    

  6. 1.45
    

  7. 96.4 Mbits
    

  8. \s\s([1-9,\\.]+)\sMbits
    

  9. ==============================
    

  10. --- no search ---
    

  11. --- no search ---
    

  12. --- no search ---
    

  13. --- no search ---
    

  14. --- no search ---
    

  15. +++++ file path: /var/fifo_1200 num: 1200
    

  16. +++++ file path: /var/fifo_1201 num: 1201
    

  17. +++++ file path: /var/fifo_1202 num: 1202
    

  18. +++++ file path: /var/fifo_1203 num: 1203
    

  19. +++++ file path: /var/fifo_1205 num: 1205
    

  20. --- no search ---
    

  21. +++++ file path: /var/fifo_1206 num: 1206
    

  22. +++++ file path: /var/fifo_1207 num: 1207
    

  23. +++++ file path: /var/fifo_1209 num: 1209
    

  24. +++++ file path: /var/fifo_1210 num: 1210
    

  25. --- no search ---
    

  26. --- no search ---
    

  27. --- no search ---
    

  28. --- no search ---
    

  29. --- no search ---
    

  30. ret: -1
    

  31. - parent -
    

  32. - child -
    

  33. please waiting...
    

  34. client
    


  35.
回复 赏

举报

 楼主| keer_zu 发表于 2022-10-9 09:40 | 显示全部楼层
封装。
头文件：
复制
  1. #ifndef __IPERF_COLLECTION_H__
    

  2. #define __IPERF_COLLECTION_H__
    


  3. 

  4. #include <map>
    

  5. #include <pthread.h>
    

  6. #include "macros.h"
    


  7. 

  8. using namespace std;
    


  9. 

  10. typedef void ( * port_performance_calback_t ) ( void * data ) ;
    


  11. 

  12. template<typename T>
    

  13. class Singleton{
    

  14. public:
    

  15.     static T& get_instance(){
    

  16.         static T instance;
    

  17.         return instance;
    

  18.     }
    

  19.         
    

  20.     virtual ~Singleton(){
    

  21.         std::cout<<"destructor called!"<<std::endl;
    

  22.     }
    

  23.         
    

  24.     Singleton(const Singleton&)=delete;
    

  25.     Singleton& operator =(const Singleton&)=delete;
    

  26.         
    

  27. protected:
    

  28.     Singleton(){
    

  29.         std::cout<<"constructor called!"<<std::endl;
    

  30.     }
    


  31. 

  32. };
    


  33. 


  34. 


  35. 

  36. class IperfCollection:public       Singleton<IperfCollection> {
    

  37.         friend class Singleton<IperfCollection>;
    

  38. public:
    


  39. 

  40.         int Init(port_performance_calback_t cb);
    

  41.         
    

  42. private:
    


  43. 

  44.         int createFifo();
    

  45.         int stringParsing(string str,int port);
    

  46.         static void *iperfDataCollection(void *data);
    

  47.         IperfCollection():_callback(NULL){}
    

  48.         ~IperfCollection(){}
    

  49.         
    

  50.         pthread_t        _threadId;
    

  51.         port_performance_calback_t _callback;
    

  52.         
    

  53.         map<int,string> _portFifo;
    

  54.         map<int,int> _portFd;
    

  55. };
    


  56. 


  57. 


  58. 


  59. 


  60. 


  61. 

  62. #endif
回复 赏

举报

 楼主| keer_zu 发表于 2022-10-9 09:41 | 显示全部楼层
.cpp文件：

复制
  1. #include <fstream>
    

  2. #include <fcntl.h>  
    

  3. #include <iostream>
    

  4. #include <regex>
    

  5. #include <string>
    

  6. #include "common_log.h"
    

  7. #include "IperfCollection.h"
    


  8. 


  9. 

  10. using namespace std;
    


  11. 


  12. 


  13. 

  14. int IperfCollection::createFifo()
    

  15. {
    

  16.         ifstream fin("ethernetTest.sh");
    

  17.         string::const_iterator itStart;
    

  18.         string::const_iterator itEnd;
    

  19.         string scriptLine;
    


  20. 

  21.         int ret;
    

  22.         regex filePath("/var/fifo_([0-9]\\d*)");
    

  23.         
    

  24.         while( getline(fin,scriptLine) ){        
    

  25.                 itStart = scriptLine.begin();
    

  26.                 itEnd = scriptLine.end();
    

  27.                 smatch result;
    

  28.                 if (regex_search(itStart, itEnd, result, filePath)) {
    

  29.                         string str_port = result[1];
    

  30.                         string file = result[0];
    

  31.                         int port = atoi(str_port.c_str());
    

  32.                         SLOG_I("fifo file path: %s  port:%d\n",file.c_str(),port);
    

  33.                         string filepath = result[0];
    

  34.                         ret = mkfifo(filepath.c_str(),S_IRUSR | S_IWUSR);
    

  35.                         SLOG_I("mkfifo return:%d\n",ret);
    

  36.                         _portFifo[port] = filepath;
    

  37.                 } else {
    

  38.                         SLOG_W("no fifo search!");
    

  39.                 }
    

  40.         }
    

  41.         
    

  42.         return 0;
    

  43. }
    


  44. 


  45. 

  46. struct rtl9072_port_status
    

  47. {
    

  48.   uint32_t port ;
    

  49.   uint32_t tx_speed ;
    

  50.   uint32_t tx_pack_drop_rate ;
    

  51.   uint32_t rx_speed ;
    

  52.   uint32_t rx_pack_drop_rate ;
    

  53. } ;
    


  54. 

  55. int IperfCollection::stringParsing(string str, int port)
    

  56. {
    

  57.         float bandwidth,loss;
    

  58.         struct rtl9072_port_status status;
    

  59.         smatch result;
    

  60.         port_performance_calback_t call = (port_performance_calback_t)_callback;
    

  61.         
    

  62.         regex BandwidthMbits("-?(((([1-9]\\d*)|([0-9]\\d)|(0))\\.(([0-9]\\d*)|([0-9])\\d))|(0)|([0-9]\\d*))\\sMbits");
    

  63.         regex BandwidthKbits("-?(((([1-9]\\d*)|([0-9]\\d)|(0))\\.(([0-9]\\d*)|([0-9])\\d))|(0)|([0-9]\\d*))\\sKbits");        
    

  64.         regex BandwidthGbits("-?(((([1-9]\\d*)|([0-9]\\d)|(0))\\.(([0-9]\\d*)|([0-9])\\d))|(0)|([0-9]\\d*))\\sGbits");
    

  65.         
    

  66.         regex  Packageloss("\\(-?(([1-9]\\d*\\.\\d*)|(0\\.\\d*[1-9]\\d*)|([0-9]\\d*))\\%\\)");
    


  67. 

  68.         string::const_iterator iterStart = str.begin();
    

  69.         string::const_iterator iterEnd = str.end();
    

  70.         string temp,value;
    


  71. 

  72.         if (regex_search(iterStart, iterEnd, result, BandwidthMbits))
    

  73.         {
    

  74.                 temp = result[0];
    


  75. 

  76.                 value = result[1];
    

  77.                 bandwidth = stof(value) * 1000;
    

  78.                 status.rx_speed = (uint32_t)bandwidth;
    

  79.                 SLOG_I("BandwidthMbits:%s\n",value.c_str());
    

  80.         } else if (regex_search(iterStart, iterEnd, result, BandwidthKbits)) {
    

  81.                 temp = result[0];
    

  82.                 value = result[1];
    

  83.                 bandwidth = stof(value);
    

  84.                 status.rx_speed = (uint32_t)bandwidth;
    

  85.                 SLOG_I("bandwidthKbits:%s\n",value.c_str());
    

  86.         } else if (regex_search(iterStart, iterEnd, result, BandwidthGbits)) {
    

  87.                 temp = result[0];
    

  88.                 value = result[1];
    

  89.                 bandwidth = stof(value) * 1000000;
    

  90.                 status.rx_speed = (uint32_t)bandwidth;
    

  91.                 SLOG_I("BandwidthGbits:%s\n",value.c_str());
    

  92.         }
    

  93.         
    

  94.         if (regex_search(iterStart, iterEnd, result, Packageloss))
    

  95.         {
    

  96.                 temp = result[0];
    

  97.                 value = result[1];
    

  98.                 loss = stof(value) * 100000;
    

  99.                 status.rx_pack_drop_rate = (uint32_t)loss;
    

  100.                 SLOG_I("package loss:%s\n",value.c_str());        
    

  101.         }
    


  102. 

  103.         if(call != NULL)
    

  104.                 call(&status);
    


  105. 

  106.         return 0;
    

  107. }
    


  108. 


  109. 


  110. 


  111. 

  112. void * IperfCollection::iperfDataCollection(void *data)
    

  113. {
    

  114.         int ret,fd;
    

  115.         IperfCollection *collection = (IperfCollection *)data;
    

  116.         map<int,string>::iterator iter_pf;
    

  117.         for(iter_pf = (collection->_portFifo).begin();iter_pf != (collection->_portFifo).end();iter_pf ++) {
    

  118.                 string file = iter_pf->second;
    

  119.                 int port = iter_pf->first;
    

  120.                 fd = open(file.c_str(),O_RDONLY | O_NONBLOCK,0);
    

  121.                 if(fd < 0){ 
    

  122.                         SLOG_E("open error!\n") ;
    

  123.                         return NULL;
    

  124.                 }
    


  125. 

  126.                 collection->_portFd[port] = fd;
    

  127.         }
    

  128.         
    

  129.         char buf1[500];
    

  130.         while(1) {
    

  131.                 for(iter_pf = (collection->_portFifo).begin();iter_pf != (collection->_portFifo).end();iter_pf ++) {
    

  132.                         string file = iter_pf->second;
    

  133.                         int port = iter_pf->first;
    

  134.                         ssize_t s = read(collection->_portFd[port],buf1,sizeof(buf1)-1);
    

  135.                         if(s > 0) {
    

  136.                                 buf1[s-1] = 0;
    

  137.                                 string row = buf1;
    

  138.                                 cout << row << endl;
    

  139.                                 collection->stringParsing(row,port);
    

  140.                         } else if (s == 0) {
    

  141.                                 SLOG_I("client(%d) quit,exit ...\n", port);
    

  142.                                 continue;
    

  143.                         }
    

  144.                 }
    


  145. 

  146.                 sleep(1);
    

  147.         }
    

  148.         close(ret);
    

  149.         return NULL;
    

  150. }
    


  151. 


  152. 


  153. 

  154. int IperfCollection::Init(port_performance_calback_t cb)
    

  155. {
    

  156.         int ret;
    

  157.         
    

  158.         ret = this->createFifo();
    

  159.         if (ret != 0) {
    

  160.                 SLOG_E("createFifo error:%d\n", ret);
    

  161.                 return ret;
    

  162.         }
    


  163. 

  164.         if(cb != NULL)
    

  165.                 _callback = cb;
    


  166. 

  167.         pthread_create(&_threadId, NULL, &iperfDataCollection ,this);
    

  168.         
    

  169.         return 0;
    

  170. }
    


  171. 


  172. 


  173. 


  174. 


  175.
回复 赏

举报

 楼主| keer_zu 发表于 2022-10-9 09:43 | 显示全部楼层
demo:

复制
  1. void callback(void *data)
    

  2. {
    

  3.         cout << "======== call back =====" << endl;
    

  4. }
    


  5. 


  6. 

  7. int main(void)
    

  8. {
    

  9.         IperfCollection &collection = IperfCollection::get_instance();
    

  10.         //collection 
    

  11.         collection.Init(callback);
    


  12. 

  13.         IperfCollection *coll = &IperfCollection::get_instance();
    

  14.         coll->Init(callback);
    


  15. 

  16.         auto re = system("./ethernetTest.sh");
    

  17.     cout << "re = " << re << endl;
    


  18. 

  19.         while(1) {
    

  20.                 sleep(10);
    

  21.                 //return 0;
    

  22.         }
    

  23. }
回复 赏

举报

 楼主| keer_zu 发表于 2022-10-9 09:44 | 显示全部楼层
ethernetTest.sh:

复制
  1. #!/bin/sh
    


  2. 

  3. # FIFO files are named as follows: /var/fifo_XXXX,XXXX is the port number to be tested
    


  4. 

  5. #100base
    

  6. iperf2 -u -s -p 1200 > /var/fifo_1200 & 
    

  7. iperf2 -u -s -p 1201 > /var/fifo_1201 &
    

  8. iperf2 -u -s -p 1202 > /var/fifo_1202 &
    

  9. iperf2 -u -s -p 1203 > /var/fifo_1203 &
    

  10. iperf2 -u -s -p 1205 > /var/fifo_1205 &
    

  11. #1000base
    

  12. iperf2 -u -s -p 1206 > /var/fifo_1206 &
    

  13. iperf2 -u -s -p 1207 > /var/fifo_1207 &
    

  14. iperf2 -u -s -p 1209 > /var/fifo_1209 &
    

  15. iperf2 -u -s -p 1210 > /var/fifo_1210 &
    

  16. #iperf2 -u -c 192.168.1.9 -p 1208 -B 192.168.1.12 -b 100m -t 60 -i 1
    


  17. 

  18. #SocketTest &
回复 赏

举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

keer_zu

1478

主题

12917

帖子

55

粉丝
快速回复 在线客服 返回列表 返回顶部