File tree Expand file tree Collapse file tree 1 file changed +6
-7
lines changed
src/main/java/org/embulk/output/sftp Expand file tree Collapse file tree 1 file changed +6
-7
lines changed Original file line number Diff line number Diff line change 1717import org .embulk .spi .unit .LocalFile ;
1818import org .slf4j .Logger ;
1919
20- import java .lang .Void ;
2120import java .io .File ;
2221import java .io .IOException ;
2322import java .io .OutputStream ;
@@ -174,7 +173,7 @@ public Void execute() throws IOException
174173 withConnectionRetry (retriable );
175174 }
176175 catch (Exception e ) {
177- throw (IOException )e ;
176+ throw (IOException ) e ;
178177 }
179178 }
180179 catch (IOException e ) {
@@ -255,20 +254,20 @@ interface Retriable<T>
255254 {
256255 /**
257256 * Execute the operation with the given (or null) return value.
258- *
259257 * @return any return value from the operation
260258 * @throws Exception
261259 */
262260 public T execute () throws Exception ;
263261 }
264262
265- private <T > T withConnectionRetry ( final Retriable <T > op ) throws Exception {
263+ private <T > T withConnectionRetry (final Retriable <T > op ) throws Exception
264+ {
266265 int count = 0 ;
267266 while (true ) {
268267 try {
269268 return op .execute ();
270269 }
271- catch (final Exception e ) {
270+ catch (final Exception e ) {
272271 if (++count > maxConnectionRetry ) {
273272 throw e ;
274273 }
@@ -309,7 +308,7 @@ public FileObject execute() throws FileSystemException
309308 return withConnectionRetry (retriable );
310309 }
311310 catch (Exception e ) {
312- throw (FileSystemException )e ;
311+ throw (FileSystemException ) e ;
313312 }
314313 }
315314
@@ -326,7 +325,7 @@ public OutputStream execute() throws FileSystemException
326325 return withConnectionRetry (retriable );
327326 }
328327 catch (Exception e ) {
329- throw (FileSystemException )e ;
328+ throw (FileSystemException ) e ;
330329 }
331330 }
332331
You can’t perform that action at this time.
0 commit comments