From 3aff90f4a822fcf5d902bbfbcc9fa931d6191a8c Mon Sep 17 00:00:00 2001
From: "William R. Otte" <wotte@dre.vanderbilt.edu>
Date: Mon, 24 Jul 2006 15:50:21 +0000
Subject: Repo restructuring

---
 TAO/tao/Synch_Queued_Message.h | 99 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 99 insertions(+)
 create mode 100644 TAO/tao/Synch_Queued_Message.h

(limited to 'TAO/tao/Synch_Queued_Message.h')

diff --git a/TAO/tao/Synch_Queued_Message.h b/TAO/tao/Synch_Queued_Message.h
new file mode 100644
index 00000000000..9dc77c54cc1
--- /dev/null
+++ b/TAO/tao/Synch_Queued_Message.h
@@ -0,0 +1,99 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file Synch_Queued_Message.h
+ *
+ *  $Id$
+ *
+ *  @author Carlos O'Ryan <coryan@uci.edu>
+ */
+//=============================================================================
+
+#ifndef TAO_SYNCH_QUEUED_MESSAGE_H
+#define TAO_SYNCH_QUEUED_MESSAGE_H
+
+#include /**/ "ace/pre.h"
+
+#include "tao/Queued_Message.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+/**
+ * @class TAO_Synch_Queued_Message
+ *
+ * @brief Specialize TAO_Queued_Message for synchronous requests,
+ *        i.e. twoways and oneways sent with reliability better than
+ *        SYNC_NONE.
+ *
+ * Reliable requests block the sending thread until the message is
+ * sent, likewise, the sending thread must be informed if the
+ * connection is closed or the message times out.
+ *
+ * In contrast oneway (and AMI) requests sent with the SYNC_NONE
+ * policy are simple discarded if the connection fails or they
+ * timeout.
+ *
+ * Another important difference is the management of the data buffer:
+ * one SYNC_NONE messages the buffer is immediately copied into a
+ * newly allocated buffer, and must be deallocated.  Other types of
+ * requests use the memory allocated by the sending thread.
+ *
+ */
+class TAO_Export TAO_Synch_Queued_Message : public TAO_Queued_Message
+{
+public:
+  /// Constructor
+  /**
+   * @param contents The message block chain that must be sent.
+   *
+   * @param alloc The allocator that is used to allocate objects of
+   *        this type.
+   */
+  TAO_Synch_Queued_Message (const ACE_Message_Block *contents,
+                            TAO_ORB_Core *oc,
+                            ACE_Allocator *alloc = 0,
+                            bool is_heap_allocated = false);
+
+  /// Destructor
+  virtual ~TAO_Synch_Queued_Message (void);
+
+  const ACE_Message_Block *current_block (void) const;
+
+  /** @name Implement the Template Methods from TAO_Queued_Message
+   */
+  //@{
+  virtual size_t message_length (void) const;
+  virtual int all_data_sent (void) const;
+  virtual void fill_iov (int iovcnt_max, int &iovcnt, iovec iov[]) const;
+  virtual void bytes_transferred (size_t &byte_count);
+  virtual TAO_Queued_Message *clone (ACE_Allocator *alloc);
+  virtual void destroy (void);
+  //@}
+
+private:
+  /// The contents of the message.
+  /**
+   * The message is normally generated by a TAO_OutputCDR stream.  The
+   * application marshals the payload, possibly generating a chain of
+   * message block connected via the 'cont()' field.
+   */
+  ACE_Message_Block *contents_;
+
+  /// The current message block
+  /**
+   * The message may be set in multiple writev() operations.  This
+   * point keeps track of the next message to send out.
+   */
+  ACE_Message_Block *current_block_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#include /**/ "ace/post.h"
+
+#endif  /* TAO_QUEUED_MESSAGE_H */
-- 
cgit v1.2.1