diff --git a/go/objectserver/replicator.go b/go/objectserver/replicator.go index 33db82cdb3..77c732c812 100644 --- a/go/objectserver/replicator.go +++ b/go/objectserver/replicator.go @@ -936,7 +936,7 @@ func NewReplicator(serverconf hummingbird.Config, flags *flag.FlagSet) (hummingb continue } if replicator.Rings[policy.Index], err = hummingbird.GetRing("object", hashPathPrefix, hashPathSuffix, policy.Index); err != nil { - return nil, fmt.Errorf("Unable to load ring.") + return nil, fmt.Errorf("Unable to load ring for Policy %d.", policy.Index) } } if replicator.logger, err = hummingbird.SetupLogger(serverconf, flags, "app:object-replicator", "object-replicator"); err != nil { diff --git a/go/probe/base.go b/go/probe/base.go index b0d306b65c..43fa1d4d66 100644 --- a/go/probe/base.go +++ b/go/probe/base.go @@ -20,6 +20,7 @@ import ( "flag" "fmt" "io/ioutil" + "log" "net" "net/http" "net/http/httptest" @@ -180,6 +181,7 @@ func (e *Environment) ObjExists(server int, timestamp string, policy int) bool { // NewEnvironment creates a new environment. Arguments should be a series of key, value pairs that are added to the object server configuration file. func NewEnvironment(settings ...string) *Environment { + log.SetFlags(log.LstdFlags | log.Lshortfile) oldLoadPolicies := hummingbird.LoadPolicies hummingbird.LoadPolicies = func() hummingbird.PolicyList { return hummingbird.PolicyList(map[int]*hummingbird.Policy{ @@ -234,13 +236,19 @@ func NewEnvironment(settings ...string) *Environment { _, _, server, _, _ := objectserver.GetServer(conf, &flag.FlagSet{}) ts.Config.Handler = server.GetHandler(conf) - replicator, _ := objectserver.NewReplicator(conf, &flag.FlagSet{}) + replicator, err := objectserver.NewReplicator(conf, &flag.FlagSet{}) + if err != nil { + log.Fatal(err) + } replicator.(*objectserver.Replicator).Rings[0] = env.ring replicator.(*objectserver.Replicator).Rings[1] = env.ring trs.Config.Handler = replicator.(*objectserver.Replicator).GetHandler() replicatorServer := &TestReplicatorWebServer{Server: trs, host: host, port: port, root: driveRoot, replicator: replicator.(*objectserver.Replicator)} - auditor, _ := objectserver.NewAuditor(conf, &flag.FlagSet{}) + auditor, err := objectserver.NewAuditor(conf, &flag.FlagSet{}) + if err != nil { + log.Fatal(err) + } env.ring.(*FakeRing).devices = append(env.ring.(*FakeRing).devices, &hummingbird.Device{ Id: i, Device: "sda", Ip: host, Port: port, Region: 0, ReplicationIp: trsHost, ReplicationPort: trsPort, Weight: 1, Zone: i,