kernel/object/socket_dispatcher.cpp

24 #include <fbl/alloc_checker.h>
25 #include <fbl/auto_lock.h>
31                                      fbl::RefPtr<Dispatcher>* dispatcher0,
32                                      fbl::RefPtr<Dispatcher>* dispatcher1,
39     fbl::AllocChecker ac;
46     fbl::unique_ptr<ControlMsg> control0;
47     fbl::unique_ptr<ControlMsg> control1;
62     auto holder0 = fbl::AdoptRef(new (&ac) PeerHolder<SocketDispatcher>());
67     auto socket0 = fbl::AdoptRef(new (&ac) SocketDispatcher(fbl::move(holder0), starting_signals,
68                                                             flags, fbl::move(control0)));
72     auto socket1 = fbl::AdoptRef(new (&ac) SocketDispatcher(fbl::move(holder1), starting_signals,
73                                                             flags, fbl::move(control1)));
81     *dispatcher0 = fbl::move(socket0);
82     *dispatcher1 = fbl::move(socket1);
86 SocketDispatcher::SocketDispatcher(fbl::RefPtr<PeerHolder<SocketDispatcher>> holder,
88                                    fbl::unique_ptr<ControlMsg> control_msg)
89     : PeeredDispatcher(fbl::move(holder), starting_signals),
91       control_msg_(fbl::move(control_msg)),
103 void SocketDispatcher::Init(fbl::RefPtr<SocketDispatcher> other) TA_NO_THREAD_SAFETY_ANALYSIS {
104     peer_ = fbl::move(other);
132     Guard<fbl::Mutex> guard{get_lock()};
197     Guard<fbl::Mutex> guard{get_lock()};
228     Guard<fbl::Mutex> guard{get_lock()};
310     Guard<fbl::Mutex> guard{get_lock()};
376     Guard<fbl::Mutex> guard{get_lock()};
398     Guard<fbl::Mutex> guard{get_lock()};
413     Guard<fbl::Mutex> guard{get_lock()};
417     return peer_->ShareSelfLocked(fbl::move(h));
426     accept_queue_ = fbl::move(h);
441     Guard<fbl::Mutex> guard{get_lock()};
446     *h = fbl::move(accept_queue_);
457     Guard<fbl::Mutex> guard{get_lock()};
463     Guard<fbl::Mutex> guard{get_lock()};
474     Guard<fbl::Mutex> guard{get_lock()};
480     Guard<fbl::Mutex> guard{get_lock()};
486     Guard<fbl::Mutex> guard{get_lock()};
498     Guard<fbl::Mutex> guard{get_lock()};
504     Guard<fbl::Mutex> guard{get_lock()};
510     Guard<fbl::Mutex> guard{get_lock()};
527     Guard<fbl::Mutex> guard{get_lock()};