parctechnologies/eclipse/RemoteEclipse.java

732   synchronized void flushStream(int streamID) throws IOException
736                                       new Integer(streamID),
737                                       new Integer(getBytesBuffered(streamID))));
739     getOutputStream(streamID).flush();
741     setBytesBuffered(streamID, 0);
767   synchronized int availableOnStream(int streamID)
769     return(this.availableInBuffer(streamID));
774   synchronized int readByteFromStream(int streamID) throws IOException
776     return(readByteFromBuffer(streamID));
1255   private void respondFlushIO(Integer streamID, Integer bytesFlushed)
1260     feq = lookupFromEclipseQueue(streamID.intValue());
1263       System.err.println("ECLiPSe yielded after flushing stream "+streamID.intValue() +
1267       bufferBytesFromSocket(streamID.intValue(), bytesFlushed.intValue());
1275   void respondWaitIO(Integer streamID) throws IOException
1277     super.respondWaitIO(streamID);
1284                                       streamID,
1351     private Integer streamID, bytesFlushed;
1353     FlushIOSignal(Integer streamID, Integer bytesFlushed)
1355       this.streamID = streamID;
1361       respondFlushIO(streamID, bytesFlushed);
1367     private Integer streamID;
1369     CloseQueueSignal(Integer streamID)
1371       this.streamID = streamID;
1376       respondCloseQueue(streamID);
1401   private FromEclipseQueueInfo getFromecInfo(int streamID)
1403     return((FromEclipseQueueInfo) queueInfo.get(new Integer(streamID)));
1406   private void bufferBytesFromSocket(int streamID, int nBytes)
1411       getFromecInfo(streamID).getBuffer().readBytesFromSocket(nBytes);
1420   private void closeFromecSocket(int streamID) throws IOException
1422     getFromecInfo(streamID).getSocket().close();
1425   private void removeInfo(int streamID)
1427     queueInfo.remove(new Integer(streamID));
1430   private void setupFromecInfo(int streamID, Socket socket) throws IOException
1433     queueInfo.put(new Integer(streamID), new FromEclipseQueueInfo(socket));
1436   private int readByteFromBuffer(int streamID)
1438     return(getFromecInfo(streamID).readByteFromBuffer());
1441   private int readBytesFromBuffer(int streamID, byte[] b, int off, int len)
1443     return(getFromecInfo(streamID).readBytesFromBuffer(b, off, len));
1446   private int availableInBuffer(int streamID)
1448     return(getFromecInfo(streamID).availableInBuffer());
1451   private AsyncEclipseQueueInfo getAsyncecInfo(int streamID)
1453     return((AsyncEclipseQueueInfo) queueInfo.get(new Integer(streamID)));
1456   private void closeAsyncecSocket(int streamID) throws IOException
1458     getAsyncecInfo(streamID).getSocket().close();
1461   private void setupAsyncecInfo(int streamID, Socket socket) throws IOException
1464     queueInfo.put(new Integer(streamID), new AsyncEclipseQueueInfo(socket));
1467   InputStream getAsyncInputStream(int streamID) throws IOException
1469     return getAsyncecInfo(streamID).getInputStream();
1472   OutputStream getAsyncOutputStream(int streamID) throws IOException
1474     return getAsyncecInfo(streamID).getOutputStream();
1546   private ToEclipseQueueInfo getToecInfo(int streamID)
1548     return((ToEclipseQueueInfo) queueInfo.get(new Integer(streamID)));
1551   private void closeToecSocket(int streamID) throws IOException
1553     getToecInfo(streamID).getSocket().close();
1556   private void setupToecInfo(int streamID, Socket socket) throws IOException
1559     queueInfo.put(new Integer(streamID), new ToEclipseQueueInfo(socket));
1562   private void setBytesBuffered(int streamID, int newVal)
1564     getToecInfo(streamID).setBytesBuffered(newVal);
1567   private int getBytesBuffered(int streamID)
1569     return(getToecInfo(streamID).getBytesBuffered());
1572   private OutputStream getOutputStream(int streamID)
1574     return(getToecInfo(streamID).getOutputStream());