| 147 | } |
| 148 | |
| 149 | func (fp *frontendProcessor) runRequests(ctx context.Context, requests []*httpgrpc.HTTPRequest) []*httpgrpc.HTTPResponse { |
| 150 | wg := sync.WaitGroup{} |
| 151 | |
| 152 | responses := make([]*httpgrpc.HTTPResponse, len(requests)) |
| 153 | for i, request := range requests { |
| 154 | wg.Add(1) |
| 155 | go func(i int, request *httpgrpc.HTTPRequest) { |
| 156 | defer wg.Done() |
| 157 | responses[i] = fp.runRequest(ctx, request) |
| 158 | }(i, request) |
| 159 | } |
| 160 | wg.Wait() |
| 161 | return responses |
| 162 | } |
| 163 | |
| 164 | func (fp *frontendProcessor) runRequest(ctx context.Context, request *httpgrpc.HTTPRequest) *httpgrpc.HTTPResponse { |
| 165 | carrier := (*httpgrpcutil.HttpgrpcHeadersCarrier)(request) |