Skip to content

Commit af3e906

Browse files
move release
1 parent 60d3e59 commit af3e906

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

netty/src/main/java/io/grpc/netty/NettyServer.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -136,16 +136,15 @@ public void initChannel(Channel ch) throws Exception {
136136
// `channel` shutdown can race with `ch` initialization, so this is only safe to increment
137137
// inside the lock.
138138
eventLoopReferenceCounter.retain();
139-
ch.closeFuture().addListener(new ChannelFutureListener() {
140-
@Override
141-
public void operationComplete(ChannelFuture future) {
142-
eventLoopReferenceCounter.release();
143-
}
144-
});
145-
146139
transportListener = listener.transportCreated(transport);
147140
}
148141
transport.start(transportListener);
142+
ch.closeFuture().addListener(new ChannelFutureListener() {
143+
@Override
144+
public void operationComplete(ChannelFuture future) {
145+
eventLoopReferenceCounter.release();
146+
}
147+
});
149148
}
150149
});
151150
// Bind and start to accept incoming connections.

0 commit comments

Comments
 (0)