Maarten Bezemer
50b20413d3
RPC stream client/server mutex fix ( #884 )
...
* Unlock RPC client while actually receiving a message
As receiving a message might block for a long time, unblocking the client allows to let it send messages in the meanwhile without using 'tricks'
* Unlock RPC server while actually receiving a message
As receiving a message might block for a long time, unblocking the client allows to let it send messages in the meanwhile without using 'tricks'
* Protect Close() against race conditions
* Concurrency and Sequence tests
2020-01-12 09:13:14 +00:00
Asim Aslam
0b0eee41d0
functioning proxy code
2019-08-16 16:46:29 +01:00
Asim Aslam
58bc4c103f
go fmt
2019-08-15 20:54:09 +01:00
Asim Aslam
ef04331b86
multiplexing cruft
2019-08-15 20:08:49 +01:00
Asim Aslam
6468733d98
Use protocol from node metadata
2019-01-18 12:30:39 +00:00
Asim Aslam
2cd2258731
For the legacy
2019-01-18 10:12:57 +00:00
Asim Aslam
c1d0237370
Add client response
2019-01-14 21:30:43 +00:00
Asim Aslam
9adebfcf1e
rename method to endpoint
2019-01-10 21:25:31 +00:00
Asim Aslam
648da5494f
Change a few things
2019-01-10 11:39:39 +00:00
Asim Aslam
1561ccbc14
remove clientCodec
2019-01-09 17:33:28 +00:00
Asim Aslam
4cb41721f1
further codec changes
2019-01-08 15:38:25 +00:00
Asim Aslam
e8b431c5ff
rename codec interface
2019-01-07 18:17:13 +00:00
Asim Aslam
386ced576a
Process header/body in one call
2018-12-31 17:53:16 +00:00
Asim Aslam
73e22eb5b1
gofmt
2018-04-06 14:03:00 +01:00
leon.peng
9b99d50396
fix bug #239
2018-03-21 03:17:38 +00:00
Asim Aslam
c9b40cb33b
switch to stdlib context
2018-03-03 11:53:52 +00:00
Asim Aslam
095793ee96
handle codec and transport errors
2016-12-06 19:40:44 +00:00
Asim
2254578760
We don't need sync.Once, we can just select
2016-05-11 00:01:32 +01:00
Asim
7401c44973
This is actually a useless error
2016-01-07 01:58:38 +00:00
Asim
bffd55f500
Channel rather than mutex to check is closed
2015-12-28 19:11:10 +00:00
Asim
3b295b16e7
Working bidirectional streaming example
2015-12-18 20:28:50 +00:00
Asim
4cba0c57ab
Checkpoint the world
2015-12-18 01:01:59 +00:00
Asim
6ae48c9f29
checkpoint
2015-12-17 20:37:35 +00:00
Asim
0c9f8411bb
Pull rpcplus in local for the time being. We need to modify it for server side middleware
2015-12-01 23:32:23 +00:00
Asim
09c784d294
add support for streaming requests. cleanup watcher initilisation
2015-06-01 18:55:27 +01:00
