* 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

1 files changed, 7 insertions, 7 deletions

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