Sha256: 755d85cdd79d5f8343ae50de870d1375e2fead5f227dd0cafa902a12f9a2e169
Contents?: true
Size: 1.87 KB
Versions: 13
Compression:
Stored size: 1.87 KB
Contents
#include "socktest.h"
#ifndef LCB_NO_SSL
#include <lcbio/ssl.h>
using namespace LCBTest;
using std::string;
using std::vector;
class SSLTest : public SockTest {
protected:
void SetUp() {
lcbio_ssl_global_init();
lcb_error_t errp = LCB_SUCCESS;
// Initialize the SSL stuff
SockTest::SetUp();
loop->settings->sslopts = LCB_SSL_ENABLED|LCB_SSL_NOVERIFY;
loop->settings->ssl_ctx = lcbio_ssl_new(NULL, 1, &errp, loop->settings);
loop->server->factory = TestServer::sslSocketFactory;
EXPECT_FALSE(loop->settings->ssl_ctx == NULL) << lcb_strerror(NULL, errp);
}
void TearDown() {
lcbio_ssl_free(loop->settings->ssl_ctx);
loop->settings->ssl_ctx = NULL;
SockTest::TearDown();
}
};
TEST_F(SSLTest, testBasic)
{
// Copy/pasted from SockConnTest::testBasic
ESocket sock;
// We can connect
loop->connect(&sock);
ASSERT_FALSE(sock.sock == NULL);
ASSERT_TRUE(sock.creq.u.cs == NULL);
ASSERT_EQ(1, sock.sock->refcount);
// We can send data
string sendStr("Hello World");
RecvFuture rf(sendStr.size());
FutureBreakCondition wbc(&rf);
sock.conn->setRecv(&rf);
sock.put(sendStr);
sock.schedule();
loop->setBreakCondition(&wbc);
loop->start();
rf.wait();
ASSERT_TRUE(rf.isOk());
ASSERT_EQ(rf.getString(), sendStr);
// We can receive data
string recvStr("Goodbye World!");
SendFuture sf(recvStr);
ReadBreakCondition rbc(&sock, recvStr.size());
sock.conn->setSend(&sf);
sock.reqrd(recvStr.size());
sock.schedule();
loop->setBreakCondition(&rbc);
loop->start();
sf.wait();
ASSERT_TRUE(sf.isOk());
ASSERT_EQ(sock.getReceived(), recvStr);
// Clean it all up
sock.close();
}
#else
class SSLTest : public ::testing::Test {};
TEST_F(SSLTest, DISABLED_testBasic)
{
EXPECT_FALSE(true);
}
#endif
Version data entries
13 entries across 13 versions & 1 rubygems