You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/08/28 15:44:56 UTC
svn commit: r1621136 - in /qpid/branches/0.30/qpid: ./ cpp/src/
cpp/src/qpid/client/SslConnector.cpp cpp/src/qpid/client/ssl.h
cpp/src/qpid/messaging/amqp/SslTransport.cpp cpp/src/tests/
cpp/src/tests/ssl_test
Author: gsim
Date: Thu Aug 28 13:44:55 2014
New Revision: 1621136
URL: http://svn.apache.org/r1621136
Log:
ensure ssl is initialised for 1.0 client connections; merged from trunk r1620948
Added:
qpid/branches/0.30/qpid/cpp/src/qpid/client/ssl.h
- copied unchanged from r1620948, qpid/trunk/qpid/cpp/src/qpid/client/ssl.h
Modified:
qpid/branches/0.30/qpid/ (props changed)
qpid/branches/0.30/qpid/cpp/src/ (props changed)
qpid/branches/0.30/qpid/cpp/src/qpid/client/SslConnector.cpp
qpid/branches/0.30/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp
qpid/branches/0.30/qpid/cpp/src/tests/ (props changed)
qpid/branches/0.30/qpid/cpp/src/tests/ssl_test
Propchange: qpid/branches/0.30/qpid/
------------------------------------------------------------------------------
Merged /qpid/trunk/qpid:r1620948
Propchange: qpid/branches/0.30/qpid/cpp/src/
------------------------------------------------------------------------------
Merged /qpid/trunk/qpid/cpp/src:r1620948
Modified: qpid/branches/0.30/qpid/cpp/src/qpid/client/SslConnector.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/0.30/qpid/cpp/src/qpid/client/SslConnector.cpp?rev=1621136&r1=1621135&r2=1621136&view=diff
==============================================================================
--- qpid/branches/0.30/qpid/cpp/src/qpid/client/SslConnector.cpp (original)
+++ qpid/branches/0.30/qpid/cpp/src/qpid/client/SslConnector.cpp Thu Aug 28 13:44:55 2014
@@ -161,6 +161,16 @@ namespace {
}
}
+void initialiseSSL()
+{
+ init.checkInitialised();
+}
+
+void shutdownSSL()
+{
+ if (StaticInit::initialised) shutdownNSS();
+}
+
SslConnector::SslConnector(Poller::shared_ptr p,
ProtocolVersion ver,
const ConnectionSettings& settings,
Modified: qpid/branches/0.30/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/0.30/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp?rev=1621136&r1=1621135&r2=1621136&view=diff
==============================================================================
--- qpid/branches/0.30/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp (original)
+++ qpid/branches/0.30/qpid/cpp/src/qpid/messaging/amqp/SslTransport.cpp Thu Aug 28 13:44:55 2014
@@ -25,6 +25,7 @@
#include "qpid/sys/AsynchIO.h"
#include "qpid/sys/ConnectionCodec.h"
#include "qpid/sys/Poller.h"
+#include "qpid/client/ssl.h"
#include "qpid/log/Statement.h"
#include <boost/bind.hpp>
#include <boost/format.hpp>
@@ -40,6 +41,7 @@ namespace amqp {
namespace {
Transport* create(TransportContext& c, Poller::shared_ptr p)
{
+ qpid::client::initialiseSSL();
return new SslTransport(c, p);
}
@@ -49,6 +51,11 @@ struct StaticInit
{
Transport::add("ssl", &create);
};
+
+ ~StaticInit()
+ {
+ qpid::client::shutdownSSL();
+ }
} init;
}
Propchange: qpid/branches/0.30/qpid/cpp/src/tests/
------------------------------------------------------------------------------
Merged /qpid/trunk/qpid/cpp/src/tests:r1620948
Modified: qpid/branches/0.30/qpid/cpp/src/tests/ssl_test
URL: http://svn.apache.org/viewvc/qpid/branches/0.30/qpid/cpp/src/tests/ssl_test?rev=1621136&r1=1621135&r2=1621136&view=diff
==============================================================================
--- qpid/branches/0.30/qpid/cpp/src/tests/ssl_test (original)
+++ qpid/branches/0.30/qpid/cpp/src/tests/ssl_test Thu Aug 28 13:44:55 2014
@@ -35,6 +35,10 @@ OTHER_CA_PEM_FILE=${TEST_CERT_DIR}/other
PY_PING_BROKER=${QPID_TEST_SRC_DIR}/ping_broker
COUNT=10
+if [[ -a $AMQP_LIB ]] ; then
+ MODULES="--load-module $AMQP_LIB"
+fi
+
trap cleanup EXIT
error() { echo $*; exit 1; }
@@ -135,7 +139,7 @@ cleanup() {
}
start_ssl_broker() {
- start_brokers 1 "--transport ssl --ssl-port 0 --require-encryption --auth no"
+ start_brokers 1 "--transport ssl --ssl-port 0 --require-encryption --auth no $MODULES"
}
start_ssl_mux_broker() {
@@ -146,7 +150,7 @@ start_ssl_mux_broker() {
sasl_config_dir=$QPID_TEST_EXEC_DIR/sasl_config
start_authenticating_broker() {
- start_brokers 1 "--transport ssl --ssl-port 0 --require-encryption --ssl-sasl-no-dict --ssl-require-client-authentication --auth yes --sasl-config=${sasl_config_dir}"
+ start_brokers 1 "--transport ssl --ssl-port 0 --require-encryption --ssl-sasl-no-dict --ssl-require-client-authentication --auth yes --sasl-config=${sasl_config_dir} $MODULES"
}
ssl_cluster_broker() { # $1 = port
@@ -184,6 +188,13 @@ URL=amqp:ssl:$TEST_HOSTNAME:$PORT
MSG=`./qpid-receive -b $URL -a "foo;{create:always}" --messages 1`
test "$MSG" = "hello" || { echo "receive failed '$MSG' != 'hello'"; exit 1; }
+if [[ -a $AMQP_LIB ]] ; then
+ echo "Testing ssl over AMQP 1.0"
+ ./qpid-send --connection-options '{protocol:amqp1.0}' -b $URL --content-string=hello -a "foo;{create:always}"
+ MSG=`./qpid-receive --connection-options '{protocol:amqp1.0}' -b $URL -a "foo;{create:always}" --messages 1`
+ test "$MSG" = "hello" || { echo "receive failed for AMQP 1.0 '$MSG' != 'hello'"; exit 1; }
+fi
+
## Test connection with a combination of URL and connection options (in messaging API)
URL=$TEST_HOSTNAME:$PORT
./qpid-send -b $URL --connection-options '{transport:ssl,heartbeat:2}' --content-string='hello again' -a "foo;{create:always}"
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org