Menu ▾ ▴

[r322]: / framework / branches / cache / worker_thread.cpp  Maximize  Restore  History

Download this file

116 lines (91 with data), 2.1 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
#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";

}



static void deflate(FCgiIO &io,string const &out)

{

	using namespace boost::iostreams;

	gzip_params params;

	long level,length;



	if((level=global_config.lval("gzip.level",-1))!=-1){

		params.level=level;

	}		



	filtering_ostream zstream;



	if((length=global_config.lval("gzip.buffer",-1))!=-1){

		zstream.push(gzip_compressor(params,length));

	}

	else {

		zstream.push(gzip_compressor(params));

	}



	zstream.push(io);

	zstream<<out;

}



void worker_thread::run(FCGX_Request *fcgi)

{

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

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

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



	out.clear();

	out.reserve(global_config.lval("performance.textalloc",65500));

	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(cppcms_error const &e) {

		string msg=e.what();

		set_header(new HTTPStatusHeader(500,msg));

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

	}





	if(gzip) {

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

		*io<<*response_header;

		if(gzip_done)

			*io<<out;

		else

			deflate(*io,out);

	}	

	else {

		*io<<*response_header;

		*io<<out;

	}



	// Clean Up

	out.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;

	}

}



worker_thread::~worker_thread()

{

}







}
MongoDB Logo MongoDB