changeset 852:b462b4ff22d8

remove AsyncNCSARequestLog
author Franklin Schmidt <fschmidt@gmail.com>
date Mon, 19 Sep 2016 20:08:16 -0600
parents 08ac7e9e59e6
children 3242aff51053
files src/org/eclipse/jetty/server/AsyncNCSARequestLog.java
diffstat 1 files changed, 0 insertions(+), 130 deletions(-) [+]
line wrap: on
line diff
--- a/src/org/eclipse/jetty/server/AsyncNCSARequestLog.java	Mon Sep 19 19:57:00 2016 -0600
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,130 +0,0 @@
-//
-//  ========================================================================
-//  Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd.
-//  ------------------------------------------------------------------------
-//  All rights reserved. This program and the accompanying materials
-//  are made available under the terms of the Eclipse Public License v1.0
-//  and Apache License v2.0 which accompanies this distribution.
-//
-//      The Eclipse Public License is available at
-//      http://www.eclipse.org/legal/epl-v10.html
-//
-//      The Apache License v2.0 is available at
-//      http://www.opensource.org/licenses/apache2.0.php
-//
-//  You may elect to redistribute this code under either of these licenses.
-//  ========================================================================
-//
-
-package org.eclipse.jetty.server;
-
-import org.eclipse.jetty.util.BlockingArrayQueue;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
-
-
-/* ------------------------------------------------------------ */
-/**
- * An asynchronously writing NCSA Request Log
- */
-public class AsyncNCSARequestLog extends NCSARequestLog
-{
-    private static final Logger LOG = LoggerFactory.getLogger(AsyncNCSARequestLog.class);
-    private final BlockingQueue<String> _queue;
-    private transient WriterThread _thread;
-    private boolean _warnedFull;
-
-    public AsyncNCSARequestLog()
-    {
-        this(null,null);
-    }
-    
-    public AsyncNCSARequestLog(BlockingQueue<String> queue)
-    {
-        this(null,queue);
-    }
-
-    public AsyncNCSARequestLog(String filename)
-    {
-        this(filename,null);
-    }
-    
-    public AsyncNCSARequestLog(String filename,BlockingQueue<String> queue)
-    {
-        super(filename);
-        if (queue==null)
-            queue=new BlockingArrayQueue<String>(1024);
-        _queue=queue;
-    }
-
-    private class WriterThread extends Thread
-    {
-        WriterThread()
-        {
-            setName("AsyncNCSARequestLog@"+Integer.toString(AsyncNCSARequestLog.this.hashCode(),16));
-        }
-        
-        @Override
-        public void run()
-        {
-            while (isRunning())
-            {
-                try
-                {
-                    String log = _queue.poll(10,TimeUnit.SECONDS);
-                    if (log!=null)
-                        AsyncNCSARequestLog.super.write(log);
-                    
-                    while(!_queue.isEmpty())
-                    {
-                        log=_queue.poll();
-                        if (log!=null)
-                            AsyncNCSARequestLog.super.write(log);
-                    }
-                }
-                catch (IOException e)
-                {
-                    LOG.warn("",e);
-                }
-                catch (InterruptedException e)
-                {
-                    LOG.trace("",e);
-                }
-            }
-        }
-    }
-
-    @Override
-    protected synchronized void doStart() throws Exception
-    {
-        super.doStart();
-        _thread = new WriterThread();
-        _thread.start();
-    }
-
-    @Override
-    protected void doStop() throws Exception
-    {
-        _thread.interrupt();
-        _thread.join();
-        super.doStop();
-        _thread=null;
-    }
-
-    @Override
-    protected void write(String log) throws IOException
-    {
-        if (!_queue.offer(log))
-        {
-            if (_warnedFull)
-                LOG.warn("Log Queue overflow");
-            _warnedFull=true;
-        }
-    }
-
-}