| 232 | } |
| 233 | |
| 234 | func (p *Proxy) initFilters() { |
| 235 | for _, filter := range p.cfg.Filers { |
| 236 | f, err := p.newFilter(filter) |
| 237 | if nil != err { |
| 238 | log.Fatalf("init filter failed, filter=<%+v> errors:\n%+v", |
| 239 | filter, |
| 240 | err) |
| 241 | } |
| 242 | |
| 243 | err = f.Init(filter.ExternalCfg) |
| 244 | if nil != err { |
| 245 | log.Fatalf("init filter failed, filter=<%+v> errors:\n%+v", |
| 246 | filter, |
| 247 | err) |
| 248 | } |
| 249 | |
| 250 | log.Infof("filter added, filter=<%+v>", filter) |
| 251 | p.filters = append(p.filters, f) |
| 252 | p.filtersMap[f.Name()] = f |
| 253 | } |
| 254 | } |
| 255 | |
| 256 | func (p *Proxy) readyToDispatch() { |
| 257 | for i := uint64(0); i < p.cfg.Option.LimitCountDispatchWorker; i++ { |