+2003-10-09 Michael Koch <konqueror@gmx.de>
+
+ * java/nio/channels/spi/AbstractSelectableChannel.java
+ (registered): Made private.
+ (blocking): Likewise.
+ (LOCK): Likewise.
+ (provider): Likewise.
+ (keys): Made it a private LinkedList.
+ (AbstractSelectableChannel): Initialize keys.
+ (isRegistered): New implementation.
+ (locate): Rewritten.
+ (register): Rewritten.
+ * java/nio/channels/spi/AbstractSelectionKey.java
+ (ok): Removed.
+ (cancelled): New member variable.
+ (cancel): Rewritten.
+ (isValid): Rewritten.
+ * java/nio/channels/spi/AbstractSelector.java:
+ Some methods moved.
+ (closed): Make private.
+ (provider): Likewise.
+ (cancelledKeys): New member variable.
+ (AbstractSelector): Initialize cancelledKeys.
+ (cancelKey): New method.
+
2003-10-09 Tom Tromey <tromey@redhat.com>
* java/lang/ClassLoader.java (setSigners): Implemented.
/* AbstractSelectableChannel.java
- Copyright (C) 2002 Free Software Foundation, Inc.
+ Copyright (C) 2002, 2003 Free Software Foundation, Inc.
This file is part of GNU Classpath.
public abstract class AbstractSelectableChannel extends SelectableChannel
{
- int registered;
- boolean blocking = true;
- Object LOCK = new Object ();
- SelectorProvider provider;
- List keys;
+ private int registered;
+ private boolean blocking = true;
+ private Object LOCK = new Object();
+ private SelectorProvider provider;
+ private LinkedList keys;
/**
* Initializes the channel
protected AbstractSelectableChannel (SelectorProvider provider)
{
this.provider = provider;
+ this.keys = new LinkedList();
}
/**
*/
public final boolean isRegistered()
{
- return registered > 0;
+ return !keys.isEmpty();
}
/**
if (keys == null)
return null;
- SelectionKey k = null;
ListIterator it = keys.listIterator ();
while (it.hasNext ())
{
- k = (SelectionKey) it.next ();
- if (k.selector () == selector)
- {
- return k;
- }
+ SelectionKey key = (SelectionKey) it.next();
+
+ if (key.selector() == selector)
+ return key;
}
- return k;
+ return null;
}
private void add (SelectionKey key)
{
- if (keys == null)
- {
- keys = new LinkedList ();
- }
-
keys.add (key);
}
if (!isOpen ())
throw new ClosedChannelException();
- SelectionKey k = null;
+ SelectionKey key = null;
AbstractSelector selector = (AbstractSelector) selin;
synchronized (LOCK)
{
- k = locate (selector);
+ key = locate (selector);
- if (k != null)
+ if (key != null)
{
- k.attach (att);
+ key.attach (att);
}
else
{
- k = selector.register (this, ops, att);
+ key = selector.register (this, ops, att);
- if (k != null)
- add (k);
+ if (key != null)
+ add (key);
}
}
- return k;
+ return key;
}
}
/* AbstractSelectionKey.java --
- Copyright (C) 2002 Free Software Foundation, Inc.
+ Copyright (C) 2002, 2003 Free Software Foundation, Inc.
This file is part of GNU Classpath.
public abstract class AbstractSelectionKey
extends SelectionKey
{
- boolean ok = true;
+ private boolean cancelled = false;
/**
* Initializes the key.
*/
public final void cancel ()
{
- if (ok)
- selector ().selectedKeys ().add (this);
-
- ok = false;
+ if (isValid())
+ {
+ // FIXME: implement this.
+ //selector().cancelledKeys().add (this);
+ cancelled = true;
+ }
}
/**
*/
public final boolean isValid ()
{
- return ok;
+ return !cancelled;
}
}
/* AbstractSelector.java --
- Copyright (C) 2002 Free Software Foundation, Inc.
+ Copyright (C) 2002, 2003 Free Software Foundation, Inc.
This file is part of GNU Classpath.
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.Set;
+import java.util.HashSet;
public abstract class AbstractSelector extends Selector
{
- boolean closed = false;
- SelectorProvider provider;
+ private boolean closed = false;
+ private SelectorProvider provider;
+ private HashSet cancelledKeys;
/**
* Initializes the slector.
protected AbstractSelector (SelectorProvider provider)
{
this.provider = provider;
+ this.cancelledKeys = new HashSet();
}
- /**
- * Marks the beginning of an I/O operation that might block indefinitely.
- */
- protected final void begin ()
- {
- }
-
/**
* Closes the channel.
*
if (closed)
return;
+ implCloseSelector();
closed = true;
- implCloseSelector ();
}
/**
return ! closed;
}
- protected final void deregister (AbstractSelectionKey key)
+ /**
+ * Marks the beginning of an I/O operation that might block indefinitely.
+ */
+ protected final void begin()
{
- cancelledKeys ().remove (key);
}
-
+
+ /**
+ * Marks the end of an I/O operation that might block indefinitely.
+ */
protected final void end()
{
}
protected final Set cancelledKeys()
{
- return null;
+ return cancelledKeys;
+ }
+
+ final void cancelKey (AbstractSelectionKey key)
+ {
+ cancelledKeys.remove (key);
}
/**
protected abstract SelectionKey register (AbstractSelectableChannel ch,
int ops, Object att);
+
+ protected final void deregister (AbstractSelectionKey key)
+ {
+ // FIXME
+ }
}