package?ict.ff.ipmsg;

import?java.io.*;


public?class?AutoPipe?{
	protected?InputStream?input;
	protected?OutputStream?output;
	protected?PipeThread?thread;
	protected?int?piped;
	protected?boolean?completed;
	protected?boolean?stoped;
	protected?boolean?closed;
	protected?Exception?error;

	private?class?PipeThread?extends?Thread?{

		public?void?run（）
????????{
????????????byte?buffer[];
????????????completed?=?false;
????????????buffer?=?new?byte[IPMSG.MAX_SOCKBUF];
????????????int?readlen?=?-1;
????????????stoped?=?false;
????????????try
????????????{
????????????????while（!stoped）?
????????????????{
????????????????????readlen?=?input.read（buffer）;
????????????????????if（readlen?==?-1）
????????????????????{
????????????????????????completed?=?true;
????????????????????????break;
????????????????????}
????????????????????output.write（buffer?0?readlen）;
????????????????????piped?+=?readlen;
????????????????????if（input.available（）?==?0）
????????????????????????output.flush（）;
????????????????}
????????????}
????????????catch（DirectoryOutputException?e）
????????????{
????????????????completed?=?true;
//????????????????break?MISSING_BLOCK_LABEL_183;
????????????}
????????????catch（IOException?e）
????????????{
????????????????error?=?e;
//????????????????break?MISSING_BLOCK_LABEL_183;
????????????}
//??????????????goto?_L1
//????????????Exception?exception;
//????????????exception;
????????????try
????????????{
????????????????close（）;
????????????}
????????????catch（IOException?e1）
????????????{
????????????????e1.printStackTrace（）;
????????????}
//????????????throw?exception;
//_L1:
????????????try
????????????{
????????????????close（）;
????????????}
????????????catch（IOException?e1）
????????????{
????????????????e1.printStackTrace（）;
????????????}
//????????????break?MISSING_BLOCK_LABEL_200;
????????????try
????????????{
????????????????close（）;
????????????}
????????????catch（IOException?e1）
????????????{
????????????????e1.printStackTrace（）;
????????????}
????????}

		final?AutoPipe?this$0;

		private?PipeThread（）?{
			this$0?=?AutoPipe.this;
//			super（）;
		}

		PipeThread（PipeThread?pipethread）?{
			this（）;
		}
	}

	public?AutoPipe（InputStream?input?OutputStream?output）?{
		this.input?=?null;
		this.output?=?null;
		thread?=?null;
		piped?=?0;
		completed?=?false;
		stoped?=?false;
		closed?=?false;
		error?=?null;
		if?（input?==?null?||?output?==?null）?{
			throw?new?NullPointerException（）;
		}?else?{
			this.input?=?input;
			this.output?=?output;
			thread?=?new?PipeThread（null）;
			return;
		}
	}

	public?void?start（）?{
		stoped?=?false;
		thread.start（）;
	}

	public?void?stop（）?{
		stoped?=?true;
	}

	public?void?close（）?throws?IOException?{
		if?（closed）
			return;
		IOException?exception?=?null;
		try?{
			input.close（）;
		}?catch?（IOException?e）?{
			exception?=?e;
		}
		closed?=?true;
		output.cl

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----

?????文件????????359??2098-01-01?08:00??test\.classpath

?????文件????????665??2098-01-01?08:00??test\.project

????.......??????1789??2008-07-07?16:50??test\bin\ict\ff\ipmsg\AutoPipe$PipeThread.class

????.......??????1971??2008-07-07?16:50??test\bin\ict\ff\ipmsg\AutoPipe.class

????.......??????4105??2008-07-07?16:50??test\bin\ict\ff\ipmsg\DirectoryInputStream.class

????.......???????394??2008-07-07?16:50??test\bin\ict\ff\ipmsg\DirectoryOutputException.class

????.......??????3884??2008-07-07?16:50??test\bin\ict\ff\ipmsg\DirectoryOutputStream.class

????.......???????768??2008-07-07?16:50??test\bin\ict\ff\ipmsg\EntryListener.class

????.......???????764??2008-07-07?16:50??test\bin\ict\ff\ipmsg\ExitListener.class

????.......???????519??2008-07-07?16:50??test\bin\ict\ff\ipmsg\FileData.class

????.......??????4138??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IPMSG.class

????.......???????754??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgChannel$1.class

????.......??????3258??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgChannel$ServerSockThread.class

????.......?????19633??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgChannel.class

????.......???????748??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$1.class

????.......???????564??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$Buffer.class

????.......???????601??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$FileTransferThread.class

????.......???????849??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$OutputThread.class

????.......??????1084??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$ReceiveFileThread.class

????.......??????1505??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$SocketThread.class

????.......???????592??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket$SuperviseThread.class

????.......??????9863??2008-07-07?16:50??test\bin\ict\ff\ipmsg\IpmsgSocket.class

????.......???????759??2008-07-07?16:50??test\bin\ict\ff\ipmsg\Member.class

????.......???????452??2008-07-07?16:50??test\bin\ict\ff\ipmsg\MemberEvent.class

????.......???????573??2008-07-07?16:50??test\bin\ict\ff\ipmsg\MessageEvent.class

????.......???????779??2008-07-07?16:50??test\bin\ict\ff\ipmsg\MessageListener.class

?????目錄??????????0??2008-07-07?16:50??test\bin\ict\ff\ipmsg

????.......??????3065??2008-07-07?16:50??test\bin\ict\ff\ui\Config.class

????.......??????1209??2008-07-07?16:50??test\bin\ict\ff\ui\ConfigDialog$1.class

????.......???????749??2008-07-07?16:50??test\bin\ict\ff\ui\ConfigDialog$2.class

............此處省略70個(gè)文件信息