added buffers to fastcgi streambufs. It gains compatibility with normal streambuf manipulations at the cost of performance (according to comments in fcgi devkit). The performance lost should not be disastrous, though.

1 files changed, 4 insertions, 1 deletions

diff --git a/src/fastcgi.cc b/src/fastcgi.cc
index 6285370..8b7668c 100644
--- a/src/fastcgi.cc
+++ b/src/fastcgi.cc
@@ -16,49 +16,52 @@ namespace kingate {
                     _initialized = true;
                 }
                 sock = FCGX_OpenSocket(s,bl);
                 if(sock<0)
                     throw exception(CODEPOINT,"failed to FCGX_OpenSocket(");
                 // TODO: check if there is a ':', not if it starts with ':'
                 if(*s != ':')
                     if(chmod(s,0777)) // XXX: configurable.
                         throw exception(CODEPOINT,"failed to chmod()");
             }
         fcgi_socket::fcgi_socket(int s)
             : sock(0) {
                 if(!_initialized) {
                     if( FCGX_Init() )
                         throw exception(CODEPOINT,"failed to FCGX_Init()");
                     _initialized = true;
                 }
             }
         fcgi_socket::~fcgi_socket() {
             if(sock>=0)
                 close(sock);
         }
 
         fcgi_interface::fcgi_interface(fcgi_socket& s,int f)
-            : sin(&sbin), sout(&sbout), serr(&sberr) {
+            : sbin(buf_sbin,sizeof(buf_sbin)),
+            sbout(buf_sbout,sizeof(buf_sbout)),
+            sberr(buf_sberr,sizeof(buf_sberr)),
+            sin(&sbin), sout(&sbout), serr(&sberr) {
                 if( FCGX_InitRequest(&request,s.sock,f) )
                     throw exception(CODEPOINT,"failed to FCGX_InitRequest()");
                 if( FCGX_Accept_r(&request) )
                     throw exception(CODEPOINT,"failed to FCGX_Accept_r()");
                 sbin.attach(request.in);
                 sbout.attach(request.out);
                 sberr.attach(request.err);
                 for(char **p = request.envp; *p; p++) {
                     const char *e = strchr(*p,'=');
                     if(!e){
                         // XXX: check if we have it already?
                         metavars[*p] = string(0);
                     }else{
                         int l = e-*p; e++;
                         // XXX: check if we have it already?
                         metavars[string(*p,l)]=e;
                     }
                 }
             }
         fcgi_interface::~fcgi_interface() {
             sout.flush();
             serr.flush();
             FCGX_Finish_r(&request);
         }