/usr/include/tao/Exclusive_TMS.h is in libtao-dev 6.0.1-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 | // -*- C++ -*-
//=============================================================================
/**
* @file Exclusive_TMS.h
*
* $Id: Exclusive_TMS.h 85012 2009-04-02 10:05:46Z msmit $
*
* @author Alexander Babu Arulanthu <alex@cs.wustl.edu>
*/
//=============================================================================
#ifndef TAO_EXCLUSIVE_TMS_H
#define TAO_EXCLUSIVE_TMS_H
#include /**/ "ace/pre.h"
#include "tao/Transport_Mux_Strategy.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_Pluggable_Reply_Params;
class TAO_Reply_Dispatcher;
/**
* @class TAO_Exclusive_TMS
*
* Using this strategy only one request can be pending at a time
* in a connection. This improves performance because the client
* does not have to demux the reply, and there is less need for
* synchronization.
* On the other hand, it does not scale well when you have
* multiple client threads or asynchronous messaging.
*/
class TAO_Export TAO_Exclusive_TMS : public TAO_Transport_Mux_Strategy
{
public:
/// Constructor.
TAO_Exclusive_TMS (TAO_Transport *transport);
/// Destructor.
virtual ~TAO_Exclusive_TMS (void);
/**
* @name The TAO_Transport_Mux_Strategy overrided methods
*
* Please read the documentation in the TAO_Transport_Mux_Strategy class
* for details.
*/
//@{
virtual CORBA::ULong request_id (void);
virtual int bind_dispatcher (CORBA::ULong request_id,
ACE_Intrusive_Auto_Ptr<TAO_Reply_Dispatcher> rd);
virtual int unbind_dispatcher (CORBA::ULong request_id);
virtual int dispatch_reply (TAO_Pluggable_Reply_Params ¶ms);
virtual int reply_timed_out (CORBA::ULong request_id);
virtual bool idle_after_send (void);
virtual bool idle_after_reply (void);
virtual void connection_closed (void);
virtual bool has_request (void);
//@}
protected:
/// Used to generate a different request_id on each call to
/// request_id().
CORBA::ULong request_id_generator_;
/// Request id for the current request.
CORBA::ULong request_id_;
/// Reply Dispatcher corresponding to the request. If this is zero we don't
/// have a reply, if it not zero we have one
ACE_Intrusive_Auto_Ptr<TAO_Reply_Dispatcher> rd_;
};
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif /* EXCLUSIVE_TMS_H */
|