made workaround for state machine freeze problem in Win32.

git-svn-id: svn://sylpheed.sraoss.jp/sylpheed/trunk@1188 ee746299-78ed-0310-b773-934348b2243d

1 files changed, 35 insertions, 3 deletions

diff --git a/libsylph/session.c b/libsylph/session.c
index b8b77aff..1d1300e5 100644
--- a/libsylph/session.c
+++ b/libsylph/session.c
@@ -41,6 +41,10 @@ static gint session_close		(Session	*session);
 
 static gboolean session_timeout_cb	(gpointer	 data);
 
+#ifdef G_OS_WIN32
+static gboolean session_ping_cb		(gpointer	 data);
+#endif
+
 static gboolean session_recv_msg_idle_cb	(gpointer	 data);
 static gboolean session_recv_data_idle_cb	(gpointer	 data);
 
@@ -107,6 +111,8 @@ void session_init(Session *session)
 	session->timeout_tag = 0;
 	session->timeout_interval = 0;
 
+	session->ping_tag = 0;
+
 	session->data = NULL;
 }
 
@@ -176,6 +182,10 @@ static gint session_connect_cb(SockInfo *sock, gpointer data)
 					 session_read_msg_cb,
 					 session);
 
+#ifdef G_OS_WIN32
+	session->ping_tag = g_timeout_add(1000, session_ping_cb, session);
+#endif
+
 	return 0;
 }
 
@@ -247,6 +257,20 @@ static gboolean session_timeout_cb(gpointer data)
 	return FALSE;
 }
 
+#ifdef G_OS_WIN32
+/* hack for state machine freeze problem in GLib >= 2.8.x */
+static gboolean session_ping_cb(gpointer data)
+{
+	Session *session = SESSION(data);
+	SockInfo *sock = session->sock;
+
+	if (session->io_tag > 0 && sock && sock->callback)
+		sock->callback(sock, sock->condition, sock->data);
+
+	return TRUE;
+}
+#endif
+
 void session_set_recv_message_notify(Session *session,
 				     RecvMsgNotify notify_func, gpointer data)
 {
@@ -300,6 +324,13 @@ static gint session_close(Session *session)
 
 	session_set_timeout(session, 0);
 
+#ifdef G_OS_WIN32
+	if (session->ping_tag > 0) {
+		g_source_remove(session->ping_tag);
+		session->ping_tag = 0;
+	}
+#endif
+
 	if (session->io_tag > 0) {
 		g_source_remove(session->io_tag);
 		session->io_tag = 0;
@@ -848,6 +879,10 @@ static gboolean session_read_data_as_file_cb(SockInfo *source,
 	}
 	rewind(session->read_data_fp);
 
+	session->preread_len = 0;
+	session->read_buf_len = 0;
+	session->read_buf_p = session->read_buf;
+
 	/* callback */
 	ret = session->recv_data_as_file_finished
 		(session, session->read_data_fp, session->read_data_pos);
@@ -859,9 +894,6 @@ static gboolean session_read_data_as_file_cb(SockInfo *source,
 				  session->recv_data_notify_data);
 
 	session->read_data_pos = 0;
-	session->preread_len = 0;
-	session->read_buf_len = 0;
-	session->read_buf_p = session->read_buf;
 
 	if (ret < 0)
 		session->state = SESSION_ERROR;