This is an automated email from the ASF dual-hosted git repository. amichai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/aries-rsa.git
commit b55a2041c9b15a89ff6394481dee7ec53f5a811f Author: Amichai Rothman <amic...@apache.org> AuthorDate: Wed Nov 13 09:02:24 2019 +0200 Fix typos --- .../org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java | 6 +++--- .../src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java | 4 ++-- .../org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java b/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java index 5d75370..3bbacb8 100644 --- a/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java +++ b/provider/fastbin/src/main/java/org/apache/aries/rsa/provider/fastbin/tcp/TcpTransport.java @@ -283,21 +283,21 @@ public class TcpTransport implements Transport { if( max_read_rate!=0 || max_write_rate!=0 ) { rateLimitingChannel = new RateLimitingChannel(); - schedualRateAllowanceReset(); + scheduleRateAllowanceReset(); } remoteAddress = channel.socket().getRemoteSocketAddress().toString(); listener.onTransportConnected(this); } - private void schedualRateAllowanceReset() { + private void scheduleRateAllowanceReset() { dispatchQueue.executeAfter(1, TimeUnit.SECONDS, new Runnable(){ public void run() { if (!socketState.isConnected()) { return; } rateLimitingChannel.resetAllowance(); - schedualRateAllowanceReset(); + scheduleRateAllowanceReset(); } }); } diff --git a/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java b/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java index 086d6f2..3ffb385 100644 --- a/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java +++ b/provider/tcp/src/main/java/org/apache/aries/rsa/provider/tcp/TCPServer.java @@ -87,7 +87,7 @@ public class TCPServer implements Closeable, Runnable { String methodName = (String)ois.readObject(); Object[] args = (Object[])ois.readObject(); Object result = invoker.invoke(methodName, args); - result = resolveAsnyc(result); + result = resolveAsync(result); if (result instanceof InvocationTargetException) { result = ((InvocationTargetException) result).getCause(); } @@ -95,7 +95,7 @@ public class TCPServer implements Closeable, Runnable { } @SuppressWarnings("unchecked") - private Object resolveAsnyc(Object result) throws InterruptedException { + private Object resolveAsync(Object result) throws InterruptedException { if (result instanceof Future) { Future<Object> fu = (Future<Object>) result; try { diff --git a/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java b/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java index 1458e34..0c77597 100644 --- a/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java +++ b/provider/tcp/src/test/java/org/apache/aries/rsa/provider/tcp/TcpProviderIntentTest.java @@ -51,7 +51,7 @@ public class TcpProviderIntentTest { } @Test - public void basicAndAsnycIntents() { + public void basicAndAsyncIntents() { Map<String, Object> props = new HashMap<>(); EndpointHelper.addObjectClass(props, exportedInterfaces); String[] standardIntents = new String[] {"osgi.basic", "osgi.async"};