/* server */
-static void
-test_server_connection_refused(void)
+static void test_server_connection_refused(void)
{
i_close_fd(&fd_listen);
}
/* client */
-static bool
-test_client_connection_refused(void)
+static bool test_client_connection_refused(void)
{
const char *error;
int ret;
/* server */
-static void
-test_connection_timed_out_input(struct server_connection *conn)
+static void test_connection_timed_out_input(struct server_connection *conn)
{
sleep(5);
server_connection_deinit(&conn);
/* client */
-static bool
-test_client_connection_timed_out(void)
+static bool test_client_connection_timed_out(void)
{
time_t time;
const char *error;
/* server */
-static void
-test_bad_version_input(struct server_connection *conn)
+static void test_bad_version_input(struct server_connection *conn)
{
server_connection_deinit(&conn);
}
-static void
-test_bad_version_init(struct server_connection *conn)
+static void test_bad_version_init(struct server_connection *conn)
{
- o_stream_nsend_str(conn->conn.output,
- "VERSION\t666\t666\n");
- o_stream_nsend_str(conn->conn.output,
- "SPID\t23234\n");
+ o_stream_nsend_str(conn->conn.output, "VERSION\t666\t666\n");
+ o_stream_nsend_str(conn->conn.output, "SPID\t23234\n");
}
static void test_server_bad_version(void)
/* client */
-static bool
-test_client_bad_version(void)
+static bool test_client_bad_version(void)
{
const char *error;
int ret;
/* server */
-static void
-test_disconnect_version_input(struct server_connection *conn)
+static void test_disconnect_version_input(struct server_connection *conn)
{
const char *line;
server_connection_deinit(&conn);
}
-static void
-test_disconnect_version_init(struct server_connection *conn)
+static void test_disconnect_version_init(struct server_connection *conn)
{
- o_stream_nsend_str(conn->conn.output,
- "VERSION\t1\t0\n");
- o_stream_nsend_str(conn->conn.output,
- "SPID\t23234\n");
+ o_stream_nsend_str(conn->conn.output, "VERSION\t1\t0\n");
+ o_stream_nsend_str(conn->conn.output, "SPID\t23234\n");
}
static void test_server_disconnect_version(void)
/* client */
-static bool
-test_client_disconnect_version(void)
+static bool test_client_disconnect_version(void)
{
const char *error;
int ret;
/* server */
-static void
-test_changed_spid_input(struct server_connection *conn)
+static void test_changed_spid_input(struct server_connection *conn)
{
const char *line;
server_connection_deinit(&conn);
}
-static void
-test_changed_spid_init(struct server_connection *conn)
+static void test_changed_spid_init(struct server_connection *conn)
{
- o_stream_nsend_str(conn->conn.output,
- "VERSION\t1\t0\n");
- o_stream_nsend_str(conn->conn.output,
- "SPID\t35341\n");
+ o_stream_nsend_str(conn->conn.output, "VERSION\t1\t0\n");
+ o_stream_nsend_str(conn->conn.output, "SPID\t35341\n");
}
static void test_server_changed_spid(void)
/* client */
-static bool
-test_client_changed_spid(void)
+static bool test_client_changed_spid(void)
{
const char *error;
int ret;
bool not_found:1;
};
-static void
-test_request_fail_input(struct server_connection *conn)
+static void test_request_fail_input(struct server_connection *conn)
{
struct _request_fail_server *ctx =
(struct _request_fail_server *)conn->context;
server_connection_deinit(&conn);
return;
} else {
- line = t_strdup_printf("FAIL\t%u\t"
+ line = t_strdup_printf(
+ "FAIL\t%u\t"
"reason=REQUEST DENIED\n", id);
}
o_stream_nsend_str(conn->conn.output, line);
}
}
-static void
-test_request_fail_init(struct server_connection *conn)
+static void test_request_fail_init(struct server_connection *conn)
{
struct _request_fail_server *ctx;
ctx = p_new(conn->pool, struct _request_fail_server, 1);
conn->context = (void*)ctx;
- o_stream_nsend_str(conn->conn.output,
- "VERSION\t1\t0\n");
- o_stream_nsend_str(conn->conn.output,
- "SPID\t23234\n");
+ o_stream_nsend_str(conn->conn.output, "VERSION\t1\t0\n");
+ o_stream_nsend_str(conn->conn.output, "SPID\t23234\n");
}
static void test_server_request_fail(void)
/* client */
-static bool
-test_client_request_fail(void)
+static bool test_client_request_fail(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_request_notfound(void)
+static bool test_client_request_notfound(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_request_timeout(void)
+static bool test_client_request_timeout(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_request_disconnect(void)
+static bool test_client_request_disconnect(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_request_reconnect(void)
+static bool test_client_request_reconnect(void)
{
const char *error;
int ret;
enum _request_login_state state;
};
-static void
-test_request_login_input(struct server_connection *conn)
+static void test_request_login_input(struct server_connection *conn)
{
struct _request_login_server *ctx =
(struct _request_login_server *)conn->context;
}
}
-static void
-test_request_login_init(struct server_connection *conn)
+static void test_request_login_init(struct server_connection *conn)
{
struct _request_login_server *ctx;
ctx = p_new(conn->pool, struct _request_login_server, 1);
conn->context = (void*)ctx;
- o_stream_nsend_str(conn->conn.output,
- "VERSION\t1\t0\n");
- o_stream_nsend_str(conn->conn.output,
- "SPID\t23234\n");
+ o_stream_nsend_str(conn->conn.output, "VERSION\t1\t0\n");
+ o_stream_nsend_str(conn->conn.output, "SPID\t23234\n");
}
static void test_server_request_login(void)
/* client */
-static bool
-test_client_request_login(void)
+static bool test_client_request_login(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_request_login_parallel(void)
+static bool test_client_request_login_parallel(void)
{
const char *error;
int ret;
/* client connection */
-static void
-server_connection_input(struct connection *_conn)
+static void server_connection_input(struct connection *_conn)
{
struct server_connection *conn = (struct server_connection *)_conn;
test_server_input(conn);
}
-static void
-server_connection_init(int fd)
+static void server_connection_init(int fd)
{
struct server_connection *conn;
pool_t pool;
conn = p_new(pool, struct server_connection, 1);
conn->pool = pool;
- connection_init_server
- (server_conn_list, &conn->conn, "server connection", fd, fd);
+ connection_init_server(server_conn_list, &conn->conn,
+ "server connection", fd, fd);
if (test_server_init != NULL)
test_server_init(conn);
}
-static void
-server_connection_deinit(struct server_connection **_conn)
+static void server_connection_deinit(struct server_connection **_conn)
{
struct server_connection *conn = *_conn;
pool_unref(&conn->pool);
}
-static void
-server_connection_destroy(struct connection *_conn)
+static void server_connection_destroy(struct connection *_conn)
{
struct server_connection *conn =
(struct server_connection *)_conn;
server_connection_deinit(&conn);
}
-static void
-server_connection_accept(void *context ATTR_UNUSED)
+static void server_connection_accept(void *context ATTR_UNUSED)
{
int fd;
volatile sig_atomic_t terminating = 0;
-static void
-test_signal_handler(int signo)
+static void test_signal_handler(int signo)
{
if (terminating != 0)
raise(signo);