Commit 3a9c2cac authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent abca1b3f
...@@ -106,16 +106,20 @@ func (c *Client) Load(xid zodb.Xid) (data []byte, tid zodb.Tid, err error) { ...@@ -106,16 +106,20 @@ func (c *Client) Load(xid zodb.Xid) (data []byte, tid zodb.Tid, err error) {
cell := cellv[rand.Intn(len(cellv))] cell := cellv[rand.Intn(len(cellv))]
stor := c.node.NodeTab.Get(cell.NodeUUID) stor := c.node.NodeTab.Get(cell.NodeUUID)
if stor == nil { if stor == nil {
// XXX? panic(0) // XXX
} }
//Slink := c.Connect(stor) // single-flight Dial; puts result into stor.Link (XXX ok?) //Slink := c.Connect(stor) // single-flight Dial; puts result into stor.Link (XXX ok?)
Slink := stor.Connect() // single-flight Dial; puts result into stor.Link (XXX ok?) //Slink := stor.Connect() // single-flight Dial; puts result into stor.Link (XXX ok?)
Slink := stor.Link // XXX stub
// TODO maintain conn pool so every new GetObject request does not // TODO maintain conn pool so every new GetObject request does not
// spawn new goroutine on server // spawn new goroutine on server
// Sconn = stor.GetConn() // Sconn = stor.GetConn()
// XXX defer if ok stor.PutConn(Sconn) // XXX defer if ok stor.PutConn(Sconn)
Sconn := Slink.NewConn() Sconn, err := Slink.NewConn()
if err != nil {
panic(0) // XXX
}
req := neo.GetObject{Oid: xid.Oid} req := neo.GetObject{Oid: xid.Oid}
if xid.TidBefore { if xid.TidBefore {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment