Lines Matching refs:req
77 req *request
83 func newResponse(c *child, req *request) *response {
85 req: req,
87 w: newWriter(c.conn, typeStdout, req.reqId),
181 req, ok := c.requests[rec.h.Id]
190 if req != nil {
204 req = newRequest(rec.h.Id, br.flags)
206 c.requests[rec.h.Id] = req
213 req.rawParams = append(req.rawParams, rec.content()...)
216 req.parseParams()
220 if req.pw == nil {
225 body, req.pw = io.Pipe()
229 go c.serveRequest(req, body)
234 req.pw.Write(content)
235 } else if req.pw != nil {
236 req.pw.Close()
251 if req.pw != nil {
252 req.pw.CloseWithError(ErrRequestAborted)
254 if !req.keepConn {
279 func (c *child) serveRequest(req *request, body io.ReadCloser) {
280 r := newResponse(c, req)
281 httpReq, err := cgi.RequestFromMap(req.params)
285 c.conn.writeRecord(typeStderr, req.reqId, []byte(err.Error()))
288 withoutUsedEnvVars := filterOutUsedEnvVars(req.params)
295 delete(c.requests, req.reqId)
297 c.conn.writeEndRequest(req.reqId, 0, statusRequestComplete)
309 if !req.keepConn {
317 for _, req := range c.requests {
318 if req.pw != nil {
321 req.pw.CloseWithError(ErrConnClosed)
