Searched refs:cancellable_operations_ (Results 1 – 8 of 8) sorted by relevance
345 cancellable_operations_.insert(operation_id, in Truncate()381 cancellable_operations_.insert(operation_id, in Write()420 if (cancellable_operations_.find(request_id_to_cancel) == in Cancel()421 cancellable_operations_.end()) { in Cancel()426 cancellable_operations_.find(request_id_to_cancel)->value->Value(); in Cancel()461 visitor->Trace(cancellable_operations_); in Trace()607 auto it = cancellable_operations_.find(operation_id); in RemoveOperationRemote()608 if (it == cancellable_operations_.end()) in RemoveOperationRemote()610 cancellable_operations_.erase(it); in RemoveOperationRemote()
204 OperationsMap cancellable_operations_; variable
341 cancellable_operations_.insert(operation_id, std::move(op_remote)); in Truncate()375 cancellable_operations_.insert(operation_id, std::move(op_remote)); in Write()413 if (cancellable_operations_.find(request_id_to_cancel) == in Cancel()414 cancellable_operations_.end()) { in Cancel()418 cancellable_operations_.find(request_id_to_cancel) in Cancel()587 auto it = cancellable_operations_.find(operation_id); in RemoveOperationRemote()588 if (it == cancellable_operations_.end()) in RemoveOperationRemote()590 cancellable_operations_.erase(it); in RemoveOperationRemote()
203 OperationsMap cancellable_operations_; variable
212 cancellable_operations_; variable
483 cancellable_operations_.Add( in Write()536 cancellable_operations_.Add( in Truncate()629 cancellable_operations_.Clear(); in OnConnectionError()
504 cancellable_operations_.Add( in Write()557 cancellable_operations_.Add( in Truncate()650 cancellable_operations_.Clear(); in OnConnectionError()