local_rendezvous.cc
imports tensorflow/core/platform/logging.himports tensorflow/core/platform/mutex.h
SHA-256e157dfcb0fed2d847a90ba6e412384155d7ce28e2d89e67fab54470c1b5745d5
MaleculeMd(In₆)
Evidence
1/* Copyright 2015 The TensorFlow Authors. All Rights Reserved.
2
3Licensed under the Apache License, Version 2.0 (the "License");
4you may not use this file except in compliance with the License.
5You may obtain a copy of the License at
6
7 http://www.apache.org/licenses/LICENSE-2.0
8
9Unless required by applicable law or agreed to in writing, software
10distributed under the License is …
11:42… IND, either express or implied.
12See the License for the specific language governing permissions and
13limitations under the License.
14==============================================================================*/
15
16#include "tensorflow/core/framework/local_rendezvous.h"
17
18#include <memory>
19#include <string>
20#include <utility>
21
22#include "absl/status/status.h"
23#include "absl/strings/str_format.h"
24#include "xla/tsl/platform/logging.h"
25#include "tensorflow/core/activity_watcher/activity.h"
26#include "tensorflow/core/framework/allocator.h"
27#include "tensorflow/core/framework/types.h"
28#include "tensorflow/core/lib/core/errors.h"
29#include "tensorflow/core/lib/core/notification.h"
30#include "tensorflow/core/lib/gtl/manual_constructor.h"
31#include "tensorflow/core/lib/monitoring/counter.h"
32#include "tensorflow/core/lib/strings/numbers.h"
33#include "tensorflow/core/lib/strings/str_util.h"
34#include "tensorflow/core/platform/logging.h"
35#include "tensorflow/core/platform/mutex.h"
36#include "tensorflow/core/platform/refcount.h"
37#include "tensorflow/core/platform/types.h"
38#include "tsl/platform/refcount.h"
39
40namespace tensorflow {
41
42// Represents a blocked Send() or Recv() call in the rendezvous.
43// Item hols a reference to the own …
123:45… nce, make sure all the done-callback
124 // calls have finished and the tensors have been released from the queue.
125 bool table_not_empty = false;
126 f …
260:12… ke a reference for the cancellation callback so that it does not
261 // access LocalRendezvous after it is destroyed. It's dropped either
262 // …