我实现了游戏服务器,我需要读取和写入。所以我接受传入的连接,并开始使用的aio_read(它读)但是当我需要送东西,我停止使用调用aio_cancel(读取)然后用aio_write()。在书写的回调中,我继续阅读。所以,我一直在阅读,但当我需要发送一些东西 - 我暂停阅读。C - 如何使用aio_read()和aio_write()
它为〜的20%的时间 - 在其他情况下调用调用aio_cancel()失败,“正在进行操作” - 我无法取消它(即使在永久而周期)。所以,我添加的写操作从来没有发生过。
如何良好地使用这些功能?我错过了什么?编辑: 在Linux 2.6.35下使用。 Ubuntu 10 - 32位。
示例代码:
所有的void handle_read(union sigval sigev_value) { /* handle data or disconnection */ }
void handle_write(union sigval sigev_value) { /* free writing buffer memory */ }
void start()
{
const int acceptorSocket = socket(AF_INET, SOCK_STREAM, 0);
struct sockaddr_in addr;
memset(&addr, 0, sizeof(struct sockaddr_in));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = INADDR_ANY;
addr.sin_port = htons(port);
bind(acceptorSocket, (struct sockaddr*)&addr, sizeof(struct sockaddr_in));
listen(acceptorSocket, SOMAXCONN);
struct sockaddr_in address;
socklen_t addressLen = sizeof(struct sockaddr_in);
for(;;)
{
const int incomingSocket = accept(acceptorSocket, (struct sockaddr*)&address, &addressLen);
if(incomingSocket == -1)
{ /* handle error ... */}
else
{
//say socket to append outcoming messages at writing:
const int currentFlags = fcntl(incomingSocket, F_GETFL, 0);
if(currentFlags < 0) { /* handle error ... */ }
if(fcntl(incomingSocket, F_SETFL, currentFlags | O_APPEND) == -1) { /* handle another error ... */ }
//start reading:
struct aiocb* readingAiocb = new struct aiocb;
memset(readingAiocb, 0, sizeof(struct aiocb));
readingAiocb->aio_nbytes = MY_SOME_BUFFER_SIZE;
readingAiocb->aio_fildes = socketDesc;
readingAiocb->aio_buf = mySomeReadBuffer;
readingAiocb->aio_sigevent.sigev_notify = SIGEV_THREAD;
readingAiocb->aio_sigevent.sigev_value.sival_ptr = (void*)mySomeData;
readingAiocb->aio_sigevent.sigev_notify_function = handle_read;
if(aio_read(readingAiocb) != 0) { /* handle error ... */ }
}
}
}
//called at any time from server side:
send(void* data, const size_t dataLength)
{
//... some thread-safety precautions not needed here ...
const int cancellingResult = aio_cancel(socketDesc, readingAiocb);
if(cancellingResult != AIO_CANCELED)
{
//this one happens ~80% of the time - embracing previous call to permanent while cycle does not help:
if(cancellingResult == AIO_NOTCANCELED)
{
puts(strerror(aio_return(readingAiocb))); // "Operation now in progress"
/* don't know what to do... */
}
}
//otherwise it's okay to send:
else
{
aio_write(...);
}
}
你应该指定这是哪个操作系统。也尝试创建一个显示问题的最小自包含示例。否则,你确定你需要取消它吗?我认为完全可以在同一个文件描述符上同时读取和写入操作。 –
在C++中,我使用两个线程同时在同一个套接字上操作。一位读者,一位作家。我认为这也可以与aio一起工作,但我不确定,但也许这可以回答某人。 –
你能否解释一下你为什么需要暂停阅读? aio不允许您发出无取消阅读的写入请求吗? –