+ public void nodeConnected(Node node) {
+ FcpClient fcpClient = nodeManager.getFcpClient(node);
+ if (fcpClient == null) {
+ logger.log(Level.WARNING, "Got no FCP client for node (" + node + ")!");
+ return;
+ }
+ try {
+ Collection<Request> requests = wrapRequests(fcpClient.getRequests(true));
+ for (Request request : requests) {
+ String clientToken = request.getClientToken();
+ if ((clientToken == null) || (clientToken.trim().length() == 0)) {
+ continue;
+ }
+ if (!isKnownClientToken(clientToken)) {
+ continue;
+ }
+ /* TODO - process request. */
+ }
+ } catch (IOException ioe1) {
+ logger.log(Level.WARNING, "Could not get requests from node (" + node + ")!", ioe1);
+ } catch (FcpException fe1) {
+ logger.log(Level.WARNING, "Could not get requests from node (" + node + ")!", fe1);
+ }