diff options
Diffstat (limited to 'protocols/ace/RMCast/Socket.cpp')
| -rw-r--r-- | protocols/ace/RMCast/Socket.cpp | 217 |
1 files changed, 0 insertions, 217 deletions
diff --git a/protocols/ace/RMCast/Socket.cpp b/protocols/ace/RMCast/Socket.cpp deleted file mode 100644 index 578897f6761..00000000000 --- a/protocols/ace/RMCast/Socket.cpp +++ /dev/null @@ -1,217 +0,0 @@ -// file : ace/RMCast/Socket.cpp -// author : Boris Kolpackov <boris@kolpackov.net> -// cvs-id : $Id$ - -#include "ace/OS_Memory.h" -#include "ace/OS_NS_string.h" - -#include "ace/Unbounded_Queue.h" - -#include "Stack.h" -#include "Protocol.h" -#include "Bits.h" - -#include "Link.h" -#include "Simulator.h" -#include "Retransmit.h" -#include "Acknowledge.h" - - -#include "Socket.h" - -namespace ACE_RMCast -{ - class Socket_Impl : protected Element - { - public: - ~Socket_Impl (); - - Socket_Impl (Address const& a, bool loop); - - public: - void - send_ (void const* buf, size_t s); - - size_t - recv_ (void* buf, size_t s); - - size_t - size_ (); - - private: - virtual void - recv (Message_ptr m); - - private: - bool loop_; - - u64 sn_; //@@ lock? - - Mutex mutex_; - Condition cond_; - - ACE_Unbounded_Queue<Message_ptr> queue_; - - ACE_Auto_Ptr<Acknowledge> acknowledge_; - ACE_Auto_Ptr<Retransmit> retransmit_; - ACE_Auto_Ptr<Simulator> simulator_; - ACE_Auto_Ptr<Link> link_; - }; - - - Socket_Impl:: - Socket_Impl (Address const& a, bool loop) - : loop_ (loop), sn_ (1), cond_ (mutex_) - { - acknowledge_.reset (new Acknowledge ()); - retransmit_.reset (new Retransmit ()); - simulator_.reset (new Simulator ()); - link_.reset (new Link (a)); - - // Start IN stack from top to bottom. - // - in_start (0); - acknowledge_->in_start (this); - retransmit_->in_start (acknowledge_.get ()); - simulator_->in_start (retransmit_.get ()); - link_->in_start (simulator_.get ()); - - // Start OUT stack from bottom up. - // - link_->out_start (0); - simulator_->out_start (link_.get ()); - retransmit_->out_start (simulator_.get ()); - acknowledge_->out_start (retransmit_.get ()); - out_start (acknowledge_.get ()); - } - - Socket_Impl:: - ~Socket_Impl () - { - // Stop OUT stack from top to bottom. - // - out_stop (); - acknowledge_->out_stop (); - retransmit_->out_stop (); - simulator_->out_stop (); - link_->out_stop (); - - // Stop IN stack from bottom up. - // - link_->in_stop (); - simulator_->in_stop (); - retransmit_->in_stop (); - acknowledge_->in_stop (); - in_stop (); - } - - - void Socket_Impl:: - send_ (void const* buf, size_t s) - { - Message_ptr m (new Message); - - m->add (Profile_ptr (new SN (sn_++))); - m->add (Profile_ptr (new Data (buf, s))); - - // Qualification is for VC6 and VxWorks. - // - Element::send (m); - } - - size_t Socket_Impl:: - recv_ (void* buf, size_t s) - { - Lock l (mutex_); - - while (queue_.is_empty ()) cond_.wait (); - - Message_ptr m; - if (queue_.dequeue_head (m) == -1) abort (); - - Data const* d = static_cast<Data const*>(m->find (Data::id)); - - size_t r (d->size () < s ? d->size () : s); - - ACE_OS::memcpy (buf, d->buf (), r); - - return r; - } - - size_t Socket_Impl:: - size_ () - { - Lock l (mutex_); - - while (queue_.is_empty ()) cond_.wait (); - - // I can't get the head of the queue without actually dequeuing - // the element. - // - Message_ptr m; - if (queue_.dequeue_head (m) == -1) abort (); - if (queue_.enqueue_head (m) == -1) abort (); - - Data const* d = static_cast<Data const*>(m->find (Data::id)); - - return d->size (); - } - - - void Socket_Impl:: - recv (Message_ptr m) - { - if (m->find (Data::id) != 0) - { - if (!loop_) - { - Address to (static_cast<To const*> (m->find (To::id))->address ()); - - Address from ( - static_cast<From const*> (m->find (From::id))->address ()); - - if (to == from) return; - } - - Lock l (mutex_); - - bool signal (queue_.is_empty ()); - - queue_.enqueue_tail (m); - - if (signal) cond_.signal (); - } - } - - // Socket - // - // - Socket:: - ~Socket () - { - } - - Socket:: - Socket (Address const& a, bool loop) - : impl_ (new Socket_Impl (a, loop)) - { - } - - void Socket:: - send (void const* buf, size_t s) - { - impl_->send_ (buf, s); - } - - size_t Socket:: - recv (void* buf, size_t s) - { - return impl_->recv_ (buf, s); - } - - size_t Socket:: - size () - { - return impl_->size_ (); - } -} |