Fixes #160357

svn path=/trunk/; revision=31755

1 files changed, 18 insertions, 0 deletions

diff --git a/calendar/gui/e-meeting-store.c b/calendar/gui/e-meeting-store.c
index a942d83779..8a185add17 100644
--- a/calendar/gui/e-meeting-store.c
+++ b/calendar/gui/e-meeting-store.c
@@ -60,6 +60,7 @@ struct _EMeetingStorePrivate {
 
 	guint callback_idle_id;
 	guint num_threads;
+	guint num_queries;
 	GAsyncQueue *async_queue;
 };
 
@@ -611,6 +612,8 @@ ems_init (EMeetingStore *store)
 
 	priv->async_queue = g_async_queue_new ();
 
+	priv->num_queries = 0;
+
 	start_addressbook_server (store);
 }
 
@@ -1177,6 +1180,7 @@ typedef struct {
 	char *email;
 	EMeetingAttendee *attendee;
 	EMeetingStoreQueueData *qdata;
+	EMeetingStore *store;
 } FreeBusyAsyncData;
 
 #define USER_SUB   "%u"
@@ -1189,12 +1193,15 @@ freebusy_async (gpointer data)
 	EMeetingAttendee *attendee = fbd->attendee;
 	gchar *default_fb_uri;
 	static GStaticMutex mutex = G_STATIC_MUTEX_INIT;
+	EMeetingStorePrivate *priv = fbd->store->priv;
 
 	if (fbd->client) {
 		/* FIXME this a work around for getting all th free busy information for the users 
 		 we should be able to get free busy asynchronously */
 		g_static_mutex_lock (&mutex);		
+		priv->num_queries++;
 		e_cal_get_free_busy (fbd->client, fbd->users, fbd->startt, fbd->endt, &(fbd->fb_data), NULL);
+		priv->num_queries--;
 		g_static_mutex_unlock (&mutex);		
 
 		g_list_foreach (fbd->users, (GFunc)g_free, NULL);
@@ -1234,9 +1241,11 @@ freebusy_async (gpointer data)
 		g_free (default_fb_uri);
 		default_fb_uri = replace_string (tmp_fb_uri, DOMAIN_SUB, split_email[1]);
 
+		priv->num_queries++;
 		gnome_vfs_async_open (&handle, default_fb_uri, GNOME_VFS_OPEN_READ, 
 				      GNOME_VFS_PRIORITY_DEFAULT, start_async_read, 
 				      fbd->qdata);
+		priv->num_queries--;
 		
 		g_free (tmp_fb_uri);
 		g_strfreev (split_email);
@@ -1300,6 +1309,7 @@ refresh_busy_periods (gpointer data)
 	fbd->fb_data = NULL;	
 	fbd->qdata = qdata;
 	fbd->fb_uri = priv->fb_uri;
+	fbd->store = store;
 	fbd->email = g_strdup (itip_strip_mailto (e_meeting_attendee_get_address (attendee)));
 
 	/* Check the server for free busy data */	
@@ -1503,3 +1513,11 @@ e_meeting_store_refresh_busy_periods (EMeetingStore *store,
 
 	refresh_queue_add (store, row, start, end, call_back, data);
 }
+
+guint
+e_meeting_store_get_num_queries (EMeetingStore *store)
+{
+	g_return_if_fail (E_IS_MEETING_STORE (store));
+
+	return store->priv->num_queries;
+}