Home
last modified time | relevance | path

Searched refs:purgeInfo (Results 1 – 8 of 8) sorted by relevance

/dports/security/keybase/client-v5.7.1/go/chat/
H A Dephemeral_purger.go31 return q.purgeInfo.String()
61 return pq.queue[i].purgeInfo.NextPurgeTime < pq.queue[j].purgeInfo.NextPurgeTime
193 if ok && item.purgeInfo.Eq(purgeInfo) {
197 if !purgeInfo.IsActive {
211 if head == nil || purgeInfo.NextPurgeTime < head.purgeInfo.NextPurgeTime {
214 b.updateQueue(purgeInfo)
241 if purgeInfo.IsActive {
242 b.updateQueue(purgeInfo)
250 item.purgeInfo = purgeInfo
253 heap.Push(b.pq, &queueItem{purgeInfo: purgeInfo})
[all …]
H A Dephemeral_purge_tracker.go273 if purgeInfo == nil {
277 if err = t.put(ctx, uid, convID, *purgeInfo); err != nil {
281 return t.G().EphemeralPurger.Queue(ctx, *purgeInfo)
291 if purgeInfo == nil || purgeInfo.IsNil() {
301 purgeInfo.IsActive = true
304 if purgeInfo.MinUnexplodedID == 0 || cache.info.MinUnexplodedID < purgeInfo.MinUnexplodedID {
305 purgeInfo.MinUnexplodedID = cache.info.MinUnexplodedID
307 …if purgeInfo.NextPurgeTime == 0 || (cache.info.NextPurgeTime != 0 && cache.info.NextPurgeTime < pu…
308 purgeInfo.NextPurgeTime = cache.info.NextPurgeTime
311 if cache != nil && purgeInfo.Eq(cache.info) {
[all …]
H A Dephemeral_purger_test.go133 purgeInfo, err := g.EphemeralTracker.GetPurgeInfo(ctx, uid, convID)
139 require.Equal(t, expectedPurgeInfo, purgeInfo)
388 purgeInfo := chat1.EphemeralPurgeInfo{
395 err := purger.Queue(ctx, purgeInfo)
401 require.Equal(t, purgeInfo, queueItem.purgeInfo)
416 require.Equal(t, purgeInfo2, queueItem.purgeInfo)
431 require.Equal(t, purgeInfo3, queueItem.purgeInfo)
H A Dephemeral_tracker_test.go122 purgeInfo, err := g.EphemeralTracker.GetPurgeInfo(ctx, uid, convID)
129 require.Equal(t, *expectedPurgeInfo, purgeInfo)
133 purgeInfo, _ := g.EphemeralTracker.GetPurgeInfo(ctx, uid, convID)
134 newPurgeInfo, purgedMsgs, err := chatStorage.EphemeralPurge(ctx, convID, uid, &purgeInfo)
H A Dconvsource.go420 …uid gregor1.UID, purgeInfo *chat1.EphemeralPurgeInfo) (*chat1.EphemeralPurgeInfo, []chat1.MessageU…
1264 …purgeInfo *chat1.EphemeralPurgeInfo) (newPurgeInfo *chat1.EphemeralPurgeInfo, explodedMsgs []chat1…
1267 …if newPurgeInfo, explodedMsgs, err = s.storage.EphemeralPurge(ctx, convID, uid, purgeInfo); err !=…
/dports/security/keybase/client-v5.7.1/go/chat/storage/
H A Dstorage_ephemeral_purge.go12 …urge(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.Ephemeral…
19 if purgeInfo == nil {
40 maxHoles := int(maxMsgID-purgeInfo.MinUnexplodedID) + 1
42 if purgeInfo.MinUnexplodedID == 0 {
83 purgeInfo, explodedMsgs, err := s.ephemeralPurgeHelper(ctx, convID, uid, msgs)
89 ierr := s.G().EphemeralTracker.MaybeUpdatePurgeInfo(ctx, convID, uid, purgeInfo)
100 …uid gregor1.UID, msgs []chat1.MessageUnboxed) (purgeInfo *chat1.EphemeralPurgeInfo, explodedMsgs […
/dports/security/keybase/client-v5.7.1/go/chat/types/
H A Dtypes.go483 func (d DummyEphemeralPurger) Queue(ctx context.Context, purgeInfo chat1.EphemeralPurgeInfo) error {
889 …Info(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.Ephemeral…
892 …Info(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.Ephemeral…
H A Dinterfaces.go110 purgeInfo *chat1.EphemeralPurgeInfo) (*chat1.EphemeralPurgeInfo, []chat1.MessageUnboxed, error)
424 Queue(ctx context.Context, purgeInfo chat1.EphemeralPurgeInfo) error
645 …SetPurgeInfo(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo *chat1.E…
646 …MaybeUpdatePurgeInfo(ctx context.Context, convID chat1.ConversationID, uid gregor1.UID, purgeInfo …