Commit 23a18e39 authored by jan.koester's avatar jan.koester
Browse files

post has now limit

parent 451adff6

.kdev4/libhttppp.kdev4

+1 −1
Original line number Diff line number Diff line
@@ -13,7 +13,7 @@ CMake Binary=/usr/bin/cmake 
CMake Executable=/usr/bin/cmake

Environment Profile=

Extra Arguments=

Install Directory=

Install Directory=/usr/local

Runtime=Host System



[Project]

CMakeLists.txt

+1 −0
Original line number Diff line number Diff line
@@ -5,6 +5,7 @@ enable_testing () 
set(LIBV "1.0.0")

set(Upstream_VERSION 1.0.0)

set (BLOCKSIZE 16384 CACHE STRING "Block size from Network Packages")

set (DEFAULT_UPLOADSIZE 4e+6 CACHE STRING "Block size from Network Packages")



include(CheckIncludeFileCXX)

config.h.in

+2 −0
Original line number Diff line number Diff line
@@ -21,3 +21,5 @@ 
#define DEFAULTCONNECTTRIES 5



#define ARCH_${CMAKE_SYSTEM_PROCESSOR}



#define DEFAULT_UPLOADSIZE ${DEFAULT_UPLOADSIZE}

src/http.cpp

+10 −6
Original line number Diff line number Diff line
@@ -419,6 +419,7 @@ libhttppp::HttpResponse::~HttpResponse() { 


libhttppp::HttpRequest::HttpRequest(){

  _RequestType=0;

  _MaxUploadSize=DEFAULT_UPLOADSIZE;

}



void libhttppp::HttpRequest::parse(netplus::con* curconnection){
@@ -550,14 +551,12 @@ void libhttppp::HttpRequest::parse(netplus::con* curconnection){ 
                        break;

                    }



                    _Request.clear();

                    curconnection->copyValue(sdblock, sdblocksize, edblock, edblocksize, _Request);

                    curconnection->resizeRecvQueue(getDataSizet(contentlen) + header.length());

                }else{

                    netplus::con::condata *edblock=curconnection->getRecvLast(),*sdblock=curconnection->getRecvFirst();

                    _Request.clear();

                    curconnection->copyValue(sdblock,header.length(), edblock, edblock->getDataLength(), _Request);

                    curconnection->resizeRecvQueue( + header.length());

                }else if(curconnection->getRecvLength() > _MaxUploadSize){

                    curconnection->cleanRecvData();

                    excep[HTTPException::Note] << "Upload too big increase Max Upload Size";

                    throw excep;

                }

            } else {

                curconnection->resizeRecvQueue(header.length());
@@ -638,6 +637,11 @@ void libhttppp::HttpRequest::setRequestData(const char* data, size_t len){ 
  _Request.insert(0,data);

}



void libhttppp::HttpRequest::setMaxUploadSize(size_t upsize){

  _MaxUploadSize=upsize;

}





void libhttppp::HttpRequest::setRequestVersion(const char* version){

  if(version)

    _RequestVersion=version;

src/http.h

+2 −1
Original line number Diff line number Diff line
@@ -142,13 +142,14 @@ namespace libhttppp { 
    void           setRequestVersion(const char *version);

    /*only for post Reuquesttype*/

    void           setRequestData(const char *data,size_t len);

    void           setMaxUploadSize(size_t upsize);

    void           send(std::shared_ptr<netplus::socket> src,std::shared_ptr<netplus::socket> dest);

  private:

    std::string    _Request;

    int            _RequestType;

    std::string    _RequestURL;

    std::string    _RequestVersion;



    size_t         _MaxUploadSize;

    netplus::con   *_Connection;

  };