#if wxUSE_SOCKETS
#include "wx/socket.h"
+#include "wx/url.h"
+#include "wx/sstream.h"
#include "wx/evtloop.h"
#include <memory>
SocketTestCase() { }
private:
+ // we need to repeat the tests twice as the sockets behave differently when
+ // there is an active event loop and without it
+ #define ALL_SOCKET_TESTS() \
+ CPPUNIT_TEST( BlockingConnect ); \
+ CPPUNIT_TEST( NonblockingConnect ); \
+ CPPUNIT_TEST( ReadNormal ); \
+ CPPUNIT_TEST( ReadBlock ); \
+ CPPUNIT_TEST( ReadNowait ); \
+ CPPUNIT_TEST( ReadWaitall ); \
+ CPPUNIT_TEST( UrlTest )
+
CPPUNIT_TEST_SUITE( SocketTestCase );
- CPPUNIT_TEST( BlockingConnect );
- CPPUNIT_TEST( NonblockingConnect );
- CPPUNIT_TEST( ReadNormal );
- CPPUNIT_TEST( ReadBlock );
- CPPUNIT_TEST( ReadNowait );
- CPPUNIT_TEST( ReadWaitall );
+ ALL_SOCKET_TESTS();
+ CPPUNIT_TEST( PseudoTest_SetUseEventLoop );
+ ALL_SOCKET_TESTS();
CPPUNIT_TEST_SUITE_END();
+ // helper event loop class which sets itself as active only if we pass it
+ // true in ctor
+ class SocketTestEventLoop : public wxEventLoop
+ {
+ public:
+ SocketTestEventLoop(bool useLoop)
+ {
+ m_useLoop = useLoop;
+ if ( useLoop )
+ SetActive(this);
+ }
+
+ virtual ~SocketTestEventLoop()
+ {
+ if ( m_useLoop )
+ SetActive(NULL);
+ }
+
+ private:
+ bool m_useLoop;
+ };
+
// get the address to connect to, if NULL is returned it means that the
// test is disabled and shouldn't run at all
wxSockAddressPtr GetServer() const;
// disabled
wxSocketClientPtr GetHTTPSocket(int flags = wxSOCKET_NONE) const;
+ void PseudoTest_SetUseEventLoop() { ms_useLoop = true; }
+
void BlockingConnect();
void NonblockingConnect();
void ReadNormal();
void ReadNowait();
void ReadWaitall();
+ void UrlTest();
+
+ static bool ms_useLoop;
+
DECLARE_NO_COPY_CLASS(SocketTestCase)
};
+bool SocketTestCase::ms_useLoop = false;
+
CPPUNIT_TEST_SUITE_REGISTRATION( SocketTestCase );
CPPUNIT_TEST_SUITE_NAMED_REGISTRATION( SocketTestCase, "SocketTestCase" );
if ( !addr.get() )
return;
- wxEventLoopGuarantor loop;
+ SocketTestEventLoop loop(ms_useLoop);
wxSocketClient sock;
sock.Connect(*addr, false);
void SocketTestCase::ReadNormal()
{
- wxEventLoopGuarantor loop;
+ SocketTestEventLoop loop(ms_useLoop);
wxSocketClientPtr sock(GetHTTPSocket());
if ( !sock.get() )
void SocketTestCase::ReadWaitall()
{
- wxEventLoopGuarantor loop;
+ SocketTestEventLoop loop(ms_useLoop);
wxSocketClientPtr sock(GetHTTPSocket(wxSOCKET_WAITALL));
if ( !sock.get() )
CPPUNIT_ASSERT_EQUAL( WXSIZEOF(buf), sock->LastCount() );
}
+void SocketTestCase::UrlTest()
+{
+ if ( gs_serverHost.empty() )
+ return;
+
+ SocketTestEventLoop loop(ms_useLoop);
+
+ wxURL url("http://" + gs_serverHost);
+
+ const std::auto_ptr<wxInputStream> in(url.GetInputStream());
+ CPPUNIT_ASSERT( in.get() );
+
+ wxStringOutputStream out;
+ CPPUNIT_ASSERT_EQUAL( wxSTREAM_EOF, in->Read(out).GetLastError() );
+}
+
#endif // wxUSE_SOCKETS