app: Send URC to all open AT pipes

Send URC messages to all pipes that are open
and are in AT mode.

Signed-off-by: Seppo Takalo <seppo.takalo@nordicsemi.no>

Author: SeppoTakalo

app/src/sm_at_host.c

@@ -1524,6 +1524,16 @@ bool in_idle_pipe(struct modem_pipe *pipe)
 	return in_idle_ctx(ctx);
 }
 
+bool is_open_pipe(struct modem_pipe *pipe)
+{
+	return pipe ? sm_pipe_is_open(pipe) : false;
+}
+
+bool is_open_ctx(struct sm_at_host_ctx *ctx)
+{
+	return sm_at_host_get_pipe(ctx);
+}
+
 void exit_datamode_handler(int result)
 {
 	struct sm_at_host_ctx *ctx = sm_at_host_get_current();
@@ -1807,6 +1817,27 @@ static struct sm_at_host_ctx *sm_at_host_create(struct modem_pipe *pipe)
 	return ctx;
 }
 
+static void send_urcs(void)
+{
+	while (!ring_buf_is_empty(&urc_buf)) {
+		struct sm_at_host_ctx *ctx;
+		uint8_t *p;
+		size_t len = ring_buf_get_claim(&urc_buf, &p, UINT16_MAX);
+
+		SYS_SLIST_FOR_EACH_CONTAINER(&instance_list, ctx, node) {
+			if (!is_open(ctx) || !in_at_mode(ctx)) {
+				continue;
+			}
+			int send = sm_at_host_pipe_tx_blocking(ctx, p, len);
+
+			if (send < len) {
+				LOG_ERR("Failed to send URC: %d (ctx %p)", send, ctx);
+			}
+		}
+		ring_buf_get_finish(&urc_buf, len);
+	}
+}
+
 static void sm_at_host_work_fn(struct k_work *work)
 {
 	struct sm_at_host_msg msg;
@@ -1889,16 +1920,7 @@ static void sm_at_host_work_fn(struct k_work *work)
 		case SM_EVENT_URC:
 			/* Don't interrupt AT command execution */
 			if (in_idle(msg.ctx)) {
-				while (!ring_buf_is_empty(&urc_buf)) {
-					uint8_t *p;
-					size_t len = ring_buf_get_claim(&urc_buf, &p, UINT16_MAX);
-					int send = sm_at_host_pipe_tx_blocking(msg.ctx, p, len);
-
-					if (send < len) {
-						LOG_ERR("Failed to send URC: %d", send);
-					}
-					ring_buf_get_finish(&urc_buf, len);
-				}
+				send_urcs();
 				event_work_fn(msg.ctx);
 			} else {
 				/* Postpone URC sending */

app/src/sm_at_host.h

@@ -170,6 +170,12 @@ bool in_idle_pipe(struct modem_pipe *pipe);
 		struct modem_pipe * : in_idle_pipe                                                 \
 		)(X)
 
+#define is_open(X) \
+		_Generic((X), \
+			struct sm_at_host_ctx * : is_open_ctx, \
+			struct modem_pipe * : is_open_pipe \
+			)(X)
+
 /**
  * @brief Exit the data mode handler
  *