Method invoke

core/pool/brutepool.go:301–388

(v interface{})

}

func (pool *BrutePool) invoke(v interface{}) {
	defer pool.wg.Done()
	unit := v.(*Unit)
	if pool.RateLimit != 0 {
		if err := pool.limiter.Wait(pool.ctx); err != nil {
			bl := &baseline.Baseline{
				SprayResult: &parsers.SprayResult{
					UrlString: unit.path,
					ErrString: err.Error(),
					Reason:    pkg.ErrRequestFailed.Error(),
				},
			}
			bl.Number = unit.number
			bl.Parent = unit.parent
			bl.Source = unit.source
			bl.From = unit.from
			bl.ReqDepth = unit.depth
			bl.Retry = unit.retry
			pool.sendProcess(bl)
			return
		}
	}

	// 使用RequestConfig.Build()构建请求
	req, err := pool.Request.Build(pool.ctx, pool.ClientType, pool.base, unit.path, unit.host, unit.word)
	if err != nil {
		logs.Log.Debug(err.Error())
		bl := &baseline.Baseline{
			SprayResult: &parsers.SprayResult{
				UrlString: unit.path,
				ErrString: err.Error(),
				Reason:    pkg.ErrUrlError.Error(),
			},
		}
		bl.Number = unit.number
		bl.Parent = unit.parent
		bl.Source = unit.source
		bl.From = unit.from
		bl.ReqDepth = unit.depth
		bl.Retry = unit.retry
		pool.sendProcess(bl)
		return
	}

	start := time.Now()
	resp, reqerr := pool.client.Do(req)
	if pool.ClientType == ihttp.FAST {
		defer fasthttp.ReleaseResponse(resp.FastResponse)
		defer fasthttp.ReleaseRequest(req.FastRequest)
	}

	// compare与各种错误处理
	var bl *baseline.Baseline
	if reqerr != nil && !errors.Is(reqerr, fasthttp.ErrBodyTooLarge) {
		bl = &baseline.Baseline{
			SprayResult: &parsers.SprayResult{
				UrlString: req.URI(),
				ErrString: reqerr.Error(),