This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 18174316457 IGNITE-26553 Remove unused Ipc classes (#12381)
18174316457 is described below
commit 18174316457203e4cfdeb779988d9c32b390a627
Author: Maksim Timonin <[email protected]>
AuthorDate: Wed Oct 1 17:08:29 2025 +0500
IGNITE-26553 Remove unused Ipc classes (#12381)
---
.../util/ipc/IpcEndpointBindException.java | 47 ----
.../internal/util/ipc/IpcEndpointFactory.java | 71 ------
.../ignite/internal/util/ipc/IpcEndpointType.java | 26 --
.../internal/util/ipc/IpcServerEndpoint.java | 72 ------
.../ignite/internal/util/ipc/IpcToNioAdapter.java | 276 ---------------------
.../util/ipc/loopback/IpcServerTcpEndpoint.java | 185 --------------
.../main/resources/META-INF/classnames.properties | 2 -
7 files changed, 679 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java
deleted file mode 100644
index e8982c65d99..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc;
-
-import org.apache.ignite.IgniteCheckedException;
-
-/**
- * Represents exception occurred during IPC endpoint binding.
- */
-public class IpcEndpointBindException extends IgniteCheckedException {
- /** */
- private static final long serialVersionUID = 0L;
-
- /**
- * Constructor.
- *
- * @param msg Message.
- */
- public IpcEndpointBindException(String msg) {
- super(msg);
- }
-
- /**
- * Constructor.
- *
- * @param msg Message.
- * @param cause Cause.
- */
- public IpcEndpointBindException(String msg, Throwable cause) {
- super(msg, cause);
- }
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java
deleted file mode 100644
index 7105f7ac2fa..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc;
-
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.internal.util.ipc.loopback.IpcClientTcpEndpoint;
-import org.apache.ignite.internal.util.ipc.loopback.IpcServerTcpEndpoint;
-import org.apache.ignite.internal.util.typedef.internal.A;
-
-/**
- * endpoint factory for inter-process communication.
- */
-public class IpcEndpointFactory {
- /**
- * Connects to open server IPC endpoint.
- *
- * @param endpointAddr Endpoint address.
- * @param log Log.
- * @return Connected client endpoint.
- * @throws IgniteCheckedException If failed to establish connection.
- */
- public static IpcEndpoint connectEndpoint(String endpointAddr,
IgniteLogger log) throws IgniteCheckedException {
- A.notNull(endpointAddr, "endpointAddr");
-
- String[] split = endpointAddr.split(":");
-
- int port;
-
- if (split.length == 2) {
- try {
- port = Integer.parseInt(split[1]);
- }
- catch (NumberFormatException e) {
- throw new IgniteCheckedException("Failed to parse port number:
" + endpointAddr, e);
- }
- }
- else
- // Use default port.
- port = -1;
-
- return connectTcpEndpoint(split[0], port > 0 ? port :
IpcServerTcpEndpoint.DFLT_IPC_PORT);
- }
-
- /**
- * Connects loopback IPC endpoint.
- *
- * @param host Loopback host.
- * @param port Loopback endpoint port.
- * @return Connected client endpoint.
- * @throws IgniteCheckedException If connection failed.
- */
- private static IpcEndpoint connectTcpEndpoint(String host, int port)
throws IgniteCheckedException {
- return new IpcClientTcpEndpoint(host, port);
- }
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java
deleted file mode 100644
index 5e183d71684..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc;
-
-/**
- * IPC endpoint type.
- */
-public enum IpcEndpointType {
- /** TCP loopback socket. Supported on all platforms. */
- TCP_LOOPBACK,
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java
deleted file mode 100644
index f633f16483a..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc;
-
-import java.io.Closeable;
-import org.apache.ignite.IgniteCheckedException;
-import org.jetbrains.annotations.Nullable;
-
-/**
- * IPC server endpoint that is capable for client connections accepting.
- */
-public interface IpcServerEndpoint extends Closeable {
- /**
- * Accepts client IPC connection. After client connection is accepted, it
can be used
- * for IPC. This method will block until client connects to IPC server
endpoint.
- *
- * @return Accepted client connection.
- * @throws IgniteCheckedException If accept failed and the endpoint is not
usable anymore.
- */
- public IpcEndpoint accept() throws IgniteCheckedException;
-
- /**
- * Starts configured endpoint implementation.
- *
- * @throws IgniteCheckedException If failed to start server endpoint.
- */
- public void start() throws IgniteCheckedException;
-
- /**
- * Closes server IPC. After IPC is closed, no further operations can be
performed on this
- * object.
- */
- @Override public void close();
-
- /**
- * Gets port endpoint is bound to.
- * Endpoints who does not bind to any port should return -1.
- *
- * @return Port number.
- */
- public int getPort();
-
- /**
- * Gets host endpoint is bound to.
- * Endpoints who does not bind to any port should return {@code null}.
- *
- * @return Host.
- */
- @Nullable public String getHost();
-
- /**
- * Indicates if this endpoint is a management endpoint.
- *
- * @return {@code true} if it's a management endpoint.
- */
- public boolean isManagement();
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java
deleted file mode 100644
index b80c8a6f933..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java
+++ /dev/null
@@ -1,276 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.nio.ByteBuffer;
-import java.nio.ByteOrder;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.atomic.AtomicReference;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteException;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
-import org.apache.ignite.internal.processors.metric.impl.LongAdderMetric;
-import org.apache.ignite.internal.util.nio.GridNioFilter;
-import org.apache.ignite.internal.util.nio.GridNioFilterAdapter;
-import org.apache.ignite.internal.util.nio.GridNioFilterChain;
-import org.apache.ignite.internal.util.nio.GridNioFinishedFuture;
-import org.apache.ignite.internal.util.nio.GridNioFuture;
-import org.apache.ignite.internal.util.nio.GridNioMessageWriterFactory;
-import org.apache.ignite.internal.util.nio.GridNioServerListener;
-import org.apache.ignite.internal.util.nio.GridNioSession;
-import org.apache.ignite.internal.util.nio.GridNioSessionImpl;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.lang.IgniteInClosure;
-import org.apache.ignite.plugin.extensions.communication.Message;
-
-import static
org.apache.ignite.internal.util.nio.GridNioServer.RECEIVED_BYTES_METRIC_DESC;
-import static
org.apache.ignite.internal.util.nio.GridNioServer.RECEIVED_BYTES_METRIC_NAME;
-import static
org.apache.ignite.internal.util.nio.GridNioServer.SENT_BYTES_METRIC_DESC;
-import static
org.apache.ignite.internal.util.nio.GridNioServer.SENT_BYTES_METRIC_NAME;
-
-/**
- * Allows to re-use existing {@link GridNioFilter}s on IPC (specifically
shared memory IPC)
- * communications.
- *
- * Note that this class consumes an entire thread inside {@link #serve()}
method
- * in order to serve one {@link IpcEndpoint}.
- */
-public class IpcToNioAdapter<T> {
- /** */
- private final IpcEndpoint endp;
-
- /** */
- private final GridNioFilterChain<T> chain;
-
- /** */
- private final GridNioSessionImpl ses;
-
- /** */
- private final AtomicReference<CountDownLatch> latchRef = new
AtomicReference<>();
-
- /** */
- private final ByteBuffer writeBuf;
-
- /** Received bytes count metric. */
- private final LongAdderMetric rcvdBytesCntMetric;
-
- /** Sent bytes count metric. */
- private final LongAdderMetric sentBytesCntMetric;
-
- /** */
- private final GridNioMessageWriterFactory writerFactory;
-
- /**
- * @param mreg Metrics registry.
- * @param log Log.
- * @param endp Endpoint.
- * @param lsnr Listener.
- * @param writerFactory Writer factory.
- * @param filters Filters.
- */
- public IpcToNioAdapter(MetricRegistryImpl mreg, IgniteLogger log,
IpcEndpoint endp,
- GridNioServerListener<T> lsnr, GridNioMessageWriterFactory
writerFactory, GridNioFilter... filters
- ) {
- assert mreg != null;
-
- rcvdBytesCntMetric = mreg.longAdderMetric(RECEIVED_BYTES_METRIC_NAME,
RECEIVED_BYTES_METRIC_DESC);
-
- sentBytesCntMetric = mreg.longAdderMetric(SENT_BYTES_METRIC_NAME,
SENT_BYTES_METRIC_DESC);
-
- this.endp = endp;
- this.writerFactory = writerFactory;
-
- chain = new GridNioFilterChain<>(log, lsnr, new HeadFilter(), filters);
- ses = new GridNioSessionImpl(chain, null, null, true);
-
- writeBuf = ByteBuffer.allocate(8 << 10);
-
- writeBuf.order(ByteOrder.nativeOrder());
- }
-
- /**
- * Serves given set of listeners repeatedly reading data from the endpoint.
- *
- * @throws InterruptedException If interrupted.
- */
- public void serve() throws InterruptedException {
- try {
- chain.onSessionOpened(ses);
-
- InputStream in = endp.inputStream();
-
- ByteBuffer readBuf = ByteBuffer.allocate(8 << 10);
-
- readBuf.order(ByteOrder.nativeOrder());
-
- assert readBuf.hasArray();
-
- while (!Thread.interrupted()) {
- int pos = readBuf.position();
-
- int read = in.read(readBuf.array(), pos, readBuf.remaining());
-
- if (read > 0) {
- rcvdBytesCntMetric.add(read);
-
- readBuf.position(0);
- readBuf.limit(pos + read);
-
- chain.onMessageReceived(ses, readBuf);
-
- if (readBuf.hasRemaining())
- readBuf.compact();
- else
- readBuf.clear();
-
- CountDownLatch latch = latchRef.get();
-
- if (latch != null)
- latch.await();
- }
- else if (read < 0) {
- endp.close();
-
- break; // And close below.
- }
- }
- }
- catch (Exception e) {
- chain.onExceptionCaught(ses, new IgniteCheckedException("Failed to
read from IPC endpoint.", e));
- }
- finally {
- try {
- // Assuming remote end closed connection - pushing event from
head to tail.
- chain.onSessionClosed(ses);
- }
- catch (IgniteCheckedException e) {
- chain.onExceptionCaught(ses, new
IgniteCheckedException("Failed to process session close event " +
- "for IPC endpoint.", e));
- }
- }
- }
-
- /**
- * Handles write events on chain.
- *
- * @param msg Buffer to send.
- * @return Send result.
- */
- private GridNioFuture<?> send(Message msg) {
- assert writeBuf.hasArray();
-
- try {
- int cnt = U.writeMessageFully(msg, endp.outputStream(), writeBuf,
writerFactory.writer(ses));
-
- sentBytesCntMetric.add(cnt);
- }
- catch (IOException | IgniteCheckedException e) {
- return new GridNioFinishedFuture<Object>(e);
- }
-
- return new GridNioFinishedFuture<>((Object)null);
- }
-
- /**
- * Filter forwarding messages from chain's head to this server.
- */
- private class HeadFilter extends GridNioFilterAdapter {
- /**
- * Assigns filter name.
- */
- protected HeadFilter() {
- super("HeadFilter");
- }
-
- /** {@inheritDoc} */
- @Override public void onSessionOpened(GridNioSession ses) throws
IgniteCheckedException {
- proceedSessionOpened(ses);
- }
-
- /** {@inheritDoc} */
- @Override public void onSessionClosed(GridNioSession ses) throws
IgniteCheckedException {
- proceedSessionClosed(ses);
- }
-
- /** {@inheritDoc} */
- @Override public void onExceptionCaught(GridNioSession ses,
IgniteCheckedException ex) throws IgniteCheckedException {
- proceedExceptionCaught(ses, ex);
- }
-
- /** {@inheritDoc} */
- @Override public GridNioFuture<?> onSessionWrite(GridNioSession ses,
- Object msg,
- boolean fut,
- IgniteInClosure<IgniteException> ackC) {
- assert ses == IpcToNioAdapter.this.ses;
-
- return send((Message)msg);
- }
-
- /** {@inheritDoc} */
- @Override public void onMessageReceived(GridNioSession ses, Object
msg) throws IgniteCheckedException {
- proceedMessageReceived(ses, msg);
- }
-
- /** {@inheritDoc} */
- @Override public GridNioFuture<?> onPauseReads(GridNioSession ses)
throws IgniteCheckedException {
- // This call should be synced externally to avoid races.
- boolean b = latchRef.compareAndSet(null, new CountDownLatch(1));
-
- assert b;
-
- return new GridNioFinishedFuture<>(b);
- }
-
- /** {@inheritDoc} */
- @Override public GridNioFuture<?> onResumeReads(GridNioSession ses)
throws IgniteCheckedException {
- // This call should be synced externally to avoid races.
- CountDownLatch latch = latchRef.getAndSet(null);
-
- if (latch != null)
- latch.countDown();
-
- return new GridNioFinishedFuture<Object>(latch != null);
- }
-
- /** {@inheritDoc} */
- @Override public GridNioFuture<Boolean> onSessionClose(GridNioSession
ses) {
- assert ses == IpcToNioAdapter.this.ses;
-
- boolean closed = IpcToNioAdapter.this.ses.setClosed();
-
- if (closed)
- endp.close();
-
- return new GridNioFinishedFuture<>(closed);
- }
-
- /** {@inheritDoc} */
- @Override public void onSessionIdleTimeout(GridNioSession ses) throws
IgniteCheckedException {
- proceedSessionIdleTimeout(ses);
- }
-
- /** {@inheritDoc} */
- @Override public void onSessionWriteTimeout(GridNioSession ses) throws
IgniteCheckedException {
- proceedSessionWriteTimeout(ses);
- }
- }
-}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java
deleted file mode 100644
index b4e9965f5eb..00000000000
---
a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java
+++ /dev/null
@@ -1,185 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.util.ipc.loopback;
-
-import java.io.IOException;
-import java.net.InetSocketAddress;
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.util.Map;
-import org.apache.ignite.IgniteCheckedException;
-import org.apache.ignite.IgniteLogger;
-import org.apache.ignite.internal.util.IgniteUtils;
-import org.apache.ignite.internal.util.ipc.IpcEndpoint;
-import org.apache.ignite.internal.util.ipc.IpcEndpointBindException;
-import org.apache.ignite.internal.util.ipc.IpcServerEndpoint;
-import org.apache.ignite.internal.util.typedef.internal.S;
-import org.apache.ignite.internal.util.typedef.internal.U;
-import org.apache.ignite.resources.LoggerResource;
-
-/**
- * Server loopback IPC endpoint.
- */
-public class IpcServerTcpEndpoint implements IpcServerEndpoint {
- /** Default endpoint port number. */
- public static final int DFLT_IPC_PORT = 10500;
-
- /** Server socket. */
- private ServerSocket srvSock;
-
- /** Port to bind socket to. */
- private int port = DFLT_IPC_PORT;
-
- /** Host to bind socket to. */
- private String host;
-
- /** Management endpoint flag. */
- private boolean mgmt;
-
- /** Logger. */
- @LoggerResource
- private IgniteLogger log;
-
- /** {@inheritDoc} */
- @Override public void start() throws IgniteCheckedException {
- if (port <= 0 || port >= 0xffff)
- throw new IpcEndpointBindException("Port value is illegal: " +
port);
-
- try {
- srvSock = new ServerSocket();
-
- assert host != null;
-
- srvSock.bind(new InetSocketAddress(U.resolveLocalHost(host),
port));
-
- if (log.isInfoEnabled())
- log.info("IPC server loopback endpoint started [port=" + port
+ ']');
- }
- catch (IOException e) {
- if (srvSock != null)
- U.closeQuiet(srvSock);
-
- throw new IpcEndpointBindException("Failed to bind loopback IPC
endpoint (is port already in " +
- "use?): " + port, e);
- }
- }
-
- /** {@inheritDoc} */
- @Override public IpcEndpoint accept() throws IgniteCheckedException {
- try {
- Socket sock = IgniteUtils.acceptServerSocket(srvSock);
-
- return new IpcClientTcpEndpoint(sock);
- }
- catch (IOException e) {
- throw new IgniteCheckedException(e);
- }
- }
-
- /** {@inheritDoc} */
- @Override public void close() {
- U.closeQuiet(srvSock);
- }
-
- /** {@inheritDoc} */
- @Override public int getPort() {
- return port;
- }
-
- /**
- * Sets port endpoint will be bound to.
- *
- * @param port Port number.
- */
- public void setPort(int port) {
- this.port = port;
- }
-
- /** {@inheritDoc} */
- @Override public String getHost() {
- return host;
- }
-
- /**
- * Sets host endpoint will be bound to.
- *
- * @param host Host.
- */
- public void setHost(String host) {
- this.host = host;
- }
-
- /** {@inheritDoc} */
- @Override public boolean isManagement() {
- return mgmt;
- }
-
- /**
- * Sets management property.
- *
- * @param mgmt flag.
- */
- public void setManagement(boolean mgmt) {
- this.mgmt = mgmt;
- }
-
- /** {@inheritDoc} */
- @Override public String toString() {
- return S.toString(IpcServerTcpEndpoint.class, this);
- }
-
- /**
- * Sets configuration properties from the map.
- *
- * @param endpointCfg Map of properties.
- * @throws IgniteCheckedException If invalid property name or value.
- */
- public void setupConfiguration(Map<String, String> endpointCfg) throws
IgniteCheckedException {
- for (Map.Entry<String, String> e : endpointCfg.entrySet()) {
- try {
- switch (e.getKey()) {
- case "type":
- //Ignore this property
- break;
-
- case "port":
- setPort(Integer.parseInt(e.getValue()));
- break;
-
- case "host":
- setHost(e.getValue());
- break;
-
- case "management":
- setManagement(Boolean.valueOf(e.getValue()));
- break;
-
- default:
- throw new IgniteCheckedException("Invalid property '"
+ e.getKey() + "' of " + getClass().getSimpleName());
- }
- }
- catch (Throwable t) {
- if (t instanceof IgniteCheckedException || t instanceof Error)
- throw t;
-
- throw new IgniteCheckedException("Invalid value '" +
e.getValue() + "' of the property '" + e.getKey() + "' in " +
- getClass().getSimpleName(), t);
- }
- }
- }
-}
diff --git a/modules/core/src/main/resources/META-INF/classnames.properties
b/modules/core/src/main/resources/META-INF/classnames.properties
index eb5449d73e3..e2606fe9983 100644
--- a/modules/core/src/main/resources/META-INF/classnames.properties
+++ b/modules/core/src/main/resources/META-INF/classnames.properties
@@ -2041,8 +2041,6 @@ org.apache.ignite.internal.util.future.IgniteRemoteMapTask
org.apache.ignite.internal.util.future.IgniteRemoteMapTask$Job
org.apache.ignite.internal.util.future.IgniteRemoteMapTask$Job$1
org.apache.ignite.internal.util.io.GridFilenameUtils$IOCase
-org.apache.ignite.internal.util.ipc.IpcEndpointBindException
-org.apache.ignite.internal.util.ipc.IpcEndpointType
org.apache.ignite.internal.util.lang.GridAbsClosure
org.apache.ignite.internal.util.lang.GridAbsClosureX
org.apache.ignite.internal.util.lang.GridCloseableIterator
