kernel/object/process_dispatcher.cpp

36 #include <fbl/alloc_checker.h>
37 #include <fbl/auto_lock.h>
58     fbl::RefPtr<JobDispatcher> job, fbl::StringPiece name, uint32_t flags,
59     fbl::RefPtr<Dispatcher>* dispatcher, zx_rights_t* rights,
60     fbl::RefPtr<VmAddressRegionDispatcher>* root_vmar_disp,
62     fbl::AllocChecker ac;
63     fbl::RefPtr<ProcessDispatcher> process =
64         fbl::AdoptRef(new (&ac) ProcessDispatcher(job, name, flags));
75     fbl::RefPtr<VmAddressRegion> vmar(process->aspace()->RootVmar());
78     fbl::RefPtr<Dispatcher> new_vmar_dispatcher;
88     *dispatcher = fbl::move(process);
95 ProcessDispatcher::ProcessDispatcher(fbl::RefPtr<JobDispatcher> job,
96                                      fbl::StringPiece name,
98   : job_(fbl::move(job)), policy_(job_->GetPolicy()),
133         Guard<fbl::Mutex> guard{get_lock()};
155     Guard<fbl::Mutex> guard{get_lock()};
177         Guard<fbl::Mutex> guard{get_lock()};
206         Guard<fbl::Mutex> guard{get_lock()};
246     Guard<fbl::Mutex> guard{get_lock()};
280         Guard<fbl::Mutex> guard{get_lock()};
303     Guard<fbl::Mutex> guard{get_lock()};
307 fbl::RefPtr<JobDispatcher> ProcessDispatcher::job() {
344     fbl::DoublyLinkedList<Handle*> to_clean;
346         Guard<fbl::Mutex> guard{&handle_table_lock_};
413     Guard<fbl::Mutex> guard{&handle_table_lock_};
414     AddHandleLocked(fbl::move(handle));
423     Guard<fbl::Mutex> guard{&handle_table_lock_};
447         auto chunk_size = fbl::min<size_t>(num_handles - offset, kMaxMessageHandles);
457             Guard<fbl::Mutex> guard{handle_table_lock()};
474     Guard<fbl::Mutex> guard{&handle_table_lock_};
482                                                      fbl::RefPtr<Dispatcher>* dispatcher,
484     Guard<fbl::Mutex> guard{&handle_table_lock_};
497                                                                fbl::RefPtr<Dispatcher>* dispatcher_out,
499     Guard<fbl::Mutex> guard{&handle_table_lock_};
519         Guard<fbl::Mutex> guard{get_lock()};
544     Guard<fbl::Mutex> guard{get_lock()};
563     Guard<fbl::Mutex> guard{get_lock()};
573     Guard<fbl::Mutex> guard{get_lock()};
596 zx_status_t ProcessDispatcher::GetThreads(fbl::Array<zx_koid_t>* out_threads) {
597     Guard<fbl::Mutex> guard{get_lock()};
599     fbl::Array<zx_koid_t> threads;
600     fbl::AllocChecker ac;
610     *out_threads = fbl::move(threads);
614 zx_status_t ProcessDispatcher::SetExceptionPort(fbl::RefPtr<ExceptionPort> eport) {
631     Guard<fbl::Mutex> guard{get_lock()};
649     fbl::RefPtr<ExceptionPort> eport;
655         Guard<fbl::Mutex> guard{get_lock()};
692 fbl::RefPtr<ExceptionPort> ProcessDispatcher::exception_port() {
693     Guard<fbl::Mutex> guard{get_lock()};
697 fbl::RefPtr<ExceptionPort> ProcessDispatcher::debugger_exception_port() {
698     Guard<fbl::Mutex> guard{get_lock()};
703         const fbl::RefPtr<ExceptionPort>& eport) {
704     Guard<fbl::Mutex> guard{get_lock()};
713     Guard<fbl::Mutex> guard{get_lock()};
720     Guard<fbl::Mutex> guard{get_lock()};
733     fbl::RefPtr<ProcessDispatcher> get_pd() { return pd_; }
738             pd_ = fbl::WrapRefPtr(process);
747     fbl::RefPtr<ProcessDispatcher> pd_ = nullptr;
751 fbl::RefPtr<ProcessDispatcher> ProcessDispatcher::LookupProcessById(zx_koid_t koid) {
757 fbl::RefPtr<ThreadDispatcher> ProcessDispatcher::LookupThreadById(zx_koid_t koid) {
759     Guard<fbl::Mutex> guard{get_lock()};
762     return fbl::WrapRefPtr(iter.CopyPointer());
766     Guard<fbl::Mutex> guard{get_lock()};
773     Guard<fbl::Mutex> guard{get_lock()};
793     Guard<fbl::Mutex> guard{get_lock()};
813     Guard<fbl::Mutex> guard{&handle_table_lock_};
818     Guard<fbl::Mutex> guard{&handle_table_lock_};