Method StartAbort

tensorflow/core/framework/rendezvous.cc:450–470

  }

  void StartAbort(const Status& status) override {
    CHECK(!status.ok());
    Table table;
    {
      mutex_lock l(mu_);
      status_.Update(status);
      table_.swap(table);
    }
    for (auto& p : table) {
      for (Item* item : p.second) {
        if (!item->IsSendValue()) {
          if (item->ref_value != nullptr && item->ref_mutex != nullptr) {
            item->ref_waiter(status, Args(), Args(), nullptr, nullptr, false);
          } else {
            item->waiter(status, Args(), Args(), Tensor(), false);
          }
        }
        delete item;
      }
    }
  }

 private:
  typedef LocalRendezvousImpl ME;