-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
- Loading branch information
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,3 +1 @@ | ||
# This should match the owning team set up in https://github.com/orgs/opensearch-project/teams | ||
* @opensearch-project/opensearch-core @reta | ||
|
||
* @reta @anasalkouz @andrross @reta @Bukhtawar @CEHENKLE @dblock @setiah @kartg @kotwanikunal @mch2 @nknize @owaiskazi19 @adnapibar @Rishikesh1159 @ryanbogan @saratvemulapalli @shwetathareja @dreamer-89 @tlfeng @VachaShah @xuezhou25 |
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,62 @@ | ||
/* | ||
* SPDX-License-Identifier: Apache-2.0 | ||
* | ||
* The OpenSearch Contributors require contributions made to | ||
* this file be licensed under the Apache-2.0 license or a | ||
* compatible open source license. | ||
*/ | ||
|
||
package org.opensearch.transport; | ||
|
||
import io.netty.channel.socket.InternetProtocolFamily; | ||
import io.netty.channel.socket.nio.NioServerSocketChannel; | ||
import io.netty.util.internal.SocketUtils; | ||
import io.netty.util.internal.logging.InternalLogger; | ||
import io.netty.util.internal.logging.InternalLoggerFactory; | ||
|
||
import java.nio.channels.ServerSocketChannel; | ||
import java.nio.channels.SocketChannel; | ||
import java.nio.channels.spi.SelectorProvider; | ||
import java.util.List; | ||
|
||
public class Netty4NioServerSocketChannel extends NioServerSocketChannel { | ||
private static final InternalLogger logger = InternalLoggerFactory.getInstance(Netty4NioServerSocketChannel.class); | ||
|
||
public Netty4NioServerSocketChannel() { | ||
super(); | ||
} | ||
|
||
public Netty4NioServerSocketChannel(SelectorProvider provider) { | ||
super(provider); | ||
} | ||
|
||
public Netty4NioServerSocketChannel(SelectorProvider provider, InternetProtocolFamily family) { | ||
super(provider, family); | ||
} | ||
|
||
public Netty4NioServerSocketChannel(ServerSocketChannel channel) { | ||
super(channel); | ||
} | ||
|
||
@Override | ||
protected int doReadMessages(List<Object> buf) throws Exception { | ||
SocketChannel ch = SocketUtils.accept(javaChannel()); | ||
|
||
try { | ||
if (ch != null) { | ||
buf.add(new Netty4NioSocketChannel(this, ch)); | ||
return 1; | ||
} | ||
} catch (Throwable t) { | ||
logger.warn("Failed to create a new channel from an accepted socket.", t); | ||
|
||
try { | ||
ch.close(); | ||
} catch (Throwable t2) { | ||
logger.warn("Failed to close a socket.", t2); | ||
} | ||
} | ||
|
||
return 0; | ||
} | ||
} |
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
7330de23c52f71617cbec7f1d2760dae32e687cd |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
e76715563a6bd150f84ccb0adb920aec8faf4779 |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
d08c064d18b2b149da937d15c0d1708cba03f29d |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
416a9dfce3714116bfdf793b15368df04266845f |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
2fb22ae74ad5aea6af1a9c64b9542f2ccf348604 |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
02efd11c940adb18c03eb9ce7ad88fc40ee6a196 |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
db113c8e9051b0ff967f4911fa20336c8325a7c5 |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
2a7fce47e22b7fedb1b277347ff4fe36d6eda50d |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
f6ed6356dd4a9bd269d873f65494376685e6192e |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
72b784a7bdab0ffde005fa64d15e3f077331d6fc |
This file was deleted.
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1 @@ | ||
00980e70b1df13c1236b750f0ca1462edd5d7417 |
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.