You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by as...@apache.org on 2021/02/16 06:33:21 UTC
[ignite-3] branch ignite-13885 updated: IGNITE-13885 minor.
This is an automated email from the ASF dual-hosted git repository.
ascherbakov pushed a commit to branch ignite-13885
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-13885 by this push:
new 945030c IGNITE-13885 minor.
945030c is described below
commit 945030cc828308ec45fc56245492e7b3d0a5f1ee
Author: Alexey Scherbakov <al...@gmail.com>
AuthorDate: Tue Feb 16 09:33:05 2021 +0300
IGNITE-13885 minor.
---
.../raft-client/src/main/java/org/apache/ignite/raft/Endpoint.java | 2 +-
modules/raft-client/src/main/java/org/apache/ignite/raft/PeerId.java | 2 +-
.../src/main/java/org/apache/ignite/raft/rpc/RpcContext.java | 2 +-
.../src/main/java/org/apache/ignite/raft/rpc/RpcUtils.java | 1 +
.../org/apache/ignite/raft/rpc/{ => impl}/NamedThreadFactory.java | 5 +----
.../src/main/java/org/apache/ignite/raft/service/RouteTable.java | 1 +
6 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/Endpoint.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/Endpoint.java
index ae7c4b6..d30554f 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/Endpoint.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/Endpoint.java
@@ -19,7 +19,7 @@ package org.apache.ignite.raft;
import java.io.Serializable;
/**
- * A IP address with port.
+ * An IP address with a port.
*/
public class Endpoint implements Serializable {
public static final String IP_ANY = "0.0.0.0";
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/PeerId.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/PeerId.java
index c31f3d1..b8f592a 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/PeerId.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/PeerId.java
@@ -19,7 +19,7 @@ package org.apache.ignite.raft;
import java.io.Serializable;
/**
- * Represent a participant in a replicating group.
+ * Represents a participant in a replicating group.
*/
public class PeerId implements Serializable {
private static final long serialVersionUID = 8083529734784884641L;
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcContext.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcContext.java
index 1f7fcf8..eeb0c2e 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcContext.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcContext.java
@@ -17,7 +17,7 @@
package org.apache.ignite.raft.rpc;
/**
- * @author jiachun.fjc
+ *
*/
public interface RpcContext {
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcUtils.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcUtils.java
index 8e6d896..9f3dab9 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcUtils.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcUtils.java
@@ -23,6 +23,7 @@ import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.apache.ignite.raft.Closure;
import org.apache.ignite.raft.Status;
+import org.apache.ignite.raft.rpc.impl.NamedThreadFactory;
/**
* RPC utilities.
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/NamedThreadFactory.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/impl/NamedThreadFactory.java
similarity index 95%
rename from modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/NamedThreadFactory.java
rename to modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/impl/NamedThreadFactory.java
index f87e993..26e48ec 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/NamedThreadFactory.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/impl/NamedThreadFactory.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.ignite.raft.rpc;
+package org.apache.ignite.raft.rpc.impl;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
@@ -22,9 +22,6 @@ import java.util.concurrent.atomic.AtomicInteger;
/**
* Named thread factory with prefix.
*
- * @author boyan (boyan@alibaba-inc.com)
- * <p>
- * 2018-Mar-21 11:32:02 AM
*/
public class NamedThreadFactory implements ThreadFactory {
private static System.Logger LOG = System.getLogger(NamedThreadFactory.class.getName());
diff --git a/modules/raft-client/src/main/java/org/apache/ignite/raft/service/RouteTable.java b/modules/raft-client/src/main/java/org/apache/ignite/raft/service/RouteTable.java
index 65e6f2b..2c27171 100644
--- a/modules/raft-client/src/main/java/org/apache/ignite/raft/service/RouteTable.java
+++ b/modules/raft-client/src/main/java/org/apache/ignite/raft/service/RouteTable.java
@@ -37,6 +37,7 @@ import org.apache.ignite.raft.rpc.RpcRequests;
public class RouteTable {
private static final System.Logger LOG = System.getLogger(RouteTable.class.getName());
+ // TODO fixme remove static table.
private static final RouteTable INSTANCE = new RouteTable();
// Map<groupId, groupConf>