From e1361284083a1ac3b2a17015c62e8d8723c575de Mon Sep 17 00:00:00 2001
From: Unbit <info@unbit.it>
Date: Wed, 11 Sep 2013 14:04:26 +0200
Subject: [PATCH] added compress and suffix log encoders

---
 core/logging.c | 33 +++++++++++++++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/core/logging.c b/core/logging.c
index ff0b3386..e888d32e 100644
--- a/core/logging.c
+++ b/core/logging.c
@@ -1678,6 +1678,18 @@ static char *uwsgi_log_encoder_gzip(struct uwsgi_log_encoder *ule, char *msg, si
 	uwsgi_buffer_destroy(ub);
 	return buf;
 }
+
+static char *uwsgi_log_encoder_compress(struct uwsgi_log_encoder *ule, char *msg, size_t len, size_t *rlen) {
+	size_t c_len = (size_t) compressBound(len);
+	uLongf destLen = c_len;
+	char *buf = uwsgi_malloc(c_len);
+	if (compress((Bytef *) buf, &destLen, (Bytef *)msg, (uLong) len) == Z_OK) {
+		*rlen = destLen;
+		return buf;
+	}
+	free(buf);
+	return NULL;
+}
 #endif
 
 /*
@@ -1716,6 +1728,25 @@ end:
         return buf;
 }
 
+/*
+
+really fast encoder adding only a suffix
+
+*/
+static char *uwsgi_log_encoder_suffix(struct uwsgi_log_encoder *ule, char *msg, size_t len, size_t *rlen) {
+        char *buf = NULL;
+        struct uwsgi_buffer *ub = uwsgi_buffer_new(len + strlen(ule->args));
+        if (uwsgi_buffer_append(ub, msg, len)) goto end;
+        if (uwsgi_buffer_append(ub, ule->args, strlen(ule->args))) goto end;
+        *rlen = ub->pos;
+        buf = ub->buf;
+        ub->buf = NULL;
+end:
+        uwsgi_buffer_destroy(ub);
+        return buf;
+}
+
+
 
 void uwsgi_log_encoder_parse_vars(struct uwsgi_log_encoder *ule) {
 		char *ptr = ule->args;
@@ -1905,10 +1936,12 @@ end:
 
 void uwsgi_log_encoders_register_embedded() {
 	uwsgi_register_log_encoder("prefix", uwsgi_log_encoder_prefix);
+	uwsgi_register_log_encoder("suffix", uwsgi_log_encoder_suffix);
 	uwsgi_register_log_encoder("nl", uwsgi_log_encoder_nl);
 	uwsgi_register_log_encoder("format", uwsgi_log_encoder_format);
 	uwsgi_register_log_encoder("json", uwsgi_log_encoder_json);
 #ifdef UWSGI_ZLIB
 	uwsgi_register_log_encoder("gzip", uwsgi_log_encoder_gzip);
+	uwsgi_register_log_encoder("compress", uwsgi_log_encoder_compress);
 #endif
 }