diff options
Diffstat (limited to 'tensorflow/core/common_runtime/executor.cc')
| -rw-r--r-- | tensorflow/core/common_runtime/executor.cc | 23 |
1 files changed, 1 insertions, 22 deletions
diff --git a/tensorflow/core/common_runtime/executor.cc b/tensorflow/core/common_runtime/executor.cc index f7f2cdc14f..8096139d90 100644 --- a/tensorflow/core/common_runtime/executor.cc +++ b/tensorflow/core/common_runtime/executor.cc @@ -1966,17 +1966,9 @@ Status ExecutorState::ProcessOutputs(const NodeItem& item, OpKernelContext* ctx, device_context = device_context_map_[node->id()]; } - // Experimental: debugger (tfdb) access to intermediate node completion. - if (item.num_outputs == 0 && impl_->params_.node_outputs_cb != nullptr) { - // If the node has no output, invoke the callback with output slot set to - // -1, signifying that this is a no-output node. - s.Update(impl_->params_.node_outputs_cb(item.node->name(), -1, nullptr, - false, ctx)); - } - for (int i = 0; i < item.num_outputs; ++i) { const TensorValue val = ctx->release_output(i); - if (*ctx->is_output_dead() || val.tensor == nullptr) { + if (val.tensor == nullptr) { // Unless it's a Switch or a Recv, the node must produce a // tensor value at i-th output. if (!IsSwitch(node) && !IsRecv(node)) { @@ -2018,13 +2010,6 @@ Status ExecutorState::ProcessOutputs(const NodeItem& item, OpKernelContext* ctx, LogMemory::RecordTensorOutput(ctx->op_kernel().name(), ctx->step_id(), i, to_log); } - - // Experimental: debugger (tfdb) access to intermediate node - // outputs. - if (impl_->params_.node_outputs_cb != nullptr) { - s.Update(impl_->params_.node_outputs_cb(item.node->name(), i, - out->ref, true, ctx)); - } } else { // NOTE that std::move is used here, so val.tensor goes to // uninitialized state (val.tensor->IsInitialized return false). @@ -2036,12 +2021,6 @@ Status ExecutorState::ProcessOutputs(const NodeItem& item, OpKernelContext* ctx, LogMemory::RecordTensorOutput(ctx->op_kernel().name(), ctx->step_id(), i, *out->val); } - - // Experimental: debugger access to intermediate node outputs. - if (impl_->params_.node_outputs_cb != nullptr) { - s.Update(impl_->params_.node_outputs_cb( - item.node->name(), i, out->val.get(), false, ctx)); - } } } else { s.Update(errors::Internal("Output ", i, " of type ", |