/* 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,
+ o_stream_nsend_str(
+ conn->conn.output,
"VERSION\t666\t666\n"
"MECH\tPLAIN\tplaintext\n"
"MECH\tLOGIN\tplaintext\n"
/* 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,
+ o_stream_nsend_str(
+ conn->conn.output,
"VERSION\t1\t2\n"
"MECH\tPLAIN\tplaintext\n"
"MECH\tLOGIN\tplaintext\n"
/* client */
-static bool
-test_client_disconnect_version(void)
+static bool test_client_disconnect_version(void)
{
const char *error;
int ret;
if (authenid == NULL)
authenid = authid;
if (strcmp(authenid, "harrie") == 0 && strcmp(pass, "frop") == 0) {
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("OK\t%u\tuser=harrie\n", id));
return TRUE;
}
if (strcmp(authenid, "hendrik") == 0)
return FALSE;
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("FAIL\t%u\tuser=%s\n", id, authenid));
return TRUE;
chal_b64 = t_str_new(64);
base64_encode(prompt1, strlen(prompt1), chal_b64);
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("CONT\t%u\t%s\n", id, str_c(chal_b64)));
return TRUE;
}
if (++req->login_state == 1) {
req->username = p_strdup(conn->pool, resp);
if (strcmp(resp, "harrie") != 0) {
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("FAIL\t%u\tuser=%s\n",
req->id, req->username));
return TRUE;
i_assert(req->login_state == 2);
DLLIST_REMOVE(&ctx->requests, req);
if (strcmp(resp, "frop") != 0) {
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("FAIL\t%u\tuser=%s\n",
req->id, req->username));
return TRUE;
}
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
t_strdup_printf("OK\t%u\tuser=harrie\n", req->id));
return TRUE;
}
chal_b64 = t_str_new(64);
base64_encode(prompt2, strlen(prompt2), chal_b64);
o_stream_nsend_str(conn->conn.output,
- t_strdup_printf("CONT\t%u\t%s\n", req->id, str_c(chal_b64)));
+ t_strdup_printf("CONT\t%u\t%s\n",
+ req->id, str_c(chal_b64)));
return TRUE;
}
if (strcasecmp(mech, "PLAIN") == 0) {
return test_auth_handshake_auth_plain(conn, id,
- data->data, data->used);
+ data->data, data->used);
} else if (strcasecmp(mech, "LOGIN") == 0) {
return test_auth_handshake_auth_login(conn, id,
data->data, data->used);
data->data, data->used);
}
-static void
-test_auth_handshake_input(struct server_connection *conn)
+static void test_auth_handshake_input(struct server_connection *conn)
{
struct _auth_handshake_server *ctx =
(struct _auth_handshake_server *)conn->context;
}
}
-static void
-test_auth_handshake_init(struct server_connection *conn)
+static void test_auth_handshake_init(struct server_connection *conn)
{
struct _auth_handshake_server *ctx;
ctx = p_new(conn->pool, struct _auth_handshake_server, 1);
conn->context = (void*)ctx;
- o_stream_nsend_str(conn->conn.output,
+ o_stream_nsend_str(
+ conn->conn.output,
"VERSION\t1\t2\n"
"MECH\tPLAIN\tplaintext\n"
"MECH\tLOGIN\tplaintext\n"
/* client */
-static bool
-test_client_auth_plain_disconnect(void)
+static bool test_client_auth_plain_disconnect(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_plain_reconnect(void)
+static bool test_client_auth_plain_reconnect(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_plain_failure(void)
+static bool test_client_auth_plain_failure(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_plain_success(void)
+static bool test_client_auth_plain_success(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_failure1(void)
+static bool test_client_auth_login_failure1(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_failure2(void)
+static bool test_client_auth_login_failure2(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_success(void)
+static bool test_client_auth_login_success(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_plain_parallel_failure(void)
+static bool test_client_auth_plain_parallel_failure(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_plain_parallel_success(void)
+static bool test_client_auth_plain_parallel_success(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_parallel_failure1(void)
+static bool test_client_auth_login_parallel_failure1(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_parallel_failure2(void)
+static bool test_client_auth_login_parallel_failure2(void)
{
const char *error;
int ret;
return FALSE;
}
-static bool
-test_client_auth_login_parallel_success(void)
+static bool test_client_auth_login_parallel_success(void)
{
const char *error;
int ret;
resp_b64 = t_str_new(64);
if (++login_req->state == 1) {
base64_encode(login_test->username,
- strlen(login_test->username), resp_b64);
+ strlen(login_test->username), resp_b64);
} else {
test_assert(login_req->state == 2);
base64_encode(login_test->password,
- strlen(login_test->password), resp_b64);
+ strlen(login_test->password), resp_b64);
}
auth_client_request_continue(request, str_c(resp_b64));
return;
io_loop_stop(login_test->ioloop);
}
-static void
-test_client_progress_timeout(void *context ATTR_UNUSED)
+static void test_client_progress_timeout(void *context ATTR_UNUSED)
{
/* Terminate test due to lack of progress */
test_assert(FALSE);
/* 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;
+ 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;
fd = net_accept(fd_listen, NULL, NULL);
if (fd == -1)
return;
- if (fd == -2) {
+ if (fd == -2)
i_fatal("test server: accept() failed: %m");
- }
server_connection_init(fd);
}
static void test_server_run(void)
{
/* open server socket */
- io_listen = io_add(fd_listen,
- IO_READ, server_connection_accept, NULL);
+ io_listen = io_add(fd_listen, IO_READ, server_connection_accept, NULL);
server_conn_list = connection_list_init(&server_connection_set,
&server_connection_vfuncs);
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);