mirror of
https://github.com/aler9/gortsplib
synced 2025-10-05 15:16:51 +08:00
client: log every incoming response (#409)
This commit is contained in:
@@ -583,7 +583,8 @@ func (c *Client) runInner() error {
|
|||||||
c.reader = nil
|
c.reader = nil
|
||||||
return err
|
return err
|
||||||
|
|
||||||
case <-c.chReadResponse:
|
case res := <-c.chReadResponse:
|
||||||
|
c.OnResponse(res)
|
||||||
return liberrors.ErrClientUnexpectedResponse{}
|
return liberrors.ErrClientUnexpectedResponse{}
|
||||||
|
|
||||||
case req := <-c.chReadRequest:
|
case req := <-c.chReadRequest:
|
||||||
@@ -612,6 +613,7 @@ func (c *Client) waitResponse() (*base.Response, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
|
|
||||||
case res := <-c.chReadResponse:
|
case res := <-c.chReadResponse:
|
||||||
|
c.OnResponse(res)
|
||||||
return res, nil
|
return res, nil
|
||||||
|
|
||||||
case req := <-c.chReadRequest:
|
case req := <-c.chReadRequest:
|
||||||
@@ -916,8 +918,6 @@ func (c *Client) do(req *base.Request, skipResponse bool) (*base.Response, error
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
c.OnResponse(res)
|
|
||||||
|
|
||||||
// get session from response
|
// get session from response
|
||||||
if v, ok := res.Header["Session"]; ok {
|
if v, ok := res.Header["Session"]; ok {
|
||||||
var sx headers.Session
|
var sx headers.Session
|
||||||
|
Reference in New Issue
Block a user