aboutsummaryrefslogtreecommitdiffstats
path: root/ethereum.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-02-23 08:57:45 +0800
committerobscuren <geffobscura@gmail.com>2014-02-23 08:57:45 +0800
commit3a45cdeaf9682dea0407f827571353220eaf257b (patch)
tree9626f13cfe4c345176d1bbd75c6657c719dfac3d /ethereum.go
parenta4a4ffbeff2fd9082f2c96330ea0915ae1b6e6c1 (diff)
downloadgo-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar.gz
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar.bz2
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar.lz
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar.xz
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.tar.zst
go-tangerine-3a45cdeaf9682dea0407f827571353220eaf257b.zip
Moved txpool start to initialisation method of ethereumm
Diffstat (limited to 'ethereum.go')
-rw-r--r--ethereum.go11
1 files changed, 6 insertions, 5 deletions
diff --git a/ethereum.go b/ethereum.go
index f86cb121e..725fe5a3d 100644
--- a/ethereum.go
+++ b/ethereum.go
@@ -47,6 +47,7 @@ type Ethereum struct {
Nonce uint64
Addr net.Addr
+ Port string
peerMut sync.Mutex
@@ -93,6 +94,9 @@ func New(caps Caps, usePnp bool) (*Ethereum, error) {
ethereum.TxPool.BlockManager = ethereum.BlockManager
ethereum.BlockManager.TransactionPool = ethereum.TxPool
+ // Start the tx pool
+ ethereum.TxPool.Start()
+
return ethereum, nil
}
@@ -229,7 +233,7 @@ func (s *Ethereum) ReapDeadPeerHandler() {
// Start the ethereum
func (s *Ethereum) Start() {
// Bind to addr and port
- ln, err := net.Listen("tcp", ":30303")
+ ln, err := net.Listen("tcp", ":"+s.Port)
if err != nil {
log.Println("Connection listening disabled. Acting as client")
} else {
@@ -246,9 +250,6 @@ func (s *Ethereum) Start() {
// Start the reaping processes
go s.ReapDeadPeerHandler()
- // Start the tx pool
- s.TxPool.Start()
-
if ethutil.Config.Seed {
ethutil.Config.Log.Debugln("Seeding")
// Testnet seed bootstrapping
@@ -306,7 +307,7 @@ func (s *Ethereum) upnpUpdateThread() {
// Go off immediately to prevent code duplication, thereafter we renew
// lease every 15 minutes.
timer := time.NewTimer(0 * time.Second)
- lport, _ := strconv.ParseInt("30303", 10, 16)
+ lport, _ := strconv.ParseInt(s.Port, 10, 16)
first := true
out:
for {