diff options
Diffstat (limited to 'channels')
| -rw-r--r-- | channels/chan_dahdi.c | 2 | ||||
| -rw-r--r-- | channels/chan_iax2.c | 2 | ||||
| -rw-r--r-- | channels/chan_mgcp.c | 2 | ||||
| -rw-r--r-- | channels/chan_sip.c | 2 | ||||
| -rw-r--r-- | channels/chan_skinny.c | 2 | ||||
| -rw-r--r-- | channels/sig_pri.c | 2 |
6 files changed, 6 insertions, 6 deletions
diff --git a/channels/chan_dahdi.c b/channels/chan_dahdi.c index 9ccec641f..8ef0cec30 100644 --- a/channels/chan_dahdi.c +++ b/channels/chan_dahdi.c @@ -12581,7 +12581,7 @@ static struct dahdi_pvt *mkintf(int channel, const struct dahdi_chan_conf *conf, mailbox_specific_topic = ast_mwi_topic(tmp->mailbox); if (mailbox_specific_topic) { - tmp->mwi_event_sub = stasis_subscribe(mailbox_specific_topic, mwi_event_cb, NULL); + tmp->mwi_event_sub = stasis_subscribe_pool(mailbox_specific_topic, mwi_event_cb, NULL); } } #ifdef HAVE_DAHDI_LINEREVERSE_VMWI diff --git a/channels/chan_iax2.c b/channels/chan_iax2.c index d093438c8..39861db0e 100644 --- a/channels/chan_iax2.c +++ b/channels/chan_iax2.c @@ -13096,7 +13096,7 @@ static struct iax2_peer *build_peer(const char *name, struct ast_variable *v, st mailbox_specific_topic = ast_mwi_topic(peer->mailbox); if (mailbox_specific_topic) { - peer->mwi_event_sub = stasis_subscribe(mailbox_specific_topic, mwi_event_cb, NULL); + peer->mwi_event_sub = stasis_subscribe_pool(mailbox_specific_topic, mwi_event_cb, NULL); } } diff --git a/channels/chan_mgcp.c b/channels/chan_mgcp.c index 72898b8ff..95fa2dc7c 100644 --- a/channels/chan_mgcp.c +++ b/channels/chan_mgcp.c @@ -4237,7 +4237,7 @@ static struct mgcp_gateway *build_gateway(char *cat, struct ast_variable *v) mailbox_specific_topic = ast_mwi_topic(e->mailbox); if (mailbox_specific_topic) { - e->mwi_event_sub = stasis_subscribe(mailbox_specific_topic, mwi_event_cb, NULL); + e->mwi_event_sub = stasis_subscribe_pool(mailbox_specific_topic, mwi_event_cb, NULL); } } snprintf(e->rqnt_ident, sizeof(e->rqnt_ident), "%08lx", (unsigned long)ast_random()); diff --git a/channels/chan_sip.c b/channels/chan_sip.c index 192956362..2cbef5243 100644 --- a/channels/chan_sip.c +++ b/channels/chan_sip.c @@ -27258,7 +27258,7 @@ static void add_peer_mwi_subs(struct sip_peer *peer) if (!peer_name) { return; } - mailbox->event_sub = stasis_subscribe(mailbox_specific_topic, mwi_event_cb, peer_name); + mailbox->event_sub = stasis_subscribe_pool(mailbox_specific_topic, mwi_event_cb, peer_name); } } } diff --git a/channels/chan_skinny.c b/channels/chan_skinny.c index 4b7f353a0..b8202d33b 100644 --- a/channels/chan_skinny.c +++ b/channels/chan_skinny.c @@ -8295,7 +8295,7 @@ static struct skinny_line *config_line(const char *lname, struct ast_variable *v mailbox_specific_topic = ast_mwi_topic(l->mailbox); if (mailbox_specific_topic) { - l->mwi_event_sub = stasis_subscribe(mailbox_specific_topic, mwi_event_cb, l); + l->mwi_event_sub = stasis_subscribe_pool(mailbox_specific_topic, mwi_event_cb, l); } } diff --git a/channels/sig_pri.c b/channels/sig_pri.c index e9e17322f..a26b56611 100644 --- a/channels/sig_pri.c +++ b/channels/sig_pri.c @@ -9174,7 +9174,7 @@ int sig_pri_start_pri(struct sig_pri_span *pri) mailbox_specific_topic = ast_mwi_topic(mbox_id); if (mailbox_specific_topic) { - pri->mbox[i].sub = stasis_subscribe(mailbox_specific_topic, sig_pri_mwi_event_cb, pri); + pri->mbox[i].sub = stasis_subscribe_pool(mailbox_specific_topic, sig_pri_mwi_event_cb, pri); } if (!pri->mbox[i].sub) { ast_log(LOG_ERROR, "%s span %d could not subscribe to MWI events for %s(%s).\n", |