comparison src/protocols/oscar/flap_connection.c @ 13608:6c34fbb75bbd

[gaim-migrate @ 15994] Disconnect the account with a decent error message when there are problems with an oscar FLAP connection. This needed to be added after I removed it when rewriting things for non-blocking I/O. committer: Tailor Script <[e-mail]>

13607:a79d422bfe62

static gboolean
flap_connection_destroy_cb(gpointer data)
{
	FlapConnection *conn;

	conn = data;

	gaim_debug_info("oscar", "Destroying oscar connection of "
			"type 0x%04hx\n", conn->type);

	flap_connection_close(conn->od, conn);

	if (conn->watcher_incoming != 0)
		gaim_input_remove(conn->watcher_incoming);
	if (conn->watcher_outgoing != 0)
		gaim_input_remove(conn->watcher_outgoing);

	/*
	 * Free conn->internal, if necessary
	 */
	if (conn->type == SNAC_FAMILY_CHAT)
		flap_connection_destroy_chat(conn->od, conn);

	if (conn->inside != NULL)
	{
		aim_conn_inside_t *inside = (aim_conn_inside_t *)conn->inside;

		flap_connection_destroy_rates(inside->rates);

		free(inside);
	}

	conn->od->oscar_connections = g_list_remove(conn->od->oscar_connections, conn);

	g_free(conn);

	return FALSE;
}

void
flap_connection_destroy(FlapConnection *conn)
{
	if (conn->destroy_timeout != 0)
		gaim_timeout_remove(conn->destroy_timeout);
	flap_connection_destroy_cb(conn);
}

/**
 * Schedule Gaim to destroy the given FlapConnection as soon as we
 * return control back to the program's main loop.  We must do this
 * if we want to destroy the connection but we are still using it
 * for some reason.
 */
void
flap_connection_schedule_destroy(FlapConnection *conn)
{
	if (conn->destroy_timeout != 0)
		/* Already taken care of */
		return;

	gaim_debug_info("oscar", "Scheduling destruction of FLAP "
			"connection of type 0x%04hx\n", conn->type);
	conn->destroy_timeout = gaim_timeout_add(0, flap_connection_destroy_cb, conn);
}

/**
 * In OSCAR, every connection has a set of SNAC groups associated

		{
				/* Error! */
				gaim_debug_warning("oscar", "Expecting FLAP version "
					"0x00000001 but received FLAP version %08lx.  Closing connection.\n",
					flap_version);
				flap_connection_schedule_destroy(conn);
		}
		else
			conn->connected = TRUE;

	} else if (frame->channel == 0x02) {

			read = recv(conn->fd, &header, 6, MSG_PEEK);

			/* Check if the FLAP server closed the connection */
			if (read == 0)
			{
				/* TODO: Print an error?  Server closed connection. */
				flap_connection_schedule_destroy(conn);
				break;
			}

			/* If there was an error then close the connection */
			if (read == -1)

				if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
					/* No worries */
					break;

				/* Error! */
				/* TODO: Print an error?  Lost connection with server. */
				flap_connection_schedule_destroy(conn);
				break;
			}

			/* If we don't even have a complete FLAP header then do nothing */
			if (read < 6)

			read = recv(conn->fd, &header, 6, 0);

			/* All FLAP frames must start with the byte 0x2a */
			if (aimutil_get8(&header[0]) != 0x2a)
			{
				flap_connection_schedule_destroy(conn);
				break;
			}

			/* Initialize a new temporary FlapFrame for incoming data */
			conn->buffer_incoming.channel = aimutil_get8(&header[1]);

						0);

			/* Check if the FLAP server closed the connection */
			if (read == 0)
			{
				flap_connection_schedule_destroy(conn);
				break;
			}

			if (read == -1)
			{
				if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
					/* No worries */
					break;

				/* Error! */
				/* TODO: Print an error?  Lost connection with server. */
				flap_connection_schedule_destroy(conn);
				break;
			}

			conn->buffer_incoming.data.offset += read;
			if (conn->buffer_incoming.data.offset < conn->buffer_incoming.data.len)

		if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
			/* No worries */
			return;

		/* Error! */
		flap_connection_schedule_destroy(conn);
		return;
	}

	gaim_circ_buffer_mark_read(conn->buffer_outgoing, ret);
}

13608:6c34fbb75bbd

static gboolean
flap_connection_destroy_cb(gpointer data)
{
	FlapConnection *conn;
	OscarData *od;
	GaimAccount *account;

	conn = data;
	od = conn->od;

	gaim_debug_info("oscar", "Destroying oscar connection of "
			"type 0x%04hx\n", conn->type);

	flap_connection_close(od, conn);

	if (conn->watcher_incoming != 0)
		gaim_input_remove(conn->watcher_incoming);
	if (conn->watcher_outgoing != 0)
		gaim_input_remove(conn->watcher_outgoing);

	/*
	 * Free conn->internal, if necessary
	 */
	if (conn->type == SNAC_FAMILY_CHAT)
		flap_connection_destroy_chat(od, conn);

	if (conn->inside != NULL)
	{
		aim_conn_inside_t *inside = (aim_conn_inside_t *)conn->inside;

		flap_connection_destroy_rates(inside->rates);

		free(inside);
	}

	od->oscar_connections = g_list_remove(od->oscar_connections, conn);
	g_free(conn);

	account = gaim_connection_get_account(od->gc);
	if ((od->oscar_connections == NULL) && (!account->disconnecting))
	{
		/* No more FLAP connections!  Sign off this GaimConnection! */
		const gchar *tmp;
		if (conn->disconnect_reason == OSCAR_DISCONNECT_REMOTE_CLOSED)
			tmp = _("Server closed the connection.");
		else if (conn->disconnect_reason == OSCAR_DISCONNECT_LOST_CONNECTION)
			tmp = _("Lost connection with server for an unknown reason.");
		else if (conn->disconnect_reason == OSCAR_DISCONNECT_INVALID_DATA)
			tmp = _("Received invalid data on connection with server.");
		else if (conn->disconnect_reason == OSCAR_DISCONNECT_COULD_NOT_CONNECT)
			tmp = _("Could not establish a connection with the server.");
		else
			tmp = NULL;

		if (tmp != NULL)
			gaim_connection_error(od->gc, tmp);
	}

	return FALSE;
}

void
flap_connection_destroy(FlapConnection *conn, OscarDisconnectReason reason)
{
	if (conn->destroy_timeout != 0)
		gaim_timeout_remove(conn->destroy_timeout);
	conn->disconnect_reason = reason;
	flap_connection_destroy_cb(conn);
}

/**
 * Schedule Gaim to destroy the given FlapConnection as soon as we
 * return control back to the program's main loop.  We must do this
 * if we want to destroy the connection but we are still using it
 * for some reason.
 */
void
flap_connection_schedule_destroy(FlapConnection *conn, OscarDisconnectReason reason)
{
	if (conn->destroy_timeout != 0)
		/* Already taken care of */
		return;

	gaim_debug_info("oscar", "Scheduling destruction of FLAP "
			"connection of type 0x%04hx\n", conn->type);
	conn->disconnect_reason = reason;
	conn->destroy_timeout = gaim_timeout_add(0, flap_connection_destroy_cb, conn);
}

/**
 * In OSCAR, every connection has a set of SNAC groups associated

		{
				/* Error! */
				gaim_debug_warning("oscar", "Expecting FLAP version "
					"0x00000001 but received FLAP version %08lx.  Closing connection.\n",
					flap_version);
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_INVALID_DATA);
		}
		else
			conn->connected = TRUE;

	} else if (frame->channel == 0x02) {

			read = recv(conn->fd, &header, 6, MSG_PEEK);

			/* Check if the FLAP server closed the connection */
			if (read == 0)
			{
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_REMOTE_CLOSED);
				break;
			}

			/* If there was an error then close the connection */
			if (read == -1)

				if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
					/* No worries */
					break;

				/* Error! */
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_LOST_CONNECTION);
				break;
			}

			/* If we don't even have a complete FLAP header then do nothing */
			if (read < 6)

			read = recv(conn->fd, &header, 6, 0);

			/* All FLAP frames must start with the byte 0x2a */
			if (aimutil_get8(&header[0]) != 0x2a)
			{
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_INVALID_DATA);
				break;
			}

			/* Initialize a new temporary FlapFrame for incoming data */
			conn->buffer_incoming.channel = aimutil_get8(&header[1]);

						0);

			/* Check if the FLAP server closed the connection */
			if (read == 0)
			{
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_REMOTE_CLOSED);
				break;
			}

			if (read == -1)
			{
				if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
					/* No worries */
					break;

				/* Error! */
				flap_connection_schedule_destroy(conn,
						OSCAR_DISCONNECT_LOST_CONNECTION);
				break;
			}

			conn->buffer_incoming.data.offset += read;
			if (conn->buffer_incoming.data.offset < conn->buffer_incoming.data.len)

		if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
			/* No worries */
			return;

		/* Error! */
		flap_connection_schedule_destroy(conn, OSCAR_DISCONNECT_LOST_CONNECTION);
		return;
	}

	gaim_circ_buffer_mark_read(conn->buffer_outgoing, ret);
}