Loading kinetic-test/src/test/java/com/seagate/kinetic/KineticTestHelpers.java +24 −0 Original line number Diff line number Diff line Loading @@ -97,6 +97,20 @@ public class KineticTestHelpers { }; } public static <T> CallbackHandler<T> buildAsyncCallbackHandler( final AsyncHandler<T> handler) { return new CallbackHandler<T>() { @Override public void onSuccess(CallbackResult<T> result) { handler.onSuccess(result); } @Override public void onError(AsyncKineticException exception) { } }; } /** * Reset pin, unless kinetic.test.disable-clean-pin system property is set * to 'true' Loading Loading @@ -128,6 +142,16 @@ public class KineticTestHelpers { void onSuccess(CallbackResult<T> result); } /** * Async success handler interface. * */ public interface AsyncHandler<T> { void onSuccess(CallbackResult<T> result); void onError(AsyncKineticException exception); } /** * Wait for count down latch reduced to zero. * Loading kinetic-test/src/test/java/com/seagate/kinetic/asyncAPI/BatchOpAPITest.java +745 −90 File changed.Preview size limit exceeded, changes collapsed. Show changes Loading
kinetic-test/src/test/java/com/seagate/kinetic/KineticTestHelpers.java +24 −0 Original line number Diff line number Diff line Loading @@ -97,6 +97,20 @@ public class KineticTestHelpers { }; } public static <T> CallbackHandler<T> buildAsyncCallbackHandler( final AsyncHandler<T> handler) { return new CallbackHandler<T>() { @Override public void onSuccess(CallbackResult<T> result) { handler.onSuccess(result); } @Override public void onError(AsyncKineticException exception) { } }; } /** * Reset pin, unless kinetic.test.disable-clean-pin system property is set * to 'true' Loading Loading @@ -128,6 +142,16 @@ public class KineticTestHelpers { void onSuccess(CallbackResult<T> result); } /** * Async success handler interface. * */ public interface AsyncHandler<T> { void onSuccess(CallbackResult<T> result); void onError(AsyncKineticException exception); } /** * Wait for count down latch reduced to zero. * Loading
kinetic-test/src/test/java/com/seagate/kinetic/asyncAPI/BatchOpAPITest.java +745 −90 File changed.Preview size limit exceeded, changes collapsed. Show changes