From f646350b5e59ccf49f1253bd55f98d062769f2ee Mon Sep 17 00:00:00 2001 From: Andrew Stitcher Date: Tue, 22 May 2007 15:18:08 +0000 Subject: * Split apart platform (threading etc.) from network io you can now use a posix platform implementation by configuring --disable-apr-platform * Changed Time classes to distinguish between absolute times (AbsTime) and durations (Duration). This should avoid bugs caused by confusing the two types of time. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@540608 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp') diff --git a/cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp b/cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp index 2676985cc6..d5a2c238d9 100644 --- a/cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp +++ b/cpp/src/qpid/sys/posix/EventChannelAcceptor.cpp @@ -51,9 +51,9 @@ class EventChannelAcceptor : public Acceptor { int16_t port_, int backlog, int nThreads, bool trace_ ); - int getPort() const; + uint16_t getPort() const; - void run(ConnectionInputHandlerFactory& factory); + void run(ConnectionInputHandlerFactory* factory); void shutdown(); @@ -96,17 +96,17 @@ EventChannelAcceptor::EventChannelAcceptor( threads(EventChannelThreads::create(EventChannel::create(), nThreads)) { } -int EventChannelAcceptor::getPort() const { +uint16_t EventChannelAcceptor::getPort() const { return port; // Immutable no need for lock. } -void EventChannelAcceptor::run(ConnectionInputHandlerFactory& f) { +void EventChannelAcceptor::run(ConnectionInputHandlerFactory* f) { { Mutex::ScopedLock l(lock); if (!isRunning && !isShutdown) { isRunning = true; - factory = &f; - threads->post(acceptEvent); + factory = f; + threads->postEvent(acceptEvent); } } threads->join(); // Wait for shutdown. @@ -143,7 +143,7 @@ void EventChannelAcceptor::accept() int fd = acceptEvent.getAcceptedDesscriptor(); connections.push_back( new EventChannelConnection(threads, *factory, fd, fd, isTrace)); - threads->post(acceptEvent); // Keep accepting. + threads->postEvent(acceptEvent); // Keep accepting. } }} // namespace qpid::sys -- cgit v1.2.1