diff options
author | hiro <hiro@ee746299-78ed-0310-b773-934348b2243d> | 2006-11-21 06:16:53 +0000 |
---|---|---|
committer | hiro <hiro@ee746299-78ed-0310-b773-934348b2243d> | 2006-11-21 06:16:53 +0000 |
commit | 706387299924733de026545cc7fd99fa15624278 (patch) | |
tree | eab31a4d5bda5f9d27fe54791ba21b00b6da1902 /libsylph/session.c | |
parent | 3bc4ce303283eb3f6652ffc0c6a1243f1002a400 (diff) |
merged from LibSylph branch.
git-svn-id: svn://sylpheed.sraoss.jp/sylpheed/trunk@1330 ee746299-78ed-0310-b773-934348b2243d
Diffstat (limited to 'libsylph/session.c')
-rw-r--r-- | libsylph/session.c | 43 |
1 files changed, 26 insertions, 17 deletions
diff --git a/libsylph/session.c b/libsylph/session.c index 8a2779f7..3109a478 100644 --- a/libsylph/session.c +++ b/libsylph/session.c @@ -614,7 +614,9 @@ static gboolean session_read_msg_cb(SockInfo *source, GIOCondition condition, g_string_truncate(session->read_msg_buf, 0); ret = session->recv_msg(session, msg); - session->recv_msg_notify(session, msg, session->recv_msg_notify_data); + if (session->recv_msg_notify) + session->recv_msg_notify(session, msg, + session->recv_msg_notify_data); g_free(msg); @@ -698,9 +700,10 @@ static gboolean session_read_data_cb(SockInfo *source, GIOCondition condition, if (tv_cur.tv_sec - session->tv_prev.tv_sec > 0 || tv_cur.tv_usec - session->tv_prev.tv_usec > UI_REFRESH_INTERVAL) { - session->recv_data_progressive_notify - (session, data_buf->len, 0, - session->recv_data_progressive_notify_data); + if (session->recv_data_progressive_notify) + session->recv_data_progressive_notify + (session, data_buf->len, 0, + session->recv_data_progressive_notify_data); g_get_current_time(&session->tv_prev); } return TRUE; @@ -720,8 +723,9 @@ static gboolean session_read_data_cb(SockInfo *source, GIOCondition condition, g_byte_array_set_size(data_buf, 0); - session->recv_data_notify(session, data_len, - session->recv_data_notify_data); + if (session->recv_data_notify) + session->recv_data_notify(session, data_len, + session->recv_data_notify_data); if (ret < 0) session->state = SESSION_ERROR; @@ -851,9 +855,10 @@ static gboolean session_read_data_as_file_cb(SockInfo *source, if (tv_cur.tv_sec - session->tv_prev.tv_sec > 0 || tv_cur.tv_usec - session->tv_prev.tv_usec > UI_REFRESH_INTERVAL) { - session->recv_data_progressive_notify - (session, session->read_data_pos, 0, - session->recv_data_progressive_notify_data); + if (session->recv_data_progressive_notify) + session->recv_data_progressive_notify + (session, session->read_data_pos, 0, + session->recv_data_progressive_notify_data); g_get_current_time(&session->tv_prev); } @@ -896,8 +901,9 @@ static gboolean session_read_data_as_file_cb(SockInfo *source, fclose(session->read_data_fp); session->read_data_fp = NULL; - session->recv_data_notify(session, session->read_data_pos, - session->recv_data_notify_data); + if (session->recv_data_notify) + session->recv_data_notify(session, session->read_data_pos, + session->recv_data_notify_data); session->read_data_pos = 0; @@ -1059,10 +1065,12 @@ static gboolean session_write_data_cb(SockInfo *source, tv_cur.tv_usec - session->tv_prev.tv_usec > UI_REFRESH_INTERVAL) { session_set_timeout(session, session->timeout_interval); - session->send_data_progressive_notify - (session, - session->write_data_pos, write_data_len, - session->send_data_progressive_notify_data); + if (session->send_data_progressive_notify) + session->send_data_progressive_notify + (session, + session->write_data_pos, + write_data_len, + session->send_data_progressive_notify_data); g_get_current_time(&session->tv_prev); } return TRUE; @@ -1075,8 +1083,9 @@ static gboolean session_write_data_cb(SockInfo *source, /* callback */ ret = session->send_data_finished(session, write_data_len); - session->send_data_notify(session, write_data_len, - session->send_data_notify_data); + if (session->send_data_notify) + session->send_data_notify(session, write_data_len, + session->send_data_notify_data); return FALSE; } |