comparison src/protocols/yahoo/yahoo_filexfer.c @ 7710:45fd907e1d48

[gaim-migrate @ 8355] " It cleaned it up slightly, removing some redundent prpl specific stuff that the core has a copy of anyway. Also, I had Simguy make sure I didn't break win32, and I didn't." --Tim Ringenbach (marv_sf) committer: Tailor Script <[e-mail]>

7709:a1d913ecd0f6

	gchar *path;
	int port;
	GaimConnection *gc;
	long expires;
	gboolean started;
	guint length;
	gchar *rxqueue;
	guint rxlen;
	guint bytes_in;
};

static void yahoo_xfer_data_free(struct yahoo_xfer_data *xd)
{
	if (xd->host)

}


size_t yahoo_xfer_read(char **buffer, GaimXfer *xfer)
{
	gchar buf[1024];
	ssize_t len;
	gchar *start = NULL;
	gchar *length;
	gchar *end;
	struct yahoo_xfer_data *xd = xfer->data;

	if (gaim_xfer_get_type(xfer) != GAIM_XFER_RECEIVE) {
		return 0;
	}

	len = read(xfer->fd, buf, sizeof(buf));

	if (len <= 0) {
		if (xd->length && (xd->length == xd->bytes_in))
			gaim_xfer_set_completed(xfer, TRUE);
		else
			gaim_xfer_cancel_remote(xfer);
		return 0;
	}

		length = g_strstr_len(xd->rxqueue, len, "Content-length:");
		if (length) {
			end = g_strstr_len(length, length - xd->rxqueue, "\r\n");
			if (!end)
				return 0;
			if ((xd->length = calculate_length(length, len - (length - xd->rxqueue))))
				gaim_xfer_set_size(xfer, xd->length);
		}
		start = g_strstr_len(xd->rxqueue, len, "\r\n\r\n");
		if (start)
			start += 4;
		if (!start || start > (xd->rxqueue + len))

	} else {
		*buffer = g_malloc(len);
		memcpy(*buffer, buf, len);
	}

	xd->bytes_in += len;
	return len;
}

size_t yahoo_xfer_write(const char *buffer, size_t size, GaimXfer *xfer)
{
	size_t len;
	struct yahoo_xfer_data *xd = xfer->data;

	if (!xd)
		return 0;

		return 0;
	}

	len = write(xfer->fd, buffer, size);

	xd->bytes_in += len;
	if (xd->bytes_in >= gaim_xfer_get_size(xfer))
		gaim_xfer_set_completed(xfer, TRUE);

	return len;

}

static void yahoo_xfer_cancel_send(GaimXfer *xfer)
{
	GaimAccount *account;

7710:45fd907e1d48

	gchar *path;
	int port;
	GaimConnection *gc;
	long expires;
	gboolean started;
	gchar *rxqueue;
	guint rxlen;
};

static void yahoo_xfer_data_free(struct yahoo_xfer_data *xd)
{
	if (xd->host)

}


size_t yahoo_xfer_read(char **buffer, GaimXfer *xfer)
{
	gchar buf[4096];
	ssize_t len;
	gchar *start = NULL;
	gchar *length;
	gchar *end;
	int filelen;
	struct yahoo_xfer_data *xd = xfer->data;

	if (gaim_xfer_get_type(xfer) != GAIM_XFER_RECEIVE) {
		return 0;
	}

	len = read(xfer->fd, buf, sizeof(buf));

	if (len <= 0) {
		if ((gaim_xfer_get_size(xfer) > 0) &&
		   (gaim_xfer_get_bytes_sent(xfer) >= gaim_xfer_get_size(xfer)))
			gaim_xfer_set_completed(xfer, TRUE);
		else
			gaim_xfer_cancel_remote(xfer);
		return 0;
	}

		length = g_strstr_len(xd->rxqueue, len, "Content-length:");
		if (length) {
			end = g_strstr_len(length, length - xd->rxqueue, "\r\n");
			if (!end)
				return 0;
			if ((filelen = calculate_length(length, len - (length - xd->rxqueue))))
				gaim_xfer_set_size(xfer, filelen);
		}
		start = g_strstr_len(xd->rxqueue, len, "\r\n\r\n");
		if (start)
			start += 4;
		if (!start || start > (xd->rxqueue + len))

	} else {
		*buffer = g_malloc(len);
		memcpy(*buffer, buf, len);
	}

	return len;
}

size_t yahoo_xfer_write(const char *buffer, size_t size, GaimXfer *xfer)
{
	ssize_t len;
	struct yahoo_xfer_data *xd = xfer->data;

	if (!xd)
		return 0;

		return 0;
	}

	len = write(xfer->fd, buffer, size);

	if (len == -1) {
		if (gaim_xfer_get_bytes_sent(xfer) >= gaim_xfer_get_size(xfer))
			gaim_xfer_set_completed(xfer, TRUE);
		if ((errno != EAGAIN) && (errno != EINTR))
			gaim_xfer_cancel_remote(xfer);
		return 0;
	}

	if ((gaim_xfer_get_bytes_sent(xfer) + len) >= gaim_xfer_get_size(xfer))
		gaim_xfer_set_completed(xfer, TRUE);

	return len;
}

static void yahoo_xfer_cancel_send(GaimXfer *xfer)
{
	GaimAccount *account;