Created
March 18, 2016 17:50
-
-
Save stephenh/cf928c4adb371077421a to your computer and use it in GitHub Desktop.
grpc output
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [shaberma@shaberma-ld1 ~ master]$ java -Xmx1G -cp mirror-all.jar mirror.MirrorServer ~/linkedin 10000 | |
| 2016-03-18 09:57:42 INFO mirror.MirrorServer initialSync Starting new session | |
| 2016-03-18 09:57:48 INFO mirror.MirrorServer initialSync Server has 49517 paths | |
| 2016-03-18 09:57:48 INFO mirror.MirrorServer initialSync Client has 7050 paths | |
| 2016-03-18 09:57:48 INFO mirror.MirrorSession seedQueueForInitialSync Queueing 43891 paths to send to the remote host | |
| ... | |
| 2016-03-18 10:00:11 SEVERE mirror.MirrorServer$1 onError Error from incoming client stream | |
| io.grpc.StatusException: CANCELLED [43/17808] | |
| at io.grpc.Status.asException(Status.java:509) | |
| at io.grpc.stub.ServerCalls$2$1.onCancel(ServerCalls.java:227) | |
| at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:272) | |
| at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$3.runInContext(ServerImpl.java:473) | |
| at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:54) | |
| at io.grpc.internal.SerializingExecutor$TaskRunner.run(SerializingExecutor.java:154) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) | |
| at java.lang.Thread.run(Thread.java:745) | |
| 2016-03-18 10:00:11 SEVERE io.grpc.internal.SerializingExecutor$TaskRunner run Exception while executing runnable io.grpc.internal.ServerImpl$JumpToApplicationThreadServerS | |
| treamListener$3@2dfcafb1 | |
| io.grpc.StatusRuntimeException: CANCELLED | |
| at io.grpc.Status.asRuntimeException(Status.java:501) | |
| at io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:288) | |
| at mirror.MirrorServer$1.onError(MirrorServer.java:70) <==== this is my fault for calling onComplete from onError | |
| at io.grpc.stub.ServerCalls$2$1.onCancel(ServerCalls.java:227) | |
| at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:272) | |
| at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$3.runInContext(ServerImpl.java:473) | |
| at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:54) | |
| at io.grpc.internal.SerializingExecutor$TaskRunner.run(SerializingExecutor.java:154) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) | |
| at java.lang.Thread.run(Thread.java:745) | |
| 2016-03-18 10:00:11 WARNING io.grpc.netty.NettyServerHandler onStreamError Stream Error | |
| io.netty.handler.codec.http2.Http2Exception$StreamException: Stream closed before write could take place | |
| at io.netty.handler.codec.http2.Http2Exception.streamError(Http2Exception.java:144) | |
| at io.netty.handler.codec.http2.DefaultHttp2RemoteFlowController$DefaultState.cancel(DefaultHttp2RemoteFlowController.java:464) | |
| at io.netty.handler.codec.http2.DefaultHttp2RemoteFlowController$DefaultState.cancel(DefaultHttp2RemoteFlowController.java:446) | |
| at io.netty.handler.codec.http2.DefaultHttp2RemoteFlowController$1.onStreamClosed(DefaultHttp2RemoteFlowController.java:110) | |
| at io.netty.handler.codec.http2.DefaultHttp2Connection.notifyClosed(DefaultHttp2Connection.java:347) | |
| at io.netty.handler.codec.http2.DefaultHttp2Connection$ActiveStreams.removeFromActiveStreams(DefaultHttp2Connection.java:1241) | |
| at io.netty.handler.codec.http2.DefaultHttp2Connection$ActiveStreams.deactivate(DefaultHttp2Connection.java:1183) | |
| at io.netty.handler.codec.http2.DefaultHttp2Connection$DefaultStream.close(DefaultHttp2Connection.java:533) | |
| at io.netty.handler.codec.http2.Http2ConnectionHandler.closeStream(Http2ConnectionHandler.java:516) | |
| at io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder$FrameReadListener.onRstStreamRead(DefaultHttp2ConnectionDecoder.java:389) | |
| at io.netty.handler.codec.http2.Http2InboundFrameLogger$1.onRstStreamRead(Http2InboundFrameLogger.java:78) | |
| at io.netty.handler.codec.http2.DefaultHttp2FrameReader.readRstStreamFrame(DefaultHttp2FrameReader.java:489) | |
| at io.netty.handler.codec.http2.DefaultHttp2FrameReader.processPayloadState(DefaultHttp2FrameReader.java:249) | |
| at io.netty.handler.codec.http2.DefaultHttp2FrameReader.readFrame(DefaultHttp2FrameReader.java:147) | |
| at io.netty.handler.codec.http2.Http2InboundFrameLogger.readFrame(Http2InboundFrameLogger.java:39) | |
| at io.netty.handler.codec.http2.DefaultHttp2ConnectionDecoder.decodeFrame(DefaultHttp2ConnectionDecoder.java:106) [0/17808] | |
| at io.netty.handler.codec.http2.Http2ConnectionHandler$FrameDecoder.decode(Http2ConnectionHandler.java:332) | |
| at io.netty.handler.codec.http2.Http2ConnectionHandler.decode(Http2ConnectionHandler.java:392) | |
| at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:387) | |
| at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:245) | |
| at io.netty.channel.ChannelHandlerInvokerUtil.invokeChannelReadNow(ChannelHandlerInvokerUtil.java:83) | |
| at io.netty.channel.DefaultChannelHandlerInvoker.invokeChannelRead(DefaultChannelHandlerInvoker.java:154) | |
| at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:354) | |
| at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:145) | |
| at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:1078) | |
| at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:125) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:510) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:467) | |
| at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:381) | |
| at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:353) | |
| at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:742) | |
| at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) | |
| at java.lang.Thread.run(Thread.java:745) | |
| Exception in thread "SyncLogic-0" java.lang.RuntimeException: io.grpc.StatusRuntimeException: CANCELLED | |
| at mirror.SyncLogic.lambda$startPolling$0(SyncLogic.java:60) | |
| at mirror.SyncLogic$$Lambda$5/971761458.run(Unknown Source) | |
| at java.lang.Thread.run(Thread.java:745) | |
| Caused by: io.grpc.StatusRuntimeException: CANCELLED | |
| at io.grpc.Status.asRuntimeException(Status.java:501) | |
| at io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onNext(ServerCalls.java:271) | |
| at mirror.MirrorServer$BlockingStreamObserver.onNext(MirrorServer.java:104) <=== i keep trying to write | |
| at mirror.SyncLogic.handleLocalFile(SyncLogic.java:139) | |
| at mirror.SyncLogic.handleLocal(SyncLogic.java:112) | |
| at mirror.SyncLogic.handleUpdate(SyncLogic.java:99) | |
| at mirror.SyncLogic.pollLoop(SyncLogic.java:76) | |
| at mirror.SyncLogic.lambda$startPolling$0(SyncLogic.java:57) | |
| ... 2 more |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment