} while (0);
BT_HIDDEN
-bool lttng_live_is_canceled(struct lttng_live_component *lttng_live)
+bool lttng_live_graph_is_canceled(struct lttng_live_component *lttng_live)
{
const bt_component *component;
bool ret;
if (lttng_live_detach_session(session)) {
live_comp = session->lttng_live_msg_iter->lttng_live_comp;
if (session->lttng_live_msg_iter &&
- !lttng_live_is_canceled(live_comp)) {
+ !lttng_live_graph_is_canceled(live_comp)) {
/* Old relayd cannot detach sessions. */
BT_LOGD("Unable to detach lttng live session %" PRIu64,
session->id);
if (!session->attached) {
ret = lttng_live_attach_session(session);
if (ret) {
- if (lttng_live_msg_iter && lttng_live_is_canceled(
+ if (lttng_live_msg_iter && lttng_live_graph_is_canceled(
lttng_live_msg_iter->lttng_live_comp)) {
status = LTTNG_LIVE_ITERATOR_STATUS_AGAIN;
} else {
}
lttng_live->self_comp = self_comp;
- if (lttng_live_is_canceled(lttng_live)) {
+ if (lttng_live_graph_is_canceled(lttng_live)) {
goto end;
}
struct lttng_live_session *session, uint64_t trace_id);
void lttng_live_need_new_streams(struct lttng_live_msg_iter *lttng_live_msg_iter);
-bool lttng_live_is_canceled(struct lttng_live_component *lttng_live);
+bool lttng_live_graph_is_canceled(struct lttng_live_component *lttng_live);
#endif /* BABELTRACE_PLUGIN_CTF_LTTNG_LIVE_H */
metadata->trace = NULL;
}
if (errno == EINTR) {
- if (lttng_live_is_canceled(lttng_live)) {
+ if (lttng_live_graph_is_canceled(lttng_live)) {
status = LTTNG_LIVE_ITERATOR_STATUS_AGAIN;
goto end;
}
}
if (ret == BT_SOCKET_ERROR && bt_socket_interrupted()) {
if (!viewer_connection->in_query &&
- lttng_live_is_canceled(lttng_live_msg_iter->lttng_live_comp)) {
+ lttng_live_graph_is_canceled(lttng_live_msg_iter->lttng_live_comp)) {
break;
} else {
continue;
ret = bt_socket_send_nosigpipe(sock, buf, len);
if (ret == BT_SOCKET_ERROR && bt_socket_interrupted()) {
if (!viewer_connection->in_query &&
- lttng_live_is_canceled(lttng_live_msg_iter->lttng_live_comp)) {
+ lttng_live_graph_is_canceled(lttng_live_msg_iter->lttng_live_comp)) {
break;
} else {
continue;
return retstatus;
error:
- if (lttng_live_is_canceled(lttng_live)) {
+ if (lttng_live_graph_is_canceled(lttng_live)) {
retstatus = LTTNG_LIVE_ITERATOR_STATUS_AGAIN;
} else {
retstatus = LTTNG_LIVE_ITERATOR_STATUS_ERROR;
return retstatus;
error:
- if (lttng_live_is_canceled(lttng_live)) {
+ if (lttng_live_graph_is_canceled(lttng_live)) {
retstatus = BT_MSG_ITER_MEDIUM_STATUS_AGAIN;
} else {
retstatus = BT_MSG_ITER_MEDIUM_STATUS_ERROR;
return status;
error:
- if (lttng_live_is_canceled(lttng_live)) {
+ if (lttng_live_graph_is_canceled(lttng_live)) {
status = LTTNG_LIVE_ITERATOR_STATUS_AGAIN;
} else {
status = LTTNG_LIVE_ITERATOR_STATUS_ERROR;