Commit 21e5d7f9 authored by Tigran Mkrtchyan's avatar Tigran Mkrtchyan
Browse files

driver: mover pending requests population into onNext section

parent 8f19e29b
Pipeline #14979 passed with stages
in 3 minutes and 42 seconds
......@@ -169,6 +169,7 @@ public class CtaNearlineStorage implements NearlineStorage {
response.getFid(),
response.getReqId()
);
pendingRequests.put(id, new PendingRequest(Instant.now(), r));
}
@Override
......@@ -181,7 +182,6 @@ public class CtaNearlineStorage implements NearlineStorage {
@Override
public void onCompleted() {
pendingRequests.put(id, new PendingRequest(Instant.now(), r));
}
});
}
......@@ -242,6 +242,7 @@ public class CtaNearlineStorage implements NearlineStorage {
r.getFileAttributes().getPnfsId(),
response.getReqId()
);
pendingRequests.put(id, new PendingRequest(Instant.now(), r));
}
@Override
......@@ -254,7 +255,6 @@ public class CtaNearlineStorage implements NearlineStorage {
@Override
public void onCompleted() {
pendingRequests.put(id, new PendingRequest(Instant.now(), r));
}
});
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment