Function TestContextInternalsCoverage

context_test.go:1316–1661

(t *testing.T)

}

func TestContextInternalsCoverage(t *testing.T) {
	t.Run("ScheduleEdgeCases", func(t *testing.T) {
		var nilCtx *Context
		require.False(t, nilCtx.Schedule(func(*Context) {}))

		ctx := &Context{}
		require.False(t, ctx.Schedule(func(*Context) {}))

		ctx.initScheduler()
		require.False(t, ctx.Schedule(nil))

		close(ctx.jobClosed)
		require.False(t, ctx.Schedule(func(*Context) {}))

		blockingCtx := &Context{
			jobQueue:  make(chan func(*Context), 1),
			jobClosed: make(chan struct{}),
		}
		blockingCtx.jobQueue <- func(*Context) {}
		done := make(chan struct{})
		go func() {
			time.Sleep(5 * time.Millisecond)
			close(blockingCtx.jobClosed)
			close(done)
		}()
		require.False(t, blockingCtx.Schedule(func(*Context) {}))
		<-done
	})

	t.Run("ProcessJobsAndDrainJobs", func(t *testing.T) {
		var nilCtx *Context
		require.NotPanics(t, func() { nilCtx.ProcessJobs() })
		require.NotPanics(t, func() { nilCtx.drainJobs() })

		emptyCtx := &Context{}
		require.NotPanics(t, func() { emptyCtx.ProcessJobs() })
		require.NotPanics(t, func() { emptyCtx.drainJobs() })

		emptyCtx.initScheduler()
		var calls int
		require.True(t, emptyCtx.Schedule(func(inner *Context) {
			require.Same(t, emptyCtx, inner)
			calls++
		}))
		emptyCtx.jobQueue <- nil
		emptyCtx.ProcessJobs()
		require.Equal(t, 1, calls)

		emptyCtx.jobQueue <- func(*Context) {}
		emptyCtx.jobQueue <- nil
		emptyCtx.drainJobs()
		require.Equal(t, 0, len(emptyCtx.jobQueue))
	})

	t.Run("DuplicateValue", func(t *testing.T) {
		rt := NewRuntime()
		defer rt.Close()
		ctx := rt.NewContext()