WriteTask.cpp
00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #include "config.h"
00023
00024 #include "WriteTask.hpp"
00025 #include "StreamHandler.hpp"
00026 #include "IOManager.hpp"
00027 #include <Time.hpp>
00028
00029 using namespace mermaid::support::io;
00030 using mermaid::support::system::Time;
00031
00032 WriteTask::~WriteTask()
00033 {
00034
00035 }
00036
00037 WriteTask::WriteTask (IOThread* ioThread, int fileDescriptor, size_t bytesToWrite, const char* data, shared_ptr<StreamOperationHandlerMethodBase> streamOperationHandlerWrite) :
00038 Task(), ioThread_ (ioThread), fileDescriptor_ (fileDescriptor), bytesToWrite_ (bytesToWrite), data_ (data), streamOperationHandlerWrite_ (streamOperationHandlerWrite)
00039 {
00040
00041 }
00042
00043 void WriteTask::run()
00044 {
00045 ioThread_->streamHandler_->getAssociatedStreamWriter (fileDescriptor_)->doWrite (bytesToWrite_, data_, streamOperationHandlerWrite_);
00046 }
00047