00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013 #ifndef TAO_ASYNCH_QUEUED_MESSAGE_H
00014 #define TAO_ASYNCH_QUEUED_MESSAGE_H
00015
00016 #include "ace/pre.h"
00017
00018 #include "tao/Queued_Message.h"
00019
00020 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00021 # pragma once
00022 #endif
00023
00024 #include "ace/Time_Value.h"
00025
00026 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
00027 class ACE_Message_Block;
00028 ACE_END_VERSIONED_NAMESPACE_DECL
00029
00030 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
00031
00032
00033
00034
00035
00036
00037
00038
00039 class TAO_Export TAO_Asynch_Queued_Message : public TAO_Queued_Message
00040 {
00041 public:
00042
00043
00044
00045
00046
00047
00048
00049
00050
00051
00052
00053
00054
00055
00056 TAO_Asynch_Queued_Message (const ACE_Message_Block *contents,
00057 TAO_ORB_Core *oc,
00058 ACE_Time_Value *timeout,
00059 ACE_Allocator *alloc,
00060 bool is_heap_allocated);
00061
00062
00063
00064 virtual ~TAO_Asynch_Queued_Message (void);
00065
00066
00067
00068
00069
00070 virtual size_t message_length (void) const;
00071 virtual int all_data_sent (void) const;
00072 virtual void fill_iov (int iovcnt_max, int &iovcnt, iovec iov[]) const;
00073 virtual void bytes_transferred (size_t &byte_count);
00074
00075
00076 virtual TAO_Queued_Message *clone (ACE_Allocator *alloc);
00077 virtual void destroy (void);
00078 virtual bool is_expired (const ACE_Time_Value &now) const;
00079
00080
00081 protected:
00082
00083
00084
00085
00086
00087
00088
00089
00090
00091
00092
00093
00094
00095
00096
00097
00098 TAO_Asynch_Queued_Message (char *buf,
00099 TAO_ORB_Core *oc,
00100 size_t size,
00101 const ACE_Time_Value &abs_timeout,
00102 ACE_Allocator *alloc,
00103 bool is_heap_allocated);
00104 private:
00105
00106 size_t const size_;
00107
00108
00109
00110
00111
00112
00113 size_t offset_;
00114
00115
00116 char *buffer_;
00117
00118
00119 ACE_Time_Value abs_timeout_;
00120
00121 };
00122
00123 TAO_END_VERSIONED_NAMESPACE_DECL
00124
00125 #include "ace/post.h"
00126 #endif