intra-cluster networking: net/http client
()
| 26 | |
| 27 | // intra-cluster networking: net/http client |
| 28 | func NewIntraDataClient() (client *http.Client) { |
| 29 | config := cmn.GCO.Get() |
| 30 | |
| 31 | // compare with ais/httpcommon.go |
| 32 | wbuf, rbuf := config.Net.HTTP.WriteBufferSize, config.Net.HTTP.ReadBufferSize |
| 33 | if wbuf == 0 { |
| 34 | wbuf = cmn.DefaultWriteBufferSize |
| 35 | } |
| 36 | if rbuf == 0 { |
| 37 | rbuf = cmn.DefaultReadBufferSize |
| 38 | } |
| 39 | tcpbuf := config.Net.L4.SndRcvBufSize |
| 40 | if tcpbuf == 0 { |
| 41 | tcpbuf = cmn.DefaultSendRecvBufferSize |
| 42 | } |
| 43 | return cmn.NewClient(cmn.TransportArgs{ |
| 44 | SndRcvBufSize: tcpbuf, |
| 45 | WriteBufferSize: wbuf, |
| 46 | ReadBufferSize: rbuf, |
| 47 | UseHTTPS: config.Net.HTTP.UseHTTPS, |
| 48 | SkipVerify: config.Net.HTTP.SkipVerify, |
| 49 | }) |
| 50 | } |
| 51 | |
| 52 | func (s *streamBase) do(body io.Reader) (err error) { |
| 53 | var ( |