Package net.tomp2p.futures

Examples of net.tomp2p.futures.FutureResponse.addListener()

227
228
229
230
231
232
233
234
235
236
237
          if (future2.isSuccess()) {
            SyncBuilder synchronizationBuilder = new SyncBuilder(senderSync, receiverAddress, 5);
            synchronizationBuilder.dataMap(dataMap);
            final FutureResponse futureResponse = senderSync.syncRPC().infoMessage(
                    receiverAddress, synchronizationBuilder, future2.channelCreator());
            futureResponse.addListener(new BaseFutureAdapter<FutureResponse>() {
              @Override
              public void operationComplete(FutureResponse future) throws Exception {
                System.err.println(future.failedReason());
                ref.set(future.responseMessage().type());
                ref2.set(future.responseMessage().dataMap(0));
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
          if (future2.isSuccess()) {
            SyncBuilder synchronizationBuilder = new SyncBuilder(senderSync, receiverAddress, 5);
            synchronizationBuilder.dataMap(dataMap);
            final FutureResponse futureResponse = senderSync.syncRPC().infoMessage(
                    receiverAddress, synchronizationBuilder, future2.channelCreator());
            futureResponse.addListener(new BaseFutureAdapter<FutureResponse>() {
              @Override
              public void operationComplete(FutureResponse future) throws Exception {
                ref.set(future.responseMessage().dataMap(0));
                Utils.addReleaseListener(future2.channelCreator(), futureResponse);
                latch.countDown();
View Full Code Here
360
361
362
363
364
365
366
367
368
369
370
          if (future2.isSuccess()) {
            SyncBuilder synchronizationBuilder = new SyncBuilder(senderSync, receiverAddress, 5);
            synchronizationBuilder.dataMap(dataMap);
            final FutureResponse futureResponse = senderSync.syncRPC().infoMessage(receiverAddress,
                    synchronizationBuilder, future2.channelCreator());
            futureResponse.addListener(new BaseFutureAdapter<FutureResponse>() {
              @Override
              public void operationComplete(FutureResponse future) throws Exception {
                ref.set(future.responseMessage().dataMap(0));
                Utils.addReleaseListener(future2.channelCreator(), futureResponse);
                latch.countDown();
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
    Message message = dispatchHandler.createMessage(relayAddress(), Commands.RELAY.getNr(), Type.REQUEST_4);
    // close the connection after this message
    message.keepAlive(false);

    FutureResponse response = sendToRelay(message);
    response.addListener(new BaseFutureAdapter<FutureResponse>() {
      @Override
      public void operationComplete(FutureResponse futureResponse) throws Exception {
        if (futureResponse.isSuccess()) {
          // reset the fail counter
          reachRelayFailCounter = 0;
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
                    LOG.error("checkDirect failed {}", future2.failedReason());
                    return;
                }
                final FutureResponse futureResponse = peerSync.syncRPC().infoMessage(other,
                        SyncBuilder.this, future2.channelCreator());
                futureResponse.addListener(new BaseFutureAdapter<FutureResponse>() {
                    @Override
                    public void operationComplete(FutureResponse future) throws Exception {
                        if (future.isFailed()) {
                            Utils.addReleaseListener(future2.channelCreator(), futureResponse);
                            futureSync.failed(future);
View Full Code Here
272
273
274
275
276
277
278
279
280
281
282
                        final SyncStat syncStat = new SyncStat(peer.peerAddress().peerId(), other.peerId(), dataCopy, dataOrig);
                        if (syncMessageRequired) {
                          SyncBuilder.this.dataMap(new DataMap(retVal));
                          FutureResponse fr = peerSync.syncRPC().syncMessage(other,
                                    SyncBuilder.this, future2.channelCreator());
                            fr.addListener(new BaseFutureAdapter<FutureResponse>() {
                                @Override
                                public void operationComplete(FutureResponse future) throws Exception {
                                    if (future.isFailed()) {
                                        futureSync.failed(future);
                                    } else {
View Full Code Here
393
394
395
396
397
398
399
400
401
402
403
                    if (future.isSuccess()) {
                        PutBuilder putBuilder = new PutBuilder(peer, locationKey);
                        putBuilder.dataMap(dataMap);
                        FutureResponse futureResponse = storageRPC.put(other, putBuilder,
                                future.channelCreator());
                        futureResponse.addListener(new BaseFutureAdapter<FutureResponse>() {
              @Override
              public void operationComplete(FutureResponse future)
                  throws Exception {
                if(future.isSuccess()) {
                  futureDone.done(); 
View Full Code Here
224
225
226
227
228
229
230
231
232
233
234
                sendDirectBuilder.object((Object) Integer.valueOf(i));

                FutureResponse futureData = sender.directDataRPC().send(recv1.peerAddress(),
                        sendDirectBuilder, cc);
                Utils.addReleaseListener(cc, futureData);
                futureData.addListener(new BaseFutureAdapter<FutureResponse>() {
                    @Override
                    public void operationComplete(FutureResponse future) throws Exception {
                        // the future object might be null if the future failed,
                        // e.g due to shutdown
                        System.err.println(future.responseMessage().buffer(0).object());
View Full Code Here
215
216
217
218
219
220
221
222
223
224
225
        });

        final FutureResponse futureResponseTCP = peer.pingRPC().pingTCPDiscover(peerAddress, cc,
                configuration);
       
        futureResponseTCP.addListener(new BaseFutureAdapter<FutureResponse>() {
            @Override
            public void operationComplete(FutureResponse future) throws Exception {
                PeerAddress serverAddress = peer.peerBean().serverPeerAddress();
                if (futureResponseTCP.isSuccess()) {
                    Collection<PeerAddress> tmp = futureResponseTCP.responseMessage().neighborsSet(0)
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
                        }
                        // else -> we announce exactly how the other peer sees
                        // us
                        FutureResponse fr1 = peer.pingRPC().pingTCPProbe(peerAddress, cc,
                                configuration);
                        fr1.addListener(new BaseFutureAdapter<FutureResponse>() {
              @Override
                            public void operationComplete(FutureResponse future) throws Exception {
                              if(future.isFailed()) {
                                futureDiscover.failed("FutureDiscover (2): We need at least the TCP connection", future);
                              }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.