자바 JSch FTP 에러.. Pipe closed, inputstream is closed

Question

잘 사용하던 코드인데 어느날? 갑자기 에러가 납니다channel.put(localFilePath, remoteFilePath, monitor);channel.get(remoteFilePath, localFilePath, monitor);여기서 멋대로 수신하는 코드에서는 Pipe closed, 송신하는 코드에서는 inputstream is closed가 뜹니다..커스텀 monitor로 확인한 결과.. 송수신 모두 100% 까지 잘했는데 마지막에 에러를 내버리네요 혹시 아시는분 답변 주시면 정말 감사하겠습니다 ㅠㅠclass CustomProgressMonitor implements SftpProgressMonitor { private long transfered; private long total; @Override public void init(int op, String src, String dest, long max) { this.total = max; this.transfered = 0; System.out.println("Starting transfer. Total bytes: " + max); } @Override public boolean count(long bytes) { this.transfered += bytes; System.out.println("Transferred: " + this.transfered + " / " + this.total); return true; // return false to cancel the operation } @Override public void end() { System.out.println("Transferred end: " + this.transfered + " / " + this.total); System.out.println("Transfer completed."); } public boolean isSuccessTf() { if (total == 0) { return false; } return this.transfered==this.total; } }private void _get(String src, OutputStream dst, SftpProgressMonitor monitor, int mode, long skip) throws SftpException{ //System.err.println("_get: "+src+", "+dst); byte[] srcb=Util.str2byte(src, fEncoding); try{ sendOPENR(srcb); Header header=new Header(); header=header(buf, header); int length=header.length; int type=header.type; fill(buf, length); if(type!=SSH_FXP_STATUS && type!=SSH_FXP_HANDLE){ throw new SftpException(SSH_FX_FAILURE, ""); } if(type==SSH_FXP_STATUS){ int i=buf.getInt(); throwStatusError(buf, i); } byte[] handle=buf.getString(); // filename long offset=0; if(mode==RESUME){ offset+=skip; } int request_max=1; rq.init(); long request_offset=offset; int request_len = buf.buffer.length-13; if(server_version==0){ request_len=1024; } loop: while(true){ while(rq.count() < request_max){ sendREAD(handle, request_offset, request_len, rq); request_offset += request_len; } header=header(buf, header); length=header.length; type=header.type; RequestQueue.Request rr = null; try{ rr = rq.get(header.rid); } catch(RequestQueue.OutOfOrderException e){ request_offset = e.offset; skip(header.length); rq.cancel(header, buf); continue; } if(type==SSH_FXP_STATUS){ fill(buf, length); int i=buf.getInt(); if(i==SSH_FX_EOF){ break loop; } throwStatusError(buf, i); } if(type!=SSH_FXP_DATA){ break loop; } buf.rewind(); fill(buf.buffer, 0, 4); length-=4; int length_of_data = buf.getInt(); // length of data /** Since sftp protocol version 6, "end-of-file" has been defined, byte SSH_FXP_DATA uint32 request-id string data bool end-of-file [optional] but some sftpd server will send such a field in the sftp protocol 3 ;-( */ int optional_data = length - length_of_data; int foo = length_of_data; while(foo>0){ int bar=foo; if(bar>buf.buffer.length){ bar=buf.buffer.length; } int data_len = io_in.read(buf.buffer, 0, bar); if(data_len<0){ break loop; } dst.write(buf.buffer, 0, data_len); offset+=data_len; foo-=data_len; if(monitor!=null){ if(!monitor.count(data_len)){ skip(foo); if(optional_data>0){ skip(optional_data); } break loop; } } } //System.err.println("length: "+length); // length should be 0 if(optional_data>0){ skip(optional_data); } if(length_of_data

자바 JSch FTP 에러.. Pipe closed, inputstream is closed

0개의 답변

기술 목록