File content as of revision 1:918ffa99c345:

/*
 *
 * RPC Over UDP
 *
 * Command format is same as serial RPC (not HTTP RPC)
 *
 * (example)
 * So you can control mbed by sending the followng command (over UDP)
 * /DigitalOut/new LED1 myled
 * /myled/write 1
 * /AnalogIn/new p20 ain
 * /ain/read
 *
 * Please find attached Test Programs(processing & ActionScript3) at end of this file as comment "#if 0"
 *
 */

// 2010/11/16
// Fixed test program(processing)
// to run it in both windows and linux.

// 2010/11/15
// written by: xshige


#define DEBUG

// Send Port (RPC output)
#define OUTPUT_PORT 8001
// Receive Port (RPC input)
#define INPUT_PORT 8000

#define DEBUG

// please comment out if you want two way unicast
#define SENDBACK_UNICAST

#define DHCP

#include "mbed.h"
#include "EthernetNetIf.h"
#include "UDPSocket.h"

#include "rpc.h"
Serial pc(USBTX, USBRX);

#ifdef DHCP
EthernetNetIf eth;
#else
EthernetNetIf eth(
  IpAddr(192,168,0,25), //IP Address
  IpAddr(255,255,255,0), //Network Mask
  IpAddr(192,168,0,1), //Gateway
  IpAddr(192,168,0,1)  //DNS
);
#endif

UDPSocket udpRec;
UDPSocket udpSend;


// mulitcast UDP
#ifdef SENDBACK_UNICAST
Host recHost(IpAddr(239, 255, 0, 1), INPUT_PORT, NULL);  // Receive Port (RPC input)
// multicast IP
// "224.0.0.1" works correctly.
// "224.0.0.2" does not work(can Not receive)
// "239.255.0.0"-"239.255.255.255" (Site-Local Scope) maybe work
#else
// please change IP address to fit your enviroment
// unicast IUDP
Host sendHost(IpAddr(192, 168, 0, 7), OUTPUT_PORT, NULL); // Send Port (RPC output)
Host recHost(IpAddr(192, 168, 0, 7), INPUT_PORT, NULL);  // Receive Port (RPC input)
//Host sendHost(IpAddr(239, 255, 0, 1), OUTPUT_PORT, NULL); // Send Port (RPC output)
//Host recHost(IpAddr(239, 255, 0, 1), INPUT_PORT, NULL);  // Receive Port (RPC input)
#endif
  
// receive commands, and send back the responses
char inbuf[512], outbuf[512];

void onUDPSocketEvent(UDPSocketEvent e)
{

  switch(e)
  {
  case UDPSOCKET_READABLE: //The only event for now

    Host host;
    while( int len = udpRec.recvfrom( inbuf, 512, &host ) )
    {
      if( len <= 0 )
        break;
      inbuf[len]=0;
#ifdef DEBUG
      printf("\r\nFrom %d.%d.%d.%d: %s\r\n", 
      host.getIp()[0], host.getIp()[1], host.getIp()[2], host.getIp()[3], inbuf);
#endif

#ifdef SENDBACK_UNICAST
    Host sendHost(IpAddr(
            host.getIp()[0], host.getIp()[1], host.getIp()[2], host.getIp()[3]),
            OUTPUT_PORT, NULL); // Send Port (RPC output)
#endif

        udpSend.bind(sendHost);

#ifdef DEBUG
        printf("debug1:%d %s\r\n",len,inbuf);
#endif
        if (len>0) {
            rpc(inbuf, outbuf); 
            udpSend.sendto( outbuf, strlen(outbuf), &sendHost);
        }
#ifdef DEBUG
        printf("debug2:%s\r\n", outbuf);
#endif
    }
    break;
  }
}

int main() {
// make debug port Fast
   Serial pc(USBTX, USBRX);
//    pc.baud(9600);
    pc.baud(115200);
//  pc.baud(230400);

    // setup the classes that can be created dynamically
    Base::add_rpc_class<AnalogIn>();
    Base::add_rpc_class<AnalogOut>();
    Base::add_rpc_class<DigitalIn>();
    Base::add_rpc_class<DigitalOut>();
    Base::add_rpc_class<DigitalInOut>();
    Base::add_rpc_class<PwmOut>();
    Base::add_rpc_class<Timer>();
    Base::add_rpc_class<SPI>();
    Base::add_rpc_class<BusOut>();
    Base::add_rpc_class<BusIn>();
    Base::add_rpc_class<BusInOut>();
    Base::add_rpc_class<Serial>();
    
    // setup network
    printf("Setting up...\r\n");
    EthernetErr ethErr = eth.setup();
    if(ethErr) {
        printf("Error %d in setup.\r\n", ethErr);
        return -1;
    }

    printf("UDP RPC Setup OK\r\n");
    
    udpRec.setOnEvent(&onUDPSocketEvent);
  
    udpRec.bind(recHost);
    
  
    while(1) {
        Net::poll();
 #if 0
 // debug code
        Host host;
        int len = udpRec.recvfrom( inbuf, 512, &host );   
        printf("debug:%d %s\r\n",len,inbuf);
  len=1;
        if (len>0) {
            rpc(inbuf, outbuf); 
  strcpy(outbuf,"RPC UDP Test");
            udpSend.sendto( outbuf, strlen(outbuf), &sendHost );
            memset(inbuf,0,512);
        }
        printf("debug:%s\r\n", outbuf);
        memset(outbuf,0,512);
        wait(1);
#endif
   }    

}

#if 0
//------------------------------------------------------------------------
// Test Program (written in processing)

// Important Note:
//  this program can NOT work in windows enviroment (only Linux enviroment)
//
//  2010/11/16:
//    Above bug fixed. Now it can work in both windows and linux.
//    Note: Please set your host IP.

/**
 * RCP over UDP (by mbed)
 * Test Program
 *
 * you can get UDP library from:
 * http://ubaa.net/shared/processing/udp/
 *
 */

// import UDP library
import hypermedia.net.*;

String remoteIP = "239.255.0.1"; // multicast IP
String localIP = "192.168.0.7"; // please set your host IP (2010/11/16)
int INPUT_PORT = 8000;
int OUTPUT_PORT = 8001;

UDP udp;  // define the UDP object

/**
 * init
 */
void setup() {
  // create a new datagram connection on port OUTPUT_PORT
  // and wait for incomming message
  udp = new UDP( this, OUTPUT_PORT, localIP ); // (2010/11/16)
// udp.log( true ); // <-- printout the connection activity
  udp.listen( true );
}

//process events
void draw() {;}

/* 
 * on key pressed event:
 * pressing a key sends predefined command
 */
void keyPressed() {
    String cmd="";
    if (key == '1') cmd="/";
    //
    if (key == '2') cmd="/AnalogIn/new p20 ain";
    if (key == '3') cmd="/ain/read";
    //
    if (key == '4') cmd="/AnalogOut/new p18 aout";
    if (key == '5') cmd="/aout/";
    if (key == '6') cmd="/aout/write_u16 4123";    
//   if (key == '4') cmd="/BusIn/new bin p23 p22 p21";
//   if (key == '5') cmd="/bin/read";
    //   
    if (key == '8') cmd="/DigitalOut/new LED4 myled4";
    if (key == '9') cmd="/myled4/write 1";
    if (key == '0') cmd="/myled4/write 0";    

    // send the command
    udp.send( cmd, remoteIP, INPUT_PORT );
 
}

/*
 * To perform any action on datagram reception
 */

void receive( byte[] data, String ip, int port ) {

  data = subset(data, 0, data.length);
  String message = new String( data );
  
  // print the result
  println( "received: \""+message+"\" from "+ip+" on port "+port );
}
//----------------------------------------------------------------------------
#endif

#if 0
//------------------------------------------------------------------------
// Test Program (written in ActionScript3)

// Important Note:
//  this program can work in both windows and Linux enviroment.

// DatagramSocketExample.as
//
// This program is comming from:
// http://help.adobe.com/en_US/FlashPlatform/beta/reference/actionscript/3/flash/net/DatagramSocket.html
//
// I changed some parameters(IP address, port# etc ) for testing mbed HTTP over UDP
// You can send command over UDP by changing "message:" field
//
//  You must build it as AIR application to utilize UDP capability.
//  localIP should be changed to fit your enviroment.
//
package
{
    import flash.display.Sprite;
    import flash.events.DatagramSocketDataEvent;
    import flash.events.Event;
    import flash.events.MouseEvent;
    import flash.events.TimerEvent;
    import flash.net.DatagramSocket;
    import flash.text.TextField;
    import flash.text.TextFieldAutoSize;
    import flash.text.TextFieldType;
    import flash.utils.ByteArray;
    import flash.utils.Timer;
    
    public class DatagramSocketExample extends Sprite
    {
        private var datagramSocket:DatagramSocket = new DatagramSocket();;

        private var localIP:TextField;
        private var localPort:TextField;
        private var logField:TextField;
        private var targetIP:TextField;
        private var targetPort:TextField;
        private var message:TextField;
        
        public function DatagramSocketExample()
        {
            setupUI();
        }

        private function bind( event:Event ):void
        {
            if( datagramSocket.bound ) 
            {
                datagramSocket.close();
                datagramSocket = new DatagramSocket();
                
            }
            datagramSocket.bind( parseInt( localPort.text ), localIP.text );
            datagramSocket.addEventListener( DatagramSocketDataEvent.DATA, dataReceived );
            datagramSocket.receive();
            log( "Bound to: " + datagramSocket.localAddress + ":" + datagramSocket.localPort );
        }
        
        private function dataReceived( event:DatagramSocketDataEvent ):void
        {
            //Read the data from the datagram
            log("Received from " + event.srcAddress + ":" + event.srcPort + "> " + 
                event.data.readUTFBytes( event.data.bytesAvailable ) );
        }
        
        private function send( event:Event ):void
        {
            //Create a message in a ByteArray
            var data:ByteArray = new ByteArray();
            data.writeUTFBytes( message.text );
            
            //Send a datagram to the target
            try
            {
                datagramSocket.send( data, 0, 0, targetIP.text, parseInt( targetPort.text )); 
                log( "Sent message to " + targetIP.text + ":" + targetPort.text );
            }
            catch ( error:Error )
            {
                log( error.message );
            }
        }
        
        private function log( text:String ):void
        {
            logField.appendText( text + "\n" );
            logField.scrollV = logField.maxScrollV;
            trace( text );
        }
        private function setupUI():void
        {
//            targetIP = createTextField( 10, 10, "Target IP:", "192.168.0.1" );
//            targetPort = createTextField( 10, 35, "Target port:", "8989" );

            targetIP = createTextField( 10, 10, "Target IP:", "239.255.0.1" ); 
            targetPort = createTextField( 10, 35, "Target port:", "8000" );
            
            message = createTextField( 10, 60, "Message:", "/AnalogIn/new p20 ain" );
//          localIP = createTextField( 10, 85, "Local IP", "0.0.0.0");
//           localPort = createTextField( 10, 110, "Local port:", "0" );

            localIP = createTextField( 10, 85, "Local IP", "192.168.0.7"); // set your host IP
            localPort = createTextField( 10, 110, "Local port:", "8001" );

            createTextButton( 250, 135, "Bind", bind );
            createTextButton( 300, 135, "Send", send );
            logField = createTextField( 10, 160, "Log:", "", false, 200 )
                
            this.stage.nativeWindow.activate();
        }
        
        private function createTextField( x:int, y:int, label:String, defaultValue:String = '', editable:Boolean = true, height:int = 20 ):TextField
        {
            var labelField:TextField = new TextField();
            labelField.text = label;
            labelField.type = TextFieldType.DYNAMIC;
            labelField.width = 180;
            labelField.x = x;
            labelField.y = y;
            
            var input:TextField = new TextField();
            input.text = defaultValue;
            input.type = TextFieldType.INPUT;
            input.border = editable;
            input.selectable = editable;
            input.width = 280;
            input.height = height;
            input.x = x + labelField.width;
            input.y = y;
            
            this.addChild( labelField );
            this.addChild( input );
            
            return input;
        }
        
        private function createTextButton( x:int, y:int, label:String, clickHandler:Function ):TextField
        {
            var button:TextField = new TextField();
            button.htmlText = "<u><b>" + label + "</b></u>";
            button.type = TextFieldType.DYNAMIC;
            button.selectable = false;
            button.width = 180;
            button.x = x;
            button.y = y;
            button.addEventListener( MouseEvent.CLICK, clickHandler );
            
            this.addChild( button );
            return button;
            
        }
    }
}
//------------------------------------------------------------------------
#endif