Skip to content

Commit e6af242

Browse files
Added gRPC pools to permProcessor
1 parent 5586120 commit e6af242

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

cmd/laclm/main.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,7 @@ func run(ctx context.Context) error {
182182
grpc.WithKeepaliveParams(kacp),
183183
)
184184

185+
/* THIS CODE IS SAFE TO BE REMOVED */
185186
for _, system := range config.BackendConfig.FileSystemServers {
186187
/* check if system is remote */
187188
if system.Remote != nil {
@@ -215,7 +216,7 @@ func run(ctx context.Context) error {
215216
sessionManager := session.NewManager(logRedisClient, archivalPQ, errChLog)
216217

217218
/* create a permissions processor */
218-
permProcessor := transprocessor.NewPermProcessor(errChLog)
219+
permProcessor := transprocessor.NewPermProcessor(pool, errChLog)
219220

220221
/* handle session and processor errors */
221222
wg.Add(1)

0 commit comments

Comments
 (0)