diff options
| -rw-r--r-- | java/src/Stream.java | 33 |
1 files changed, 22 insertions, 11 deletions
diff --git a/java/src/Stream.java b/java/src/Stream.java index 09f1a392ff2..acb9a8856c8 100644 --- a/java/src/Stream.java +++ b/java/src/Stream.java @@ -30,6 +30,28 @@ import ACE.OS.*; public class Stream { + + public Stream () + { + this (null, null, null); + } + + // Create a Stream consisting of <head> and <tail> as the Stream + // head and Stream tail, respectively. If these are 0 then the + // <ACE_Stream_Head> and <ACE_Stream_Tail> are used, respectively. + // <arg> is the value past in to the open() methods of the tasks. + + public Stream (Object a, + Module head, + Module tail) + { + this.linkedUs_ = null; + // this.final_close_ = this.lock_; + + if (this.open (a, head, tail) == -1) + ACE.ERROR ("open" + head.name () + " " + tail.name ()); + } + public int push (Module newTop) { if (this.pushModule (newTop, @@ -358,17 +380,6 @@ public class Stream return this.unlinkInternal (); } - public Stream (Object a, - Module head, - Module tail) - { - this.linkedUs_ = null; - // this.final_close_ = this.lock_; - - if (this.open (a, head, tail) == -1) - ACE.ERROR ("open" + head.name () + " " + tail.name ()); - } - public void dump () { ACE.DEBUG ("-------- module links --------"); |