Function TestAllThreads

thread_test.go:30–47

(t *testing.T)

)

func TestAllThreads(t *testing.T) {
	fixFS := getProcFixtures(t)
	threads, err := fixFS.AllThreads(testPID)
	if err != nil {
		t.Fatal(err)
	}
	sort.Sort(threads)
	for i, tid := range testTIDS {
		if diff := cmp.Diff(tid, threads[i].PID); diff != "" {
			t.Fatalf("unexpected diff (-want +got):\n%s", diff)
		}
		wantFS := fixFS.proc.Path(strconv.Itoa(testPID), "task")
		haveFS := string(threads[i].fs.proc)
		if diff := cmp.Diff(wantFS, haveFS); diff != "" {
			t.Fatalf("unexpected diff (-want +got):\n%s", diff)
		}
	}
}

func TestThreadStat(t *testing.T) {
	// Pull process and thread stats.