Changeset 7550

Timestamp:

Dec 30, 2008, 8:40:48 PM (12 years ago)

Author:

charles

Message:

(trunk libT) patch from wereHamster to recycle the zlib deflate stream s.t. we don't have to keep reallocating it

File:

• trunk/libtransmission/rpc-server.c (modified) (11 diffs)

trunk/libtransmission/rpc-server.c

@@ -58 +58 @@
     char *             whitelistStr;
     tr_list *          whitelist;
+
+#ifdef HAVE_ZLIB
+    z_stream           stream;
+#endif
 };
 
@@ -223 +227 @@
 static void
 add_response( struct evhttp_request * req,
+              struct tr_rpc_server *  server,
               struct evbuffer *       out,
               const void *            content,
@@ -241 +246 @@
     {
         int state;
-        z_stream stream;
-
-        stream.zalloc = (alloc_func) Z_NULL;
-        stream.zfree = (free_func) Z_NULL;
-        stream.opaque = (voidpf) Z_NULL;
-        deflateInit( &stream, Z_BEST_COMPRESSION );
-
-        stream.next_in = (Bytef*) content;
-        stream.avail_in = content_len;
+
+        server->stream.next_in = (Bytef*) content;
+        server->stream.avail_in = content_len;
 
         /* allocate space for the raw data and call deflate() just once --
@@ -255 +254 @@
          * so it's okay to let deflate() run out of output buffer space */
         evbuffer_expand( out, content_len );
-        stream.next_out = EVBUFFER_DATA( out );
-        stream.avail_out = content_len;
-
-        state = deflate( &stream, Z_FINISH );
+        server->stream.next_out = EVBUFFER_DATA( out );
+        server->stream.avail_out = content_len;
+
+        state = deflate( &server->stream, Z_FINISH );
 
         if( state == Z_STREAM_END )
         {
-            EVBUFFER_LENGTH( out ) = content_len - stream.avail_out;
+            EVBUFFER_LENGTH( out ) = content_len - server->stream.avail_out;
 
             /* http://carsten.codimi.de/gzip.yaws/
@@ -288 +287 @@
         }
 
-        deflateEnd( &stream );
+        deflateReset( &server->stream );
     }
 #endif
@@ -295 +294 @@
 static void
 serve_file( struct evhttp_request * req,
+            struct tr_rpc_server *  server,
             const char *            filename )
 {
@@ -324 +324 @@
             evhttp_add_header( req->output_headers, "Content-Type",
                                mimetype_guess( filename ) );
-            add_response( req, out, content, content_len );
+            add_response( req, server, out, content, content_len );
             evhttp_send_reply( req, HTTP_OK, "OK", out );
 
@@ -368 +368 @@
                        subpath && *subpath ? subpath : "index.html" );
 
-        serve_file( req, filename );
+        serve_file( req, server, filename );
 
         tr_free( filename );
@@ -401 +401 @@
 
     buf = tr_getBuffer( );
-    add_response( req, buf, out, len );
+    add_response( req, server, buf, out, len );
     evhttp_add_header( req->output_headers, "Content-Type",
                        "application/json; charset=UTF-8" );
@@ -692 +692 @@
     while(( tmp = tr_list_pop_front( &s->whitelist )))
         tr_free( tmp );
+#ifdef HAVE_ZLIB
+    deflateEnd( &s->stream );
+#endif
     tr_free( s->whitelistStr );
     tr_free( s->username );
@@ -726 +729 @@
     s->isEnabled = isEnabled != 0;
     tr_rpcSetWhitelist( s, whitelist ? whitelist : "127.0.0.1" );
+
+#ifdef HAVE_ZLIB
+    s->stream.zalloc = (alloc_func) Z_NULL;
+    s->stream.zfree = (free_func) Z_NULL;
+    s->stream.opaque = (voidpf) Z_NULL;
+    deflateInit( &s->stream, Z_BEST_COMPRESSION );
+#endif
+
     if( isEnabled )
         tr_runInEventThread( session, startServer, s );