*/
package org.opendaylight.controller.sal.restconf.impl;
+import java.math.BigInteger;
+import java.util.Collection;
+import java.util.Collections;
import org.opendaylight.controller.config.yang.md.sal.rest.connector.Config;
import org.opendaylight.controller.config.yang.md.sal.rest.connector.Get;
import org.opendaylight.controller.config.yang.md.sal.rest.connector.Operational;
import org.opendaylight.controller.config.yang.md.sal.rest.connector.Rpcs;
import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker;
import org.opendaylight.controller.md.sal.dom.api.DOMMountPointService;
+import org.opendaylight.controller.md.sal.dom.api.DOMRpcService;
import org.opendaylight.controller.sal.core.api.Broker.ProviderSession;
import org.opendaylight.controller.sal.core.api.Provider;
import org.opendaylight.controller.sal.core.api.model.SchemaService;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.yangtools.yang.model.api.SchemaContextListener;
-import java.math.BigInteger;
-import java.util.Collection;
-import java.util.Collections;
-
public class RestconfProviderImpl implements Provider, AutoCloseable, RestConnector, RestConnectorRuntimeMXBean {
private final StatisticsRestconfServiceWrapper stats = StatisticsRestconfServiceWrapper.getInstance();
private PortNumber port;
private Thread webSocketServerThread;
- public void setWebsocketPort(PortNumber port) {
+ public void setWebsocketPort(final PortNumber port) {
this.port = port;
}
@Override
- public void onSessionInitiated(ProviderSession session) {
+ public void onSessionInitiated(final ProviderSession session) {
final DOMDataBroker domDataBroker = session.getService(DOMDataBroker.class);
BrokerFacade.getInstance().setContext(session);
BrokerFacade.getInstance().setDomDataBroker( domDataBroker);
-
- SchemaService schemaService = session.getService(SchemaService.class);
+ final SchemaService schemaService = session.getService(SchemaService.class);
listenerRegistration = schemaService.registerSchemaContextListener(ControllerContext.getInstance());
+ BrokerFacade.getInstance().setRpcService(session.getService(DOMRpcService.class));
+
+
ControllerContext.getInstance().setSchemas(schemaService.getGlobalContext());
ControllerContext.getInstance().setMountService(session.getService(DOMMountPointService.class));
@Override
public Config getConfig() {
- Config config = new Config();
- Get get = new Get();
+ final Config config = new Config();
+ final Get get = new Get();
get.setReceivedRequests(stats.getConfigGet());
config.setGet(get);
- Post post = new Post();
+ final Post post = new Post();
post.setReceivedRequests(stats.getConfigPost());
config.setPost(post);
- Put put = new Put();
+ final Put put = new Put();
put.setReceivedRequests(stats.getConfigPut());
config.setPut(put);
return config;
@Override
public Operational getOperational() {
- BigInteger opGet = stats.getOperationalGet();
- Operational operational = new Operational();
- Get get = new Get();
+ final BigInteger opGet = stats.getOperationalGet();
+ final Operational operational = new Operational();
+ final Get get = new Get();
get.setReceivedRequests(opGet);
operational.setGet(get);
return operational;
@Override
public Rpcs getRpcs() {
- BigInteger rpcInvoke = stats.getRpc();
- Rpcs rpcs = new Rpcs();
+ final BigInteger rpcInvoke = stats.getRpc();
+ final Rpcs rpcs = new Rpcs();
rpcs.setReceivedRequests(rpcInvoke);
return rpcs ;
}