Examples of aleph.Message

aleph.Message
The base class for aleph messages. When a PE receives a message m, it executes that message's run() method. Messages between pairs of PEs are received and executed in FIFO order: if PE0 sends m0 and then m1 to PE1, then PE1 runs m0.run() to completion befor starting m1.run(). A message's run() method should therefore not block for non-trivial durations. If you need to block, use aleph.AsynchMessage. Messages from different PEs are not synchronized: if PE0 sends m0 and PE1 sends m1 to PE2, then m0.run() and m1.run() may be run concurrently. @see aleph.AsynchMessage @author Maurice Herlihy @date July 1998

   **/
  protected Message receive () throws IOException {
    try {
      if (DEBUG)
        Aleph.debug("TCPConnection: receive socket is " + socket);
      Message message = (Message) objectInput.readObject();
      Logger.debug("Received " + message.stamp);
      if (DEBUG)
        Aleph.debug("TCPConnection: received " + message + " From: " + remoteAddress);
      return message;
    } catch (ClassNotFoundException e) {

View Full Code Here


  private class MessageHandler extends Thread {
    public void run() {
      try {
        while(! quit) {         // keep on keeping on
          Message message = Connection.this.receive();
          if (message != null) { // ignore spurious nulls
            if (DEBUG)
              Aleph.debug("Connection received " + message);
            if (message instanceof AsynchMessage)
              Scheduler.getScheduler().schedule(message); // maybe later
            else
              message.run();
          }
        }
      } catch(IOException e) {
        if (DEBUG)
          Aleph.debug("tcp.Connection closing: " + e);

View Full Code Here


  private class MessageHandler extends Thread {
    public void run() {
      try {
        while(! quit) {         // keep snarfing up messages
          Message message = Connection.this.receive();
          if (message != null) {  //  ignore spurious nulls in stream
            if (DEBUG)
              Aleph.debug("Connection received " + message);
            if (message instanceof AsynchMessage)
              scheduler.schedule(message); // place in work pool
            else
              message.run();  // run it immediately
          }
        }
      } catch(java.io.IOException e) {
        return;            
      } catch(Exception e) {

View Full Code Here

  private class Worker extends Thread {
   public void run () {
     while (true) {
       if (DEBUG)
         Aleph.debug("waiting for message ...");
       Message message = (Message) queue.deq();
       if (DEBUG)
         if (message instanceof AsynchMessage)
           Aleph.debug("dequeued asynchronous " + message);
         else
           Aleph.debug("dequeued normal " + message);
       if (message instanceof AsynchMessage)
         scheduler.schedule(message); // do it later
       else
         message.run();         // 
     }
   }

View Full Code Here

  public synchronized Message deq () {
    if (DEBUG)
      Aleph.debug("MessageQueue.deq ...");
    while (queue.isEmpty())
      try {wait();} catch (InterruptedException e) {}
    Message message = (Message) queue.removeLast();
    if (DEBUG)
      Aleph.debug("MessageQueue.deq() returns " + message);
    return message;
  }

View Full Code Here

TOP

Related Classes of aleph.Message

aleph.comm.rmi.DeliveryImpl$Worker

aleph.comm.tcp.Connection$MessageHandler

aleph.comm.tcp.TCPConnection

aleph.comm.udp.Connection$MessageHandler

aleph.thread.MessageQueue

java.io.ObjectOutputStream

java.io.ObjectInputStream

java.io.ByteArrayInputStream

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.