mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
commit
4fd378ee80
@ -189,11 +189,11 @@ func saveDB(destDB, srcDB string, idx uint64, v3 bool) {
|
|||||||
var src *bolt.DB
|
var src *bolt.DB
|
||||||
ch := make(chan *bolt.DB, 1)
|
ch := make(chan *bolt.DB, 1)
|
||||||
go func() {
|
go func() {
|
||||||
src, err := bolt.Open(srcDB, 0444, &bolt.Options{ReadOnly: true})
|
db, err := bolt.Open(srcDB, 0444, &bolt.Options{ReadOnly: true})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
ch <- src
|
ch <- db
|
||||||
}()
|
}()
|
||||||
select {
|
select {
|
||||||
case src = <-ch:
|
case src = <-ch:
|
||||||
|
@ -106,9 +106,9 @@ func doRounds(rcs []roundClient, rounds int, requests int) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func endpointsFromFlag(cmd *cobra.Command) []string {
|
func endpointsFromFlag(cmd *cobra.Command) []string {
|
||||||
endpoints, err := cmd.Flags().GetStringSlice("endpoints")
|
eps, err := cmd.Flags().GetStringSlice("endpoints")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
ExitWithError(ExitError, err)
|
ExitWithError(ExitError, err)
|
||||||
}
|
}
|
||||||
return endpoints
|
return eps
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user