summaryrefslogtreecommitdiff
path: root/src/PeerConnection.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/PeerConnection.h')
-rw-r--r--src/PeerConnection.h27
1 files changed, 8 insertions, 19 deletions
diff --git a/src/PeerConnection.h b/src/PeerConnection.h
index ebd61133..6571fe65 100644
--- a/src/PeerConnection.h
+++ b/src/PeerConnection.h
@@ -88,10 +88,8 @@ private:
ssize_t sendData(const unsigned char* data, size_t length, bool encryption);
public:
- PeerConnection
- (cuid_t cuid,
- const std::shared_ptr<Peer>& peer,
- const std::shared_ptr<SocketCore>& socket);
+ PeerConnection(cuid_t cuid, const std::shared_ptr<Peer>& peer,
+ const std::shared_ptr<SocketCore>& socket);
~PeerConnection();
@@ -99,7 +97,7 @@ public:
// ownership of data, so caller must not delete or alter it.
void pushBytes(unsigned char* data, size_t len,
std::unique_ptr<ProgressUpdate> progressUpdate =
- std::unique_ptr<ProgressUpdate>{});
+ std::unique_ptr<ProgressUpdate>{});
bool receiveMessage(unsigned char* data, size_t& dataLength);
@@ -109,8 +107,8 @@ public:
* In both cases, 'msg' is filled with received bytes and the filled length
* is assigned to 'length'.
*/
- bool receiveHandshake
- (unsigned char* data, size_t& dataLength, bool peek = false);
+ bool receiveHandshake(unsigned char* data, size_t& dataLength,
+ bool peek = false);
void enableEncryption(std::unique_ptr<ARC4Encryptor> encryptor,
std::unique_ptr<ARC4Encryptor> decryptor);
@@ -123,15 +121,9 @@ public:
ssize_t sendPendingData();
- const unsigned char* getBuffer() const
- {
- return resbuf_.get();
- }
+ const unsigned char* getBuffer() const { return resbuf_.get(); }
- size_t getBufferLength() const
- {
- return resbufLength_;
- }
+ size_t getBufferLength() const { return resbufLength_; }
// Returns the pointer to the message in wire format. This method
// must be called after receiveMessage() returned true.
@@ -141,10 +133,7 @@ public:
// buffer length < minSize
void reserveBuffer(size_t minSize);
- size_t getBufferCapacity()
- {
- return bufferCapacity_;
- }
+ size_t getBufferCapacity() { return bufferCapacity_; }
};
} // namespace aria2