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