From 495f02ebbceaf72c125d809f6ce38004b6dd580a Mon Sep 17 00:00:00 2001
From: Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>
Date: Sat, 13 Sep 2008 16:32:47 +0000
Subject: 2008-09-14  Tatsuhiro Tsujikawa  <tujikawa at rednoah dot com>

	Use non-blocking socket for TCP communication to avoid possible
	blocking due to buffer full.
	* src/AbstractProxyRequestCommand.cc
	* src/FtpConnection.cc
	* src/FtpConnection.h
	* src/FtpNegotiationCommand.cc
	* src/FtpNegotiationCommand.h
	* src/HttpConnection.cc
	* src/HttpConnection.h
	* src/HttpRequestCommand.cc
	* src/InitiatorMSEHandshakeCommand.cc
	* src/InitiatorMSEHandshakeCommand.h
	* src/MSEHandshake.cc
	* src/MSEHandshake.h
	* src/Makefile.am
	* src/PeerConnection.cc
	* src/PeerConnection.h
	* src/PeerInteractionCommand.cc
	* src/PeerListenCommand.cc
	* src/ReceiverMSEHandshakeCommand.cc
	* src/ReceiverMSEHandshakeCommand.h
	* src/SocketBuffer.cc
	* src/SocketBuffer.h
	* src/SocketCore.cc
	* src/SocketCore.h
---
 src/HttpConnection.h | 6 ++++++
 1 file changed, 6 insertions(+)

(limited to 'src/HttpConnection.h')

diff --git a/src/HttpConnection.h b/src/HttpConnection.h
index 02ac19b4..0584d2aa 100644
--- a/src/HttpConnection.h
+++ b/src/HttpConnection.h
@@ -37,6 +37,7 @@
 
 #include "common.h"
 #include "SharedHandle.h"
+#include "SocketBuffer.h"
 #include <string>
 #include <deque>
 
@@ -71,6 +72,7 @@ class HttpConnection {
 private:
   int32_t cuid;
   SharedHandle<SocketCore> socket;
+  SocketBuffer _socketBuffer;
   const Option* option;
   Logger* logger;
 
@@ -112,6 +114,10 @@ public:
   SharedHandle<HttpRequest> getFirstHttpRequest() const;
 
   bool isIssued(const SharedHandle<Segment>& segment) const;
+
+  bool sendBufferIsEmpty() const;
+
+  void sendPendingData();
 };
 
 typedef SharedHandle<HttpConnection> HttpConnectionHandle;
-- 
cgit