From a3f93a617b386efacba42ab988309f9f5d541c75 Mon Sep 17 00:00:00 2001 From: Cody Soyland Date: Fri, 6 Dec 2013 16:38:29 -0600 Subject: [PATCH] add things. --- core/etcd.go | 3 ++- db/topology.go | 12 ++++++++---- 2 files changed, 10 insertions(+), 5 deletions(-) diff --git a/core/etcd.go b/core/etcd.go index 66679beef..95eaeb093 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -148,7 +148,8 @@ func (service *Service) MetaWatcher() { } } database, _ := cluster.GetDatabase("main") - database.TestSetBit(db.Bitmap{0, "general"}, 0) + spew.Dump(database) + database.TestSetBit(db.Bitmap{1200, "general"}, 1) receiver := make(chan *etcd.Response) stop := make(chan bool) diff --git a/db/topology.go b/db/topology.go index b3b016c8b..bb1521eda 100644 --- a/db/topology.go +++ b/db/topology.go @@ -2,6 +2,7 @@ package db import ( "github.com/stathat/consistent" + "github.com/davecgh/go-spew/spew" "github.com/nu7hatch/gouuid" "log" "fmt" @@ -219,8 +220,11 @@ func (d *Database) TestSetBit(bitmap Bitmap, profile_id int) { log.Println("slice:",slice) frame, _ := d.GetFrame(bitmap.FrameType) fsi, _ := d.GetFrameSliceIntersect(frame, slice) - fragment,erry := fsi.Hashring.Get(fmt.Sprintf("%d", bitmap.Id)) - - log.Println("fragment:",fragment) - log.Println("error:",erry) + frag_id_s,err := fsi.Hashring.Get(fmt.Sprintf("%d", bitmap.Id)) + frag_id, err := strconv.Atoi(frag_id_s) + fragment, err := fsi.GetFragment(frag_id) + if err != nil { + log.Fatal(err) + } + spew.Dump(fragment) }