MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-11-09 21:49:46 -05:00
Code Issues Packages Projects Releases Wiki Activity

rpc: Do not use read/write deadlines for rpc connections. (#4647)

Browse Source 
Fixes #4626
This commit is contained in:
Harshavardhana
2017-07-18 08:30:46 -08:00
committed by Krishna Srinivas
parent c59b995f7b
commit f8bd9cfd83
9 changed files with 159 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/storage-rpc-server.go
View File

@@ -18,7 +18,6 @@ package cmd
import (
"io"
"net/rpc"
"path"
"time"
@@ -217,7 +216,7 @@ func (s *storageServer) RenameFileHandler(args *RenameFileArgs, reply *AuthRPCRe
}
// Initialize new storage rpc.
func newRPCServer(endpoints EndpointList) (servers []*storageServer, err error) {
func newStorageRPCServer(endpoints EndpointList) (servers []*storageServer, err error) {
for _, endpoint := range endpoints {
if endpoint.IsLocal {
storage, err := newPosix(endpoint.Path)
@@ -238,14 +237,14 @@ func newRPCServer(endpoints EndpointList) (servers []*storageServer, err error)
// registerStorageRPCRouter - register storage rpc router.
func registerStorageRPCRouters(mux *router.Router, endpoints EndpointList) error {
// Initialize storage rpc servers for every disk that is hosted on this node.
storageRPCs, err := newRPCServer(endpoints)
storageRPCs, err := newStorageRPCServer(endpoints)
if err != nil {
return traceError(err)
}
// Create a unique route for each disk exported from this node.
for _, stServer := range storageRPCs {
storageRPCServer := rpc.NewServer()
storageRPCServer := newRPCServer()
err = storageRPCServer.RegisterName("Storage", stServer)
if err != nil {
return traceError(err)