Get access to EventBaseManager object

Summary: as title

Test Plan: run unit tests

Reviewed By: yfeldblum@fb.com

Subscribers: ming, fugalh, folly-diffs@, jsedgwick, yfeldblum, chalfant

FB internal diff: D1955074

diff --git a/folly/wangle/concurrent/IOThreadPoolExecutor.cpp b/folly/wangle/concurrent/IOThreadPoolExecutor.cpp
index 4ac0b79b7167a6e8805a433de5cc40c48e8035bf..f8a68e25115d1a95ece7d75c670c497a1215b0b5 100644 (file)
--- a/folly/wangle/concurrent/IOThreadPoolExecutor.cpp
+++ b/folly/wangle/concurrent/IOThreadPoolExecutor.cpp
@@ -129,6 +129,10 @@ EventBase* IOThreadPoolExecutor::getEventBase(
   return nullptr;
 }
 
+EventBaseManager* IOThreadPoolExecutor::getEventBaseManager() {
+  return eventBaseManager_;
+}
+
 std::shared_ptr<ThreadPoolExecutor::Thread>
 IOThreadPoolExecutor::makeThread() {
   return std::make_shared<IOThread>(this);

diff --git a/folly/wangle/concurrent/IOThreadPoolExecutor.h b/folly/wangle/concurrent/IOThreadPoolExecutor.h
index 00aaa4779c6bc28f1ec535a6e90902a6a54b4283..b298ccae9000814f152f1b830f0718ae3cacc5db 100644 (file)
--- a/folly/wangle/concurrent/IOThreadPoolExecutor.h
+++ b/folly/wangle/concurrent/IOThreadPoolExecutor.h
@@ -44,6 +44,8 @@ class IOThreadPoolExecutor : public ThreadPoolExecutor, public IOExecutor {
 
   static EventBase* getEventBase(ThreadPoolExecutor::ThreadHandle*);
 
+  EventBaseManager* getEventBaseManager();
+
  private:
   struct FOLLY_ALIGN_TO_AVOID_FALSE_SHARING IOThread : public Thread {
     IOThread(IOThreadPoolExecutor* pool)