summaryrefslogtreecommitdiff
path: root/src/UDPTrackerClient.h
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:39:47 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:40:08 +0900
commitb1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch)
tree9ce465b42bf09372118335c7c619bb2b41869eaf /src/UDPTrackerClient.h
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/UDPTrackerClient.h')
-rw-r--r--src/UDPTrackerClient.h83
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);