diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:12:52 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:20:27 +0900 |
| commit | d64089632e82a2548752c7a6baaa68365a795a74 (patch) | |
| tree | 57fc7b85a8c1290975d58fa4761b04a7695bf7e3 /src/DHTMessageDispatcherImpl.h | |
| parent | c81b1321122e8509b55c94c0cbca0d8d6d319f0c (diff) | |
| parent | a7cd943a06b1a5ff4515b57060b84037f8d01f9f (diff) | |
Merge branch 'master' into random-webseeding
Diffstat (limited to 'src/DHTMessageDispatcherImpl.h')
| -rw-r--r-- | src/DHTMessageDispatcherImpl.h | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/src/DHTMessageDispatcherImpl.h b/src/DHTMessageDispatcherImpl.h index d03b5cb3..992899e3 100644 --- a/src/DHTMessageDispatcherImpl.h +++ b/src/DHTMessageDispatcherImpl.h @@ -43,7 +43,7 @@ namespace aria2 { class DHTMessageTracker; struct DHTMessageEntry; -class DHTMessageDispatcherImpl:public DHTMessageDispatcher { +class DHTMessageDispatcherImpl : public DHTMessageDispatcher { private: std::shared_ptr<DHTMessageTracker> tracker_; @@ -52,21 +52,19 @@ private: std::chrono::seconds timeout_; bool sendMessage(DHTMessageEntry* msg); + public: DHTMessageDispatcherImpl(const std::shared_ptr<DHTMessageTracker>& tracker); - virtual void - addMessageToQueue(std::unique_ptr<DHTMessage> message, - std::chrono::seconds timeout, - std::unique_ptr<DHTMessageCallback> callback = - std::unique_ptr<DHTMessageCallback>{}) - CXX11_OVERRIDE; + virtual void addMessageToQueue( + std::unique_ptr<DHTMessage> message, std::chrono::seconds timeout, + std::unique_ptr<DHTMessageCallback> + callback = std::unique_ptr<DHTMessageCallback>{}) CXX11_OVERRIDE; - virtual void - addMessageToQueue(std::unique_ptr<DHTMessage> message, - std::unique_ptr<DHTMessageCallback> callback = - std::unique_ptr<DHTMessageCallback>{}) - CXX11_OVERRIDE; + virtual void addMessageToQueue( + std::unique_ptr<DHTMessage> message, + std::unique_ptr<DHTMessageCallback> + callback = std::unique_ptr<DHTMessageCallback>{}) CXX11_OVERRIDE; virtual void sendMessages() CXX11_OVERRIDE; |
