Skip to content

Commit 1e09248

Browse files
committed
adding cleanup fix update
1 parent 8d57c25 commit 1e09248

File tree

3 files changed

+6
-22
lines changed

3 files changed

+6
-22
lines changed

internal/mode/static/manager.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ const (
6363
)
6464

6565
var scheme = runtime.NewScheme()
66-
var proccesHandler = &ngxruntime.ProcessHandlerImpl{}
66+
var processHandler = &ngxruntime.ProcessHandlerImpl{}
6767

6868
func init() {
6969
utilruntime.Must(gatewayv1beta1.Install(scheme))
@@ -135,7 +135,7 @@ func StartManager(cfg config.Config) error {
135135
}
136136

137137
// Ensure NGINX is running before registering metrics & starting the manager.
138-
if err := proccesHandler.EnsureNginxRunning(ctx); err != nil {
138+
if err := processHandler.EnsureNginxRunning(ctx); err != nil {
139139
return fmt.Errorf("NGINX is not running: %w", err)
140140
}
141141

@@ -212,7 +212,7 @@ func StartManager(cfg config.Config) error {
212212
ngxPlusClient,
213213
ngxruntimeCollector,
214214
cfg.Logger.WithName("nginxRuntimeManager"),
215-
proccesHandler,
215+
processHandler,
216216
ngxruntime.NewVerifyClient(ngxruntime.NginxReloadTimeout),
217217
),
218218
statusUpdater: groupStatusUpdater,

internal/mode/static/nginx/runtime/manager.go

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -225,19 +225,9 @@ func (p *ProcessHandlerImpl) FindMainProcess(
225225
}
226226

227227
func (p *ProcessHandlerImpl) ReadFile(file string) ([]byte, error) {
228-
content, err := os.ReadFile(file)
229-
if err != nil {
230-
return nil, err
231-
}
232-
233-
return content, nil
228+
return os.ReadFile(file)
234229
}
235230

236231
func (p *ProcessHandlerImpl) Kill(pid int, signum syscall.Signal) error {
237-
err := syscall.Kill(pid, syscall.SIGHUP)
238-
if err != nil {
239-
return err
240-
}
241-
242-
return nil
232+
return syscall.Kill(pid, syscall.SIGHUP)
243233
}

internal/mode/static/nginx/runtime/manager_test.go

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@ var _ = Describe("NGINX Runtime Manager", func() {
2828
var (
2929
manager runtime.Manager
3030
upstreamServers []ngxclient.UpstreamServer
31-
upstreamServer ngxclient.UpstreamServer
3231
ngxPlusClient *runtimefakes.FakeNginxPlusClient
3332
process *runtimefakes.FakeProcessHandler
3433

@@ -37,12 +36,9 @@ var _ = Describe("NGINX Runtime Manager", func() {
3736
)
3837

3938
BeforeEach(func() {
40-
upstreamServer = ngxclient.UpstreamServer{}
41-
4239
upstreamServers = []ngxclient.UpstreamServer{
43-
upstreamServer,
40+
ngxclient.UpstreamServer{},
4441
}
45-
4642
})
4743

4844
Context("Reload", func() {
@@ -98,7 +94,6 @@ var _ = Describe("NGINX Runtime Manager", func() {
9894
})
9995

10096
It("sucessfully updates HTTP server upstream", func() {
101-
10297
Expect(manager.UpdateHTTPServers("test", upstreamServers)).To(Succeed())
10398
})
10499

@@ -226,7 +221,6 @@ func TestFindMainProcess(t *testing.T) {
226221
g := NewWithT(t)
227222
p := runtime.ProcessHandlerImpl{}
228223
result, err := p.FindMainProcess(test.ctx, test.checkFile, test.readFile, 2*time.Millisecond)
229-
//result, err := runtime.FindMainProcess(test.ctx, test.checkFile, test.readFile, 2*time.Millisecond)
230224

231225
if test.expectError {
232226
g.Expect(err).To(HaveOccurred())

0 commit comments

Comments
 (0)