|
@@ -1601,8 +1601,9 @@ public class ZooKeeperServer implements SessionExpirer, ServerStats.Provider {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if (authReturn == KeeperException.Code.OK) {
|
|
if (authReturn == KeeperException.Code.OK) {
|
|
- LOG.debug("Authentication succeeded for scheme: {}", scheme);
|
|
|
|
- LOG.info("auth success {}", cnxn.getRemoteSocketAddress());
|
|
|
|
|
|
+ LOG.info("Session 0x{}: auth success for scheme {} and address {}",
|
|
|
|
+ Long.toHexString(cnxn.getSessionId()), scheme,
|
|
|
|
+ cnxn.getRemoteSocketAddress());
|
|
ReplyHeader rh = new ReplyHeader(h.getXid(), 0, KeeperException.Code.OK.intValue());
|
|
ReplyHeader rh = new ReplyHeader(h.getXid(), 0, KeeperException.Code.OK.intValue());
|
|
cnxn.sendResponse(rh, null, null);
|
|
cnxn.sendResponse(rh, null, null);
|
|
} else {
|
|
} else {
|
|
@@ -1663,7 +1664,8 @@ public class ZooKeeperServer implements SessionExpirer, ServerStats.Provider {
|
|
responseToken = saslServer.evaluateResponse(clientToken);
|
|
responseToken = saslServer.evaluateResponse(clientToken);
|
|
if (saslServer.isComplete()) {
|
|
if (saslServer.isComplete()) {
|
|
String authorizationID = saslServer.getAuthorizationID();
|
|
String authorizationID = saslServer.getAuthorizationID();
|
|
- LOG.info("adding SASL authorization for authorizationID: {}", authorizationID);
|
|
|
|
|
|
+ LOG.info("Session 0x{}: adding SASL authorization for authorizationID: {}",
|
|
|
|
+ Long.toHexString(cnxn.getSessionId()), authorizationID);
|
|
cnxn.addAuthInfo(new Id("sasl", authorizationID));
|
|
cnxn.addAuthInfo(new Id("sasl", authorizationID));
|
|
if (System.getProperty("zookeeper.superUser") != null
|
|
if (System.getProperty("zookeeper.superUser") != null
|
|
&& authorizationID.equals(System.getProperty("zookeeper.superUser"))) {
|
|
&& authorizationID.equals(System.getProperty("zookeeper.superUser"))) {
|