diff options
| author | devonh <devon.dmytro@gmail.com> | 2023-01-28 23:27:53 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-28 23:27:53 +0000 |
| commit | 63df85db6d5bc528a784dc52e550fc64385c5f67 (patch) | |
| tree | 80da0f2cbcf9f4473974e600f90f20aed9803707 /federationapi/queue/queue_test.go | |
| parent | 2debabf0f09bb6e55063bbaa00dfb77090789abc (diff) | |
Relay integration to pinecone demos (#2955)
This extends the dendrite monolith for pinecone to integrate the s&f
features into the mobile apps.
Also makes a few tweaks to federation queueing/statistics to make some
edge cases more robust.
Diffstat (limited to 'federationapi/queue/queue_test.go')
| -rw-r--r-- | federationapi/queue/queue_test.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/federationapi/queue/queue_test.go b/federationapi/queue/queue_test.go index 36e2ccbc..bccfb342 100644 --- a/federationapi/queue/queue_test.go +++ b/federationapi/queue/queue_test.go @@ -923,7 +923,7 @@ func TestSendPDUOnRelaySuccessRemovedFromDB(t *testing.T) { assert.NoError(t, err) check := func(log poll.LogT) poll.Result { - if fc.txCount.Load() == 1 { + if fc.txCount.Load() >= 1 { if fc.txRelayCount.Load() == 1 { data, dbErr := db.GetPendingPDUs(pc.Context(), destination, 100) assert.NoError(t, dbErr) @@ -962,7 +962,7 @@ func TestSendEDUOnRelaySuccessRemovedFromDB(t *testing.T) { assert.NoError(t, err) check := func(log poll.LogT) poll.Result { - if fc.txCount.Load() == 1 { + if fc.txCount.Load() >= 1 { if fc.txRelayCount.Load() == 1 { data, dbErr := db.GetPendingEDUs(pc.Context(), destination, 100) assert.NoError(t, dbErr) |