“operation now in progress”錯誤通常表明一個非阻塞操作仍在進行中，但后續調用試圖操作相同的文件描述符。1. 使用select或poll檢查文件描述符是否可讀/寫，以確保在操作前等待其變為可用狀態；2. 采用信號處理機制正確中斷操作，例如檢查errno是否為eintr并決定重試或放棄；3. 調試時可通過增加日志輸出、使用strace跟蹤系統調用、使用gdb調試程序以及簡化代碼來定位問題；4. 其他解決方案包括epoll（高效的i/o多路復用機制）、線程或進程池（用于處理大量并發連接）以及異步i/o（aio，通過信號或回調通知操作完成）。選擇哪種方案取決于具體需求和應用場景。
解決方案
這個錯誤，”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 connectionsn"); } else { perror("accept"); exit(EXIT_FAILURE); } } if(new_socket > 0){ printf("Connection acceptedn"); // 使用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 errorn"); } if (activity > 0) { if (FD_ISSET(new_socket, &readfds)) { // 接收數據 ssize_t valread = recv(new_socket, buffer, BUFFER_SIZE, 0); if (valread > 0) { printf("Received: %sn", buffer); } else if (valread == 0) { printf("Client disconnectedn"); } else { perror("recv"); } } } else { printf("Timeout occurredn"); } } 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 peern"); break; } else { // 成功接收到數據 printf("Received: %sn", buffer); break; } }
這個循環會不斷重試recv，直到成功接收到數據、連接關閉或發生其他錯誤。
為什么非阻塞I/O會產生這個錯誤？
非阻塞I/O的目的是讓程序在等待I/O操作完成時，可以繼續執行其他任務。但這也就意味著，你需要自己負責檢查I/O操作是否已經完成。如果沒有正確處理，就可能出現”Operation now in progress”錯誤。想象一下，你讓快遞員送貨，并且告訴他不用等簽收就走。然后，你又立刻讓另一個快遞員送同樣的貨。如果第一個快遞員還沒把貨送到，第二個快遞員就會發現貨已經在路上了，這就是非阻塞I/O可能出現的問題。
如何調試這類錯誤？
調試這類錯誤可能比較棘手，因為它通常涉及到并發和時序問題。你可以嘗試以下方法：
- 增加日志輸出： 在關鍵的代碼路徑上添加日志輸出，例如在調用recv、send、accept等函數前后，記錄函數參數和返回值。
- 使用strace： strace是一個非常有用的工具，它可以跟蹤程序的系統調用。你可以使用strace來查看程序實際執行了哪些系統調用，以及它們的返回值。這可以幫助你找到問題的根源。例如：strace -p ，其中是你的程序的進程ID。
- 使用gdb： 如果你有程序的源代碼，可以使用gdb來調試程序。設置斷點，單步執行，查看變量的值，可以幫助你理解程序的行為。
- 簡化代碼： 嘗試簡化你的代碼，減少并發的數量，看看是否還能重現這個問題。如果簡化后的代碼不再出現問題，那么問題很可能與并發有關。
除了select和poll，還有其他解決方案嗎？
是的，除了select和poll，還有一些其他的解決方案：
- epoll： epoll是Linux特有的I/O多路復用機制，它比select和poll更高效，特別是在處理大量文件描述符時。epoll使用事件驅動的方式，只有當文件描述符真正發生變化時，才會通知應用程序。
- 使用線程或進程池： 如果你的程序需要處理大量的并發連接，可以考慮使用線程或進程池。每個線程或進程負責處理一個連接，這樣可以避免阻塞I/O帶來的問題。
- 異步I/O (AIO)： 異步I/O允許你發起一個I/O操作，然后立即返回，而不需要等待I/O操作完成。當I/O操作完成時，系統會通過信號或回調函數通知你。AIO可以顯著提高程序的性能，但它也比較復雜，需要仔細設計和實現。
選擇哪種解決方案取決于你的具體需求和應用場景。對于簡單的程序，select或poll可能就足夠了。對于高性能的服務器，epoll或AIO可能更適合。
