@ -10,8 +10,8 @@ import (
"sync"
"github.com/chrislusf/seaweedfs/weed/util"
"github.com/chrislusf/seaweedfs/weed/glog"
)
var (
@ -1,15 +1,14 @@
package operation
import (
"context"
"errors"
"fmt"
"net/http"
"strings"
"github.com/chrislusf/seaweedfs/weed/pb/volume_server_pb"
type DeleteResult struct {
@ -2,12 +2,12 @@ package operation
"strconv"
"github.com/chrislusf/seaweedfs/weed/pb/master_pb"
@ -1,6 +1,7 @@
"encoding/json"
@ -9,9 +10,8 @@ import (
"time"
type Location struct {
@ -19,8 +19,8 @@ import (
_ "github.com/chrislusf/seaweedfs/weed/statik"
statik "github.com/rakyll/statik/fs"
"github.com/gorilla/mux"
var serverStats *stats.ServerStats
@ -1,8 +1,9 @@
package weed_server
func (ms *MasterServer) LookupVolume(ctx context.Context, req *master_pb.LookupVolumeRequest) (*master_pb.LookupVolumeResponse, error) {
@ -66,7 +66,6 @@ func (vc *vidMap) LookupVolumeServer(fileId string) (volumeServer string, err er
return serverUrl, nil
}
func (vc *vidMap) GetLocations(vid uint32) (locations []Location) {
vc.RLock()
defer vc.RUnlock()