|
|
@@ -1226,7 +1226,7 @@ Status StreamAllocator::InsertSyncEventNodes() { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
Status status = ReorderEventNodes(); |
|
|
|
Status status = whole_graph_->InsertGraphEvents(); |
|
|
|
if (status != SUCCESS) { |
|
|
|
GELOGE(status, "Graph ReorderEventNodes failed"); |
|
|
|
return status; |
|
|
@@ -1235,22 +1235,6 @@ Status StreamAllocator::InsertSyncEventNodes() { |
|
|
|
return SUCCESS; |
|
|
|
} |
|
|
|
|
|
|
|
Status StreamAllocator::ReorderEventNodes() const { |
|
|
|
Status status = whole_graph_->InsertEventNodes(); |
|
|
|
if (status != SUCCESS) { |
|
|
|
GELOGE(status, "Whole graph InsertEventNodes failed"); |
|
|
|
return status; |
|
|
|
} |
|
|
|
for (const auto &subgraph : whole_graph_->GetAllSubgraphs()) { |
|
|
|
status = subgraph->InsertEventNodes(); |
|
|
|
if (status != SUCCESS) { |
|
|
|
GELOGE(status, "Subgraph %s InsertEventNodes failed", subgraph->GetName().c_str()); |
|
|
|
return status; |
|
|
|
} |
|
|
|
} |
|
|
|
return SUCCESS; |
|
|
|
} |
|
|
|
|
|
|
|
void StreamAllocator::DumpEvents() { |
|
|
|
map<int64_t, vector<NodePtr>> after_refresh_stream_nodes; |
|
|
|
for (const auto &node : whole_graph_->GetNodes(whole_graph_->GetGraphUnknownFlag())) { |
|
|
|