[grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-19 Thread 'Carl Mastrangelo' via grpc.io
If the connection is alive and the server doesn't send anything, the call will just wait. What does your server code look like? On Monday, July 18, 2016 at 7:38:54 PM UTC-7, ran...@addepar.com wrote: > > I run into an issue that `BlockingResponseStream.hasNext` occasionally > blocks forever whi

[grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-19 Thread ran.bi via grpc.io
I don't think that is the problem in my case. My server is basically like for all data stream.onNext(data) stream.onComplete() I don't see any chance to cause the problem you described. On Tuesday, July 19, 2016 at 11:23:12 AM UTC-7, Carl Mastrangelo wrote: > > If the connection is alive and t

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-19 Thread 'Eric Anderson' via grpc.io
On Tue, Jul 19, 2016 at 12:20 PM, ran.bi via grpc.io < grpc-io@googlegroups.com> wrote: > I don't think that is the problem in my case. > My server is basically like > > for all data > stream.onNext(data) > stream.onComplete() > > I don't see any chance to cause the problem you described. > Hmm

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-19 Thread ran.bi via grpc.io
1.2 millions protos, and the total serialized data is a few GB I think. The client thread is blocked here > - waiting on <0x7552c6db> (a > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) > - locked <0x7552c6db> (a > java.util.concurrent.locks.AbstractQueuedSynchron

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-25 Thread ran.bi via grpc.io
Anyone has any idea about the potential cause? On Tuesday, July 19, 2016 at 3:43:40 PM UTC-7, ran...@addepar.com wrote: > > 1.2 millions protos, and the total serialized data is a few GB I think. > The client thread is blocked here > >> - waiting on <0x7552c6db> (a >> java.util.concurrent.loc

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-07-25 Thread ran.bi via grpc.io
I just noticed that the problem only happens when I make multiple large server->client streaming RPC simultaneously. I haven't been able to reproduce the issue in a single thread. Could it be a race condition on the client side? On Monday, July 25, 2016 at 4:21:49 PM UTC-7, ran...@addepar.com w

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-08-01 Thread 'Eric Anderson' via grpc.io
It looks like isCancelled() is a bit useless right now, since it's value changes too late . Thanks for bringing this to our attention. Sorry it took so long for me to look at it. On Mon, Jul 25, 2016 at 4:55 PM, ran.bi via grpc.io < grpc-io@googlegrou

Re: [grpc-io] Re: [Question] BlockingResponseStream.hasNext blocks forever

2016-08-01 Thread 'Eric Anderson' via grpc.io
Oops. Sorry. Wrong thread. That response is actually for this issue instead. For your actual issue, I'm still wondering what version of grpc-java you're using. Also, are you using any proxy between the client and server? As a shot-in-the-dark, you m