You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@mina.apache.org by "Emmanuel Lécharny (Jira)" <ji...@apache.org> on 2019/10/01 14:38:00 UTC
[jira] [Updated] (DIRMINA-886) isBrokenConnection
[ https://issues.apache.org/jira/browse/DIRMINA-886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Emmanuel Lécharny updated DIRMINA-886:
--------------------------------------
Description:
class :org.apache.mina.transport.socket.nio.NioProcessor
Method:
{code:java}
protected boolean isBrokenConnection() throws IOException
/**
* {@inheritDoc}
*/
@Override
protected boolean isBrokenConnection() throws IOException {
// A flag set to true if we find a broken session
boolean brokenSession = false;
synchronized (selector) {
// Get the selector keys
Set<SelectionKey> keys = selector.keys();
// Loop on all the keys to see if one of them
// has a closed channel
for (SelectionKey key : keys) {
SelectableChannel channel = key.channel();
if (((channel instanceof DatagramChannel) && ((DatagramChannel) channel)
.isConnected())
|| ((channel instanceof SocketChannel) && ((SocketChannel) channel)
.isConnected())) {
// The channel is not connected anymore. Cancel
// the associated key then.
key.cancel();
// Set the flag to true to avoid a selector switch
brokenSession = true;
}
}
}
return brokenSession;
}
{code}
--------------------------------------------------------------------------------
Question: if is need to add ! before ?
was:
class :org.apache.mina.transport.socket.nio.NioProcessor
Method:protected boolean isBrokenConnection() throws IOException
/**
* {@inheritDoc}
*/
@Override
protected boolean isBrokenConnection() throws IOException {
// A flag set to true if we find a broken session
boolean brokenSession = false;
synchronized (selector) {
// Get the selector keys
Set<SelectionKey> keys = selector.keys();
// Loop on all the keys to see if one of them
// has a closed channel
for (SelectionKey key : keys) {
SelectableChannel channel = key.channel();
if (((channel instanceof DatagramChannel) && ((DatagramChannel) channel)
.isConnected())
|| ((channel instanceof SocketChannel) && ((SocketChannel) channel)
.isConnected())) {
// The channel is not connected anymore. Cancel
// the associated key then.
key.cancel();
// Set the flag to true to avoid a selector switch
brokenSession = true;
}
}
}
return brokenSession;
}
--------------------------------------------------------------------------------
Question: if is need to add ! before ?
> isBrokenConnection
> ------------------
>
> Key: DIRMINA-886
> URL: https://issues.apache.org/jira/browse/DIRMINA-886
> Project: MINA
> Issue Type: Bug
> Components: Core
> Affects Versions: 2.0.4
> Reporter: jinkai mao
> Priority: Minor
> Labels: isBrokenConnection
> Fix For: 2.0.5
>
>
> class :org.apache.mina.transport.socket.nio.NioProcessor
> Method:
> {code:java}
> protected boolean isBrokenConnection() throws IOException
> /**
> * {@inheritDoc}
> */
> @Override
> protected boolean isBrokenConnection() throws IOException {
> // A flag set to true if we find a broken session
> boolean brokenSession = false;
> synchronized (selector) {
> // Get the selector keys
> Set<SelectionKey> keys = selector.keys();
> // Loop on all the keys to see if one of them
> // has a closed channel
> for (SelectionKey key : keys) {
> SelectableChannel channel = key.channel();
> if (((channel instanceof DatagramChannel) && ((DatagramChannel) channel)
> .isConnected())
> || ((channel instanceof SocketChannel) && ((SocketChannel) channel)
> .isConnected())) {
> // The channel is not connected anymore. Cancel
> // the associated key then.
> key.cancel();
> // Set the flag to true to avoid a selector switch
> brokenSession = true;
> }
> }
> }
> return brokenSession;
> }
>
> {code}
> --------------------------------------------------------------------------------
> Question: if is need to add ! before ?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@mina.apache.org
For additional commands, e-mail: dev-help@mina.apache.org