static void ipc_disconnect (struct conn_info *conn_info);
+static void msg_send (void *conn, struct iovec *iov, int iov_len, int locked);
+
+static int memcpy_dwrap (struct conn_info *conn_info, void *msg, int len);
+
static int ipc_thread_active (void *conn)
{
struct conn_info *conn_info = (struct conn_info *)conn;
int error)
{
mar_res_setup_t res_setup;
- res_setup.error = error;
unsigned int res;
+ res_setup.error = error;
+
retry_send:
res = send (conn_info->fd, &res_setup, sizeof (mar_res_setup_t), MSG_WAITALL);
if (res == -1 && errno == EINTR) {
#endif
#if defined(COROSYNC_LINUX)
-char *socketname = "libais.socket";
+const char *socketname = "libais.socket";
#else
-char *socketname = "/var/run/libais.socket";
+const char *socketname = "/var/run/libais.socket";
#endif
static int poll_handler_accept (
return (bytes_left);
}
-int memcpy_dwrap (struct conn_info *conn_info, void *msg, int len)
+static int memcpy_dwrap (struct conn_info *conn_info, void *msg, int len)
{
char *dest_char = (char *)conn_info->mem->dispatch_buffer;
char *src_char = (char *)msg;
return (0);
}
-void msg_send (void *conn, struct iovec *iov, int iov_len, int locked)
+static void msg_send (void *conn, struct iovec *iov, int iov_len, int locked)
{
struct conn_info *conn_info = (struct conn_info *)conn;
struct sembuf sop;