[go: nahoru, domu]

Skip to content

Commit

Permalink
Automated Code Change
Browse files Browse the repository at this point in the history
PiperOrigin-RevId: 646751150
  • Loading branch information
tensorflower-gardener committed Jun 26, 2024
1 parent 80c7862 commit cfc5c2e
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions tensorflow/core/common_runtime/executor.cc
Original file line number Diff line number Diff line change
Expand Up @@ -647,7 +647,7 @@ void ExecutorState<PropagatorStateType>::ProcessAsync(
tsl::profiler::GetTFTraceMeLevel(/*is_expensive=*/false));

// Trace async op start.
profiler::TraceMeProducer producer(
tsl::profiler::TraceMeProducer producer(
[&] {
return tsl::profiler::TraceMeEncode(
"ExecutorState::ProcessAsync::Start",
Expand All @@ -659,7 +659,7 @@ void ExecutorState<PropagatorStateType>::ProcessAsync(

auto done = [this, state, activity_id, ctx_id = producer.GetContextId()]() {
// Trace async op done.
profiler::TraceMeConsumer consumer(
tsl::profiler::TraceMeConsumer consumer(
[&] {
return profiler::TraceMeEncode(
"ExecutorState::ProcessAsync::Done",
Expand Down Expand Up @@ -807,13 +807,13 @@ void ExecutorState<PropagatorStateType>::ProcessInline(

bool completed = false;
int64_t last_iter_num = -1;
std::unique_ptr<profiler::TraceMeConsumer> iteration_scope;
std::unique_ptr<tsl::profiler::TraceMeConsumer> iteration_scope;
while (!inline_ready->empty()) {
TaggedNode tagged_node = inline_ready->front();

int64_t current_iter_num = tagged_node.get_iter_num();
if (current_iter_num != last_iter_num) {
iteration_scope = std::make_unique<profiler::TraceMeConsumer>(
iteration_scope = std::make_unique<tsl::profiler::TraceMeConsumer>(
// From TraceMeProducer in DirectSession::RunInternal,
// GraphMgr::ExecuteAsync, or FunctionLibraryRuntime::Run.
[&] {
Expand Down Expand Up @@ -1459,7 +1459,7 @@ void ExecutorState<PropagatorStateType>::Finish() {
}
delete this;
runner([step_id, trace_id, status, done_cb = std::move(done_cb)]() {
profiler::TraceMeConsumer activity(
tsl::profiler::TraceMeConsumer activity(
// From TraceMeProducer in KernelAndDeviceFunc::RunAsync,
// DirectSession::RunInternal or GraphMgr::ExecuteAsync.
[&] {
Expand All @@ -1482,7 +1482,7 @@ void ExecutorState<PropagatorStateType>::Finish() {
done_cb = std::move(done_cb)](const Status& status) mutable {
delete this;
runner([step_id, trace_id, status, done_cb = std::move(done_cb)]() {
profiler::TraceMeConsumer activity(
tsl::profiler::TraceMeConsumer activity(
// From TraceMeProducer in KernelAndDeviceFunc::RunAsync,
// DirectSession::RunInternal or GraphMgr::ExecuteAsync.
[&] {
Expand All @@ -1497,7 +1497,7 @@ void ExecutorState<PropagatorStateType>::Finish() {
} else {
delete this;
runner([step_id, trace_id, status, done_cb = std::move(done_cb)]() {
profiler::TraceMeConsumer activity(
tsl::profiler::TraceMeConsumer activity(
// From TraceMeProducer in KernelAndDeviceFunc::RunAsync,
// DirectSession::RunInternal or GraphMgr::ExecuteAsync.
[&] {
Expand Down

0 comments on commit cfc5c2e

Please sign in to comment.