diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-10-16 06:55:56 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-10-16 06:55:56 +0000 |
commit | 4a2a3f11bbbbd3d0be9f1ca725c8b36705b7b40c (patch) | |
tree | d60a25718c35a15cfc2adc47e435a075a76df5a8 /java/src/StreamTail.java | |
parent | e51367e839d2bffab3c31a21d2972c56ae32166a (diff) | |
download | ATCD-4a2a3f11bbbbd3d0be9f1ca725c8b36705b7b40c.tar.gz |
This commit was manufactured by cvs2svn to create tag 'TAO-0_2_28'.TAO-0_2_28
Diffstat (limited to 'java/src/StreamTail.java')
-rw-r--r-- | java/src/StreamTail.java | 111 |
1 files changed, 0 insertions, 111 deletions
diff --git a/java/src/StreamTail.java b/java/src/StreamTail.java deleted file mode 100644 index 44f9dde6634..00000000000 --- a/java/src/StreamTail.java +++ /dev/null @@ -1,111 +0,0 @@ -/************************************************* - * - * = PACKAGE - * JACE.ASX - * - * = FILENAME - * StreamTail.java - * - *@author Prashant Jain - * - *************************************************/ -package JACE.ASX; - -import JACE.OS.*; - -/** - * <hr> - * <h2>SYNOPSIS</h2> - *<blockquote> - * Standard module that acts as the tail of a ustream. - *</blockquote> - */ - -public class StreamTail extends Task -{ - // Module that acts as the tail of a Stream. - - public int open (Object obj) - { - return 0; - } - - public int close (long l) - { - return 0; - } - - public int svc () - { - return -1; - } - - private int control (MessageBlock mb) - { - IOCntlMsg ioc = (IOCntlMsg) mb.obj (); - int cmd = ioc.cmd (); - - switch (cmd) - { - case IOCntlCmds.SET_LWM: - case IOCntlCmds.SET_HWM: - { - int size = mb.cont ().length (); - - this.waterMarks (cmd, size); - this.sibling ().waterMarks (cmd, size); - ioc.rval (0); - break; - } - default: - mb.msgType (MessageType.MB_IOCNAK); - } - return this.reply (mb, new TimeValue ()); - } - - // Perform flush algorithm as though we were the driver - private int canonicalFlush (MessageBlock mb) - { - String s = mb.base (); - long f = (new Long (s)).longValue (); - - if ((f & TaskFlags.ACE_FLUSHW) != 0) - { - this.flush (TaskFlags.ACE_FLUSHALL); - f &= ~TaskFlags.ACE_FLUSHW; - } - if ((f & TaskFlags.ACE_FLUSHR) != 0) - { - this.sibling ().flush (TaskFlags.ACE_FLUSHALL); - return this.reply (mb, new TimeValue ()); - } - return 0; - } - - public int put (MessageBlock mb, TimeValue tv) - { - if (this.isWriter ()) - { - switch (mb.msgType ()) - { - case MessageType.MB_IOCTL: - return this.control (mb); - /* NOTREACHED */ - default: - break; - } - } - - return -1; - } - - public void dump () - { - } - - public int handleTimeout (TimeValue tv, Object obj) - { - return 0; - } - -} |