You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

220 lines
5.8 KiB

9 years ago
7 years ago
9 years ago
8 years ago
8 years ago
8 years ago
8 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
8 years ago
7 years ago
8 years ago
7 years ago
8 years ago
8 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
8 years ago
8 years ago
8 years ago
8 years ago
7 years ago
8 years ago
8 years ago
8 years ago
8 years ago
7 years ago
7 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
new pubsub package comment out failing consensus tests for now rewrite rpc httpclient to use new pubsub package import pubsub as tmpubsub, query as tmquery make event IDs constants EventKey -> EventTypeKey rename EventsPubsub to PubSub mempool does not use pubsub rename eventsSub to pubsub new subscribe API fix channel size issues and consensus tests bugs refactor rpc client add missing discardFromChan method add mutex rename pubsub to eventBus remove IsRunning from WSRPCConnection interface (not needed) add a comment in broadcastNewRoundStepsAndVotes rename registerEventCallbacks to broadcastNewRoundStepsAndVotes See https://dave.cheney.net/2014/03/19/channel-axioms stop eventBuses after reactor tests remove unnecessary Unsubscribe return subscribe helper function move discardFromChan to where it is used subscribe now returns an err this gives us ability to refuse to subscribe if pubsub is at its max capacity. use context for control overflow cache queries handle err when subscribing in replay_test rename testClientID to testSubscriber extract var set channel buffer capacity to 1 in replay_file fix byzantine_test unsubscribe from single event, not all events refactor httpclient to return events to appropriate channels return failing testReplayCrashBeforeWriteVote test fix TestValidatorSetChanges refactor code a bit fix testReplayCrashBeforeWriteVote add comment fix TestValidatorSetChanges fixes from Bucky's review update comment [ci skip] test TxEventBuffer update changelog fix TestValidatorSetChanges (2nd attempt) only do wg.Done when no errors benchmark event bus create pubsub server inside NewEventBus only expose config params (later if needed) set buffer capacity to 0 so we are not testing cache new tx event format: key = "Tx" plus a tag {"tx.hash": XYZ} This should allow to subscribe to all transactions! or a specific one using a query: "tm.events.type = Tx and tx.hash = '013ABF99434...'" use TimeoutCommit instead of afterPublishEventNewBlockTimeout TimeoutCommit is the time a node waits after committing a block, before it goes into the next height. So it will finish everything from the last block, but then wait a bit. The idea is this gives it time to hear more votes from other validators, to strengthen the commit it includes in the next block. But it also gives it time to hear about new transactions. waitForBlockWithUpdatedVals rewrite WAL crash tests Task: test that we can recover from any WAL crash. Solution: the old tests were relying on event hub being run in the same thread (we were injecting the private validator's last signature). when considering a rewrite, we considered two possible solutions: write a "fuzzy" testing system where WAL is crashing upon receiving a new message, or inject failures and trigger them in tests using something like https://github.com/coreos/gofail. remove sleep no cs.Lock around wal.Save test different cases (empty block, non-empty block, ...) comments add comments test 4 cases: empty block, non-empty block, non-empty block with smaller part size, many blocks fixes as per Bucky's last review reset subscriptions on UnsubscribeAll use a simple counter to track message for which we panicked also, set a smaller part size for all test cases
7 years ago
8 years ago
8 years ago
9 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
8 years ago
7 years ago
7 years ago
7 years ago
8 years ago
7 years ago
8 years ago
8 years ago
8 years ago
8 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
7 years ago
  1. hash: bd982742a0aee39426f3866914a59f7c47e68dc8dedb87219e2099c0d9c19f7e
  2. updated: 2017-12-21T17:45:25.372327218Z
  3. imports:
  4. - name: github.com/btcsuite/btcd
  5. version: 2e60448ffcc6bf78332d1fe590260095f554dd78
  6. subpackages:
  7. - btcec
  8. - name: github.com/ebuchman/fail-test
  9. version: 95f809107225be108efcf10a3509e4ea6ceef3c4
  10. - name: github.com/fsnotify/fsnotify
  11. version: 4da3e2cfbabc9f751898f250b49f2439785783a1
  12. - name: github.com/go-kit/kit
  13. version: 953e747656a7bbb5e1f998608b460458958b70cc
  14. subpackages:
  15. - log
  16. - log/level
  17. - log/term
  18. - name: github.com/go-logfmt/logfmt
  19. version: 390ab7935ee28ec6b286364bba9b4dd6410cb3d5
  20. - name: github.com/go-playground/locales
  21. version: e4cbcb5d0652150d40ad0646651076b6bd2be4f6
  22. subpackages:
  23. - currency
  24. - name: github.com/go-playground/universal-translator
  25. version: 71201497bace774495daed26a3874fd339e0b538
  26. - name: github.com/go-stack/stack
  27. version: 259ab82a6cad3992b4e21ff5cac294ccb06474bc
  28. - name: github.com/gogo/protobuf
  29. version: 342cbe0a04158f6dcb03ca0079991a51a4248c02
  30. subpackages:
  31. - gogoproto
  32. - jsonpb
  33. - proto
  34. - protoc-gen-gogo/descriptor
  35. - sortkeys
  36. - types
  37. - name: github.com/golang/protobuf
  38. version: 1e59b77b52bf8e4b449a57e6f79f21226d571845
  39. subpackages:
  40. - proto
  41. - ptypes
  42. - ptypes/any
  43. - ptypes/duration
  44. - ptypes/timestamp
  45. - name: github.com/golang/snappy
  46. version: 553a641470496b2327abcac10b36396bd98e45c9
  47. - name: github.com/gorilla/websocket
  48. version: ea4d1f681babbce9545c9c5f3d5194a789c89f5b
  49. - name: github.com/hashicorp/hcl
  50. version: 23c074d0eceb2b8a5bfdbb271ab780cde70f05a8
  51. subpackages:
  52. - hcl/ast
  53. - hcl/parser
  54. - hcl/scanner
  55. - hcl/strconv
  56. - hcl/token
  57. - json/parser
  58. - json/scanner
  59. - json/token
  60. - name: github.com/inconshreveable/mousetrap
  61. version: 76626ae9c91c4f2a10f34cad8ce83ea42c93bb75
  62. - name: github.com/jmhodges/levigo
  63. version: c42d9e0ca023e2198120196f842701bb4c55d7b9
  64. - name: github.com/kr/logfmt
  65. version: b84e30acd515aadc4b783ad4ff83aff3299bdfe0
  66. - name: github.com/magiconair/properties
  67. version: 8d7837e64d3c1ee4e54a880c5a920ab4316fc90a
  68. - name: github.com/mitchellh/mapstructure
  69. version: 06020f85339e21b2478f756a78e295255ffa4d6a
  70. - name: github.com/pelletier/go-buffruneio
  71. version: c37440a7cf42ac63b919c752ca73a85067e05992
  72. - name: github.com/pelletier/go-toml
  73. version: b8b5e7696574464b2f9bf303a7b37781bb52889f
  74. - name: github.com/pkg/errors
  75. version: 645ef00459ed84a119197bfb8d8205042c6df63d
  76. - name: github.com/rcrowley/go-metrics
  77. version: 1f30fe9094a513ce4c700b9a54458bbb0c96996c
  78. - name: github.com/spf13/afero
  79. version: 5660eeed305fe5f69c8fc6cf899132a459a97064
  80. subpackages:
  81. - mem
  82. - name: github.com/spf13/cast
  83. version: acbeb36b902d72a7a4c18e8f3241075e7ab763e4
  84. - name: github.com/spf13/cobra
  85. version: 7b2c5ac9fc04fc5efafb60700713d4fa609b777b
  86. - name: github.com/spf13/jwalterweatherman
  87. version: 12bd96e66386c1960ab0f74ced1362f66f552f7b
  88. - name: github.com/spf13/pflag
  89. version: 4c012f6dcd9546820e378d0bdda4d8fc772cdfea
  90. - name: github.com/spf13/viper
  91. version: 25b30aa063fc18e48662b86996252eabdcf2f0c7
  92. - name: github.com/syndtr/goleveldb
  93. version: 34011bf325bce385408353a30b101fe5e923eb6e
  94. subpackages:
  95. - leveldb
  96. - leveldb/cache
  97. - leveldb/comparer
  98. - leveldb/errors
  99. - leveldb/filter
  100. - leveldb/iterator
  101. - leveldb/journal
  102. - leveldb/memdb
  103. - leveldb/opt
  104. - leveldb/storage
  105. - leveldb/table
  106. - leveldb/util
  107. - name: github.com/tendermint/abci
  108. version: e4b9f1abe794a2117a59738a1294e09b46d0fa00
  109. subpackages:
  110. - client
  111. - example/code
  112. - example/counter
  113. - example/dummy
  114. - server
  115. - types
  116. - name: github.com/tendermint/ed25519
  117. version: d8387025d2b9d158cf4efb07e7ebf814bcce2057
  118. subpackages:
  119. - edwards25519
  120. - extra25519
  121. - name: github.com/tendermint/go-crypto
  122. version: dd20358a264c772b4a83e477b0cfce4c88a7001d
  123. - name: github.com/tendermint/go-wire
  124. version: b6fc872b42d41158a60307db4da051dd6f179415
  125. subpackages:
  126. - data
  127. - data/base58
  128. - nowriter/tmlegacy
  129. - name: github.com/tendermint/iavl
  130. version: 594cc0c062a7174475f0ab654384038d77067917
  131. subpackages:
  132. - iavl
  133. - name: github.com/tendermint/tmlibs
  134. version: e236218516289f91bde3273e99fe5c1fc20eb304
  135. subpackages:
  136. - autofile
  137. - cli
  138. - cli/flags
  139. - clist
  140. - common
  141. - db
  142. - flowrate
  143. - log
  144. - merkle
  145. - pubsub
  146. - pubsub/query
  147. - test
  148. - name: golang.org/x/crypto
  149. version: d585fd2cc9195196078f516b69daff6744ef5e84
  150. subpackages:
  151. - curve25519
  152. - nacl/box
  153. - nacl/secretbox
  154. - openpgp/armor
  155. - openpgp/errors
  156. - poly1305
  157. - ripemd160
  158. - salsa20/salsa
  159. - name: golang.org/x/net
  160. version: d866cfc389cec985d6fda2859936a575a55a3ab6
  161. subpackages:
  162. - context
  163. - http2
  164. - http2/hpack
  165. - idna
  166. - internal/timeseries
  167. - lex/httplex
  168. - trace
  169. - name: golang.org/x/sys
  170. version: d818ba11af4465e00c1998bd3f8a55603b422290
  171. subpackages:
  172. - unix
  173. - name: golang.org/x/text
  174. version: eb22672bea55af56d225d4e35405f4d2e9f062a0
  175. subpackages:
  176. - secure/bidirule
  177. - transform
  178. - unicode/bidi
  179. - unicode/norm
  180. - name: google.golang.org/genproto
  181. version: a8101f21cf983e773d0c1133ebc5424792003214
  182. subpackages:
  183. - googleapis/rpc/status
  184. - name: google.golang.org/grpc
  185. version: 401e0e00e4bb830a10496d64cd95e068c5bf50de
  186. subpackages:
  187. - balancer
  188. - codes
  189. - connectivity
  190. - credentials
  191. - grpclb/grpc_lb_v1/messages
  192. - grpclog
  193. - internal
  194. - keepalive
  195. - metadata
  196. - naming
  197. - peer
  198. - resolver
  199. - stats
  200. - status
  201. - tap
  202. - transport
  203. - name: gopkg.in/go-playground/validator.v9
  204. version: b1f51f36f1c98cc97f777d6fc9d4b05eaa0cabb5
  205. - name: gopkg.in/yaml.v2
  206. version: eb3733d160e74a9c7e442f435eb3bea458e1d19f
  207. testImports:
  208. - name: github.com/davecgh/go-spew
  209. version: 04cdfd42973bb9c8589fd6a731800cf222fde1a9
  210. subpackages:
  211. - spew
  212. - name: github.com/pmezard/go-difflib
  213. version: d8ed2627bdf02c080bf22230dbb337003b7aba2d
  214. subpackages:
  215. - difflib
  216. - name: github.com/stretchr/testify
  217. version: 2aa2c176b9dab406a6970f6a55f513e8a8c8b18f
  218. subpackages:
  219. - assert
  220. - require