#include <boost/test/included/unit_test.hpp>
#include <boost/thread/condition.hpp>
-#include "http_protocol_module_base.h"
+#include "protocol_module_cinsert.h"
using namespace boost::unit_test_framework;
using namespace l7vs;
-#define CHECK_METHOD_OK_STRING_NUM (16)
-#define CHECK_METHOD_NG_STRING_NUM (8)
-#define CHECK_METHOD_INPOSSIBLE_STRING_NUM (3)
-
-#define CHECK_VERSION_OK_STRING_NUM (10)
-#define CHECK_VERSION_NG_STRING_NUM (16)
-#define CHECK_VERSION_INPOSSIBLE_STRING_NUM (4)
-
-#define CHECK_STATUS_CODE_OK_STRING_NUM (6)
-#define CHECK_STATUS_CODE_NG_STRING_NUM (9)
-#define CHECK_STATUS_CODE_INPOSSIBLE_STRING_NUM (2)
-
-#define FIND_URI_OK_STRING_NUM (4)
-#define FIND_URI_NG_STRING_NUM (4)
-
-#define FIND_STATUS_CODE_OK_STRING_NUM (2)
-#define FIND_STATUS_CODE_NG_STRING_NUM (4)
-
#define THREAD_LOOP_NUM (1)
//--stub functions--
//--test class--
-class http_protocol_module_base_test : public http_protocol_module_base {
+class protocol_module_cinsert_test : public protocol_module_cinsert {
public:
boost::mutex sync_mutex;
boost::condition sync_condition;
-http_protocol_module_base_test( std::string in_modulename ) : http_protocol_module_base( in_modulename ){}
-~http_protocol_module_base_test(){}
-bool is_tcp(){ return true; }
-bool is_udp(){ return true; }
-void replication_interrupt(){}
-void initialize(
- rs_list_itr_func_type inlist_begin,
- rs_list_itr_func_type inlist_end,
- rs_list_itr_next_func_type inlist_next,
- boost::function< void( void ) > inlist_lock,
- boost::function< void( void ) > inlist_unlock ){}
-
-void finalize(){}
-
-bool is_use_sorry(){ return true; }
-
-void handle_rslist_update(){}
-
-check_message_result check_parameter( const std::vector<std::string>& args ){
- check_message_result result;
- return result;
-}
-check_message_result set_parameter( const std::vector<std::string>& args ){
- check_message_result result;
- return result;
-}
-check_message_result add_parameter( const std::vector<std::string>& args ){
- check_message_result result;
- return result;
-}
-void register_schedule( tcp_schedule_func_type inschedule ){}
-void register_schedule( udp_schedule_func_type inschedule ){}
-EVENT_TAG handle_session_initialize(
- const boost::thread::id up_thread_id,
- const boost::thread::id down_thread_id,
- const boost::asio::ip::tcp::endpoint& client_endpoint_tcp,
- const boost::asio::ip::udp::endpoint& client_endpoint_udp ){ return STOP; }
-EVENT_TAG handle_session_finalize(
- const boost::thread::id up_thread_id,
- const boost::thread::id down_thread_id ){ return STOP; }
-EVENT_TAG handle_accept( const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_client_recv(
- const boost::thread::id thread_id,
- const boost::array<char,MAX_BUFFER_SIZE>& recvbuffer,
- const size_t recvlen ){ return STOP; }
-EVENT_TAG handle_realserver_select(
- const boost::thread::id thread_id,
- boost::asio::ip::tcp::endpoint& rs_endpoint ){ return STOP; }
-EVENT_TAG handle_realserver_select(
- const boost::thread::id thread_id,
- boost::asio::ip::udp::endpoint& rs_endpoint,
- boost::array<char,MAX_BUFFER_SIZE>& sendbuffer,
- size_t& datalen ){ return STOP; }
-EVENT_TAG handle_realserver_connect(
- const boost::thread::id thread_id,
- boost::array<char,MAX_BUFFER_SIZE>& sendbuffer,
- size_t& datalen ){ return STOP; }
-EVENT_TAG handle_realserver_connection_fail(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& rs_endpoint ){ return STOP; }
-EVENT_TAG handle_realserver_send(
- const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_sorryserver_select(
- const boost::thread::id thread_id,
- boost::asio::ip::tcp::endpoint& sorry_endpoint ){ return STOP; }
-EVENT_TAG handle_sorryserver_connect(
- const boost::thread::id thread_id,
- boost::array<char,MAX_BUFFER_SIZE>& sendbuffer,
- size_t& datalen ){ return STOP; }
-EVENT_TAG handle_sorryserver_connection_fail(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& sorry_endpoint ){ return STOP; }
-EVENT_TAG handle_sorryserver_send( const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_realserver_recv(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& rs_endpoint,
- const boost::array<char,MAX_BUFFER_SIZE>& recvbuffer,
- const size_t recvlen ){ return STOP; }
-EVENT_TAG handle_realserver_recv(
- const boost::thread::id thread_id,
- const boost::asio::ip::udp::endpoint& rs_endpoint,
- const boost::array<char,MAX_BUFFER_SIZE>& recvbuffer,
- const size_t recvlen ){ return STOP; }
-EVENT_TAG handle_sorryserver_recv(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& sorry_endpoint,
- const boost::array<char,MAX_BUFFER_SIZE>& recvbuffer,
- const size_t recvlen ){ return STOP; }
-EVENT_TAG handle_response_send_inform(
- const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_client_connection_check(
- const boost::thread::id thread_id,
- boost::array<char,MAX_BUFFER_SIZE>& sendbuffer,
- size_t& datalen ){ return STOP; }
-EVENT_TAG handle_client_select(
- const boost::thread::id thread_id,
- boost::asio::ip::udp::endpoint& cl_endpoint,
- boost::array<char,MAX_BUFFER_SIZE>& sendbuffer,
- size_t& datalen ){ return STOP; }
-EVENT_TAG handle_client_send( const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_client_disconnect(
- const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_sorry_enable( const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_sorry_disable( const boost::thread::id thread_id ){ return STOP; }
-EVENT_TAG handle_realserver_disconnect(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& rs_endpoint ){ return STOP; }
-EVENT_TAG handle_sorryserver_disconnect(
- const boost::thread::id thread_id,
- const boost::asio::ip::tcp::endpoint& sorry_endpoint ){ return STOP; }
-EVENT_TAG handle_realserver_close(
- const boost::thread::id thread_id,
- const boost::asio::ip::udp::endpoint& rs_endpoint ){ return STOP; }
-
-void check_http_method_test(){
-
- int count = 1;
-
- char buffer_ok[CHECK_METHOD_OK_STRING_NUM][256]
- = {
-// unit_test[01] check_http_method( CheckData = "GET /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[02] check_http_method( CheckData = "HEAD /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[03] check_http_method( CheckData = "POST /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[04] check_http_method( CheckData = "PUT /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[05] check_http_method( CheckData = "PROPFIND /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[06] check_http_method( CheckData = "PROPPATCH /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[07] check_http_method( CheckData = "OPTIONS /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[08] check_http_method( CheckData = "CONNECT /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[09] check_http_method( CheckData = "COPY /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[10] check_http_method( CheckData = "TRACE /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[11] check_http_method( CheckData = "DELETE /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[12] check_http_method( CheckData = "LOCK /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[13] check_http_method( CheckData = "UNLOCK /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[14] check_http_method( CheckData = "MOVE /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[15] check_http_method( CheckData = "MKCOL /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[16] check_http_method( CheckData = "GET /a HTTP/1.0" / Result = OK )
- "GET /abc/def/ HTTP/1.0",
- "HEAD /abc/def/ HTTP/1.0",
- "POST /abc/def/ HTTP/1.0",
- "PUT /abc/def/ HTTP/1.0",
- "PROPFIND /abc/def/ HTTP/1.0",
- "PROPPATCH /abc/def/ HTTP/1.0",
- "OPTIONS /abc/def/ HTTP/1.0",
- "CONNECT /abc/def/ HTTP/1.0",
- "COPY /abc/def/ HTTP/1.0",
- "TRACE /abc/def/ HTTP/1.0",
- "DELETE /abc/def/ HTTP/1.0",
- "LOCK /abc/def/ HTTP/1.0",
- "UNLOCK /abc/def/ HTTP/1.0",
- "MOVE /abc/def/ HTTP/1.0",
- "MKCOL /abc/def/ HTTP/1.0",
- "GET /a HTTP/1.0",
- };
- char buffer_ng[CHECK_METHOD_NG_STRING_NUM][256]
- = {
-// unit_test[17] check_http_method( CheckData = "get /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[18] check_http_method( CheckData = "Get /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[19] check_http_method( CheckData = "GET/abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[20] check_http_method( CheckData = "GGET /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[21] check_http_method( CheckData = " GET /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[22] check_http_method( CheckData = "get GET /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[23] check_http_method( CheckData = "get /abc/GET /abc/def/ HTTP/1.0" / Result = NG )
-// unit_test[24] check_http_method( CheckData = "GET /abc/def/ HTTP/1.0 GET /abc/def/ HTTP/1.0" / Result = NG )
- "get /abc/def/ HTTP/1.0",
- "Get /abc/def/ HTTP/1.0",
- "GET/abc/def/ HTTP/1.0",
- "GGET /abc/def/ HTTP/1.0",
- " GET /abc/def/ HTTP/1.0",
- "get GET /abc/def/ HTTP/1.0",
- "get /abc/GET /abc/def/ HTTP/1.0",
- "GET /abc/def/ HTTP/1.0 GET /abc/def/ HTTP/1.0",
- };
- char buffer_inpossible[CHECK_METHOD_INPOSSIBLE_STRING_NUM][256]
- = {
-// unit_test[25] check_http_method( CheckData = "GET / HTTP/1.0" / Result = INPOSSIBLE )
-// unit_test[26] check_http_method( CheckData = "Get / HTTP/1.0" / Result = INPOSSIBLE )
-// unit_test[27] check_http_method( CheckData = "" / Result = INPOSSIBLE )
- "GET / HTTP/1.0",
- "Get / HTTP/1.0",
- "",
- };
- size_t buffer_len = 0;
-
- for( int i = 0; i < CHECK_METHOD_OK_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ok[i] << "] + [CR]" << std::endl;
- buffer_ok[i][strlen( buffer_ok[i] )] = '\r';
- buffer_len = strlen( buffer_ok[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [01] - [16]
- BOOST_CHECK( check_http_method( (const char*)buffer_ok[i], buffer_len ) == CHECK_OK );
- }
-
- for( int i = 0; i < CHECK_METHOD_NG_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ng[i] << "] + [CR]" << std::endl;
- buffer_ng[i][strlen( buffer_ng[i] )] = '\r';
- buffer_len = strlen( buffer_ng[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [17] - [24]
- BOOST_CHECK( check_http_method( (const char*)buffer_ng[i], buffer_len ) == CHECK_NG );
- }
-
- for( int i = 0; i < CHECK_METHOD_INPOSSIBLE_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_inpossible[i] << "]" << std::endl;
- buffer_len = strlen( buffer_inpossible[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [25] - [27]
- BOOST_CHECK( check_http_method( (const char*)buffer_inpossible[i], buffer_len ) == CHECK_INPOSSIBLE );
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[28] check_http_method( CheckData = NULL, Length = 0 / Result = NG )
- BOOST_CHECK( check_http_method( NULL, buffer_len ) == CHECK_NG );
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 100;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[29] check_http_method( CheckData = NULL, Length = 100 / Result = NG )
- BOOST_CHECK( check_http_method( NULL, buffer_len ) == CHECK_NG );
- count++;
-
-}
-
-void check_http_method_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
-
- char buffer[5][256]
- = {
-// unit_test[30] check_http_method( CheckData = "GET /abc/def/ HTTP/1.0" / Result = OK / ThreadNo = 1 )
-// unit_test[31] check_http_method( CheckData = "HEAD /abc/def/ HTTP/1.0" / Result = OK / ThreadNo = 2 )
-// unit_test[32] check_http_method( CheckData = "get /abc/def/ HTTP/1.0" / Result = NG / ThreadNo = 3 )
-// unit_test[33] check_http_method( CheckData = "Get /abc/def/ HTTP/1.0" / Result = NG / ThreadNo = 4 )
-// unit_test[34] check_http_method( CheckData = "" / Result = INPOSSIBLE / ThreadNo = 5 )
- "GET /abc/def/ HTTP/1.0",
- "HEAD /abc/def/ HTTP/1.0",
- "get /abc/def/ HTTP/1.0",
- "Get /abc/def/ HTTP/1.0",
- "",
- };
-
- int edit_flag[5]
- = {
- 1,
- 1,
- 1,
- 1,
- 0,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG result[5]
- = {
- CHECK_OK,
- CHECK_OK,
- CHECK_NG,
- CHECK_NG,
- CHECK_INPOSSIBLE,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG check_result;
-
- size_t buffer_len = 0;
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "String = [" << buffer[thread_no-1] << "]" << std::endl;
- if( edit_flag[thread_no-1] == 1){
- buffer[thread_no-1][strlen( buffer[thread_no-1] )] = '\r';
- }
- buffer_len = strlen( buffer[thread_no-1] );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [30] - [34]
- check_result = check_http_method( (const char*)buffer[thread_no-1], buffer_len );
- if( check_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( check_http_method( (const char*)buffer[thread_no-1], buffer_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
-void check_http_version_test(){
-
- int count = 1;
-
- char buffer_ok[CHECK_VERSION_OK_STRING_NUM][256]
- = {
-// unit_test[01] check_http_version( CheckData = "GET /abc/def/ HTTP/1.0" / Result = OK )
-// unit_test[02] check_http_version( CheckData = "GET /abc/def/ HTTP/1.1" / Result = OK )
-// unit_test[03] check_http_version( CheckData = "GET /abc/def/ghi HTTP/1.0" / Result = OK )
-// unit_test[04] check_http_version( CheckData = "GET /abc/def/ghi HTTP/1.1" / Result = OK )
-// unit_test[05] check_http_version( CheckData = "get /abc/def/ghi HTTP/1.0" / Result = OK )
-// unit_test[06] check_http_version( CheckData = "get /abc/def/ghi HTTP/1.1" / Result = OK )
-// unit_test[07] check_http_version( CheckData = "HTTP/1.0 100 abcdff" / Result = OK )
-// unit_test[08] check_http_version( CheckData = "HTTP/1.1 100 abcdff" / Result = OK )
-// unit_test[09] check_http_version( CheckData = "HTTP/1.0 404 abcdff" / Result = OK )
-// unit_test[10] check_http_version( CheckData = "HTTP/1.1 404 abcdff" / Result = OK )
- "GET /abc/def/ HTTP/1.0",
- "GET /abc/def/ HTTP/1.1",
- "GET /abc/def/ghi HTTP/1.0",
- "GET /abc/def/ghi HTTP/1.1",
- "get /abc/def/ghi HTTP/1.0",
- "get /abc/def/ghi HTTP/1.1",
- "HTTP/1.0 100 abcdff",
- "HTTP/1.1 100 abcdff",
- "HTTP/1.0 404 abcdff",
- "HTTP/1.1 404 abcdff",
- };
- char buffer_ng[CHECK_VERSION_NG_STRING_NUM][256]
- = {
-// unit_test[11] check_http_version( CheckData = "GET /abc/def/ HTTP/0.0" / Result = NG )
-// unit_test[12] check_http_version( CheckData = "GET /abc/def/ HTTP/0.9" / Result = NG )
-// unit_test[13] check_http_version( CheckData = "GET /abc/def/ HTTP/1.2" / Result = NG )
-// unit_test[14] check_http_version( CheckData = "GET /abc/def/ HTTP/2.0" / Result = NG )
-// unit_test[15] check_http_version( CheckData = "GET /abc/def/ghiHTTP/1.0" / Result = NG )
-// unit_test[16] check_http_version( CheckData = "GET/abc/def/ghi HTTP/1.1" / Result = NG )
-// unit_test[17] check_http_version( CheckData = "/abc/def/ghi HTTP/1.0" / Result = NG )
-// unit_test[18] check_http_version( CheckData = "GET /abc/def/ http/1.0" / Result = NG )
-// unit_test[19] check_http_version( CheckData = "HTTP/0.0 100 abcdff" / Result = NG )
-// unit_test[20] check_http_version( CheckData = "HTTP/0.9 100 abcdff" / Result = NG )
-// unit_test[21] check_http_version( CheckData = "HTTP/1.2 100 abcdff" / Result = NG )
-// unit_test[22] check_http_version( CheckData = "HTTP/2.0 100 abcdff" / Result = NG )
-// unit_test[23] check_http_version( CheckData = "HTTP/1.0 404abcdff" / Result = NG )
-// unit_test[24] check_http_version( CheckData = "HTTP/1.1404 abcdff" / Result = NG )
-// unit_test[25] check_http_version( CheckData = "HTTP/1.1404abcdff" / Result = NG )
-// unit_test[26] check_http_version( CheckData = "http/1.0 100 abcdff" / Result = NG )
- "GET /abc/def/ HTTP/0.0",
- "GET /abc/def/ HTTP/0.9",
- "GET /abc/def/ HTTP/1.2",
- "GET /abc/def/ HTTP/2.0",
- "GET /abc/def/ghiHTTP/1.0",
- "GET/abc/def/ghi HTTP/1.1",
- "/abc/def/ghi HTTP/1.0",
- "GET /abc/def/ http/1.0",
- "HTTP/0.0 100 abcdff",
- "HTTP/0.9 100 abcdff",
- "HTTP/1.2 100 abcdff",
- "HTTP/2.0 100 abcdff",
- "HTTP/1.0 404abcdff",
- "HTTP/1.1404 abcdff",
- "HTTP/1.1404abcdff",
- "http/1.0 100 abcdff",
- };
- char buffer_inpossible[CHECK_VERSION_INPOSSIBLE_STRING_NUM][256]
- = {
-// unit_test[27] check_http_version( CheckData = "GET /abc/def/ HTTP/1.0" / Result = INPOSSIBLE )
-// unit_test[28] check_http_version( CheckData = "GET /abc/def/ H" / Result = INPOSSIBLE )
-// unit_test[29] check_http_version( CheckData = "Get /abc/def/ H" / Result = INPOSSIBLE )
-// unit_test[30] check_http_version( CheckData = "" / Result = INPOSSIBLE )
- "GET /abc/def/ HTTP/1.0",
- "GET /abc/def/ H",
- "Get /abc/def/ H",
- "",
- };
- size_t buffer_len = 0;
-
- for( int i = 0; i < CHECK_VERSION_OK_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ok[i] << "] + [CR]" << std::endl;
- buffer_ok[i][strlen( buffer_ok[i] )] = '\r';
- buffer_len = strlen( buffer_ok[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [01] - [10]
- BOOST_CHECK( check_http_version( (const char*)buffer_ok[i], buffer_len ) == CHECK_OK );
- }
-
- for( int i = 0; i < CHECK_VERSION_NG_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ng[i] << "] + [CR]" << std::endl;
- buffer_ng[i][strlen( buffer_ng[i] )] = '\r';
- buffer_len = strlen( buffer_ng[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [11] - [26]
- BOOST_CHECK( check_http_version( (const char*)buffer_ng[i], buffer_len ) == CHECK_NG );
- }
-
- for( int i = 0; i < CHECK_VERSION_INPOSSIBLE_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_inpossible[i] << "]" << std::endl;
- buffer_len = strlen( buffer_inpossible[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [27] - [30]
- BOOST_CHECK( check_http_version( (const char*)buffer_inpossible[i], buffer_len ) == CHECK_INPOSSIBLE );
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[31] check_http_version( CheckData = NULL, Length = 0 / Result = NG )
- BOOST_CHECK( check_http_version( NULL, buffer_len ) == CHECK_NG );
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 100;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[32] check_http_version( CheckData = NULL, Length = 100 / Result = NG )
- BOOST_CHECK( check_http_version( NULL, buffer_len ) == CHECK_NG );
- count++;
-
-}
-
-void check_http_version_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
-
- char buffer[5][256]
- = {
-// unit_test[33] check_http_version( CheckData = "GET /abc/def/ HTTP/1.0" / Result = OK / ThreadNo = 1 )
-// unit_test[34] check_http_version( CheckData = "HTTP/1.0 100 abcdff" / Result = OK / ThreadNo = 2 )
-// unit_test[35] check_http_version( CheckData = "GET /abc/def/ HTTP/0.0" / Result = NG / ThreadNo = 3 )
-// unit_test[36] check_http_version( CheckData = "HTTP/0.0 100 abcdff" / Result = NG / ThreadNo = 4 )
-// unit_test[37] check_http_version( CheckData = "" / Result = INPOSSIBLE / ThreadNo = 5 )
- "GET /abc/def/ HTTP/1.0",
- "HTTP/1.0 100 abcdff",
- "GET /abc/def/ HTTP/0.0",
- "HTTP/0.0 100 abcdff",
- "",
- };
-
- int edit_flag[5]
- = {
- 1,
- 1,
- 1,
- 1,
- 0,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG result[5]
- = {
- CHECK_OK,
- CHECK_OK,
- CHECK_NG,
- CHECK_NG,
- CHECK_INPOSSIBLE,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG check_result;
-
- size_t buffer_len = 0;
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "String = [" << buffer[thread_no-1] << "]" << std::endl;
- if( edit_flag[thread_no-1] == 1){
- buffer[thread_no-1][strlen( buffer[thread_no-1] )] = '\r';
- }
- buffer_len = strlen( buffer[thread_no-1] );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [33] - [37]
- check_result = check_http_version( (const char*)buffer[thread_no-1], buffer_len );
- if( check_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( check_http_version( (const char*)buffer[thread_no-1], buffer_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
-
-void check_status_code_test(){
-
- int count = 1;
-
- char buffer_ok[CHECK_STATUS_CODE_OK_STRING_NUM][256]
- = {
-// unit_test[01] check_status_code( CheckData = "HTTP/1.0 100 abcdff" / Result = OK )
-// unit_test[02] check_status_code( CheckData = "HTTP/1.0 199 abcdff" / Result = OK )
-// unit_test[03] check_status_code( CheckData = "HTTP/1.0 200 abcdff" / Result = OK )
-// unit_test[04] check_status_code( CheckData = "HTTP/1.0 299 abcdff" / Result = OK )
-// unit_test[05] check_status_code( CheckData = "HTTP/1.0 300 abcdff" / Result = OK )
-// unit_test[06] check_status_code( CheckData = "HTTP/1.0 399 abcdff" / Result = OK )
- "HTTP/1.0 100 abcdff",
- "HTTP/1.0 199 abcdff",
- "HTTP/1.0 200 abcdff",
- "HTTP/1.0 299 abcdff",
- "HTTP/1.0 300 abcdff",
- "HTTP/1.0 399 abcdff",
- };
- char buffer_ng[CHECK_STATUS_CODE_NG_STRING_NUM][256]
- = {
-// unit_test[07] check_status_code( CheckData = "HTTP/1.0 000 abcdff" / Result = NG )
-// unit_test[08] check_status_code( CheckData = "HTTP/1.0 099 abcdff" / Result = NG )
-// unit_test[09] check_status_code( CheckData = "HTTP/1.0 400 abcdff" / Result = NG )
-// unit_test[10] check_status_code( CheckData = "HTTP/1.0 999 abcdff" / Result = NG )
-// unit_test[11] check_status_code( CheckData = "HTTP/1.0 10 abcdff" / Result = NG )
-// unit_test[12] check_status_code( CheckData = "HTTP/1.0 1000 abcdff" / Result = NG )
-// unit_test[13] check_status_code( CheckData = "HTTP/1.0 a00 abcdff" / Result = NG )
-// unit_test[14] check_status_code( CheckData = "HTTP/1.0 1a0 abcdff" / Result = NG )
-// unit_test[15] check_status_code( CheckData = "HTTP/1.0 10a abcdff" / Result = NG )
- "HTTP/1.0 000 abcdff",
- "HTTP/1.0 099 abcdff",
- "HTTP/1.0 400 abcdff",
- "HTTP/1.0 999 abcdff",
- "HTTP/1.0 10 abcdff",
- "HTTP/1.0 1000 abcdff",
- "HTTP/1.0 a00 abcdff",
- "HTTP/1.0 1a0 abcdff",
- "HTTP/1.0 10a abcdff",
- };
- char buffer_inpossible[CHECK_STATUS_CODE_INPOSSIBLE_STRING_NUM][256]
- = {
-// unit_test[16] check_status_code( CheckData = "HTTP/1.0 100" / Result = INPOSSIBLE )
-// unit_test[17] check_status_code( CheckData = "" / Result = INPOSSIBLE )
- "HTTP/1.0 100",
- "",
- };
- size_t buffer_len = 0;
-
- for( int i = 0; i < CHECK_STATUS_CODE_OK_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ok[i] << "] + [CR]" << std::endl;
- buffer_ok[i][strlen( buffer_ok[i] )] = '\r';
- buffer_len = strlen( buffer_ok[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [01] - [06]
- BOOST_CHECK( check_status_code( (const char*)buffer_ok[i], buffer_len ) == CHECK_OK );
- }
-
- for( int i = 0; i < CHECK_STATUS_CODE_NG_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_ng[i] << "] + [CR]" << std::endl;
- buffer_ng[i][strlen( buffer_ng[i] )] = '\r';
- buffer_len = strlen( buffer_ng[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [07] - [15]
- BOOST_CHECK( check_status_code( (const char*)buffer_ng[i], buffer_len ) == CHECK_NG );
- }
-
- for( int i = 0; i < CHECK_STATUS_CODE_INPOSSIBLE_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "String = [" << buffer_inpossible[i] << "] + [CR]" << std::endl;
- buffer_len = strlen( buffer_inpossible[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [16] - [17]
- BOOST_CHECK( check_status_code( (const char*)buffer_inpossible[i], buffer_len ) == CHECK_INPOSSIBLE );
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[18] check_status_code( CheckData = NULL, Length = 0 / Result = NG )
- BOOST_CHECK( check_status_code( NULL, buffer_len ) == CHECK_NG );
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- buffer_len = 100;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[19] check_status_code( CheckData = NULL, Length = 100 / Result = NG )
- BOOST_CHECK( check_status_code( NULL, buffer_len ) == CHECK_NG );
- count++;
-
-}
-
-void check_status_code_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
-
- char buffer[5][256]
- = {
-// unit_test[20] check_status_code( CheckData = "HTTP/1.0 100 abcdff" / Result = OK / ThreadNo = 1 )
-// unit_test[21] check_status_code( CheckData = "HTTP/1.0 399 abcdff" / Result = OK / ThreadNo = 2 )
-// unit_test[22] check_status_code( CheckData = "HTTP/1.0 099 abcdff" / Result = NG / ThreadNo = 3 )
-// unit_test[23] check_status_code( CheckData = "HTTP/1.0 400 abcdff" / Result = NG / ThreadNo = 4 )
-// unit_test[24] check_status_code( CheckData = "" / Result = INPOSSIBLE / ThreadNo = 5 )
- "HTTP/1.0 100 abcdff",
- "HTTP/1.0 399 abcdff",
- "HTTP/1.0 099 abcdff",
- "HTTP/1.0 400 abcdff",
- "",
- };
-
- int edit_flag[5]
- = {
- 1,
- 1,
- 1,
- 1,
- 0,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG result[5]
- = {
- CHECK_OK,
- CHECK_OK,
- CHECK_NG,
- CHECK_NG,
- CHECK_INPOSSIBLE,
- };
-
- l7vs::http_protocol_module_base::CHECK_RESULT_TAG check_result;
-
- size_t buffer_len = 0;
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "String = [" << buffer[thread_no-1] << "]" << std::endl;
- if( edit_flag[thread_no-1] == 1){
- buffer[thread_no-1][strlen( buffer[thread_no-1] )] = '\r';
- }
- buffer_len = strlen( buffer[thread_no-1] );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [20] - [24]
- check_result = check_status_code( (const char*)buffer[thread_no-1], buffer_len );
- if( check_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( check_status_code( (const char*)buffer[thread_no-1], buffer_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
-
-void find_uri_test(){
-
- int count = 1;
-
- char disp_uri[256];
-
- char buffer_ok[FIND_URI_OK_STRING_NUM][256]
- = {
-// unit_test[01] find_uri( FindData = "GET /abc/def/ HTTP/1.0" / Result = true )
-// unit_test[02] find_uri( FindData = "GET /abc/def/ghi HTTP/1.0" / Result = true )
-// unit_test[03] find_uri( FindData = "HEAD abcdef HTTP/1.0" / Result = true )
-// unit_test[04] find_uri( FindData = "HEAD /abc/def/ghi/jkl/mno/pqr/stu/vwx/yz0/123/456/789/ HTTP/1.0" / Result = true )
- "GET /abc/def/ HTTP/1.0",
- "GET /abc/def/ghi HTTP/1.0",
- "HEAD abcdef HTTP/1.0",
- "HEAD /abc/def/ghi/jkl/mno/pqr/stu/vwx/yz0/123/456/789/ HTTP/1.0",
- };
-
- char buffer_ng[FIND_URI_NG_STRING_NUM][256]
- = {
-// unit_test[05] find_uri( FindData = "GET/abc/def/ HTTP/1.0" / Result = false )
-// unit_test[06] find_uri( FindData = "GET /abc/def/HTTP/1.0" / Result = false )
-// unit_test[07] find_uri( FindData = "HEAD/abc/def/HTTP/1.0" / Result = false )
-// unit_test[08] find_uri( FindData = "" / Result = false )
- "GET/abc/def/ HTTP/1.0",
- "GET /abc/def/HTTP/1.0",
- "HEAD/abc/def/HTTP/1.0",
- "",
- };
-
- size_t buffer_len = 0;
- size_t uri_offset = 0;
- size_t uri_len = 0;
-
- for( int i = 0; i < FIND_URI_OK_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_uri, '\0', 256 );
- uri_offset = 0;
- uri_len = 0;
- std::cout << "String = [" << buffer_ok[i] << "] + [CR]" << std::endl;
- buffer_ok[i][strlen( buffer_ok[i] )] = '\r';
- buffer_len = strlen( buffer_ok[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [01] - [04]
- BOOST_CHECK( find_uri( (const char*)buffer_ok[i], buffer_len, uri_offset, uri_len ) == true );
- memcpy( disp_uri, buffer_ok[i] + uri_offset, uri_len );
- std::cout << "URI Offset = [" << uri_offset << "]" << std::endl;
- std::cout << "URI Length = [" << uri_len << "]" << std::endl;
- std::cout << "URI String = [" << disp_uri << "]" << std::endl;
- }
-
- for( int i = 0; i < FIND_URI_NG_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_uri, '\0', 256 );
- uri_offset = 0;
- uri_len = 0;
- std::cout << "String = [" << buffer_ng[i] << "] + [CR]" << std::endl;
- buffer_ng[i][strlen( buffer_ng[i] )] = '\r';
- buffer_len = strlen( buffer_ng[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [05] - [07]
- BOOST_CHECK( find_uri( (const char*)buffer_ng[i], buffer_len, uri_offset, uri_len ) == false );
- memcpy( disp_uri, buffer_ng[i] + uri_offset, uri_len );
- std::cout << "URI Offset = [" << uri_offset << "]" << std::endl;
- std::cout << "URI Length = [" << uri_len << "]" << std::endl;
- std::cout << "URI String = [" << disp_uri << "]" << std::endl;
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_uri, '\0', 256 );
- uri_offset = 0;
- uri_len = 0;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[09] find_uri( FindData = NULL, Length = 0 / Result = false )
- BOOST_CHECK( find_uri( NULL, buffer_len, uri_offset, uri_len ) == false );
- std::cout << "URI Offset = [" << uri_offset << "]" << std::endl;
- std::cout << "URI Length = [" << uri_len << "]" << std::endl;
- std::cout << "URI String = [" << disp_uri << "]" << std::endl;
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_uri, '\0', 256 );
- uri_offset = 0;
- uri_len = 0;
- buffer_len = 100;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[10] find_uri( FindData = NULL, Length = 100 / Result = false )
- BOOST_CHECK( find_uri( NULL, buffer_len, uri_offset, uri_len ) == false );
- std::cout << "URI Offset = [" << uri_offset << "]" << std::endl;
- std::cout << "URI Length = [" << uri_len << "]" << std::endl;
- std::cout << "URI String = [" << disp_uri << "]" << std::endl;
- count++;
-
-}
-
-void find_uri_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
-
- char disp_uri[256];
-
- char buffer[5][256]
- = {
-// unit_test[11] find_uri( FindData = "GET /abc/def/ HTTP/1.0" / Result = true / ThreadNo = 1 )
-// unit_test[12] find_uri( FindData = "HEAD /abc/def/ghi/jkl/mno/pqr/stu/vwx/yz0/123/456/789/ HTTP/1.0" / Result = true / ThreadNo = 2 )
-// unit_test[13] find_uri( FindData = "GET/abc/def/ HTTP/1.0" / Result = false / ThreadNo = 3 )
-// unit_test[14] find_uri( FindData = "HEAD/abc/def/HTTP/1.0" / Result = false / ThreadNo = 4 )
-// unit_test[15] find_uri( FindData = "" / Result = false / ThreadNo = 5 )
- "GET /abc/def/ HTTP/1.0",
- "HEAD /abc/def/ghi/jkl/mno/pqr/stu/vwx/yz0/123/456/789/ HTTP/1.0",
- "GET/abc/def/ HTTP/1.0",
- "HEAD/abc/def/HTTP/1.0",
- "",
- };
-
- int edit_flag[5]
- = {
- 1,
- 1,
- 1,
- 1,
- 0,
- };
-
- bool result[5]
- = {
- true,
- true,
- false,
- false,
- false,
- };
-
- bool find_result;
-
- size_t buffer_len = 0;
- size_t uri_offset = 0;
- size_t uri_len = 0;
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_uri, '\0', 256 );
- uri_offset = 0;
- uri_len = 0;
- std::cout << "[Thread_" << thread_no << "] " << "String = [" << buffer[thread_no-1] << "]" << std::endl;
- if( edit_flag[thread_no-1] == 1){
- buffer[thread_no-1][strlen( buffer[thread_no-1] )] = '\r';
- }
- buffer_len = strlen( buffer[thread_no-1] );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [11] - [15]
- find_result = find_uri( (const char*)buffer[thread_no-1], buffer_len, uri_offset, uri_len );
- if( find_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( find_uri( (const char*)buffer[thread_no-1], buffer_len, uri_offset, uri_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- memcpy( disp_uri, buffer[thread_no-1] + uri_offset, uri_len );
- std::cout << "[Thread_" << thread_no << "] " << "URI Offset = [" << uri_offset << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "URI Length = [" << uri_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "URI String = [" << disp_uri << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
-
-void find_status_code_test(){
-
- int count = 1;
-
- char disp_status_code[256];
-
- char buffer_ok[FIND_STATUS_CODE_OK_STRING_NUM][256]
- = {
-// unit_test[01] find_status_code( FindData = "HTTP/1.0 000 abcdff" / Result = true )
-// unit_test[02] find_status_code( FindData = "HTTP/1.0 999 abcdff" / Result = true )
- "HTTP/1.0 000 abcdff",
- "HTTP/1.0 999 abcdff",
- };
- size_t size_OK[FIND_STATUS_CODE_OK_STRING_NUM][2];
-
- char buffer_ng[FIND_STATUS_CODE_NG_STRING_NUM][256]
- = {
-// unit_test[03] find_status_code( FindData = "HTTP/1.0 10 abcdff" / Result = false )
-// unit_test[04] find_status_code( FindData = "HTTP/1.0 1000 abcdff" / Result = false )
-// unit_test[05] find_status_code( FindData = "HTTP/1.0 aaa abcdff" / Result = false )
-// unit_test[06] find_status_code( FindData = "" / Result = false )
- "HTTP/1.0 10 abcdff",
- "HTTP/1.0 1000 abcdff",
- "HTTP/1.0 aaa abcdff",
- "",
- };
-
- size_t buffer_len = 0;
- size_t status_code_offset = 0;
- size_t status_code_len = 0;
-
- for( int i = 0; i < FIND_STATUS_CODE_OK_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_status_code, '\0', 256 );
- status_code_offset = 0;
- status_code_len = 0;
- std::cout << "String = [" << buffer_ok[i] << "] + [CR]" << std::endl;
- buffer_ok[i][strlen( buffer_ok[i] )] = '\r';
- buffer_len = strlen( buffer_ok[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [01] - [02]
- BOOST_CHECK( find_status_code( (const char*)buffer_ok[i], buffer_len, status_code_offset, status_code_len ) == true );
- memcpy( disp_status_code, buffer_ok[i] + status_code_offset, status_code_len );
- std::cout << "STATUS CODE Offset = [" << status_code_offset << "]" << std::endl;
- std::cout << "STATUS CODE Length = [" << status_code_len << "]" << std::endl;
- std::cout << "STATUS CODE String = [" << disp_status_code << "]" << std::endl;
- }
-
- for( int i = 0; i < FIND_STATUS_CODE_NG_STRING_NUM; i++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_status_code, '\0', 256 );
- status_code_offset = 0;
- status_code_len = 0;
- std::cout << "String = [" << buffer_ng[i] << "] + [CR]" << std::endl;
- buffer_ng[i][strlen( buffer_ng[i] )] = '\r';
- buffer_len = strlen( buffer_ng[i] );
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- // [03] - [06]
- BOOST_CHECK( find_status_code( (const char*)buffer_ng[i], buffer_len, status_code_offset, status_code_len ) == false );
- memcpy( disp_status_code, buffer_ng[i] + status_code_offset, status_code_len );
- std::cout << "STATUS CODE Offset = [" << status_code_offset << "]" << std::endl;
- std::cout << "STATUS CODE Length = [" << status_code_len << "]" << std::endl;
- std::cout << "STATUS CODE String = [" << disp_status_code << "]" << std::endl;
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_status_code, '\0', 256 );
- status_code_offset = 0;
- status_code_len = 0;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[07] find_status_code( FindData = NULL, Length = 0 / Result = false )
- BOOST_CHECK( find_status_code( NULL, buffer_len, status_code_offset, status_code_len ) == false );
- std::cout << "STATUS CODE Offset = [" << status_code_offset << "]" << std::endl;
- std::cout << "STATUS CODE Length = [" << status_code_len << "]" << std::endl;
- std::cout << "STATUS CODE String = [" << disp_status_code << "]" << std::endl;
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_status_code, '\0', 256 );
- status_code_offset = 0;
- status_code_len = 0;
- buffer_len = 0;
- std::cout << "String = [NULL]" << std::endl;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
-// unit_test[08] find_status_code( FindData = NULL, Length = 100 / Result = false )
- BOOST_CHECK( find_status_code( NULL, buffer_len, status_code_offset, status_code_len ) == false );
- std::cout << "STATUS CODE Offset = [" << status_code_offset << "]" << std::endl;
- std::cout << "STATUS CODE Length = [" << status_code_len << "]" << std::endl;
- std::cout << "STATUS CODE String = [" << disp_status_code << "]" << std::endl;
- count++;
-
-}
-
-void find_status_code_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
-
- char disp_status_code[256];
-
- char buffer[5][256]
- = {
-// unit_test[09] find_status_code( FindData = "HTTP/1.0 000 abcdff" / Result = true / ThreadNo = 1 )
-// unit_test[10] find_status_code( FindData = "HTTP/1.0 999 abcdff" / Result = true / ThreadNo = 2 )
-// unit_test[11] find_status_code( FindData = "HTTP/1.0 10 abcdff" / Result = false / ThreadNo = 3 )
-// unit_test[12] find_status_code( FindData = "HTTP/1.0 1000 abcdff" / Result = false / ThreadNo = 4 )
-// unit_test[13] find_status_code( FindData = "" / Result = false / ThreadNo = 5 )
- "HTTP/1.0 000 abcdff",
- "HTTP/1.0 999 abcdff",
- "HTTP/1.0 10 abcdff",
- "HTTP/1.0 1000 abcdff",
- "",
- };
-
- int edit_flag[5]
- = {
- 1,
- 1,
- 1,
- 1,
- 0,
- };
-
- bool result[5]
- = {
- true,
- true,
- false,
- false,
- false,
- };
-
- bool find_result;
-
- size_t buffer_len = 0;
- size_t status_code_offset = 0;
- size_t status_code_len = 0;
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_status_code, '\0', 256 );
- status_code_offset = 0;
- status_code_len = 0;
- std::cout << "[Thread_" << thread_no << "] " << "String = [" << buffer[thread_no-1] << "]" << std::endl;
- if( edit_flag[thread_no-1] == 1){
- buffer[thread_no-1][strlen( buffer[thread_no-1] )] = '\r';
- }
- buffer_len = strlen( buffer[thread_no-1] );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [09] - [13]
- find_result = find_status_code( (const char*)buffer[thread_no-1], buffer_len, status_code_offset, status_code_len );
- if( find_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( find_status_code( (const char*)buffer[thread_no-1], buffer_len, status_code_offset, status_code_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- memcpy( disp_status_code, buffer[thread_no-1] + status_code_offset, status_code_len );
- std::cout << "[Thread_" << thread_no << "] " << "STATUS CODE Offset = [" << status_code_offset << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "STATUS CODE Length = [" << status_code_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "STATUS CODE String = [" << disp_status_code << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
-void find_http_header_test(){
-
- int count = 1;
- int i = 0;
- int j = 0;
-
- char disp_http_header[4096];
-
- std::string http_header_name[10]
- = {
- "Cookie",
- "X-Forwarded-For",
- "Cookie2",
- "X-Forwarded-For2",
- "",
- "cookie",
- "COOKIE",
- "content-length",
- "Content-Length",
- "CONTENT-LENGTH",
- };
-
- bool result_1[10]
- = {
-// unit_test[01] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "Cookie", ReturnCode = "\r" / Result = true )
-// unit_test[02] find_http_header( FindData = "...X-Forwarded-For: 20.20.20.20...BlankLine...", HeaderName = "X-Forwarded-For", ReturnCode = "\r" / Result = true )
-// unit_test[03] find_http_header( FindData = "...BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\r" / Result = false )
-// unit_test[04] find_http_header( FindData = "...BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\r" / Result = false )
-// unit_test[05] find_http_header( FindData = "...BlankLine...", HeaderName = "", ReturnCode = "\r" / Result = true )
-// unit_test[06] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "cookie", ReturnCode = "\r" / Result = true )
-// unit_test[07] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "COOKIE", ReturnCode = "\r" / Result = true )
-// unit_test[08] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "content-length", ReturnCode = "\r" / Result = true )
-// unit_test[09] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "Content-Length", ReturnCode = "\r" / Result = true )
-// unit_test[10] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\r" / Result = true )
-
-// unit_test[11] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "Cookie", ReturnCode = "\n" / Result = true )
-// unit_test[12] find_http_header( FindData = "...X-Forwarded-For: 20.20.20.20...BlankLine...", HeaderName = "X-Forwarded-For", ReturnCode = "\n" / Result = true )
-// unit_test[13] find_http_header( FindData = "...BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\n" / Result = false )
-// unit_test[14] find_http_header( FindData = "...BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\n" / Result = false )
-// unit_test[15] find_http_header( FindData = "...BlankLine...", HeaderName = "", ReturnCode = "\n" / Result = true )
-// unit_test[16] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "cookie", ReturnCode = "\n" / Result = true )
-// unit_test[17] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "COOKIE", ReturnCode = "\n" / Result = true )
-// unit_test[18] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "content-length", ReturnCode = "\n" / Result = true )
-// unit_test[19] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "Content-Length", ReturnCode = "\n" / Result = true )
-// unit_test[20] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\n" / Result = true )
-
-// unit_test[21] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "Cookie", ReturnCode = "\r\n" / Result = true )
-// unit_test[22] find_http_header( FindData = "...X-Forwarded-For: 20.20.20.20...BlankLine...", HeaderName = "X-Forwarded-For", ReturnCode = "\r\n" / Result = true )
-// unit_test[23] find_http_header( FindData = "...BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\r\n" / Result = false )
-// unit_test[24] find_http_header( FindData = "...BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\r\n" / Result = false )
-// unit_test[25] find_http_header( FindData = "...BlankLine...", HeaderName = "", ReturnCode = "\r\n" / Result = true )
-// unit_test[26] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "cookie", ReturnCode = "\r\n" / Result = true )
-// unit_test[27] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "COOKIE", ReturnCode = "\r\n" / Result = true )
-// unit_test[28] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "content-length", ReturnCode = "\r\n" / Result = true )
-// unit_test[29] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "Content-Length", ReturnCode = "\r\n" / Result = true )
-// unit_test[30] find_http_header( FindData = "...CONTENT-LENGTH: 1000...BlankLine...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\r\n" / Result = true )
- true,
- true,
- false,
- false,
- true,
- true,
- true,
- true,
- true,
- true,
- };
-
- bool result_2[10]
- = {
-// unit_test[31] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "Cookie", ReturnCode = "\r" / Result = false )
-// unit_test[32] find_http_header( FindData = "BlankLine...X-Forwarded-For: 20.20.20.20...", HeaderName = "X-Forwarded-For", ReturnCode = "\r" / Result = false )
-// unit_test[33] find_http_header( FindData = "BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\r" / Result = false )
-// unit_test[34] find_http_header( FindData = "BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\r" / Result = false )
-// unit_test[35] find_http_header( FindData = "BlankLine...", HeaderName = "", ReturnCode = "\r" / Result = true )
-// unit_test[36] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "cookie", ReturnCode = "\r" / Result = false )
-// unit_test[37] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "COOKIE", ReturnCode = "\r" / Result = false )
-// unit_test[38] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "content-length", ReturnCode = "\r" / Result = false )
-// unit_test[39] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "Content-Length", ReturnCode = "\r" / Result = false )
-// unit_test[40] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\r" / Result = false )
-
-// unit_test[41] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "Cookie", ReturnCode = "\n" / Result = false )
-// unit_test[42] find_http_header( FindData = "BlankLine...X-Forwarded-For: 20.20.20.20...", HeaderName = "X-Forwarded-For", ReturnCode = "\n" / Result = false )
-// unit_test[43] find_http_header( FindData = "BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\n" / Result = false )
-// unit_test[44] find_http_header( FindData = "BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\n" / Result = false )
-// unit_test[45] find_http_header( FindData = "BlankLine...", HeaderName = "", ReturnCode = "\n" / Result = true )
-// unit_test[46] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "cookie", ReturnCode = "\n" / Result = false )
-// unit_test[47] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "COOKIE", ReturnCode = "\n" / Result = false )
-// unit_test[48] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "content-length", ReturnCode = "\n" / Result = false )
-// unit_test[49] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "Content-Length", ReturnCode = "\n" / Result = false )
-// unit_test[50] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\n" / Result = false )
-
-// unit_test[51] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "Cookie", ReturnCode = "\r\n" / Result = false )
-// unit_test[52] find_http_header( FindData = "BlankLine...X-Forwarded-For: 20.20.20.20...", HeaderName = "X-Forwarded-For", ReturnCode = "\r\n" / Result = false )
-// unit_test[53] find_http_header( FindData = "BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2", ReturnCode = "\r\n" / Result = false )
-// unit_test[54] find_http_header( FindData = "BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2", ReturnCode = "\r\n" / Result = false )
-// unit_test[55] find_http_header( FindData = "BlankLine...", HeaderName = "", ReturnCode = "\r\n" / Result = true )
-// unit_test[56] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "cookie", ReturnCode = "\r\n" / Result = false )
-// unit_test[57] find_http_header( FindData = "BlankLine...Cookie: 10.10.10.10:11111...", HeaderName = "COOKIE", ReturnCode = "\r\n" / Result = false )
-// unit_test[58] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "content-length", ReturnCode = "\r\n" / Result = false )
-// unit_test[59] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "Content-Length", ReturnCode = "\r\n" / Result = false )
-// unit_test[60] find_http_header( FindData = "BlankLine...CONTENT-LENGTH: 1000...", HeaderName = "CONTENT-LENGTH", ReturnCode = "\r\n" / Result = false )
- false,
- false,
- false,
- false,
- true,
- false,
- false,
- false,
- false,
- false,
- };
-
- char buffer_all_1[3][4096];
- char buffer_all_2[3][4096];
-
- char buffer_line_1[8][256]
- = {
- "GET /abc/def/ HTTP/1.0",
- "Cookie: 10.10.10.10:11111",
- "X-Forwarded-For: 20.20.20.20",
- "CONTENT-LENGTH: 1000",
- "",
- "GET /abc/def/ HTTP/1.0",
- "Cookie2: 30.30.30.30:33333",
- "X-Forwarded-For2: 40.40.40.40",
- };
-
-
- char buffer_line_2[8][256]
- = {
- "GET /abc/def/ HTTP/1.0",
- "",
- "Cookie: 10.10.10.10:11111",
- "X-Forwarded-For: 20.20.20.20",
- "CONTENT-LENGTH: 1000",
- "GET /abc/def/ HTTP/1.0",
- "Cookie2: 30.30.30.30:33333",
- "X-Forwarded-For2: 40.40.40.40",
- };
-
- size_t buffer_len = 0;
- size_t http_header_offset = 0;
- size_t http_header_len = 0;
-
- memset( buffer_all_1, '\0', sizeof(buffer_all_1));
- memset( buffer_all_2, '\0', sizeof(buffer_all_2));
- for( i = 0; i < 8; i++ ){
- for( j = 0; j < 3; j++ ){
- memcpy( buffer_all_1[j] + strlen( buffer_all_1[j] ), buffer_line_1[i], strlen( buffer_line_1[i] ));
- if( j == 0 || j == 2 ){
- buffer_all_1[j][strlen( buffer_all_1[j] )] = '\r';
- }
- if( j == 1 || j == 2 ){
- buffer_all_1[j][strlen( buffer_all_1[j] )] = '\n';
- }
-
- }
- }
-
- for( i = 0; i < 8; i++ ){
- for( j = 0; j < 3; j++ ){
- memcpy( buffer_all_2[j] + strlen( buffer_all_2[j] ), buffer_line_2[i], strlen( buffer_line_1[i] ));
- if( j == 0 || j == 2 ){
- buffer_all_2[j][strlen( buffer_all_2[j] )] = '\r';
- }
- if( j == 1 || j == 2 ){
- buffer_all_2[j][strlen( buffer_all_2[j] )] = '\n';
- }
-
- }
- }
-
-
- for( i = 0; i < 3; i++ ){
- buffer_len = strlen( buffer_all_1[i] );
- for( j = 0; j < 10; j++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- http_header_offset = 0;
- http_header_len = 0;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "Http Header Name = [" << http_header_name[j] << "]" << std::endl;
- std::cout << "Http Header Name Length = [" << http_header_name[j].length() << "]" << std::endl;
- // [01] - [30]
- BOOST_CHECK( find_http_header( (const char*)buffer_all_1[i], buffer_len, http_header_name[j], http_header_offset, http_header_len ) == result_1[j] );
- memset( disp_http_header, '\0', sizeof(disp_http_header));
- memcpy( disp_http_header, buffer_all_1[i] + http_header_offset, http_header_len );
- std::cout << "Http Header Offset = [" << http_header_offset << "]" << std::endl;
- std::cout << "Http Header Length = [" << http_header_len << "]" << std::endl;
- std::cout << "Http Header String = [" << disp_http_header << "]" << std::endl;
- }
- }
-
- for( i = 0; i < 3; i++ ){
- buffer_len = strlen( buffer_all_2[i] );
- for( j = 0; j < 10; j++, count++ ){
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- http_header_offset = 0;
- http_header_len = 0;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "Http Header Name = [" << http_header_name[j] << "]" << std::endl;
- std::cout << "Http Header Name Length = [" << http_header_name[j].length() << "]" << std::endl;
- // [31] - [60]
- BOOST_CHECK( find_http_header( (const char*)buffer_all_2[i], buffer_len, http_header_name[j], http_header_offset, http_header_len ) == result_2[j] );
- memset( disp_http_header, '\0', sizeof(disp_http_header));
- memcpy( disp_http_header, buffer_all_2[i] + http_header_offset, http_header_len );
- std::cout << "Http Header Offset = [" << http_header_offset << "]" << std::endl;
- std::cout << "Http Header Length = [" << http_header_len << "]" << std::endl;
- std::cout << "Http Header String = [" << disp_http_header << "]" << std::endl;
- }
- }
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- http_header_offset = 0;
- http_header_len = 0;
- buffer_len = 0;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "Http Header Name = [" << http_header_name[0] << "]" << std::endl;
- std::cout << "Http Header Name Length = [" << http_header_name[0].length() << "]" << std::endl;
-// unit_test[61] find_http_header( FindData = NULL, HeaderName = "Cookie", Length = 0 / Result = false )
- BOOST_CHECK( find_http_header( NULL, buffer_len, http_header_name[0], http_header_offset, http_header_len ) == false );
- memset( disp_http_header, '\0', sizeof(disp_http_header));
- std::cout << "Http Header Offset = [" << http_header_offset << "]" << std::endl;
- std::cout << "Http Header Length = [" << http_header_len << "]" << std::endl;
- std::cout << "Http Header String = [" << disp_http_header << "]" << std::endl;
- count++;
-
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- http_header_offset = 0;
- http_header_len = 0;
- buffer_len = 100;
- std::cout << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "Http Header Name = [" << http_header_name[0] << "]" << std::endl;
- std::cout << "Http Header Name Length = [" << http_header_name[0].length() << "]" << std::endl;
-// unit_test[62] find_http_header( FindData = NULL, HeaderName = "Cookie", Length = 100 / Result = false )
- BOOST_CHECK( find_http_header( NULL, buffer_len, http_header_name[0], http_header_offset, http_header_len ) == false );
- memset( disp_http_header, '\0', sizeof(disp_http_header));
- std::cout << "Http Header Offset = [" << http_header_offset << "]" << std::endl;
- std::cout << "Http Header Length = [" << http_header_len << "]" << std::endl;
- std::cout << "Http Header String = [" << disp_http_header << "]" << std::endl;
- count++;
-
-}
-
-void find_http_header_test_thread( int thread_no, bool* ret ){
-
- boost::xtime start_time;
- boost::xtime end_time;
-
- int count = 1;
- int i = 0;
-
- char disp_http_header[4096];
-
- std::string http_header_name[5]
- = {
-// unit_test[63] find_http_header( FindData = "...Cookie: 10.10.10.10:11111...BlankLine...", HeaderName = "Cookie" / Result = true / ThreadNo = 1 )
-// unit_test[64] find_http_header( FindData = "...X-Forwarded-For: 20.20.20.20...BlankLine...", HeaderName = "X-Forwarded-For" / Result = true / ThreadNo = 2 )
-// unit_test[65] find_http_header( FindData = "...BlankLine...Cookie2: 30.30.30.30:33333...", HeaderName = "Cookie2" / Result = false / ThreadNo = 3 )
-// unit_test[66] find_http_header( FindData = "...BlankLine...X-Forwarded-For2: 40.40.40.40...", HeaderName = "X-Forwarded-For2" / Result = false / ThreadNo = 4 )
-// unit_test[67] find_http_header( FindData = "...BlankLine...", HeaderName = "" / Result = true / ThreadNo = 5 )
- "Cookie",
- "X-Forwarded-For",
- "Cookie2",
- "X-Forwarded-For2",
- "",
- };
-
- bool result[5]
- = {
- true,
- true,
- false,
- false,
- true,
- };
-
- char buffer_all[4096];
-
- char buffer_line[8][256]
- = {
- "GET /abc/def/ HTTP/1.0",
- "Cookie: 10.10.10.10:11111",
- "X-Forwarded-For: 20.20.20.20",
- "CONTENT-LENGTH: 1000",
- "",
- "GET /abc/def/ HTTP/1.0",
- "Cookie2: 30.30.30.30:33333",
- "X-Forwarded-For2: 40.40.40.40",
- };
-
- bool find_result;
-
- size_t buffer_len = 0;
- size_t http_header_offset = 0;
- size_t http_header_len = 0;
-
- memset( buffer_all, '\0', sizeof(buffer_all));
- for( i = 0; i < 8; i++ ){
- memcpy( buffer_all + strlen( buffer_all ), buffer_line[i], strlen( buffer_line[i] ));
- buffer_all[strlen( buffer_all )] = '\r';
- }
-
- std::cout << "[Thread_" << thread_no << "] ";
- std::cout.width(2);
- std::cout.fill('0');
- std::cout << count << "---------------------------------------" << std::endl;
- memset( disp_http_header, '\0', sizeof(disp_http_header));
- http_header_offset = 0;
- http_header_len = 0;
- buffer_len = strlen( buffer_all );
- std::cout << "[Thread_" << thread_no << "] " << "Length = [" << buffer_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Http Header Name = [" << http_header_name[thread_no-1] << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Http Header Name Length = [" << http_header_name[thread_no-1].length() << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Wait..." << std::endl;
- {
- boost::mutex::scoped_lock lk( sync_mutex );
- sync_condition.wait( lk );
- }
- boost::xtime_get(&start_time, boost::TIME_UTC);
- // [63] - [67]
- find_result = find_http_header( (const char*)buffer_all, buffer_len, http_header_name[thread_no-1], http_header_offset, http_header_len );
- if( find_result == result[thread_no-1] ){
- *ret = true;
- }
- else{
- *ret = false;
- }
-// BOOST_CHECK( find_http_header( (const char*)buffer_all, buffer_len, http_header_name[thread_no-1], http_header_offset, http_header_len ) == result[thread_no-1] );
- boost::xtime_get(&end_time, boost::TIME_UTC);
- memcpy( disp_http_header, buffer_all + http_header_offset, http_header_len );
-
- std::cout << "[Thread_" << thread_no << "] " << "Http Header Offset = [" << http_header_offset << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Http Header Length = [" << http_header_len << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "Http Header String = [" << disp_http_header << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "StartTime = [" << start_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "EndTime = [" << end_time.nsec << "]" << std::endl;
- std::cout << "[Thread_" << thread_no << "] " << "CheckEnd" << std::endl;
-
-}
-
+protocol_module_cinsert_test() : protocol_module_cinsert(){}
+~protocol_module_cinsert_test(){}
};
//--test functions--
-void check_http_method_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->check_http_method_test_thread( thread_no, ret );
- }
-
-}
-void check_http_method_test(){
-
- bool thread_1;
- bool thread_2;
- bool thread_3;
- bool thread_4;
- bool thread_5;
-
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
-
- BOOST_MESSAGE( "----- check_http_method test start -----" );
- http_protocol_module_base_test_1.check_http_method_test();
- BOOST_MESSAGE( "----- check_http_method test end -----" );
-
- BOOST_MESSAGE( "----- check_http_method test multi thread start -----" );
- boost::thread t1( boost::bind( &check_http_method_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &check_http_method_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &check_http_method_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &check_http_method_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &check_http_method_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
-
- sleep(1);
-
- http_protocol_module_base_test_1.sync_condition.notify_all();
-
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
-
- BOOST_CHECK( thread_1 == true );
- BOOST_CHECK( thread_2 == true );
- BOOST_CHECK( thread_3 == true );
- BOOST_CHECK( thread_4 == true );
- BOOST_CHECK( thread_5 == true );
-
- BOOST_MESSAGE( "----- check_http_method test multi thread end -----" );
-}
-//-------------------------------------------------------------------
-void check_http_version_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->check_http_version_test_thread( thread_no, ret );
- }
-
-}
-void check_http_version_test(){
-
- bool thread_1;
- bool thread_2;
- bool thread_3;
- bool thread_4;
- bool thread_5;
-
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
-
- BOOST_MESSAGE( "----- check_http_version test start -----" );
- http_protocol_module_base_test_1.check_http_version_test();
- BOOST_MESSAGE( "----- check_http_version test end -----" );
-
- BOOST_MESSAGE( "----- check_http_version test multi thread start -----" );
- boost::thread t1( boost::bind( &check_http_version_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &check_http_version_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &check_http_version_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &check_http_version_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &check_http_version_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
-
- sleep(1);
-
- http_protocol_module_base_test_1.sync_condition.notify_all();
-
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
-
- BOOST_CHECK( thread_1 == true );
- BOOST_CHECK( thread_2 == true );
- BOOST_CHECK( thread_3 == true );
- BOOST_CHECK( thread_4 == true );
- BOOST_CHECK( thread_5 == true );
-
- BOOST_MESSAGE( "----- check_http_version test multi thread end -----" );
-}
-//-------------------------------------------------------------------
-void check_status_code_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->check_status_code_test_thread( thread_no, ret );
- }
-
-}
-void check_status_code_test(){
-
- bool thread_1;
- bool thread_2;
- bool thread_3;
- bool thread_4;
- bool thread_5;
-
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
-
- BOOST_MESSAGE( "----- check_status_code test start -----" );
- http_protocol_module_base_test_1.check_status_code_test();
- BOOST_MESSAGE( "----- check_status_code test end -----" );
-
- BOOST_MESSAGE( "----- check_status_code test multi thread start -----" );
- boost::thread t1( boost::bind( &check_status_code_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &check_status_code_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &check_status_code_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &check_status_code_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &check_status_code_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
-
- sleep(1);
-
- http_protocol_module_base_test_1.sync_condition.notify_all();
-
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
-
- BOOST_CHECK( thread_1 == true );
- BOOST_CHECK( thread_2 == true );
- BOOST_CHECK( thread_3 == true );
- BOOST_CHECK( thread_4 == true );
- BOOST_CHECK( thread_5 == true );
-
- BOOST_MESSAGE( "----- check_status_code test multi thread end -----" );
-}
-//-------------------------------------------------------------------
-void find_uri_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->find_uri_test_thread( thread_no, ret );
- }
-
-}
-void find_uri_test(){
-
+//void check_http_method_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret )
+//{
+//}
+void check_http_method_test()
+{
bool thread_1;
bool thread_2;
bool thread_3;
bool thread_4;
bool thread_5;
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
+// http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
- BOOST_MESSAGE( "----- find_uri test start -----" );
- http_protocol_module_base_test_1.find_uri_test();
- BOOST_MESSAGE( "----- find_uri test end -----" );
+// BOOST_MESSAGE( "----- check_http_method test start -----" );
+// http_protocol_module_base_test_1.check_http_method_test();
+// BOOST_MESSAGE( "----- check_http_method test end -----" );
- BOOST_MESSAGE( "----- find_uri test multi thread start -----" );
- boost::thread t1( boost::bind( &find_uri_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &find_uri_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &find_uri_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &find_uri_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &find_uri_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
+// BOOST_MESSAGE( "----- check_http_method test multi thread start -----" );
+// boost::thread t1( boost::bind( &check_http_method_test_thread,
+// &http_protocol_module_base_test_1, 1, &thread_1));
+// boost::thread t2( boost::bind( &check_http_method_test_thread,
+// &http_protocol_module_base_test_1, 2, &thread_2));
+// boost::thread t3( boost::bind( &check_http_method_test_thread,
+// &http_protocol_module_base_test_1, 3, &thread_3));
+// boost::thread t4( boost::bind( &check_http_method_test_thread,
+// &http_protocol_module_base_test_1, 4, &thread_4));
+// boost::thread t5( boost::bind( &check_http_method_test_thread,
+// &http_protocol_module_base_test_1, 5, &thread_5));
- sleep(1);
+// sleep(1);
- http_protocol_module_base_test_1.sync_condition.notify_all();
+// http_protocol_module_base_test_1.sync_condition.notify_all();
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
+// t1.join();
+// t2.join();
+// t3.join();
+// t4.join();
+// t5.join();
BOOST_CHECK( thread_1 == true );
BOOST_CHECK( thread_2 == true );
BOOST_CHECK( thread_4 == true );
BOOST_CHECK( thread_5 == true );
- BOOST_MESSAGE( "----- find_uri test multi thread end -----" );
+// BOOST_MESSAGE( "----- check_http_method test multi thread end -----" );
}
//-------------------------------------------------------------------
-void find_status_code_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->find_status_code_test_thread( thread_no, ret );
- }
-
-}
-void find_status_code_test(){
-
- bool thread_1;
- bool thread_2;
- bool thread_3;
- bool thread_4;
- bool thread_5;
-
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
-
- BOOST_MESSAGE( "----- find_status_code test start -----" );
- http_protocol_module_base_test_1.find_status_code_test();
- BOOST_MESSAGE( "----- find_status_code test end -----" );
-
- BOOST_MESSAGE( "----- find_status_code test multi thread start -----" );
- boost::thread t1( boost::bind( &find_status_code_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &find_status_code_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &find_status_code_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &find_status_code_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &find_status_code_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
-
- sleep(1);
-
- http_protocol_module_base_test_1.sync_condition.notify_all();
-
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
-
- BOOST_CHECK( thread_1 == true );
- BOOST_CHECK( thread_2 == true );
- BOOST_CHECK( thread_3 == true );
- BOOST_CHECK( thread_4 == true );
- BOOST_CHECK( thread_5 == true );
-
- BOOST_MESSAGE( "----- find_status_code test multi thread end -----" );
-}
-//-------------------------------------------------------------------
-void find_http_header_test_thread( http_protocol_module_base_test* http_protocol_module_base_test_1, int thread_no, bool* ret ){
-
- for( int i = 0; i < THREAD_LOOP_NUM; i++ ){
- http_protocol_module_base_test_1->find_http_header_test_thread( thread_no, ret );
- }
-
-}
-void find_http_header_test(){
-
- bool thread_1;
- bool thread_2;
- bool thread_3;
- bool thread_4;
- bool thread_5;
-
- http_protocol_module_base_test http_protocol_module_base_test_1( "cinsert" );
-
- BOOST_MESSAGE( "----- find_http_header test start -----" );
- http_protocol_module_base_test_1.find_http_header_test();
- BOOST_MESSAGE( "----- find_http_header test end -----" );
-
- BOOST_MESSAGE( "----- find_http_header test multi thread start -----" );
- boost::thread t1( boost::bind( &find_http_header_test_thread,
- &http_protocol_module_base_test_1, 1, &thread_1));
- boost::thread t2( boost::bind( &find_http_header_test_thread,
- &http_protocol_module_base_test_1, 2, &thread_2));
- boost::thread t3( boost::bind( &find_http_header_test_thread,
- &http_protocol_module_base_test_1, 3, &thread_3));
- boost::thread t4( boost::bind( &find_http_header_test_thread,
- &http_protocol_module_base_test_1, 4, &thread_4));
- boost::thread t5( boost::bind( &find_http_header_test_thread,
- &http_protocol_module_base_test_1, 5, &thread_5));
-
- sleep(1);
-
- http_protocol_module_base_test_1.sync_condition.notify_all();
-
- t1.join();
- t2.join();
- t3.join();
- t4.join();
- t5.join();
-
- BOOST_CHECK( thread_1 == true );
- BOOST_CHECK( thread_2 == true );
- BOOST_CHECK( thread_3 == true );
- BOOST_CHECK( thread_4 == true );
- BOOST_CHECK( thread_5 == true );
-
- BOOST_MESSAGE( "----- find_http_header test multi thread end -----" );
-}
-//-------------------------------------------------------------------
-// void multi_thread_test_t1(){
-//
-// for( int i = 0; i < THREAD_01_LOOP_NUM; i++ ){
-// BOOST_CHECK( true );
-// }
-//
-// }
-// void multi_thread_test_t2(){
-//
-// for( int i = 0; i < THREAD_02_LOOP_NUM; i++ ){
-// BOOST_CHECK( true );
-// }
-//
-// }
-// void multi_thread_test(){
-//
-// boost::thread t1( &multi_thread_test_t1);
-// boost::thread t2( &multi_thread_test_t2);
-//
-// t1.join();
-// t2.join();
-//
-// }
-//-------------------------------------------------------------------
-
//-------------------------------------------------------------------
test_suite* init_unit_test_suite( int argc, char* argv[] ){
test_suite* ts = BOOST_TEST_SUITE( "http_protocol_module_base class test" );
ts->add( BOOST_TEST_CASE( &check_http_method_test ) );
- ts->add( BOOST_TEST_CASE( &check_http_version_test ) );
- ts->add( BOOST_TEST_CASE( &check_status_code_test ) );
- ts->add( BOOST_TEST_CASE( &find_uri_test ) );
- ts->add( BOOST_TEST_CASE( &find_status_code_test ) );
- ts->add( BOOST_TEST_CASE( &find_http_header_test ) );
-
-// ts->add( BOOST_TEST_CASE( &multi_thread_test ) );
framework::master_test_suite().add( ts );
OSDN Git Service
