Skip to content

Instantly share code, notes, and snippets.

@jamel

jamel/01. NettyStreamLeakTest.java

Last active March 3, 2017 17:48
Show Gist options
  • Save jamel/957aab95a8385ef43768f378fb405d25 to your computer and use it in GitHub Desktop.
Save jamel/957aab95a8385ef43768f378fb405d25 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
01. NettyStreamLeakTest.java
package com.mongodb.async.client;
import java.util.concurrent.CompletableFuture;
import com.mongodb.async.SingleResultCallback;
import com.mongodb.client.model.Filters;
import com.mongodb.connection.netty.NettyStreamFactoryFactory;
import com.mongodb.event.CommandFailedEvent;
import com.mongodb.event.CommandListener;
import com.mongodb.event.CommandStartedEvent;
import com.mongodb.event.CommandSucceededEvent;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.util.ResourceLeakDetector;
import org.bson.Document;
import org.bson.conversions.Bson;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @author Sergey Polovko
*/
public class NettyStreamLeakTest extends DatabaseTestCase {
private static final Logger logger = LoggerFactory.getLogger(NettyStreamLeakTest.class);
@Override
public void setUp() {
// System.setProperty("io.netty.leakDetection.maxRecords", "200");
ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.PARANOID);
NettyStreamFactoryFactory streamFactoryFactory = NettyStreamFactoryFactory.builder()
.eventLoopGroup(new NioEventLoopGroup())
.socketChannelClass(NioSocketChannel.class)
.build();
MongoClientSettings.Builder builder = Fixture.getMongoClientBuilderFromConnectionString()
// .addCommandListener(new NopCommandListener()) // <--- uncomment to see deference
.streamFactoryFactory(streamFactoryFactory);
client = MongoClients.create(builder.build());
database = client.getDatabase(Fixture.getDefaultDatabaseName());
collection = database.getCollection(getClass().getName());
Fixture.drop(collection.getNamespace());
}
@Test
public void run() throws Exception {
for (int i = 1; i <= 1000; i++) {
CompletableFuture<Document> f = findOne(Filters.eq("key", 0));
f.join(); // wait completion and throw exception if any
if (i % 100 == 0) {
logger.info("query #{} complete", i);
}
}
}
private CompletableFuture<Document> findOne(Bson filter) {
final CompletableFuture<Document> f = new CompletableFuture<Document>();
collection.find(filter).first(new SingleResultCallback<Document>() {
@Override
public void onResult(Document result, Throwable t) {
if (t != null) {
f.completeExceptionally(t);
} else {
f.complete(result);
}
}
});
return f;
}
/**
* simple no operation command listener
*/
private static final class NopCommandListener implements CommandListener {
@Override
public void commandStarted(CommandStartedEvent event) { }
@Override
public void commandSucceeded(CommandSucceededEvent event) { }
@Override
public void commandFailed(CommandFailedEvent event) { }
}
}
Raw
02. normal_run.log
20:41:54,332 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.groovy]
20:41:54,332 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback-test.xml] at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-async/build/resources/test/logback-test.xml]
20:41:54,334 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs multiple times on the classpath.
20:41:54,334 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-async/build/resources/test/logback-test.xml]
20:41:54,334 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-core/build/resources/test/logback-test.xml]
20:41:54,527 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug attribute not set
20:41:54,540 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
20:41:54,564 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [STDOUT]
20:41:54,619 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
20:41:54,743 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - Setting level of ROOT logger to INFO
20:41:54,743 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [STDOUT] to Logger[ROOT]
20:41:54,743 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - End of configuration.
20:41:54,745 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@548b7f67 - Registering current configuration as safe fallback point
20:41:55.436 [main] INFO org.mongodb.driver.cluster - Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
20:41:55.866 [main] INFO org.mongodb.driver.cluster - Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
20:41:55.919 [main] INFO org.mongodb.driver.cluster - No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
20:41:56.105 [cluster-ClusterId{value='58b9aae3f648714e50957532', description='null'}-localhost:27017] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:2, serverValue:199}] to localhost:27017
20:41:56.108 [cluster-ClusterId{value='58b9aae3f648714e50957532', description='null'}-localhost:27017] INFO org.mongodb.driver.cluster - Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 10]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=1170146}
20:41:56.194 [Thread-3] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:3, serverValue:201}] to localhost:27017
20:41:56.321 [main] INFO org.mongodb.driver.cluster - No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
20:41:56.530 [cluster-ClusterId{value='58b9aae3f648714e50957531', description='null'}-localhost:27017] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:1, serverValue:200}] to localhost:27017
20:41:56.631 [cluster-ClusterId{value='58b9aae3f648714e50957531', description='null'}-localhost:27017] INFO org.mongodb.driver.cluster - Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 10]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=99638716}
20:41:56.930 [nioEventLoopGroup-2-2] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:4, serverValue:202}] to localhost:27017
20:42:03.062 [main] INFO c.m.async.client.NettyStreamLeakTest - query #100 complete
20:42:09.429 [main] INFO c.m.async.client.NettyStreamLeakTest - query #200 complete
20:42:14.961 [main] INFO c.m.async.client.NettyStreamLeakTest - query #300 complete
20:42:20.884 [main] INFO c.m.async.client.NettyStreamLeakTest - query #400 complete
20:42:26.679 [main] INFO c.m.async.client.NettyStreamLeakTest - query #500 complete
20:42:32.328 [main] INFO c.m.async.client.NettyStreamLeakTest - query #600 complete
20:42:37.700 [main] INFO c.m.async.client.NettyStreamLeakTest - query #700 complete
20:42:43.963 [main] INFO c.m.async.client.NettyStreamLeakTest - query #800 complete
20:42:49.973 [main] INFO c.m.async.client.NettyStreamLeakTest - query #900 complete
20:42:55.393 [main] INFO c.m.async.client.NettyStreamLeakTest - query #1000 complete
20:42:55.400 [Thread-1] INFO org.mongodb.driver.connection - Closed connection [connectionId{localValue:3, serverValue:201}] to localhost:27017 because the pool has been closed.
Process finished with exit code 0
Raw
03. buggy_run.log
20:43:28,621 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could NOT find resource [logback.groovy]
20:43:28,622 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [logback-test.xml] at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-async/build/resources/test/logback-test.xml]
20:43:28,628 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs multiple times on the classpath.
20:43:28,628 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-async/build/resources/test/logback-test.xml]
20:43:28,628 |-WARN in ch.qos.logback.classic.LoggerContext[default] - Resource [logback-test.xml] occurs at [file:/Users/jamel/projects/_oss/mongo-java-driver/driver-core/build/resources/test/logback-test.xml]
20:43:28,964 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - debug attribute not set
20:43:28,975 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
20:43:28,995 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming appender as [STDOUT]
20:43:29,034 |-INFO in ch.qos.logback.core.joran.action.NestedComplexPropertyIA - Assuming default type [ch.qos.logback.classic.encoder.PatternLayoutEncoder] for [encoder] property
20:43:29,228 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - Setting level of ROOT logger to INFO
20:43:29,228 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - Attaching appender named [STDOUT] to Logger[ROOT]
20:43:29,231 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - End of configuration.
20:43:29,233 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@548b7f67 - Registering current configuration as safe fallback point
20:43:29.960 [main] INFO org.mongodb.driver.cluster - Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
20:43:30.351 [main] INFO org.mongodb.driver.cluster - Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}
20:43:30.418 [main] INFO org.mongodb.driver.cluster - No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
20:43:30.533 [cluster-ClusterId{value='58b9ab42f648714e5562709a', description='null'}-localhost:27017] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:2, serverValue:203}] to localhost:27017
20:43:30.539 [cluster-ClusterId{value='58b9ab42f648714e5562709a', description='null'}-localhost:27017] INFO org.mongodb.driver.cluster - Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 10]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=1961621}
20:43:30.588 [Thread-3] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:3, serverValue:205}] to localhost:27017
20:43:30.777 [main] INFO org.mongodb.driver.cluster - No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out
20:43:30.920 [cluster-ClusterId{value='58b9ab41f648714e55627099', description='null'}-localhost:27017] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:1, serverValue:204}] to localhost:27017
20:43:30.979 [cluster-ClusterId{value='58b9ab41f648714e55627099', description='null'}-localhost:27017] INFO org.mongodb.driver.cluster - Monitor thread successfully connected to server with description ServerDescription{address=localhost:27017, type=STANDALONE, state=CONNECTED, ok=true, version=ServerVersion{versionList=[3, 2, 10]}, minWireVersion=0, maxWireVersion=4, maxDocumentSize=16777216, roundTripTimeNanos=57764319}
20:43:31.355 [nioEventLoopGroup-2-2] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:4, serverValue:206}] to localhost:27017
20:43:31.503 [main] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See http://netty.io/wiki/reference-counted-objects.html for more information.
WARNING: 117 leak records were discarded because the leak record count is limited to 4. Use system property io.netty.leakDetection.maxRecords to increase the limit.
Recent access records: 5
#5:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
com.mongodb.connection.netty.NettyByteBuf.release(NettyByteBuf.java:238)
com.mongodb.connection.ByteBufferBsonOutput.close(ByteBufferBsonOutput.java:180)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:58)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:25)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:454)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:448)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:107)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:103)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:312)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:297)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:188)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:182)
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:514)
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:488)
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:427)
io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:170)
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:93)
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:28)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:182)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#4:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1675)
io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1940)
io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:116)
io.netty.buffer.WrappedCompositeByteBuf.release(WrappedCompositeByteBuf.java:43)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.release(AdvancedLeakAwareCompositeByteBuf.java:1041)
io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:84)
io.netty.util.ReferenceCountUtil.safeRelease(ReferenceCountUtil.java:109)
io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:261)
io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:342)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:443)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:812)
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:824)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:804)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:841)
io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1032)
io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:296)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:182)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#3:
io.netty.buffer.AdvancedLeakAwareByteBuf.internalNioBuffer(AdvancedLeakAwareByteBuf.java:735)
io.netty.buffer.CompositeByteBuf.internalNioBuffer(CompositeByteBuf.java:1449)
io.netty.buffer.WrappedCompositeByteBuf.internalNioBuffer(WrappedCompositeByteBuf.java:853)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.internalNioBuffer(AdvancedLeakAwareCompositeByteBuf.java:730)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:416)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:812)
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:824)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:804)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:841)
io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1032)
io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:296)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:182)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#2:
io.netty.buffer.AdvancedLeakAwareByteBuf.nioBufferCount(AdvancedLeakAwareByteBuf.java:705)
io.netty.buffer.CompositeByteBuf.nioBufferCount(CompositeByteBuf.java:1431)
io.netty.buffer.WrappedCompositeByteBuf.nioBufferCount(WrappedCompositeByteBuf.java:848)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.nioBufferCount(AdvancedLeakAwareCompositeByteBuf.java:700)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:404)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeWriteAndFlush(AbstractChannelHandlerContext.java:812)
io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:824)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:804)
io.netty.channel.AbstractChannelHandlerContext.writeAndFlush(AbstractChannelHandlerContext.java:841)
io.netty.channel.DefaultChannelPipeline.writeAndFlush(DefaultChannelPipeline.java:1032)
io.netty.channel.AbstractChannel.writeAndFlush(AbstractChannel.java:296)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:182)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#1:
io.netty.buffer.AdvancedLeakAwareByteBuf.slice(AdvancedLeakAwareByteBuf.java:75)
io.netty.buffer.CompositeByteBuf.addComponent0(CompositeByteBuf.java:259)
io.netty.buffer.CompositeByteBuf.addComponent(CompositeByteBuf.java:195)
io.netty.buffer.WrappedCompositeByteBuf.addComponent(WrappedCompositeByteBuf.java:524)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.addComponent(AdvancedLeakAwareCompositeByteBuf.java:928)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:179)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
Created at:
io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:271)
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179)
io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:115)
com.mongodb.connection.netty.NettyStream.getBuffer(NettyStream.java:92)
com.mongodb.connection.InternalStreamConnection.getBuffer(InternalStreamConnection.java:514)
com.mongodb.connection.UsageTrackingInternalConnection.getBuffer(UsageTrackingInternalConnection.java:85)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.getBuffer(DefaultConnectionPool.java:420)
com.mongodb.connection.ByteBufferBsonOutput.getByteBufferAtIndex(ByteBufferBsonOutput.java:91)
com.mongodb.connection.ByteBufferBsonOutput.getCurrentByteBuffer(ByteBufferBsonOutput.java:80)
com.mongodb.connection.ByteBufferBsonOutput.writeByte(ByteBufferBsonOutput.java:75)
org.bson.io.OutputBuffer.write(OutputBuffer.java:150)
org.bson.io.OutputBuffer.writeInt32(OutputBuffer.java:56)
com.mongodb.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:158)
com.mongodb.connection.RequestMessage.encodeWithMetadata(RequestMessage.java:146)
com.mongodb.connection.ProtocolHelper.encodeMessageWithMetadata(ProtocolHelper.java:156)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:151)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:207)
com.mongodb.connection.DefaultConnectionPool$2.onResult(DefaultConnectionPool.java:192)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:62)
com.mongodb.connection.UsageTrackingInternalConnection$1.onResult(UsageTrackingInternalConnection.java:54)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:156)
com.mongodb.connection.InternalStreamConnection$1$1.onResult(InternalStreamConnection.java:143)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:156)
com.mongodb.connection.InternalStreamConnectionInitializer$3.onResult(InternalStreamConnectionInitializer.java:150)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:53)
com.mongodb.connection.CommandHelper$1$1.onResult(CommandHelper.java:43)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:155)
com.mongodb.connection.CommandHelper$3.onResult(CommandHelper.java:148)
com.mongodb.connection.InternalStreamConnection.executeCallbackAndReceiveResponse(InternalStreamConnection.java:378)
com.mongodb.connection.InternalStreamConnection.access$1700(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:420)
com.mongodb.connection.InternalStreamConnection$ResponseBuffersCallback.onResult(InternalStreamConnection.java:389)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onSuccess(InternalStreamConnection.java:562)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.access$2200(InternalStreamConnection.java:517)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:584)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback$ResponseBodyCallback.onResult(InternalStreamConnection.java:568)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:444)
com.mongodb.connection.InternalStreamConnection.access$2000(InternalStreamConnection.java:66)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:541)
com.mongodb.connection.InternalStreamConnection$ResponseHeaderCallback.onResult(InternalStreamConnection.java:517)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:447)
com.mongodb.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:444)
com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:233)
com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:263)
com.mongodb.connection.netty.NettyStream.access$500(NettyStream.java:64)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:314)
com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:311)
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:350)
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:372)
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:358)
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129)
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:610)
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:551)
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:465)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:437)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
20:43:31.810 [main] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See http://netty.io/wiki/reference-counted-objects.html for more information.
WARNING: 117 leak records were discarded because the leak record count is limited to 4. Use system property io.netty.leakDetection.maxRecords to increase the limit.
Recent access records: 5
#5:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
com.mongodb.connection.netty.NettyByteBuf.release(NettyByteBuf.java:238)
com.mongodb.connection.ByteBufferBsonOutput.close(ByteBufferBsonOutput.java:180)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:58)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:25)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:454)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:448)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:107)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:103)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:312)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:297)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:188)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:182)
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:514)
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:488)
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:427)
io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:111)
io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:82)
io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:672)
io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:262)
io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:342)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:443)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#4:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1675)
io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1940)
io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:116)
io.netty.buffer.WrappedCompositeByteBuf.release(WrappedCompositeByteBuf.java:43)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.release(AdvancedLeakAwareCompositeByteBuf.java:1041)
io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:84)
io.netty.util.ReferenceCountUtil.safeRelease(ReferenceCountUtil.java:109)
io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:261)
io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:342)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:443)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#3:
io.netty.buffer.AdvancedLeakAwareByteBuf.internalNioBuffer(AdvancedLeakAwareByteBuf.java:735)
io.netty.buffer.CompositeByteBuf.internalNioBuffer(CompositeByteBuf.java:1449)
io.netty.buffer.WrappedCompositeByteBuf.internalNioBuffer(WrappedCompositeByteBuf.java:853)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.internalNioBuffer(AdvancedLeakAwareCompositeByteBuf.java:730)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:416)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#2:
io.netty.buffer.AdvancedLeakAwareByteBuf.nioBufferCount(AdvancedLeakAwareByteBuf.java:705)
io.netty.buffer.CompositeByteBuf.nioBufferCount(CompositeByteBuf.java:1431)
io.netty.buffer.WrappedCompositeByteBuf.nioBufferCount(WrappedCompositeByteBuf.java:848)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.nioBufferCount(AdvancedLeakAwareCompositeByteBuf.java:700)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:404)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#1:
io.netty.buffer.AdvancedLeakAwareByteBuf.slice(AdvancedLeakAwareByteBuf.java:75)
io.netty.buffer.CompositeByteBuf.addComponent0(CompositeByteBuf.java:259)
io.netty.buffer.CompositeByteBuf.addComponent(CompositeByteBuf.java:195)
io.netty.buffer.WrappedCompositeByteBuf.addComponent(WrappedCompositeByteBuf.java:524)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.addComponent(AdvancedLeakAwareCompositeByteBuf.java:928)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:179)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:186)
com.mongodb.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:143)
com.mongodb.connection.DefaultServer.getConnectionAsync(DefaultServer.java:92)
com.mongodb.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:102)
com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:481)
com.mongodb.operation.OperationHelper.access$100(OperationHelper.java:58)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:501)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:489)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:81)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:75)
com.mongodb.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:409)
com.mongodb.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:280)
com.mongodb.connection.BaseCluster.selectServerAsync(BaseCluster.java:141)
com.mongodb.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:75)
com.mongodb.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:65)
com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:448)
com.mongodb.operation.FindOperation.executeAsync(FindOperation.java:546)
com.mongodb.async.client.MongoClientImpl$2.execute(MongoClientImpl.java:123)
com.mongodb.async.client.OperationIterable.batchCursor(OperationIterable.java:132)
com.mongodb.async.client.OperationIterable.first(OperationIterable.java:93)
com.mongodb.async.client.FindIterableImpl.first(FindIterableImpl.java:155)
com.mongodb.async.client.NettyStreamLeakTest.findOne(NettyStreamLeakTest.java:61)
com.mongodb.async.client.NettyStreamLeakTest.run(NettyStreamLeakTest.java:50)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:119)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:42)
com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:234)
com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:74)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
Created at:
io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:271)
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179)
io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:115)
com.mongodb.connection.netty.NettyStream.getBuffer(NettyStream.java:92)
com.mongodb.connection.InternalStreamConnection.getBuffer(InternalStreamConnection.java:514)
com.mongodb.connection.UsageTrackingInternalConnection.getBuffer(UsageTrackingInternalConnection.java:85)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.getBuffer(DefaultConnectionPool.java:420)
com.mongodb.connection.ByteBufferBsonOutput.getByteBufferAtIndex(ByteBufferBsonOutput.java:91)
com.mongodb.connection.ByteBufferBsonOutput.getCurrentByteBuffer(ByteBufferBsonOutput.java:80)
com.mongodb.connection.ByteBufferBsonOutput.writeByte(ByteBufferBsonOutput.java:75)
org.bson.io.OutputBuffer.write(OutputBuffer.java:150)
org.bson.io.OutputBuffer.writeInt32(OutputBuffer.java:56)
com.mongodb.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:158)
com.mongodb.connection.RequestMessage.encodeWithMetadata(RequestMessage.java:146)
com.mongodb.connection.ProtocolHelper.encodeMessageWithMetadata(ProtocolHelper.java:156)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:151)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:186)
com.mongodb.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:143)
com.mongodb.connection.DefaultServer.getConnectionAsync(DefaultServer.java:92)
com.mongodb.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:102)
com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:481)
com.mongodb.operation.OperationHelper.access$100(OperationHelper.java:58)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:501)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:489)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:81)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:75)
com.mongodb.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:409)
com.mongodb.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:280)
com.mongodb.connection.BaseCluster.selectServerAsync(BaseCluster.java:141)
com.mongodb.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:75)
com.mongodb.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:65)
com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:448)
com.mongodb.operation.FindOperation.executeAsync(FindOperation.java:546)
com.mongodb.async.client.MongoClientImpl$2.execute(MongoClientImpl.java:123)
com.mongodb.async.client.OperationIterable.batchCursor(OperationIterable.java:132)
com.mongodb.async.client.OperationIterable.first(OperationIterable.java:93)
com.mongodb.async.client.FindIterableImpl.first(FindIterableImpl.java:155)
com.mongodb.async.client.NettyStreamLeakTest.findOne(NettyStreamLeakTest.java:61)
com.mongodb.async.client.NettyStreamLeakTest.run(NettyStreamLeakTest.java:50)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:119)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:42)
com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:234)
com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:74)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
20:43:39.689 [main] INFO c.m.async.client.NettyStreamLeakTest - query #100 complete
20:43:47.597 [main] INFO c.m.async.client.NettyStreamLeakTest - query #200 complete
20:43:51.070 [main] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See http://netty.io/wiki/reference-counted-objects.html for more information.
WARNING: 117 leak records were discarded because the leak record count is limited to 4. Use system property io.netty.leakDetection.maxRecords to increase the limit.
Recent access records: 5
#5:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
com.mongodb.connection.netty.NettyByteBuf.release(NettyByteBuf.java:238)
com.mongodb.connection.ByteBufferBsonOutput.close(ByteBufferBsonOutput.java:180)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:58)
com.mongodb.connection.SendMessageCallback.onResult(SendMessageCallback.java:25)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:454)
com.mongodb.connection.DefaultConnectionPool$PooledConnection$1.onResult(DefaultConnectionPool.java:448)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:107)
com.mongodb.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:103)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:312)
com.mongodb.connection.InternalStreamConnection$2.completed(InternalStreamConnection.java:297)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:188)
com.mongodb.connection.netty.NettyStream$3.operationComplete(NettyStream.java:182)
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:514)
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:488)
io.netty.util.concurrent.DefaultPromise.access$000(DefaultPromise.java:34)
io.netty.util.concurrent.DefaultPromise$1.run(DefaultPromise.java:438)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#4:
io.netty.buffer.AdvancedLeakAwareByteBuf.release(AdvancedLeakAwareByteBuf.java:955)
io.netty.buffer.CompositeByteBuf$Component.freeIfNecessary(CompositeByteBuf.java:1675)
io.netty.buffer.CompositeByteBuf.deallocate(CompositeByteBuf.java:1940)
io.netty.buffer.AbstractReferenceCountedByteBuf.release(AbstractReferenceCountedByteBuf.java:116)
io.netty.buffer.WrappedCompositeByteBuf.release(WrappedCompositeByteBuf.java:43)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.release(AdvancedLeakAwareCompositeByteBuf.java:1041)
io.netty.util.ReferenceCountUtil.release(ReferenceCountUtil.java:84)
io.netty.util.ReferenceCountUtil.safeRelease(ReferenceCountUtil.java:109)
io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:261)
io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:342)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:443)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#3:
io.netty.buffer.AdvancedLeakAwareByteBuf.internalNioBuffer(AdvancedLeakAwareByteBuf.java:735)
io.netty.buffer.CompositeByteBuf.internalNioBuffer(CompositeByteBuf.java:1449)
io.netty.buffer.WrappedCompositeByteBuf.internalNioBuffer(WrappedCompositeByteBuf.java:853)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.internalNioBuffer(AdvancedLeakAwareCompositeByteBuf.java:730)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:416)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#2:
io.netty.buffer.AdvancedLeakAwareByteBuf.nioBufferCount(AdvancedLeakAwareByteBuf.java:705)
io.netty.buffer.CompositeByteBuf.nioBufferCount(CompositeByteBuf.java:1431)
io.netty.buffer.WrappedCompositeByteBuf.nioBufferCount(WrappedCompositeByteBuf.java:848)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.nioBufferCount(AdvancedLeakAwareCompositeByteBuf.java:700)
io.netty.channel.ChannelOutboundBuffer.nioBuffers(ChannelOutboundBuffer.java:404)
io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:396)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:856)
io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:362)
io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:823)
io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1296)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:786)
io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:778)
io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1149)
io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1090)
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:418)
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:440)
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:873)
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:144)
java.lang.Thread.run(Thread.java:745)
#1:
io.netty.buffer.AdvancedLeakAwareByteBuf.slice(AdvancedLeakAwareByteBuf.java:75)
io.netty.buffer.CompositeByteBuf.addComponent0(CompositeByteBuf.java:259)
io.netty.buffer.CompositeByteBuf.addComponent(CompositeByteBuf.java:195)
io.netty.buffer.WrappedCompositeByteBuf.addComponent(WrappedCompositeByteBuf.java:524)
io.netty.buffer.AdvancedLeakAwareCompositeByteBuf.addComponent(AdvancedLeakAwareCompositeByteBuf.java:928)
com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:179)
com.mongodb.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:297)
com.mongodb.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:291)
com.mongodb.connection.UsageTrackingInternalConnection.sendMessageAsync(UsageTrackingInternalConnection.java:110)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.sendMessageAsync(DefaultConnectionPool.java:448)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:156)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:186)
com.mongodb.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:143)
com.mongodb.connection.DefaultServer.getConnectionAsync(DefaultServer.java:92)
com.mongodb.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:102)
com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:481)
com.mongodb.operation.OperationHelper.access$100(OperationHelper.java:58)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:501)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:489)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:81)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:75)
com.mongodb.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:409)
com.mongodb.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:280)
com.mongodb.connection.BaseCluster.selectServerAsync(BaseCluster.java:141)
com.mongodb.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:75)
com.mongodb.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:65)
com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:448)
com.mongodb.operation.FindOperation.executeAsync(FindOperation.java:546)
com.mongodb.async.client.MongoClientImpl$2.execute(MongoClientImpl.java:123)
com.mongodb.async.client.OperationIterable.batchCursor(OperationIterable.java:132)
com.mongodb.async.client.OperationIterable.first(OperationIterable.java:93)
com.mongodb.async.client.FindIterableImpl.first(FindIterableImpl.java:155)
com.mongodb.async.client.NettyStreamLeakTest.findOne(NettyStreamLeakTest.java:61)
com.mongodb.async.client.NettyStreamLeakTest.run(NettyStreamLeakTest.java:50)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:119)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:42)
com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:234)
com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:74)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
Created at:
io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:271)
io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:179)
io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:115)
com.mongodb.connection.netty.NettyStream.getBuffer(NettyStream.java:92)
com.mongodb.connection.InternalStreamConnection.getBuffer(InternalStreamConnection.java:514)
com.mongodb.connection.UsageTrackingInternalConnection.getBuffer(UsageTrackingInternalConnection.java:85)
com.mongodb.connection.DefaultConnectionPool$PooledConnection.getBuffer(DefaultConnectionPool.java:420)
com.mongodb.connection.ByteBufferBsonOutput.getByteBufferAtIndex(ByteBufferBsonOutput.java:91)
com.mongodb.connection.ByteBufferBsonOutput.getCurrentByteBuffer(ByteBufferBsonOutput.java:80)
com.mongodb.connection.ByteBufferBsonOutput.writeByte(ByteBufferBsonOutput.java:75)
org.bson.io.OutputBuffer.write(OutputBuffer.java:150)
org.bson.io.OutputBuffer.writeInt32(OutputBuffer.java:56)
com.mongodb.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:158)
com.mongodb.connection.RequestMessage.encodeWithMetadata(RequestMessage.java:146)
com.mongodb.connection.ProtocolHelper.encodeMessageWithMetadata(ProtocolHelper.java:156)
com.mongodb.connection.CommandProtocol.executeAsync(CommandProtocol.java:151)
com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:175)
com.mongodb.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:295)
com.mongodb.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:184)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:376)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:366)
com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocolAsync(CommandOperationHelper.java:272)
com.mongodb.operation.FindOperation$2$1.call(FindOperation.java:564)
com.mongodb.operation.OperationHelper$7.call(OperationHelper.java:267)
com.mongodb.operation.OperationHelper.validateCollation(OperationHelper.java:128)
com.mongodb.operation.OperationHelper$6.call(OperationHelper.java:255)
com.mongodb.operation.OperationHelper.validateReadConcern(OperationHelper.java:91)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:249)
com.mongodb.operation.OperationHelper.validateReadConcernAndCollation(OperationHelper.java:264)
com.mongodb.operation.FindOperation$2.call(FindOperation.java:556)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:484)
com.mongodb.operation.OperationHelper$9.onResult(OperationHelper.java:481)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:101)
com.mongodb.connection.DefaultServer$1.onResult(DefaultServer.java:92)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:186)
com.mongodb.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:143)
com.mongodb.connection.DefaultServer.getConnectionAsync(DefaultServer.java:92)
com.mongodb.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:102)
com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:481)
com.mongodb.operation.OperationHelper.access$100(OperationHelper.java:58)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:501)
com.mongodb.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:489)
com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:49)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:81)
com.mongodb.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:75)
com.mongodb.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:409)
com.mongodb.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:280)
com.mongodb.connection.BaseCluster.selectServerAsync(BaseCluster.java:141)
com.mongodb.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:75)
com.mongodb.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:65)
com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:448)
com.mongodb.operation.FindOperation.executeAsync(FindOperation.java:546)
com.mongodb.async.client.MongoClientImpl$2.execute(MongoClientImpl.java:123)
com.mongodb.async.client.OperationIterable.batchCursor(OperationIterable.java:132)
com.mongodb.async.client.OperationIterable.first(OperationIterable.java:93)
com.mongodb.async.client.FindIterableImpl.first(FindIterableImpl.java:155)
com.mongodb.async.client.NettyStreamLeakTest.findOne(NettyStreamLeakTest.java:61)
com.mongodb.async.client.NettyStreamLeakTest.run(NettyStreamLeakTest.java:50)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
org.junit.runners.ParentRunner.run(ParentRunner.java:363)
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:119)
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:42)
com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:234)
com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:74)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:497)
com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)
20:43:55.949 [main] INFO c.m.async.client.NettyStreamLeakTest - query #300 complete
20:44:02.967 [main] INFO c.m.async.client.NettyStreamLeakTest - query #400 complete
20:44:09.725 [main] INFO c.m.async.client.NettyStreamLeakTest - query #500 complete
20:44:17.839 [main] INFO c.m.async.client.NettyStreamLeakTest - query #600 complete
20:44:24.355 [main] INFO c.m.async.client.NettyStreamLeakTest - query #700 complete
20:44:31.048 [main] INFO c.m.async.client.NettyStreamLeakTest - query #800 complete
20:44:37.224 [main] INFO c.m.async.client.NettyStreamLeakTest - query #900 complete
20:44:43.366 [main] INFO c.m.async.client.NettyStreamLeakTest - query #1000 complete
20:44:43.372 [Thread-1] INFO org.mongodb.driver.connection - Closed connection [connectionId{localValue:3, serverValue:205}] to localhost:27017 because the pool has been closed.
Process finished with exit code 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment