59 Commits (096daa9a7d4f64a5f01fdecb9b11a5d4d33f877e)

Author	SHA1	Message	Date
Łukasz Zimnoch	231040c633	event: add ResubscribeErr (#22191) ... This adds a way to get the error of the failing subscription for logging/debugging purposes. Co-authored-by: Felix Lange <fjl@twurst.com>	4 years ago
Alex Prut	810f9e057d	all: remove redundant conversions and import names (#21903)	4 years ago
ucwong	0708b573bc	event, whisper/whisperv6: use defer where possible (#20940)	5 years ago
Boqin Qin	ca22d0761b	event: fix inconsistency in Lock and Unlock (#20933) ... Co-authored-by: Felix Lange <fjl@twurst.com>	5 years ago
Boqin Qin	be6078ad83	all: fix a bunch of inconsequential goroutine leaks (#20667) ... The leaks were mostly in unit tests, and could all be resolved by adding suitably-sized channel buffers or by restructuring the test to not send on a channel after an error has occurred. There is an unavoidable goroutine leak in Console.Interactive: when we receive a signal, the line reader cannot be unblocked and will get stuck. This leak is now documented and I've tried to make it slightly less bad by adding a one-element buffer to the output channels of the line-reading loop. Should the reader eventually awake from its blocked state (i.e. when stdin is closed), at least it won't get stuck trying to send to the interpreter loop which has quit long ago. Co-authored-by: Felix Lange <fjl@twurst.com>	5 years ago
ucwong	0893ee6d51	event: add missing timer.Stop call in TestFeed (#20868)	5 years ago
Boqin Qin	a9614c3c91	event, p2p/simulations/adapters: fix rare goroutine leaks (#20657) ... Co-authored-by: Felix Lange <fjl@twurst.com>	5 years ago
Boqin Qin	1821328162	event: add missing unlock before panic (#20653)	5 years ago
Felix Lange	7f70a70106	event: remove unused field 'closed' (#20324)	5 years ago
Felix Lange	9313fa63f9	event/filter: delete unused package (#18063)	6 years ago
Corey Lin	968f6019d0	event, event/filter: minor code cleanup (#18061)	6 years ago
Felix Lange	53a18d2e27	event: document select case slice use and add edge case test (#16680) ... 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'.	7 years ago
gary rong	4e7dc34ff1	eth/filter: check nil pointer when unsubscribe (#16682) ... * 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	7 years ago
kiel barry	60b433ab84	event: golint updates for this or self warning (#16631) ... * event/*: golint updates for this or self warning * event/*: golint updates for this or self warning, pr updated per feedback	7 years ago
Péter Szilágyi	65738c1eb3	event: fix datarace between Subscribe and Send	7 years ago
Jia Chenhui	cefeb58598	event: fix typo (#15270)	7 years ago
Felix Lange	0cc492f815	all: update license information	8 years ago
Felix Lange	c213fd1fd8	all: import "context" instead of "golang.org/x/net/context" ... 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.	8 years ago
Péter Szilágyi	9b5c7153c9	event: use sync.Once for init for faster/cleaner locking	8 years ago
Felix Lange	1bed9b3fea	event: address review issues (multiple commits) ... 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	8 years ago
Felix Lange	6d5e100d0d	event: add new Subscription type and related utilities ... 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.	8 years ago
Felix Lange	9b62facdd4	event: deprecate TypeMux and related types ... 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'	8 years ago
Felix Lange	35a7dcb162	all: gofmt -w -s	8 years ago
Jeffrey Wilcke	7c1f74713e	event: fixed subscribtions to stopped event mux ... 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.	9 years ago
Péter Szilágyi	8e2bf42c46	event/filter: fix data race in the test	9 years ago
Péter Szilágyi	402fd6e8c6	core, eth, event, miner, xeth: fix event post / subscription race	9 years ago
Jeffrey Wilcke	f7a71996fb	core, event/filter, xeth: refactored filter system ... 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".	9 years ago
Felix Lange	bfbcfbe4a9	all: fix license headers one more time ... I forgot to update one instance of "go-ethereum" in commit 3f047be5a.	9 years ago
Felix Lange	3f047be5aa	all: update license headers to distiguish GPL/LGPL ... All code outside of cmd/ is licensed as LGPL. The headers now reflect this by calling the whole work "the go-ethereum library".	9 years ago
Felix Lange	bdae4fd573	all: add some godoc synopsis comments	9 years ago
Felix Lange	ea54283b30	all: update license information	9 years ago
Péter Szilágyi	4541c22964	event/filter: hack around data race in the test	10 years ago
obscuren	7e160a677d	xeth, core, event/filter, rpc: new block and transaction filters	10 years ago
obscuren	09147a50ed	Improved tx pool to ignore invalid transactions ... Transaction pool will attempt to ignore invalid transactions it had previously encountered.	10 years ago
obscuren	0330077d76	moved state and vm to core	10 years ago
obscuren	55fdf3e462	Listen to tx pre event and trigger 'pending'	10 years ago
Taylor Gerring	6c04c19eb4	Reorg filter logic to XEth	10 years ago
obscuren	14a2f42f37	fixed chain event. Closes #529	10 years ago
obscuren	7c510109cd	skipping test	10 years ago
obscuren	7fc9b5b3f9	Changed to ChainEvent and fixed a nil pointer in transact	10 years ago
obscuren	44eafb15e0	Renamed filter	10 years ago
obscuren	c64852dbcc	pending / chain event	10 years ago
obscuren	65158d39b0	Filtering	10 years ago
obscuren	f3e78c8f3c	reworking messages => log	10 years ago
obscuren	34689cb3f3	Added manual triggering of filters	10 years ago
obscuren	35fe4313d5	pre-pow	10 years ago
obscuren	e3da85faed	Implemented filter for ws + fixes ... * proper 0xhex * filters fixed * start of filter manager * accounts for ws. Closes #246	10 years ago
obscuren	52b54631a4	Whisper watches fixes	10 years ago
obscuren	cdb2ebbdfa	Added old filter. Needs some refactoring	10 years ago
obscuren	ed1538248f	Moved filter to events	10 years ago