Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Polishes, prepping for release.

  • Loading branch information...
commit a1f12c7ded3003f85b683df67db3d397a21ae142 1 parent 7bfe17e
@karalabe karalabe authored
View
2  README.md
@@ -7,7 +7,7 @@
* Version 0.1-pre2 (hotfix): **development**
- Fix fast subscription reply only if subsciption succeeds.
- Fix topic self report after a node failure.
- - Fix heart mechanism to report errors not panics, check duplicate monitoring.
+ - Fix heart mechanism to report errors not panics, check duplicate monitoring.
- Fix late carrier heartbeat startup.
- Fix panic caused by balance requests pending during topic termination.
- Fix corrupt topic balancer caused by stale parent after removal.
View
2  config/config.go
@@ -159,7 +159,7 @@ var BootFastProbe = 250
var BootSlowProbe = 1000
// Scanning interval during bootstrapping (ms).
-var BootScan = 250
+var BootScan = 100
// Virtual address space (bits).
var OverlaySpace = 40
View
4 heart/heart.go
@@ -23,7 +23,6 @@ package heart
import (
"fmt"
- "log"
"math/big"
"sort"
"sync"
@@ -63,13 +62,11 @@ func New(beat time.Duration, kill int, handler Callback) *Heart {
// Starts the beater and event notifier.
func (h *Heart) Start() {
- log.Printf("starting heartbeat")
go h.beater()
}
// Terminates the heartbeat mechanism.
func (h *Heart) Terminate() {
- log.Printf("terminating heartbeat")
close(h.quit)
}
@@ -133,7 +130,6 @@ func (h *Heart) beater() {
case <-h.quit:
return
case <-beat.C:
- log.Printf("beating")
// Beat cycle: update tick and collect dead entries
h.lock.Lock()
h.tick++
View
6 main.go
@@ -31,8 +31,6 @@ import (
"io/ioutil"
"log"
rng "math/rand"
- "net/http"
- _ "net/http/pprof"
"os"
"os/signal"
"runtime"
@@ -146,10 +144,6 @@ func main() {
// Extract the command line arguments
relayPort, clusterId, rsaKey := parseFlags()
- go func() {
- log.Println(http.ListenAndServe("0:6060", nil))
- }()
-
// Check for CPU profiling
if *cpuProfile != "" {
prof, err := os.Create(*cpuProfile)
View
2  proto/carrier/carrier.go
@@ -66,7 +66,7 @@ func New(overId string, key *rsa.PrivateKey) Carrier {
// Boots the message carrier, returning the numner of remote peers.
func (c *carrier) Boot() (int, error) {
- log.Printf("Booting carrier: %v.", c.transport.Self())
+ log.Printf("carrier: booting with id %v.", c.transport.Self())
// Start the heartbeat first since convergence can last long
c.heart.Start()
Please sign in to comment.
Something went wrong with that request. Please try again.