hadoop-core-1.1.0/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.1.1/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.0.3/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.0.4/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.2.0/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.2.1/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-0.20.203.0/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.1.2/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - hadoop-core-1.0.0/src/main/java/org/apache/hadoop/security/UserGroupInformation.java [478:530]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - private void spawnAutoRenewalThreadForUserCreds() { if (isSecurityEnabled()) { //spawn thread only if we have kerb credentials if (user.getAuthenticationMethod() == AuthenticationMethod.KERBEROS && !isKeytab) { renewerThread = new Thread(new Runnable() { public void run() { String cmd = conf.get("hadoop.kerberos.kinit.command", "/usr/kerberos/bin/kinit"); KerberosTicket tgt = getTGT(); if (tgt == null) { return; } long nextRefresh = getRefreshTime(tgt); while (shouldRunRenewerThread) { try { long now = System.currentTimeMillis(); LOG.debug("Current time is " + now); LOG.debug("Next refresh is " + nextRefresh); if (now < nextRefresh) { Thread.sleep(nextRefresh - now); } Shell.execCommand(cmd, "-R"); LOG.debug("renewed ticket"); reloginFromTicketCache(); tgt = getTGT(); if (tgt == null) { LOG.warn("No TGT after renewal. Aborting renew thread for " + getUserName()); return; } nextRefresh = Math.max(getRefreshTime(tgt), now + MIN_TIME_BEFORE_RELOGIN); } catch (InterruptedException ie) { LOG.warn("Terminating renewal thread"); return; } catch (IOException ie) { LOG.warn("Exception encountered while running the" + " renewal command." + ie + ". Aborting renew thread for " + user); return; } } LOG.info("TGT renewer thread exiting."); } }); renewerThread.setDaemon(true); renewerThread.setName("TGT Renewer for " + getUserName()); renewerThread.start(); } } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -