TestTajoResourceManager.this.response = response;
barrier.countDown();
}
};
tajoWorkerResourceManager.allocateWorkerResources(request, callBack);
assertTrue(barrier.await(3, TimeUnit.SECONDS));
for(WorkerAllocatedResource eachResource: response.getWorkerAllocatedResourceList()) {
assertTrue("AllocatedDiskSlot:" + eachResource.getAllocatedDiskSlots(),
eachResource.getAllocatedDiskSlots() >= minDiskSlots &&