[Rename] refactor the libs/nio module. (#318)

Refactor the `libs/nio` module to rename `org.elasticsearch.nio` to `org.opensearch.nio`.

Signed-off-by: Rabi Panda <adnapibar@gmail.com>

libs/nio/build.gradle

@@ -16,17 +16,17 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-apply plugin: 'elasticsearch.publish'
+apply plugin: 'opensearch.publish'
 
 dependencies {
-  api project(':libs:elasticsearch-core')
+  api project(':libs:opensearch-core')
 
   testImplementation "com.carrotsearch.randomizedtesting:randomizedtesting-runner:${versions.randomizedrunner}"
   testImplementation "junit:junit:${versions.junit}"
   testImplementation "org.hamcrest:hamcrest:${versions.hamcrest}"
 
   testImplementation(project(":test:framework")) {
-    exclude group: 'org.elasticsearch', module: 'elasticsearch-nio'
+    exclude group: 'org.opensearch', module: 'opensearch-nio'
   }
 }
 

libs/nio/src/main/java/org/opensearch/nio/BytesChannelContext.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.IOException;
 import java.util.function.Consumer;

libs/nio/src/main/java/org/opensearch/nio/BytesWriteHandler.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.nio.ByteBuffer;
 import java.util.Collections;

libs/nio/src/main/java/org/opensearch/nio/ChannelContext.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.concurrent.CompletableContext;
 

libs/nio/src/main/java/org/opensearch/nio/ChannelFactory.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.Closeable;
 import java.io.IOException;

libs/nio/src/main/java/org/opensearch/nio/Config.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.net.InetSocketAddress;
 

libs/nio/src/main/java/org/opensearch/nio/DelegatingHandler.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.IOException;
 import java.util.List;

libs/nio/src/main/java/org/opensearch/nio/EventHandler.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.IOException;
 import java.nio.channels.SelectionKey;

libs/nio/src/main/java/org/opensearch/nio/FlushOperation.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.nio.ByteBuffer;
 import java.util.Arrays;

libs/nio/src/main/java/org/opensearch/nio/FlushReadyWrite.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.nio.ByteBuffer;
 import java.util.function.BiConsumer;

libs/nio/src/main/java/org/opensearch/nio/InboundChannelBuffer.java

@@ -17,9 +17,9 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
-import org.elasticsearch.nio.utils.ExceptionsHelper;
+import org.opensearch.nio.utils.ExceptionsHelper;
 
 import java.nio.ByteBuffer;
 import java.util.ArrayDeque;

libs/nio/src/main/java/org/opensearch/nio/NioChannel.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.net.InetSocketAddress;
 import java.nio.channels.NetworkChannel;

libs/nio/src/main/java/org/opensearch/nio/NioChannelHandler.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.IOException;
 import java.util.List;

libs/nio/src/main/java/org/opensearch/nio/NioGroup.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.Closeable;
 import java.io.IOException;

libs/nio/src/main/java/org/opensearch/nio/NioSelector.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.io.Closeable;
 import java.io.IOException;

libs/nio/src/main/java/org/opensearch/nio/NioSelectorGroup.java

@@ -17,9 +17,9 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
-import org.elasticsearch.nio.utils.ExceptionsHelper;
+import org.opensearch.nio.utils.ExceptionsHelper;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;

libs/nio/src/main/java/org/opensearch/nio/NioServerSocketChannel.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.net.InetSocketAddress;
 import java.nio.channels.ServerSocketChannel;

libs/nio/src/main/java/org/opensearch/nio/NioSocketChannel.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.net.InetSocketAddress;
 import java.nio.channels.SocketChannel;

libs/nio/src/main/java/org/opensearch/nio/Page.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.util.concurrent.AbstractRefCounted;
 

libs/nio/src/main/java/org/opensearch/nio/RoundRobinSupplier.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;

libs/nio/src/main/java/org/opensearch/nio/SelectionKeyUtils.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.nio.channels.CancelledKeyException;
 import java.nio.channels.SelectionKey;

libs/nio/src/main/java/org/opensearch/nio/ServerChannelContext.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.concurrent.CompletableContext;
 

libs/nio/src/main/java/org/opensearch/nio/SocketChannelContext.java

@@ -17,12 +17,12 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.concurrent.CompletableContext;
 import org.elasticsearch.core.internal.net.NetUtils;
-import org.elasticsearch.nio.utils.ByteBufferUtils;
-import org.elasticsearch.nio.utils.ExceptionsHelper;
+import org.opensearch.nio.utils.ByteBufferUtils;
+import org.opensearch.nio.utils.ExceptionsHelper;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;

libs/nio/src/main/java/org/opensearch/nio/TaskScheduler.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.util.Comparator;
 import java.util.PriorityQueue;

libs/nio/src/main/java/org/opensearch/nio/WriteOperation.java

@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.util.function.BiConsumer;
 

libs/nio/src/main/java/org/opensearch/nio/utils/ByteBufferUtils.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio.utils;
+package org.opensearch.nio.utils;
 
 import java.nio.ByteBuffer;
 

libs/nio/src/main/java/org/opensearch/nio/utils/ExceptionsHelper.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio.utils;
+package org.opensearch.nio.utils;
 
 import java.util.List;
 

libs/nio/src/test/java/org/opensearch/nio/BytesChannelContextTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.CheckedFunction;
 import org.elasticsearch.common.util.PageCacheRecycler;

libs/nio/src/test/java/org/opensearch/nio/ChannelContextTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.test.ESTestCase;
 import org.junit.Before;

libs/nio/src/test/java/org/opensearch/nio/ChannelFactoryTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.core.internal.io.IOUtils;
 import org.elasticsearch.test.ESTestCase;

libs/nio/src/test/java/org/opensearch/nio/EventHandlerTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.test.ESTestCase;
 import org.junit.Before;

libs/nio/src/test/java/org/opensearch/nio/FlushOperationTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.test.ESTestCase;
 import org.junit.Before;

libs/nio/src/test/java/org/opensearch/nio/InboundChannelBufferTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.test.ESTestCase;
 

libs/nio/src/test/java/org/opensearch/nio/NioSelectorGroupTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.CheckedRunnable;
 import org.elasticsearch.common.settings.Settings;

libs/nio/src/test/java/org/opensearch/nio/NioSelectorTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.CheckedRunnable;
 import org.elasticsearch.common.unit.TimeValue;

libs/nio/src/test/java/org/opensearch/nio/SocketChannelContextTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.common.SuppressForbidden;
 import org.elasticsearch.test.ESTestCase;

libs/nio/src/test/java/org/opensearch/nio/TaskSchedulerTests.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import org.elasticsearch.test.ESTestCase;
 

libs/nio/src/test/java/org/opensearch/nio/TestSelectionKey.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.elasticsearch.nio;
+package org.opensearch.nio;
 
 import java.nio.channels.SelectableChannel;
 import java.nio.channels.SelectionKey;

test/framework/src/main/java/org/opensearch/transport/nio/MockNioTransport.java

@@ -41,17 +41,17 @@ import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.PageCacheRecycler;
 import org.elasticsearch.core.internal.io.IOUtils;
 import org.elasticsearch.indices.breaker.CircuitBreakerService;
-import org.elasticsearch.nio.BytesChannelContext;
-import org.elasticsearch.nio.BytesWriteHandler;
-import org.elasticsearch.nio.ChannelFactory;
-import org.elasticsearch.nio.Config;
-import org.elasticsearch.nio.InboundChannelBuffer;
-import org.elasticsearch.nio.NioSelector;
-import org.elasticsearch.nio.NioSelectorGroup;
-import org.elasticsearch.nio.NioServerSocketChannel;
-import org.elasticsearch.nio.NioSocketChannel;
-import org.elasticsearch.nio.Page;
-import org.elasticsearch.nio.ServerChannelContext;
+import org.opensearch.nio.BytesChannelContext;
+import org.opensearch.nio.BytesWriteHandler;
+import org.opensearch.nio.ChannelFactory;
+import org.opensearch.nio.Config;
+import org.opensearch.nio.InboundChannelBuffer;
+import org.opensearch.nio.NioSelector;
+import org.opensearch.nio.NioSelectorGroup;
+import org.opensearch.nio.NioServerSocketChannel;
+import org.opensearch.nio.NioSocketChannel;
+import org.opensearch.nio.Page;
+import org.opensearch.nio.ServerChannelContext;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.ConnectionProfile;
 import org.opensearch.transport.InboundPipeline;

test/framework/src/main/java/org/opensearch/transport/nio/TestEventHandler.java

@@ -19,11 +19,11 @@
 
 package org.opensearch.transport.nio;
 
-import org.elasticsearch.nio.ChannelContext;
-import org.elasticsearch.nio.EventHandler;
-import org.elasticsearch.nio.NioSelector;
-import org.elasticsearch.nio.ServerChannelContext;
-import org.elasticsearch.nio.SocketChannelContext;
+import org.opensearch.nio.ChannelContext;
+import org.opensearch.nio.EventHandler;
+import org.opensearch.nio.NioSelector;
+import org.opensearch.nio.ServerChannelContext;
+import org.opensearch.nio.SocketChannelContext;
 
 import java.io.IOException;
 import java.util.Collections;

test/framework/src/test/java/org/opensearch/transport/nio/TestEventHandlerTests.java

@@ -24,8 +24,8 @@ import org.apache.logging.log4j.LogManager;
 import org.elasticsearch.common.CheckedRunnable;
 import org.elasticsearch.common.logging.Loggers;
 import org.elasticsearch.common.settings.Settings;
-import org.elasticsearch.nio.ServerChannelContext;
-import org.elasticsearch.nio.SocketChannelContext;
+import org.opensearch.nio.ServerChannelContext;
+import org.opensearch.nio.SocketChannelContext;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.test.MockLogAppender;
 import org.opensearch.threadpool.ThreadPool;