void *pop;
switch_mutex_lock(profile->ireg_mutex);
while (switch_queue_trypop(profile->sql_queue, &pop) == SWITCH_STATUS_SUCCESS && pop) {
+ printf("WTF [%s]\n", (char *)pop);
sofia_glue_actually_execute_sql(profile, SWITCH_TRUE, (char *) pop, NULL);
free(pop);
}
}
switch_assert(d_sql);
- status = switch_queue_trypush(profile->sql_queue, d_sql);
+ if ((status = switch_queue_trypush(profile->sql_queue, d_sql)) == SWITCH_STATUS_SUCCESS) {
+ d_sql = NULL;
+ }
} else if (sql_already_dynamic) {
d_sql = sql;
}
-
+
if (status != SWITCH_STATUS_SUCCESS) {
sofia_glue_actually_execute_sql(profile, SWITCH_FALSE, sql, profile->ireg_mutex);
}
- switch_safe_free(d_sql);
+ switch_safe_free(d_sql);
if (sql_already_dynamic) {
*sqlp = NULL;