diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:39:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:40:08 +0900 |
| commit | b1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch) | |
| tree | 9ce465b42bf09372118335c7c619bb2b41869eaf /src/UDPTrackerClient.h | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/UDPTrackerClient.h')
| -rw-r--r-- | src/UDPTrackerClient.h | 83 |
1 files changed, 39 insertions, 44 deletions
diff --git a/src/UDPTrackerClient.h b/src/UDPTrackerClient.h index f2bbdce7..09e1e743 100644 --- a/src/UDPTrackerClient.h +++ b/src/UDPTrackerClient.h @@ -50,26 +50,23 @@ namespace aria2 { struct UDPTrackerRequest; -enum UDPTrackerConnectionState { - UDPT_CST_CONNECTING, - UDPT_CST_CONNECTED -}; +enum UDPTrackerConnectionState { UDPT_CST_CONNECTING, UDPT_CST_CONNECTED }; struct UDPTrackerConnection { int state; int64_t connectionId; Timer lastUpdated; UDPTrackerConnection() - : state(UDPT_CST_CONNECTING), - connectionId(UDPT_INITIAL_CONNECTION_ID), - lastUpdated(Timer::zero()) - {} + : state(UDPT_CST_CONNECTING), + connectionId(UDPT_INITIAL_CONNECTION_ID), + lastUpdated(Timer::zero()) + { + } UDPTrackerConnection(int state, int64_t connectionId, const Timer& lastUpdated) - : state(state), - connectionId(connectionId), - lastUpdated(lastUpdated) - {} + : state(state), connectionId(connectionId), lastUpdated(lastUpdated) + { + } }; class UDPTrackerClient { @@ -77,17 +74,17 @@ public: UDPTrackerClient(); ~UDPTrackerClient(); - int receiveReply - (const unsigned char* data, size_t length, const std::string& remoteAddr, - uint16_t remotePort, const Timer& now); + int receiveReply(const unsigned char* data, size_t length, + const std::string& remoteAddr, uint16_t remotePort, + const Timer& now); // Creates data frame for the next pending request. This function // always processes first entry of pendingRequests_. If the data is // sent successfully, call requestSent(). Otherwise call // requestFail(). - ssize_t createRequest - (unsigned char* data, size_t length, std::string& remoteAddr, - uint16_t& remotePort, const Timer& now); + ssize_t createRequest(unsigned char* data, size_t length, + std::string& remoteAddr, uint16_t& remotePort, + const Timer& now); // Tells this object that first entry of pendingRequests_ is // successfully sent. @@ -101,17 +98,17 @@ public: // Handles timeout for inflight requests. void handleTimeout(const Timer& now); - const std::deque<std::shared_ptr<UDPTrackerRequest> >& + const std::deque<std::shared_ptr<UDPTrackerRequest>>& getPendingRequests() const { return pendingRequests_; } - const std::deque<std::shared_ptr<UDPTrackerRequest> >& + const std::deque<std::shared_ptr<UDPTrackerRequest>>& getConnectRequests() const { return connectRequests_; } - const std::deque<std::shared_ptr<UDPTrackerRequest> >& + const std::deque<std::shared_ptr<UDPTrackerRequest>>& getInflightRequests() const { return inflightRequests_; @@ -120,16 +117,13 @@ public: bool noRequest() const { return pendingRequests_.empty() && connectRequests_.empty() && - getInflightRequests().empty(); + getInflightRequests().empty(); } // Makes all contained requests fail. void failAll(); - int getNumWatchers() const - { - return numWatchers_; - } + int getNumWatchers() const { return numWatchers_; } void increaseWatchers(); void decreaseWatchers(); @@ -138,29 +132,30 @@ public: // function. void failConnect(const std::string& remoteAddr, uint16_t remotePort, int error); + private: - std::shared_ptr<UDPTrackerRequest> findInflightRequest - (const std::string& remoteAddr, uint16_t remotePort, int32_t transactionId, - bool remove); - - UDPTrackerConnection* getConnectionId - (const std::string& remoteAddr, uint16_t remotePort, const Timer& now); - - std::map<std::pair<std::string, uint16_t>, - UDPTrackerConnection> connectionIdCache_; - std::deque<std::shared_ptr<UDPTrackerRequest> > inflightRequests_; - std::deque<std::shared_ptr<UDPTrackerRequest> > pendingRequests_; - std::deque<std::shared_ptr<UDPTrackerRequest> > connectRequests_; + std::shared_ptr<UDPTrackerRequest> + findInflightRequest(const std::string& remoteAddr, uint16_t remotePort, + int32_t transactionId, bool remove); + + UDPTrackerConnection* getConnectionId(const std::string& remoteAddr, + uint16_t remotePort, const Timer& now); + + std::map<std::pair<std::string, uint16_t>, UDPTrackerConnection> + connectionIdCache_; + std::deque<std::shared_ptr<UDPTrackerRequest>> inflightRequests_; + std::deque<std::shared_ptr<UDPTrackerRequest>> pendingRequests_; + std::deque<std::shared_ptr<UDPTrackerRequest>> connectRequests_; int numWatchers_; }; -ssize_t createUDPTrackerConnect -(unsigned char* data, size_t length, std::string& remoteAddr, - uint16_t& remotePort, const std::shared_ptr<UDPTrackerRequest>& req); +ssize_t createUDPTrackerConnect(unsigned char* data, size_t length, + std::string& remoteAddr, uint16_t& remotePort, + const std::shared_ptr<UDPTrackerRequest>& req); -ssize_t createUDPTrackerAnnounce -(unsigned char* data, size_t length, std::string& remoteAddr, - uint16_t& remotePort, const std::shared_ptr<UDPTrackerRequest>& req); +ssize_t createUDPTrackerAnnounce(unsigned char* data, size_t length, + std::string& remoteAddr, uint16_t& remotePort, + const std::shared_ptr<UDPTrackerRequest>& req); const char* getUDPTrackerActionStr(int action); |
