akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

htlcswitch: run decay log tests in parallel

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2018-05-22 16:55:08 -07:00
parent 5e3b239ebc
commit b60575fdac
No known key found for this signature in database
GPG Key ID: 964EA263DD637C21
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
htlcswitch/decayedlog_test.go
View File

@ -63,6 +63,8 @@ func shutdown(dir string, d sphinx.ReplayLog) {
// to delete expired cltv values every time a block is received. Expired cltv // to delete expired cltv values every time a block is received. Expired cltv
// values are cltv values that are < current block height. // values are cltv values that are < current block height.
func TestDecayedLogGarbageCollector(t *testing.T) { func TestDecayedLogGarbageCollector(t *testing.T) {
t.Parallel()
d, notifier, hashedSecret, err := startup(true) d, notifier, hashedSecret, err := startup(true)
if err != nil { if err != nil {
t.Fatalf("Unable to start up DecayedLog: %v", err) t.Fatalf("Unable to start up DecayedLog: %v", err)
@ -120,6 +122,8 @@ func TestDecayedLogGarbageCollector(t *testing.T) {
// We test that this causes the <hashedSecret, CLTV> pair to be deleted even // We test that this causes the <hashedSecret, CLTV> pair to be deleted even
// on GC restarts. // on GC restarts.
func TestDecayedLogPersistentGarbageCollector(t *testing.T) { func TestDecayedLogPersistentGarbageCollector(t *testing.T) {
t.Parallel()
d, _, hashedSecret, err := startup(true) d, _, hashedSecret, err := startup(true)
if err != nil { if err != nil {
t.Fatalf("Unable to start up DecayedLog: %v", err) t.Fatalf("Unable to start up DecayedLog: %v", err)
@ -166,6 +170,8 @@ func TestDecayedLogPersistentGarbageCollector(t *testing.T) {
// sharedHashBucket and then deletes it and finally asserts that we can no // sharedHashBucket and then deletes it and finally asserts that we can no
// longer retrieve it. // longer retrieve it.
func TestDecayedLogInsertionAndDeletion(t *testing.T) { func TestDecayedLogInsertionAndDeletion(t *testing.T) {
t.Parallel()
d, _, hashedSecret, err := startup(false) d, _, hashedSecret, err := startup(false)
if err != nil { if err != nil {
t.Fatalf("Unable to start up DecayedLog: %v", err) t.Fatalf("Unable to start up DecayedLog: %v", err)
@ -200,6 +206,8 @@ func TestDecayedLogInsertionAndDeletion(t *testing.T) {
// cltv value is indeed still stored in the sharedHashBucket. We then delete // cltv value is indeed still stored in the sharedHashBucket. We then delete
// the cltv value and check that it persists upon startup. // the cltv value and check that it persists upon startup.
func TestDecayedLogStartAndStop(t *testing.T) { func TestDecayedLogStartAndStop(t *testing.T) {
t.Parallel()
d, _, hashedSecret, err := startup(false) d, _, hashedSecret, err := startup(false)
if err != nil { if err != nil {
t.Fatalf("Unable to start up DecayedLog: %v", err) t.Fatalf("Unable to start up DecayedLog: %v", err)
@ -262,6 +270,8 @@ func TestDecayedLogStartAndStop(t *testing.T) {
// via the nested sharedHashBucket and finally asserts that the original stored // via the nested sharedHashBucket and finally asserts that the original stored
// and retrieved cltv values are equal. // and retrieved cltv values are equal.
func TestDecayedLogStorageAndRetrieval(t *testing.T) { func TestDecayedLogStorageAndRetrieval(t *testing.T) {
t.Parallel()
d, _, hashedSecret, err := startup(false) d, _, hashedSecret, err := startup(false)
if err != nil { if err != nil {
t.Fatalf("Unable to start up DecayedLog: %v", err) t.Fatalf("Unable to start up DecayedLog: %v", err)