Compare commits
	
		
			2 Commits
		
	
	
		
			22d50ed4bd
			...
			c42f27e961
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 
						
						
							
						
						c42f27e961
	
				 | 
					
					
						|||
| 
						
						
							
						
						de8ab406f6
	
				 | 
					
					
						
@@ -155,14 +155,14 @@ int cache_process() {
 | 
				
			|||||||
                            compress_compress_mode(&comp_ctx, COMPRESS_GZ,buf + read - avail_in, &avail_in,
 | 
					                            compress_compress_mode(&comp_ctx, COMPRESS_GZ,buf + read - avail_in, &avail_in,
 | 
				
			||||||
                                                   comp_buf, &avail_out, feof(file));
 | 
					                                                   comp_buf, &avail_out, feof(file));
 | 
				
			||||||
                            fwrite(comp_buf, 1, CACHE_BUF_SIZE - avail_out, comp_file_gz);
 | 
					                            fwrite(comp_buf, 1, CACHE_BUF_SIZE - avail_out, comp_file_gz);
 | 
				
			||||||
                        } while (avail_in != 0);
 | 
					                        } while (avail_in != 0 || avail_out != CACHE_BUF_SIZE);
 | 
				
			||||||
                        avail_in = read;
 | 
					                        avail_in = read;
 | 
				
			||||||
                        do {
 | 
					                        do {
 | 
				
			||||||
                            avail_out = CACHE_BUF_SIZE;
 | 
					                            avail_out = CACHE_BUF_SIZE;
 | 
				
			||||||
                            compress_compress_mode(&comp_ctx, COMPRESS_BR, buf + read - avail_in, &avail_in,
 | 
					                            compress_compress_mode(&comp_ctx, COMPRESS_BR, buf + read - avail_in, &avail_in,
 | 
				
			||||||
                                                   comp_buf, &avail_out, feof(file));
 | 
					                                                   comp_buf, &avail_out, feof(file));
 | 
				
			||||||
                            fwrite(comp_buf, 1, CACHE_BUF_SIZE - avail_out, comp_file_br);
 | 
					                            fwrite(comp_buf, 1, CACHE_BUF_SIZE - avail_out, comp_file_br);
 | 
				
			||||||
                        } while (avail_in != 0);
 | 
					                        } while (avail_in != 0 || avail_out != CACHE_BUF_SIZE);
 | 
				
			||||||
                    }
 | 
					                    }
 | 
				
			||||||
                }
 | 
					                }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -487,7 +487,7 @@ int fastcgi_send(fastcgi_conn *conn, sock *client, int flags) {
 | 
				
			|||||||
                    sock_send(client, ptr, buf_len, 0);
 | 
					                    sock_send(client, ptr, buf_len, 0);
 | 
				
			||||||
                    if (flags & FASTCGI_CHUNKED) sock_send(client, "\r\n", 2, 0);
 | 
					                    if (flags & FASTCGI_CHUNKED) sock_send(client, "\r\n", 2, 0);
 | 
				
			||||||
                }
 | 
					                }
 | 
				
			||||||
            } while ((flags & FASTCGI_COMPRESS) && avail_in != 0);
 | 
					            } while ((flags & FASTCGI_COMPRESS) && (avail_in != 0 || avail_out != sizeof(comp_out)));
 | 
				
			||||||
            if (finish_comp) goto finish;
 | 
					            if (finish_comp) goto finish;
 | 
				
			||||||
        } else {
 | 
					        } else {
 | 
				
			||||||
            print(ERR_STR "Unknown FastCGI type: %i" CLR_STR, header.type);
 | 
					            print(ERR_STR "Unknown FastCGI type: %i" CLR_STR, header.type);
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -275,6 +275,16 @@ int main(int argc, const char *argv[]) {
 | 
				
			|||||||
        closedir(geoip);
 | 
					        closedir(geoip);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					    ret = cache_init();
 | 
				
			||||||
 | 
					    if (ret < 0) {
 | 
				
			||||||
 | 
					        config_unload();
 | 
				
			||||||
 | 
					        return 1;
 | 
				
			||||||
 | 
					    } else if (ret != 0) {
 | 
				
			||||||
 | 
					        children[0] = ret;  // pid
 | 
				
			||||||
 | 
					    } else {
 | 
				
			||||||
 | 
					        return 0;
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    openssl_init();
 | 
					    openssl_init();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    client.buf = NULL;
 | 
					    client.buf = NULL;
 | 
				
			||||||
@@ -283,7 +293,7 @@ int main(int argc, const char *argv[]) {
 | 
				
			|||||||
    client.ctx = SSL_CTX_new(TLS_server_method());
 | 
					    client.ctx = SSL_CTX_new(TLS_server_method());
 | 
				
			||||||
    SSL_CTX_set_options(client.ctx, SSL_OP_SINGLE_DH_USE);
 | 
					    SSL_CTX_set_options(client.ctx, SSL_OP_SINGLE_DH_USE);
 | 
				
			||||||
    SSL_CTX_set_verify(client.ctx, SSL_VERIFY_NONE, NULL);
 | 
					    SSL_CTX_set_verify(client.ctx, SSL_VERIFY_NONE, NULL);
 | 
				
			||||||
    SSL_CTX_set_min_proto_version(client.ctx, TLS1_VERSION);
 | 
					    SSL_CTX_set_min_proto_version(client.ctx, TLS1_2_VERSION);
 | 
				
			||||||
    SSL_CTX_set_mode(client.ctx, SSL_MODE_ENABLE_PARTIAL_WRITE);
 | 
					    SSL_CTX_set_mode(client.ctx, SSL_MODE_ENABLE_PARTIAL_WRITE);
 | 
				
			||||||
    SSL_CTX_set_cipher_list(client.ctx, "HIGH:!aNULL:!kRSA:!PSK:!SRP:!MD5:!RC4");
 | 
					    SSL_CTX_set_cipher_list(client.ctx, "HIGH:!aNULL:!kRSA:!PSK:!SRP:!MD5:!RC4");
 | 
				
			||||||
    SSL_CTX_set_ecdh_auto(client.ctx, 1);
 | 
					    SSL_CTX_set_ecdh_auto(client.ctx, 1);
 | 
				
			||||||
@@ -319,16 +329,6 @@ int main(int argc, const char *argv[]) {
 | 
				
			|||||||
        }
 | 
					        }
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    ret = cache_init();
 | 
					 | 
				
			||||||
    if (ret < 0) {
 | 
					 | 
				
			||||||
        config_unload();
 | 
					 | 
				
			||||||
        return 1;
 | 
					 | 
				
			||||||
    } else if (ret != 0) {
 | 
					 | 
				
			||||||
        children[0] = ret;  // pid
 | 
					 | 
				
			||||||
    } else {
 | 
					 | 
				
			||||||
        return 0;
 | 
					 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
 | 
					 | 
				
			||||||
    fprintf(stderr, "Ready to accept connections\n");
 | 
					    fprintf(stderr, "Ready to accept connections\n");
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    while (active) {
 | 
					    while (active) {
 | 
				
			||||||
@@ -375,6 +375,7 @@ int main(int argc, const char *argv[]) {
 | 
				
			|||||||
            }
 | 
					            }
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        // TODO outsource in thread
 | 
				
			||||||
        int status = 0;
 | 
					        int status = 0;
 | 
				
			||||||
        for (int i = 0; i < MAX_CHILDREN; i++) {
 | 
					        for (int i = 0; i < MAX_CHILDREN; i++) {
 | 
				
			||||||
            if (children[i] != 0) {
 | 
					            if (children[i] != 0) {
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user