[JBoss JIRA] (ELY-373) General peer verification callback
by David Lloyd (JIRA)
[ https://issues.jboss.org/browse/ELY-373?page=com.atlassian.jira.plugin.sy... ]
David Lloyd resolved ELY-373.
-----------------------------
Resolution: Done
> General peer verification callback
> ----------------------------------
>
> Key: ELY-373
> URL: https://issues.jboss.org/browse/ELY-373
> Project: WildFly Elytron
> Issue Type: Task
> Components: Callbacks
> Reporter: David Lloyd
> Assignee: David Lloyd
> Fix For: 1.1.0.Beta3
>
>
> We need to generalize peer verification. Right now the peer verification callback ({{org.wildfly.security.auth.callback.VerifyPeerTrustedCallback}}) is specific to X.509 certificate chains, but other mechanisms might use different peer credentials for the verification.
> An ideal API might use an optional Principal and an optional Credential. For Entity, a {{org.wildfly.security.credential.X509CertificateChainPublicCredential}} might be used for the Credential, and the Principal would be extracted from that. For key-based authentication, the principal could be the NamePrincipal of the host name and the credential would be a PublicKeyCredential.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (ELY-374) Ambiguous application of CredentialCallback
by David Lloyd (JIRA)
[ https://issues.jboss.org/browse/ELY-374?page=com.atlassian.jira.plugin.sy... ]
David Lloyd resolved ELY-374.
-----------------------------
Fix Version/s: 1.1.0.Beta2
(was: 1.1.0.Beta3)
Resolution: Done
> Ambiguous application of CredentialCallback
> -------------------------------------------
>
> Key: ELY-374
> URL: https://issues.jboss.org/browse/ELY-374
> Project: WildFly Elytron
> Issue Type: Bug
> Components: Authentication Mechanisms, Callbacks, SASL
> Reporter: David Lloyd
> Priority: Critical
> Fix For: 1.1.0.Beta2
>
>
> We have a problem where there is an ambiguous application of {{CredentialCallback}}.
> On the client, this callback is used to acquire the credential to use for outbound authentication. On the server, it is used in two ways:
> * For most authentication, it is used to acquire the credential that is used to verify the client identity.
> * For Entity authentication, it is used to acquire the credential that is used to identify the server to the client.
> The reason Entity can get away with this special behavior is that it uses the {{VerifyPeerTrustedCallback}} instead of {{CredentialCallbak}} for checking the peer. Unfortunately, it is not easy for a callback handler to know when {{CredentialCallback}} is being used for the host identity versus the authenticating user identity. This needs to be solved ASAP so that we can have server mechanisms that present a host identity as well as acquiring a credential for user authentication.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (WFCORE-1133) JDK 1.8 on Mac causes javax.script.ScriptEngineFactory: Provider apple.applescript.AppleScriptEngineFactory not found
by Brian Stansberry (JIRA)
[ https://issues.jboss.org/browse/WFCORE-1133?page=com.atlassian.jira.plugi... ]
Brian Stansberry reassigned WFCORE-1133:
----------------------------------------
Assignee: Stuart Douglas
Stuart, I'm assigning this to you as you can best evaluate how critical this is for WF 10 and whether the PR is ok.
You're a busy guy, so if it's valid feel free to reassign back to me and I'll deal with the process hoops to get it in (file JBEAP, backport etc).
> JDK 1.8 on Mac causes javax.script.ScriptEngineFactory: Provider apple.applescript.AppleScriptEngineFactory not found
> ---------------------------------------------------------------------------------------------------------------------
>
> Key: WFCORE-1133
> URL: https://issues.jboss.org/browse/WFCORE-1133
> Project: WildFly Core
> Issue Type: Bug
> Affects Versions: 2.0.1.Final
> Environment: Macbook
> JDK 1.8
> Reporter: Jay SenSharma
> Assignee: Stuart Douglas
> Attachments: WildFlyServerSideJavaScript.war
>
>
> - When we try deploying any simple ServerSide java script based application on WildFly 10 we see the following Error while deploying the application:
> {code:java}
> 22:50:49,050 ERROR [stderr] (ServerService Thread Pool -- 62) ScriptEngineManager providers.next(): javax.script.ScriptEngineFactory: Provider apple.applescript.AppleScriptEngineFactory not found
> {code}
> try deploying the attached application on WildFly 10 and notice the console output.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (DROOLS-984) @expires( -1 ) should disable Event expiration
by Duncan Doyle (JIRA)
Duncan Doyle created DROOLS-984:
-----------------------------------
Summary: @expires( -1 ) should disable Event expiration
Key: DROOLS-984
URL: https://issues.jboss.org/browse/DROOLS-984
Project: Drools
Issue Type: Bug
Components: core engine
Affects Versions: 6.3.0.Final
Environment: Mac OS X 10.11.1, Oracle Hotspot 1.7.0_79, Drools 6.4.0-SNAPSHOT
Reporter: Duncan Doyle
Assignee: Mario Fusco
Defining an event with @expires( -1 ) should disable event expiration. However, when configuring my event like this:
{code}
declare SimpleEvent
@role( event )
@timestamp( logicalTimestamp )
@expires( -1 )
end
{code}
and having a rule like this:
{code}
rule "rule_1"
when
$s: SimpleEvent ()
not SimpleEvent (this != $s, this after[0, 30s] $s)
then
System.out.println("No event within 30 seconds of this event: " + $s.getId());
end
{code}
the event is still expired and retracted from WM after 30 seconds (the expiration time inferred from the temporal constraint in the rule).
Reproducer can be found here: https://github.com/DuncanDoyle/drools-disable-expiration-issue
Run 'mvn clean test' to reproduce.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (ELY-374) Ambiguous application of CredentialCallback
by David Lloyd (JIRA)
[ https://issues.jboss.org/browse/ELY-374?page=com.atlassian.jira.plugin.sy... ]
David Lloyd edited comment on ELY-374 at 11/19/15 11:17 AM:
------------------------------------------------------------
Here are some options:
# Add a field to {{CredentialCallback}} to designate local or peer credential, or perhaps client or server credential. In the Entity mechanism, use {{CredentialCallback}} on the client and server to acquire the local credential to use, and the general peer trust callback to verify the peer's public credential. On the client, only local credentials may be sensibly acquired, but on the server, either local or peer credentials might be acquired.
# Add a field to {{CredentialCallback}} as above, but stop using {{VerifyPeerTrustedCallback}} to verify the client, instead using a second (peer) {{CredentialCallback}} to acquire the user public credential and performing the validation within the mechanism. The {{VerifyPeerTrustedCallback}} (or its ELY-373 equivalent) would still be used on the client to verify the server.
# Add a {{LocalCredentialCallback}} which acquires the local credential. Use this credential on the server to acquire the host credential. Change the client to use this callback to acquire the user credential on the client. The server would continue to use {{CredentialCallback}} to acquire the user (peer) credential.
# Add a {{HostCredentialCallback}} which is basically identical to {{CredentialCallback}}. This would only be used server-side, to acquire the local host credential. Other existing uses of {{CredentialCallback}} would then remain unchanged. The advantage to this approach over #1 is that the client doesn't have to make sure the credential "type" makes sense (i.e. is "LOCAL" or "CLIENT" as opposed to "PEER" or "SERVER"). The advantage over #3 is that existing client and server usages don't have to change.
was (Author: dmlloyd):
Here are some options:
# Add a field to {{CredentialCallback}} to designate local or peer credential, or perhaps client or server credential. In the Entity mechanism, use {{CredentialCallback}} on the client and server to acquire the local credential to use, and the general peer trust callback to verify the peer's public credential. On the client, only local credentials may be sensibly acquired, but on the server, either local or peer credentials might be acquired.
# Add a field to {{CredentialCallback}} as above, but stop using {{VerifyPeerTrustedCallback}} to verify the client, instead using a second (peer) {{CredentialCallback}} to acquire the user public credential and performing the validation within the mechanism. The {{VerifyPeerTrustedCallback}} (or its ELY-373 equivalent) would still be used on the client to verify the server.
# Add a {{LocalCredentialCallback}} which acquires the local credential. Use this credential on the server to acquire the host credential. Change the client to use this callback to acquire the user credential on the client. The server would continue to use {{CredentialCallback}} to acquire the user (peer) credential.
> Ambiguous application of CredentialCallback
> -------------------------------------------
>
> Key: ELY-374
> URL: https://issues.jboss.org/browse/ELY-374
> Project: WildFly Elytron
> Issue Type: Bug
> Components: Authentication Mechanisms, Callbacks, SASL
> Reporter: David Lloyd
> Priority: Critical
> Fix For: 1.1.0.Beta3
>
>
> We have a problem where there is an ambiguous application of {{CredentialCallback}}.
> On the client, this callback is used to acquire the credential to use for outbound authentication. On the server, it is used in two ways:
> * For most authentication, it is used to acquire the credential that is used to verify the client identity.
> * For Entity authentication, it is used to acquire the credential that is used to identify the server to the client.
> The reason Entity can get away with this special behavior is that it uses the {{VerifyPeerTrustedCallback}} instead of {{CredentialCallbak}} for checking the peer. Unfortunately, it is not easy for a callback handler to know when {{CredentialCallback}} is being used for the host identity versus the authenticating user identity. This needs to be solved ASAP so that we can have server mechanisms that present a host identity as well as acquiring a credential for user authentication.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (JGRP-1968) JGroups missing JBoss logging internationalization
by Romain Pelisse (JIRA)
[ https://issues.jboss.org/browse/JGRP-1968?page=com.atlassian.jira.plugin.... ]
Romain Pelisse commented on JGRP-1968:
--------------------------------------
To clarify, in JBEAP-1401, @bilge stated that , in the current state, externalizing messages from JGroups is no longer a blocker. Nevertheless, after discussing with Bela Ban, I still opted to translate some more messages - to progress a bit more on this front).
Using the following bash script I've managed to externalized almost 200 more messages (all for the error level):
{code:bash}
$ cat translate.sh
#!/bin/bash
readonly SRC_FOLDER=${SRC_FOLDER:-'src'}
id=100
grep -e '.error(' -r "${SRC_FOLDER}" | sed -e 's/^.*log.error("//' -e 's/".*//g' | sed -e '/java:/d' \
| sed -e '/^[^ ]*$/d' | sort -u \
| sed -e '/^rsp_mode/d' -e '/^request/d' -e '/Verb/d' -e '/^type/d' -e '/Thread/d' -e '/%s/d' | \
while
read message
do
name=$(echo $message | sed -e "s/\b\(.\)/\u\1/g" | sed -e 's/ //g' | \
sed -e 's/://g' -e 's/(//g' -e 's/)//g' -e "s/'//g" -e 's/=//g' \
-e 's/-//g' -e 's/,//g' -e 's/\.//g' -e 's/_//g' -e 's/!//g' -e 's/;//g' )
if [ "${name}" != 'Mode' ]; then
echo -e "${name} = JGRP000${id}: ${message}"
id=$(expr "${id}" + 1)
grep -e "${message}" -r "${SRC_FOLDER}" | cut -f1 -d: | \
while
read file
do
sed -e "s|\"${message}\( *\)\"|Util.getMessage(\"${name}\")|g" -i "${file}"
done
fi
done
{code}
I'm adding the script here just for information or for later reference (it could be reused to externalized more message - debug or trace ones for instance). It supposed to be run like that:
{code:bash}
$ cd jgroups/
$ ./translate.sh >> conf/jg-messages.properties
{code}
* (!) Once executed, one still needs to add the appropriate import statement in each modfied classes.
* (!) Message finishing by a white space (such as "Header of type ") needs to be modified in the properties to add the extra space
> JGroups missing JBoss logging internationalization
> --------------------------------------------------
>
> Key: JGRP-1968
> URL: https://issues.jboss.org/browse/JGRP-1968
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 3.6.6
> Reporter: Michal Vinkler
> Assignee: Romain Pelisse
> Fix For: 3.6.7
>
>
> It is required for EAP7 to contain all features from EAP6.
> Per https://issues.jboss.org/browse/ANDIAMO-7, in EAP6 every serious log message (warn, error, fatal) should have a unique code that can be used to identify it.
> However, we found 559 serious log messages in EAP7.0.0.DR11 JGroups module (jgroups 3.6.6.) without id.
> List of serious log messages without id from a smoke test (link to Jenkins run will be provided when the automated test case is finished):
> {code}
> Suspicious logs: 559
> /tests/junit/org/jgroups/tests/StateTransferTest.java:338 log.error(channel.getAddress() + ": ", e);
> /src/org/jgroups/demos/applets/DrawApplet.java:70 log.error("DrawApplet.run(): msg or msg.buffer is null !");
> /src/org/jgroups/demos/applets/DrawApplet.java:170 log.error(e.toString());
> /src/org/jgroups/demos/applets/DrawApplet.java:202 log.error(ex.toString());
> /src/org/jgroups/demos/applets/DrawApplet.java:233 log.error(ex.toString());
> /src/org/jgroups/demos/applets/DrawApplet.java:250 log.error(ex.toString());
> /src/org/jgroups/demos/PubServer.java:41 log.error("failed publishing message", ex);
> /src/org/jgroups/demos/PubServer.java:51 log.error("failed publishing message", ex);
> /src/org/jgroups/demos/QuoteServer.java:68 log.error("QuoteServer.start() : " + e);
> /src/org/jgroups/demos/wb/Whiteboard.java:107 log.error("Whiteboard.init(): " + e);
> /src/org/jgroups/demos/wb/Whiteboard.java:129 log.error(e.toString());
> /src/org/jgroups/demos/wb/Whiteboard.java:160 log.error(ex.toString());
> /src/org/jgroups/demos/wb/GraphPanel.java:91 log.error("removeNode(): address of node to be removed is null !");
> /src/org/jgroups/demos/wb/GraphPanel.java:242 log.error(ex.toString());
> /src/org/jgroups/demos/wb/GraphPanel.java:274 log.error(e.toString());
> /src/org/jgroups/fork/ForkProtocolStack.java:159 log.error("failed passing up batch", t);
> /src/org/jgroups/fork/ForkChannel.java:105 log.error("name (%s) cannot be set in a fork-channel", name);
> /src/org/jgroups/fork/ForkChannel.java:110 log.error("name (%s) cannot be set in a fork-channel", name);
> /src/org/jgroups/JChannel.java:934 log.error("address generator %s does not subclass %s which is required if multiple address generators " +
> /src/org/jgroups/JChannel.java:1177 log.error("unable to invoke %s() on %s: %s", setter, protocol_name, e);
> /src/org/jgroups/stack/NakReceiverWindow.java:333 log.warn("seqno " + seqno + " is > highest_delivered (" + highest_delivered + ";) ignoring stability message");
> /src/org/jgroups/stack/RangeBasedRetransmitter.java:80 log.error("new range " + range + " overlaps with old range " + old_range);
> /src/org/jgroups/stack/RangeBasedRetransmitter.java:108 log.error("task for range " + range + " not found");
> /src/org/jgroups/stack/Protocol.java:128 log.warn("Field " + getName() + "." + name + " is deprecated: " + deprecated_msg);
> /src/org/jgroups/stack/Protocol.java:235 log.warn("Could not retrieve value of attribute (field) " + attr_name, e);
> /src/org/jgroups/stack/Protocol.java:262 log.warn("Could not retrieve value of attribute (method) " + method_name,e);
> /src/org/jgroups/stack/DiagnosticsHandler.java:132 log.error("failure handling diagnostics request", e);
> /src/org/jgroups/stack/DiagnosticsHandler.java:172 log.error("failed sending diag rsp to " + sender, t);
> /src/org/jgroups/stack/DiagnosticsHandler.java:224 log.warn("failed to join " + group_addr + " on " + i.getName() + ": " + e);
> /src/org/jgroups/stack/ProtocolStack.java:98 log.error("failed removing protocol " + prot_name, e);
> /src/org/jgroups/stack/ProtocolStack.java:111 log.error("Protocol %s cannot be inserted as it is already present", prot_name);
> /src/org/jgroups/stack/ProtocolStack.java:121 log.error("failed creating an instance of " + prot_name, e);
> /src/org/jgroups/stack/ProtocolStack.java:129 log.error("= missing in insert-protocol command");
> /src/org/jgroups/stack/ProtocolStack.java:136 log.error("Missing \"above\" or \"below\" in insert-protocol command");
> /src/org/jgroups/stack/ProtocolStack.java:144 log.error("Neighbor protocol " + neighbor_prot + " not found in stack");
> /src/org/jgroups/stack/ProtocolStack.java:152 log.error("failed inserting protocol " + prot_name + " " + tmp + " " + neighbor_prot, e);
> /src/org/jgroups/stack/ProtocolStack.java:160 log.error("failed creating an instance of " + prot_name, e);
> /src/org/jgroups/stack/ProtocolStack.java:704 log.error("failed stopping " + prot.getName() + ": " + t);
> /src/org/jgroups/stack/ProtocolStack.java:710 log.error("failed destroying " + prot.getName() + ": " + t);
> /src/org/jgroups/stack/RouterStubManager.java:244 log.warn("failed invoking stub", t);
> /src/org/jgroups/stack/Retransmitter.java:156 log.error("failed retransmission task", t);
> /src/org/jgroups/stack/RouterStub.java:206 log.error("failed reading data", ex);
> /src/org/jgroups/stack/RouterStub.java:273 log.error("failed notifying %s: %s", group, t);
> /src/org/jgroups/stack/GossipRouter.java:163 log.error("MBean de-registration failed", ex);
> /src/org/jgroups/stack/GossipRouter.java:205 log.error("failed reading data from %s: %s", sender, ex);
> /src/org/jgroups/stack/GossipRouter.java:225 log.error("failed reading request", t);
> /src/org/jgroups/stack/GossipRouter.java:250 log.error("failed sending %d to %s: %s", GossipType.GET_MBRS_RSP, sender, ex);
> /src/org/jgroups/stack/GossipRouter.java:280 log.error("failed reading request", ex);
> /src/org/jgroups/stack/GossipRouter.java:367 log.error("failed marshalling gossip data %s: %s; dropping request", request, ex);
> /src/org/jgroups/stack/GossipRouter.java:380 log.error("failed sending message to %s (%s): %s", e.logical_name, e.phys_addr, ex);
> /src/org/jgroups/stack/GossipRouter.java:396 log.error("failed sending message to %s (%s): %s", e.logical_name, e.phys_addr, ex);
> /src/org/jgroups/stack/GossipRouter.java:409 log.error("failed sending unicast message to %s: %s", dest, ex);
> /src/org/jgroups/stack/GossipRouter.java:418 log.error("failed sending unicast message to %s: %s", dest, ex);
> /src/org/jgroups/conf/ProtocolConfiguration.java:113 log.warn("variable \"" + val + "\" in " + protocol_name + " could not be substituted; " +
> /src/org/jgroups/client/StompConnection.java:145 log.error("failed to send connect message:", ex);
> /src/org/jgroups/client/StompConnection.java:173 log.error("failed subscribing to " + destination + ": ", ex);
> /src/org/jgroups/client/StompConnection.java:201 log.error("failed unsubscribing from " + destination + ": ", ex);
> /src/org/jgroups/client/StompConnection.java:228 log.error("failed sending message to " + destination + ": ", e);
> /src/org/jgroups/client/StompConnection.java:315 log.error("Connection closed unexpectedly:", e);
> /src/org/jgroups/client/StompConnection.java:324 log.error("failure reading frame", t);
> /src/org/jgroups/client/StompConnection.java:335 log.error("failed calling listener", t);
> /src/org/jgroups/client/StompConnection.java:346 log.error("failed calling listener", t);
> /src/org/jgroups/client/StompConnection.java:367 log.error("failed connecting to " + dest + ":" + ex);
> /src/org/jgroups/blocks/PartitionedHashMap.java:312 log.warn("_get() failed", t);
> /src/org/jgroups/blocks/PartitionedHashMap.java:333 log.warn("_remove() failed", t);
> /src/org/jgroups/blocks/PartitionedHashMap.java:424 log.warn("_put() failed", t);
> /src/org/jgroups/blocks/executor/ExecutionRunner.java:104 _logger.error("Unexpected Runtime Error encountered in Runnable request", t);
> /src/org/jgroups/blocks/cs/TcpConnection.java:203 server.log.error("%s: exception setting send buffer to %d bytes: %s", server.local_addr, server.send_buf_size, ex);
> /src/org/jgroups/blocks/cs/TcpConnection.java:209 server.log.error("%s: exception setting receive buffer to %d bytes: %s", server.local_addr, server.recv_buf_size, ex);
> /src/org/jgroups/blocks/cs/TcpConnection.java:350 server.log.warn("%s: discarding message because TCP send_queue is full and hasn't been releasing for %d ms",
> /src/org/jgroups/blocks/cs/NioBaseServer.java:149 log.warn("acceptor failure", t);
> /src/org/jgroups/blocks/cs/BaseServer.java:388 log.warn("failed notifying listener %s of connection close: %s", l, t);
> /src/org/jgroups/blocks/cs/BaseServer.java:399 log.warn("failed notifying listener %s of connection establishment: %s", l, t);
> /src/org/jgroups/blocks/cs/BaseServer.java:420 log.error("failed sending data to %s: %s", dest, ex);
> /src/org/jgroups/blocks/cs/BaseServer.java:435 log.error("failed sending data to %s: %s", dest, ex);
> /src/org/jgroups/blocks/cs/BaseServer.java:449 log.warn("%s: data is null; discarding message to %s", local_addr, dest);
> /src/org/jgroups/blocks/cs/NioConnection.java:317 server.log().error("%s: exception setting send buffer to %d bytes: %s", server.localAddress(), server.sendBufferSize(), ex);
> /src/org/jgroups/blocks/cs/NioConnection.java:323 server.log().error("%s: exception setting receive buffer to %d bytes: %s", server.localAddress(), server.receiveBufferSize(), ex);
> /src/org/jgroups/blocks/RpcDispatcher.java:315 if(log.isErrorEnabled()) log.error("no method handler is registered. Discarding request.");
> /src/org/jgroups/blocks/RpcDispatcher.java:320 if(log.isErrorEnabled()) log.error("message or message buffer is null");
> /src/org/jgroups/blocks/GroupRequest.java:388 if(log.isErrorEnabled()) log.error("rsp_mode " + options.getMode() + " unknown !");
> /src/org/jgroups/blocks/RequestCorrelator.java:137 if(log.isWarnEnabled()) log.warn("transport is not available !");
> /src/org/jgroups/blocks/RequestCorrelator.java:188 if(log.isWarnEnabled()) log.warn("transport is not available !");
> /src/org/jgroups/blocks/RequestCorrelator.java:394 log.error("failed unmarshalling buffer into return value", e);
> /src/org/jgroups/blocks/RequestCorrelator.java:404 if(log.isErrorEnabled()) log.error("header's type is neither REQ nor RSP !");
> /src/org/jgroups/blocks/RequestCorrelator.java:466 log.error(local_addr + ": failed dispatching request asynchronously: " + t);
> /src/org/jgroups/blocks/RequestCorrelator.java:494 if(log.isErrorEnabled()) log.error("failed marshalling rsp (" + reply + "): not serializable");
> /src/org/jgroups/blocks/RequestCorrelator.java:498 if(log.isErrorEnabled()) log.error("failed marshalling rsp (" + reply + "): " + tt);
> /src/org/jgroups/blocks/Cache.java:255 log.error("failed notifying change listener", t);
> /src/org/jgroups/blocks/ReplicatedTree.java:178 if(log.isErrorEnabled()) log.error("channel is null, cannot broadcast PUT request");
> /src/org/jgroups/blocks/ReplicatedTree.java:189 if(log.isErrorEnabled()) log.error("failure bcasting PUT request: " + ex);
> /src/org/jgroups/blocks/ReplicatedTree.java:217 if(log.isErrorEnabled()) log.error("channel is null, cannot broadcast PUT request");
> /src/org/jgroups/blocks/ReplicatedTree.java:228 if(log.isErrorEnabled()) log.error("failure bcasting PUT request: " + ex);
> /src/org/jgroups/blocks/ReplicatedTree.java:250 if(log.isErrorEnabled()) log.error("channel is null, cannot broadcast REMOVE request");
> /src/org/jgroups/blocks/ReplicatedTree.java:258 if(log.isErrorEnabled()) log.error("failure bcasting REMOVE request: " + ex);
> /src/org/jgroups/blocks/ReplicatedTree.java:281 if(log.isErrorEnabled()) log.error("channel is null, cannot broadcast REMOVE request");
> /src/org/jgroups/blocks/ReplicatedTree.java:292 if(log.isErrorEnabled()) log.error("failure bcasting REMOVE request: " + ex);
> /src/org/jgroups/blocks/ReplicatedTree.java:543 if(log.isErrorEnabled()) log.error("type " + req.type + " unknown");
> /src/org/jgroups/blocks/ReplicatedTree.java:548 if(log.isErrorEnabled()) log.error("failed unmarshalling request: " + ex);
> /src/org/jgroups/blocks/BasicConnectionTable.java:291 log.error("destination is null");
> /src/org/jgroups/blocks/BasicConnectionTable.java:296 log.warn("data is null; discarding packet");
> /src/org/jgroups/blocks/BasicConnectionTable.java:302 log.warn("connection table is not running, discarding message to " + dest);
> /src/org/jgroups/blocks/BasicConnectionTable.java:423 if(log.isErrorEnabled()) log.error("exception is " + ex);
> /src/org/jgroups/blocks/BasicConnectionTable.java:490 log.warn("Connection is not running, discarding message");
> /src/org/jgroups/blocks/BasicConnectionTable.java:528 if(log.isErrorEnabled()) log.error("failed sending data to " + peer_addr + ": " + ex);
> /src/org/jgroups/blocks/BasicConnectionTable.java:581 log.warn(new StringBuilder("packet from ").append(client_addr).append(':').append(client_port).
> /src/org/jgroups/blocks/BasicConnectionTable.java:604 if(log.isWarnEnabled()) log.warn("local_addr is null");
> /src/org/jgroups/blocks/BasicConnectionTable.java:619 if(log.isErrorEnabled()) log.error("exception is " + t);
> /src/org/jgroups/blocks/BasicConnectionTable.java:649 if(log.isErrorEnabled()) log.error("input stream is null !");
> /src/org/jgroups/blocks/BasicConnectionTable.java:659 if(log.isWarnEnabled()) log.warn("dropped invalid message, closing connection");
> /src/org/jgroups/blocks/BasicConnectionTable.java:669 if(log.isWarnEnabled()) log.warn("Problem encountered while receiving message from peer " + peer_addr, e);
> /src/org/jgroups/blocks/MessageDispatcher.java:234 log.warn("Channel Muxer already has a default up handler installed (" +
> /src/org/jgroups/blocks/MessageDispatcher.java:240 log.warn("Channel already has an up handler installed (" + existing + ") but now it is being overridden");
> /src/org/jgroups/blocks/MessageDispatcher.java:527 log.warn("notifying channel listener " + l + " failed", t);
> /src/org/jgroups/blocks/MessageDispatcher.java:540 log.warn("notifying channel listener " + l + " failed", t);
> /src/org/jgroups/blocks/MessageDispatcher.java:553 log.warn("notifying channel listener " + l + " failed", t);
> /src/org/jgroups/blocks/Request.java:79 if(log.isErrorEnabled()) log.error("corr is null, cannot send request");
> /src/org/jgroups/blocks/ConnectionTableNIO.java:249 if (log.isErrorEnabled()) log.error("exception setting send buffer size to " +
> /src/org/jgroups/blocks/ConnectionTableNIO.java:262 if (log.isErrorEnabled()) log.error("exception setting receive buffer size to " +
> /src/org/jgroups/blocks/ConnectionTableNIO.java:285 log.warn("Thread (" +Thread.currentThread().getName() + ") was interrupted, closing connection", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:392 log.error("Thread ("+Thread.currentThread().getName() +") was interrupted, failed to shutdown selector", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:406 log.error("Thread ("+Thread.currentThread().getName() +") was interrupted, failed to shutdown selector", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:438 log.error("Thread ("+Thread.currentThread().getName() +") was interrupted while waiting on thread " + t.getName() + " to finish.");
> /src/org/jgroups/blocks/ConnectionTableNIO.java:459 log.warn("Select operation on listening socket failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:477 log.warn("Attempt to accept new connection from listening socket failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:489 if(log.isErrorEnabled()) log.error("exception setting send buffer size to " + send_buf_size + " bytes: ", ex);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:492 if(log.isErrorEnabled()) log.error("exception setting send buffer size to " + send_buf_size + " bytes: ", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:499 if(log.isErrorEnabled()) log.error("exception setting receive buffer size to " + send_buf_size + " bytes: ", ex);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:502 if(log.isErrorEnabled()) log.error("exception setting receive buffer size to " + recv_buf_size + " bytes: ", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:538 log.warn("Attempt to configure non-blocking mode failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:544 log.warn("Attempt to handshake with other peer failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:564 log.warn("Attempt to configure read handler for accepted connection failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:577 log.error("exception closing server listening socket", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:627 log.error("Attempt to bind serversocket failed, port="+start_port+", bind addr=" + bind_addr ,io_ex);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:666 if (log.isErrorEnabled()) log.error(e.toString());
> /src/org/jgroups/blocks/ConnectionTableNIO.java:716 log.warn("Select operation on socket failed", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:721 log.warn("Select operation on socket failed" , e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:831 log.error("Thread ("+Thread.currentThread().getName() +") was interrupted while assigning executor to process read request" , e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:998 log.error("failed sending message", (Exception)ex);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1025 log.error("error closing socket connection", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1071 if (log.isErrorEnabled()) log.error(e.toString());
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1218 if (log.isErrorEnabled()) log.error("SelectNow operation on write selector failed, didn't expect this to occur, please report this", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1251 if (log.isErrorEnabled()) log.error("Failure while writing to socket",e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1257 if (log.isErrorEnabled()) log.error("Thread ("+Thread.currentThread().getName() +") was interrupted", e);
> /src/org/jgroups/blocks/ConnectionTableNIO.java:1262 if (log.isErrorEnabled()) log.error("Thread ("+Thread.currentThread().getName() +") caught Throwable" , e);
> /src/org/jgroups/blocks/ReplCache.java:349 log.warn("repl_count of 0 is invalid, data will not be stored in the cluster");
> /src/org/jgroups/blocks/ReplCache.java:445 log.warn("get() failed", t);
> /src/org/jgroups/blocks/ReplCache.java:474 log.warn("remove() failed", t);
> /src/org/jgroups/blocks/ReplCache.java:636 log.error("failed notifying change listener", t);
> /src/org/jgroups/blocks/ReplCache.java:660 log.warn(key + " has no value associated; ignoring");
> /src/org/jgroups/blocks/ReplCache.java:666 log.warn(key + " has no value associated; ignoring");
> /src/org/jgroups/blocks/ReplCache.java:715 log.warn(key + " has no value associated; ignoring");
> /src/org/jgroups/blocks/ReplCache.java:721 log.warn(key + " has no value associated; ignoring");
> /src/org/jgroups/blocks/ReplCache.java:742 log.warn("put() failed", t);
> /src/org/jgroups/blocks/ReplCache.java:753 log.warn("clear() failed", t);
> /src/org/jgroups/blocks/ReplCache.java:766 log.warn("move() failed", t);
> /src/org/jgroups/blocks/MethodCall.java:203 log.warn("unable to enumerate methods of superclass "+superclass+" of class "+target);
> /src/org/jgroups/blocks/MethodCall.java:280 if(log.isErrorEnabled()) log.error("mode " + mode + " is invalid");
> /src/org/jgroups/blocks/MethodCall.java:402 if(log.isErrorEnabled()) log.error("mode " + mode + " is invalid");
> /src/org/jgroups/blocks/MethodCall.java:433 if(log.isErrorEnabled()) log.error("mode " + mode + " is invalid");
> /src/org/jgroups/logging/Log4J2LogImpl.java:75 logger.warn(msg);
> /src/org/jgroups/logging/Log4J2LogImpl.java:79 logger.warn(msg, args);
> /src/org/jgroups/logging/Log4J2LogImpl.java:83 logger.warn(msg, throwable);
> /src/org/jgroups/logging/Log4J2LogImpl.java:87 logger.error(msg);
> /src/org/jgroups/logging/Log4J2LogImpl.java:91 logger.error(format, args);
> /src/org/jgroups/logging/Log4J2LogImpl.java:95 logger.error(msg, throwable);
> /src/org/jgroups/logging/Log4J2LogImpl.java:99 logger.fatal(msg);
> /src/org/jgroups/logging/Log4J2LogImpl.java:103 logger.fatal(msg, args);
> /src/org/jgroups/logging/Log4J2LogImpl.java:107 logger.fatal(msg, throwable);
> /src/org/jgroups/auth/FixedMembershipToken.java:70 log.error("didn't find physical address for " + msg.getSrc());
> /src/org/jgroups/auth/FixedMembershipToken.java:77 log.warn("Invalid AuthToken instance - wrong type or null");
> /src/org/jgroups/auth/Krb5TokenUtils.java:33 log.error("Exception was generated while creating an Oid instance", e);
> /src/org/jgroups/auth/Krb5TokenUtils.java:79 log.error("Krb5Token Kerberos context processing exception",e);
> /src/org/jgroups/auth/Krb5TokenUtils.java:100 log.error("Krb5Token Kerberos context processing exception",e);
> /src/org/jgroups/auth/X509Token.java:111 log.error("X509Token not setup correctly - check token attrs");
> /src/org/jgroups/auth/X509Token.java:121 log.error("X509Token - received token not valid");
> /src/org/jgroups/auth/X509Token.java:140 log.error(e.toString());
> /src/org/jgroups/auth/SimpleToken.java:71 log.warn("Invalid AuthToken instance - wrong type or null");
> /src/org/jgroups/auth/sasl/SimpleAuthorizingCallbackHandler.java:175 log.error("An error occurred while loading properties from " + file, e);
> /src/org/jgroups/auth/MD5Token.java:88 log.warn("Failed to hash token - sending in clear text");
> /src/org/jgroups/auth/MD5Token.java:104 log.warn("Invalid AuthToken instance - wrong type or null");
> /src/org/jgroups/auth/Krb5Token.java:66 log.warn("Krb5Token failed to authenticate", e);
> /src/org/jgroups/auth/Krb5Token.java:77 log.error("Krb5Token failed to setup correctly - cannot authenticate any peers");
> /src/org/jgroups/auth/Krb5Token.java:90 log.error("Krb5Token service ticket validation failed", e);
> /src/org/jgroups/Channel.java:399 log.warn("%s: receiver already set");
> /src/org/jgroups/protocols/TP.java:1190 log.warn("The internal thread pool was configured with only %d min_threads; this might lead to problems " +
> /src/org/jgroups/protocols/TP.java:1298 log.error("failed starting diagnostics", e);
> /src/org/jgroups/protocols/TP.java:1724 log.error("%s: failed submitting DONT_BUNDLE message to thread pool: %s. Msg: %s",
> /src/org/jgroups/protocols/SWIFT_PING.java:103 log.error("failure creating container", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:115 log.warn("failed reading " + object);
> /src/org/jgroups/protocols/SWIFT_PING.java:127 log.error("Error unmarshalling object", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:140 log.error("Error marshalling object", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:151 log.error("failure removing data", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:165 log.error("failed removing objects", t);
> /src/org/jgroups/protocols/SWIFT_PING.java:359 log.error("Error building URL", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:372 log.error("Error creating connection", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:381 log.error("Protocol error", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:427 log.error("Error reading objects", e);
> /src/org/jgroups/protocols/SWIFT_PING.java:484 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/SWIFT_PING.java:488 log.error("Error deleting object " + objectName
> /src/org/jgroups/protocols/SWIFT_PING.java:510 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/SWIFT_PING.java:514 log.error("Error creating container " + containerName
> /src/org/jgroups/protocols/SWIFT_PING.java:539 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/SWIFT_PING.java:543 log.error("Error creating object " + objectName
> /src/org/jgroups/protocols/SWIFT_PING.java:568 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/SWIFT_PING.java:572 log.error("Error reading object " + objectName
> /src/org/jgroups/protocols/SWIFT_PING.java:596 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/SWIFT_PING.java:600 log.error("Error listing container " + containerName
> /src/org/jgroups/protocols/PING.java:40 log.error("failed sending discovery request", ex);
> /src/org/jgroups/protocols/FD_ALL.java:158 log.warn("%s: time service is not available, using System.currentTimeMillis() instead", local_addr);
> /src/org/jgroups/protocols/FD_ALL.java:161 log.warn("%s: interval of time service (%d) is greater than timeout (%d), disabling time service",
> /src/org/jgroups/protocols/JDBC_PING.java:146 log.error("Error while unregistering of our own Address from JDBC_PING database during shutdown", e);
> /src/org/jgroups/protocols/JDBC_PING.java:212 log.error("Error updating JDBC_PING table", e);
> /src/org/jgroups/protocols/JDBC_PING.java:218 log.error("Failed to store PingData in database");
> /src/org/jgroups/protocols/JDBC_PING.java:237 log.error("Error reading table", e);
> /src/org/jgroups/protocols/JDBC_PING.java:247 log.error("Error", e);
> /src/org/jgroups/protocols/JDBC_PING.java:257 log.error("Error reading JDBC_PING table", e);
> /src/org/jgroups/protocols/JDBC_PING.java:280 log.error("%s: failed deserializing row %d: %s; removing it from the table", local_addr, row, e);
> /src/org/jgroups/protocols/JDBC_PING.java:285 log.error("%s: failed removing row %d: %s; please delete it manually", local_addr, row, e);
> /src/org/jgroups/protocols/JDBC_PING.java:315 log.error("Error closing connection", e);
> /src/org/jgroups/protocols/JDBC_PING.java:338 log.error("Could not open connection to database", e);
> /src/org/jgroups/protocols/JDBC_PING.java:342 log.error("Received null connection from the DriverManager!");
> /src/org/jgroups/protocols/JDBC_PING.java:350 log.error("Could not open connection to database", e);
> /src/org/jgroups/protocols/JDBC_PING.java:384 log.error("Error updating JDBC_PING table", e);
> /src/org/jgroups/protocols/JDBC_PING.java:389 log.error("Failed to delete PingData in database");
> /src/org/jgroups/protocols/JDBC_PING.java:405 log.error("Error clearing table", e);
> /src/org/jgroups/protocols/JDBC_PING.java:414 log.error("Error closing connection to JDBC_PING database", e);
> /src/org/jgroups/protocols/JDBC_PING.java:443 log.warn("Failed to close naming context.", e);
> /src/org/jgroups/protocols/SHARED_LOOPBACK.java:77 log.error("failed sending message to " + dest, t);
> /src/org/jgroups/protocols/UFC.java:115 log.error(getClass().getSimpleName() + " doesn't handle multicast messages; passing message down");
> /src/org/jgroups/protocols/TCPGOSSIP.java:110 log.error("group_addr or local_addr is null, cannot register with GossipRouter(s)");
> /src/org/jgroups/protocols/TCPGOSSIP.java:150 log.error("cluster_name is null, cannot get membership");
> /src/org/jgroups/protocols/TCPGOSSIP.java:162 log.warn("failed fetching members from %s: %s, cause: %s", stub.gossipRouterAddress(), t, t.getCause());
> /src/org/jgroups/protocols/ENCRYPT.java:254 log.warn("cipher_pool_size of %d is invalid; setting it to 1", cipher_pool_size);
> /src/org/jgroups/protocols/ENCRYPT.java:260 log.warn("setting cipher_pool_size (%d) to %d (power of 2) for faster modulo operation", cipher_pool_size, tmp);
> /src/org/jgroups/protocols/ENCRYPT.java:450 log.warn("exception occurred decrypting message", e);
> /src/org/jgroups/protocols/ENCRYPT.java:498 log.error("could not initialize new ciphers", e);
> /src/org/jgroups/protocols/ENCRYPT.java:587 log.warn("unrecognised cipher; discarding message");
> /src/org/jgroups/protocols/ENCRYPT.java:594 log.warn("we received an encrypt header of %s while in configured mode",hdr.getType());
> /src/org/jgroups/protocols/ENCRYPT.java:612 log.warn("unable to reconstitute peer's public key");
> /src/org/jgroups/protocols/ENCRYPT.java:629 log.warn("unable to process received public key", e);
> /src/org/jgroups/protocols/ENCRYPT.java:633 log.warn("received ignored encrypt header of %s", hdr.getType());
> /src/org/jgroups/protocols/ENCRYPT.java:659 log.error("failed decrypting and sending message up when draining queue", t);
> /src/org/jgroups/protocols/ENCRYPT.java:679 log.error("failed sending message down when draining queue", t);
> /src/org/jgroups/protocols/ENCRYPT.java:721 log.warn("attempting to use stored cipher as message does not use current encryption version ");
> /src/org/jgroups/protocols/ENCRYPT.java:724 log.warn("unable to find a matching cipher in previous key map");
> /src/org/jgroups/protocols/ENCRYPT.java:804 log.warn("unable to send message down", e);
> /src/org/jgroups/protocols/ENCRYPT.java:897 log.error("failed decoding key", e);
> /src/org/jgroups/protocols/ENCRYPT.java:959 log.error("failed decrypting message from %s (offset=%d, length=%d, buf.length=%d): %s, headers are %s",
> /src/org/jgroups/protocols/TCP_NIO.java:40 if(log.isWarnEnabled()) log.warn("reaper_interval was 0, set it to " + ri);
> /src/org/jgroups/protocols/TCP_NIO.java:44 if(log.isWarnEnabled()) log.warn("conn_expire_time was 0, set it to " + cet);
> /src/org/jgroups/protocols/PRIO.java:248 log.error( "Error handling message. Sleeping " + (prio.message_failure_sleep_time/1000) + " seconds", e );
> /src/org/jgroups/protocols/SEQUENCER2.java:188 log.error("%s: non-coord; dropping REQUEST request from %s", local_addr, msg.getSrc());
> /src/org/jgroups/protocols/SEQUENCER2.java:193 log.error("%s : dropping REQUEST from non-member %s; view=%s" + view, local_addr, sender, view);
> /src/org/jgroups/protocols/SEQUENCER2.java:206 log.error(local_addr + "%s: dropping RESPONSE from non-coordinator %s; view=%s", local_addr, coordinator, view);
> /src/org/jgroups/protocols/SEQUENCER2.java:214 log.error("received %d seqnos but fwd_queue is empty", hdr.num_seqnos);
> /src/org/jgroups/protocols/SEQUENCER2.java:281 log.error(local_addr + ": sender is null, cannot deliver batch " + "::" + batch);
> /src/org/jgroups/protocols/SEQUENCER2.java:312 log.error("failed passing up message", t);
> /src/org/jgroups/protocols/SEQUENCER2.java:392 log.error(local_addr + ": sender is null, cannot deliver " + "::" + hdr.getSeqno());
> /src/org/jgroups/protocols/PDC.java:157 log.warn("failed parsing content in " + file.getAbsolutePath() + ": removing it ");
> /src/org/jgroups/protocols/PDC.java:211 log.error("attempt to move failed at: " + tmpFile.getName() + "->" + destination.getName(), ioe);
> /src/org/jgroups/protocols/PDC.java:244 log.error("Failed to write temporary file: " + filename, e);
> /src/org/jgroups/protocols/PDC.java:286 log.error("Failed to delete file: " + file.getAbsolutePath(), e);
> /src/org/jgroups/protocols/FD_SOCK.java:180 log.warn("Node crash detection manually started, was not running for some reason.");
> /src/org/jgroups/protocols/FD_SOCK.java:452 log.error("exception", catch_all_the_rest);
> /src/org/jgroups/protocols/FD_SOCK.java:629 log.error("%s: failed creating client socket to %s: %s", local_addr, dest, e);
> /src/org/jgroups/protocols/FD_SOCK.java:872 log.error("%s: failed reading addresses from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/FD_SOCK.java:1196 log.warn("%s: task %s was rejected as timer thread pool is shutting down", local_addr, this);
> /src/org/jgroups/protocols/UNICAST3.java:798 log.warn("%s: entry not found for %s; dropping message", local_addr, sender);
> /src/org/jgroups/protocols/FD.java:234 log.warn("%s: I was suspected by %s; ignoring the SUSPECT message and sending back a HEARTBEAT_ACK",
> /src/org/jgroups/protocols/FD_PING.java:46 log.warn("ping_dest is null: members=" + members + ", pingable_mbrs=" +
> /src/org/jgroups/protocols/FD_PING.java:87 log.error("failed executing command " + command, ex);
> /src/org/jgroups/protocols/UDP.java:342 log.error("failed setting ip_ttl", e);
> /src/org/jgroups/protocols/UDP.java:346 log.warn("ip_ttl %d could not be set in the datagram socket; ttl will default to 1 (getImpl=%s, " +
> /src/org/jgroups/protocols/UDP.java:686 log.error("size of the received packet (" + len + ") is bigger than allocated buffer (" +
> /src/org/jgroups/protocols/UDP.java:701 log.error("failed receiving packet", sock_ex);
> /src/org/jgroups/protocols/UDP.java:705 log.error("failed receiving packet", ex);
> /src/org/jgroups/protocols/rules/Rule.java:53 log.error(sv.getLocalAddress() + ": failed executiong rule " + name(), t);
> /src/org/jgroups/protocols/rules/SUPERVISOR.java:186 log.error("event handler failed handling down event", t);
> /src/org/jgroups/protocols/rules/SUPERVISOR.java:206 log.error("event handler failed handling up event", t);
> /src/org/jgroups/protocols/rules/SUPERVISOR.java:221 log.error("event handler failed handling up event", t);
> /src/org/jgroups/protocols/SEQUENCER.java:168 log.error("failed sending message", ex);
> /src/org/jgroups/protocols/SEQUENCER.java:211 log.error(local_addr + ": non-coord; dropping FORWARD request from " + msg.getSrc());
> /src/org/jgroups/protocols/SEQUENCER.java:217 log.error(local_addr + ": dropping FORWARD request from non-member " + sender +
> /src/org/jgroups/protocols/SEQUENCER.java:262 log.error("failed passing up message", t);
> /src/org/jgroups/protocols/SEQUENCER.java:351 log.error("flushing (broadcasting) failed", e);
> /src/org/jgroups/protocols/SEQUENCER.java:385 log.error("flushing (broadcasting) failed", e);
> /src/org/jgroups/protocols/SEQUENCER.java:451 log.error("failed forwarding message to " + msg.getDest(), ex);
> /src/org/jgroups/protocols/SEQUENCER.java:492 log.error("failure unmarshalling buffer", ex);
> /src/org/jgroups/protocols/SEQUENCER.java:501 log.error(local_addr + ": sender is null, cannot deliver " + "::" + hdr.getSeqno());
> /src/org/jgroups/protocols/SEQUENCER.java:517 log.warn(local_addr + ": dropped duplicate message " + sender + "::" + msg_seqno);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:79 log.warn("failed reading " + object);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:91 log.error("Error unmarshalling object", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:104 log.error("Error marshalling object", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:193 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/RACKSPACE_PING.java:197 log.error("Error deleting object " + objectName + " from container " + containerName + ",code = " + response.code);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:217 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/RACKSPACE_PING.java:221 log.error("Error creating container " + containerName + " ,code = " + response.code);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:243 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/RACKSPACE_PING.java:247 log.error("Error creating object " + objectName + " in container " + containerName + ",code = " + response.code);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:267 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/RACKSPACE_PING.java:271 log.error("Error reading object " + objectName + " from container " + containerName + ", code = " + response.code);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:291 log.warn("Refreshing credentials and retrying");
> /src/org/jgroups/protocols/RACKSPACE_PING.java:295 log.error("Error listing container " + containerName + ", code = " + response.code);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:328 log.error("Error calling service", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:389 log.error("Error building URL", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:403 log.error("Error creating connection", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:412 log.error("Protocol error", e);
> /src/org/jgroups/protocols/RACKSPACE_PING.java:481 log.error("Error reading objects", e);
> /src/org/jgroups/protocols/FRAG.java:228 log.error("exception occurred trying to fragment message", e);
> /src/org/jgroups/protocols/FRAG.java:267 log.error("failed unfragmenting a message", e);
> /src/org/jgroups/protocols/Locking.java:262 log.error("Request of type %s not known", req.type);
> /src/org/jgroups/protocols/Locking.java:375 log.error("failed sending %s request: %s", req.type, ex);
> /src/org/jgroups/protocols/Locking.java:428 log.error("Condition await was received but lock was not created. Waiter may block forever");
> /src/org/jgroups/protocols/Locking.java:443 log.error("Condition await delete was received, but lock was gone");
> /src/org/jgroups/protocols/Locking.java:456 log.error("Condition response was client lock was not present. Ignored signal.");
> /src/org/jgroups/protocols/Locking.java:469 log.error("Condition signal was received but lock was not created. Couldn't notify anyone.");
> /src/org/jgroups/protocols/Locking.java:554 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:565 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:576 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:587 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:598 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:609 log.error("failed notifying %s: %s", listener, t.toString());
> /src/org/jgroups/protocols/Locking.java:913 log.error("discarded LOCK-GRANTED response with lock-id=" + lock_id + ", my lock-id=" + this.lock_id);
> /src/org/jgroups/protocols/Locking.java:922 log.error("discarded LOCK-DENIED response with lock-id=" + lock_id + ", my lock_id=" + this.lock_id);
> /src/org/jgroups/protocols/FD_HOST.java:159 log.warn("%s: time service is not available, using System.currentTimeMillis() instead", local_addr);
> /src/org/jgroups/protocols/FD_HOST.java:162 log.warn("%s: interval of time service (%d) is greater than timeout (%d), disabling time service",
> /src/org/jgroups/protocols/FD_HOST.java:403 log.error("%s: ping command failed: %s", local_addr, e);
> /src/org/jgroups/protocols/SCOPE.java:256 log.error("message doesn't have a ScopeHeader attached");
> /src/org/jgroups/protocols/SCOPE.java:443 log.error("couldn't deliver message " + msg_to_deliver, t);
> /src/org/jgroups/protocols/SCOPE.java:467 log.error("failed expiring old scopes", t);
> /src/org/jgroups/protocols/TUNNEL.java:253 log.warn("failed sending a message to all members, router used %s", stub.gossipRouterAddress());
> /src/org/jgroups/protocols/TUNNEL.java:268 log.warn("failed sending a message to all members, router used %s", stub.gossipRouterAddress());
> /src/org/jgroups/protocols/PERF.java:66 log.error("%s: no perf header found", local_addr);
> /src/org/jgroups/protocols/PERF.java:70 log.error("%s: time is <= 0");
> /src/org/jgroups/protocols/PERF.java:82 log.error("%s: no perf header found", local_addr);
> /src/org/jgroups/protocols/PERF.java:86 log.error("%s: time is <= 0");
> /src/org/jgroups/protocols/BARRIER.java:290 log.warn("%s: failure passing message up the stack: %s", local_addr, t);
> /src/org/jgroups/protocols/SASL.java:254 log.warn("failed to validate CHALLENGE from " + remoteAddress + ", token", e);
> /src/org/jgroups/protocols/SASL.java:279 log.warn("failed to validate RESPONSE from " + remoteAddress + ", token", e);
> /src/org/jgroups/protocols/SASL.java:305 log.warn("Found GMS join or merge request but no SASL header");
> /src/org/jgroups/protocols/SASL.java:371 log.warn("failed to validate SaslHeader from %s, header: %s", msg.getSrc(), saslHeader);
> /src/org/jgroups/protocols/SASL.java:376 log.warn("failed to validate SaslHeader from %s, header: %s", msg.getSrc(), saslHeader);
> /src/org/jgroups/protocols/SASL.java:400 log.error("type " + type + " unknown");
> /src/org/jgroups/protocols/Executing.java:374 log.warn("Cancelling requestId didn't match waiting");
> /src/org/jgroups/protocols/Executing.java:382 log.warn("Couldn't interrupt server task: " + runnable);
> /src/org/jgroups/protocols/Executing.java:412 log.warn("Cancelling requestId didn't match waiting");
> /src/org/jgroups/protocols/Executing.java:494 log.error("Request of type " + req.type +
> /src/org/jgroups/protocols/Executing.java:534 log.error("Request of type " + req.type + " not known");
> /src/org/jgroups/protocols/Executing.java:781 log.warn("Task Request Id doesn't match in rejection");
> /src/org/jgroups/protocols/Executing.java:786 log.error("error resubmitting task for request-id: " + requestId);
> /src/org/jgroups/protocols/Executing.java:806 log.warn("Runnable was not found in awaiting");
> /src/org/jgroups/protocols/Executing.java:829 log.error("Runtime Error encountered from cluster execute(Runnable) method", throwable);
> /src/org/jgroups/protocols/Executing.java:902 log.error("failed sending " + type + " request: " + ex);
> /src/org/jgroups/protocols/Executing.java:918 log.error("failed sending " + type + " request: " + ex);
> /src/org/jgroups/protocols/FC.java:383 log.warn("No fragmentation protocol was found. When flow control (e.g. FC or SFC) is used, we recommend " +
> /src/org/jgroups/protocols/FC.java:515 log.error("header type " + hdr.type + " not known");
> /src/org/jgroups/protocols/FC.java:526 log.warn("The fragmentation size of the fragmentation protocol is " + frag_size +
> /src/org/jgroups/protocols/VERIFY_SUSPECT.java:101 if(log.isErrorEnabled()) log.error("suspected member is null");
> /src/org/jgroups/protocols/VERIFY_SUSPECT.java:126 if(log.isErrorEnabled()) log.error("ARE_YOU_DEAD: hdr.from is null");
> /src/org/jgroups/protocols/VERIFY_SUSPECT.java:140 if(log.isErrorEnabled()) log.error("I_AM_NOT_DEAD: hdr.from is null");
> /src/org/jgroups/protocols/VERIFY_SUSPECT.java:243 log.error("failed pinging " + suspected_mbr, ex);
> /src/org/jgroups/protocols/MERGE3.java:132 log.warn("set check_interval=%d as it is <= max_interval", computeCheckInterval());
> /src/org/jgroups/protocols/MERGE3.java:281 log.error("Type %s not known", hdr.type);
> /src/org/jgroups/protocols/MERGE3.java:310 log.error("%s: failed reading View from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/MERGE3.java:367 log.warn("view is null, cannot send INFO message");
> /src/org/jgroups/protocols/FlowControl.java:295 log.warn("No fragmentation protocol was found. When flow control is used, we recommend " +
> /src/org/jgroups/protocols/FlowControl.java:298 log.warn("The fragmentation size of the fragmentation protocol is " + frag_size +
> /src/org/jgroups/protocols/FlowControl.java:412 log.error("header type " + hdr.type + " not known");
> /src/org/jgroups/protocols/TCP.java:81 log.warn("reaper_interval was 0, set it to %d", reaper_interval);
> /src/org/jgroups/protocols/TCP.java:85 log.warn("conn_expire_time was 0, set it to %d", conn_expire_time);
> /src/org/jgroups/protocols/FRAG2.java:247 log.error("%s: fragmentation failure: %s", local_addr, e);
> /src/org/jgroups/protocols/Discovery.java:307 log.warn("cluster_name (%s) or cluster_name of header (%s) is null; passing up discovery " +
> /src/org/jgroups/protocols/Discovery.java:312 log.warn("%s: discarding discovery request for cluster '%s' from %s; " +
> /src/org/jgroups/protocols/Discovery.java:359 log.warn("got PING header with unknown type %d", hdr.type);
> /src/org/jgroups/protocols/Discovery.java:476 log.error("failed reading line of input stream", t);
> /src/org/jgroups/protocols/Discovery.java:553 log.error("error serializing PingData", e);
> /src/org/jgroups/protocols/Discovery.java:571 log.error("%s: failed reading PingData from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/AUTH.java:158 log.warn("found GMS join or merge request but no AUTH header");
> /src/org/jgroups/protocols/AUTH.java:222 log.warn("failed to validate AuthHeader token from " + msg.getSrc() + ", token: " + auth_token);
> /src/org/jgroups/protocols/AUTH.java:242 log.error("type " + type + " unknown");
> /src/org/jgroups/protocols/pbcast/STATE_SOCK.java:236 log.warn(local_addr + ": failed handling request from requester", e);
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:113 log.warn("%s: JOIN(%s) sent to %s timed out (after %d ms), on try %d",
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:118 log.warn("%s: too many JOIN attempts (%d): becoming singleton", gms.local_addr, join_attempts);
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:191 log.warn("%s: digest is empty: digest=%s", gms.local_addr, rsp.getDigest());
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:196 log.error("%s: digest in JOIN_RSP does not contain myself; join response: %s", gms.local_addr, rsp);
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:201 log.error("%s: JoinRsp has a null view, skipping it", gms.local_addr);
> /src/org/jgroups/protocols/pbcast/ClientGmsImpl.java:214 log.error("%s: I'm not member of %s, will not install view", gms.local_addr, new_view);
> /src/org/jgroups/protocols/pbcast/STABLE.java:257 log.error("%s: StableHeader type %s not known", local_addr, hdr.type);
> /src/org/jgroups/protocols/pbcast/STABLE.java:542 if(log.isErrorEnabled()) log.error("digest or sender is null");
> /src/org/jgroups/protocols/pbcast/STABLE.java:603 if(log.isErrorEnabled()) log.error("stability digest is null");
> /src/org/jgroups/protocols/pbcast/STABLE.java:684 log.warn("failed sending STABLE message", t);
> /src/org/jgroups/protocols/pbcast/STABLE.java:698 log.error("%s: failed reading Digest from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/pbcast/STABLE.java:846 log.warn("failed sending STABILITY message", e);
> /src/org/jgroups/protocols/pbcast/STABLE.java:857 log.warn("ResumeTask resumed message garbage collection - this should be done by a RESUME_STABLE event; " +
> /src/org/jgroups/protocols/pbcast/Merger.java:217 log.error("%s: unable to determine merge leader from %s; not starting a merge", gms.local_addr, views);
> /src/org/jgroups/protocols/pbcast/Merger.java:316 log.error("view or digest is null, cannot send consolidated merge view/digest");
> /src/org/jgroups/protocols/pbcast/Merger.java:341 log.warn("%s: failed to collect all ACKs (%d) for merge view %s after %d ms, missing ACKs from %s",
> /src/org/jgroups/protocols/pbcast/Merger.java:526 log.warn(gms.local_addr + ": merge is cancelled", ex);
> /src/org/jgroups/protocols/pbcast/Merger.java:546 log.warn("%s: failed to set my own merge_id (%s) to %s", gms.local_addr, merge_id, new_merge_id);
> /src/org/jgroups/protocols/pbcast/NAKACK.java:325 log.warn("use_mcast_xmit should not be used because the transport (" + transport.getName() +
> /src/org/jgroups/protocols/pbcast/NAKACK.java:330 log.warn("use_mcast_xmit_req should not be used because the transport (" + transport.getName() +
> /src/org/jgroups/protocols/pbcast/NAKACK.java:608 log.error("XMIT_REQ: range of xmit msg is null; discarding request from " + msg.getSrc());
> /src/org/jgroups/protocols/pbcast/NAKACK.java:621 log.error("NakAck header type " + hdr.type + " not known !");
> /src/org/jgroups/protocols/pbcast/NAKACK.java:669 log.warn(local_addr + ": discarded message to " + local_addr + " with no window, my view is " + view);
> /src/org/jgroups/protocols/pbcast/NAKACK.java:708 log.error("sender of message is null");
> /src/org/jgroups/protocols/pbcast/NAKACK.java:747 log.error("failed to deliver OOB message " + msg, t);
> /src/org/jgroups/protocols/pbcast/NAKACK.java:793 log.error("failed to deliver message " + msg_to_deliver, t);
> /src/org/jgroups/protocols/pbcast/NAKACK.java:843 log.error(sb.toString());
> /src/org/jgroups/protocols/pbcast/NAKACK.java:868 log.warn(sb.toString());
> /src/org/jgroups/protocols/pbcast/NAKACK.java:929 log.error("message is null, cannot send retransmission");
> /src/org/jgroups/protocols/pbcast/NAKACK.java:971 log.error("failed reading retransmitted message", ex);
> /src/org/jgroups/protocols/pbcast/NAKACK.java:1271 log.warn("members, local_addr or digest are null !");
> /src/org/jgroups/protocols/pbcast/CoordGmsImpl.java:48 if(log.isErrorEnabled()) log.error("member's address is null !");
> /src/org/jgroups/protocols/pbcast/CoordGmsImpl.java:64 if(log.isWarnEnabled()) log.warn("I am the coord and I'm suspected -- will probably leave shortly");
> /src/org/jgroups/protocols/pbcast/CoordGmsImpl.java:152 log.warn("I am the coord and I'm being suspected -- will probably leave shortly");
> /src/org/jgroups/protocols/pbcast/CoordGmsImpl.java:165 log.warn("%s: did not find a digest matching view %s; dropping JOIN-RSP", gms.local_addr, gms.view);
> /src/org/jgroups/protocols/pbcast/CoordGmsImpl.java:214 log.warn("%s: digest does not match view (missing seqnos for %s); dropping JOIN-RSP",
> /src/org/jgroups/protocols/pbcast/GmsImpl.java:68 log.warn("%s: %s() should not be invoked on an instance of %s", gms.local_addr, method_name, getClass().getName());
> /src/org/jgroups/protocols/pbcast/FLUSH.java:350 log.warn(localAddress + ": unblocking after " + timeout + "ms");
> /src/org/jgroups/protocols/pbcast/FLUSH.java:520 log.warn(localAddress + ": waiting for UNBLOCK timed out after " + end_flush_timeout + " ms");
> /src/org/jgroups/protocols/pbcast/FLUSH.java:963 log.error("%s: failed reading particpants and digest from message: %s", localAddress, ex);
> /src/org/jgroups/protocols/pbcast/GMS.java:428 log.error("exception switching to coordinator role", e);
> /src/org/jgroups/protocols/pbcast/GMS.java:445 log.error("exception switching to participant", e);
> /src/org/jgroups/protocols/pbcast/GMS.java:460 log.error("exception switching to client role", e);
> /src/org/jgroups/protocols/pbcast/GMS.java:495 log.error("view_id is null");
> /src/org/jgroups/protocols/pbcast/GMS.java:543 log.error("membership change policy " + membership_change_policy.getClass().getSimpleName() +
> /src/org/jgroups/protocols/pbcast/GMS.java:551 log.error("default membership change policy failed", t);
> /src/org/jgroups/protocols/pbcast/GMS.java:565 log.error("membership change policy " + membership_change_policy.getClass().getSimpleName() +
> /src/org/jgroups/protocols/pbcast/GMS.java:573 log.error("default membership change policy failed", t);
> /src/org/jgroups/protocols/pbcast/GMS.java:630 log.warn("%s: failed to collect all ACKs (expected=%d) for view %s after %dms, missing %d ACKs from %s",
> /src/org/jgroups/protocols/pbcast/GMS.java:648 log.warn("%s: failed to collect all ACKs (expected=%d) for unicast view %s after %dms, missing %d ACKs from %s",
> /src/org/jgroups/protocols/pbcast/GMS.java:684 log.warn("%s: not member of view %s; discarding it", local_addr, new_view.getViewId());
> /src/org/jgroups/protocols/pbcast/GMS.java:839 log.warn(local_addr + ": GMS flush by coordinator failed");
> /src/org/jgroups/protocols/pbcast/GMS.java:912 log.warn("%s: failed to create view from delta-view; dropping view: %s", local_addr, t.toString());
> /src/org/jgroups/protocols/pbcast/GMS.java:1022 if(log.isErrorEnabled()) log.error("GmsHeader with type=" + hdr.type + " not known");
> /src/org/jgroups/protocols/pbcast/GMS.java:1237 log.error("%s: failed reading JoinRsp from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/pbcast/GMS.java:1249 log.error("%s: failed reading members from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/pbcast/GMS.java:1260 log.error("%s: failed reading view and digest from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/pbcast/GMS.java:1300 log.error("%s: failed reading ViewId from message: %s", local_addr, ex);
> /src/org/jgroups/protocols/pbcast/GMS.java:1705 log.error("request " + firstReq.type + " is unknown; discarded");
> /src/org/jgroups/protocols/pbcast/StreamingStateTransfer.java:156 log.error("%s: cannot fetch state from myself", local_addr);
> /src/org/jgroups/protocols/pbcast/StreamingStateTransfer.java:215 log.error("%s: type %d not known in StateHeader", local_addr, hdr.type);
> /src/org/jgroups/protocols/pbcast/StreamingStateTransfer.java:335 log.error("%s: failed sending EOF to %s", local_addr, requester);
> /src/org/jgroups/protocols/pbcast/StreamingStateTransfer.java:345 log.error("%s: failed sending exception %s to %s", local_addr, exception.toString(), requester);
> /src/org/jgroups/protocols/pbcast/STATE_TRANSFER.java:130 log.error("%s: type %s not known in StateHeader", local_addr, hdr.type);
> /src/org/jgroups/protocols/pbcast/STATE_TRANSFER.java:143 log.error("Protocol stack cannot contain two state transfer protocols. Remove either one of them");
> /src/org/jgroups/protocols/pbcast/STATE_TRANSFER.java:166 log.error("%s: cannot fetch state from myself", local_addr);
> /src/org/jgroups/protocols/pbcast/STATE_TRANSFER.java:261 log.warn("%s: discovered that the state provider (%s) left", local_addr, old_coord);
> /src/org/jgroups/protocols/pbcast/STATE_TRANSFER.java:346 log.error("%s: failed sending exception %s to %s", local_addr, exception, requester);
> /src/org/jgroups/protocols/RATE_LIMITER.java:114 log.error("message length (" + len + " bytes) exceeded max_bytes (" + max_bytes + "); " +
> /src/org/jgroups/protocols/RATE_LIMITER.java:147 log.warn("For optimal performance, max_bytes (" + max_bytes +
> /src/org/jgroups/protocols/FILE_PING.java:239 log.warn("failed reading " + file.getAbsolutePath());
> /src/org/jgroups/protocols/FILE_PING.java:294 log.error("attempt to write data failed at " + clustername + " : " + destination.getName(), ioe);
> /src/org/jgroups/protocols/FILE_PING.java:322 log.error("Failed to delete file: " + file.getAbsolutePath(), e);
> /src/org/jgroups/protocols/UNICAST.java:417 log.error("UnicastHeader type " + hdr.type + " not known !");
> /src/org/jgroups/protocols/UNICAST.java:444 log.error(local_addr + ": failed handling event", t);
> /src/org/jgroups/protocols/UNICAST.java:642 log.error("couldn't deliver OOB message " + msg, t);
> /src/org/jgroups/protocols/UNICAST.java:694 log.error("couldn't deliver OOB message " + msg, t);
> /src/org/jgroups/protocols/UNICAST.java:754 log.error("failed to deliver batch " + batch, t);
> /src/org/jgroups/protocols/UNICAST.java:854 log.warn(local_addr + ": sender window for " + sender + " not found");
> /src/org/jgroups/protocols/UNICAST.java:908 log.error("failed sending ACK(" + seqno + ") to " + dst, t);
> /src/org/jgroups/protocols/TCP_NIO2.java:89 log.warn("%s: failed sending message to %s: %s", local_addr, dest, ex);
> /src/org/jgroups/protocols/TCP_NIO2.java:114 log.warn("reaper_interval was 0, set it to %d", reaper_interval);
> /src/org/jgroups/protocols/TCP_NIO2.java:118 log.warn("conn_expire_time was 0, set it to %d", conn_expire_time);
> /src/org/jgroups/protocols/FORWARD_TO_COORD.java:125 log.warn(local_addr + ": received a message with id=" + msg_id + " from " + sender +
> /src/org/jgroups/protocols/COUNTER.java:190 log.error("received object is neither a Request nor a Response: " + obj);
> /src/org/jgroups/protocols/COUNTER.java:194 log.error("failed handling message", ex);
> /src/org/jgroups/protocols/COUNTER.java:350 log.warn("response for " + ((SimpleResponse)rsp).owner + " didn't have an entry");
> /src/org/jgroups/protocols/COUNTER.java:444 log.error("failed sending " + req + " request: " + ex);
> /src/org/jgroups/protocols/COUNTER.java:462 log.error("failed sending " + rsp + " message to " + dest + ": " + ex);
> /src/org/jgroups/protocols/COUNTER.java:476 log.error("failed sending " + req + " to backup coordinator(s):" + ex);
> /src/org/jgroups/protocols/COUNTER.java:488 log.error("failed sending message to " + dest + ": " + ex);
> /src/org/jgroups/protocols/MPING.java:289 log.error("failed sending packet on socket " + s);
> /src/org/jgroups/protocols/MPING.java:299 log.error("failed sending discovery request", ex);
> /src/org/jgroups/protocols/MPING.java:322 log.error("failed receiving packet (from " + packet.getSocketAddress() + ")", ex);
> /src/org/jgroups/protocols/RELAY.java:196 log.warn("failed relaying message", e);
> /src/org/jgroups/protocols/RELAY.java:247 log.error("failed processing message", t);
> /src/org/jgroups/protocols/RELAY.java:259 log.warn("failed relaying message", e);
> /src/org/jgroups/protocols/RELAY.java:318 log.error("failed installing view", e);
> /src/org/jgroups/protocols/RELAY.java:332 log.error("failed forwarding message over bridge", t);
> /src/org/jgroups/protocols/RELAY.java:358 log.error("failed forwarding unicast message to coord", e);
> /src/org/jgroups/protocols/RELAY.java:376 log.error("failed sending view to remote", e);
> /src/org/jgroups/protocols/RELAY.java:386 log.error("failed sending view to remote", e);
> /src/org/jgroups/protocols/RELAY.java:438 log.error("failed creating bridge channel (props=" + bridge_props + ")", e);
> /src/org/jgroups/protocols/RELAY.java:451 log.warn("[" + local_addr + "] dest=" + dest + " is not local (site=" + this.site + "); discarding it");
> /src/org/jgroups/protocols/RELAY.java:467 log.error("failed sending on local cluster", e);
> /src/org/jgroups/protocols/RELAY.java:497 log.error("failed sending view to local cluster", e);
> /src/org/jgroups/protocols/RELAY.java:571 log.error("failed unmarshalling view from remote cluster", e);
> /src/org/jgroups/protocols/MERGE2.java:365 log.error("FindSubgroupsTask failed", t);
> /src/org/jgroups/protocols/MERGE2.java:420 log.error("failed sending up MERGE event", t);
> /src/org/jgroups/protocols/RSVP.java:168 log.error("message with RSVP flag needs to have an RsvpHeader");
> /src/org/jgroups/protocols/RSVP.java:213 log.error("message with RSVP flag needs to have an RsvpHeader");
> /src/org/jgroups/protocols/RSVP.java:280 log.error("failed sending response", t);
> /src/org/jgroups/protocols/BPING.java:114 log.error("failed sending discovery request", ex);
> /src/org/jgroups/protocols/BPING.java:138 log.error("failed receiving packet (from " + packet.getSocketAddress() + ")", ex);
> /src/org/jgroups/protocols/FORK.java:52 log.warn("%s: fork-stack for id=%s not found; discarding message", local_addr, forkStackId);
> /src/org/jgroups/protocols/FORK.java:58 log.warn("%s: fork-channel for id=%s not found; discarding message", local_addr, forkChannelId);
> /src/org/jgroups/protocols/FORK.java:164 log.error("failed passing up batch", t);
> /src/org/jgroups/protocols/FORK.java:192 log.error("%s: failed fetching state from main channel", local_addr, ex);
> /src/org/jgroups/protocols/FORK.java:230 log.warn("%s: fork stack %s not found, dropping state for %s:%s", local_addr, stack_name, stack_name, ch_name);
> /src/org/jgroups/protocols/FORK.java:236 log.warn("%s: fork channel %s not found, dropping state for %s:%s", local_addr, ch_name, stack_name, ch_name);
> /src/org/jgroups/protocols/FORK.java:247 log.error("%s: failed setting state in main channel", local_addr, ex);
> /src/org/jgroups/protocols/UNICAST2.java:449 log.error("UnicastHeader type " + hdr.type + " not known !");
> /src/org/jgroups/protocols/UNICAST2.java:673 log.error("sending of STABLE messages failed", t);
> /src/org/jgroups/protocols/UNICAST2.java:808 log.error("couldn't deliver OOB message %s: %s", msg, t);
> /src/org/jgroups/protocols/UNICAST2.java:852 log.error("couldn't deliver OOB message %s: %s", msg, t);
> /src/org/jgroups/protocols/UNICAST2.java:934 log.error("failed to deliver batch " + batch, t);
> /src/org/jgroups/protocols/UNICAST2.java:1018 log.warn(sb.toString());
> /src/org/jgroups/protocols/BasicTCP.java:97 log.warn("reaper interval (%d) set, but not conn_expire_time, disabling reaping", reaper_interval);
> /src/org/jgroups/protocols/BasicTCP.java:102 log.warn("conn_expire_time (%d) is set but reaper_interval is 0; setting it to %d", conn_expire_time, reaper_interval);
> /src/org/jgroups/protocols/STOMP.java:230 log.error("failed passing up message", t);
> /src/org/jgroups/protocols/STOMP.java:458 log.error("failure reading frame", t);
> /src/org/jgroups/protocols/STOMP.java:521 log.error("Verb " + frame.getVerb() + " is not handled");
> /src/org/jgroups/protocols/STOMP.java:557 log.error("failed writing response " + response + ": " + ex);
> /src/org/jgroups/protocols/STOMP.java:567 log.error("failed writing response: " + ex);
> /src/org/jgroups/protocols/relay/Relayer.java:205 log.error("failure relaying message", e);
> /src/org/jgroups/protocols/relay/Relayer.java:260 log.warn("received a message without a relay header; discarding it");
> /src/org/jgroups/protocols/relay/RELAY2.java:236 log.warn("max_size_masters was " + max_site_masters + ", changed to 1");
> /src/org/jgroups/protocols/relay/RELAY2.java:248 log.warn(local_addr + ": forwarding routes are currently not supported and will be ignored. This will change " +
> /src/org/jgroups/protocols/relay/RELAY2.java:254 log.warn(local_addr + ": " + FORWARD_TO_COORD.class.getSimpleName() + " protocol not found below; " +
> /src/org/jgroups/protocols/relay/RELAY2.java:495 log.error("type " + hdr.type + " unknown");
> /src/org/jgroups/protocols/relay/RELAY2.java:520 log.warn(local_addr + ": not site master; dropping message");
> /src/org/jgroups/protocols/relay/RELAY2.java:526 log.error(local_addr + ": no route to " + target_site + ": dropping message");
> /src/org/jgroups/protocols/relay/RELAY2.java:548 log.error(local_addr + ": failed relaying message from " + sender + " via route " + route, ex);
> /src/org/jgroups/protocols/relay/RELAY2.java:623 log.error("failed delivering message", e);
> /src/org/jgroups/protocols/relay/RELAY2.java:680 log.error(local_addr + ": failed starting relayer", t);
> /src/org/jgroups/protocols/S3_PING.java:133 log.error("failed reading key %s: %s", key.key, t);
> /src/org/jgroups/protocols/S3_PING.java:139 log.error("failed reading addresses", ex);
> /src/org/jgroups/protocols/S3_PING.java:162 log.error("failed unmarshalling response", e);
> /src/org/jgroups/protocols/S3_PING.java:190 log.error("Failed to write file to S3 bucket - HTTP Response code: (" + httpConn.getResponseCode() + ")");
> /src/org/jgroups/protocols/S3_PING.java:193 log.error("Error marshalling object", e);
> /src/org/jgroups/protocols/S3_PING.java:215 log.error("failure removing data", e);
> /src/org/jgroups/protocols/S3_PING.java:240 log.error("failed deleting object %s/%s: %s", location, key.key, t);
> /src/org/jgroups/protocols/S3_PING.java:246 log.error("failed deleting all objects", ex);
> /src/org/jgroups/util/DefaultTimeScheduler.java:35 log.error("could not set number of timer threads", e);
> /src/org/jgroups/util/DefaultTimeScheduler.java:184 log.error("exception executing task " + command + ": " + t);
> /src/org/jgroups/util/DefaultTimeScheduler.java:221 log.error("failed running task " + task, t);
> /src/org/jgroups/util/HashedTimingWheel.java:291 log.error("failed executing tasks(s)", t);
> /src/org/jgroups/util/HashedTimingWheel.java:311 log.error("failure submitting task to thread pool", t);
> /src/org/jgroups/util/HashedTimingWheel.java:413 log.error("failed executing task " + task, t);
> /src/org/jgroups/util/HashedTimingWheel.java:481 log.error("failed running task " + task, t);
> /src/org/jgroups/util/TimeScheduler3.java:169 log.error("failed submitting task to thread pool", t);
> /src/org/jgroups/util/TimeScheduler3.java:290 log.error("failed executing task " + runnable, t);
> /src/org/jgroups/util/SuppressLog.java:44 log.error(message);
> /src/org/jgroups/util/SuppressLog.java:47 log.warn(message);
> /src/org/jgroups/util/ForwardQueue.java:120 log.error(local_addr + ": sender is null, cannot deliver message " + "::" + id);
> /src/org/jgroups/util/ForwardQueue.java:125 log.warn(local_addr + ": dropped duplicate message " + sender + "::" + id);
> /src/org/jgroups/util/TimeScheduler2.java:247 log.error("failed executing tasks(s)", t);
> /src/org/jgroups/util/TimeScheduler2.java:403 log.error("task execution failed", t);
> /src/org/jgroups/util/TimeScheduler2.java:498 log.error("failed executing task " + task, t);
> /src/org/jgroups/util/TimeScheduler2.java:566 log.error("failed running task " + task, t);
> /src/org/jgroups/util/Util.java:3101 log.warn(sb.toString());
> /src/org/jgroups/jmx/ResourceDMBean.java:96 log.warn("Did not find attribute " + name);
> /src/org/jgroups/jmx/ResourceDMBean.java:109 log.warn("Failed to update attribute name " + attr.getName() + " with value " + attr.getValue());
> /src/org/jgroups/jmx/ResourceDMBean.java:223 log.warn("setter for \"" + attr_name + "\" is already defined (new method=" + method.getName() + ")");
> /src/org/jgroups/jmx/ResourceDMBean.java:231 log.warn("getter for \"" + attr_name + "\" is already defined (new method=" + method.getName() + ")");
> /src/org/jgroups/jmx/JmxConfigurator.java:106 log.warn("MBean unregistration failed: " + e.getCause());
> /src/org/jgroups/jmx/JmxConfigurator.java:165 log.warn("unregistering already registered MBean: " + objName);
> {code}
> Giving blocker priority as this issue blocks RFE verification.
> Also, https://bugzilla.redhat.com/show_bug.cgi?id=999671 is related.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (ELY-373) General peer verification callback
by David Lloyd (JIRA)
[ https://issues.jboss.org/browse/ELY-373?page=com.atlassian.jira.plugin.sy... ]
David Lloyd reassigned ELY-373:
-------------------------------
Assignee: David Lloyd
> General peer verification callback
> ----------------------------------
>
> Key: ELY-373
> URL: https://issues.jboss.org/browse/ELY-373
> Project: WildFly Elytron
> Issue Type: Task
> Components: Callbacks
> Reporter: David Lloyd
> Assignee: David Lloyd
> Fix For: 1.1.0.Beta3
>
>
> We need to generalize peer verification. Right now the peer verification callback ({{org.wildfly.security.auth.callback.VerifyPeerTrustedCallback}}) is specific to X.509 certificate chains, but other mechanisms might use different peer credentials for the verification.
> An ideal API might use an optional Principal and an optional Credential. For Entity, a {{org.wildfly.security.credential.X509CertificateChainPublicCredential}} might be used for the Credential, and the Principal would be extracted from that. For key-based authentication, the principal could be the NamePrincipal of the host name and the credential would be a PublicKeyCredential.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months
[JBoss JIRA] (JGRP-1979) org.jgroups.blocks.Cache.get() method always evicts values because it does not check Value.insertion_time
by Bela Ban (JIRA)
[ https://issues.jboss.org/browse/JGRP-1979?page=com.atlassian.jira.plugin.... ]
Bela Ban commented on JGRP-1979:
--------------------------------
Can you submit a RP for the change and unit tests?
> org.jgroups.blocks.Cache.get() method always evicts values because it does not check Value.insertion_time
> ---------------------------------------------------------------------------------------------------------
>
> Key: JGRP-1979
> URL: https://issues.jboss.org/browse/JGRP-1979
> Project: JGroups
> Issue Type: Bug
> Affects Versions: 3.6.1, 3.6.6
> Environment: Windows 10 64-bit
> Reporter: Ben Johnson
> Assignee: Bela Ban
> Priority: Minor
> Fix For: 3.6.7
>
> Attachments: Cache.java, Cache.java, CacheTest.java, CacheTest.java
>
>
> org.jgroups.blocks.Cache.get(String key) always evicts the matching entry and returns a value of null. It is doing this because the method is comparing the Value timeout property against the current system time without using the Value's insertion_time (unlike the evict() method, which does).
> I have created a simple unit test to illustrate this and provided a fix (from the 3.6.1.Final code base, which doesn't include the diamond operator updates). I added a couple of helper methods isExpired(Value val) and getValue(Value val)
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 8 months