---

AmuletRWIL.cpp

Go to the documentation of this file.

/* ************************************************************************ 
 *         The Amulet User Interface Development Environment              *
 * ************************************************************************
 * This code was written as part of the Amulet project at                 *
 * Carnegie Mellon University, and has been placed in the public          *
 * domain.  If you are using this code or any part of Amulet,             *
 * please contact amulet@cs.cmu.edu to be put on the mailing list.        *
 * ************************************************************************/


#include <unistd.h>
#include <amulet.h>

#include <am_inc.h>
#include OBJECT_ADVANCED__H
#include STANDARD_SLOTS__H
#include OPAL_ADVANCED__H


#define Am_X10_VALUE_SLOT 0x0004


#include "rwil.h"
#include "X10Device.h"
#include "AmuletRWIL.h"
using namespace rwil;

Am_Slot_Key Am_DIMMABLE = Am_Register_Slot_Name ("Am_DIMMABLE");
Am_Slot_Key Am_HOUSE = Am_Register_Slot_Name ("Am_HOUSE");
Am_Slot_Key Am_NUMBER = Am_Register_Slot_Name ("Am_NUMBER");
Am_Slot_Key Am_CUR_VALUE = Am_Register_Slot_Name ("Am_CUR_VALUE");
Am_Slot_Key Am_READY = Am_Register_Slot_Name ("Am_READY");
Am_Slot_Key Am_CHECK_IF_READY = Am_Register_Slot_Name ("Am_CHECK_IF_READY");
Am_Slot_Key Am_DEV_PTR = Am_Register_Slot_Name("Am_DEV_PTR");
char strangebuf[10000];
Am_Object Am_X10_Device;



int grumblebuf[6000];

RWIL *g_myRWIL;
int grumblebuf2[6000];
static void x10_create (Am_Object device)
{
  Device *devptr = new X10Device(device.Get_Name(), g_myRWIL->output, 'a',1);
  device.Add(Am_DEV_PTR, (Am_Ptr)devptr);
  g_myRWIL->AddDevice(devptr);
}

//demon procedure
static void x10_destroy (Am_Object device) 
{
  fflush(stdin);
  Device *devptr = g_myRWIL->GetDevice((const std::string)(const char *)device.Get_Name());

  if(devptr)
  {
    g_myRWIL->RemoveDevice(device.Get_Name());
    delete devptr;;
  }

}



static void x10_send_message(Am_Object device)
{
  Message msg(device.Get_Name(), "dim");
  Device *devptr = (Device *)(Am_Ptr)device.Get(Am_DEV_PTR);

  if((int)device.Get(Am_VALUE) >=0)
    {

      msg.SetParam("percent", IntToString(device.Get(Am_VALUE)));
  
      ((X10Device*)devptr)->SetHouse((std::string)(const char *)(Am_String)device.Get(Am_HOUSE));
      ((X10Device*)devptr)->SetNumber((int)device.Get(Am_NUMBER));
  
      g_myRWIL->input.Add(msg);
    }
}


Am_Define_Method (Am_Timer_Method, void, x10_check_slot, (Am_Object device, const Am_Time& tme))
{
  //discover if we got a message of completion of event
  //update Am_CUR_VALUE
  std::list<Message *> lst;
  bool messagereceived = false;

  lst = g_myRWIL->output.Query("device", device.Get_Name());
  if(!lst.empty())
    {
      device.Set(Am_CUR_VALUE, atoi(lst.front()->GetParam("percent").c_str()));
      messagereceived = true;
      g_myRWIL->output.Destroy(lst);
    }
  if(messagereceived)
    {
      if(device.Get(Am_VALUE) != device.Get(Am_CUR_VALUE))
        {
          x10_send_message(device);
        }
      else
        {
          device.Set(Am_READY, true);
          Am_Stop_Timer(device, Am_CHECK_IF_READY);
        }
    }
}


//demon procedure called when "common" slots are changed
static void x10_value_slot (Am_Slot first_invalidated)
{
  Am_Object device = first_invalidated.Get_Owner ();
  if (device.Get(Am_VALUE) != device.Get(Am_CUR_VALUE))
    {
      if (device.Get(Am_READY))
        {
          x10_send_message(device);
          device.Set(Am_READY, false);
          Am_Register_Timer(Am_Time(1000), device, Am_CHECK_IF_READY, false);
        }
    }
}



// Initialize section

// this function is called by Am_Initialize
void RWIL_Initialize ()
{
  Am_Object_Advanced temp;
  Am_Demon_Set demons;
  unsigned short demon_mask;
  
  Am_X10_Device = Am_Root_Object.Create("Am_X10_Device")
    .Add (Am_ACTIVE, false) // consider a formula that checks to see if object is in window and sets active from that.
    .Add (Am_VALUE, 0)
    .Add (Am_DIMMABLE, true)
    .Add (Am_HOUSE, "")
    .Add (Am_NUMBER, -1)
    .Add (Am_CUR_VALUE, -1)
    .Add (Am_READY, true)
    .Add (Am_CHECK_IF_READY, x10_check_slot)
    ;


  temp = (Am_Object_Advanced&)Am_X10_Device;
 
  demons = temp.Get_Demons ().Copy ();
  demons.Set_Object_Demon (Am_CREATE_OBJ, x10_create);
  //  demons.Set_Object_Demon (Am_COPY_OBJ, x10_copy); // Do not really want to allow copying...  x10copy should assert
  demons.Set_Object_Demon (Am_DESTROY_OBJ, x10_destroy);
  
  temp.Get_Slot (Am_VALUE).Set_Demon_Bits (Am_X10_VALUE_SLOT |
                           Am_EAGER_DEMON);

  demons.Set_Slot_Demon (Am_X10_VALUE_SLOT, x10_value_slot,
             Am_DEMON_PER_OBJECT | Am_DEMON_ON_CHANGE);
  demon_mask = temp.Get_Demon_Mask ();
  demon_mask |= 0x0004;
  temp.Set_Demon_Mask (demon_mask);  
  temp.Set_Demons (demons);

  g_myRWIL = new RWIL;
  g_myRWIL->Start();
}
#if (0)
int main()
{
  Am_Initialize();
  RWIL_Initialize();
  Am_Object myObj = Am_X10_Device.Create("myObj");
  myObj.Set(Am_HOUSE, "A").Set(Am_NUMBER, 1).Set(Am_VALUE, 50).Validate();
  sleep(12);
  return 12;
}
#endif

---