| 9108 | |
| 9109 | |
| 9110 | void Slave::addOperation(Operation* operation) |
| 9111 | { |
| 9112 | operations.put(operation->uuid(), operation); |
| 9113 | |
| 9114 | if (operation->info().has_id() && operation->has_framework_id()) { |
| 9115 | operationIds.put( |
| 9116 | std::make_pair(operation->framework_id(), operation->info().id()), |
| 9117 | operation->uuid()); |
| 9118 | } |
| 9119 | |
| 9120 | Result<ResourceProviderID> resourceProviderId = |
| 9121 | getResourceProviderId(operation->info()); |
| 9122 | |
| 9123 | CHECK(!resourceProviderId.isError()) |
| 9124 | << "Failed to get resource provider ID: " |
| 9125 | << resourceProviderId.error(); |
| 9126 | |
| 9127 | if (resourceProviderId.isSome()) { |
| 9128 | ResourceProvider* resourceProvider = |
| 9129 | getResourceProvider(resourceProviderId.get()); |
| 9130 | |
| 9131 | CHECK_NOTNULL(resourceProvider); |
| 9132 | |
| 9133 | resourceProvider->addOperation(operation); |
| 9134 | } |
| 9135 | } |
| 9136 | |
| 9137 | |
| 9138 | void Slave::updateOperation( |