Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
home:Alexander_Naumov:SLE12
libgweather
libgweather-soup-no-abort-session.patch
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File libgweather-soup-no-abort-session.patch of Package libgweather
From d5695b1183ad4d895dae24a6048b8788f9e8d7d0 Mon Sep 17 00:00:00 2001 From: Giovanni Campagna <gcampagna@src.gnome.org> Date: Sat, 8 Mar 2014 19:34:18 +0100 Subject: [PATCH 2/2] GWeatherInfo: don't abort the entire SoupSession The SoupSession is shared between all GWeatherInfos, so it's extremely bad to abort it, expecially because we do when infos are finalized. Instead, have each info keep a list of pending SoupMessages and cancel them. --- libgweather/weather-iwin.c | 11 ++++++----- libgweather/weather-metar.c | 12 ++++++------ libgweather/weather-owm.c | 12 ++++++------ libgweather/weather-priv.h | 7 +++++-- libgweather/weather-wx.c | 13 +++++++------ libgweather/weather-yahoo.c | 12 ++++++------ libgweather/weather-yrno.c | 24 ++++++++++++------------ libgweather/weather.c | 37 +++++++++++++++++++++++++++++++------ 8 files changed, 79 insertions(+), 49 deletions(-) diff --git a/libgweather/weather-iwin.c b/libgweather/weather-iwin.c index 5961878..1bc60f5 100644 --- a/libgweather/weather-iwin.c +++ b/libgweather/weather-iwin.c @@ -322,16 +322,17 @@ iwin_finish (SoupSession *session, SoupMessage *msg, gpointer data) if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { /* forecast data is not really interesting anyway ;) */ - g_warning ("Failed to get IWIN forecast data: %d %s\n", - msg->status_code, msg->reason_phrase); - _gweather_info_request_done (info); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_warning ("Failed to get IWIN forecast data: %d %s\n", + msg->status_code, msg->reason_phrase); + _gweather_info_request_done (info, msg); return; } priv = info->priv; priv->forecast_list = parseForecastXml (msg->response_body->data, info); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } /* Get forecast into newly alloc'ed string */ @@ -370,9 +371,9 @@ iwin_start_open (GWeatherInfo *info) url = g_strdup_printf ("http://www.weather.gov/forecasts/xml/sample_products/browser_interface/ndfdBrowserClientByDay.php?&lat=%s&lon=%s&format=24+hourly&startDate=%04d-%02d-%02d&numDays=7", latstr, lonstr, 1900 + tm.tm_year, 1 + tm.tm_mon, tm.tm_mday); msg = soup_message_new ("GET", url); + _gweather_info_begin_request (info, msg); soup_session_queue_message (priv->session, msg, iwin_finish, info); - priv->requests_pending++; g_free (url); return TRUE; diff --git a/libgweather/weather-metar.c b/libgweather/weather-metar.c index 94ff2cc..d808e43 100644 --- a/libgweather/weather-metar.c +++ b/libgweather/weather-metar.c @@ -570,11 +570,12 @@ metar_finish (SoupSession *session, SoupMessage *msg, gpointer data) priv->network_error = TRUE; else { /* Translators: %d is an error code, and %s the error string */ - g_warning (_("Failed to get METAR data: %d %s.\n"), - msg->status_code, msg->reason_phrase); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_warning (_("Failed to get METAR data: %d %s.\n"), + msg->status_code, msg->reason_phrase); } - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); return; } @@ -601,7 +602,7 @@ metar_finish (SoupSession *session, SoupMessage *msg, gpointer data) } priv->valid = success; - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } /* Read current conditions and fill in info structure */ @@ -623,7 +624,6 @@ metar_start_open (GWeatherInfo *info) "GET", "http://weather.noaa.gov/cgi-bin/mgetmetar.pl", "cccc", loc->code, NULL); + _gweather_info_begin_request (info, msg); soup_session_queue_message (priv->session, msg, metar_finish, info); - - priv->requests_pending++; } diff --git a/libgweather/weather-owm.c b/libgweather/weather-owm.c index 40a8832..b23cd56 100644 --- a/libgweather/weather-owm.c +++ b/libgweather/weather-owm.c @@ -400,14 +400,15 @@ owm_finish (SoupSession *session, if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { /* forecast data is not really interesting anyway ;) */ - g_message ("Failed to get OpenWeatherMap forecast data: %d %s\n", - msg->status_code, msg->reason_phrase); - _gweather_info_request_done (info); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_message ("Failed to get OpenWeatherMap forecast data: %d %s\n", + msg->status_code, msg->reason_phrase); + _gweather_info_request_done (info, msg); return; } parse_forecast_xml (info, msg->response_body); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } gboolean @@ -440,10 +441,9 @@ owm_start_open (GWeatherInfo *info) url = g_strdup_printf (template, latstr, lonstr); message = soup_message_new ("GET", url); + _gweather_info_begin_request (info, message); soup_session_queue_message (priv->session, message, owm_finish, info); - priv->requests_pending++; - g_free (url); return TRUE; diff --git a/libgweather/weather-priv.h b/libgweather/weather-priv.h index c9e4b73..8bea95b 100644 --- a/libgweather/weather-priv.h +++ b/libgweather/weather-priv.h @@ -133,7 +133,7 @@ struct _GWeatherInfoPrivate { GdkPixbufLoader *radar_loader; GdkPixbufAnimation *radar; SoupSession *session; - gint requests_pending; + GSList *requests_pending; }; /* Values common to the parsing source files */ @@ -190,7 +190,10 @@ gboolean owm_start_open (GWeatherInfo *info); gboolean metar_parse (gchar *metar, GWeatherInfo *info); -void _gweather_info_request_done (GWeatherInfo *info); +void _gweather_info_begin_request (GWeatherInfo *info, + SoupMessage *message); +void _gweather_info_request_done (GWeatherInfo *info, + SoupMessage *message); void ecl2equ (gdouble t, gdouble eclipLon, diff --git a/libgweather/weather-wx.c b/libgweather/weather-wx.c index 567e072..2701dce 100644 --- a/libgweather/weather-wx.c +++ b/libgweather/weather-wx.c @@ -34,10 +34,11 @@ wx_finish (SoupSession *session, SoupMessage *msg, gpointer data) priv = info->priv; if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { - g_warning ("Failed to get radar map image: %d %s.\n", - msg->status_code, msg->reason_phrase); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_warning ("Failed to get radar map image: %d %s.\n", + msg->status_code, msg->reason_phrase); g_object_unref (priv->radar_loader); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); return; } @@ -51,7 +52,7 @@ wx_finish (SoupSession *session, SoupMessage *msg, gpointer data) } g_object_unref (priv->radar_loader); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } static void @@ -103,8 +104,8 @@ wx_start_open (GWeatherInfo *info) g_signal_connect (msg, "got-chunk", G_CALLBACK (wx_got_chunk), info); soup_message_body_set_accumulate (msg->response_body, FALSE); + _gweather_info_begin_request (info, msg); soup_session_queue_message (priv->session, msg, wx_finish, info); - g_free (url); - priv->requests_pending++; + g_free (url); } diff --git a/libgweather/weather-yahoo.c b/libgweather/weather-yahoo.c index 778169e..a44ae21 100644 --- a/libgweather/weather-yahoo.c +++ b/libgweather/weather-yahoo.c @@ -249,14 +249,15 @@ yahoo_finish (SoupSession *session, if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { /* forecast data is not really interesting anyway ;) */ - g_warning ("Failed to get Yahoo! Weather forecast data: %d %s\n", - msg->status_code, msg->reason_phrase); - _gweather_info_request_done (info); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_warning ("Failed to get Yahoo! Weather forecast data: %d %s\n", + msg->status_code, msg->reason_phrase); + _gweather_info_request_done (info, msg); return; } parse_forecast_xml (info, msg->response_body); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } gboolean @@ -280,10 +281,9 @@ yahoo_start_open (GWeatherInfo *info) url = g_strdup_printf("http://weather.yahooapis.com/forecastrss?w=%s&u=f", loc->yahoo_id); message = soup_message_new ("GET", url); + _gweather_info_begin_request (info, message); soup_session_queue_message (priv->session, message, yahoo_finish, info); - priv->requests_pending++; - g_free (url); return TRUE; diff --git a/libgweather/weather-yrno.c b/libgweather/weather-yrno.c index 6f07e16..05d43a9 100644 --- a/libgweather/weather-yrno.c +++ b/libgweather/weather-yrno.c @@ -463,14 +463,15 @@ yrno_finish_old (SoupSession *session, if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { /* forecast data is not really interesting anyway ;) */ - g_message ("Failed to get Yr.no forecast data: %d %s\n", - msg->status_code, msg->reason_phrase); - _gweather_info_request_done (info); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_message ("Failed to get Yr.no forecast data: %d %s\n", + msg->status_code, msg->reason_phrase); + _gweather_info_request_done (info, msg); return; } parse_forecast_xml_old (info, msg->response_body); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } static gboolean @@ -487,10 +488,9 @@ yrno_start_open_old (GWeatherInfo *info) return FALSE; message = soup_message_new ("GET", url); + _gweather_info_begin_request (info, message); soup_session_queue_message (priv->session, message, yrno_finish_old, info); - priv->requests_pending++; - g_free (url); return TRUE; @@ -505,15 +505,16 @@ yrno_finish_new (SoupSession *session, if (!SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) { /* forecast data is not really interesting anyway ;) */ - g_message ("Failed to get Yr.no forecast data: %d %s\n", - msg->status_code, msg->reason_phrase); - _gweather_info_request_done (info); + if (msg->status_code != SOUP_STATUS_CANCELLED) + g_message ("Failed to get Yr.no forecast data: %d %s\n", + msg->status_code, msg->reason_phrase); + _gweather_info_request_done (info, msg); return; } parse_forecast_xml_new (info, msg->response_body); - _gweather_info_request_done (info); + _gweather_info_request_done (info, msg); } static gboolean @@ -539,10 +540,9 @@ yrno_start_open_new (GWeatherInfo *info) url = g_strdup_printf("http://api.yr.no/weatherapi/locationforecast/1.8/?lat=%s;lon=%s", latstr, lonstr); message = soup_message_new ("GET", url); + _gweather_info_begin_request (info, message); soup_session_queue_message (priv->session, message, yrno_finish_new, info); - priv->requests_pending++; - g_free (url); return TRUE; diff --git a/libgweather/weather.c b/libgweather/weather.c index b0d40d1..4cca36b 100644 --- a/libgweather/weather.c +++ b/libgweather/weather.c @@ -226,9 +226,21 @@ requests_init (GWeatherInfo *info) } void -_gweather_info_request_done (GWeatherInfo *info) +_gweather_info_begin_request (GWeatherInfo *info, + SoupMessage *message) { - if (!--info->priv->requests_pending) + info->priv->requests_pending = g_slist_prepend (info->priv->requests_pending, message); + g_object_ref (message); +} + +void +_gweather_info_request_done (GWeatherInfo *info, + SoupMessage *message) +{ + info->priv->requests_pending = g_slist_remove (info->priv->requests_pending, message); + g_object_ref (message); + + if (info->priv->requests_pending == NULL) g_signal_emit (info, gweather_info_signals[SIGNAL_UPDATED], 0); } @@ -423,7 +435,7 @@ settings_changed_cb (GSettings *settings, Otherwise just wait for the update that will happen at the end */ - if (priv->requests_pending == 0) + if (priv->requests_pending == NULL) g_signal_emit (info, gweather_info_signals[SIGNAL_UPDATED], 0); } @@ -589,12 +601,25 @@ gweather_info_update (GWeatherInfo *info) void gweather_info_abort (GWeatherInfo *info) { + GSList *list, *iter; + GSList dummy = { NULL, NULL }; + g_return_if_fail (GWEATHER_IS_INFO (info)); - if (info->priv->session) { - soup_session_abort (info->priv->session); - info->priv->requests_pending = 0; + if (info->priv->session == NULL) { + g_assert (info->priv->requests_pending == NULL); + return; } + + list = info->priv->requests_pending; + /* to block updated signals */ + info->priv->requests_pending = &dummy; + + for (iter = list; iter; iter = iter->next) + soup_session_cancel_message (info->priv->session, iter->data, SOUP_STATUS_CANCELLED); + g_slist_free (list); + + info->priv->requests_pending = NULL; } static void -- 1.8.4
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor
