2 * Copyright (c) 2016 Pantheon Technologies s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.openflowjava.protocol.impl.clients;
10 import com.google.common.base.Preconditions;
11 import com.google.common.util.concurrent.SettableFuture;
12 import io.netty.bootstrap.Bootstrap;
13 import io.netty.channel.EventLoopGroup;
14 import io.netty.channel.socket.nio.NioSocketChannel;
15 import java.net.InetAddress;
16 import java.util.concurrent.Callable;
17 import org.slf4j.LoggerFactory;
21 * Callable client class, inspired by SimpleClient class.
22 * Simulating device/switch connected to controller.
24 * @author Jozef Bacigal
26 public class CallableClient implements Callable<Boolean>, OFClient {
28 private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(CallableClient.class);
30 private int port = 6653;
31 private boolean securedClient = false;
32 private InetAddress ipAddress = null;
33 private String name = "Empty name";
35 private final EventLoopGroup workerGroup;
36 private SettableFuture<Boolean> isOnlineFuture;
37 private SettableFuture<Boolean> scenarioDone;
38 private ScenarioHandler scenarioHandler = null;
39 private Bootstrap bootstrap = null;
41 public CallableClient(
43 final boolean securedClient,
44 final InetAddress ipAddress,
46 final ScenarioHandler scenarioHandler,
47 final Bootstrap bootstrap,
48 final EventLoopGroup eventExecutors) {
50 Preconditions.checkNotNull(ipAddress, "IP address cannot be null");
51 Preconditions.checkNotNull(scenarioHandler, "Scenario handler cannot be null");
53 this.securedClient = securedClient;
54 this.ipAddress = ipAddress;
55 this.workerGroup = eventExecutors;
56 this.bootstrap = bootstrap;
58 this.scenarioHandler = scenarioHandler;
62 public SettableFuture<Boolean> getIsOnlineFuture() {
63 return isOnlineFuture;
67 public SettableFuture<Boolean> getScenarioDone() {
72 public void setScenarioHandler(final ScenarioHandler scenario) {
73 this.scenarioHandler = scenario;
77 public void setSecuredClient(final boolean securedClient) {
78 this.securedClient = securedClient;
83 @SuppressWarnings("checkstyle:IllegalCatch")
84 public Boolean call() throws Exception {
85 Preconditions.checkNotNull(bootstrap);
86 Preconditions.checkNotNull(workerGroup);
87 LOG.info("Switch {} trying connect to controller", this.name);
88 SimpleClientInitializer clientInitializer = new SimpleClientInitializer(isOnlineFuture, securedClient);
89 clientInitializer.setScenario(scenarioHandler);
91 bootstrap.group(workerGroup)
92 .channel(NioSocketChannel.class)
93 .handler(clientInitializer);
95 bootstrap.connect(ipAddress, port).sync();
96 synchronized (scenarioHandler) {
97 LOG.debug("WAITING FOR SCENARIO");
98 while (!scenarioHandler.isScenarioFinished()) {
99 scenarioHandler.wait();
102 } catch (RuntimeException ex) {
103 LOG.error("Error {}", ex);
106 if (scenarioHandler.isFinishedOK()) {
107 LOG.info("Device {} finished scenario OK", this.name);
109 LOG.error("Device {} finished scenario with error", this.name);
111 return scenarioHandler.isFinishedOK();
117 throw new UnsupportedOperationException();