-
- Downloads
New data flow (#944)
* feat: Extract stores from tangle to MessageStore (#900) * feat: Extract stores from tangle to MessageStore *Change FPC shutdown priority * chores: Update wording * fix: Store MessageMetadata automatically * feat: Introduce booked flag to MessageMetadata * feat: Introduce MessageBooked event * Fix: Fix Co-authored-by: capossele <angelocapossele@gmail.com> * refactor: Refactor solidifier (#923) * feat: Add parents check and introduce eligible flag to MessageMetadata * feat: Hook events to parents check * feat: Add MessageEligible event * refactor: Update to the data flow figure and remove the solidifier workerpool * test: Add InvalidParentsAgeMessage unit test * fix: Fix
* fix: Fix comments * test: Implement data flow unit test - from filter to solidifier * Add inbox workerpool to FilterStoreSolidify unit test * test: Use WP at start and use default parameters in unit test * Enable Leak detection for debugging * Fix FPC round duration * Disable Leak detection * Assign shutdown order to value tangle * Dump stacktrace in case of shutdown failure * Release msg and metadata if findByID fails * Ensure to set right issuanceTime in messageFactory * Fix transaction could not be booked in time issue * Fix linter warnings * chores: Remove debugging codes * Revert "chores: Remove debugging codes" This reverts commit b35ec269a762583b2a06e5a3235c80bf61945ed3. Co-authored-by: capossele <angelocapossele@gmail.com> * Add core logic for timestamp voting (#930) *
Add timestampOpinion * Add TimestampQuality unit test * Remove debug print * Simplify code * feat: Add parents check and introduce eligible flag to MessageMetadata * feat: Hook events to parents check * feat: Add MessageEligible event * refactor: Update to the data flow figure and remove the solidifier workerpool * test: Add InvalidParentsAgeMessage unit test * fix: Fix * fix: Fix comments * test: Implement data flow unit test - from filter to solidifier * Add inbox workerpool to FilterStoreSolidify unit test * test: Use WP at start and use default parameters in unit test * Enable Leak detection for debugging * Fix FPC round duration * Disable Leak detection * Assign shutdown order to value tangle * Dump stacktrace in case of shutdown failure * Release msg and metadata if findByID fails * Ensure to set right issuanceTime in messageFactory * Fix transaction could not be booked in time issue * Fix linter warnings * WIP * Fix messagemetadata * Add missing comment * Fix MessageMetadataFromMarshalUtil * Address review comments * Refactor err usage Co-authored-by: jkrvivian <jkrvivian@gmail.com> * test: Add invalid timestamp msgs to data flow unit test (#935) * test: Add invalid ts msgs to data flow unit test * fix: Unexport testing methods * fix: Fix unit test *
Refactor filter setup (#937) * feat: Introduce invalid to MessageMetadata (#938) * feat: Hook DeleteMessage to MessageInvalid event * feat: Introduce invalid flage to MessageMetadata * fix: Fix comments * refactor: Remove double locking in boolean setters * fix: Fix typo * refactor: Apply defer to unlock mutexes * feat: Avoid gossiping requested messages (#941) * feat: Avoid gossiping requested messages * chores: Format with gofmt * refactor: Make requestedMsgs a structure * fix: Fix * Fix sigsev in faucet * Get rid of ugly read/write lock business Co-authored-by: Ching-Hua (Vivian) Lin <jkrvivian@gmail.com> Co-authored-by:
Levente Pap <levente.pap@iota.org> Co-authored-by:
jonastheis <mail@jonastheis.de>
Showing
- dapps/valuetransfers/dapp.go 30 additions, 4 deletionsdapps/valuetransfers/dapp.go
- dapps/valuetransfers/packages/consensus/fcob.go 6 additions, 5 deletionsdapps/valuetransfers/packages/consensus/fcob.go
- dapps/valuetransfers/packages/tangle/signature_filter_test.go 2 additions, 0 deletions...s/valuetransfers/packages/tangle/signature_filter_test.go
- packages/metrics/events.go 3 additions, 3 deletionspackages/metrics/events.go
- packages/shutdown/order.go 4 additions, 4 deletionspackages/shutdown/order.go
- packages/spammer/spammer.go 1 addition, 1 deletionpackages/spammer/spammer.go
- packages/tangle/events.go 30 additions, 12 deletionspackages/tangle/events.go
- packages/tangle/messagefactory.go 14 additions, 1 deletionpackages/tangle/messagefactory.go
- packages/tangle/messagemetadata.go 130 additions, 2 deletionspackages/tangle/messagemetadata.go
- packages/tangle/messageparser.go 6 additions, 2 deletionspackages/tangle/messageparser.go
- packages/tangle/messageparser_test.go 3 additions, 0 deletionspackages/tangle/messageparser_test.go
- packages/tangle/messagestore.go 254 additions, 0 deletionspackages/tangle/messagestore.go
- packages/tangle/solidifier.go 283 additions, 0 deletionspackages/tangle/solidifier.go
- packages/tangle/tangle.go 4 additions, 365 deletionspackages/tangle/tangle.go
- packages/tangle/tangle_test.go 378 additions, 30 deletionspackages/tangle/tangle_test.go
- packages/tangle/timestamp.go 122 additions, 0 deletionspackages/tangle/timestamp.go
- packages/tangle/timestamp_test.go 68 additions, 0 deletionspackages/tangle/timestamp_test.go
- packages/vote/fpc/fpc.go 22 additions, 21 deletionspackages/vote/fpc/fpc.go
- packages/vote/fpc/fpc_test.go 33 additions, 32 deletionspackages/vote/fpc/fpc_test.go
- packages/vote/net/server.go 2 additions, 1 deletionpackages/vote/net/server.go
Loading
Please register or sign in to comment