Package org.apache.sshd.common.future

Examples of org.apache.sshd.common.future.CloseFuture.addListener()

293
294
295
296
297
298
299
300
301
302
303
        } else if (ioServiceFactory != null) {
            future = ioServiceFactory.close(immediately);
        } else {
            future = CloseableUtils.closed();
        }
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                connector = null;
                ioServiceFactory = null;
                if (shutdownExecutor && executor != null) {
                    executor.shutdown();
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
                            public void operationComplete(CloseFuture previousFuture) {
                                while (iterator.hasNext()) {
                                    Closeable c = iterator.next();
                                    if (c != null) {
                                        CloseFuture nextFuture = c.close(immediately);
                                        nextFuture.addListener(this);
                                        return;
                                    }
                                }
                                if (!iterator.hasNext()) {
                                    future.setClosed();
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
                    SshFutureListener<CloseFuture> listener = new SshFutureListener<CloseFuture>() {
                        public void operationComplete(CloseFuture previousFuture) {
                            if (iterator.hasNext()) {
                                Closeable c = iterator.next();
                                CloseFuture nextFuture = c.close(immediately);
                                nextFuture.addListener(this);
                            } else {
                                future.setClosed();
                            }
                        }
                    };
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
    }

    public CloseFuture close(boolean immediately) {
        List<IoSession> s = new ArrayList<IoSession>(sessions.values());
        CloseFuture future = CloseableUtils.parallel(s).close(immediately);
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                doDispose();
            }
        });
        return future;
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
        } else if (ioServiceFactory != null) {
            future = ioServiceFactory.close(immediately);
        } else {
            future = CloseableUtils.closed();
        }
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                acceptor = null;
                ioServiceFactory = null;
                if (shutdownExecutor && executor != null) {
                    executor.shutdown();
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
        } else if (ioServiceFactory != null) {
            future = ioServiceFactory.close(immediately);
        } else {
            future = CloseableUtils.closed();
        }
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                connector = null;
                ioServiceFactory = null;
                if (shutdownExecutor && executor != null) {
                    executor.shutdown();
View Full Code Here
290
291
292
293
294
295
296
297
298
299
300
        } else if (ioServiceFactory != null) {
            future = ioServiceFactory.close(immediately);
        } else {
            future = CloseableUtils.closed();
        }
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                connector = null;
                ioServiceFactory = null;
                if (shutdownExecutor && executor != null) {
                    executor.shutdown();
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
        } else if (ioServiceFactory != null) {
            future = ioServiceFactory.close(immediately);
        } else {
            future = CloseableUtils.closed();
        }
        future.addListener(new SshFutureListener<CloseFuture>() {
            public void operationComplete(CloseFuture future) {
                acceptor = null;
                ioServiceFactory = null;
                if (shutdownExecutor && executor != null) {
                    executor.shutdown();
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.