gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

switch it back to chris's repo

Browse source
This commit is contained in:
Brian McQueen 2014-12-14 00:35:26 -08:00
parent 57ec736941
commit d56c748fa8
69 changed files with 140 additions and 140 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
go/filer/client_operations.go
View file

@ -5,7 +5,7 @@ import (
"errors" "errors"
"fmt" "fmt"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"net/url" "net/url"
) )

2
go/filer/directory_in_map.go
View file

@ -10,7 +10,7 @@ import (
"strings" "strings"
"sync" "sync"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
var writeLock sync.Mutex //serialize changes to dir.log var writeLock sync.Mutex //serialize changes to dir.log

2
go/filer/filer_embedded.go
View file

@ -6,7 +6,7 @@ import (
"path/filepath" "path/filepath"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
) )
type FilerEmbedded struct { type FilerEmbedded struct {

2
go/filer/files_in_leveldb.go
View file

@ -3,7 +3,7 @@ package filer
import ( import (
"bytes" "bytes"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb"
"github.com/syndtr/goleveldb/leveldb/util" "github.com/syndtr/goleveldb/leveldb/util"
) )

4
go/operation/assign_file_id.go
View file

@ -6,8 +6,8 @@ import (
"net/url" "net/url"
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type AssignResult struct { type AssignResult struct {

2
go/operation/delete_content.go
View file

@ -7,7 +7,7 @@ import (
"strings" "strings"
"sync" "sync"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type DeleteResult struct { type DeleteResult struct {

4
go/operation/list_masters.go
View file

@ -3,8 +3,8 @@ package operation
import ( import (
"encoding/json" "encoding/json"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type ClusterStatusResult struct { type ClusterStatusResult struct {

2
go/operation/lookup.go
View file

@ -9,7 +9,7 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type Location struct { type Location struct {

2
go/operation/submit.go
View file

@ -9,7 +9,7 @@ import (
"strconv" "strconv"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
type FilePart struct { type FilePart struct {

2
go/operation/upload_content.go
View file

@ -14,7 +14,7 @@ import (
"path/filepath" "path/filepath"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
type UploadResult struct { type UploadResult struct {

2
go/storage/cdb_map.go
View file

@ -7,7 +7,7 @@ import (
"os" "os"
"path/filepath" "path/filepath"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/tgulacsi/go-cdb" "github.com/tgulacsi/go-cdb"
) )

2
go/storage/cdb_map_test.go
View file

@ -6,7 +6,7 @@ import (
"runtime" "runtime"
"testing" "testing"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
var testIndexFilename string = "../../test/sample.idx" var testIndexFilename string = "../../test/sample.idx"

4
go/storage/compact_map_perf_test.go
View file

@ -5,8 +5,8 @@ import (
"os" "os"
"testing" "testing"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func TestMemoryUsage(t *testing.T) { func TestMemoryUsage(t *testing.T) {

2
go/storage/compress.go
View file

@ -7,7 +7,7 @@ import (
"io/ioutil" "io/ioutil"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
/* /*

2
go/storage/crc.go
View file

@ -4,7 +4,7 @@ import (
"fmt" "fmt"
"hash/crc32" "hash/crc32"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
var table = crc32.MakeTable(crc32.Castagnoli) var table = crc32.MakeTable(crc32.Castagnoli)

4
go/storage/file_id.go
View file

@ -5,8 +5,8 @@ import (
"errors" "errors"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type FileId struct { type FileId struct {

6
go/storage/needle.go
View file

@ -11,9 +11,9 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/images" "github.com/chrislusf/weed-fs/go/images"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
const ( const (

4
go/storage/needle_map.go
View file

@ -5,8 +5,8 @@ import (
"io" "io"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type NeedleMapper interface { type NeedleMapper interface {

4
go/storage/needle_read_write.go
View file

@ -6,8 +6,8 @@ import (
"io" "io"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
const ( const (

6
go/storage/store.go
View file

@ -10,9 +10,9 @@ import (
"strings" "strings"
proto "code.google.com/p/goprotobuf/proto" proto "code.google.com/p/goprotobuf/proto"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
const ( const (

2
go/storage/store_vacuum.go
View file

@ -4,7 +4,7 @@ import (
"fmt" "fmt"
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func (s *Store) CheckCompactVolume(volumeIdString string, garbageThresholdString string) (error, bool) { func (s *Store) CheckCompactVolume(volumeIdString string, garbageThresholdString string) (error, bool) {

2
go/storage/volume.go
View file

@ -10,7 +10,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
type Volume struct { type Volume struct {

2
go/storage/volume_info.go
View file

@ -1,7 +1,7 @@
package storage package storage
import ( import (
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
) )
type VolumeInfo struct { type VolumeInfo struct {

2
go/storage/volume_super_block.go
View file

@ -4,7 +4,7 @@ import (
"fmt" "fmt"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
const ( const (

2
go/storage/volume_vacuum.go
View file

@ -5,7 +5,7 @@ import (
"os" "os"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func (v *Volume) garbageLevel() float64 { func (v *Volume) garbageLevel() float64 {

2
go/tools/read_index.go
View file

@ -6,7 +6,7 @@ import (
"log" "log"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
var ( var (

4
go/topology/allocate_volume.go
View file

@ -5,8 +5,8 @@ import (
"errors" "errors"
"net/url" "net/url"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type AllocateVolumeResult struct { type AllocateVolumeResult struct {

4
go/topology/cluster_commands.go
View file

@ -1,8 +1,8 @@
package topology package topology
import ( import (
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/goraft/raft" "github.com/goraft/raft"
) )

4
go/topology/collection.go
View file

@ -1,8 +1,8 @@
package topology package topology
import ( import (
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type Collection struct { type Collection struct {

4
go/topology/data_node.go
View file

@ -3,8 +3,8 @@ package topology
import ( import (
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
type DataNode struct { type DataNode struct {

4
go/topology/node.go
View file

@ -5,8 +5,8 @@ import (
"math/rand" "math/rand"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
type NodeId string type NodeId string

8
go/topology/store_replicate.go
View file

@ -5,10 +5,10 @@ import (
"net/http" "net/http"
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func ReplicatedWrite(masterNode string, s *storage.Store, volumeId storage.VolumeId, needle *storage.Needle, r *http.Request) (size uint32, errorStatus string) { func ReplicatedWrite(masterNode string, s *storage.Store, volumeId storage.VolumeId, needle *storage.Needle, r *http.Request) (size uint32, errorStatus string) {

10
go/topology/topology.go
View file

@ -5,11 +5,11 @@ import (
"io/ioutil" "io/ioutil"
"math/rand" "math/rand"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/sequence" "github.com/chrislusf/weed-fs/go/sequence"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/goraft/raft" "github.com/goraft/raft"
) )

4
go/topology/topology_event_handling.go
View file

@ -4,8 +4,8 @@ import (
"math/rand" "math/rand"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
func (t *Topology) StartRefreshWritableVolumes(garbageThreshold string) { func (t *Topology) StartRefreshWritableVolumes(garbageThreshold string) {

6
go/topology/topology_vacuum.go
View file

@ -6,9 +6,9 @@ import (
"net/url" "net/url"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func batchVacuumVolumeCheck(vl *VolumeLayout, vid storage.VolumeId, locationlist *VolumeLocationList, garbageThreshold string) bool { func batchVacuumVolumeCheck(vl *VolumeLayout, vid storage.VolumeId, locationlist *VolumeLocationList, garbageThreshold string) bool {

4
go/topology/volume_growth.go
View file

@ -5,8 +5,8 @@ import (
"math/rand" "math/rand"
"sync" "sync"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
/* /*

4
go/topology/volume_growth_test.go
View file

@ -5,8 +5,8 @@ import (
"fmt" "fmt"
"testing" "testing"
"github.com/mcqueenorama/weed-fs/go/sequence" "github.com/chrislusf/weed-fs/go/sequence"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
var topologyLayout = ` var topologyLayout = `

4
go/topology/volume_layout.go
View file

@ -5,8 +5,8 @@ import (
"math/rand" "math/rand"
"sync" "sync"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
// mapping from volume to its locations, inverted from server to volume // mapping from volume to its locations, inverted from server to volume

2
go/util/config.go
View file

@ -13,7 +13,7 @@ import (
"encoding/json" "encoding/json"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
type Config struct { type Config struct {

2
go/util/file_util.go
View file

@ -5,7 +5,7 @@ import (
"errors" "errors"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func TestFolderWritable(folder string) (err error) { func TestFolderWritable(folder string) (err error) {

2
go/util/net_timeout.go
View file

@ -4,7 +4,7 @@ import (
"net" "net"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/stats" "github.com/chrislusf/weed-fs/go/stats"
) )
// Listener wraps a net.Listener, and gives a place to store the timeout // Listener wraps a net.Listener, and gives a place to store the timeout

6
go/weed/benchmark.go
View file

@ -14,9 +14,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
type BenchmarkOptions struct { type BenchmarkOptions struct {

4
go/weed/compact.go
View file

@ -1,8 +1,8 @@
package main package main
import ( import (
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
func init() { func init() {

4
go/weed/download.go
View file

@ -8,8 +8,8 @@ import (
"path" "path"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
var ( var (

4
go/weed/export.go
View file

@ -11,8 +11,8 @@ import (
"text/template" "text/template"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
func init() { func init() {

6
go/weed/filer.go
View file

@ -6,9 +6,9 @@ import (
"strconv" "strconv"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/mcqueenorama/weed-fs/go/weed/weed_server" "github.com/chrislusf/weed-fs/go/weed/weed_server"
) )
var ( var (

4
go/weed/fix.go
View file

@ -5,8 +5,8 @@ import (
"path" "path"
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
func init() { func init() {

6
go/weed/master.go
View file

@ -8,9 +8,9 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/mcqueenorama/weed-fs/go/weed/weed_server" "github.com/chrislusf/weed-fs/go/weed/weed_server"
"github.com/gorilla/mux" "github.com/gorilla/mux"
) )

8
go/weed/mount_std.go
View file

@ -9,10 +9,10 @@ import (
"bazil.org/fuse" "bazil.org/fuse"
"bazil.org/fuse/fs" "bazil.org/fuse/fs"
"github.com/mcqueenorama/weed-fs/go/filer" "github.com/chrislusf/weed-fs/go/filer"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func runMount(cmd *Command, args []string) bool { func runMount(cmd *Command, args []string) bool {

6
go/weed/server.go
View file

@ -10,9 +10,9 @@ import (
"sync" "sync"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/mcqueenorama/weed-fs/go/weed/weed_server" "github.com/chrislusf/weed-fs/go/weed/weed_server"
"github.com/gorilla/mux" "github.com/gorilla/mux"
) )

2
go/weed/shell.go
View file

@ -5,7 +5,7 @@ import (
"fmt" "fmt"
"os" "os"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func init() { func init() {

2
go/weed/upload.go
View file

@ -6,7 +6,7 @@ import (
"os" "os"
"path/filepath" "path/filepath"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
) )
var ( var (

2
go/weed/version.go
View file

@ -4,7 +4,7 @@ import (
"fmt" "fmt"
"runtime" "runtime"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
var cmdVersion = &Command{ var cmdVersion = &Command{

6
go/weed/volume.go
View file

@ -8,9 +8,9 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/mcqueenorama/weed-fs/go/weed/weed_server" "github.com/chrislusf/weed-fs/go/weed/weed_server"
) )
func init() { func init() {

2
go/weed/volume_test.go
View file

@ -5,7 +5,7 @@ import (
"testing" "testing"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func TestXYZ(t *testing.T) { func TestXYZ(t *testing.T) {

2
go/weed/weed.go
View file

@ -13,7 +13,7 @@ import (
"unicode" "unicode"
"unicode/utf8" "unicode/utf8"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
var IsDebug *bool var IsDebug *bool

10
go/weed/weed_server/common.go
View file

@ -10,11 +10,11 @@ import (
"strconv" "strconv"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/stats" "github.com/chrislusf/weed-fs/go/stats"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
var serverStats *stats.ServerStats var serverStats *stats.ServerStats

4
go/weed/weed_server/filer_server.go
View file

@ -4,8 +4,8 @@ import (
"net/http" "net/http"
"strconv" "strconv"
"github.com/mcqueenorama/weed-fs/go/filer" "github.com/chrislusf/weed-fs/go/filer"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
type FilerServer struct { type FilerServer struct {

6
go/weed/weed_server/filer_server_handlers.go
View file

@ -11,9 +11,9 @@ import (
"strconv" "strconv"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/syndtr/goleveldb/leveldb" "github.com/syndtr/goleveldb/leveldb"
) )

2
go/weed/weed_server/filer_server_handlers_admin.go
View file

@ -3,7 +3,7 @@ package weed_server
import ( import (
"net/http" "net/http"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
/* /*

8
go/weed/weed_server/master_server.go
View file

@ -6,10 +6,10 @@ import (
"net/url" "net/url"
"sync" "sync"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/sequence" "github.com/chrislusf/weed-fs/go/sequence"
"github.com/mcqueenorama/weed-fs/go/topology" "github.com/chrislusf/weed-fs/go/topology"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
"github.com/goraft/raft" "github.com/goraft/raft"
"github.com/gorilla/mux" "github.com/gorilla/mux"
) )

6
go/weed/weed_server/master_server_handlers.go
View file

@ -5,9 +5,9 @@ import (
"strconv" "strconv"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/stats" "github.com/chrislusf/weed-fs/go/stats"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
func (ms *MasterServer) lookupVolumeId(vids []string, collection string) (volumeLocations map[string]operation.LookupResult) { func (ms *MasterServer) lookupVolumeId(vids []string, collection string) (volumeLocations map[string]operation.LookupResult) {

10
go/weed/weed_server/master_server_handlers_admin.go
View file

@ -9,11 +9,11 @@ import (
"strings" "strings"
proto "code.google.com/p/goprotobuf/proto" proto "code.google.com/p/goprotobuf/proto"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/topology" "github.com/chrislusf/weed-fs/go/topology"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func (ms *MasterServer) collectionDeleteHandler(w http.ResponseWriter, r *http.Request) { func (ms *MasterServer) collectionDeleteHandler(w http.ResponseWriter, r *http.Request) {

4
go/weed/weed_server/raft_server.go
View file

@ -14,8 +14,8 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/topology" "github.com/chrislusf/weed-fs/go/topology"
"github.com/goraft/raft" "github.com/goraft/raft"
"github.com/gorilla/mux" "github.com/gorilla/mux"
) )

4
go/weed/weed_server/raft_server_handlers.go
View file

@ -6,8 +6,8 @@ import (
"net/http" "net/http"
"strings" "strings"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/goraft/raft" "github.com/goraft/raft"
) )

4
go/weed/weed_server/volume_server.go
View file

@ -6,8 +6,8 @@ import (
"strconv" "strconv"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
) )
type VolumeServer struct { type VolumeServer struct {

12
go/weed/weed_server/volume_server_handlers.go
View file

@ -9,12 +9,12 @@ import (
"strings" "strings"
"time" "time"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/images" "github.com/chrislusf/weed-fs/go/images"
"github.com/mcqueenorama/weed-fs/go/operation" "github.com/chrislusf/weed-fs/go/operation"
"github.com/mcqueenorama/weed-fs/go/stats" "github.com/chrislusf/weed-fs/go/stats"
"github.com/mcqueenorama/weed-fs/go/storage" "github.com/chrislusf/weed-fs/go/storage"
"github.com/mcqueenorama/weed-fs/go/topology" "github.com/chrislusf/weed-fs/go/topology"
) )
var fileNameEscaper = strings.NewReplacer("\\", "\\\\", "\"", "\\\"") var fileNameEscaper = strings.NewReplacer("\\", "\\\\", "\"", "\\\"")

6
go/weed/weed_server/volume_server_handlers_admin.go
View file

@ -4,9 +4,9 @@ import (
"net/http" "net/http"
"path/filepath" "path/filepath"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
"github.com/mcqueenorama/weed-fs/go/stats" "github.com/chrislusf/weed-fs/go/stats"
"github.com/mcqueenorama/weed-fs/go/util" "github.com/chrislusf/weed-fs/go/util"
) )
func (vs *VolumeServer) statusHandler(w http.ResponseWriter, r *http.Request) { func (vs *VolumeServer) statusHandler(w http.ResponseWriter, r *http.Request) {

2
go/weed/weed_server/volume_server_handlers_vacuum.go
View file

@ -3,7 +3,7 @@ package weed_server
import ( import (
"net/http" "net/http"
"github.com/mcqueenorama/weed-fs/go/glog" "github.com/chrislusf/weed-fs/go/glog"
) )
func (vs *VolumeServer) vacuumVolumeCheckHandler(w http.ResponseWriter, r *http.Request) { func (vs *VolumeServer) vacuumVolumeCheckHandler(w http.ResponseWriter, r *http.Request) {