2 // ========================================================================
3 // Copyright (c) 1995-2016 Mort Bay Consulting Pty. Ltd.
4 // ------------------------------------------------------------------------
5 // All rights reserved. This program and the accompanying materials
6 // are made available under the terms of the Eclipse Public License v1.0
7 // and Apache License v2.0 which accompanies this distribution.
9 // The Eclipse Public License is available at
10 // http://www.eclipse.org/legal/epl-v10.html
12 // The Apache License v2.0 is available at
13 // http://www.opensource.org/licenses/apache2.0.php
15 // You may elect to redistribute this code under either of these licenses.
16 // ========================================================================
19 package org.eclipse.jetty.io;
21 import java.nio.ByteBuffer;
22 import java.util.concurrent.atomic.AtomicLong;
24 import org.eclipse.jetty.util.BufferUtil;
25 import org.eclipse.jetty.util.LeakDetector;
26 import org.eclipse.jetty.util.component.ContainerLifeCycle;
27 import org.eclipse.jetty.util.log.Log;
28 import org.eclipse.jetty.util.log.Logger;
30 public class LeakTrackingByteBufferPool extends ContainerLifeCycle implements ByteBufferPool
32 private static final Logger LOG = Log.getLogger(LeakTrackingByteBufferPool.class);
34 private final LeakDetector<ByteBuffer> leakDetector = new LeakDetector<ByteBuffer>()
36 public String id(ByteBuffer resource)
38 return BufferUtil.toIDString(resource);
42 protected void leaked(LeakInfo leakInfo)
44 leaked.incrementAndGet();
45 LeakTrackingByteBufferPool.this.leaked(leakInfo);
49 private final static boolean NOISY = Boolean.getBoolean(LeakTrackingByteBufferPool.class.getName() + ".NOISY");
50 private final ByteBufferPool delegate;
51 private final AtomicLong leakedReleases = new AtomicLong(0);
52 private final AtomicLong leakedAcquires = new AtomicLong(0);
53 private final AtomicLong leaked = new AtomicLong(0);
55 public LeakTrackingByteBufferPool(ByteBufferPool delegate)
57 this.delegate = delegate;
58 addBean(leakDetector);
63 public ByteBuffer acquire(int size, boolean direct)
65 ByteBuffer buffer = delegate.acquire(size, direct);
66 boolean leaked = leakDetector.acquired(buffer);
69 leakedAcquires.incrementAndGet();
70 LOG.info(String.format("ByteBuffer acquire %s leaked.acquired=%s", leakDetector.id(buffer), leaked ? "normal" : "LEAK"),
71 new Throwable("LeakStack.Acquire"));
77 public void release(ByteBuffer buffer)
81 boolean leaked = leakDetector.released(buffer);
84 leakedReleases.incrementAndGet();
85 LOG.info(String.format("ByteBuffer release %s leaked.released=%s", leakDetector.id(buffer), leaked ? "normal" : "LEAK"), new Throwable(
86 "LeakStack.Release"));
88 delegate.release(buffer);
91 public void clearTracking()
93 leakedAcquires.set(0);
94 leakedReleases.set(0);
98 * @return count of BufferPool.acquire() calls that detected a leak
100 public long getLeakedAcquires()
102 return leakedAcquires.get();
106 * @return count of BufferPool.release() calls that detected a leak
108 public long getLeakedReleases()
110 return leakedReleases.get();
114 * @return count of resources that were acquired but not released
116 public long getLeakedResources()
121 protected void leaked(LeakDetector<ByteBuffer>.LeakInfo leakInfo)
123 LOG.warn("ByteBuffer " + leakInfo.getResourceDescription() + " leaked at:", leakInfo.getStackFrames());