All Packages  This Package  Class Hierarchy  Class Search  Index

java.lang.Object
   |
   +----edu.utah.janos.core.Buffer
           |
           +----edu.utah.janos.core.UdpBuffer

Summary

class  UdpBuffer
     extends edu.utah.janos.core.Buffer
{
          // Fields 6
     static final int MAX_PACKET_LEN;
     static UdpBuffer freeList;
     private int len;
     UdpBuffer nextFree;
     private FlowState state;
     private final DatagramPacket udpPacket;

          // Constructors 1
     private UdpBuffer();

          // Methods 8
     static synchronized void addBuffers(int);
     private static synchronized void addToFreeList(UdpBuffer);
     static synchronized UdpBuffer getFree();

     boolean charge(FlowState);
     private void credit();
     int length();
     void receive(DatagramSocket) throws IOException;
     void recycle();
}

A UDP implementation of Buffer.

Cross Reference

Returned By:

UdpBuffer.getFree()

   static UdpBuffer freeList

   static final int MAX_PACKET_LEN

   private final DatagramPacket udpPacket

   UdpBuffer nextFree

   private FlowState state

   private int len

Constructors

· UdpBuffer

Summary  |  Top

   private UdpBuffer() 

UdpBuffers can only be allocated by addBuffers()

Each UdpBuffer is MAX_PACKET_LEN bytes big.

See Also: addBuffers

   static synchronized void addBuffers(int numBuffers) 

Add a bunch of buffers to the free buffer queue.

   static synchronized UdpBuffer getFree() 

Get the next available UdpBuffer.

Returns null if no buffers are available.

   boolean charge(FlowState state) 

Charge the given flow for this buffer. This buffer will be associated with the flow (via this.state).

Returns true if the given flow can pay for this buffer.

Overrides:

charge in class Buffer

   private void credit() 

Credit the flow associated with this buffer.

   void recycle() 

Put this buffer back in the recycle list (we're done with it).

Overrides:

recycle in class Buffer

   private static synchronized void addToFreeList(UdpBuffer b) 

Add the given flow to this global free list.

   void receive(DatagramSocket socket)  throws IOException

   int length() 

All Packages  This Package  Class Hierarchy  Class Search  Index