index 6ce11ff511a97a30f67f9d482d1368806ff21a94..8c5f88297cc6802e0dc9db663a81f5936a7e4c6e 100644 (file)
#include "frontend/connection.h"
#include "frontend/connection-private.h"
-#include "utils/proto.h"
#include "utils/os.h"
#include "libsysdb_test.h"
free(conn);
} /* mock_conn_destroy */
+static ssize_t
+mock_conn_read(sdb_conn_t *conn, size_t len)
+{
+ return sdb_strbuf_read(conn->buf, conn->fd, len);
+} /* conn_read */
+
+static ssize_t
+mock_conn_write(sdb_conn_t *conn, const void *buf, size_t len)
+{
+ return sdb_write(conn->fd, len, buf);
+} /* conn_write */
+
static sdb_conn_t *
mock_conn_create(void)
{
unlink(tmp_file);
+ conn->read = mock_conn_read;
+ conn->write = mock_conn_write;
+
conn->username = strdup(username);
assert(conn->username);
pthread_t thr;
- conn = sdb_connection_accept(-1);
+ conn = sdb_connection_accept(-1, NULL, NULL);
fail_unless(conn == NULL,
"sdb_connection_accept(-1) = %p; expected: NULL", conn);
fail_unless(check == 0,
"INTERNAL ERROR: pthread_create() = %i; expected: 0", check);
- conn = sdb_connection_accept(fd);
+ conn = sdb_connection_accept(fd, NULL, NULL);
fail_unless(conn != NULL,
"sdb_connection_accept(%d) = %p; expected: <conn>", fd, conn);
memcpy(buffer + offset, golden_data[i].msg,
strlen(golden_data[i].msg));
- check = sdb_proto_send(conn->fd, msg_len, buffer);
+ check = sdb_write(conn->fd, msg_len, buffer);
fail_unless(check == (ssize_t)msg_len,
- "sdb_proto_send(%s) = %zi; expected: %zu",
+ "sdb_write(%s) = %zi; expected: %zu",
check, msg_len);
mock_conn_rewind(conn);