#include "includes.h"
#include "messages.h"
-#include "ctdb_conn.h"
+#include "lib/messages_ctdb.h"
+#include "lib/messages_ctdb_ref.h"
#include "ctdbd_conn.h"
#include "lib/dbwrap/dbwrap.h"
#include "lib/dbwrap/dbwrap_ctdb.h"
#include "torture/proto.h"
-NTSTATUS ctdbd_probe(void)
-{
- return NT_STATUS_NOT_IMPLEMENTED;
-}
-
-NTSTATUS ctdbd_messaging_send_blob(struct ctdbd_connection *conn,
- uint32_t dst_vnn, uint64_t dst_srvid,
- const uint8_t *buf, size_t buflen)
-{
- return NT_STATUS_NOT_IMPLEMENTED;
-}
-
-NTSTATUS register_with_ctdbd(struct ctdbd_connection *conn, uint64_t srvid,
- void (*cb)(struct ctdb_req_message *msg,
- void *private_data),
- void *private_data)
-{
- return NT_STATUS_NOT_IMPLEMENTED;
-}
-
-NTSTATUS ctdbd_register_ips(struct ctdbd_connection *conn,
- const struct sockaddr_storage *_server,
- const struct sockaddr_storage *_client,
- bool (*release_ip_handler)(const char *ip_addr,
- void *private_data),
- void *private_data)
-{
- return NT_STATUS_NOT_IMPLEMENTED;
-}
-
-const char *lp_ctdbd_socket(void)
-{
- return "";
-}
-
-bool ctdb_serverids_exist_supported(struct ctdbd_connection *conn)
-{
- return false;
-}
-
-bool ctdb_serverids_exist(struct ctdbd_connection *conn,
- const struct server_id *pids, unsigned num_pids,
- bool *results)
-{
- return false;
-}
-
-bool ctdb_processes_exist(struct ctdbd_connection *conn,
- const struct server_id *pids, int num_pids,
- bool *results)
-{
- return false;
-}
-
-struct dummy_state {
- uint8_t dummy;
-};
-
-static struct tevent_req *dummy_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev)
-{
- struct tevent_req *req;
- struct dummy_state *state;
- req = tevent_req_create(mem_ctx, &state, struct dummy_state);
- if (req == NULL) {
- return NULL;
- }
- tevent_req_done(req);
- return tevent_req_post(req, ev);
-}
-
-struct tevent_req *ctdb_conn_init_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev,
- const char *sock)
-{
- return dummy_send(mem_ctx, ev);
-}
-
-int ctdb_conn_init_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,
- struct ctdb_conn **pconn)
+int ctdbd_probe(const char *sockname, int timeout)
{
return ENOSYS;
}
-struct tevent_req *ctdb_conn_msg_write_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev,
- struct ctdb_conn *conn,
- uint32_t vnn, uint64_t srvid,
- uint8_t *msg, size_t msg_len)
-{
- return dummy_send(mem_ctx, ev);
-}
-
-int ctdb_conn_msg_write_recv(struct tevent_req *req)
+int ctdbd_messaging_send_iov(struct ctdbd_connection *conn,
+ uint32_t dst_vnn, uint64_t dst_srvid,
+ const struct iovec *iov, int iovlen)
{
return ENOSYS;
}
-struct tevent_req *ctdb_msg_channel_init_send(
- TALLOC_CTX *mem_ctx, struct tevent_context *ev,
- const char *sock, uint64_t srvid)
-{
- return dummy_send(mem_ctx, ev);
-}
-
-int ctdb_msg_channel_init_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,
- struct ctdb_msg_channel **pchannel)
+int register_with_ctdbd(struct ctdbd_connection *conn, uint64_t srvid,
+ int (*cb)(struct tevent_context *ev,
+ uint32_t src_vnn, uint32_t dst_vnn,
+ uint64_t dst_srvid,
+ const uint8_t *msg, size_t msglen,
+ void *private_data),
+ void *private_data)
{
return ENOSYS;
}
-struct tevent_req *ctdb_msg_read_send(TALLOC_CTX *mem_ctx,
- struct tevent_context *ev,
- struct ctdb_msg_channel *channel)
+int ctdbd_register_ips(struct ctdbd_connection *conn,
+ const struct sockaddr_storage *_server,
+ const struct sockaddr_storage *_client,
+ int (*cb)(struct tevent_context *ev,
+ uint32_t src_vnn, uint32_t dst_vnn,
+ uint64_t dst_srvid,
+ const uint8_t *msg, size_t msglen,
+ void *private_data),
+ void *private_data)
{
- return dummy_send(mem_ctx, ev);
+ return ENOSYS;
}
-int ctdb_msg_read_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,
- uint8_t **pmsg, size_t *pmsg_len)
+bool ctdbd_process_exists(struct ctdbd_connection *conn, uint32_t vnn,
+ pid_t pid, uint64_t unique_id)
{
- return ENOSYS;
+ return false;
}
struct db_context *db_open_ctdb(TALLOC_CTX *mem_ctx,
+ struct messaging_context *msg_ctx,
const char *name,
int hash_size, int tdb_flags,
int open_flags, mode_t mode,
return NULL;
}
-NTSTATUS messaging_ctdbd_init(struct messaging_context *msg_ctx,
- TALLOC_CTX *mem_ctx,
- struct messaging_backend **presult)
+int messaging_ctdb_send(uint32_t dst_vnn, uint64_t dst_srvid,
+ const struct iovec *iov, int iovlen)
{
- return NT_STATUS_NOT_IMPLEMENTED;
+ return ENOSYS;
}
-struct ctdbd_connection *messaging_ctdbd_connection(void)
+void *messaging_ctdb_ref(TALLOC_CTX *mem_ctx, struct tevent_context *ev,
+ const char *sockname, int timeout, uint64_t unique_id,
+ void (*recv_cb)(struct tevent_context *ev,
+ const uint8_t *msg, size_t msg_len,
+ int *fds, size_t num_fds,
+ void *private_data),
+ void *private_data,
+ int *err)
{
return NULL;
}
-bool run_ctdb_conn(int dummy)
+struct messaging_ctdb_fde *messaging_ctdb_register_tevent_context(
+ TALLOC_CTX *mem_ctx, struct tevent_context *ev)
{
- return true;
+ return NULL;
+}
+
+struct ctdbd_connection *messaging_ctdb_connection(void)
+{
+ return NULL;
+}
+
+int ctdb_async_ctx_reinit(TALLOC_CTX *mem_ctx, struct tevent_context *ev)
+{
+ return ENOSYS;
}