1271 Commits

Author SHA1 Message Date
b5e39adfb2 Add generic close loop 2016-04-27 16:14:24 -07:00
257710d39c Add close benchmark rpc calls 2016-04-27 16:13:32 -07:00
2aaff82a6e Add RunClient() 2016-04-27 16:13:06 -07:00
b062a3c003 Merge pull request #654 from jazzgal/patch-1
Comment typo
2016-04-25 10:42:00 -07:00
b4ad52a6ec Comment typo 2016-04-24 16:01:42 +07:00
262ed2bd6d Merge pull request #651 from iamqizhao/master
Start reader Goroutine earlier
2016-04-22 16:00:04 -07:00
0f4e1e7ee5 Start reader Goroutine earlier 2016-04-22 13:49:56 -07:00
c2e8421003 Minor changes
Change log print
Ignore cpu core list and return the actual number of cores used
Add copyright
Change certfile and keyfile path to relative
RunClient() returns "not implemented" error
Close existing server when new server setup received
Main goroutine will wait for server to stop
Move benchmarkServer out of workerServer
2016-04-22 13:48:50 -07:00
bdd0e9ff61 Fix error in benchmark_test 2016-04-22 13:48:50 -07:00
26b336d491 Add driver command line options 2016-04-22 13:48:50 -07:00
643486f084 Add bytebuf codec and generic benchmark server 2016-04-22 13:48:50 -07:00
9fd1d5bee8 Implement QPS workerServer and Add RunServer() for benchmarkServer 2016-04-22 13:47:34 -07:00
142fdefa83 Sync proto and update service name in src 2016-04-22 10:58:15 -07:00
306a1ee0fe Merge pull request #636 from menghanl/histogram
Change histogram to comply with benchmark worker requirements
2016-04-21 18:06:02 -07:00
f4425a1062 Address review comments 2016-04-21 17:47:21 -07:00
c962da7be9 Merge pull request #647 from iamqizhao/master
Phase 3 for server interceptor: support stream interceptor
2016-04-21 15:55:25 -07:00
e4bb85b43f Support the stream interceptor on server side. 2016-04-21 14:58:45 -07:00
95f4d27b65 Merge pull request #649 from iamqizhao/fix
Close errorChan even when there is no pending I/O
2016-04-21 14:16:13 -07:00
293b2f9fa8 Close errorChan even when there is no pending I/O 2016-04-21 13:42:59 -07:00
782915aae8 Add extra option smallest bucket size 2016-04-20 10:16:33 -07:00
1a5928317d Merge pull request #645 from iamqizhao/master
Phase 2 for server interceptor: The installation of server unary interceptor
2016-04-19 18:13:47 -07:00
7e9d489649 Address review comments 2016-04-19 17:26:15 -07:00
616cb8ecfe Add the missing comment 2016-04-19 16:33:09 -07:00
310ca08496 gofmt -w 2016-04-19 16:04:09 -07:00
c321387fd9 the installation of server unary interceptor 2016-04-19 15:54:30 -07:00
dd828651e4 Merge pull request #642 from iamqizhao/master
Phase 1 to add the server interceptor
2016-04-18 16:49:42 -07:00
61e92eacc3 Phase 1 to add the server interceptor 2016-04-18 16:18:34 -07:00
dec33edc37 Merge pull request #641 from iamqizhao/master
make setDefault(...) non-member function
2016-04-18 13:39:30 -07:00
9cec19a4d4 make setDefault(...) non-member function 2016-04-18 13:15:27 -07:00
75407c0f82 change backoff to pointer receiver 2016-04-18 12:12:19 -07:00
867e23d72a Merge pull request #638 from stevvooe/backoff-set-defaults
backoff: set default values on BackoffConfig
2016-04-18 11:58:19 -07:00
8ef1dcabab backoff: make DefaultBackoffConfig a concrete value
To enforce immutability of the `DefaultBackoffConfig`, we've made it a
concrete value. While fields can still be set directly on the value,
taking a copy will not incidentally pull a reference to the variable.

Signed-off-by: Stephen J Day <stephen.day@docker.com>
2016-04-18 11:33:39 -07:00
56c490a369 Merge pull request #640 from iamqizhao/master
Fix a couple of misuse of ctx introduced recently
2016-04-18 10:58:19 -07:00
25dd388f9a more typo 2016-04-18 10:42:21 -07:00
ee96f6b348 Fix a typo 2016-04-18 10:37:34 -07:00
7af9aab473 Merge branch 'master' of https://github.com/grpc/grpc-go 2016-04-18 10:30:44 -07:00
ac3c5847a1 fix a couple of misuse of ctx introduced recently 2016-04-18 10:30:34 -07:00
8086cee031 Merge pull request #627 from menghanl/stress_testing
Stress testing
2016-04-18 09:58:50 -07:00
8c5cde66aa Address code review comments 2016-04-15 17:49:25 -07:00
9ff38e9093 backoff: set default values on BackoffConfig
Because most of the fields on `BackoffConfig` are unexported, correctly
using the config requires copying from the default. This sets the
defaults appropriately and falls back to a default if MaxDelay is
negative or zero.

Tests are added to ensure that the backoff is set correctly in common
use cases.

Signedroff-by: Stephen J Day <stephen.day@docker.com>
Signed-off-by: Stephen J Day <stephen.day@docker.com>
2016-04-15 16:12:47 -07:00
8eeecf2291 Merge pull request #637 from iamqizhao/master
Refactored the inbound flow control and fixed a couple of issues.
2016-04-15 13:47:30 -07:00
9530d84aba Add license 2016-04-15 12:56:21 -07:00
0bf5c5c18f Rewrite timeout stop with channel 2016-04-15 12:56:13 -07:00
5ae93a9d0e Addressed the comments 2016-04-15 11:54:48 -07:00
963ee99c99 Refactored the inbound flow control and fixed a couple of issues. 2016-04-14 14:16:39 -07:00
056dc9c933 Change histogram algorithm to comply with benchmark requirements 2016-04-14 11:43:24 -07:00
536ed747b8 Change histogram lowbound to float64 2016-04-14 11:43:24 -07:00
d8783294dd Add sumOfSquares to histogram 2016-04-14 11:43:15 -07:00
9ac074585f Merge pull request #634 from heyitsanthony/cancel-nosend
transport: do not create a Stream on a canceled context
2016-04-13 10:35:15 -07:00
025674fec5 transport: do not create a Stream on a canceled context
Occasionally Invoke() would let a message slip through when the context
is already canceled.
2016-04-12 21:45:35 -07:00