broadband-bearer: port disconnect to use GTask

This commit is contained in:
Ben Chan
2017-07-18 22:32:12 -07:00
parent 903e228782
commit fd34814b36

View File

@@ -1750,28 +1750,12 @@ disconnect_3gpp (MMBroadbandBearer *self,
/*****************************************************************************/ /*****************************************************************************/
/* DISCONNECT */ /* DISCONNECT */
typedef struct {
MMBroadbandBearer *self;
GSimpleAsyncResult *result;
MMPort *data;
} DisconnectContext;
static void
disconnect_context_complete_and_free (DisconnectContext *ctx)
{
g_simple_async_result_complete_in_idle (ctx->result);
g_object_unref (ctx->result);
g_object_unref (ctx->data);
g_object_unref (ctx->self);
g_free (ctx);
}
static gboolean static gboolean
disconnect_finish (MMBaseBearer *self, disconnect_finish (MMBaseBearer *self,
GAsyncResult *res, GAsyncResult *res,
GError **error) GError **error)
{ {
return !g_simple_async_result_propagate_error (G_SIMPLE_ASYNC_RESULT (res), error); return g_task_propagate_boolean (G_TASK (res), error);
} }
static void static void
@@ -1790,57 +1774,48 @@ reset_bearer_connection (MMBroadbandBearer *self)
self->priv->connection_type = CONNECTION_TYPE_NONE; self->priv->connection_type = CONNECTION_TYPE_NONE;
} }
static void
disconnect_succeeded (DisconnectContext *ctx)
{
/* Cleanup all connection related data */
reset_bearer_connection (ctx->self);
/* Set operation result */
g_simple_async_result_set_op_res_gboolean (ctx->result, TRUE);
disconnect_context_complete_and_free (ctx);
}
static void
disconnect_failed (DisconnectContext *ctx,
GError *error)
{
g_simple_async_result_take_error (ctx->result, error);
disconnect_context_complete_and_free (ctx);
}
static void static void
disconnect_cdma_ready (MMBroadbandBearer *self, disconnect_cdma_ready (MMBroadbandBearer *self,
GAsyncResult *res, GAsyncResult *res,
DisconnectContext *ctx) GTask *task)
{ {
GError *error = NULL; GError *error = NULL;
if (!MM_BROADBAND_BEARER_GET_CLASS (self)->disconnect_cdma_finish (self, if (!MM_BROADBAND_BEARER_GET_CLASS (self)->disconnect_cdma_finish (self,
res, res,
&error)) &error))
disconnect_failed (ctx, error); g_task_return_error (task, error);
else else {
disconnect_succeeded (ctx); /* Cleanup all connection related data */
reset_bearer_connection (self);
g_task_return_boolean (task, TRUE);
}
g_object_unref (task);
} }
static void static void
disconnect_3gpp_ready (MMBroadbandBearer *self, disconnect_3gpp_ready (MMBroadbandBearer *self,
GAsyncResult *res, GAsyncResult *res,
DisconnectContext *ctx) GTask *task)
{ {
GError *error = NULL; GError *error = NULL;
if (!MM_BROADBAND_BEARER_GET_CLASS (self)->disconnect_3gpp_finish (self, if (!MM_BROADBAND_BEARER_GET_CLASS (self)->disconnect_3gpp_finish (self,
res, res,
&error)) &error))
disconnect_failed (ctx, error); g_task_return_error (task, error);
else { else {
/* Clear CID if we got any set */ /* Clear CID if we got any set */
if (ctx->self->priv->cid) if (self->priv->cid)
ctx->self->priv->cid = 0; self->priv->cid = 0;
disconnect_succeeded (ctx);
/* Cleanup all connection related data */
reset_bearer_connection (self);
g_task_return_boolean (task, TRUE);
} }
g_object_unref (task);
} }
static void static void
@@ -1850,13 +1825,14 @@ disconnect (MMBaseBearer *self,
{ {
MMPortSerialAt *primary; MMPortSerialAt *primary;
MMBaseModem *modem = NULL; MMBaseModem *modem = NULL;
DisconnectContext *ctx; GTask *task;
if (!MM_BROADBAND_BEARER (self)->priv->port) { if (!MM_BROADBAND_BEARER (self)->priv->port) {
g_simple_async_report_error_in_idle ( g_task_report_new_error (
G_OBJECT (self), self,
callback, callback,
user_data, user_data,
disconnect,
MM_CORE_ERROR, MM_CORE_ERROR,
MM_CORE_ERROR_FAILED, MM_CORE_ERROR_FAILED,
"Couldn't disconnect: this bearer is not connected"); "Couldn't disconnect: this bearer is not connected");
@@ -1871,10 +1847,11 @@ disconnect (MMBaseBearer *self,
/* We need the primary port to disconnect... */ /* We need the primary port to disconnect... */
primary = mm_base_modem_peek_port_primary (modem); primary = mm_base_modem_peek_port_primary (modem);
if (!primary) { if (!primary) {
g_simple_async_report_error_in_idle ( g_task_report_new_error (
G_OBJECT (self), self,
callback, callback,
user_data, user_data,
disconnect,
MM_CORE_ERROR, MM_CORE_ERROR,
MM_CORE_ERROR_FAILED, MM_CORE_ERROR_FAILED,
"Couldn't disconnect: couldn't get primary port"); "Couldn't disconnect: couldn't get primary port");
@@ -1882,14 +1859,7 @@ disconnect (MMBaseBearer *self,
return; return;
} }
/* In this context, we only keep the stuff we'll need later */ task = g_task_new (self, NULL, callback , user_data);
ctx = g_new0 (DisconnectContext, 1);
ctx->self = g_object_ref (self);
ctx->data = g_object_ref (MM_BROADBAND_BEARER (self)->priv->port);
ctx->result = g_simple_async_result_new (G_OBJECT (self),
callback,
user_data,
disconnect);
switch (MM_BROADBAND_BEARER (self)->priv->connection_type) { switch (MM_BROADBAND_BEARER (self)->priv->connection_type) {
case CONNECTION_TYPE_3GPP: case CONNECTION_TYPE_3GPP:
@@ -1901,7 +1871,7 @@ disconnect (MMBaseBearer *self,
MM_BROADBAND_BEARER (self)->priv->port, MM_BROADBAND_BEARER (self)->priv->port,
MM_BROADBAND_BEARER (self)->priv->cid, MM_BROADBAND_BEARER (self)->priv->cid,
(GAsyncReadyCallback) disconnect_3gpp_ready, (GAsyncReadyCallback) disconnect_3gpp_ready,
ctx); task);
break; break;
case CONNECTION_TYPE_CDMA: case CONNECTION_TYPE_CDMA:
@@ -1912,7 +1882,7 @@ disconnect (MMBaseBearer *self,
mm_base_modem_peek_port_secondary (modem), mm_base_modem_peek_port_secondary (modem),
MM_BROADBAND_BEARER (self)->priv->port, MM_BROADBAND_BEARER (self)->priv->port,
(GAsyncReadyCallback) disconnect_cdma_ready, (GAsyncReadyCallback) disconnect_cdma_ready,
ctx); task);
break; break;
case CONNECTION_TYPE_NONE: case CONNECTION_TYPE_NONE: