devicemonitor.java

这是一个以JAVA编写的程序,本人还没有试过,是一个简单的温度控制系统

/*---------------------------------------------------------------------------
 * Copyright (C) 2002 Dallas Semiconductor Corporation, All Rights Reserved.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a
 * copy of this software and associated documentation files (the "Software"),
 * to deal in the Software without restriction, including without limitation
 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
 * and/or sell copies of the Software, and to permit persons to whom the
 * Software is furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included
 * in all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY,  FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 * IN NO EVENT SHALL DALLAS SEMICONDUCTOR BE LIABLE FOR ANY CLAIM, DAMAGES
 * OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 * OTHER DEALINGS IN THE SOFTWARE.
 *
 * Except as contained in this notice, the name of Dallas Semiconductor
 * shall not be used except as stated in the Dallas Semiconductor
 * Branding Policy.
 *---------------------------------------------------------------------------
 */
package com.dalsemi.onewire.application.monitor;

import java.util.Enumeration;
import java.util.Vector;

import com.dalsemi.onewire.utils.OWPath;
import com.dalsemi.onewire.utils.OWPathElement;
import com.dalsemi.onewire.adapter.DSPortAdapter;
import com.dalsemi.onewire.OneWireException;
import com.dalsemi.onewire.adapter.OneWireIOException;
import com.dalsemi.onewire.container.OneWireContainer;

/**
 * <P>Class DeviceMonitor represents the monitor that searches the 1-Wire net
 * for new arrivals.  This monitor performs a simple search, meaning that
 * no branches are explicitly traversed.  If a branch is activated/deactivated
 * between search cycles, this monitor will see the arrival/departure of
 * new devices without reference to the branch which they lie on.</P>
 *
 * @author SH
 * @version 1.00
 */
public class DeviceMonitor
   extends AbstractDeviceMonitor
{
   private OWPath defaultPath = null;

   /**
    * Create a simple monitor that does not search branches
    *
    * @param the DSPortAdapter this monitor should search
    */
   public DeviceMonitor(DSPortAdapter adapter)
   {
      setAdapter(adapter);
   }

   /**
    * Sets this monitor to search a new DSPortAdapter
    *
    * @param the DSPortAdapter this monitor should search
    */
   public void setAdapter(DSPortAdapter adapter)
   {
      if(adapter==null)
         throw new IllegalArgumentException("Adapter cannot be null");

      synchronized(sync_flag)
      {
         this.adapter = adapter;
         defaultPath = new OWPath(adapter);

         resetSearch();
      }
   }

   /**
    * Returns the OWPath of the device with the given address.
    *
    * @param address a Long object representing the address of the device
    * @return The OWPath representing the network path to the device.
    */
   public OWPath getDevicePath(Long address)
   {
      return defaultPath;
   }

   /**
    * Performs a search of the 1-Wire network without searching branches
    *
    * @param arrivals A vector of Long objects, represent new arrival addresses.
    * @param departures A vector of Long objects, represent departed addresses.
    */
   public void search(Vector arrivals, Vector departures)
      throws OneWireException, OneWireIOException
   {
      synchronized(sync_flag)
      {
         try
         {
            // aquire the adapter
            adapter.beginExclusive(true);

            // setup the search
            adapter.setSearchAllDevices();
            adapter.targetAllFamilies();
            adapter.setSpeed(adapter.SPEED_REGULAR);

            boolean search_result = adapter.findFirstDevice();

            // loop while devices found
            while (search_result)
            {
               // get the 1-Wire address
               Long longAddress = new Long(adapter.getAddressAsLong());
               if(!deviceAddressHash.containsKey(longAddress) && arrivals!=null)
                  arrivals.addElement(longAddress);

               deviceAddressHash.put(longAddress, new Integer(max_state_count));

               // search for the next device
               search_result = adapter.findNextDevice();
            }
         }
         finally
         {
            adapter.endExclusive();
         }

         // remove any devices that have not been seen
         for (Enumeration device_enum = deviceAddressHash.keys();
                 device_enum.hasMoreElements(); )
         {
            Long longAddress = (Long)device_enum.nextElement();

            // check for removal by looking at state counter
            int cnt = ((Integer)deviceAddressHash.get(longAddress)).intValue();
            if (cnt <= 0)
            {
               deviceAddressHash.remove(longAddress);
               if(departures!=null)
                  departures.addElement(longAddress);

               synchronized(deviceContainerHash)
               {
                  deviceContainerHash.remove(longAddress);
               }
            }
            else
            {
               // it stays
               deviceAddressHash.put(longAddress, new Integer(cnt-1));
            }
         }

         // fire notification events
         if(arrivals!=null && arrivals.size()>0)
            fireArrivalEvent(adapter, arrivals);
         if(departures!=null && departures.size()>0)
            fireDepartureEvent(adapter, departures);
      }
   }
}