using System;
using System.IO;

namespace Tamir.SharpSsh.jsch
{
	internal class OutputStreamPut : java.io.OutputStream
	{
		ChannelSftp sftp;
		byte[] handle;
		long[] _offset;
		SftpProgressMonitor monitor;
	
		internal OutputStreamPut
			(ChannelSftp sftp,
			byte[] handle,
			long[] _offset,
			SftpProgressMonitor monitor):base()
		{
			this.sftp=sftp;
			this.handle=handle;
			this._offset=_offset;
			this.monitor=monitor;
		}
	
		public override void Write(byte[] d, int s, int len) 
		{
			try
			{
				int _len=len;
				while(_len>0)
				{
					_len-=sftp.sendWRITE(handle, _offset[0], d, s, _len);
				}
				_offset[0]+=len;
				//            if(!checkStatus()){ 
				//              throw new IOException("jsch status error");
				//            }
				if(monitor!=null && !monitor.count(len))
				{
					throw new IOException("canceled");
				}
			}
			catch(IOException e){ throw e; }
			catch(Exception e){ throw new IOException(e.ToString());  }
		}
		byte[] _data=new byte[1];
		public void write(int foo) 
		{
			_data[0]=(byte)foo;
			Write(_data, 0, 1);
		}
		public override void Close() 
		{
			if(monitor!=null)monitor.end();
			try{ sftp._sendCLOSE(handle); }
			catch(IOException e){ throw e; }
			catch(Exception e)
			{
				throw new IOException(e.ToString());
			}
		}
	}
}