| 213 | BaseCollectiveExecutor::~BaseCollectiveExecutor() {} |
| 214 | |
| 215 | void BaseCollectiveExecutor::StartAbort(const Status& s) { |
| 216 | LOG(WARNING) << "BaseCollectiveExecutor::StartAbort " << s; |
| 217 | remote_access_->StartAbort(s); |
| 218 | } |
| 219 | |
| 220 | void BaseCollectiveExecutor::ExecuteAsync(OpKernelContext* ctx, |
| 221 | const CollectiveParams& col_params, |