- private void getRequests(final Node node) throws IOException, JSiteException {
- HighLevelClient highLevelClient = nodeManager.getHighLevelClient(node);
- if (highLevelClient == null) {
- logger.log(Level.WARNING, "no client for node: " + node);
- return;
- }
- final Map<String, Request> identifierRequests = Collections.synchronizedMap(new HashMap<String, Request>());
- nodeRequests.put(node, identifierRequests);
- HighLevelCallback<RequestListResult> requestListCallback;
- try {
- requestListCallback = highLevelClient.getRequests();
- requestListCallback.addHighLevelCallbackListener(new HighLevelCallbackListener<RequestListResult>() {
-
- @SuppressWarnings("synthetic-access")
- public void gotResult(HighLevelCallback<RequestListResult> highLevelCallback) {
- RequestListResult requestListResult;
- try {
- requestListResult = highLevelCallback.getResult();
- } catch (InterruptedException e) {
- logger.log(Level.SEVERE, "getResult() blocked and was interrupted");
- return;
- }
- for (RequestResult requestResult : requestListResult) {
- String identifier = requestResult.getIdentifier();
- logger.log(Level.FINER, "got identifier: " + identifier);
- Request request = identifierRequests.get(identifier);
- if (request == null) {
- request = new Request(node, identifier);
- }
- if (request.getType() == null) {
- if (requestResult instanceof GetRequestResult) {
- request.setType(Type.get);
- } else if (requestResult instanceof PutRequestResult) {
- request.setType(Type.put);
- } else if (requestResult instanceof PutDirRequestResult) {
- request.setType(Type.putDir);
- }
- }
- if (identifierRequests.containsKey(identifier)) {
- continue;
- }
- identifierRequests.put(requestResult.getIdentifier(), request);
- fireRequestAdded(request);
- }
- }
- });
- } catch (HighLevelException hle1) {
- throw new BackendException(hle1);
- }
+ private Collection<Request> wrapRequests(Collection<net.pterodactylus.fcp.highlevel.Request> requests) {
+ Collection<Request> wrappedRequests = new HashSet<Request>();
+ for (net.pterodactylus.fcp.highlevel.Request request : requests) {
+ Request wrappedRequest = new Request(request.getIdentifier());
+ wrappedRequest.setClientToken(request.getClientToken());
+ wrappedRequests.add(wrappedRequest);
+ }
+ return wrappedRequests;