StreamWriteReplyTask.hpp
00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #ifndef __STREAMWRITEREPLYTASK_H
00023 #define __STREAMWRITEREPLYTASK_H
00024
00025 #include <Task.hpp>
00026
00027 #include "StreamOperationHandlerMethod.hpp"
00028
00029 namespace mermaid
00030 {
00031 namespace support
00032 {
00033 namespace io
00034 {
00035
00036 using mermaid::support::activeobject::Task;
00037 using boost::shared_ptr;
00038
00039 class StreamWriteReplyTask : public Task
00040 {
00041 public:
00042 StreamWriteReplyTask (size_t bytesWritten, size_t requestedBytes, const char* const data, bool success,
00043 shared_ptr<StreamOperationHandlerMethodBase> streamOperationHandler);
00044
00045 virtual void run();
00046
00047 virtual ~StreamWriteReplyTask();
00048 private:
00049 size_t bytesWritten_;
00050 size_t requestedBytes_;
00051 const char * data_;
00052 bool success_;
00053 shared_ptr<StreamOperationHandlerMethodBase> streamOperationHandler_;
00054
00055 };
00056
00057 }
00058 }
00059 }
00060
00061 #endif // __STREAMWRITEREPLYTASK_H