File tree Expand file tree Collapse file tree 2 files changed +0
-23
lines changed
third_party/xla/xla/service/cpu Expand file tree Collapse file tree 2 files changed +0
-23
lines changed Original file line number Diff line number Diff line change @@ -22,20 +22,6 @@ namespace xla {
22
22
namespace cpu {
23
23
namespace runtime {
24
24
25
- void XfeedManager::Reset () {
26
- infeed ()->Reset ();
27
- outfeed ()->Reset ();
28
- }
29
-
30
- void XfeedQueueManager::Reset () {
31
- absl::MutexLock l (&mu_);
32
- CHECK (current_buffer_ == nullptr );
33
- for (auto buffer : enqueued_buffers_) {
34
- buffer->Done (ShapeUtil::MakeNil ());
35
- }
36
- enqueued_buffers_.clear ();
37
- }
38
-
39
25
void XfeedQueueManager::EnqueueBuffersAtomically (
40
26
absl::Span<XfeedBuffer* const > buffers) {
41
27
absl::MutexLock l (&mu_);
Original file line number Diff line number Diff line change @@ -52,13 +52,6 @@ class XfeedQueueManager {
52
52
public:
53
53
XfeedQueueManager (std::string queue_name) : queue_name_(queue_name) {}
54
54
55
- // Calls the completion callback for any enqueued buffers that have
56
- // not been dequeued by the runtime, and empties the
57
- // queue. Reset may not be called while a runtime computation is
58
- // processing a dequeued buffer. The only safe way to ensure this
59
- // condition is to call Reset when no computation is taking place.
60
- void Reset ();
61
-
62
55
// Adds a sequence of buffers to the queue atomically. buffer->Done will be
63
56
// called when the buffer will no longer be accessed by the XfeedManager,
64
57
// either as a result of a call to Reset or because the runtime has dequeued
@@ -108,8 +101,6 @@ class XfeedManager {
108
101
public:
109
102
XfeedManager () = default ;
110
103
111
- void Reset ();
112
-
113
104
XfeedQueueManager* infeed () { return &infeed_; }
114
105
XfeedQueueManager* outfeed () { return &outfeed_; }
115
106
You can’t perform that action at this time.
0 commit comments