X-Git-Url: http://git.silcnet.org/gitweb/?a=blobdiff_plain;f=apps%2Firssi%2Fsrc%2Fcore%2Fnet-sendbuffer.c;fp=apps%2Firssi%2Fsrc%2Fcore%2Fnet-sendbuffer.c;h=0000000000000000000000000000000000000000;hb=72c2de619079457f7a68100eb13385275a424a23;hp=f8aac80ce2e95212a0aa1a63387e543f5d574e07;hpb=e7b6c157b80152bf9fb9266e6bdd93f9fb0db776;p=runtime.git

diff --git a/apps/irssi/src/core/net-sendbuffer.c b/apps/irssi/src/core/net-sendbuffer.c
deleted file mode 100644
index f8aac80c..00000000
--- a/apps/irssi/src/core/net-sendbuffer.c
+++ /dev/null
@@ -1,168 +0,0 @@
-/*
- net-sendbuffer.c : Buffered send()
-
-    Copyright (C) 1998-2000 Timo Sirainen
-
-    This program is free software; you can redistribute it and/or modify
-    it under the terms of the GNU 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 General Public License for more details.
-
-    You should have received a copy of the GNU 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 "module.h"
-
-#include "network.h"
-#include "net-sendbuffer.h"
-
-static GSList *buffers;
-
-/* Create new buffer - if `bufsize' is zero or less, DEFAULT_BUFFER_SIZE
-   is used */
-NET_SENDBUF_REC *net_sendbuffer_create(GIOChannel *handle, int bufsize)
-{
-	NET_SENDBUF_REC *rec;
-
-	g_return_val_if_fail(handle != NULL, NULL);
-
-	rec = g_new0(NET_SENDBUF_REC, 1);
-        rec->send_tag = -1;
-	rec->handle = handle;
-	rec->bufsize = bufsize > 0 ? bufsize : DEFAULT_BUFFER_SIZE;
-
-	buffers = g_slist_append(buffers, rec);
-	return rec;
-}
-
-/* Destroy the buffer. `close' specifies if socket handle should be closed. */
-void net_sendbuffer_destroy(NET_SENDBUF_REC *rec, int close)
-{
-	buffers = g_slist_remove(buffers, rec);
-
-        if (rec->send_tag != -1) g_source_remove(rec->send_tag);
-	if (close) net_disconnect(rec->handle);
-	g_free_not_null(rec->buffer);
-	g_free(rec);
-}
-
-/* Transmit all data from buffer - return TRUE if the whole buffer was sent */
-static int buffer_send(NET_SENDBUF_REC *rec)
-{
-	int ret;
-
-	ret = net_transmit(rec->handle, rec->buffer, rec->bufpos);
-	if (ret < 0 || rec->bufpos == ret) {
-		/* error/all sent - don't try to send it anymore */
-                g_free_and_null(rec->buffer);
-		return TRUE;
-	}
-
-	if (ret > 0) {
-                rec->bufpos -= ret;
-		g_memmove(rec->buffer, rec->buffer+ret, rec->bufpos);
-	}
-	return FALSE;
-}
-
-static void sig_sendbuffer(NET_SENDBUF_REC *rec)
-{
-	if (rec->buffer != NULL) {
-		if (!buffer_send(rec))
-                        return;
-	}
-
-	g_source_remove(rec->send_tag);
-	rec->send_tag = -1;
-}
-
-/* Add `data' to transmit buffer - return FALSE if buffer is full */
-static int buffer_add(NET_SENDBUF_REC *rec, const void *data, int size)
-{
-	if (rec->buffer == NULL) {
-		rec->buffer = g_malloc(rec->bufsize);
-		rec->bufpos = 0;
-	}
-
-	if (rec->bufpos+size > rec->bufsize)
-		return FALSE;
-
-	memcpy(rec->buffer+rec->bufpos, data, size);
-	rec->bufpos += size;
-	return TRUE;
-}
-
-/* Send data, if all of it couldn't be sent immediately, it will be resent
-   automatically after a while. Returns -1 if some unrecoverable error
-   occured. */
-int net_sendbuffer_send(NET_SENDBUF_REC *rec, const void *data, int size)
-{
-	int ret;
-
-	g_return_val_if_fail(rec != NULL, -1);
-	g_return_val_if_fail(data != NULL, -1);
-	if (size <= 0) return 0;
-
-	if (rec->buffer == NULL) {
-                /* nothing in buffer - transmit immediately */
-		ret = net_transmit(rec->handle, data, size);
-		if (ret < 0) return -1;
-		size -= ret;
-		data = ((const char *) data) + ret;
-	}
-
-	if (size <= 0)
-		return 0;
-
-	/* everything couldn't be sent. */
-	if (rec->send_tag == -1) {
-		rec->send_tag =
-			g_input_add(rec->handle, G_INPUT_WRITE,
-				    (GInputFunction) sig_sendbuffer, rec);
-	}
-
-	return buffer_add(rec, data, size) ? 0 : -1;
-}
-
-/* Flush the buffer, blocks until finished. */
-void net_sendbuffer_flush(NET_SENDBUF_REC *rec)
-{
-	int handle;
-
-	if (rec->buffer == NULL)
-		return;
-
-        /* set the socket blocking while doing this */
-	handle = g_io_channel_unix_get_fd(rec->handle);
-#ifndef WIN32
-	fcntl(handle, F_SETFL, 0);
-#endif
-	while (!buffer_send(rec)) ;
-#ifndef WIN32
-	fcntl(handle, F_SETFL, O_NONBLOCK);
-#endif
-}
-
-/* Returns the socket handle */
-GIOChannel *net_sendbuffer_handle(NET_SENDBUF_REC *rec)
-{
-	g_return_val_if_fail(rec != NULL, NULL);
-
-	return rec->handle;
-}
-
-void net_sendbuffer_init(void)
-{
-	buffers = NULL;
-}
-
-void net_sendbuffer_deinit(void)
-{
-}