java类org.apache.log4j.helpers.LogLog的实例源码

@Override
protected void append(LoggingEvent event) {
    String group = (String) event.getMDC(GROUP_KEY);
    if ("".equals(group))
        group = DEFALUT_GROUP_NAME;
    if (!checkEntryConditions())
        return;
    try {
        CountingQuietWriterEx qw = writers.get(group);
        if (qw == null) {
            qw = addCQWriter(group, getMaxLogBlockIndex(group), true);
        }
        if (qw != null)
            subAppend(qw, event);
    } catch (IOException e) {
        LogLog.error("写日志文件失败：" + group, e);
    }
}

public ZeroConfSupport(String zone, int port, String name, Map properties) {
    //if version 3 is available, use it to constuct a serviceInfo instance, otherwise support the version1 API
    boolean isVersion3 = false;
    try {
        //create method is in version 3, not version 1
        jmDNSClass.getMethod("create", null);
        isVersion3 = true;
    } catch (NoSuchMethodException e) {
        //no-op
    }

    if (isVersion3) {
        LogLog.debug("using JmDNS version 3 to construct serviceInfo instance");
        serviceInfo = buildServiceInfoVersion3(zone, port, name, properties);
    } else {
        LogLog.debug("using JmDNS version 1.0 to construct serviceInfo instance");
        serviceInfo = buildServiceInfoVersion1(zone, port, name, properties);
    }
}

public void configure()
{
    final Logger root = Logger.getRootLogger();

    if (isResetConfiguration())
    {
        LogManager.getLoggerRepository().resetConfiguration();
    }

    LogLog.setInternalDebugging(isInternalDebugging());

    if (isUseFileAppender())
    {
        configureFileAppender();
    }

    if (isUseLogCatAppender())
    {
        configureLogCatAppender();
    }

    root.setLevel(getRootLevel());
}

protected
 void checkAndConfigure() {
   boolean fileExists;
   try {
     fileExists = file.exists();
   } catch(SecurityException  e) {
     LogLog.warn("Was not allowed to read check file existance, file:["+
      filename+"].");
     interrupted = true; // there is no point in continuing
     return;
   }

   if(fileExists) {
     long l = file.lastModified(); // this can also throw a SecurityException
     if(l > lastModif) {           // however, if we reached this point this
lastModif = l;              // is very unlikely.
doOnChange();
warnedAlready = false;
     }
   } else {
     if(!warnedAlready) {
LogLog.debug("["+filename+"] does not exist.");
warnedAlready = true;
     }
   }
 }

/**
   Read configuration options from url <code>configURL</code>.
 */
public
void doConfigure(java.net.URL configURL, LoggerRepository hierarchy) {
  Properties props = new Properties();
  LogLog.debug("Reading configuration from URL " + configURL);
  InputStream istream = null;
  try {
    istream = configURL.openStream();
    props.load(istream);
  }
  catch (Exception e) {
    LogLog.error("Could not read configuration file from URL [" + configURL
   + "].", e);
    LogLog.error("Ignoring configuration file [" + configURL +"].");
    return;
  }
  finally {
      if (istream != null) {
          try {
              istream.close();
          } catch(Exception ignore) {
          }
      }
  }
  doConfigure(props, hierarchy);
}

/**
  * This method performs threshold checks and invokes filters before
  * delegating actual logging to the subclasses specific {@link
  * AppenderSkeleton#append} method.
  * */
public
synchronized 
void doAppend(LoggingEvent event) {
  if(closed) {
    LogLog.error("Attempted to append to closed appender named ["+name+"].");
    return;
  }

  if(!isAsSevereAsThreshold(event.getLevel())) {
    return;
  }

  Filter f = this.headFilter;

  FILTER_LOOP:
  while(f != null) {
    switch(f.decide(event)) {
    case Filter.DENY: return;
    case Filter.ACCEPT: break FILTER_LOOP;
    case Filter.NEUTRAL: f = f.getNext();
    }
  }

  this.append(event);    
}

void printPeriodicity(int type) {
    switch (type) {
        case TOP_OF_MINUTE:
            LogLog.debug("Appender [[+name+]] to be rolled every minute.");
            break;
        case TOP_OF_HOUR:
            LogLog.debug("Appender [" + name + "] to be rolled on top of every hour.");
            break;
        case HALF_DAY:
            LogLog.debug("Appender [" + name + "] to be rolled at midday and midnight.");
            break;
        case TOP_OF_DAY:
            LogLog.debug("Appender [" + name + "] to be rolled at midnight.");
            break;
        case TOP_OF_WEEK:
            LogLog.debug("Appender [" + name + "] to be rolled at start of week.");
            break;
        case TOP_OF_MONTH:
            LogLog.debug("Appender [" + name + "] to be rolled at start of every month.");
            break;
        default:
            LogLog.warn("Unknown periodicity for appender [[+name+]].");
    }
}

public void run() {
   try {
     String line = dis.readUTF();
     LogLog.debug("Got external roll over signal.");
     if(ExternallyRolledFileAppender.ROLL_OVER.equals(line)) {
synchronized(er) {
  er.rollOver();
}
dos.writeUTF(ExternallyRolledFileAppender.OK);
     }
     else {
dos.writeUTF("Expecting [RollOver] string.");
     }
     dos.close();
   }
   catch(Exception e) {
     LogLog.error("Unexpected exception. Exiting HUPNode.", e);
   }
 }

/**
   Prints the message and the stack trace of the exception on
   <code>System.err</code>.
 */
public
void error(String message, Exception e, int errorCode, LoggingEvent event) {
  if (e instanceof InterruptedIOException) {
      Thread.currentThread().interrupt();
  }
  LogLog.debug("FB: The following error reported: " + message, e);
  LogLog.debug("FB: INITIATING FALLBACK PROCEDURE.");
  if (loggers != null) {
    for(int i = 0; i < loggers.size(); i++) {
            Logger l = (Logger) loggers.elementAt(i);
            LogLog.debug("FB: Searching for ["+primary.getName()+"] in logger ["
        +l.getName() + "].");
            LogLog.debug("FB: Replacing ["+primary.getName()+"] by ["
        + backup.getName() + "] in logger ["+ l.getName() +"].");
            l.removeAppender(primary);
            LogLog.debug("FB: Adding appender ["+backup.getName()+"] to logger "
        +  l.getName());
            l.addAppender(backup);
      }
  }    
}

/**
   Activate the specified options, such as the smtp host, the
   recipient, from, etc. */
public
void activateOptions() {
  Session session = createSession();
  msg = new MimeMessage(session);

   try {
      addressMessage(msg);
      if(subject != null) {
         try {
              msg.setSubject(MimeUtility.encodeText(subject, "UTF-8", null));
         } catch(UnsupportedEncodingException ex) {
              LogLog.error("Unable to encode SMTP subject", ex);
         }
      }
   } catch(MessagingException e) {
     LogLog.error("Could not activate SMTPAppender options.", e );
   }

   if (evaluator instanceof OptionHandler) {
       ((OptionHandler) evaluator).activateOptions();
   }
}