/soc/2013/ankitkv/gobjectification: a2a55c2e450c: Merged soc.201...
Ankit Vani
a at nevitus.org
Fri Aug 9 13:44:50 EDT 2013
Changeset: a2a55c2e450c558ae5cd153bdb6b3dd613ecd5f6
Author: Ankit Vani <a at nevitus.org>
Date: 2013-08-09 23:14 +0530
Branch: soc.2013.gobjectification.plugins
URL: https://hg.pidgin.im/soc/2013/ankitkv/gobjectification/rev/a2a55c2e450c
Description:
Merged soc.2013.gobjectification branch
diffstat:
finch/plugins/gnttinyurl.c | 4 +-
libpurple/connection.c | 10 +
libpurple/ft.c | 113 +-
libpurple/ft.h | 13 +
libpurple/http.c | 61 +-
libpurple/http.h | 2 +-
libpurple/protocols/gg/avatar.c | 4 +-
libpurple/protocols/gg/oauth/oauth-purple.c | 2 +-
libpurple/protocols/gg/pubdir-prpl.c | 2 +-
libpurple/protocols/jabber/bosh.c | 2 +-
libpurple/protocols/jabber/google/relay.c | 2 +-
libpurple/protocols/jabber/oob.c | 3 +-
libpurple/protocols/jabber/useravatar.c | 2 +-
libpurple/protocols/msn/httpconn.c | 2 +-
libpurple/protocols/msn/msn.c | 4 +-
libpurple/protocols/msn/slp.c | 2 +-
libpurple/protocols/msn/soap.c | 2 +-
libpurple/protocols/mxit/formcmds.c | 2 +-
libpurple/protocols/mxit/login.c | 4 +-
libpurple/protocols/mxit/markup.c | 2 +-
libpurple/protocols/mxit/protocol.c | 2 +-
libpurple/protocols/myspace/user.c | 2 +-
libpurple/protocols/oscar/clientlogin.c | 4 +-
libpurple/protocols/yahoo/libyahoo.c | 3 -
libpurple/protocols/yahoo/libyahoojp.c | 3 -
libpurple/protocols/yahoo/libymsg.c | 312 ++---
libpurple/protocols/yahoo/libymsg.h | 2 -
libpurple/protocols/yahoo/yahoo_aliases.c | 4 +-
libpurple/protocols/yahoo/yahoo_filexfer.c | 1448 +++++---------------------
libpurple/protocols/yahoo/yahoo_filexfer.h | 5 -
libpurple/protocols/yahoo/yahoo_picture.c | 9 +-
libpurple/protocols/yahoo/yahoo_profile.c | 4 +-
libpurple/protocols/yahoo/yahoochat.c | 2 +-
libpurple/upnp.c | 6 +-
pidgin/gtkprefs.c | 2 +-
pidgin/gtksmiley.c | 2 +-
pidgin/plugins/relnot.c | 2 +-
37 files changed, 584 insertions(+), 1466 deletions(-)
diffs (truncated from 3039 to 300 lines):
diff --git a/finch/plugins/gnttinyurl.c b/finch/plugins/gnttinyurl.c
--- a/finch/plugins/gnttinyurl.c
+++ b/finch/plugins/gnttinyurl.c
@@ -213,7 +213,7 @@ static void url_fetched(PurpleHttpConnec
GList *convs = purple_conversations_get_all();
const gchar *url;
- if (purple_http_response_is_successfull(response))
+ if (purple_http_response_is_successful(response))
url = purple_http_response_get_data(response, NULL);
else
url = _("Error while querying TinyURL");
@@ -360,7 +360,7 @@ tinyurl_notify_fetch_cb(PurpleHttpConnec
char *message;
const gchar *url;
- if (!purple_http_response_is_successfull(response))
+ if (!purple_http_response_is_successful(response))
return;
url = purple_http_response_get_data(response, NULL);
diff --git a/libpurple/connection.c b/libpurple/connection.c
--- a/libpurple/connection.c
+++ b/libpurple/connection.c
@@ -386,6 +386,16 @@ void
priv->active_chats = g_slist_remove(priv->active_chats, chat);
}
+gboolean
+_purple_connection_wants_to_die(const PurpleConnection *gc)
+{
+ PurpleConnectionPrivate *priv = PURPLE_CONNECTION_GET_PRIVATE(gc);
+
+ g_return_val_if_fail(priv != NULL, FALSE);
+
+ return priv->wants_to_die;
+}
+
void
purple_connection_update_progress(PurpleConnection *gc, const char *text,
size_t step, size_t count)
diff --git a/libpurple/ft.c b/libpurple/ft.c
--- a/libpurple/ft.c
+++ b/libpurple/ft.c
@@ -1161,14 +1161,22 @@ purple_xfer_write_file(PurpleXfer *xfer,
if (fs_known && size > purple_xfer_get_bytes_remaining(xfer)) {
purple_debug_warning("filetransfer",
- "Got too much data (truncating).\n");
+ "Got too much data (truncating at %" G_GOFFSET_FORMAT
+ ").\n", purple_xfer_get_size(xfer));
size = purple_xfer_get_bytes_remaining(xfer);
}
if (ui_ops && ui_ops->ui_write)
wc = ui_ops->ui_write(xfer, buffer, size);
- else
+ else {
+ if (xfer->dest_fp == NULL) {
+ purple_debug_error("filetransfer",
+ "File is not opened for writing\n");
+ purple_xfer_cancel_local(xfer);
+ return FALSE;
+ }
wc = fwrite(buffer, 1, size, xfer->dest_fp);
+ }
if (wc != size) {
purple_debug_error("filetransfer",
@@ -1183,6 +1191,57 @@ purple_xfer_write_file(PurpleXfer *xfer,
return TRUE;
}
+gssize
+purple_xfer_read_file(PurpleXfer *xfer, guchar *buffer, gsize size)
+{
+ PurpleXferUiOps *ui_ops;
+ gssize got_len;
+
+ g_return_val_if_fail(xfer != NULL, FALSE);
+ g_return_val_if_fail(buffer != NULL, FALSE);
+
+ ui_ops = purple_xfer_get_ui_ops(xfer);
+
+ if (ui_ops && ui_ops->ui_read) {
+ guchar *buffer_got = NULL;
+
+ got_len = ui_ops->ui_read(xfer, &buffer_got, size);
+
+ if (got_len > size) {
+ g_free(buffer_got);
+ purple_debug_error("filetransfer",
+ "Got too much data from UI.\n");
+ purple_xfer_cancel_local(xfer);
+ return -1;
+ }
+
+ if (got_len > 0)
+ memcpy(buffer, buffer_got, got_len);
+ g_free(buffer_got);
+ } else {
+ if (xfer->dest_fp == NULL) {
+ purple_debug_error("filetransfer",
+ "File is not opened for reading\n");
+ purple_xfer_cancel_local(xfer);
+ return -1;
+ }
+ got_len = fread(buffer, 1, size, xfer->dest_fp);
+ if (got_len != size && ferror(xfer->dest_fp)) {
+ purple_debug_error("filetransfer",
+ "Unable to read file.\n");
+ purple_xfer_cancel_local(xfer);
+ return -1;
+ }
+ }
+
+ if (got_len > 0) {
+ purple_xfer_set_bytes_sent(xfer,
+ purple_xfer_get_bytes_sent(xfer) + got_len);
+ }
+
+ return got_len;
+}
+
static void
do_transfer(PurpleXfer *xfer)
{
@@ -1209,7 +1268,7 @@ do_transfer(PurpleXfer *xfer)
return;
}
} else if (xfer->type == PURPLE_XFER_SEND) {
- size_t result = 0;
+ gssize result = 0;
size_t s = MIN(purple_xfer_get_bytes_remaining(xfer), xfer->current_buffer_size);
PurpleXferPrivData *priv = g_hash_table_lookup(xfers_data, xfer);
gboolean read = TRUE;
@@ -1234,40 +1293,26 @@ do_transfer(PurpleXfer *xfer)
}
if (read) {
- if (ui_ops && ui_ops->ui_read) {
- gssize tmp = ui_ops->ui_read(xfer, &buffer, s);
- if (tmp == 0) {
- /*
- * The UI claimed it was ready, but didn't have any data for
- * us... It will call purple_xfer_ui_ready when ready, which
- * sets back up this watcher.
- */
- if (xfer->watcher != 0) {
- purple_input_remove(xfer->watcher);
- xfer->watcher = 0;
- }
-
- /* Need to indicate the prpl is still ready... */
- priv->ready |= PURPLE_XFER_READY_PRPL;
-
- g_return_if_reached();
- } else if (tmp < 0) {
- purple_debug_error("filetransfer", "Unable to read whole buffer.\n");
- purple_xfer_cancel_local(xfer);
- return;
+ buffer = g_new(guchar, s);
+ result = purple_xfer_read_file(xfer, buffer, s);
+ if (result == 0) {
+ /*
+ * The UI claimed it was ready, but didn't have any data for
+ * us... It will call purple_xfer_ui_ready when ready, which
+ * sets back up this watcher.
+ */
+ if (xfer->watcher != 0) {
+ purple_input_remove(xfer->watcher);
+ xfer->watcher = 0;
}
- result = tmp;
- } else {
- buffer = g_malloc(s);
- result = fread(buffer, 1, s, xfer->dest_fp);
- if (result != s) {
- purple_debug_error("filetransfer", "Unable to read whole buffer.\n");
- purple_xfer_cancel_local(xfer);
- g_free(buffer);
- return;
- }
+ /* Need to indicate the prpl is still ready... */
+ priv->ready |= PURPLE_XFER_READY_PRPL;
+
+ g_return_if_reached();
}
+ if (result < 0)
+ return;
}
if (priv->buffer) {
diff --git a/libpurple/ft.h b/libpurple/ft.h
--- a/libpurple/ft.h
+++ b/libpurple/ft.h
@@ -650,6 +650,19 @@ gboolean
purple_xfer_write_file(PurpleXfer *xfer, const guchar *buffer, gsize size);
/**
+ * Writes chunk of file being sent.
+ *
+ * @param xfer The file transfer.
+ * @param buffer The buffer to write the data to.
+ * @param size The size of buffer.
+ *
+ * @return Number of bytes written (0 means, the device is busy), or -1 on
+ * failure.
+ */
+gssize
+purple_xfer_read_file(PurpleXfer *xfer, guchar *buffer, gsize size);
+
+/**
* Starts a file transfer.
*
* Either @a fd must be specified <i>or</i> @a ip and @a port on a
diff --git a/libpurple/http.c b/libpurple/http.c
--- a/libpurple/http.c
+++ b/libpurple/http.c
@@ -868,18 +868,18 @@ static gboolean _purple_http_recv_header
hdrline[hdrline_len] = '\0';
if (hdrline[0] == '\0') {
- if (!hc->main_header_got && hc->is_keepalive) {
- if (purple_debug_is_verbose()) {
+ if (!hc->main_header_got) {
+ if (purple_debug_is_verbose() &&
+ hc->is_keepalive)
+ {
purple_debug_misc("http", "Got keep-"
"alive terminator from previous"
" request\n");
+ } else {
+ purple_debug_warning("http", "Got empty"
+ " line at the beginning - this "
+ "may be a HTTP server quirk\n");
}
- } else if (!hc->main_header_got) {
- hc->response->code = 0;
- purple_debug_warning("http",
- "Main header not present\n");
- _purple_http_error(hc, _("Error parsing HTTP"));
- return FALSE;
} else /* hc->main_header_got */ {
hc->headers_got = TRUE;
if (purple_debug_is_verbose()) {
@@ -939,6 +939,8 @@ static gboolean _purple_http_recv_body_d
}
if (hc->request->max_length >= 0) {
if (hc->length_got + len > hc->request->max_length) {
+ purple_debug_warning("http",
+ "Maximum length exceeded, truncating\n");
len = hc->request->max_length - hc->length_got;
hc->length_expected = hc->request->max_length;
}
@@ -1002,10 +1004,6 @@ static gboolean _purple_http_recv_body_c
g_string_erase(hc->response_buffer, 0, got_now);
hc->in_chunk = (hc->chunk_got < hc->chunk_length);
- if (purple_debug_is_verbose())
- purple_debug_misc("http", "Chunk (%d/%d)\n",
- hc->chunk_got, hc->chunk_length);
-
continue;
}
@@ -1086,6 +1084,12 @@ static gboolean _purple_http_recv_loopbo
/* EOF */
if (len == 0) {
+ if (hc->request->max_length == 0) {
+ /* It's definitely YHttpServer quirk. */
+ purple_debug_warning("http", "Got EOF, but no data was "
+ "expected (this may be a server quirk)\n");
+ hc->length_expected = hc->length_got;
+ }
if (hc->length_expected >= 0 &&
hc->length_got < hc->length_expected) {
purple_debug_warning("http", "No more data while reading"
@@ -1101,10 +1105,21 @@ static gboolean _purple_http_recv_loopbo
purple_http_conn_retry(hc);
return FALSE;
} else {
- purple_debug_warning("http", "No more data while "
- "parsing headers\n");
- _purple_http_error(hc, _("Error parsing HTTP"));
- return FALSE;
+ if (g_ascii_strcasecmp(purple_http_headers_get(
+ hc->response->headers, "Server"),
+ "YHttpServer") == 0)
+ {
+ purple_debug_warning("http", "No more data "
+ "while parsing headers (YHttpServer "
+ "quirk)\n");
+ hc->headers_got = TRUE;
+ hc->length_expected = hc->length_got = 0;
+ } else {
+ purple_debug_warning("http", "No more data "
+ "while parsing headers\n");
More information about the Commits
mailing list