diff options
| -rw-r--r-- | gatchat/gatchat.c | 27 | ||||
| -rw-r--r-- | gatchat/gatchat.h | 1 |
2 files changed, 28 insertions, 0 deletions
diff --git a/gatchat/gatchat.c b/gatchat/gatchat.c index df659066..54e64340 100644 --- a/gatchat/gatchat.c +++ b/gatchat/gatchat.c @@ -1219,6 +1219,33 @@ gboolean g_at_chat_cancel(GAtChat *chat, guint id) return TRUE; } +gboolean g_at_chat_cancel_all(GAtChat *chat) +{ + int n = 0; + struct at_command *c; + + if (chat == NULL || chat->command_queue == NULL) + return FALSE; + + while ((c = g_queue_peek_nth(chat->command_queue, n)) != NULL) { + if (c->id == 0) { + n += 1; + continue; + } + + if (n == 0 && chat->cmd_bytes_written > 0) { + c->callback = NULL; + n += 1; + continue; + } + + at_command_destroy(c); + g_queue_remove(chat->command_queue, c); + } + + return TRUE; +} + static struct at_notify *at_notify_create(GAtChat *chat, const char *prefix, gboolean pdu) { diff --git a/gatchat/gatchat.h b/gatchat/gatchat.h index 249c8cfc..8fffda6a 100644 --- a/gatchat/gatchat.h +++ b/gatchat/gatchat.h @@ -118,6 +118,7 @@ guint g_at_chat_send_pdu_listing(GAtChat *chat, const char *cmd, gpointer user_data, GDestroyNotify notify); gboolean g_at_chat_cancel(GAtChat *chat, guint id); +gboolean g_at_chat_cancel_all(GAtChat *chat); guint g_at_chat_register(GAtChat *chat, const char *prefix, GAtNotifyFunc func, gboolean expect_pdu, |