Menu ▾ ▴

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

Download this file

109 lines (86 with data), 2.0 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
#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(cgicc_connection &cgi_conn)

{

	cgi=&cgi_conn.cgi();

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

	ostream &cout=cgi_conn.cout();



	other_headers.clear();

	out.clear();

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

	cache.reset();



	set_header(new HTTPHTMLHeader);



	gzip=gzip_done=false;

	string encoding;



	if((encoding=cgi_conn.env("HTTP_ACCEPT_ENCODING"))!="") {

		if(strstr(encoding.c_str(),"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++) {

		cout<<*h<<"\n";

	}



	if(gzip) {

		if(out.size()>0) {

			if(gzip_done){

				cout<<"Content-Length: "<<out.size()<<"\n";

			}

			cout<<"Content-Encoding: gzip\n";

			cout<<*response_header;

			if(gzip_done) {

				cout<<out;

			}

			else

				deflate(out,cout);

		}

		else {

			cout<<*response_header;

		}

	}

	else {

		cout<<"Content-Length: "<<out.size()<<"\n";

		cout<<*response_header;

		cout<<out;

	}



	// Clean Up

	out.clear();

	other_headers.clear();

	response_header.reset();

	cgi=NULL;

}



void worker_thread::init_internal()

{

	caching_module=settings.cache.get();

}



worker_thread::~worker_thread()

{

	settings.cache.del(caching_module);

}







}
MongoDB Logo MongoDB