activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r379623 [16/18] - in /incubator/activemq/trunk: ./ activecluster/ activecluster/src/java/org/apache/activecluster/ activecluster/src/java/org/apache/activecluster/group/ activecluster/src/java/org/apache/activecluster/impl/ activeio/ active...
Date Tue, 21 Feb 2006 23:29:06 GMT
Modified: incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.cpp Tue Feb 21 15:28:33 2006
@@ -1,272 +1,272 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include <iostream>
-#include <exception>
-#include <typeinfo>
-#include "transport/SocketTransport.hpp"
-
-using namespace std;
-using namespace apache::activemq::client::transport;
-
-
-// --- Constructors -------------------------------------------------
-
-/*
- *
- */
-SocketTransport::SocketTransport(const char* host, int port)
-{
-	// Initialize APR framework
-    init() ;
-
-    cout << "Opening socket to: " << host << " on port: " << port << endl ;
-
-    // Open socket
-    socket = connect(host, port) ;
-    writer = new SocketBinaryWriter(socket) ;
-    reader = new SocketBinaryReader(socket) ;
-}
-
-/*
- *
- */
-SocketTransport::~SocketTransport()
-{
-	// Destroy memory pools (including sub pool) and terminate APR
-	if( memoryPool != NULL )
-		apr_pool_destroy(memoryPool) ;
-
-	// Terminate APR framework
-	apr_terminate() ;
-}
-
-
-// --- Attribute methods --------------------------------------------
-
-
-// --- Operation methods --------------------------------------------
-
-/*
- *
- */
-void SocketTransport::oneway(p<ICommand> command)
-{
-    p<BaseCommand> baseCommand = (p<BaseCommand>&)command ;
-
-    // Set command id and that no response is required
-    baseCommand->setCommandId( getNextCommandId() ) ;
-    baseCommand->setResponseRequired(false) ;
-
-    send(command) ;
-}
-
-/*
- *
- */
-p<FutureResponse> SocketTransport::asyncRequest(p<ICommand> command)
-{
-    p<BaseCommand> baseCommand = (p<BaseCommand>&)command ;
-
-    // Set command id and that a response is required
-    baseCommand->setCommandId( getNextCommandId() ) ;
-    baseCommand->setResponseRequired(true) ;
-    send(command) ;
-
-    // Register a future response holder with the command id
-    p<FutureResponse> future = new FutureResponse() ;
-    requestMap[baseCommand->getCommandId()] = future ;
-
-    return future ;
-}
-
-/*
- *
- */
-p<Response> SocketTransport::request(p<ICommand> command)
-{
-    p<FutureResponse> future = asyncRequest(command) ;
-    return future->getResponse() ;
-}
-
-
-// --- Implementation methods ---------------------------------------
-
-/*
- *
- */
-void SocketTransport::init()
-{
-    apr_threadattr_t *attribs ;
-    apr_status_t     rc ;
-
-	// Initialize APR framework
-    rc = apr_initialize() ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to initialize APR framework.") ;
-   
-    // Create APR memory pool
-    rc = apr_pool_create(&memoryPool, NULL) ;
-    if( rc != APR_SUCCESS )
-	    throw exception("Failed to allocate APR memory pool.") ;
-
-    // Create transmission mutex
-    apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_UNNESTED, memoryPool) ;
-
-	// Create attached thread attribute so main thread can terminate it
-    apr_threadattr_create(&attribs, memoryPool) ;
-    apr_threadattr_detach_set(attribs, 0) ;
-
-    // Create and start the background read thread
-    apr_thread_create(&readThread, attribs, this->readLoop, this, memoryPool) ;
-}
-
-/*
- *
- */
-void SocketTransport::acquireLock()
-{
-    apr_thread_mutex_lock(mutex) ;
-}
-
-/*
- *
- */
-void SocketTransport::releaseLock()
-{
-    apr_thread_mutex_unlock(mutex) ;
-}
-
-/*
- *
- */
-void SocketTransport::send(p<ICommand> command)
-{
-    // Wait for lock and then transmit command
-    acquireLock() ;
-    CommandMarshallerRegistry::writeCommand(command, writer) ;
-    releaseLock() ;
-}
-
-/*
- *
- */
-long SocketTransport::getNextCommandId()
-{
-    long id ;
-
-    // Wait for lock and then fetch next command id
-    acquireLock() ;
-    id = ++nextCommandId ;
-    releaseLock() ;
-
-    return id ;
-}
-
-/*
- *
- */
-apr_socket_t* SocketTransport::connect(const char* host, int port)
-{
-    apr_socket_t* sock ;
-	apr_status_t   rc ;
-    
-	// Look up the remote address
-	rc = apr_sockaddr_info_get(&remote_sa, host, APR_UNSPEC, port, 0, memoryPool) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to lookup remote address") ;
-	
-	// Create socket
-	rc = apr_socket_create(&sock, remote_sa->sa.sin.sin_family, SOCK_STREAM, APR_PROTO_TCP, memoryPool) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to create socket") ;
-
-	// Connect socket
-    rc = apr_socket_connect(sock, remote_sa) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to connect socket") ;
-   
-    // Get socket info
-    rc = apr_socket_addr_get(&remote_sa, APR_REMOTE, sock) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to fetch remote socket address") ;
-    rc = apr_sockaddr_ip_get(&remote_ip, remote_sa) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to fetch remote IP address") ;
-    rc = apr_socket_addr_get(&local_sa, APR_LOCAL, sock) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to fetch local socket address") ;
-    rc = apr_sockaddr_ip_get(&local_ip, local_sa) ;
-    if( rc != APR_SUCCESS )
-        throw exception("Failed to fetch local IP address") ;
-   
-	return sock ;
-}
-
-/*
- *
- */
-void* APR_THREAD_FUNC SocketTransport::readLoop(apr_thread_t* thread, void* data)
-{
-    SocketTransport *transport = (SocketTransport*)data ;
-
-    cout << "Starting to read commands from ActiveMQ" << endl ;
-
-    while( !transport->closed )
-    {
-        p<BaseCommand> baseCommand = NULL ;
-
-        try
-        {
-            baseCommand = (p<BaseCommand>&)CommandMarshallerRegistry::readCommand(transport->reader) ;
-        }
-        catch( exception e )
-        {
-            // socket closed
-            break ;
-        }
-        if( typeid(baseCommand) == typeid(Response) )
-        {
-            p<Response>       response = (p<Response>&)baseCommand ;
-            p<FutureResponse> future = (p<FutureResponse>&)transport->requestMap[response->getCommandId()] ;
-
-            cout << "Received response: " << response->getCommandTypeAsString( response->getCommandType() )->c_str() << endl ;
-
-            if( future != NULL )
-            {
-                if( typeid(response) == typeid(ExceptionResponse) )
-                {
-                    p<ExceptionResponse> er  = (p<ExceptionResponse>&)response ;
-                    p<OpenWireException> owe = new BrokerException( er->getException() ) ;
-                    // TODO: Forward incoming exception
-                }
-                else
-                {
-                    future->setResponse(response) ;
-                }
-            }
-            else
-            {
-                cout << "Unknown response ID: " << response->getCommandId() << endl ;
-            }
-        }
-        else
-        {
-            // TODO: Forward incoming response
-        }
-    }
-    return NULL  ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include <iostream>
+#include <exception>
+#include <typeinfo>
+#include "transport/SocketTransport.hpp"
+
+using namespace std;
+using namespace apache::activemq::client::transport;
+
+
+// --- Constructors -------------------------------------------------
+
+/*
+ *
+ */
+SocketTransport::SocketTransport(const char* host, int port)
+{
+	// Initialize APR framework
+    init() ;
+
+    cout << "Opening socket to: " << host << " on port: " << port << endl ;
+
+    // Open socket
+    socket = connect(host, port) ;
+    writer = new SocketBinaryWriter(socket) ;
+    reader = new SocketBinaryReader(socket) ;
+}
+
+/*
+ *
+ */
+SocketTransport::~SocketTransport()
+{
+	// Destroy memory pools (including sub pool) and terminate APR
+	if( memoryPool != NULL )
+		apr_pool_destroy(memoryPool) ;
+
+	// Terminate APR framework
+	apr_terminate() ;
+}
+
+
+// --- Attribute methods --------------------------------------------
+
+
+// --- Operation methods --------------------------------------------
+
+/*
+ *
+ */
+void SocketTransport::oneway(p<ICommand> command)
+{
+    p<BaseCommand> baseCommand = (p<BaseCommand>&)command ;
+
+    // Set command id and that no response is required
+    baseCommand->setCommandId( getNextCommandId() ) ;
+    baseCommand->setResponseRequired(false) ;
+
+    send(command) ;
+}
+
+/*
+ *
+ */
+p<FutureResponse> SocketTransport::asyncRequest(p<ICommand> command)
+{
+    p<BaseCommand> baseCommand = (p<BaseCommand>&)command ;
+
+    // Set command id and that a response is required
+    baseCommand->setCommandId( getNextCommandId() ) ;
+    baseCommand->setResponseRequired(true) ;
+    send(command) ;
+
+    // Register a future response holder with the command id
+    p<FutureResponse> future = new FutureResponse() ;
+    requestMap[baseCommand->getCommandId()] = future ;
+
+    return future ;
+}
+
+/*
+ *
+ */
+p<Response> SocketTransport::request(p<ICommand> command)
+{
+    p<FutureResponse> future = asyncRequest(command) ;
+    return future->getResponse() ;
+}
+
+
+// --- Implementation methods ---------------------------------------
+
+/*
+ *
+ */
+void SocketTransport::init()
+{
+    apr_threadattr_t *attribs ;
+    apr_status_t     rc ;
+
+	// Initialize APR framework
+    rc = apr_initialize() ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to initialize APR framework.") ;
+   
+    // Create APR memory pool
+    rc = apr_pool_create(&memoryPool, NULL) ;
+    if( rc != APR_SUCCESS )
+	    throw exception("Failed to allocate APR memory pool.") ;
+
+    // Create transmission mutex
+    apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_UNNESTED, memoryPool) ;
+
+	// Create attached thread attribute so main thread can terminate it
+    apr_threadattr_create(&attribs, memoryPool) ;
+    apr_threadattr_detach_set(attribs, 0) ;
+
+    // Create and start the background read thread
+    apr_thread_create(&readThread, attribs, this->readLoop, this, memoryPool) ;
+}
+
+/*
+ *
+ */
+void SocketTransport::acquireLock()
+{
+    apr_thread_mutex_lock(mutex) ;
+}
+
+/*
+ *
+ */
+void SocketTransport::releaseLock()
+{
+    apr_thread_mutex_unlock(mutex) ;
+}
+
+/*
+ *
+ */
+void SocketTransport::send(p<ICommand> command)
+{
+    // Wait for lock and then transmit command
+    acquireLock() ;
+    CommandMarshallerRegistry::writeCommand(command, writer) ;
+    releaseLock() ;
+}
+
+/*
+ *
+ */
+long SocketTransport::getNextCommandId()
+{
+    long id ;
+
+    // Wait for lock and then fetch next command id
+    acquireLock() ;
+    id = ++nextCommandId ;
+    releaseLock() ;
+
+    return id ;
+}
+
+/*
+ *
+ */
+apr_socket_t* SocketTransport::connect(const char* host, int port)
+{
+    apr_socket_t* sock ;
+	apr_status_t   rc ;
+    
+	// Look up the remote address
+	rc = apr_sockaddr_info_get(&remote_sa, host, APR_UNSPEC, port, 0, memoryPool) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to lookup remote address") ;
+	
+	// Create socket
+	rc = apr_socket_create(&sock, remote_sa->sa.sin.sin_family, SOCK_STREAM, APR_PROTO_TCP, memoryPool) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to create socket") ;
+
+	// Connect socket
+    rc = apr_socket_connect(sock, remote_sa) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to connect socket") ;
+   
+    // Get socket info
+    rc = apr_socket_addr_get(&remote_sa, APR_REMOTE, sock) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to fetch remote socket address") ;
+    rc = apr_sockaddr_ip_get(&remote_ip, remote_sa) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to fetch remote IP address") ;
+    rc = apr_socket_addr_get(&local_sa, APR_LOCAL, sock) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to fetch local socket address") ;
+    rc = apr_sockaddr_ip_get(&local_ip, local_sa) ;
+    if( rc != APR_SUCCESS )
+        throw exception("Failed to fetch local IP address") ;
+   
+	return sock ;
+}
+
+/*
+ *
+ */
+void* APR_THREAD_FUNC SocketTransport::readLoop(apr_thread_t* thread, void* data)
+{
+    SocketTransport *transport = (SocketTransport*)data ;
+
+    cout << "Starting to read commands from ActiveMQ" << endl ;
+
+    while( !transport->closed )
+    {
+        p<BaseCommand> baseCommand = NULL ;
+
+        try
+        {
+            baseCommand = (p<BaseCommand>&)CommandMarshallerRegistry::readCommand(transport->reader) ;
+        }
+        catch( exception e )
+        {
+            // socket closed
+            break ;
+        }
+        if( typeid(baseCommand) == typeid(Response) )
+        {
+            p<Response>       response = (p<Response>&)baseCommand ;
+            p<FutureResponse> future = (p<FutureResponse>&)transport->requestMap[response->getCommandId()] ;
+
+            cout << "Received response: " << response->getCommandTypeAsString( response->getCommandType() )->c_str() << endl ;
+
+            if( future != NULL )
+            {
+                if( typeid(response) == typeid(ExceptionResponse) )
+                {
+                    p<ExceptionResponse> er  = (p<ExceptionResponse>&)response ;
+                    p<OpenWireException> owe = new BrokerException( er->getException() ) ;
+                    // TODO: Forward incoming exception
+                }
+                else
+                {
+                    future->setResponse(response) ;
+                }
+            }
+            else
+            {
+                cout << "Unknown response ID: " << response->getCommandId() << endl ;
+            }
+        }
+        else
+        {
+            // TODO: Forward incoming response
+        }
+    }
+    return NULL  ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.hpp Tue Feb 21 15:28:33 2006
@@ -1,105 +1,105 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef SocketTransport_hpp_
-#define SocketTransport_hpp_
-
-#include <map>
-//#include <string>
-
-#include <apr_general.h>
-#include <apr_pools.h>
-#include <apr_network_io.h>
-#include <apr_thread_proc.h>
-#include <apr_thread_mutex.h>
-
-#include "OpenWireException.hpp"
-#include "BrokerException.hpp"
-#include "FutureResponse.hpp"
-#include "command/ICommand.hpp"
-#include "command/BaseCommand.hpp"
-#include "command/Response.hpp"
-#include "command/ExceptionResponse.hpp"
-#include "io/SocketBinaryReader.hpp"
-#include "io/SocketBinaryWriter.hpp"
-#include "marshal/CommandMarshallerRegistry.hpp"
-#include "transport/ITransport.hpp"
-#include "util/SimpleMutex.hpp"
-#include "util/ifr/p"
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace transport
-      {
-        using namespace ifr ;
-        using namespace std;
-        using namespace apache::activemq::client;
-        using namespace apache::activemq::client::command;
-        using namespace apache::activemq::client::io;
-        using namespace apache::activemq::client::marshal;
-        using namespace apache::activemq::client::util;
-
-/*
- * An implementation of ITransport that uses sockets to communicate with
- * the broker.
- */
-class SocketTransport : public ITransport
-{
-private:
-    p<SocketBinaryReader>        reader ;
-    p<SocketBinaryWriter>        writer ;
-    apr_pool_t*                  memoryPool ;
-    apr_thread_mutex_t*          mutex ;
-    apr_socket_t*                socket ;
-    apr_sockaddr_t              *local_sa, *remote_sa ;
-    char                        *local_ip, *remote_ip ;
-    apr_thread_t*                readThread ;
-    map<int, p<FutureResponse> > requestMap ;
-    bool                         closed ;
-    long                         nextCommandId ;
-
-public:
-    SocketTransport(const char* host, int port) ;
-    virtual ~SocketTransport() ;
-
-    virtual void oneway(p<ICommand> command) ;
-    virtual p<FutureResponse> asyncRequest(p<ICommand> command) ;
-    virtual p<Response> request(p<ICommand> command) ;
-
-protected:
-    virtual void init() ;
-    virtual void send(p<ICommand> command) ;
-    virtual long getNextCommandId() ;
-    virtual apr_socket_t* connect(const char* host, int port) ;
-
-private:
-    virtual void acquireLock() ;
-    virtual void releaseLock() ;
-
-    static void* APR_THREAD_FUNC readLoop(apr_thread_t* thread, void *data) ;
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*SocketTransport_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef SocketTransport_hpp_
+#define SocketTransport_hpp_
+
+#include <map>
+//#include <string>
+
+#include <apr_general.h>
+#include <apr_pools.h>
+#include <apr_network_io.h>
+#include <apr_thread_proc.h>
+#include <apr_thread_mutex.h>
+
+#include "OpenWireException.hpp"
+#include "BrokerException.hpp"
+#include "FutureResponse.hpp"
+#include "command/ICommand.hpp"
+#include "command/BaseCommand.hpp"
+#include "command/Response.hpp"
+#include "command/ExceptionResponse.hpp"
+#include "io/SocketBinaryReader.hpp"
+#include "io/SocketBinaryWriter.hpp"
+#include "marshal/CommandMarshallerRegistry.hpp"
+#include "transport/ITransport.hpp"
+#include "util/SimpleMutex.hpp"
+#include "util/ifr/p"
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace transport
+      {
+        using namespace ifr ;
+        using namespace std;
+        using namespace apache::activemq::client;
+        using namespace apache::activemq::client::command;
+        using namespace apache::activemq::client::io;
+        using namespace apache::activemq::client::marshal;
+        using namespace apache::activemq::client::util;
+
+/*
+ * An implementation of ITransport that uses sockets to communicate with
+ * the broker.
+ */
+class SocketTransport : public ITransport
+{
+private:
+    p<SocketBinaryReader>        reader ;
+    p<SocketBinaryWriter>        writer ;
+    apr_pool_t*                  memoryPool ;
+    apr_thread_mutex_t*          mutex ;
+    apr_socket_t*                socket ;
+    apr_sockaddr_t              *local_sa, *remote_sa ;
+    char                        *local_ip, *remote_ip ;
+    apr_thread_t*                readThread ;
+    map<int, p<FutureResponse> > requestMap ;
+    bool                         closed ;
+    long                         nextCommandId ;
+
+public:
+    SocketTransport(const char* host, int port) ;
+    virtual ~SocketTransport() ;
+
+    virtual void oneway(p<ICommand> command) ;
+    virtual p<FutureResponse> asyncRequest(p<ICommand> command) ;
+    virtual p<Response> request(p<ICommand> command) ;
+
+protected:
+    virtual void init() ;
+    virtual void send(p<ICommand> command) ;
+    virtual long getNextCommandId() ;
+    virtual apr_socket_t* connect(const char* host, int port) ;
+
+private:
+    virtual void acquireLock() ;
+    virtual void releaseLock() ;
+
+    static void* APR_THREAD_FUNC readLoop(apr_thread_t* thread, void *data) ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*SocketTransport_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/transport/SocketTransport.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/util/Endian.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/util/Endian.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/util/Endian.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/util/Endian.cpp Tue Feb 21 15:28:33 2006
@@ -1,47 +1,47 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "util/Endian.hpp"
-
-#if APR_IS_BIGENDIAN
-  // Don't define
-#else
-
-float htonf( const float f )
-{
-    int i = htoni( *(int *)&f ) ;
-    return *(float *)&i ;
-}
-
-float ntohf( const float f )
-{
-    int i = ntohi( *(int *)&f ) ;
-    return *(float *)&i ;
-}
-
-double htond( const double d )
-{
-    long long l = htonl( *(long long *)&d ) ;
-    return *(double *)&l ;
-}
-
-double ntohd( const double d )
-{
-    long long l = ntohl( *(long long *)&d ) ;
-    return *(double *)&l ;
-}
-
-#endif
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "util/Endian.hpp"
+
+#if APR_IS_BIGENDIAN
+  // Don't define
+#else
+
+float htonf( const float f )
+{
+    int i = htoni( *(int *)&f ) ;
+    return *(float *)&i ;
+}
+
+float ntohf( const float f )
+{
+    int i = ntohi( *(int *)&f ) ;
+    return *(float *)&i ;
+}
+
+double htond( const double d )
+{
+    long long l = htonl( *(long long *)&d ) ;
+    return *(double *)&l ;
+}
+
+double ntohd( const double d )
+{
+    long long l = ntohl( *(long long *)&d ) ;
+    return *(double *)&l ;
+}
+
+#endif

Propchange: incubator/activemq/trunk/openwire-cpp/src/util/Endian.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/util/Endian.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/util/Endian.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/util/Endian.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/util/Endian.hpp Tue Feb 21 15:28:33 2006
@@ -1,70 +1,70 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef Endian_hpp_
-#define Endian_hpp_
-
-#include <apr.h>
-
-// Use these if the compiler does not support _intXX
-#ifdef NEEDS_INT_DEFINED
-#define _int16 short
-#define _int32 int
-#define _int64 long long
-#endif
-
-// Macros and helpers for endian conversion
-#if APR_IS_BIGENDIAN
-#define htons(x) x
-#define htoni(x) x
-#define htonl(x) x
-#define htonf(x) x
-#define htond(x) x
-#define ntohs(x) x
-#define ntohi(x) x
-#define ntohl(x) x
-#define ntohf(x) x
-#define ntohd(x) x
-#else
-#define htons(x) \
-	( x << 8  ) & 0xFF00 | \
-	( x >> 8  ) & 0x00FF
-#define htoni(x) \
-    ( x << 24 ) & 0xFF000000 | \
-	( x << 8  ) & 0x00FF0000 | \
-	( x >> 8  ) & 0x0000FF00 | \
-	( x >> 24 ) & 0x000000FF
-#define htonl(x) \
-    ( x << 56 ) & 0xFF00000000000000LL | \
-	( x << 40 ) & 0x00FF000000000000LL | \
-	( x << 24 ) & 0x0000FF0000000000LL | \
-	( x << 8  ) & 0x000000FF00000000LL | \
-    ( x >> 8  ) & 0x00000000FF000000LL | \
-	( x >> 24 ) & 0x0000000000FF0000LL | \
-	( x >> 40 ) & 0x000000000000FF00LL | \
-	( x >> 56 ) & 0x00000000000000FFLL
-#define ntohs  htons
-#define ntohi  htoni
-#define ntohl  htonl
-
-extern float htonf( const float f ) ;
-extern float ntohf( const float f ) ;
-extern double htond( const double d ) ;
-extern double ntohd( const double d ) ;
-
-#endif
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef Endian_hpp_
+#define Endian_hpp_
+
+#include <apr.h>
+
+// Use these if the compiler does not support _intXX
+#ifdef NEEDS_INT_DEFINED
+#define _int16 short
+#define _int32 int
+#define _int64 long long
+#endif
+
+// Macros and helpers for endian conversion
+#if APR_IS_BIGENDIAN
+#define htons(x) x
+#define htoni(x) x
+#define htonl(x) x
+#define htonf(x) x
+#define htond(x) x
+#define ntohs(x) x
+#define ntohi(x) x
+#define ntohl(x) x
+#define ntohf(x) x
+#define ntohd(x) x
+#else
+#define htons(x) \
+	( x << 8  ) & 0xFF00 | \
+	( x >> 8  ) & 0x00FF
+#define htoni(x) \
+    ( x << 24 ) & 0xFF000000 | \
+	( x << 8  ) & 0x00FF0000 | \
+	( x >> 8  ) & 0x0000FF00 | \
+	( x >> 24 ) & 0x000000FF
+#define htonl(x) \
+    ( x << 56 ) & 0xFF00000000000000LL | \
+	( x << 40 ) & 0x00FF000000000000LL | \
+	( x << 24 ) & 0x0000FF0000000000LL | \
+	( x << 8  ) & 0x000000FF00000000LL | \
+    ( x >> 8  ) & 0x00000000FF000000LL | \
+	( x >> 24 ) & 0x0000000000FF0000LL | \
+	( x >> 40 ) & 0x000000000000FF00LL | \
+	( x >> 56 ) & 0x00000000000000FFLL
+#define ntohs  htons
+#define ntohi  htoni
+#define ntohl  htonl
+
+extern float htonf( const float f ) ;
+extern float ntohf( const float f ) ;
+extern double htond( const double d ) ;
+extern double ntohd( const double d ) ;
+
+#endif
+
 #endif /*Endian_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/util/Endian.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/util/Guid.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/util/Guid.cpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/util/Guid.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/util/Guid.cpp Tue Feb 21 15:28:33 2006
@@ -1,97 +1,97 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "util/guid.hpp"
-
-using namespace apache::activemq::client::util;
-
-/*
- *
- */
-Guid::Guid()
-{
-    // no-op
-}
-
-/*
- *
- */
-Guid::~Guid()
-{
-    // no-op
-}
-
-/*
- * Creates a new UUID string.
- */
-unsigned char* Guid::getGuid()
-{
-    unsigned char* buffer = new unsigned char[16] ;
-
-#if defined(WIN32) || defined(__CYGWIN__)
-    GUID guid = GUID_NULL ;
-
-	// Create GUID
-    CoCreateGuid(&guid) ;
-    if( guid == GUID_NULL )
-    {
-        // TODO: exception
-        //cerr << "Failed to create an UUID" << endl ;
-        return NULL ;
-    }
-	// Store GUID in internal buffer
-    memcpy(buffer, &guid, 16) ;
-
-#else
-    uuid_t uuid ;
-
-	// Create UUID
-    uuid_generate(uuid) ;
-
-	// Store UUID in internal buffer
-	memcpy(buffer, uuid, 16) ;
-#endif
-
-    return buffer ;
-}
-
-/*
- *
- */
-p<string> Guid::getGuidString()
-{
-   unsigned char* buffer = NULL ;
-   char*          result = NULL ;
-   p<string>      guidStr ;
-
-   buffer = getGuid() ;
-   result = new char[36] ;
-
-	// Format into a string
-   sprintf(result, "%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\0",
-           buffer[0],  buffer[1],  buffer[2],  buffer[3],
-           buffer[4],  buffer[5],  buffer[6],  buffer[7],
-           buffer[8],  buffer[9],  buffer[10], buffer[11],
-           buffer[12], buffer[13], buffer[14], buffer[15]) ;
-
-   guidStr = new string(result) ;
-
-   // Clean up
-   delete result ;
-   delete buffer ;
-
-   return guidStr ;
-}
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "util/guid.hpp"
+
+using namespace apache::activemq::client::util;
+
+/*
+ *
+ */
+Guid::Guid()
+{
+    // no-op
+}
+
+/*
+ *
+ */
+Guid::~Guid()
+{
+    // no-op
+}
+
+/*
+ * Creates a new UUID string.
+ */
+unsigned char* Guid::getGuid()
+{
+    unsigned char* buffer = new unsigned char[16] ;
+
+#if defined(WIN32) || defined(__CYGWIN__)
+    GUID guid = GUID_NULL ;
+
+	// Create GUID
+    CoCreateGuid(&guid) ;
+    if( guid == GUID_NULL )
+    {
+        // TODO: exception
+        //cerr << "Failed to create an UUID" << endl ;
+        return NULL ;
+    }
+	// Store GUID in internal buffer
+    memcpy(buffer, &guid, 16) ;
+
+#else
+    uuid_t uuid ;
+
+	// Create UUID
+    uuid_generate(uuid) ;
+
+	// Store UUID in internal buffer
+	memcpy(buffer, uuid, 16) ;
+#endif
+
+    return buffer ;
+}
+
+/*
+ *
+ */
+p<string> Guid::getGuidString()
+{
+   unsigned char* buffer = NULL ;
+   char*          result = NULL ;
+   p<string>      guidStr ;
+
+   buffer = getGuid() ;
+   result = new char[36] ;
+
+	// Format into a string
+   sprintf(result, "%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x\0",
+           buffer[0],  buffer[1],  buffer[2],  buffer[3],
+           buffer[4],  buffer[5],  buffer[6],  buffer[7],
+           buffer[8],  buffer[9],  buffer[10], buffer[11],
+           buffer[12], buffer[13], buffer[14], buffer[15]) ;
+
+   guidStr = new string(result) ;
+
+   // Clean up
+   delete result ;
+   delete buffer ;
+
+   return guidStr ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/util/Guid.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/util/Guid.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/util/Guid.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/util/Guid.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/util/Guid.hpp Tue Feb 21 15:28:33 2006
@@ -1,68 +1,68 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef Guid_hpp_
-#define Guid_hpp_
-
-#include <string>
-#include <util/ifr/p>
-
-#if (defined(__unix__) || defined(unix)) && !defined(USG)
-#include <sys/param.h>
-#endif
-#include <stdio.h>
-#include <assert.h>
-#if defined(WIN32) || defined(__CYGWIN__)
-#include <objbase.h>
-#elif defined MACOSX
-#include "uuid.h"
-#else
-#include <uuid/uuid.h>
-#endif
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace util
-      {
-        using namespace std ;
-        using namespace ifr ;
-
-/*
- * Helper class that generates global unique identifiers.
- */
-class Guid
-{
-private:
-    Guid() ;
-
-public:
-    ~Guid() ;
-
-    static unsigned char* getGuid() ;
-    static p<string> getGuidString() ;
-} ;
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*Guid_hpp_*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef Guid_hpp_
+#define Guid_hpp_
+
+#include <string>
+#include <util/ifr/p>
+
+#if (defined(__unix__) || defined(unix)) && !defined(USG)
+#include <sys/param.h>
+#endif
+#include <stdio.h>
+#include <assert.h>
+#if defined(WIN32) || defined(__CYGWIN__)
+#include <objbase.h>
+#elif defined MACOSX
+#include "uuid.h"
+#else
+#include <uuid/uuid.h>
+#endif
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace util
+      {
+        using namespace std ;
+        using namespace ifr ;
+
+/*
+ * Helper class that generates global unique identifiers.
+ */
+class Guid
+{
+private:
+    Guid() ;
+
+public:
+    ~Guid() ;
+
+    static unsigned char* getGuid() ;
+    static p<string> getGuidString() ;
+} ;
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*Guid_hpp_*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/util/Guid.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/util/SimpleMutex.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/util/SimpleMutex.hpp?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/util/SimpleMutex.hpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/util/SimpleMutex.hpp Tue Feb 21 15:28:33 2006
@@ -1,123 +1,123 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#ifndef SIMPLE_MUTEX_HPP
-#define SIMPLE_MUTEX_HPP
-
-#if (defined(__unix__) || defined(unix) || defined(MACOSX)) && !defined(USG)
-#define unix
-#include <pthread.h>
-#endif
-#if defined(WIN32) || defined(__CYGWIN__)
-#if ( !defined(_WIN32_WINNT) || _WIN32_WINNT < 0x0400)
-#pragma message "Unsupported platform, Windows NT 4.0 or later required"
-#endif
-#include <windows.h>
-#endif
-#include <assert.h>
-
-namespace apache
-{
-  namespace activemq
-  {
-    namespace client
-    {
-      namespace util
-      {
-
-/*
- *
- */
-class SimpleMutex
-{
-private:
-#ifdef unix
-    pthread_mutex_t mutex ;
-#else
-    CRITICAL_SECTION  mutex ;
-#endif
-
-public:
-    SimpleMutex() ;
-    virtual ~SimpleMutex() ;
-
-    bool trylock() ;
-    void lock() ;
-    void unlock() ;
-} ;
-
-// Optimize all methods via inline code
-
-inline SimpleMutex::SimpleMutex()
-{
-#ifdef unix
-    pthread_mutexattr_t attr ;
-    pthread_mutexattr_init(&attr) ;
-    pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE) ;
-    pthread_mutex_init(&mutex, &attr) ;
-    pthread_mutexattr_destroy(&attr) ;
-#else
-    InitializeCriticalSection(&mutex) ;
-#endif
-}
-
-inline SimpleMutex::~SimpleMutex()
-{
-#ifdef unix
-    pthread_mutex_destroy(&mutex) ;
-#else
-    DeleteCriticalSection(&mutex) ;
-#endif
-}
-
-inline bool SimpleMutex::trylock()
-{
-#ifdef unix
-    int try_l = pthread_mutex_trylock(&mutex) ;
-    if (try_l == 0)
-        return true;
-    else
-        return false ;
-#else
-    return (TryEnterCriticalSection(&mutex) != 0) ;
-#endif
-}
-
-inline void SimpleMutex::lock()
-{
-#ifdef unix
-    pthread_mutex_lock(&mutex) ;
-#else
-    EnterCriticalSection(&mutex) ;
-#endif
-}
-
-inline void SimpleMutex::unlock()
-{
-#ifdef unix
-    pthread_mutex_unlock(&mutex) ;
-#else
-    LeaveCriticalSection(&mutex) ;
-#endif
-}
-
-/* namespace */
-      }
-    }
-  }
-}
-
-#endif /*SIMPLE_MUTEX_HPP*/
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#ifndef SIMPLE_MUTEX_HPP
+#define SIMPLE_MUTEX_HPP
+
+#if (defined(__unix__) || defined(unix) || defined(MACOSX)) && !defined(USG)
+#define unix
+#include <pthread.h>
+#endif
+#if defined(WIN32) || defined(__CYGWIN__)
+#if ( !defined(_WIN32_WINNT) || _WIN32_WINNT < 0x0400)
+#pragma message "Unsupported platform, Windows NT 4.0 or later required"
+#endif
+#include <windows.h>
+#endif
+#include <assert.h>
+
+namespace apache
+{
+  namespace activemq
+  {
+    namespace client
+    {
+      namespace util
+      {
+
+/*
+ *
+ */
+class SimpleMutex
+{
+private:
+#ifdef unix
+    pthread_mutex_t mutex ;
+#else
+    CRITICAL_SECTION  mutex ;
+#endif
+
+public:
+    SimpleMutex() ;
+    virtual ~SimpleMutex() ;
+
+    bool trylock() ;
+    void lock() ;
+    void unlock() ;
+} ;
+
+// Optimize all methods via inline code
+
+inline SimpleMutex::SimpleMutex()
+{
+#ifdef unix
+    pthread_mutexattr_t attr ;
+    pthread_mutexattr_init(&attr) ;
+    pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE) ;
+    pthread_mutex_init(&mutex, &attr) ;
+    pthread_mutexattr_destroy(&attr) ;
+#else
+    InitializeCriticalSection(&mutex) ;
+#endif
+}
+
+inline SimpleMutex::~SimpleMutex()
+{
+#ifdef unix
+    pthread_mutex_destroy(&mutex) ;
+#else
+    DeleteCriticalSection(&mutex) ;
+#endif
+}
+
+inline bool SimpleMutex::trylock()
+{
+#ifdef unix
+    int try_l = pthread_mutex_trylock(&mutex) ;
+    if (try_l == 0)
+        return true;
+    else
+        return false ;
+#else
+    return (TryEnterCriticalSection(&mutex) != 0) ;
+#endif
+}
+
+inline void SimpleMutex::lock()
+{
+#ifdef unix
+    pthread_mutex_lock(&mutex) ;
+#else
+    EnterCriticalSection(&mutex) ;
+#endif
+}
+
+inline void SimpleMutex::unlock()
+{
+#ifdef unix
+    pthread_mutex_unlock(&mutex) ;
+#else
+    LeaveCriticalSection(&mutex) ;
+#endif
+}
+
+/* namespace */
+      }
+    }
+  }
+}
+
+#endif /*SIMPLE_MUTEX_HPP*/

Propchange: incubator/activemq/trunk/openwire-cpp/src/util/SimpleMutex.hpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/AbstractPacket.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQ.csproj
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQ.csproj.user
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQDestination.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQTopic.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/BrokerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ConnectionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ConsumerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/DestinationFilter.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/IntResponseReceipt.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/MessageAck.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/MessageAcknowledge.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/PacketConstants.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ProducerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/Receipt.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ResponseReceipt.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/SessionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionConstants.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/WireFormatInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/BrokerException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQBytesMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQDestination.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMapMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQObjectMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQStreamMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTempQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTempTopic.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTextMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ActiveMQTopic.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/BaseCommand.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/BrokerId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/BrokerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ConnectionError.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ConnectionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ConnectionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ConsumerId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ConsumerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ControlCommand.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/DataArrayResponse.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/DataResponse.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/DestinationInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/DiscoveryEvent.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ExceptionResponse.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/FlushCommand.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/IntegerResponse.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/JournalQueueAck.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/JournalTopicAck.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/JournalTrace.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/JournalTransaction.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/KeepAliveInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/LocalTransactionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/Message.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/MessageAck.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/MessageDispatch.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/MessageId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ProducerId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ProducerInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/RemoveInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/RemoveSubscriptionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/Response.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/SessionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/SessionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/ShutdownInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/SubscriptionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/TransactionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/TransactionInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/WireFormatInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Commands/XATransactionId.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Connection.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionClosedException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConnectionFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ConsumerClosedException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/AbstractCommand.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/AbstractCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/BrokerError.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/Command.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/DataStructure.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/FutureResponse.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/ITransport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Core/SocketTransport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/DestinationFilter.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IConnection.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IConnectionFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IDestination.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IMessageConsumer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IMessageProducer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQBytesMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQDestinationMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQMapMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQObjectMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQQueueMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQStreamMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempDestinationMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempQueueMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTempTopicMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTextMessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ActiveMQTopicMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BaseCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/BrokerInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/CommandMarshallerRegistry.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionErrorMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConnectionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ConsumerInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ControlCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataArrayResponseMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DataResponseMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DestinationInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/DiscoveryEventMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ExceptionResponseMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/FlushCommandMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/IntegerResponseMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/JournalQueueAckMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/JournalTopicAckMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/JournalTraceMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/JournalTransactionMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/KeepAliveInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/LocalTransactionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/MessageAckMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/MessageDispatchMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/MessageIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/MessageMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ProducerIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ProducerInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/RemoveInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/RemoveSubscriptionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ResponseMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/SessionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/SessionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/ShutdownInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/SubscriptionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/TransactionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/TransactionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/WireFormatInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IO/XATransactionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/IQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ISession.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ITemporaryQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ITemporaryTopic.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ITextMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/ITopic.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/MessageConsumer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/MessageProducer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWire.Client.build
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWire.Client.build?rev=379623&r1=379622&r2=379623&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWire.Client.build (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWire.Client.build Tue Feb 21 15:28:33 2006
@@ -1,32 +1,32 @@
-<?xml version="1.0"?>
-<project name="OpenWire.Core" default="build">
-    <!--
-        Required properties:
-            * build.dir             - (path) root level to build to, assemblies will go in ${build.dir}/bin
-            * build.debug           - (true|false) debug build?
-            * current.build.defines - framework-specific build defines
-    -->
-    <target name="build">
-        <!-- build OpenWire.Core -->
-        <csc target="library" define="${current.build.defines}" warnaserror="true" debug="${build.debug}" output="${build.dir}/bin/${project.name}.dll" doc="${build.dir}/bin/${project.name}.xml">
-            <nowarn>
-                <!-- do not report warnings for missing XML comments -->
-                <warning number="1591" />
-                <!-- do not report deprecation warnings -->
-                <warning number="0618" />
-            </nowarn>
-            <sources failonempty="true">
-                <include name="**/*.cs" />
-                <!-- common assembly-level attributes -->
-                <include name="../CommonAssemblyInfo.cs" />               
-            </sources>                       
-            <resources basedir="Resources">
-                <include name="**/*" />
-            </resources>
-            <references>
-                <include name="${build.dir}/bin/log4net.dll"/>
-                <include name="System.Web.dll"/>
-            </references>
-        </csc>
-    </target>
-</project>
+<?xml version="1.0"?>
+<project name="OpenWire.Core" default="build">
+    <!--
+        Required properties:
+            * build.dir             - (path) root level to build to, assemblies will go in ${build.dir}/bin
+            * build.debug           - (true|false) debug build?
+            * current.build.defines - framework-specific build defines
+    -->
+    <target name="build">
+        <!-- build OpenWire.Core -->
+        <csc target="library" define="${current.build.defines}" warnaserror="true" debug="${build.debug}" output="${build.dir}/bin/${project.name}.dll" doc="${build.dir}/bin/${project.name}.xml">
+            <nowarn>
+                <!-- do not report warnings for missing XML comments -->
+                <warning number="1591" />
+                <!-- do not report deprecation warnings -->
+                <warning number="0618" />
+            </nowarn>
+            <sources failonempty="true">
+                <include name="**/*.cs" />
+                <!-- common assembly-level attributes -->
+                <include name="../CommonAssemblyInfo.cs" />               
+            </sources>                       
+            <resources basedir="Resources">
+                <include name="**/*" />
+            </resources>
+            <references>
+                <include name="${build.dir}/bin/log4net.dll"/>
+                <include name="System.Web.dll"/>
+            </references>
+        </csc>
+    </target>
+</project>

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWire.Client.build
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/OpenWireException.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Client/Session.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/ClientTest.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/OpenWire.Client.build
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-dotnet/tests/OpenWire.Client/TestSupport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/project.properties
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message