- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
在一个简单的 C 程序中,每次接受 TCP 套接字上的传入连接时,我都会打开一个新线程来异步处理客户端输入。接受是在无限循环中发生的。客户端数据在传递给 pthread_create 的回调函数中进行处理。当客户端发送数据时,套接字将立即关闭并断开连接。
一旦我使用 telnet 客户端连接到程序监听的端口,程序就准备好接受新连接。到目前为止一切顺利。
现在,当我同时连接两个客户端并依次为其提供一些输入时,主程序将退出并显示代码 141。
服务器控制台
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $ ./sysmon
Thu Apr 9 12:03:17 2015: Finished reading configuration file
Thu Apr 9 12:03:17 2015: Initializing server socket
Thu Apr 9 12:03:17 2015: Accepting connections...
Thu Apr 9 12:03:19 2015: Inbound connection from 127.0.0.1
Using Thread: 0
Thu Apr 9 12:03:19 2015: Accepting connections...
Thu Apr 9 12:03:22 2015: Inbound connection from 127.0.0.1
Using Thread: 1
Thu Apr 9 12:03:22 2015: Accepting connections...
Client msg: asdf
Client msg: asdfasdfdsfadsf
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $ echo $?
141
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $
客户端控制台 1
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $ telnet 127.0.0.1 50231
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
asdfasdfdsfadsf
Connection closed by foreign host.
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $
客户端控制台 2
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $ telnet 127.0.0.1 50231
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
asdf
Message was: asdf
Connection closed by foreign host.
cehrig@devbox /home/cehrig/projects/SystemMonitor/build $
这是用于接受连接的函数的片段。
int connections = 0;
pthread_t * newthread = malloc(sizeof(pthread_t));
while(1) {
_print(stdout, "messages.socketacceppt", cfg, 1);
newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
thrpass_st thr_pass;
thr_pass.sockfd = newsockfd;
thr_pass.cfg = cfg;
_print(stdout, "messages.socketreceived", cfg, 0);
fprintf(stdout, "%d.%d.%d.%d\n",
cli_addr.sin_addr.s_addr&0xFF,
(cli_addr.sin_addr.s_addr&0xFF00)>>8,
(cli_addr.sin_addr.s_addr&0xFF0000)>>16,
(cli_addr.sin_addr.s_addr&0xFF000000)>>24);
printf("Using Thread: %d\n", connections);
pthread_create(newthread+connections, NULL, &read_socket, (void *) &thr_pass);
newthread = (pthread_t *) realloc(newthread, (++connections+1)*sizeof(pthread_t));
}
这是每个新线程的回调函数/入口点。
void * read_socket(void * args)
{
thrpass_st * _args = (thrpass_st *) malloc(sizeof(thrpass_st));
_args = (thrpass_st *) args;
int n;
char * _buf = (char *) malloc(512*sizeof(char));
char * _cor = (char *) malloc(512*sizeof(char));
char * _out = _cor;
bzero(_buf, 512);
bzero(_cor, 512);
size_t bread = 0;
do {
if((n = read(_args->sockfd, _buf+bread, 512-bread)) < 0) {
_print(stderr, "messages.socketreadfail", _args->cfg, 1);
_exit(0);
}
bread+=n;
} while(strchr(_buf, '\n') == NULL && bread <= 512);
int x = 0;
while(*_buf != '\n' && x++ <= 512) {
*_cor++ = *_buf++;
}
printf("Client msg: %s\n", _out);
fflush(stdout);
FILE * sstream = fdopen(_args->sockfd, "w+");
fprintf(sstream, "Message was: %s\n", _out);
fflush(sstream);
shutdown(_args->sockfd, 2);
}
我认为问题出在该函数末尾的某个地方,因为第二个 telnet 客户端没有收到“消息已发送:”行。
任何帮助将不胜感激!干杯。
最佳答案
这是因为 undefined behavior ,并且您的线程函数中有这个 UB,源于以下几行:
thrpass_st * _args = (thrpass_st *) malloc(sizeof(thrpass_st));
_args = (thrpass_st *) args;
第一行分配内存,但随后您用另一个指针覆盖指向该内存的指针,该指针指向另一个函数内的局部变量,该变量一旦 accept
就超出范围。循环迭代。
最简单的解决方案是复制结构:
*_args = *(thrpass_st *) args;
<小时/>
实际上,在这种情况下根本不需要指针,只需执行例如即可。
thrpass_st _args = *(thrpass_st *) args;
这样也不会因为忘记free
而出现内存泄漏。线程末尾的指针。
另请注意,这里有一个竞争条件。如果两个客户端连接非常紧密,则存在两个线程将具有作为参数传递的相同结构数据的风险。
正确的解决方案是为循环中的参数结构分配内存,并将该指针传递给线程函数。并且不要忘记free
当然是线程函数末尾的内存。
关于接受连接后打开两个线程时,C 无限循环中断并出现代码 141,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29535777/
#include int main() { int i; for( i = 0; i< 10 ; i++ ) { printf("test1 &d", i);
我有一个连接到远程服务器以查询数据的 C# 程序。数据很大,所以查询大约需要 2 分钟才能完成。在这 2 分钟的时间内,互联网中断了。这导致作业无法完成,程序卡在获取数据例程中。 它建立了连接,但在选
语句 1: [2,4,6,7,8].each do |i| (i % 2 == 0) || (puts "Not even" && break) puts i end 声明 2: [2
我想知道 C++ 是否有任何处理中断的方法。我希望一个程序将信息存储在文本文件中,而另一个程序根据文本文件中的内容打印一条语句。由于我希望它尽可能准确,因此我需要在更新程序更新文件时中断打印程序。 最
我正在尝试终止一个线程,但它不会中断或停止。所有这些都是名为 Webots 的软件 Controller 的一部分。我用它来模拟多机器人系统。在每个机器人的 Controller 中,我启动了一个线程
中断10h可以使用的服务有很多, 我想问一下关于其中两个我很困惑的问题 首先是, AH = 06H SCROLL UP WINDOW AH = 07H SCROLL DOWN WINDOW 在 D
我有一个基本的 SQL 问题,如果有两个事件连接,"A"和 "B"到 SQL 服务器,假设两者之间发生死锁,那么为了避免死锁,SQL 服务器将回滚其中一个连接“A”或“B”的交易。假设 SQL Ser
我有一个 mapkit/ View ,它工作正常 - 但我滚动并在 2 - 10 次移动后我的应用程序崩溃了......而且这只是一个“中断”。 这是我的代码的一部分。我认为这是后台线程和数组释放/覆
有什么办法可以做到,比如 C/C# ? 例如(C#风格) for (int i = 0; i Seq.tryFind (fun i -> printfn "%d" i i=66) 在实践中,
我的问题是Haskell如何与系统交互。 例如,IO如何发生? 我对IO monad不感兴趣。或者如何使Haskell打印字符串或读取文件。 我对Haskell和底层操作系统之间的层(如果是这样的话)
你能确认下一个break是否取消了内部for循环吗? for (out in 1:n_old){ id_velho <- old_table_df$id[out] for
我有一个程序可以进行一些数据分析,并且有几百行长。 在程序的早期,我想做一些质量控制,如果没有足够的数据,我希望程序终止并返回到 R 控制台。否则,我希望执行其余代码。 我尝试过break、brows
我有一个 if 语句,用于检查我的对象(向导)是否命中了项目。如果他这样做了,巫师的大小将会改变,他应该能够在与障碍物的 1 次碰撞中幸存。 现在我陷入了“在 1 个障碍物碰撞中幸存”,因为在我的碰撞
我正在尝试使用迭代器来显示很多内容。我不断收到“break;”错误线。它说这是一个无法访问的声明。如有任何帮助,我们将不胜感激。 public Lot getLot(int number) {
我正在创建一个应用程序,我需要在其中处理可能非常庞大且可能需要一些时间的数据。 现在我阅读了很多关于 IntentService 的资料,实际上我已经将它实现为处理 REST 调用的通信类,但现在我试
我有一个自定义的 UITableViewCell。该单元具有三个标签。最左边的“金额”标签具有以下约束。 在单元格的右侧,我有另一个标签,“Label Dollar Amount”。它具有以下约束:
我有以下不和谐嵌入: message.reply({ content: '', embed: { color: 11416728, author
JavaScript 不是我最擅长的技能,但我会尽力解释,所以就这样吧。我有人在我的网站上创建了一个幻灯片菜单,我也使用 jplayer 音乐播放器。 现在一切正常,直到我在顶部添加此脚本。由于某种原
我已经在 Ubuntu 上安装了 android studio,有一个带有损坏图像的 API,我也尝试过重新安装。我应该怎么做才能克服这个问题。 删除它后,它没有在 sdk 管理器中显示 提前致谢。
假设我的站点上有大约 10 个 css 文件。我想把它们合二为一。但是当我组合它们时(只是“连接”文件,以便将它们包含到 html 中),我的样式/布局中断了。这不是路径问题或其他问题,只是选择器无法
我是一名优秀的程序员,十分优秀!