Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-27 09:14:44 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

加速rpc访问

Browse Source
This commit is contained in:
boyce
2019-01-30 18:29:26 +08:00
parent 71f47b88ba
commit b290834b2f
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
rpc/client.go
View File

@@ -247,9 +247,13 @@ func DialHTTP(network, address string) (*Client, error) {
func DialHTTPPath(network, address, path string) (*Client, error) { func DialHTTPPath(network, address, path string) (*Client, error) {
var err error var err error
conn, err := net.Dial(network, address) conn, err := net.Dial(network, address)
if err != nil { if err != nil {
return nil, err return nil, err
} }
tcpconn, _ := conn.(*net.TCPConn)
tcpconn.SetNoDelay(true)
io.WriteString(conn, "CONNECT "+path+" HTTP/1.0\n\n") io.WriteString(conn, "CONNECT "+path+" HTTP/1.0\n\n")
// Require successful HTTP response // Require successful HTTP response
@@ -276,6 +280,9 @@ func Dial(network, address string) (*Client, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
tcpconn, _ := conn.(*net.TCPConn)
tcpconn.SetNoDelay(true)
return NewClient(conn), nil return NewClient(conn), nil
} }