First version

1 files changed, 65 insertions, 0 deletions

diff --git a/TAO/orbsvcs/orbsvcs/Concurrency/Concurrency_Utils.h b/TAO/orbsvcs/orbsvcs/Concurrency/Concurrency_Utils.h
new file mode 100644
index 00000000000..5f2599a078e
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Concurrency/Concurrency_Utils.h
@@ -0,0 +1,65 @@
+/* -*- C++ -*- */
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    TAO/orbsvcs/Concurrency_Service
+//
+// = FILENAME
+//    Concurrency_Utils.h
+//
+// = DESCRIPTION
+//      This class implements a Concurrency Server wrapper class which holds
+//      a number of lock sets
+//      The server must run in the thread per request concurrency model in
+//      order to let the clients block on the semaphores.
+//
+// = AUTHORS
+//    Torben Worm <tworm@cs.wustl.edu>
+//
+// ============================================================================
+
+#if !defined (_CONCURRENCY_SERVER_H)
+#define _CONCURRENCY_SERVER_H
+
+#include "tao/corba.h"
+#include "orbsvcs/CosConcurrencyControlC.h"
+#include "CC_LockSetFactory.h"
+
+class TAO_ORBSVCS_Export TAO_Concurrency_Server
+{
+  // = TITLE
+  //    Defines a wrapper class for the implementation of the
+  //    concurrency server.
+  //
+  // = DESCRIPTION
+  //    
+  //    
+  //    
+  //    
+public:
+  TAO_Concurrency_Server (void);
+  //Default constructor.
+
+  TAO_Concurrency_Server (CORBA::ORB_var &orb,
+			  PortableServer::POA_var &poa);
+  // Takes the POA under which to register the Concurrency Service
+  // implementation object.
+
+  int init (CORBA::ORB_var &orb,
+            PortableServer::POA_var &poa);
+  // Initialize the concurrency server under the given ORB and POA.
+
+  CC_LockSetFactory *GetLockSetFactory(void);
+  // Get the lock set factory 
+
+  ~TAO_Concurrency_Server (void);
+  // Destructor.
+
+private:
+  CC_LockSetFactory lock_set_factory_;
+};
+
+#endif /* _CONCURRENCY_SERVER_H */
+