summaryrefslogtreecommitdiffabout
path: root/src/fastcgi.cc
Unidiff
Diffstat (limited to 'src/fastcgi.cc') (more/less context) (ignore whitespace changes)
-rw-r--r--src/fastcgi.cc19
1 files changed, 12 insertions, 7 deletions
diff --git a/src/fastcgi.cc b/src/fastcgi.cc
index 8b7668c..63b59f8 100644
--- a/src/fastcgi.cc
+++ b/src/fastcgi.cc
@@ -1,48 +1,53 @@
1#include <unistd.h> 1#include <unistd.h>
2#include <sys/types.h> 2#include <sys/types.h>
3#include <sys/stat.h> 3#include <sys/stat.h>
4#include <fastcgi.h>
4#include "kingate/fastcgi.h" 5#include "kingate/fastcgi.h"
5#include "kingate/exception.h" 6#include "kingate/exception.h"
6 7
7namespace kingate { 8namespace kingate {
8 9
9 bool fcgi_socket::_initialized = false; 10 bool fcgi_socket::_initialized = false;
10 11
11 fcgi_socket::fcgi_socket(const char *s,int bl) 12 fcgi_socket::fcgi_socket(const char *s,int bl)
12 : sock(-1) { 13 : sock(-1) {
13 if(!_initialized) { 14 if(!_initialized) {
14 if( FCGX_Init() ) 15 if( FCGX_Init() )
15 throw exception(CODEPOINT,"failed to FCGX_Init()"); 16 throw exception(CODEPOINT,"failed to FCGX_Init()");
16 _initialized = true; 17 _initialized = true;
17 } 18 }
18 sock = FCGX_OpenSocket(s,bl); 19 if(!s) {
19 if(sock<0) 20 sock = FCGI_LISTENSOCK_FILENO;
20 throw exception(CODEPOINT,"failed to FCGX_OpenSocket("); 21 }else{
21 // TODO: check if there is a ':', not if it starts with ':' 22 sock = FCGX_OpenSocket(s,bl);
22 if(*s != ':') 23 if(sock<0)
23 if(chmod(s,0777)) // XXX: configurable. 24 throw exception(CODEPOINT,"failed to FCGX_OpenSocket(");
24 throw exception(CODEPOINT,"failed to chmod()"); 25 // TODO: check if there is a ':', not if it starts with ':'
26 if(*s != ':')
27 if(chmod(s,0777)) // XXX: configurable.
28 throw exception(CODEPOINT,"failed to chmod()");
29 }
25 } 30 }
26 fcgi_socket::fcgi_socket(int s) 31 fcgi_socket::fcgi_socket(int s)
27 : sock(0) { 32 : sock(0) {
28 if(!_initialized) { 33 if(!_initialized) {
29 if( FCGX_Init() ) 34 if( FCGX_Init() )
30 throw exception(CODEPOINT,"failed to FCGX_Init()"); 35 throw exception(CODEPOINT,"failed to FCGX_Init()");
31 _initialized = true; 36 _initialized = true;
32 } 37 }
33 } 38 }
34 fcgi_socket::~fcgi_socket() { 39 fcgi_socket::~fcgi_socket() {
35 if(sock>=0) 40 if(sock>=0)
36 close(sock); 41 close(sock);
37 } 42 }
38 43
39 fcgi_interface::fcgi_interface(fcgi_socket& s,int f) 44 fcgi_interface::fcgi_interface(fcgi_socket& s,int f)
40 : sbin(buf_sbin,sizeof(buf_sbin)), 45 : sbin(buf_sbin,sizeof(buf_sbin)),
41 sbout(buf_sbout,sizeof(buf_sbout)), 46 sbout(buf_sbout,sizeof(buf_sbout)),
42 sberr(buf_sberr,sizeof(buf_sberr)), 47 sberr(buf_sberr,sizeof(buf_sberr)),
43 sin(&sbin), sout(&sbout), serr(&sberr) { 48 sin(&sbin), sout(&sbout), serr(&sberr) {
44 if( FCGX_InitRequest(&request,s.sock,f) ) 49 if( FCGX_InitRequest(&request,s.sock,f) )
45 throw exception(CODEPOINT,"failed to FCGX_InitRequest()"); 50 throw exception(CODEPOINT,"failed to FCGX_InitRequest()");
46 if( FCGX_Accept_r(&request) ) 51 if( FCGX_Accept_r(&request) )
47 throw exception(CODEPOINT,"failed to FCGX_Accept_r()"); 52 throw exception(CODEPOINT,"failed to FCGX_Accept_r()");
48 sbin.attach(request.in); 53 sbin.attach(request.in);