NotificationsYou must be signed in to change notification settings
Fork1k
Star11.2k

Commitcea4851

committed

prevent race

1 parent8aaa6d5 commitcea4851Copy full SHA for cea4851

File tree

1 file changed

+30

-4

lines changed

agent
- agent_test.go

1 file changed

+30

-4

lines changed

`‎agent/agent_test.go‎`

Lines changed: 30 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -2525,14 +2525,21 @@ func TestAgent_ManageProcessPriority(t *testing.T) {`
`2525`	`2525`	`t.Skip("Skipping non-linux environment")`
`2526`	`2526`	`}`
`2527`	`2527`
`2528`		`-varbuf bytes.Buffer`
`2529`		`-log:=slog.Make(sloghuman.Sink(&buf)).Leveled(slog.LevelDebug)`
	`2528`	`+var (`
	`2529`	`+buf bytes.Buffer`
	`2530`	`+wr=&syncWriter{`
	`2531`	`+w:&buf,`
	`2532`	`+}`
	`2533`	`+)`
	`2534`	`+log:=slog.Make(sloghuman.Sink(wr)).Leveled(slog.LevelDebug)`
`2530`	`2535`
`2531`	`2536`	`_,_,_,_,_=setupAgent(t, agentsdk.Manifest{},0,func(cagenttest.Client,oagent.Options) {`
`2532`	`2537`	`o.Logger=log`
`2533`	`2538`	`})`
`2534`	`2539`
`2535`	`2540`	`require.Eventually(t,func()bool {`
	`2541`	`+wr.mu.Lock()`
	`2542`	`+deferwr.mu.Unlock()`
`2536`	`2543`	`returnstrings.Contains(buf.String(),"process priority not enabled")`
`2537`	`2544`	`},testutil.WaitLong,testutil.IntervalFast)`
`2538`	`2545`	`})`
`@@ -2544,8 +2551,13 @@ func TestAgent_ManageProcessPriority(t *testing.T) {`
`2544`	`2551`	`t.Skip("Skipping linux environment")`
`2545`	`2552`	`}`
`2546`	`2553`
`2547`		`-varbuf bytes.Buffer`
`2548`		`-log:=slog.Make(sloghuman.Sink(&buf)).Leveled(slog.LevelDebug)`
	`2554`	`+var (`
	`2555`	`+buf bytes.Buffer`
	`2556`	`+wr=&syncWriter{`
	`2557`	`+w:&buf,`
	`2558`	`+}`
	`2559`	`+)`
	`2560`	`+log:=slog.Make(sloghuman.Sink(wr)).Leveled(slog.LevelDebug)`
`2549`	`2561`
`2550`	`2562`	`_,_,_,_,_=setupAgent(t, agentsdk.Manifest{},0,func(cagenttest.Client,oagent.Options) {`
`2551`	`2563`	`o.Logger=log`
`@@ -2554,6 +2566,9 @@ func TestAgent_ManageProcessPriority(t *testing.T) {`
`2554`	`2566`	`o.EnvironmentVariables=map[string]string{agent.EnvProcPrioMgmt:"1"}`
`2555`	`2567`	`})`
`2556`	`2568`	`require.Eventually(t,func()bool {`
	`2569`	`+wr.mu.Lock()`
	`2570`	`+deferwr.mu.Unlock()`
	`2571`	`+`
`2557`	`2572`	`returnstrings.Contains(buf.String(),"process priority not enabled")`
`2558`	`2573`	`},testutil.WaitLong,testutil.IntervalFast)`
`2559`	`2574`	`})`
`@@ -2580,3 +2595,14 @@ func verifyCollectedMetrics(t *testing.T, expected []agentsdk.AgentMetric, actua`
`2580`	`2595`	`}`
`2581`	`2596`	`returntrue`
`2582`	`2597`	`}`
	`2598`	`+`
	`2599`	`+typesyncWriterstruct {`
	`2600`	`+mu sync.Mutex`
	`2601`	`+w io.Writer`
	`2602`	`+}`
	`2603`	`+`
	`2604`	`+func (s*syncWriter)Write(p []byte) (int,error) {`
	`2605`	`+s.mu.Lock()`
	`2606`	`+defers.mu.Unlock()`
	`2607`	`+returns.w.Write(p)`
	`2608`	`+}`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitcea4851

File tree

1 file changed

1 file changed

`‎agent/agent_test.go‎`

0 commit comments