本文整理汇总了Golang中github.com/gobby/src/rpc/rpcwrapper.SetForwardDropRate函数的典型用法代码示例。如果您正苦于以下问题:Golang SetForwardDropRate函数的具体用法?Golang SetForwardDropRate怎么用?Golang SetForwardDropRate使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了SetForwardDropRate函数的2个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: main
func main() {
rpcwrapper.SetForwardDropRate(20)
rpcwrapper.SetBackwardDropRate(20)
fmt.Printf("node %d starts\n", nid)
node, err := paxos.NewPaxosNode(nid, numNodes, fakecallback)
if err != nil {
fmt.Println("Cannot start node.\n")
fmt.Println(err)
return
}
listener, err := net.Listen("tcp", fmt.Sprintf(":%d", config.Nodes[nid].Port))
if err != nil {
fmt.Printf("node %d cannot listen to port:%s\n", err)
return
}
node.SetListener(&listener)
rpc.HandleHTTP()
go http.Serve(listener, nil)
time.Sleep(5 * time.Second)
for i := 0; i < 50; i++ {
c := command.Command{strconv.Itoa(nid), strconv.Itoa(i), command.Put, i, ""}
node.Replicate(&c)
}
for res := 0; res < 150; res++ {
_, ok := <-done
if !ok {
break
}
}
node.DumpLog()
fmt.Printf("node %d closes\n", nid)
_, _ = <-done
}
开发者ID:postfix,项目名称:gobby,代码行数:35,代码来源:node.go
示例2: main
func main() {
rpcwrapper.SetForwardDropRate(20)
rpcwrapper.SetBackwardDropRate(20)
fmt.Printf("node %d starts\n", nid)
_, err := lease.NewLeaseNode(nid, numNodes)
if err != nil {
fmt.Println("Cannot start node.\n")
fmt.Println(err)
return
}
listener, err := net.Listen("tcp", fmt.Sprintf(":%d", config.Nodes[nid].Port))
if err != nil {
fmt.Printf("node %d cannot listen to port:%s\n", err)
return
}
rpc.HandleHTTP()
http.Serve(listener, nil)
}
开发者ID:postfix,项目名称:gobby,代码行数:18,代码来源:node.go
注:本文中的github.com/gobby/src/rpc/rpcwrapper.SetForwardDropRate函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论