| 501 | } |
| 502 | |
| 503 | void complete(RelocateData const& relocation, std::map<UID, Busyness>& busymap, std::map<UID, Busyness>& destBusymap) { |
| 504 | ASSERT(relocation.workFactor > 0); |
| 505 | for (int i = 0; i < relocation.src.size(); i++) |
| 506 | busymap[relocation.src[i]].removeWork(relocation.priority, relocation.workFactor); |
| 507 | |
| 508 | completeDest(relocation, destBusymap); |
| 509 | } |
| 510 | |
| 511 | // Cancells in-flight data moves intersecting with range. |
| 512 | ACTOR Future<Void> cancelDataMove(struct DDQueue* self, KeyRange range, const DDEnabledState* ddEnabledState); |
no test coverage detected