aboutsummaryrefslogtreecommitdiffstats
path: root/event
Commit message (Collapse)AuthorAgeFilesLines
* event: document select case slice use and add edge case test (#16680)Felix Lange2018-05-102-1/+43
| | | | | | | | | | | Feed keeps active subscription channels in a slice called 'f.sendCases'. The Send method tracks the active cases in a local variable 'cases' whose value is f.sendCases initially. 'cases' shrinks to a shorter prefix of f.sendCases every time a send succeeds, moving the successful case out of range of the active case list. This can be confusing because the two slices share a backing array. Add more comments to document what is going on. Also add a test for removing a case that is in 'f.sentCases' but not 'cases'.
* eth/filter: check nil pointer when unsubscribe (#16682)gary rong2018-05-091-0/+6
| | | | | | | | | | * eth/filter: check nil pointer when unsubscribe * eth/filters, accounts, rpc: abort system if subscribe failed * eth/filter: add crit log before exit * eth/filter, event: minor fixes
* event: golint updates for this or self warning (#16631)kiel barry2018-05-031-19/+19
| | | | | | * event/*: golint updates for this or self warning * event/*: golint updates for this or self warning, pr updated per feedback
* event: fix datarace between Subscribe and SendPéter Szilágyi2017-10-201-3/+5
|
* event: fix typo (#15270)Jia Chenhui2017-10-101-1/+1
|
* all: update license informationFelix Lange2017-04-145-5/+5
|
* all: import "context" instead of "golang.org/x/net/context"Felix Lange2017-03-232-3/+2
| | | | | | | | | | There is no need to depend on the old context package now that the minimum Go version is 1.7. The move to "context" eliminates our weird vendoring setup. Some vendored code still uses golang.org/x/net/context and it is now vendored in the normal way. This change triggered new vet checks around context.WithTimeout which didn't fire with golang.org/x/net/context.
* event: use sync.Once for init for faster/cleaner lockingPéter Szilágyi2017-02-031-11/+5
|
* event: address review issues (multiple commits)Felix Lange2017-02-033-16/+93
| | | | | | | | | | | | | event: address Feed review issues event: clarify role of NewSubscription function event: more Feed review fixes * take sendLock after dropping f.mu * add constant for number of special cases event: fix subscribing/unsubscribing while Send is blocked
* event: add new Subscription type and related utilitiesFelix Lange2017-01-269-7/+1144
| | | | | | | | | This commit introduces a new Subscription type, which is synonymous with ethereum.Subscription. It also adds a couple of utilities that make working with Subscriptions easier. The mot complex utility is Feed, a synchronisation device that implements broadcast subscriptions. Feed is slightly faster than TypeMux and will replace uses of TypeMux across the go-ethereum codebase in the future.
* event: deprecate TypeMux and related typesFelix Lange2017-01-251-34/+24
| | | | | | | | | | | The Subscription type is gone, all uses are replaced by *TypeMuxSubscription. This change is prep-work for the introduction of the new Subscription type in a later commit. gorename -from '"github.com/ethereum/go-ethereum/event"::Event' -to TypeMuxEvent gorename -from '"github.com/ethereum/go-ethereum/event"::muxsub' -to TypeMuxSubscription gofmt -w -r 'Subscription -> *TypeMuxSubscription' ./event/*.go find . -name '*.go' -and -not -regex '\./vendor/.*' \| xargs gofmt -w -r 'event.Subscription -> *event.TypeMuxSubscription'
* all: gofmt -w -sFelix Lange2017-01-062-3/+3
|
* event: fixed subscribtions to stopped event muxJeffrey Wilcke2016-05-132-0/+11
| | | | | | | | | | | | | This fixes an issue where the following would lead to a panic due to a channel being closed twice: * Start mux * Stop mux * Sub to mux * Unsub This is fixed by setting the subscriptions status to closed resulting in the Unsubscribe to ignore the request when called.
* event/filter: fix data race in the testPéter Szilágyi2015-11-051-12/+17
|
* core, eth, event, miner, xeth: fix event post / subscription racePéter Szilágyi2015-10-123-11/+30
|
* core, event/filter, xeth: refactored filter systemJeffrey Wilcke2015-10-031-127/+0
| | | | | | | Moved the filtering system from `event` to `eth/filters` package and removed the `core.Filter` object. The `filters.Filter` object now requires a `common.Database` rather than a `eth.Backend` and invokes the `core.GetBlockByX` directly rather than thru a "manager".
* all: fix license headers one more timeFelix Lange2015-07-247-7/+7
| | | | I forgot to update one instance of "go-ethereum" in commit 3f047be5a.
* all: update license headers to distiguish GPL/LGPLFelix Lange2015-07-237-28/+28
| | | | | All code outside of cmd/ is licensed as LGPL. The headers now reflect this by calling the whole work "the go-ethereum library".
* all: add some godoc synopsis commentsFelix Lange2015-07-071-0/+1
|
* all: update license informationFelix Lange2015-07-077-0/+112
|
* event/filter: hack around data race in the testPéter Szilágyi2015-06-101-1/+6
|
* xeth, core, event/filter, rpc: new block and transaction filtersobscuren2015-05-071-2/+2
|
* Improved tx pool to ignore invalid transactionsobscuren2015-04-081-1/+1
| | | | | Transaction pool will attempt to ignore invalid transactions it had previously encountered.
* moved state and vm to coreobscuren2015-03-231-1/+1
|
* Merge branch 'rpcxeth' into rpcfrontierTaylor Gerring2015-03-201-1/+3
|\ | | | | | | | | Conflicts: rpc/api.go
| * Reorg filter logic to XEthTaylor Gerring2015-03-201-1/+3
| |
* | Listen to tx pre event and trigger 'pending'obscuren2015-03-201-3/+4
|/
* fixed chain event. Closes #529obscuren2015-03-191-3/+3
|
* skipping testobscuren2015-02-241-3/+0
|
* fixed mergeobscuren2015-02-201-3/+7
|
* Changed to ChainEvent and fixed a nil pointer in transactobscuren2015-02-181-2/+5
|
* Renamed filterobscuren2015-02-081-1/+2
|
* pending / chain eventobscuren2015-02-061-1/+10
|
* Filteringobscuren2015-02-051-1/+1
|
* reworking messages => logobscuren2015-01-281-4/+4
|
* Added manual triggering of filtersobscuren2015-01-131-0/+8
|
* pre-powobscuren2015-01-121-2/+0
|
* Implemented filter for ws + fixesobscuren2015-01-101-0/+2
| | | | | | | * proper 0xhex * filters fixed * start of filter manager * accounts for ws. Closes #246
* Whisper watches fixesobscuren2014-12-171-5/+15
|
* Added old filter. Needs some refactoringobscuren2014-12-151-0/+94
|
* Moved filter to eventsobscuren2014-12-133-0/+126
|
* Added `chain` tests & minor fixesobscuren2014-11-191-40/+0
| | | | | | * Fork tests (equal and larger chains) * `chain.link` fields are now exported * moved debug function from state to dump.go
* enable `go vet`Taylor Gerring2014-11-181-0/+40
|
* event: panic for duplicate typeFelix Lange2014-10-172-1/+20
|
* event: make TypeMux zero value ready to useFelix Lange2014-10-172-13/+12
|
* event: make Unsubscribe idempotentFelix Lange2014-10-171-7/+16
|
* event: add some documentationFelix Lange2014-10-172-0/+51
|
* event: new package for event multiplexerFelix Lange2014-10-172-0/+323
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-06 10:14:01 +0800