/* * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.controller.sample.toaster.provider; import java.util.Arrays; import java.util.Collections; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.atomic.AtomicLong; import org.opendaylight.controller.config.yang.config.toaster_provider.impl.ToasterProviderRuntimeMXBean; import org.opendaylight.controller.md.sal.common.api.data.DataChangeEvent; import org.opendaylight.controller.sal.binding.api.NotificationProviderService; import org.opendaylight.controller.sal.binding.api.data.DataBrokerService; import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction; import org.opendaylight.controller.sal.common.util.RpcErrors; import org.opendaylight.controller.sal.common.util.Rpcs; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.DisplayString; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.MakeToastInput; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.Toaster; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.Toaster.ToasterStatus; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.RestockToasterInput; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.ToasterBuilder; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.ToasterOutOfBreadBuilder; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.ToasterRestocked; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.ToasterRestockedBuilder; import org.opendaylight.yang.gen.v1.http.netconfcentral.org.ns.toaster.rev091120.ToasterService; import org.opendaylight.controller.sal.binding.api.data.DataChangeListener; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.common.RpcError; import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.google.common.util.concurrent.Futures; public class OpendaylightToaster implements ToasterService, ToasterProviderRuntimeMXBean, DataChangeListener, AutoCloseable { private static final Logger LOG = LoggerFactory.getLogger(OpendaylightToaster.class); public static final InstanceIdentifier TOASTER_IID = InstanceIdentifier.builder(Toaster.class).build(); private static final DisplayString TOASTER_MANUFACTURER = new DisplayString("Opendaylight"); private static final DisplayString TOASTER_MODEL_NUMBER = new DisplayString("Model 1 - Binding Aware"); private NotificationProviderService notificationProvider; private DataBrokerService dataProvider; private final ExecutorService executor; // As you will see we are using multiple threads here. Therefore we need to be careful about concurrency. // In this case we use the taskLock to provide synchronization for the current task. private volatile Future> currentTask; private final Object taskLock = new Object(); private final AtomicLong amountOfBreadInStock = new AtomicLong( 100 ); private final AtomicLong toastsMade = new AtomicLong(0); // Thread safe holder for our darkness multiplier. private final AtomicLong darknessFactor = new AtomicLong( 1000 ); public OpendaylightToaster() { executor = Executors.newFixedThreadPool(1); } public void setNotificationProvider(NotificationProviderService salService) { this.notificationProvider = salService; } public void setDataProvider(DataBrokerService salDataProvider) { this.dataProvider = salDataProvider; updateStatus(); } /** * Implemented from the AutoCloseable interface. */ @Override public void close() throws ExecutionException, InterruptedException { // When we close this service we need to shutdown our executor! executor.shutdown(); if (dataProvider != null) { final DataModificationTransaction t = dataProvider.beginTransaction(); t.removeOperationalData(TOASTER_IID); t.commit().get(); } } private Toaster buildToaster() { // We don't need to synchronize on currentTask here b/c it's declared volatile and // we're just doing a read. boolean isUp = currentTask == null; // note - we are simulating a device whose manufacture and model are // fixed (embedded) into the hardware. // This is why the manufacture and model number are hardcoded. ToasterBuilder tb = new ToasterBuilder(); tb.setToasterManufacturer(TOASTER_MANUFACTURER).setToasterModelNumber(TOASTER_MODEL_NUMBER) .setToasterStatus(isUp ? ToasterStatus.Up : ToasterStatus.Down); return tb.build(); } /** * Implemented from the DataChangeListener interface. */ @Override public void onDataChanged( DataChangeEvent, DataObject> change ) { DataObject dataObject = change.getUpdatedConfigurationData().get( TOASTER_IID ); if( dataObject instanceof Toaster ) { Toaster toaster = (Toaster) dataObject; Long darkness = toaster.getDarknessFactor(); if( darkness != null ) { darknessFactor.set( darkness ); } } } /** * RestConf RPC call implemented from the ToasterService interface. */ @Override public Future> cancelToast() { synchronized (taskLock) { if (currentTask != null) { currentTask.cancel(true); currentTask = null; } } // Always return success from the cancel toast call. return Futures.immediateFuture(Rpcs. getRpcResult(true, Collections. emptySet())); } /** * RestConf RPC call implemented from the ToasterService interface. */ @Override public Future> makeToast(MakeToastInput input) { LOG.info("makeToast: " + input); synchronized (taskLock) { if (currentTask != null) { // return an error since we are already toasting some toast. LOG.info( "Toaster is already making toast" ); RpcResult result = Rpcs. getRpcResult(false, null, Arrays.asList( RpcErrors.getRpcError( null, null, null, null, "Toaster is busy", null, null ) ) ); return Futures.immediateFuture(result); } else if( outOfBread() ) { RpcResult result = Rpcs. getRpcResult(false, null, Arrays.asList( RpcErrors.getRpcError( null, null, null, null, "Toaster is out of bread", null, null ) ) ); return Futures.immediateFuture(result); } else { // Notice that we are moving the actual call to another thread, // allowing this thread to return immediately. // The MD-SAL design encourages asynchronus programming. If the // caller needs to block until the call is // complete then they can leverage the blocking methods on the // Future interface. currentTask = executor.submit(new MakeToastTask(input)); } } updateStatus(); return currentTask; } /** * RestConf RPC call implemented from the ToasterService interface. * Restocks the bread for the toaster, resets the toastsMade counter to 0, and sends a * ToasterRestocked notification. */ @Override public Future> restockToaster(RestockToasterInput input) { LOG.info( "restockToaster: " + input ); synchronized( taskLock ) { amountOfBreadInStock.set( input.getAmountOfBreadToStock() ); if( amountOfBreadInStock.get() > 0 ) { ToasterRestocked reStockedNotification = new ToasterRestockedBuilder().setAmountOfBread( input.getAmountOfBreadToStock() ).build(); notificationProvider.publish( reStockedNotification ); } } return Futures.immediateFuture(Rpcs. getRpcResult(true, Collections. emptySet())); } /** * JMX RPC call implemented from the ToasterProviderRuntimeMXBean interface. */ @Override public void clearToastsMade() { LOG.info( "clearToastsMade" ); toastsMade.set( 0 ); } /** * Accesssor method implemented from the ToasterProviderRuntimeMXBean interface. */ @Override public Long getToastsMade() { return toastsMade.get(); } private void updateStatus() { if (dataProvider != null) { final DataModificationTransaction t = dataProvider.beginTransaction(); t.removeOperationalData(TOASTER_IID); t.putOperationalData(TOASTER_IID, buildToaster()); try { t.commit().get(); } catch (InterruptedException | ExecutionException e) { LOG.warn("Failed to update toaster status, operational otherwise", e); } } else { LOG.trace("No data provider configured, not updating status"); } } private boolean outOfBread() { return amountOfBreadInStock.get() == 0; } private class MakeToastTask implements Callable> { final MakeToastInput toastRequest; public MakeToastTask(MakeToastInput toast) { toastRequest = toast; } @Override public RpcResult call() { try { // make toast just sleeps for n secondn per doneness level. long darknessFactor = OpendaylightToaster.this.darknessFactor.get(); Thread.sleep(darknessFactor * toastRequest.getToasterDoneness()); } catch( InterruptedException e ) { LOG.info( "Interrupted while making the toast" ); } toastsMade.incrementAndGet(); amountOfBreadInStock.getAndDecrement(); if( outOfBread() ) { LOG.info( "Toaster is out of bread!" ); notificationProvider.publish( new ToasterOutOfBreadBuilder().build() ); } synchronized (taskLock) { currentTask = null; } updateStatus(); LOG.debug("Toast done"); return Rpcs. getRpcResult(true, null, Collections. emptySet()); } } }