Linux出现“Operationnowinprogress”错误？手把手教你轻松解决！

在Linux环境下，遇到“Operation now in progress”错误，往往是因为程序在进行非阻塞I/O操作时，未正确处理文件描述符的状态。这通常发生在网络编程中，特别是使用socket时。该错误表明一个非阻塞操作仍在进行中，但后续调用试图操作相同的文件描述符。想要解决这个问题，可以使用`select`或`poll`系统调用来监视文件描述符，确保在操作前等待其变为可读/写状态。此外，采用信号处理机制正确中断操作也是一种方法，例如检查`errno`是否为`EINTR`并决定重试或放弃。本文将深入探讨该错误的原因、解决方法，并提供代码示例，即使是小白也能轻松理解和修复这一问题。

"Operation now in progress"错误通常表明一个非阻塞操作仍在进行中，但后续调用试图操作相同的文件描述符。1. 使用select或poll检查文件描述符是否可读/写，以确保在操作前等待其变为可用状态；2. 采用信号处理机制正确中断操作，例如检查errno是否为EINTR并决定重试或放弃；3. 调试时可通过增加日志输出、使用strace跟踪系统调用、使用gdb调试程序以及简化代码来定位问题；4. 其他解决方案包括epoll（高效的I/O多路复用机制）、线程或进程池（用于处理大量并发连接）以及异步I/O（AIO，通过信号或回调通知操作完成）。选择哪种方案取决于具体需求和应用场景。

简而言之，"Operation now in progress"错误通常表明一个非阻塞操作仍在进行中，但后续调用试图操作相同的文件描述符。解决办法包括使用select或poll检查文件描述符是否可读/写，或采用信号处理机制来正确中断操作。

解决方案

这个错误，"Operation now in progress"，在Linux环境下，遇到它的时候，往往让人有点摸不着头脑。它不像"File not found"那样直白，但它通常意味着你的程序在进行非阻塞I/O操作时遇到了麻烦。想象一下，你让一个快递员送货（非阻塞I/O），你告诉他送完就走，不用等收货人签收。结果你又马上让另一个快递员去送同样的货，那肯定会出问题。

所以，问题的核心在于，你可能在没有确认上一个非阻塞操作完成的情况下，就尝试进行下一个操作。这通常发生在网络编程，特别是使用socket的时候。

使用select或poll检查文件描述符状态

最常见的解决方案是使用select或poll系统调用。这两个函数允许你监视多个文件描述符，等待它们变为可读、可写或发生错误。

例如，假设你正在使用非阻塞socket进行接收数据：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/select.h>

#define PORT 8080
#define BUFFER_SIZE 1024

int main() {
    int sockfd, new_socket;
    struct sockaddr_in address;
    int addrlen = sizeof(address);
    char buffer[BUFFER_SIZE] = {0};

    // 创建socket
    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(PORT);

    // 绑定socket
    if (bind(sockfd, (struct sockaddr *)&address, sizeof(address)) < 0) {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(sockfd, 3) < 0) {
        perror("listen");
        exit(EXIT_FAILURE);
    }

    // 设置socket为非阻塞
    int flags = fcntl(sockfd, F_GETFL, 0);
    if (fcntl(sockfd, F_SETFL, flags | O_NONBLOCK) < 0) {
        perror("fcntl");
        exit(EXIT_FAILURE);
    }

    printf("Server listening on port %d...\n", PORT);

    // 接受连接
    if ((new_socket = accept(sockfd, (struct sockaddr *)&address, (socklen_t*)&addrlen))<0) {
        if (errno == EWOULDBLOCK || errno == EAGAIN) {
            printf("No pending connections\n");
        } else {
            perror("accept");
            exit(EXIT_FAILURE);
        }
    }

    if(new_socket > 0){
        printf("Connection accepted\n");
        // 使用select来等待数据
        fd_set readfds;
        FD_ZERO(&readfds);
        FD_SET(new_socket, &readfds);

        struct timeval timeout;
        timeout.tv_sec = 5;
        timeout.tv_usec = 0;

        int activity = select(new_socket + 1, &readfds, NULL, NULL, &timeout);

        if ((activity < 0) && (errno!=EINTR)) {
            perror("select error");
            printf("select error\n");
        }

        if (activity > 0) {
            if (FD_ISSET(new_socket, &readfds)) {
                // 接收数据
                ssize_t valread = recv(new_socket, buffer, BUFFER_SIZE, 0);
                if (valread > 0) {
                    printf("Received: %s\n", buffer);
                } else if (valread == 0) {
                    printf("Client disconnected\n");
                } else {
                    perror("recv");
                }
            }
        } else {
            printf("Timeout occurred\n");
        }
    }


    close(new_socket);
    close(sockfd);
    return 0;
}

在这个例子中，select函数会阻塞，直到new_socket变为可读（即有数据到达），或者超时。如果在超时时间内没有数据到达，select会返回0，你可以处理超时的情况。这避免了在recv之前盲目地调用它，从而避免了"Operation now in progress"错误。

信号处理机制

另一种情况是，你的操作可能被信号中断。例如，如果你的程序接收到一个SIGINT信号（通常是用户按下Ctrl+C），正在进行的系统调用可能会被中断，并返回EINTR错误。你需要检查errno是否为EINTR，如果是，则决定是重试操作还是放弃。

ssize_t bytes_received;
while (1) {
    bytes_received = recv(sockfd, buffer, BUFFER_SIZE, 0);
    if (bytes_received < 0) {
        if (errno == EINTR) {
            // 被信号中断，重试
            continue;
        } else {
            perror("recv");
            break;
        }
    } else if (bytes_received == 0) {
        // 连接关闭
        printf("Connection closed by peer\n");
        break;
    } else {
        // 成功接收到数据
        printf("Received: %s\n", buffer);
        break;
    }
}

这个循环会不断重试recv，直到成功接收到数据、连接关闭或发生其他错误。

为什么非阻塞I/O会产生这个错误？

非阻塞I/O的目的是让程序在等待I/O操作完成时，可以继续执行其他任务。但这也就意味着，你需要自己负责检查I/O操作是否已经完成。如果没有正确处理，就可能出现"Operation now in progress"错误。想象一下，你让快递员送货，并且告诉他不用等签收就走。然后，你又立刻让另一个快递员送同样的货。如果第一个快递员还没把货送到，第二个快递员就会发现货已经在路上了，这就是非阻塞I/O可能出现的问题。

如何调试这类错误？

调试这类错误可能比较棘手，因为它通常涉及到并发和时序问题。你可以尝试以下方法：

1. 增加日志输出： 在关键的代码路径上添加日志输出，例如在调用recv、send、accept等函数前后，记录函数参数和返回值。
2. 使用strace： strace是一个非常有用的工具，它可以跟踪程序的系统调用。你可以使用strace来查看程序实际执行了哪些系统调用，以及它们的返回值。这可以帮助你找到问题的根源。例如：strace -p ，其中是你的程序的进程ID。
3. 使用gdb： 如果你有程序的源代码，可以使用gdb来调试程序。设置断点，单步执行，查看变量的值，可以帮助你理解程序的行为。
4. 简化代码： 尝试简化你的代码，减少并发的数量，看看是否还能重现这个问题。如果简化后的代码不再出现问题，那么问题很可能与并发有关。

除了select和poll，还有其他解决方案吗？

是的，除了select和poll，还有一些其他的解决方案：

1. epoll： epoll是Linux特有的I/O多路复用机制，它比select和poll更高效，特别是在处理大量文件描述符时。epoll使用事件驱动的方式，只有当文件描述符真正发生变化时，才会通知应用程序。
2. 使用线程或进程池： 如果你的程序需要处理大量的并发连接，可以考虑使用线程或进程池。每个线程或进程负责处理一个连接，这样可以避免阻塞I/O带来的问题。
3. 异步I/O (AIO)： 异步I/O允许你发起一个I/O操作，然后立即返回，而不需要等待I/O操作完成。当I/O操作完成时，系统会通过信号或回调函数通知你。AIO可以显著提高程序的性能，但它也比较复杂，需要仔细设计和实现。

选择哪种解决方案取决于你的具体需求和应用场景。对于简单的程序，select或poll可能就足够了。对于高性能的服务器，epoll或AIO可能更适合。

今天关于《Linux出现“Operationnowinprogress”错误？手把手教你轻松解决！》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于信号处理,非阻塞I/O,文件描述符,select/poll,errno的内容请关注golang学习网公众号！