You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by am...@apache.org on 2019/11/14 09:51:28 UTC
[aries-rsa] 01/09: Fix typos
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 <am...@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"};