///////////////////////////////////////////////////////////////////////////// // Name: tests/benchmarks/ipcclient.cpp // Purpose: wxIPC client side benchmarks // Author: Vadim Zeitlin // Created: 2008-10-13 // RCS-ID: $Id$ // Copyright: (c) 2008 Vadim Zeitlin // Licence: wxWindows license ///////////////////////////////////////////////////////////////////////////// #include "bench.h" #include "wx/evtloop.h" #include "wx/ipc.h" #include "../../samples/ipc/ipcsetup.h" namespace { class PokeAdviseConn : public wxConnection { public: PokeAdviseConn() { m_gotAdvised = false; } bool GotAdvised() { if ( !m_gotAdvised ) return false; m_gotAdvised = false; return true; } const wxString& GetItem() const { return m_item; } virtual bool OnAdvise(const wxString& topic, const wxString& item, const void *data, size_t size, wxIPCFormat format) { m_gotAdvised = true; if ( topic != IPC_BENCHMARK_TOPIC || item != IPC_BENCHMARK_ITEM || !IsTextFormat(format) ) { m_item = "ERROR"; return false; } m_item = GetTextFromData(data, size, format); return true; } private: wxString m_item; bool m_gotAdvised; DECLARE_NO_COPY_CLASS(PokeAdviseConn) }; class PokeAdviseClient : public wxClient { public: // provide a convenient helper taking care of connecting to the right // server/service/topic and returning the connection of the derived type // (or NULL if we failed to connect) PokeAdviseConn *Connect() { wxString host = Bench::GetStringParameter(); if ( host.empty() ) host = IPC_HOST; wxString service; int port = Bench::GetNumericParameter(); if ( !port ) service = IPC_SERVICE; else service.Printf("%d", port); return static_cast( MakeConnection(host, service, IPC_BENCHMARK_TOPIC)); } // override base class virtual to use a custom connection class virtual wxConnectionBase *OnMakeConnection() { return new PokeAdviseConn; } }; class PokeAdvisePersistentConnection { public: PokeAdvisePersistentConnection() { m_client = new PokeAdviseClient; m_conn = m_client->Connect(); if ( m_conn ) m_conn->StartAdvise(IPC_BENCHMARK_ITEM); } ~PokeAdvisePersistentConnection() { if ( m_conn ) { m_conn->StopAdvise(IPC_BENCHMARK_ITEM); m_conn->Disconnect(); } delete m_client; } PokeAdviseConn *Get() const { return m_conn; } private: PokeAdviseClient *m_client; PokeAdviseConn *m_conn; bool m_initDone; DECLARE_NO_COPY_CLASS(PokeAdvisePersistentConnection) }; PokeAdvisePersistentConnection *theConnection = NULL; bool ConnInit() { theConnection = new PokeAdvisePersistentConnection; if ( !theConnection->Get() ) { delete theConnection; theConnection = NULL; return false; } return true; } void ConnDone() { delete theConnection; } } // anonymous namespace BENCHMARK_FUNC_WITH_INIT(IPCPokeAdvise, ConnInit, ConnDone) { wxEventLoop loop; PokeAdviseConn * const conn = theConnection->Get(); const wxString s(1024, '@'); if ( !conn->Poke(IPC_BENCHMARK_ITEM, s) ) return false; while ( !conn->GotAdvised() ) loop.Dispatch(); if ( conn->GetItem() != s ) return false; return true; }