Lines Matching refs:streamID
677 private Integer streamID;
678 WaitIOSignal(Integer streamID)
680 this.streamID = streamID;
684 respondWaitIO(streamID);
691 private Integer streamID;
693 OpenQueueSignal(Atom nameAtom, Integer streamID, Atom direction)
696 this.streamID = streamID;
701 respondOpenQueue(nameAtom, streamID, direction);
709 void respondWaitIO(Integer streamID) throws IOException
712 ToEclipseQueue teq = lookupToEclipseQueue(streamID.intValue());
716 streamID.intValue() +
725 void respondCloseQueue(Integer streamID) throws IOException
730 teq = lookupToEclipseQueue(streamID.intValue());
734 closeToEclipseStreamJavaSide(streamID.intValue());
737 feq = lookupFromEclipseQueue(streamID.intValue());
741 closeFromEclipseStreamJavaSide(streamID.intValue());
744 aeq = lookupAsyncEclipseQueue(streamID.intValue());
748 closeAsyncEclipseStreamJavaSide(streamID.intValue());
751 System.err.println("Cannot close "+streamID+": not the "+
756 void respondOpenQueue(Atom nameAtom, Integer streamID, Atom direction)