开源工具iperf代码C/C++

时间: 2023-12-20 09:04:28 浏览: 64
以下是iperf3的C代码,可以在GitHub上找到完整的代码: ```c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <signal.h> #include <errno.h> #include <netdb.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include "iperf.h" #include "iperf_api.h" #include "iperf_locale.h" #include "units.h" #include "net.h" #include "timer.h" #include "tcp_window_size.h" #include "cjson.h" #ifdef HAVE_SSL #include <openssl/ssl.h> #include <openssl/err.h> #endif /* Forwards. */ static int iperf_run(struct iperf_test *test); /**************************************************************************/ int main(int argc, char **argv) { int i; struct iperf_test *test; int result; struct sigaction sa; char client_version[10] = IPERF_VERSION; setlocale(LC_ALL, ""); bindtextdomain("iperf3", LOCALEDIR); textdomain("iperf3"); /* Initialize settings. */ test = iperf_new_test(); /* Register a few signal handlers to make clean exit more likely. */ memset(&sa, 0, sizeof(sa)); sa.sa_handler = &iperf_got_sigint; sigaction(SIGINT, &sa, NULL); sa.sa_handler = &iperf_got_sigpipe; sigaction(SIGPIPE, &sa, NULL); /* Parse command line options, handling some options immediately. */ i = iperf_parse_arguments(test, argc, argv); if (i < 0) { fprintf(stderr, "%s", iperf_strerror(i)); exit(1); } if (test->version) { printf("%s\n", client_version); exit(0); } else if (test->help) { iperf_printf(test, "\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n", "Usage: iperf3 [-options] [-s|-c host] [options]\n", "Client/Server:", " -V, --version show version information and quit.", " -h, --help show this message and quit.", " -i, --interval n seconds between periodic bandwidth reports.", " -f, --format [kmKM] format to report: Kbits, Mbits, KBytes, MBytes", " -P, --parallel n number of parallel client streams to run."); iperf_printf(test, "\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n", "Client specific:", " -c, --client <host> run in client mode, connecting to <host>.", " -u, --udp use UDP rather than TCP.", " -b, --bitrate #[KMG][/#] target bitrate in bits/sec (0 for unlimited)", " (default 1 Mbit/sec for UDP, unlimited for TCP)", " -t, --time n time in seconds to transmit for (default 10 secs)", " -n, --bytes n number of bytes to transmit (instead of -t)", " -k, --blockcount #[KMG] number of blocks (packets) to transmit (instead of -t or -n)", " -l, --length #[KMG] length of buffer to read or write", " (default 128 KB for TCP, dynamic or 8 KB for UDP)", " -R, --reverse reverse the direction of a test (client sends, server receives)."); iperf_printf(test, "\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n", "Server specific:", " -s, --server run in server mode.", " -D, --daemon run the server as a daemon", " -I, --pidfile file write PID file (default /var/run/iperf3.pid)", " -1, --one-off handle one client connection then exit.", " -B, --bind <host> bind to a specific interface, e.g. eth0"); iperf_printf(test, "\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n%s\n\n", "JSON options:", " -J, --json output in JSON format", " --logfile f send output to a log file", "", "For more information and tuning options, see iperf3's man page.", "", "Please report bugs to https://github.com/esnet/iperf", ""); exit(0); } /* Check for version number consistency. */ if (test->protocol->id == Ptcp && test->version == 3 && test->tcp.omit_version) { i = 2; } else { i = 3; } if (strncmp(client_version, test->version_string, i) != 0) { iperf_printf(test, "warning: version number mismatch (client %s, server %s)\n", client_version, test->version_string); } /* Initialize IP protocol */ if (test->cookiefile) { test->cookie = iperf_load_cookie(test->cookiefile); if (test->cookie == NULL) { iperf_errexit(test, "unable to load cookie from file '%s'", test->cookiefile); } } if (test->reverse) test->settings->reverse = 1; if (test->protocol->id == Pudp) { if (test->settings->mss || test->settings->socket_bufsize) { iperf_printf(test, "warning: MSS and socket buffer size settings are not used in UDP mode.\n"); } if (test->settings->no_delay) { iperf_printf(test, "warning: the TCP_NODELAY option is not used in UDP mode.\n"); } if (test->settings->pmtu != -1) { iperf_printf(test, "warning: the PMTU option is not used in UDP mode.\n"); } } #ifdef HAVE_SSL /* Initialize SSL library */ if (test->protocol->id == Ptcp && test->settings->ssl) { SSL_load_error_strings(); SSL_library_init(); test->sslctx = SSL_CTX_new(TLS_client_method()); if (test->sslctx == NULL) { iperf_errexit(test, "failed to create SSL context\n"); } if (test->settings->ssl_cafile) { if (SSL_CTX_load_verify_locations(test->sslctx, test->settings->ssl_cafile, NULL) != 1) { SSL_CTX_free(test->sslctx); iperf_errexit(test, "failed to load CA certificates from %s\n", test->settings->ssl_cafile); } } if (test->settings->ssl_cert) { if (SSL_CTX_use_certificate_chain_file(test->sslctx, test->settings->ssl_cert) != 1) { SSL_CTX_free(test->sslctx); iperf_errexit(test, "failed to load SSL certificate from %s\n", test->settings->ssl_cert); } } if (test->settings->ssl_key) { if (SSL_CTX_use_PrivateKey_file(test->sslctx, test->settings->ssl_key, SSL_FILETYPE_PEM) != 1) { SSL_CTX_free(test->sslctx); iperf_errexit(test, "failed to load SSL key from %s\n", test->settings->ssl_key); } } SSL_CTX_set_verify(test->sslctx, SSL_VERIFY_PEER, NULL); } #endif /* Daemon mode. */ if (test->daemon) { if (daemon(0, 0) != 0) { iperf_errexit(test, "error - failed to become a daemon: %s\n", strerror(errno)); } if (test->pidfile) { FILE *f; f = fopen(test->pidfile, "w"); if (f == NULL) { iperf_errexit(test, "error - unable to write PID file '%s': %s\n", test->pidfile, strerror(errno)); } fprintf(f, "%d\n", getpid()); fclose(f); } } /* Ignore SIGPIPE to simplify error handling */ sa.sa_handler = SIG_IGN; sigaction(SIGPIPE, &sa, NULL); /* If we are doing a single client (-1) and it is a daemon, don't do -D again */ if (test->daemon && test->num_ostreams == 1) test->daemon = 0; /* Defer daemon mode until after the above check for single client + daemon */ if (test->daemon) { if (daemon(0, 0) != 0) { iperf_errexit(test, "error - failed to become a daemon: %s\n", strerror(errno)); } if (test->pidfile) { FILE *f; f = fopen(test->pidfile, "w"); if (f == NULL) { iperf_errexit(test, "error - unable to write PID file '%s': %s\n", test->pidfile, strerror(errno)); } fprintf(f, "%d\n", getpid()); fclose(f); } } /* Ignore SIGPIPE to simplify error handling */ sa.sa_handler = SIG_IGN; sigaction(SIGPIPE, &sa, NULL); /* Set up the output stream */ if (test->json_output) { test->outfile = json_get_output_stream(test->json_output_file); } else if (test->logfile) { test->outfile = fopen(test->logfile, "w"); if (test->outfile == NULL) { iperf_errexit(test, "error - unable to write log to file '%s': %s\n", test->logfile, strerror(errno)); } } else { test->outfile = stdout; } /* Start the client or server */ if (test->server) { if (test->daemon) { iperf_printf(test, "Server listening on port %d\n", test->server_port); } else { iperf_printf(test, "-----------------------------------------------------------\n"); iperf_printf(test, "Server listening on %s port %d\n", test->settings->domain == AF_INET6 ? "[::]" : "0.0.0.0", test->server_port); iperf_printf(test, "-----------------------------------------------------------\n"); } result = iperf_run_server(test); } else { if (test->daemon) { iperf_printf(test, "Client connecting to %s, TCP port %d\n", test->server_hostname, test->server_port); } else { if (test->reverse) iperf_printf(test, "-----------------------------------------------------------\n"); iperf_printf(test, "Client connecting to %s, %s port %d\n", test->server_hostname, test->protocol->name, test->server_port); if (test->reverse) iperf_printf(test, "-----------------------------------------------------------\n"); } result = iperf_run_client(test); } if (test->cookie) iperf_delete_cookie(test->cookie); #ifdef HAVE_SSL if (test->protocol->id == Ptcp && test->settings->ssl) { SSL_CTX_free(test->sslctx); } ERR_free_strings(); #endif iperf_free_test(test); return result; } static int iperf_run(struct iperf_test *test) { test->start_time = milliseconds(); test->next_time = test->start_time; test->bytes_sent = 0; test->blocks_sent = 0; test->retransmits = 0; if (test->server_hostname) { test->server_hostname_len = strlen(test->server_hostname); } if (test->bind_address) { test->bind_address_len = strlen(test->bind_address); } if (test->json_output) { cJSON *json_output = cJSON_CreateObject(); if (json_output == NULL) { iperf_errexit(test, "error - cJSON_CreateObject failed: %s\n", strerror(errno)); } cJSON_AddItemToObject(json_output, "start", cJSON_CreateNumber((double) test->start_time / 1000)); if (test->verbose) { cJSON_AddItemToObject(json_output, "verbose", cJSON_CreateNumber(1)); } cJSON_AddItemToObject(json_output, "system_info", cJSON_CreateObject()); iperf_json_printf(json_output, "version", "%s", test->version); iperf_json_printf(json_output, "system_info", "%s", get_system_info()); if (test->title) { iperf_json_printf(json_output, "title", "%s", test->title); } if (test->extra_data) { cJSON_AddItemToObject(json_output, "extra_data", cJSON_Parse(test->extra_data)); } test->json_start_time = milliseconds(); test->json_output_string = cJSON_Print(json_output); cJSON_Delete(json_output); if (test->json_output_string == NULL) { iperf_errexit(test, "error - cJSON_Print failed: %s\n", strerror(errno)); } } if (test->protocol->id == Ptcp) { if (test->settings->socket_bufsize) { if (iperf_set_tcp_windowsize(test) != 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } } if (test->reverse) { if (test->protocol->id == Ptcp) { if (iperf_create_streams(test, test->reverse) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } if (iperf_connect(test, test->reverse) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } else { if (iperf_create_streams(test, test->reverse) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } if (iperf_connect(test, test->reverse) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } if (test->json_output) { cJSON *json_output = cJSON_CreateObject(); if (json_output == NULL) { iperf_errexit(test, "error - cJSON_CreateObject failed: %s\n", strerror(errno)); } cJSON_AddItemToObject(json_output, "start", cJSON_CreateNumber((double) test->start_time / 1000)); if (test->verbose) { cJSON_AddItemToObject(json_output, "verbose", cJSON_CreateNumber(1)); } iperf_json_printf(json_output, "interval", "%d", test->settings->stats_interval); if (test->title) { iperf_json_printf(json_output, "title", "%s", test->title); } if (test->extra_data) { cJSON_AddItemToObject(json_output, "extra_data", cJSON_Parse(test->extra_data)); } iperf_json_printf(json_output, "start_connected", "%d", test->connected); cJSON_AddItemToObject(json_output, "intervals", cJSON_CreateArray()); test->json_output_string = cJSON_Print(json_output); cJSON_Delete(json_output); if (test->json_output_string == NULL) { iperf_errexit(test, "error - cJSON_Print failed: %s\n", strerror(errno)); } } if (test->protocol->id == Pudp) { if (iperf_udp_connect(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } if (test->reverse) { if (test->protocol->id == Ptcp) { if (iperf_listen(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } if (test->protocol->id == Pudp || test->protocol->id == Psctp) { if (iperf_run_server_udp(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } else { if (iperf_run_server_tcp(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } } else { if (test->protocol->id == Ptcp) { if (iperf_run_client_tcp(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } else { if (iperf_run_client_udp(test) < 0) { iperf_errexit(test, "error - %s\n", strerror(errno)); } } } if (test->json_output) { cJSON *json_output = cJSON_CreateObject(); if (json_output == NULL) { iperf_errexit(test, "error - cJSON_CreateObject failed: %s\n", strerror(errno)); } cJSON_AddItemToObject(json_output, "start", cJSON_CreateNumber((double) test->start_time / 1000)); if (test->verbose) { cJSON_AddItemToObject(json_output, "verbose", cJSON_CreateNumber(1)); } iperf_json_printf(json_output, "interval", "%d", test->settings->stats_interval); if (test->title) { iperf_json_printf(json_output, "title", "%s", test->title); } if (test

相关推荐

最新推荐

怎么使用iperf来测量wifi吞吐量

第一步:Push the iperf(怎么使用iperf来测量wifi吞吐量\iperf_androidKK_win7 version) to your phone。 adb push iperf /system/bin/ adb shell chmod 777 iperf 第二步:collect the AP by wired or ...

安装aarch64交叉编译工具并交叉编译iperf3.1.3.docx

文档包含完整的例子,交叉编译还提供了下载链接,保证有用,不成功可...centos7下进行aarch64(arm64)交叉编译工具安装 iperf3交叉编译并在Android下运行 iperf3带宽TCP、UDP性能测试 怎么5分变6分了,不知道为什么

iperf3灌包方法.doc

iPerf3是用于主动侦测IP网络上最大可实现带宽的工具。它支持时序、缓冲区、协议(TCP,UDP,SCTP与IPv4和IPv6)有关的各种参数。对于每个测试,它都会报告带宽,丢包和其他参数。

iperf使用工具说明文档

iperf使用工具说明文档,很多人只会用工具不会分析,我就是一样,所以找了个文档的说明,给大家分享一下

iperf使用方法及流程介绍.docx

iperf参数介绍,iperf的tcp,udp,单线程,多线程,交互及双向通信测试命令,示例及说明,实际测试截图及结果项说明,iperf实际应用场景,通信框图及程序流程图介绍iperf,并介绍其他类似网络性能测试工具netperf,...

ChatGPT的工作原理-2023最新版

ChatGPT 是一种能够生成文本的AI模型,它可以自动生成看起来非常像人类写的文字。尽管这让人感到惊讶,但它的工作原理其实并不复杂。在本文中,我们将深入探讨 ChatGPT 的内部结构和运行原理,解释为什么它如此成功地生成有意义的文本。 首先,我们需要了解概率是怎么产生的。概率在AI系统中起着至关重要的作用,通过统计数据和模式识别来预测下一个可能的事件。在 ChatGPT 中,概率被用来生成各种不同的文本形式。 接下来,我们将探讨模型的概念。在AI领域,模型是指一种数学和统计工具,用于解决复杂的问题。ChatGPT 就是一个基于神经网络的模型,它可以学习和理解大量的文本数据,并生成类似的内容。 神经网络是 ChatGPT 的核心组成部分,它模拟了人类大脑的工作方式,并通过多层次的神经元相互连接来处理信息。通过机器学习和神经网络的训练,ChatGPT 可以不断改进其生成文本的质量和准确性。 在 ChatGPT 的训练过程中,嵌入是一个重要的概念。嵌入是将单词或短语转换为向量形式的技术,它有助于模型更好地理解和处理文本数据。 随着 ChatGPT 不断进行基本训练,其能力也在不断提升。但是真正让 ChatGPT 发挥作用的是意义空间和语义运动法则。这些概念帮助模型更好地理解文本的含义和语境,从而生成更加准确和有意义的文本。 此外,语义语法和计算语言的力量也在 ChatGPT 的工作原理中扮演着重要角色。这些工具和技术帮助 ChatGPT 更好地理解文本结构和语法规则,生成更加流畅和自然的文本。 最后,我们将探讨 ChatGPT 对于普通人的影响和机会。作为一种能够生成文本的工具,ChatGPT 可以帮助人们更高效地处理信息和进行沟通,为个人和企业带来更多的机会和发展空间。 综上所述,ChatGPT 是一种非常先进的AI模型,其工作原理基于概率、模型、神经网络和机器学习等技术。通过不断的训练和优化,ChatGPT 能够生成高质量、有意义的文本,为人们的工作和生活带来便利和价值。ChatGPT 的成功离不开对概率、神经网络和语义理解等方面的深入研究,它的影响和机会也将继续扩大,为未来的人工智能发展开辟新的可能性。

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire

嵌入式系统设计:单片机与外设模块的接口设计与优化

# 1. 嵌入式系统设计基础 嵌入式系统是一种专用计算机系统,通常用于控制、监视或执行特定功能。其特点包括紧凑、低功耗、实时性要求高等。与通用计算机系统相比,嵌入式系统更专注于特定应用领域,硬件资源有限、软件定制化程度高。 在嵌入式系统架构中,单片机架构常用于资源受限的场景,外设模块扩展了系统功能。处理器的选择需兼顾性能与功耗,并优化功耗管理策略。 设计嵌入式系统时,需要考虑单片机的选择与接口设计,保证系统稳定可靠。外设模块的选择与接口设计也至关重要,要确保数据传输高效可靠。最后,设计优化技巧如电路布局、供电系统设计、软硬件协同优化能提升系统性能与稳定性。 # 2. 单片机的选择与应用

halcon控件中点击区域选中已存在区域

如果你想在Halcon控件中点击已存在的区域以选中它,你可以使用`set_check`函数来实现。以下是一个示例代码: ```c++ HWindow hWnd; // Halcon窗口句柄 HObject image; // Halcon图像对象 HObject region; // 已存在的区域对象 // 读取图像到image对象中 ReadImage(&image, "image.jpg"); // 生成一个示例的区域对象 GenRectangle1(&region, 100, 100, 300, 300); // 显示图像和已存在的区域到Halcon窗口 DispObj(imag

毕业论文jsp714学生管理系统 带论坛ssh.doc

本文是关于一个JSP714学生管理系统带论坛的毕业论文。论文包括了摘要、背景意义、论文结构安排、开发技术介绍、需求分析、可行性分析、功能分析、业务流程分析、数据库设计、ER图、数据字典、数据流图、详细设计、系统截图、测试、总结、致谢和参考文献。 在毕业论文中,作者首先对学生管理系统的背景和意义进行了阐述,指出了学生管理系统的重要性和实用价值。接着作者详细介绍了论文的结构安排,包括各章节的内容和组织方式。在开发技术介绍中,作者说明了使用的技术和工具,为后续开发工作做好准备。 需求分析部分详细描述了学生管理系统的功能需求和性能需求,为系统设计和开发提供了指导。可行性分析则对系统的可行性进行了评估,包括技术可行性、经济可行性和实施可行性等方面。功能分析部分对系统的主要功能进行了梳理,明确了系统需要实现的功能模块和功能点。 在业务流程分析中,作者对学生管理系统的业务流程进行了建模和分析,确保系统设计符合实际业务需求。数据库设计部分包括ER图和数据字典,详细说明了系统数据库的结构和字段定义。数据流图则展示了系统的数据流向和处理过程,为系统设计提供了参考。 详细设计部分包括系统架构设计、模块设计和界面设计等内容,为系统开发提供了具体步骤和方法。系统截图展示了系统的界面和功能,使读者可以直观地了解系统的运行情况。测试部分对系统进行了全面的测试,确保系统的稳定性和可靠性。 总结部分对整个毕业论文进行了总结和归纳,指出了系统的优点和不足之处,并提出了改进和发展的方向。致谢部分感谢了所有支持和帮助过作者的人,表达了作者的诚挚感激之情。参考文献列出了作者在研究过程中所参考的文献和资料。 整个毕业论文详细而全面地介绍了一个JSP714学生管理系统带论坛的设计与开发过程,具有很高的实用价值和参考意义。通过本文的阅读,读者可以了解到学生管理系统的设计方法和开发过程,对相关领域的研究和实践起到了有效的指导作用。