NODE_STREAMING
test_all_nodes(cfe, NODE_ENABLED, NODE_STREAMING);
set_state(cfe, NODE_STREAMING, node->id);
if (!test_all_nodes(cfe, NODE_ENABLED, NODE_STREAMING)) {
NODE_STREAMING));
clear_state(cfe, NODE_STREAMING, node->id);
test_all_nodes(cfe, NODE_ENABLED, NODE_STREAMING);
clear_state(cfe, NODE_STREAMING, node->id);
if (!test_any_node(cfe, NODE_STREAMING)) {
if (!check_state(cfe, NODE_STREAMING, i))
if (!check_state(cfe, NODE_STREAMING, i))
if (!check_state(cfe, NODE_STREAMING, i) || i == node->id)
if (!check_state(cfe, NODE_STREAMING, i) || !(sof[i] || eof[i]))
test_all_nodes(cfe, NODE_ENABLED, NODE_STREAMING);
if (cfe->job_ready && test_all_nodes(cfe, NODE_ENABLED, NODE_STREAMING))