From 7e757377e4e25ed73a2d613ac3c1d8f2f91d95c8 Mon Sep 17 00:00:00 2001 From: Alexey Arno Date: Wed, 11 Mar 2015 16:40:15 +0300 Subject: [PATCH] dbms: Server: feature development. [#METR-15090] --- dbms/src/IO/ReadBufferAIO.cpp | 4 ++-- dbms/src/IO/WriteBufferAIO.cpp | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/dbms/src/IO/ReadBufferAIO.cpp b/dbms/src/IO/ReadBufferAIO.cpp index ebe5435921..fb123dfd9b 100644 --- a/dbms/src/IO/ReadBufferAIO.cpp +++ b/dbms/src/IO/ReadBufferAIO.cpp @@ -26,6 +26,8 @@ ReadBufferAIO::ReadBufferAIO(const std::string & filename_, size_t buffer_size_, auto error_code = (errno == ENOENT) ? ErrorCodes::FILE_DOESNT_EXIST : ErrorCodes::CANNOT_OPEN_FILE; throwFromErrno("Cannot open file " + filename, error_code); } + + ::memset(&request, 0, sizeof(request)); } ReadBufferAIO::~ReadBufferAIO() @@ -124,8 +126,6 @@ bool ReadBufferAIO::nextImpl() return true; /// Создать запрос. - ::memset(&request, 0, sizeof(request)); - request.aio_lio_opcode = IOCB_CMD_PREAD; request.aio_fildes = fd; request.aio_buf = reinterpret_cast(fill_buffer.internalBuffer().begin()); diff --git a/dbms/src/IO/WriteBufferAIO.cpp b/dbms/src/IO/WriteBufferAIO.cpp index b407433a88..f8f2c24a53 100644 --- a/dbms/src/IO/WriteBufferAIO.cpp +++ b/dbms/src/IO/WriteBufferAIO.cpp @@ -26,6 +26,8 @@ WriteBufferAIO::WriteBufferAIO(const std::string & filename_, size_t buffer_size auto error_code = (errno == ENOENT) ? ErrorCodes::FILE_DOESNT_EXIST : ErrorCodes::CANNOT_OPEN_FILE; throwFromErrno("Cannot open file " + filename, error_code); } + + ::memset(&request, 0, sizeof(request)); } WriteBufferAIO::~WriteBufferAIO() @@ -102,8 +104,6 @@ void WriteBufferAIO::nextImpl() swapBuffers(); /// Создать запрос. - ::memset(&request, 0, sizeof(request)); - request.aio_lio_opcode = IOCB_CMD_PWRITE; request.aio_fildes = fd; request.aio_buf = reinterpret_cast(flush_buffer.buffer().begin()); -- GitLab