jdk-sandbox: comparison jdk/src/solaris/classes/sun/nio/ch/SolarisEventPort.java

equal deleted inserted replaced

-:b583b4c82a82
+:16fa902b1469
 import java.util.concurrent.RejectedExecutionException;
 import java.io.IOException;
 import sun.misc.Unsafe;
 /**
-* AsynchronousChannelGroup implementation based on the Solaris 10 event port
+* Provides an AsynchronousChannelGroup implementation based on the Solaris 10
-* framework.
+* event port framework and also provides direct access to that framework.
 */
 class SolarisEventPort
 extends Port
 {
 *     ushort_t        portev_pad;
 *     uintptr_t       portev_object;
 *     void            *portev_user;
 * } port_event_t;
 */
-private static final int SIZEOF_PORT_EVENT  = dependsArch(16, 24);
+static final int SIZEOF_PORT_EVENT  = dependsArch(16, 24);
-private static final int OFFSETOF_EVENTS    = 0;
+static final int OFFSETOF_EVENTS    = 0;
-private static final int OFFSETOF_SOURCE    = 4;
+static final int OFFSETOF_SOURCE    = 4;
-private static final int OFFSETOF_OBJECT    = 8;
+static final int OFFSETOF_OBJECT    = 8;
 // port sources
-private static final short PORT_SOURCE_USER     = 3;
+static final short PORT_SOURCE_USER     = 3;
-private static final short PORT_SOURCE_FD       = 4;
+static final short PORT_SOURCE_FD       = 4;
 // file descriptor to event port.
 private final int port;
 // true when port is closed
 throws IOException
 {
 super(provider, pool);
 // create event port
-this.port = portCreate();
+this.port = port_create();
 }
 SolarisEventPort start() {
 startThreads(new EventHandlerTask());
 return this;
 synchronized (this) {
 if (closed)
 return;
 closed = true;
 }
-portClose(port);
+port_close(port);
 }
 private void wakeup() {
 try {
-portSend(port, 0);
+port_send(port, 0);
 } catch (IOException x) {
 throw new AssertionError(x);
 }
 }
 implClose();
 } else {
 // send user event to wakeup each thread
 while (nThreads-- > 0) {
 try {
-portSend(port, 0);
+port_send(port, 0);
 } catch (IOException x) {
 throw new AssertionError(x);
 }
 }
 }
 @Override
 void startPoll(int fd, int events) {
 // (re-)associate file descriptor
 // no need to translate events
 try {
-portAssociate(port, PORT_SOURCE_FD, fd, events);
+port_associate(port, PORT_SOURCE_FD, fd, events);
 } catch (IOException x) {
 throw new AssertionError();     // should not happen
 }
 }
 // wait for I/O completion event
 // A error here is fatal (thread will not be replaced)
 replaceMe = false;
 try {
-portGet(port, address);
+port_get(port, address);
 } catch (IOException x) {
 x.printStackTrace();
 return;
 }
 implClose();
 }
 }
 }
-// -- Native methods --
+/**
+* Creates an event port
-private static native void init();
+*/
+static native int port_create() throws IOException;
-private static native int portCreate() throws IOException;
+/**
-private static native void portAssociate(int port, int source, long object,
+* Associates specific events of a given object with a port
-int events) throws IOException;
+*/
+static native boolean port_associate(int port, int source, long object, int events)
-private static native void portGet(int port, long pe) throws IOException;
-private static native int portGetn(int port, long address, int max)
 throws IOException;
-private static native void portSend(int port, int events) throws IOException;
+/**
+* Removes the association of an object with a port.
-private static native void portClose(int port);
+*/
+static native boolean port_dissociate(int port, int source, long object)
+throws IOException;
+/**
+* Retrieves a single event from a port
+*/
+static native void port_get(int port, long pe) throws IOException;
+/**
+* Retrieves at most {@code max} events from a port.
+*/
+static native int port_getn(int port, long address, int max, long timeout)
+throws IOException;
+/**
+* Sends a user-defined eventto a specified  port.
+*/
+static native void port_send(int port, int events) throws IOException;
+/**
+* Closes a port.
+*/
+static native void port_close(int port);
 static {
 Util.load();
-init();
 }
 }

changeset 12872	16fa902b1469
parent 5506	202f599c92aa
child 14342	8435a30053c1