class HttpRequest : public TcpSocket {
public:
	....................................
	HttpRequest&  PostData(const String& pd)              { postdata = pd; return *this; }
	....................................
	HttpRequest&  ClearPost()                             { PostData(Null); multipart.Clear(); GET(); return *this; }
	....................................
};

class HttpRequest : public TcpSocket {
	....................................
	int64       postdataPos;		// Added
	Upp::String postdataName;		// Added
	
	....................................
	bool		 SendingStream();	// Added
public:
	....................................
	HttpRequest&  PostData(const String& pd)              						{ postdata = pd; return *this; }
	HttpRequest&  PostDataStream(const String& pdn, const int64 pos = 0)        { postdataName = pdn; postdataPos = pos; return *this; }	// Added
	
	....................................
//	HttpRequest&  ClearPost()                             { PostData(Null); multipart.Clear(); GET(); return *this; }	// Delete
	HttpRequest&  ClearPost()                             { PostData(Null); PostDataStream(Null); multipart.Clear(); GET(); return *this; }	// Added

	....................................
};

bool HttpRequest::Do()
{
	....................................
	case REQUEST:
		if(SendingData())
			break;
		StartPhase(HEADER);
		break;
	....................................
}

void HttpRequest::StartRequest()
{
	....................................
	if(method == METHOD_GET || method == METHOD_HEAD)
		pd.Clear();
	....................................
			if(pd.GetCount() || method == METHOD_POST || method == METHOD_PUT)
			data << "Content-Length: " << pd.GetCount() << "\r\n";
	....................................
}

bool HttpRequest::SendingData()
{
	for(;;) {
		int n = min(2048, data.GetLength() - (int)count);
		n = TcpSocket::Put(~data + count, n);
		if(n == 0)
			break;
		count += n;
	}
	return count < data.GetLength();
}

bool HttpRequest::Do()
{
	....................................
	case REQUEST:
		if( IsNull(postdataName) ) {
			if(SendingData())
				break;
		}
		else {
			if(SendingStream())
				break;
		}
		StartPhase(HEADER);
		break;
	....................................
}

void HttpRequest::StartRequest()
{
	....................................
	if(method == METHOD_GET || method == METHOD_HEAD){
		pd.Clear();
		postdataName.Clear();
	}
	....................................
			if((IsNull(postdataName)? pd.GetCount() : Upp::GetFileLength(postdataName)-postdataPos) || method == METHOD_POST || method == METHOD_PUT)
				data << "Content-Length: " << (IsNull(postdataName)? pd.GetCount() : Upp::GetFileLength(postdataName)-postdataPos) << "\r\n";
	....................................
}

bool HttpRequest::SendingData()
{
	for(;;) {
		int n = min(2048, data.GetLength() - (int)count);
		n = TcpSocket::Put(~data + count, n);
		if(n == 0)
			break;
		count += n;
	}
	return count < data.GetLength();
}

bool HttpRequest::SendingStream() {
	Upp::FileIn in( postdataName );
	in.Seek( postdataPos );	

	int bufferSize = 2048 - (data.GetLength() & 2047);	

	Upp::StringBuffer buffer( bufferSize );
	int readingSize = in.Get( buffer, bufferSize );
	int64 postdataSize = in.GetSize() - postdataPos - readingSize;

	data << Upp::String( ~buffer, readingSize );

	for(;;) {
		int n = min(2048, data.GetLength() - (int)count);
		if( data.GetLength() - (int)count < 0 ) {
			int kk = 0;
		}
		n = TcpSocket::Put(~data + count, n);
		if(n == 0)
			break;
		count += n;
	}

	if( data.GetLength() == count ) {
		Upp::StringBuffer buffer( 2048 );
		for(;;) {
			int n = min((int64)2048, (int64)data.GetLength() + postdataSize - (int64)count);
			int readingSize = in.Get( buffer, n );
			n = TcpSocket::Put(~buffer, readingSize);
			if(n == 0)
				break;
			count += n;
		}
	}
	return count < data.GetLength() + postdataSize;
}

bool HttpRequest::SendingStream() {
	Upp::FileIn in( postdataName );
	in.Seek( postdataPos );

	int readingSize = 0;
	Upp::String dataPadding = data;
	if( dataPadding.GetLength() & 2047 ) {
		int bufferSize = 2048 - (dataPadding.GetLength() & 2047);

		Upp::StringBuffer buffer( bufferSize );
		readingSize = in.Get( buffer, bufferSize );
		dataPadding << Upp::String( ~buffer, readingSize );
	}
	int64 postdataSize = in.GetSize() - postdataPos - readingSize;

	if( count == 0 ) {
		for(;;) {
			int n = min(2048, dataPadding.GetLength() - (int)count);
			n = TcpSocket::Put(~dataPadding + count, n);
			if(n == 0)
				break;
			count += n;
		}

		if( (count == dataPadding.GetLength()) && postdataSize ) {
			Upp::StringBuffer buffer( 2048 );
			for(;;) {
				int n = min((int64)2048, (int64)dataPadding.GetLength() + postdataSize - (int64)count);
				int readingSize = in.Get(buffer, n);
				n = TcpSocket::Put(~buffer, readingSize);
				if(n == 0)
					break;
				count += n;
			}
		}
	}
	else {
		if( count < dataPadding.GetLength() ) {
			for(;;) {
				int n = min(2048, dataPadding.GetLength() - (int)count);
				n = TcpSocket::Put(~dataPadding + count, n);
				if(n == 0)
					break;
				count += n;
			}
		}
		if( (count >= dataPadding.GetLength()) && postdataSize ) {
			Upp::StringBuffer buffer( 2048 );
			in.Seek( postdataPos + readingSize + (count - dataPadding.GetLength()) );
			for(;;) {
				int n = min((int64)2048, (int64)dataPadding.GetLength() + postdataSize - (int64)count);
				int readingSize = in.Get(buffer, n);
				n = TcpSocket::Put(~buffer, readingSize);
				if(n == 0)
					break;
				count += n;
			}
		}
	}
	return count < dataPadding.GetLength() + postdataSize;
}