/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
/*
* Copyright (C) 2006 Imendio AB
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this program; if not, write to the
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
* Boston, MA 02111-1307, USA.
*/
#include "lm-socket.h"
#ifndef G_OS_WIN32
typedef int LmSock;
#else /* G_OS_WIN32 */
typedef SOCKET LmSock;
#endif /* G_OS_WIN32 */
/* FIXME: Integrate with the SSL stuff */
struct _LmSocket {
LmSock sock;
/* FIXME: Add the rest */
LmSocketFuncs funcs;
LmSocketState state;
gboolean is_blocking;
gint ref;
};
static LmSocket * socket_create (void);
static void socket_free (LmSocket *socket);
static LmSocket *
socket_create (void)
{
LmSocket *socket;
socket = g_new0 (LmSocket, 1);
socket->ref_count = 1;
socket->is_blocking = FALSE;
return socket;
}
static void
socket_free (LmSocket *socket)
{
/* FIXME: Free up the rest of the memory */
g_free (socket->host);
g_free (socket);
}
LmSocket *
lm_socket_new (LmSocketFuncs funcs, const gchar *host, guint port)
{
LmSocket *socket;
socket = socket_create ();
socket->funcs = funcs;
socket->host = g_strdup (host);
socket->port = port;
return socket;
}
void
lm_socket_open (LmSocket *socket)
{
}
int
lm_socket_get_fd (LmSocket *socket)
{
g_return_val_if_fail (socket != NULL, -1);
return socket->fd;
}
gboolean
lm_socket_get_is_blocking (LmSocket *socket)
{
return socket->is_blocking;
}
void
lm_socket_set_is_blocking (LmSocket *socket, gboolean is_block)
{
int res;
g_return_if_fail (socket != NULL);
/* FIXME: Don't unset all flags */
#ifndef G_OS_WIN32
res = fcntl (socket->sock, F_SETFL, is_block ? 0 : O_NONBLOCK);
#else /* G_OS_WIN32 */
u_long mode = (is_block ? 0 : 1);
res = ioctlsocket (socket->sock, FIONBIO, &mode);
#endif /* G_OS_WIN32 */
if (res != 0) {
g_log (LM_LOG_DOMAIN, LM_LOG_LEVEL_NET,
"Could not set socket to be %s\n",
block ? "blocking" : "non-blocking");
}
socket->is_blocking = is_block;
}
int
lm_socket_write (LmSocket *socket,
gsize size,
gchar *buf,
GError **error)
{
}
int
lm_socket_read (LmSocket *socket,
gsize size,
gchar *buf,
GError **error)
{
}
gboolean
lm_socket_close (LmSocket *socket, GError **error)
{
}
LmSocket *
lm_socket_ref (LmSocket *socket)
{
g_return_val_if_fail (socket != NULL, NULL);
socket->ref++;
return socket;
}
void
lm_socket_unref (LmSocket *socket)
{
g_return_if_fail (socket != NULL);
socket->ref--;
if (socket->ref <= 0) {
socket_free (socket);
}
}