java.lang .Object java.lang .Thread org.w3c.www.protocol.http.icp .ICPReceiver DEFAULT_PACKET_SIZE final public static int DEFAULT_PACKET_SIZE (Code) The default received datagram packet size.
DEFAULT_QUEUE_SIZE final public static int DEFAULT_QUEUE_SIZE (Code) The default waiter queue size.
nextid protected int nextid(Code) Our current request identifier.
port protected int port(Code) The port number this receiver listens on.
addReplyWaiter protected synchronized void addReplyWaiter(ICPWaiter waiter)(Code) Add a waiter for on the given request identifier.
Parameters: waiter - The ICPWaiter instance for that request.
createQuery protected ICPQuery createQuery(URL url)(Code) Create a new ICP query instance.
Parameters: url - The URL to be queried.
handleQuery protected synchronized void handleQuery(ICPQuery query) throws ICPProtocolException (Code) Handle the given ICP query.
Parameters: p - The DatagramPacket that wraps up the query.
removeReplyWaiter protected synchronized void removeReplyWaiter(ICPWaiter waiter)(Code) Remove the given waiter from the waiters queue.
This waiter has completed his job, he doesn't care about what happens
next at the ICP level.
Parameters: waiter - The wauter to remove from our queue.
run public void run()(Code) Run the ICP manager.