Commit 09a3c949 authored by rl1987's avatar rl1987
Browse files

Add connection_dir_buf_add() helper function

parent 7f59b9fb

src/core/mainloop/connection.c

+17 −0
Original line number Diff line number Diff line
@@ -4341,6 +4341,23 @@ connection_write_to_buf_impl_,(const char *string, size_t len, 
  connection_write_to_buf_commit(conn, written);

}



/**

 * Write a <b>string</b> (of size <b>len</b> to directory connection

 * <b>dir_conn</b>. Apply compression if connection is configured to use

 * it and finalize it if <b>done</b> is true.

 */

void

connection_dir_buf_add(const char *string, size_t len,

                       dir_connection_t *dir_conn, int done)

{

  if (dir_conn->compress_state != NULL) {

    connection_buf_add_compress(string, len, dir_conn, done);

    return;

  }



  connection_buf_add(string, len, TO_CONN(dir_conn));

}



void

connection_buf_add_compress(const char *string, size_t len,

                            dir_connection_t *conn, int done)

src/core/mainloop/connection.h

+2 −0
Original line number Diff line number Diff line
@@ -226,6 +226,8 @@ MOCK_DECL(void, connection_write_to_buf_impl_, 
/* DOCDOC connection_write_to_buf */

static void connection_buf_add(const char *string, size_t len,

                                    connection_t *conn);

void connection_dir_buf_add(const char *string, size_t len,

                            dir_connection_t *dir_conn, int done);

static inline void

connection_buf_add(const char *string, size_t len, connection_t *conn)

{