mkfifo并发使用host读client写出现卡住情况

**【问题复现步骤】**，请描述具体的操作步骤
1.read.c和write.c文件如下：
[root@openEuler ~]# cat read.c
/*
 * Copyright (c) Huawei Technologies Co., Ltd. 2023-2023. All rights reserved.
 * Author: zhuyiyang<zhuyiyang@huawei.com>
 * Create: 2023-6-5
 */
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>

#define SLEEP_TIME 5
#define ARG_COUNT 2
int main(int argc, char *argv[])
{
    if (argc != ARG_COUNT) {
        return -1;
    }
    char *fifoName = argv[1];
    int fifoFd = open(fifoName, O_RDONLY);
    if (fifoFd < 0) {
        printf("open fifo failed!\n");
        return -1;
    }
    int i;
    sleep(SLEEP_TIME);
    while (read(fifoFd, &i, sizeof(int)) == sizeof(int)) {
        printf("%d", i);
    }
    close(fifoFd);
    return 0;
}

[root@openEuler ~]# cat write.c
/*
 * Copyright (c) Huawei Technologies Co., Ltd. 2023-2023. All rights reserved.
 * Author: zhuyiyang<zhuyiyang@huawei.com>
 * Create: 2023-6-6
 */
#include <stdlib.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>

#define ARG_2 2
#define ARG_3 3
int main(int argc, char *argv[])
{
    int forLoops = 10;
    if (argc < ARG_2 || argc > ARG_3) {
        return -1;
    }
    if (argc == ARG_3) {
        forLoops = argv[ARG_2];
    }
    char *fifoName = argv[1];
    int fifoFd = open(fifoName, O_WRONLY);
    printf("open fifo succeed!\n");
    if (fifoFd < 0) {
        printf("open fifo failed!\n");
        return -1;
    }
    int i = 1;
    for (; i < forLoops; i++) {
        write(fifoFd, &i, sizeof(int));
    }
    printf("write succeed: %d\n", i);
    close(fifoFd);
    return 0;
}

2.
编译host侧gcc -o read read.c
编译client侧gcc -o write write.c

3.host侧执行
mkfifo dpu_server/fifo
./read dpu_server/fifo

4.client侧执行
for i in {1..10}; do ./write dpu_client/fifo;done
for i in {1..100}; do ./write dpu_client/fifo;done

*【实际结果】**，请描述出问题的结果和影响
1.client侧卡住
![输入图片说明](https://foruda.gitee.com/images/1701857541544633994/e369eb4d_11577111.png "屏幕截图")

2.dmesg信息如下：
![输入图片说明](https://foruda.gitee.com/images/1701857858190847088/9d93d898_11577111.png "屏幕截图")
![输入图片说明](https://foruda.gitee.com/images/1701857874347990377/62b4e88d_11577111.png "屏幕截图")
![输入图片说明](https://foruda.gitee.com/images/1701857887124527961/e7bccc98_11577111.png "屏幕截图")
![输入图片说明](https://foruda.gitee.com/images/1701857901661114883/4d172886_11577111.png "屏幕截图")

openEuler/dpu-utilities
关闭

内容风险标识

评论 (3)

openEuler/dpu-utilities关闭 .gitee-modal { width: 500px !important; }

内容风险标识