Index: src/libchcore/Tests/OverlappedCallbacksTests.cpp =================================================================== diff -u -N -r3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4 -ra4635addad389b9e117679437a3e1b64a739ea96 --- src/libchcore/Tests/OverlappedCallbacksTests.cpp (.../OverlappedCallbacksTests.cpp) (revision 3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4) +++ src/libchcore/Tests/OverlappedCallbacksTests.cpp (.../OverlappedCallbacksTests.cpp) (revision a4635addad389b9e117679437a3e1b64a739ea96) @@ -1,78 +1,78 @@ -#include "stdafx.h" -#include "gtest/gtest.h" -#include "gmock/gmock.h" -#include "../OverlappedCallbacks.h" -#include "../TOverlappedMemoryPool.h" -#include "../../liblogger/TLogFileData.h" -#include "../TOverlappedReader.h" -#include "../TOverlappedWriter.h" - -using namespace chcore; -/* - -TEST(OverlappedCallbackTests, OverlappedReadCompleted_Success) -{ - logger::TLogFileDataPtr spLogData(std::make_shared()); - - TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); - TOverlappedProcessorRangePtr spRange(std::make_shared(0)); - TOverlappedReader queue(spLogData, spBuffers->GetBufferList(), spRange, 4096); - TOverlappedDataBuffer buffer(16384, &queue); - - buffer.InitForRead(0, 1024); - buffer.SetStatusCode(0); - buffer.SetBytesTransferred(234); - buffer.SetParam(&queue); - - OverlappedReadCompleted(ERROR_SUCCESS, 234, &buffer); - - EXPECT_TRUE(buffer.IsLastPart()); - EXPECT_EQ(ERROR_SUCCESS, buffer.GetErrorCode()); - EXPECT_EQ(234, buffer.GetRealDataSize()); -} - -TEST(OverlappedCallbackTests, OverlappedReadCompleted_Failure) -{ - logger::TLogFileDataPtr spLogData(std::make_shared()); - - TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); - TOverlappedProcessorRangePtr spRange(std::make_shared(0)); - TOverlappedReader queue(spLogData, spBuffers->GetBufferList(), spRange, 4096); - TOverlappedDataBuffer buffer(16384, &queue); - - buffer.InitForRead(0, 1024); - buffer.SetStatusCode(0); - buffer.SetBytesTransferred(0); - - OverlappedReadCompleted(ERROR_ACCESS_DENIED, 0, &buffer); - - EXPECT_FALSE(buffer.IsLastPart()); - EXPECT_EQ(ERROR_ACCESS_DENIED, buffer.GetErrorCode()); - EXPECT_EQ(0, buffer.GetRealDataSize()); - - EXPECT_EQ(queue.GetFailedReadBuffer(), &buffer); -}*/ -/* - -TEST(OverlappedCallbackTests, OverlappedWriteCompleted_Success) -{ - logger::TLogFileDataPtr spLogData(std::make_shared()); - - TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); - TOrderedBufferQueuePtr spBuffersToWrite(std::make_shared(0)); - TOverlappedProcessorRangePtr spRange(std::make_shared(0)); - TOverlappedWriter queue(spLogData, spBuffersToWrite, spRange, spBuffers->GetBufferList()); - TOverlappedDataBuffer buffer(16384, &queue); - - buffer.InitForRead(0, 1024); - buffer.SetStatusCode(0); - buffer.SetBytesTransferred(234); - buffer.SetLastPart(true); - buffer.SetRealDataSize(234); - - OverlappedWriteCompleted(ERROR_SUCCESS, 234, &buffer); - - EXPECT_EQ(ERROR_SUCCESS, buffer.GetErrorCode()); - EXPECT_EQ(queue.GetFinishedBuffer(), &buffer); -} -*/ +#include "stdafx.h" +#include "gtest/gtest.h" +#include "gmock/gmock.h" +#include "../OverlappedCallbacks.h" +#include "../TOverlappedMemoryPool.h" +#include "../../liblogger/TLogFileData.h" +#include "../TOverlappedReader.h" +#include "../TOverlappedWriter.h" + +using namespace chcore; +/* + +TEST(OverlappedCallbackTests, OverlappedReadCompleted_Success) +{ + logger::TLogFileDataPtr spLogData(std::make_shared()); + + TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); + TOverlappedProcessorRangePtr spRange(std::make_shared(0)); + TOverlappedReader queue(spLogData, spBuffers->GetBufferList(), spRange, 4096); + TOverlappedDataBuffer buffer(16384, &queue); + + buffer.InitForRead(0, 1024); + buffer.SetStatusCode(0); + buffer.SetBytesTransferred(234); + buffer.SetParam(&queue); + + OverlappedReadCompleted(ERROR_SUCCESS, 234, &buffer); + + EXPECT_TRUE(buffer.IsLastPart()); + EXPECT_EQ(ERROR_SUCCESS, buffer.GetErrorCode()); + EXPECT_EQ(234, buffer.GetRealDataSize()); +} + +TEST(OverlappedCallbackTests, OverlappedReadCompleted_Failure) +{ + logger::TLogFileDataPtr spLogData(std::make_shared()); + + TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); + TOverlappedProcessorRangePtr spRange(std::make_shared(0)); + TOverlappedReader queue(spLogData, spBuffers->GetBufferList(), spRange, 4096); + TOverlappedDataBuffer buffer(16384, &queue); + + buffer.InitForRead(0, 1024); + buffer.SetStatusCode(0); + buffer.SetBytesTransferred(0); + + OverlappedReadCompleted(ERROR_ACCESS_DENIED, 0, &buffer); + + EXPECT_FALSE(buffer.IsLastPart()); + EXPECT_EQ(ERROR_ACCESS_DENIED, buffer.GetErrorCode()); + EXPECT_EQ(0, buffer.GetRealDataSize()); + + EXPECT_EQ(queue.GetFailedReadBuffer(), &buffer); +}*/ +/* + +TEST(OverlappedCallbackTests, OverlappedWriteCompleted_Success) +{ + logger::TLogFileDataPtr spLogData(std::make_shared()); + + TOverlappedMemoryPoolPtr spBuffers(std::make_shared()); + TOrderedBufferQueuePtr spBuffersToWrite(std::make_shared(0)); + TOverlappedProcessorRangePtr spRange(std::make_shared(0)); + TOverlappedWriter queue(spLogData, spBuffersToWrite, spRange, spBuffers->GetBufferList()); + TOverlappedDataBuffer buffer(16384, &queue); + + buffer.InitForRead(0, 1024); + buffer.SetStatusCode(0); + buffer.SetBytesTransferred(234); + buffer.SetLastPart(true); + buffer.SetRealDataSize(234); + + OverlappedWriteCompleted(ERROR_SUCCESS, 234, &buffer); + + EXPECT_EQ(ERROR_SUCCESS, buffer.GetErrorCode()); + EXPECT_EQ(queue.GetFinishedBuffer(), &buffer); +} +*/