| /dports/security/keybase/client-v5.7.1/go/chat/ |
| H A D | convloader_test.go | 49 require.NoError(t, tc.Context().ConvLoader.Queue(ctx,
99 require.NoError(t, tc.Context().ConvLoader.Queue(context.TODO(),
106 require.True(t, tc.Context().ConvLoader.Suspend(context.TODO()))
112 require.False(t, tc.Context().ConvLoader.Suspend(context.TODO()))
115 require.False(t, tc.Context().ConvLoader.Resume(context.TODO()))
121 require.True(t, tc.Context().ConvLoader.Resume(context.TODO()))
136 tc.ChatG.ConvLoader.(*BackgroundConvLoader).loadWait = 0
137 tc.ChatG.ConvLoader.(*BackgroundConvLoader).clock = clock
149 require.NoError(t, tc.Context().ConvLoader.Queue(context.TODO(),
158 require.True(t, tc.Context().ConvLoader.Suspend(context.TODO()))
[all …]
|
| H A D | localizer_test.go | 26 <-tc.Context().ConvLoader.Stop(ctx)
|
| H A D | convloader.go | 141 var _ types.ConvLoader = (*BackgroundConvLoader)(nil)
553 if err := g.ConvLoader.Queue(ctx, job); err != nil {
|
| H A D | ephemeral_purger_test.go | 169 require.NoError(t, tc.Context().ConvLoader.Queue(context.TODO(),
173 require.NoError(t, tc.Context().ConvLoader.Queue(context.TODO(),
|
| H A D | sync.go | 468 if err := s.G().ConvLoader.Queue(ctx, job); err != nil {
482 if err := s.G().ConvLoader.Queue(ctx, job); err != nil {
|
| H A D | ephemeral_tracker_test.go | 52 <-g.ConvLoader.Stop(context.TODO())
|
| H A D | convsource_test.go | 539 <-tc.ChatG.ConvLoader.Stop(context.Background())
635 <-tc.Context().ConvLoader.Stop(context.TODO())
715 <-tc.Context().ConvLoader.Stop(context.TODO())
|
| H A D | ephemeral_purger.go | 332 if err := b.G().ConvLoader.Queue(ctx, job); err != nil {
|
| H A D | uithreadloader_test.go | 196 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
469 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
|
| H A D | sync_test.go | 846 tc.Context().ConvLoader.(*BackgroundConvLoader).loadWait = 0
847 tc.Context().ConvLoader.(*BackgroundConvLoader).loads = bgLoads
848 tc.Context().ConvLoader.Start(ctx, uid)
|
| H A D | convsource.go | 62 err := s.G().ConvLoader.Queue(ctx, types.NewConvLoaderJob(convID, &chat1.Pagination{Num: 0},
969 if err := s.G().ConvLoader.Queue(ctx, types.NewConvLoaderJob(convID, &chat1.Pagination{Num: 0},
|
| H A D | uithreadloader.go | 292 if err := t.G().ConvLoader.Queue(ctx, types.NewConvLoaderJob(convID, p,
|
| H A D | sender_test.go | 282 g.ConvLoader = convLoader
283 g.ConvLoader.Start(context.TODO(), uid)
|
| H A D | server_test.go | 450 g.ConvLoader = NewBackgroundConvLoader(g)
3249 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
3400 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx1)
3401 <-ctc.as(t, users[1]).h.G().ConvLoader.Stop(ctx2)
3575 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
3686 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
3782 ctc.as(t, users[0]).h.G().ConvLoader.Start(ctx, uid)
3783 ctc.as(t, users[0]).h.G().ConvLoader.(*BackgroundConvLoader).loads = bgConvLoads
4070 <-ctc.as(t, users[0]).h.G().ConvLoader.Stop(ctx)
|
| H A D | helper.go | 963 defer utils.SuspendComponent(ctx, g, g.ConvLoader)()
|
| H A D | inboxsource.go | 953 if err := s.G().ConvLoader.Queue(ctx, job); err != nil {
|
| H A D | server.go | 154 h.G().ConvLoader,
|
| /dports/security/keybase/client-v5.7.1/go/chat/globals/ |
| H A D | globals.go | 26 ConvLoader types.ConvLoader // background conversation loader member
64 ConvLoader: %v,
99 c.ConvLoader != nil,
|
| /dports/security/keybase/client-v5.7.1/go/runtimestats/ |
| H A D | stats.go | 143 stats.ConvLoaderActive = r.G().ConvLoader.IsBackgroundActive()
|
| /dports/security/keybase/client-v5.7.1/go/service/ |
| H A D | main.go | 424 g.ConvLoader.Start(context.Background(), uid)
444 <-d.ChatG().ConvLoader.Stop(m.Ctx())
489 g.ConvLoader = chat.NewBackgroundConvLoader(g)
|
| /dports/security/keybase/client-v5.7.1/go/kbtest/ |
| H A D | chat.go | 52 if c.ChatG.ConvLoader != nil {
53 <-c.ChatG.ConvLoader.Stop(context.TODO())
|
| /dports/security/keybase/client-v5.7.1/go/chat/types/ |
| H A D | interfaces.go | 273 type ConvLoader interface { interface
|