comparison src/protocols/msn/httpmethod.c @ 8298:c719f9a181d4

[gaim-migrate @ 9022] Though it doesn't fix a thing, this is a better timer implementation for HTTP polling. committer: Tailor Script <[e-mail]>

8297:a6e8ef48c7a4

} MsnHttpQueueData;

static gboolean
http_poll(gpointer data)
{
	MsnServConn *servconn = data;

	gaim_debug_info("msn", "Polling server %s.\n",
					servconn->http_data->gateway_ip);
	msn_http_servconn_poll(servconn);

	servconn->http_data->timer = 0;

	gaim_debug(GAIM_DEBUG_INFO, "msn", "Returning from http_poll\n");

	return FALSE;
}

static void
stop_timer(MsnServConn *servconn)
{
	if (servconn->http_data->timer)
	{
		gaim_debug(GAIM_DEBUG_INFO, "msn", "Stopping timer\n");
		gaim_timeout_remove(servconn->http_data->timer);
		servconn->http_data->timer = 0;
	}
}

static void
start_timer(MsnServConn *servconn)
{
	stop_timer(servconn);

	gaim_debug(GAIM_DEBUG_INFO, "msn", "Starting timer\n");
	servconn->http_data->timer = gaim_timeout_add(5000, http_poll, servconn);
}

size_t
msn_http_servconn_write(MsnServConn *servconn, const char *buf, size_t size,
						const char *server_type)

	} while (s < needed);

	g_free(temp);

	servconn->http_data->waiting_response = TRUE;

	servconn->http_data->virgin = FALSE;

	stop_timer(servconn);

	return s;
}

void

	s = write(servconn->fd, temp, strlen(temp));

	g_free(temp);

	servconn->http_data->waiting_response = TRUE;

	stop_timer(servconn);

	if (s <= 0)
		gaim_connection_error(servconn->session->account->gc,
							  _("Write error"));
}

		g_free(queue_data->buffer);
		g_free(queue_data);
	}
	else
		start_timer(servconn);

	return TRUE;
}

8298:c719f9a181d4

} MsnHttpQueueData;

static gboolean
http_poll(gpointer data)
{
	MsnSession *session = data;
	MsnServConn *servconn;
	GList *l;

	for (l = session->servconns; l != NULL; l = l->next)
	{
		servconn = (MsnServConn *)l->data;

		if (servconn->http_data->dirty)
		{
			gaim_debug_info("msn", "Polling server %s.\n",
							servconn->http_data->gateway_ip);
			msn_http_servconn_poll(servconn);
		}
	}

	return TRUE;
}

static void
stop_timer(MsnSession *session)
{
	if (session->http_poll_timer)
	{
		gaim_debug(GAIM_DEBUG_INFO, "msn", "Stopping timer\n");
		gaim_timeout_remove(session->http_poll_timer);
		session->http_poll_timer = 0;
	}
}

static void
start_timer(MsnSession *session)
{
	stop_timer(session);

	gaim_debug(GAIM_DEBUG_INFO, "msn", "Starting timer\n");
	session->http_poll_timer = gaim_timeout_add(5000, http_poll, session);
}

void
msn_http_session_init(MsnSession *session)
{
	g_return_if_fail(session != NULL);

	start_timer(session);
}

void
msn_http_session_uninit(MsnSession *session)
{
	g_return_if_fail(session != NULL);

	stop_timer(session);
}

size_t
msn_http_servconn_write(MsnServConn *servconn, const char *buf, size_t size,
						const char *server_type)

	} while (s < needed);

	g_free(temp);

	servconn->http_data->waiting_response = TRUE;
	servconn->http_data->virgin = FALSE;
	servconn->http_data->dirty = FALSE;

	return s;
}

void

	s = write(servconn->fd, temp, strlen(temp));

	g_free(temp);

	servconn->http_data->waiting_response = TRUE;
	servconn->http_data->dirty = FALSE;

	if (s <= 0)
		gaim_connection_error(servconn->session->account->gc,
							  _("Write error"));
}

		g_free(queue_data->buffer);
		g_free(queue_data);
	}
	else
		servconn->http_data->dirty = TRUE;

	return TRUE;
}