< prev index next >

src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/AsyncEvent.java

Print this page

        

@@ -1,7 +1,7 @@
 /*
- * Copyright (c) 2015, 2016, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2015, 2017, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this

@@ -23,27 +23,28 @@
  * questions.
  */
 
 package jdk.incubator.http;
 
+import java.io.IOException;
 import java.nio.channels.SelectableChannel;
 
 /**
  * Event handling interface from HttpClientImpl's selector.
  *
- * If BLOCKING is set, then the channel will be put in blocking
- * mode prior to handle() being called. If false, then it remains non-blocking.
- *
  * If REPEATING is set then the event is not cancelled after being posted.
  */
 abstract class AsyncEvent {
 
-    public static final int BLOCKING = 0x1; // non blocking if not set
     public static final int REPEATING = 0x2; // one off event if not set
 
     protected final int flags;
 
+    AsyncEvent() {
+        this(0);
+    }
+
     AsyncEvent(int flags) {
         this.flags = flags;
     }
 
     /** Returns the channel */

@@ -53,16 +54,17 @@
     public abstract int interestOps();
 
     /** Called when event occurs */
     public abstract void handle();
 
-    /** Called when selector is shutting down. Abort all exchanges. */
-    public abstract void abort();
-
-    public boolean blocking() {
-        return (flags & BLOCKING) != 0;
-    }
+    /**
+     * Called when an error occurs during registration, or when the selector has
+     * been shut down. Aborts all exchanges.
+     *
+     * @param ioe  the IOException, or null
+     */
+    public abstract void abort(IOException ioe);
 
     public boolean repeating() {
         return (flags & REPEATING) != 0;
     }
 }
< prev index next >