| 981 | return; |
| 982 | } |
| 983 | if (!isOnThread() && !isTerminated()) { |
| 984 | LOG(FATAL) << "Driver::close is only allowed from the Driver's thread"; |
| 985 | } |
| 986 | closeOperators(); |
| 987 | closed_ = true; |
| 988 | Task::removeDriver(ctx_->task, this); |
| 989 | } |
| 990 | |
| 991 | void Driver::closeByTask() { |