Lines Matching refs:rosu

318 		final ConcurrentReadOutputStream rosu, rosm;  in process()
328 			rosu=ConcurrentReadOutputStream.getStream(ffout1, ffout2, qfout1, qfout2, buff, null, false);  in process()
329 			rosu.start(); //Start the stream  in process()
330 		}else{rosu=null;}  in process()
347 		spawnThreads(cris, rosu, rosm);  in process()
354 		errorState|=ReadWrite.closeStreams(cris, rosu, rosm);  in process()
383 …ds(final ConcurrentReadInputStream cris, final ConcurrentReadOutputStream rosu, final ConcurrentRe…
393 			alpt.add(new ProcessThread(cris, rosu, rosm, i));
444 			rosu=rosu_;
527 				if(rosu!=null){rosu.add(reads, ln.id);}
579 		private final ConcurrentReadOutputStream rosu;  local