svn commit: r1799085 - in /tomcat/tc8.5.x/trunk/java/org/apache/juli: AsyncFileHandler.java FileHandler.java

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

svn commit: r1799085 - in /tomcat/tc8.5.x/trunk/java/org/apache/juli: AsyncFileHandler.java FileHandler.java

violetagg
Author: violetagg
Date: Sun Jun 18 13:39:42 2017
New Revision: 1799085

URL: http://svn.apache.org/viewvc?rev=1799085&view=rev
Log:
Format the code. No functional changes.

Modified:
    tomcat/tc8.5.x/trunk/java/org/apache/juli/AsyncFileHandler.java
    tomcat/tc8.5.x/trunk/java/org/apache/juli/FileHandler.java

Modified: tomcat/tc8.5.x/trunk/java/org/apache/juli/AsyncFileHandler.java
URL: http://svn.apache.org/viewvc/tomcat/tc8.5.x/trunk/java/org/apache/juli/AsyncFileHandler.java?rev=1799085&r1=1799084&r2=1799085&view=diff
==============================================================================
--- tomcat/tc8.5.x/trunk/java/org/apache/juli/AsyncFileHandler.java (original)
+++ tomcat/tc8.5.x/trunk/java/org/apache/juli/AsyncFileHandler.java Sun Jun 18 13:39:42 2017
@@ -71,7 +71,7 @@ public class AsyncFileHandler extends Fi
     protected volatile boolean closed = false;
 
     public AsyncFileHandler() {
-        this(null,null,null);
+        this(null, null, null);
     }
 
     public AsyncFileHandler(String directory, String prefix, String suffix) {
@@ -81,14 +81,18 @@ public class AsyncFileHandler extends Fi
 
     @Override
     public void close() {
-        if (closed) return;
+        if (closed) {
+            return;
+        }
         closed = true;
         super.close();
     }
 
     @Override
     protected void open() {
-        if(!closed) return;
+        if (!closed) {
+            return;
+        }
         closed = false;
         super.open();
     }
@@ -102,7 +106,7 @@ public class AsyncFileHandler extends Fi
         // fill source entries, before we hand the record over to another
         // thread with another class loader
         record.getSourceMethodName();
-        LogEntry entry = new LogEntry(record,this);
+        LogEntry entry = new LogEntry(record, this);
         boolean added = false;
         try {
             while (!added && !queue.offer(entry)) {
@@ -118,7 +122,7 @@ public class AsyncFileHandler extends Fi
                         break;
                     }
                     case OVERFLOW_DROP_FLUSH: {
-                        added = queue.offer(entry,1000,TimeUnit.MILLISECONDS);
+                        added = queue.offer(entry, 1000, TimeUnit.MILLISECONDS);
                         break;
                     }
                     case OVERFLOW_DROP_CURRENT: {
@@ -127,7 +131,7 @@ public class AsyncFileHandler extends Fi
                     }
                 }//switch
             }//while
-        }catch (InterruptedException x) {
+        } catch (InterruptedException x) {
             // Allow thread to be interrupted and back out of the publish
             // operation. No further action required.
         }
@@ -142,7 +146,7 @@ public class AsyncFileHandler extends Fi
         protected final boolean run = true;
         public LoggerThread() {
             this.setDaemon(true);
-            this.setName("AsyncFileHandlerWriter-"+System.identityHashCode(this));
+            this.setName("AsyncFileHandlerWriter-" + System.identityHashCode(this));
         }
 
         @Override
@@ -150,7 +154,9 @@ public class AsyncFileHandler extends Fi
             while (run) {
                 try {
                     LogEntry entry = queue.poll(LOGGER_SLEEP_TIME, TimeUnit.MILLISECONDS);
-                    if (entry!=null) entry.flush();
+                    if (entry != null) {
+                        entry.flush();
+                    }
                 } catch (InterruptedException x) {
                     // Ignore the attempt to interrupt the thread.
                 } catch (Exception x) {

Modified: tomcat/tc8.5.x/trunk/java/org/apache/juli/FileHandler.java
URL: http://svn.apache.org/viewvc/tomcat/tc8.5.x/trunk/java/org/apache/juli/FileHandler.java?rev=1799085&r1=1799084&r2=1799085&view=diff
==============================================================================
--- tomcat/tc8.5.x/trunk/java/org/apache/juli/FileHandler.java (original)
+++ tomcat/tc8.5.x/trunk/java/org/apache/juli/FileHandler.java Sun Jun 18 13:39:42 2017
@@ -76,8 +76,7 @@ import java.util.logging.LogRecord;
  *    <code>java.util.logging.SimpleFormatter</code></li>
  * </ul>
  */
-public class FileHandler
-    extends Handler {
+public class FileHandler extends Handler {
 
 
     // ------------------------------------------------------------ Constructor
@@ -199,13 +198,14 @@ public class FileHandler
             }
 
             try {
-                if (writer!=null) {
+                if (writer != null) {
                     writer.write(result);
                     if (bufferSize < 0) {
                         writer.flush();
                     }
                 } else {
-                    reportError("FileHandler is closed or not yet initialized, unable to log ["+result+"]", null, ErrorManager.WRITE_FAILURE);
+                    reportError("FileHandler is closed or not yet initialized, unable to log ["
+                            + result + "]", null, ErrorManager.WRITE_FAILURE);
                 }
             } catch (Exception e) {
                 reportError(null, e, ErrorManager.WRITE_FAILURE);
@@ -232,8 +232,9 @@ public class FileHandler
 
         writerLock.writeLock().lock();
         try {
-            if (writer == null)
+            if (writer == null) {
                 return;
+            }
             writer.write(getFormatter().getTail(this));
             writer.flush();
             writer.close();
@@ -255,8 +256,9 @@ public class FileHandler
 
         writerLock.readLock().lock();
         try {
-            if (writer == null)
+            if (writer == null) {
                 return;
+            }
             writer.flush();
         } catch (Exception e) {
             reportError(null, e, ErrorManager.FLUSH_FAILURE);
@@ -282,12 +284,15 @@ public class FileHandler
 
         // Retrieve configuration of logging file name
         rotatable = Boolean.parseBoolean(getProperty(className + ".rotatable", "true"));
-        if (directory == null)
+        if (directory == null) {
             directory = getProperty(className + ".directory", "logs");
-        if (prefix == null)
+        }
+        if (prefix == null) {
             prefix = getProperty(className + ".prefix", "juli.");
-        if (suffix == null)
+        }
+        if (suffix == null) {
             suffix = getProperty(className + ".suffix", ".log");
+        }
         String sBufferSize = getProperty(className + ".bufferSize", String.valueOf(bufferSize));
         try {
             bufferSize = Integer.parseInt(sBufferSize);
@@ -359,8 +364,7 @@ public class FileHandler
         // Create the directory if necessary
         File dir = new File(directory);
         if (!dir.mkdirs() && !dir.isDirectory()) {
-            reportError("Unable to create [" + dir + "]", null,
-                    ErrorManager.OPEN_FAILURE);
+            reportError("Unable to create [" + dir + "]", null, ErrorManager.OPEN_FAILURE);
             writer = null;
             return;
         }
@@ -374,14 +378,13 @@ public class FileHandler
                     + (rotatable ? date : "") + suffix);
             File parent = pathname.getParentFile();
             if (!parent.mkdirs() && !parent.isDirectory()) {
-                reportError("Unable to create [" + parent + "]", null,
-                        ErrorManager.OPEN_FAILURE);
+                reportError("Unable to create [" + parent + "]", null, ErrorManager.OPEN_FAILURE);
                 writer = null;
                 return;
             }
             String encoding = getEncoding();
             fos = new FileOutputStream(pathname, true);
-            os = bufferSize>0?new BufferedOutputStream(fos,bufferSize):fos;
+            os = bufferSize > 0 ? new BufferedOutputStream(fos, bufferSize) : fos;
             writer = new PrintWriter(
                     (encoding != null) ? new OutputStreamWriter(os, encoding)
                                        : new OutputStreamWriter(os), false);



---------------------------------------------------------------------
To unsubscribe, e-mail: [hidden email]
For additional commands, e-mail: [hidden email]

Loading...