|
|
@ -1985,16 +1985,13 @@ static int process_events(struct mansession *s)
|
|
|
|
if (s->fd > -1) {
|
|
|
|
if (s->fd > -1) {
|
|
|
|
if (!ret && ast_carefulwrite(s->fd, eqe->eventdata, strlen(eqe->eventdata), s->writetimeout) < 0)
|
|
|
|
if (!ret && ast_carefulwrite(s->fd, eqe->eventdata, strlen(eqe->eventdata), s->writetimeout) < 0)
|
|
|
|
ret = -1;
|
|
|
|
ret = -1;
|
|
|
|
} else {
|
|
|
|
} else if (!s->outputstr && !(s->outputstr = ast_calloc(1, sizeof(*s->outputstr))))
|
|
|
|
if (!s->outputstr && !(s->outputstr = ast_calloc(1, sizeof(*s->outputstr)))) {
|
|
|
|
ret = -1;
|
|
|
|
ast_mutex_unlock(&s->__lock);
|
|
|
|
else
|
|
|
|
return;
|
|
|
|
ast_dynamic_str_append(&s->outputstr, 0, "%s", eqe->eventdata);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ast_dynamic_str_append(&s->outputstr, 0, "%s", buf->str);
|
|
|
|
unuse_eventqent(s->eventq);
|
|
|
|
}
|
|
|
|
s->eventq = eqe;
|
|
|
|
}
|
|
|
|
|
|
|
|
unuse_eventqent(s->eventq);
|
|
|
|
|
|
|
|
s->eventq = eqe;
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ast_mutex_unlock(&s->__lock);
|
|
|
|
ast_mutex_unlock(&s->__lock);
|
|
|
|
return ret;
|
|
|
|
return ret;
|
|
|
|