Commit 75ad72b0 authored by Yuri Putivsky's avatar Yuri Putivsky Committed by afrind

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
parent 13dda79b
...@@ -129,6 +129,10 @@ EventBase* IOThreadPoolExecutor::getEventBase( ...@@ -129,6 +129,10 @@ EventBase* IOThreadPoolExecutor::getEventBase(
return nullptr; return nullptr;
} }
EventBaseManager* IOThreadPoolExecutor::getEventBaseManager() {
return eventBaseManager_;
}
std::shared_ptr<ThreadPoolExecutor::Thread> std::shared_ptr<ThreadPoolExecutor::Thread>
IOThreadPoolExecutor::makeThread() { IOThreadPoolExecutor::makeThread() {
return std::make_shared<IOThread>(this); return std::make_shared<IOThread>(this);
......
...@@ -44,6 +44,8 @@ class IOThreadPoolExecutor : public ThreadPoolExecutor, public IOExecutor { ...@@ -44,6 +44,8 @@ class IOThreadPoolExecutor : public ThreadPoolExecutor, public IOExecutor {
static EventBase* getEventBase(ThreadPoolExecutor::ThreadHandle*); static EventBase* getEventBase(ThreadPoolExecutor::ThreadHandle*);
EventBaseManager* getEventBaseManager();
private: private:
struct FOLLY_ALIGN_TO_AVOID_FALSE_SHARING IOThread : public Thread { struct FOLLY_ALIGN_TO_AVOID_FALSE_SHARING IOThread : public Thread {
IOThread(IOThreadPoolExecutor* pool) IOThread(IOThreadPoolExecutor* pool)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment