Menu ▾ ▴

[r344]: / framework / trunk / worker_thread.cpp  Maximize  Restore  History

Download this file

118 lines (96 with data), 2.2 kB 

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
#include "worker_thread.h"

#include "global_config.h"

#include "thread_cache.h"



#include <boost/iostreams/filtering_stream.hpp>

#include <boost/iostreams/filter/gzip.hpp>



using namespace cgicc;

namespace cppcms {



void worker_thread::main()

{

	out="<h1>Hello World</h2>\n";

}





void worker_thread::run(FCGX_Request *fcgi)

{

	io = auto_ptr<fcgi_stream>(new fcgi_stream(*fcgi));

	cgi = auto_ptr<Cgicc>(new Cgicc(&*io));

	env=&(cgi->getEnvironment());



	other_headers.clear();

	out.clear();

	out.reserve(global_config.lval("server.buffer_reserve",16000));

	cache.reset();



	set_header(new HTTPHTMLHeader);



	gzip=gzip_done=false;

	char *ptr;

	if((ptr=FCGX_GetParam("HTTP_ACCEPT_ENCODING",fcgi->envp))!=NULL) {

		if(strstr(ptr,"gzip")!=NULL) {

			gzip=global_config.lval("gzip.enable",0);

		}

	}



	try {

		/**********/

		main();

		/**********/

		if(response_header.get() == NULL) {

			throw cppcms_error("Looks like a bug");

		}

	}

	catch(std::exception const &e) {

		string msg=e.what();

		set_header(new HTTPStatusHeader(500,msg));

		out="<html><body><p>"+msg+"</p><body></html>";

		gzip=gzip_done=false;

		other_headers.clear();

	}



	if(global_config.lval("server.disable_xpowered_by",0)==0) {

		add_header("X-Powered-By: CppCMS/0.0alpha1");

	}



	for(list<string>::iterator h=other_headers.begin();h!=other_headers.end();h++) {

		*io<<*h<<"\r\n";

	}



	if(gzip) {

		if(out.size()>0) {

			if(gzip_done){

				*io<<"Content-Length: "<<out.size()<<"\r\n";

			}

			*io<<"Content-Encoding: gzip\r\n";

			*io<<*response_header;

			if(gzip_done) {

				*io<<out;

			}

			else

				deflate(out,*io);

		}

		else {

			*io<<*response_header;

		}

	}	

	else {

		*io<<"Content-Length: "<<out.size()<<"\r\n";

		*io<<*response_header;

		*io<<out;

	}



	// Clean Up

	out.clear();

	other_headers.clear();

	response_header.reset();

	cgi.reset();

	io.reset();

        FCGX_Finish_r(fcgi);

}



void worker_thread::init_internal()

{

	string backend=global_config.sval("cache.backend","none");

	caching_module=NULL;

	if(backend=="threaded") {

		static thread_cache tc;

		tc.set_size(global_config.lval("cache.limit",100));

		caching_module=&tc;

		if(global_config.lval("cache.debug",0)==1) {

			tc.set_debug_mode(2);

		}

	}

}



worker_thread::~worker_thread()

{

}







}
MongoDB Logo MongoDB