diff --git a/packages/accountability/accountability.go b/packages/accountability/accountability.go
index 0a24e9b8b362a3e6bbcb370206d298e0e6b2cd34..eef9bcbc2f12846ae163b5d9f1fcac8aa5956941 100644
--- a/packages/accountability/accountability.go
+++ b/packages/accountability/accountability.go
@@ -4,9 +4,22 @@ import (
"github.com/dgraph-io/badger"
"github.com/iotaledger/goshimmer/packages/settings"
"github.com/iotaledger/goshimmer/packages/identity"
+ "sync"
)
-var OWN_ID = getIdentity()
+var ownId *identity.Identity
+
+var lazyInit sync.Once
+
+func GetOwnId() *identity.Identity {
+ lazyInit.Do(initOwnId)
+
+ return ownId
+}
+
+func initOwnId() {
+ ownId = getIdentity()
+}
func generateNewIdentity() *identity.Identity {
newIdentity := identity.GenerateRandomIdentity()
diff --git a/packages/settings/settings.go b/packages/settings/settings.go
index d2a0862f46059ad7fb628fcc176a9ecac94de080..b23c7dfa1e7858dd6fe463386b371f8b12fb8800 100644
--- a/packages/settings/settings.go
+++ b/packages/settings/settings.go
@@ -1,21 +1,30 @@
package settings
-import "github.com/iotaledger/goshimmer/packages/database"
+import (
+ "github.com/iotaledger/goshimmer/packages/database"
+ "sync"
+)
var settingsDatabase database.Database
-func init() {
- if db, err := database.Get("settings"); err != nil {
- panic(err)
- } else {
- settingsDatabase = db
- }
-}
+var lazyInit sync.Once
func Get(key []byte) ([]byte, error) {
- return settingsDatabase.Get(key)
+ lazyInit.Do(initDb)
+
+ return settingsDatabase.Get(key)
}
func Set(key []byte, value []byte) error {
- return settingsDatabase.Set(key, value)
-}
\ No newline at end of file
+ lazyInit.Do(initDb)
+
+ return settingsDatabase.Set(key, value)
+}
+
+func initDb() {
+ if db, err := database.Get("settings"); err != nil {
+ panic(err)
+ } else {
+ settingsDatabase = db
+ }
+}
diff --git a/plugins/analysis/client/plugin.go b/plugins/analysis/client/plugin.go
index 663bf6cba2bbdfaeacd4af175425da8c10131ef0..ae494ea846108930dbe8b211cf8af646f5417dd3 100644
--- a/plugins/analysis/client/plugin.go
+++ b/plugins/analysis/client/plugin.go
@@ -62,7 +62,7 @@ func getEventDispatchers(conn *network.ManagedConnection) *EventDispatchers {
}
func reportCurrentStatus(eventDispatchers *EventDispatchers) {
- eventDispatchers.AddNode(accountability.OWN_ID.Identifier)
+ eventDispatchers.AddNode(accountability.GetOwnId().Identifier)
reportChosenNeighbors(eventDispatchers)
}
@@ -75,19 +75,19 @@ func setupHooks(conn *network.ManagedConnection, eventDispatchers *EventDispatch
})
onAddAcceptedNeighbor := events.NewClosure(func(p *peer.Peer) {
- eventDispatchers.ConnectNodes(p.Identity.Identifier, accountability.OWN_ID.Identifier)
+ eventDispatchers.ConnectNodes(p.Identity.Identifier, accountability.GetOwnId().Identifier)
})
onRemoveAcceptedNeighbor := events.NewClosure(func(p *peer.Peer) {
- eventDispatchers.DisconnectNodes(p.Identity.Identifier, accountability.OWN_ID.Identifier)
+ eventDispatchers.DisconnectNodes(p.Identity.Identifier, accountability.GetOwnId().Identifier)
})
onAddChosenNeighbor := events.NewClosure(func(p *peer.Peer) {
- eventDispatchers.ConnectNodes(accountability.OWN_ID.Identifier, p.Identity.Identifier)
+ eventDispatchers.ConnectNodes(accountability.GetOwnId().Identifier, p.Identity.Identifier)
})
onRemoveChosenNeighbor := events.NewClosure(func(p *peer.Peer) {
- eventDispatchers.DisconnectNodes(accountability.OWN_ID.Identifier, p.Identity.Identifier)
+ eventDispatchers.DisconnectNodes(accountability.GetOwnId().Identifier, p.Identity.Identifier)
})
// setup hooks /////////////////////////////////////////////////////////////////////////////////////////////////////
@@ -118,7 +118,7 @@ func reportChosenNeighbors(dispatchers *EventDispatchers) {
dispatchers.AddNode(chosenNeighbor.Identity.Identifier)
}
for _, chosenNeighbor := range chosenneighbors.INSTANCE.Peers {
- dispatchers.ConnectNodes(accountability.OWN_ID.Identifier, chosenNeighbor.Identity.Identifier)
+ dispatchers.ConnectNodes(accountability.GetOwnId().Identifier, chosenNeighbor.Identity.Identifier)
}
}
diff --git a/plugins/autopeering/instances/ownpeer/instance.go b/plugins/autopeering/instances/ownpeer/instance.go
index 9e3c0cef207b3c6bdf94e1fd693cb67e606070b7..e5af993c1a1e78faced8070154a6ad3198669f1f 100644
--- a/plugins/autopeering/instances/ownpeer/instance.go
+++ b/plugins/autopeering/instances/ownpeer/instance.go
@@ -14,7 +14,7 @@ var INSTANCE *peer.Peer
func Configure(plugin *node.Plugin) {
INSTANCE = &peer.Peer{
- Identity: accountability.OWN_ID,
+ Identity: accountability.GetOwnId(),
PeeringPort: uint16(*parameters.PORT.Value),
GossipPort: uint16(*gossip.PORT.Value),
Address: net.IPv4(0, 0, 0, 0),
diff --git a/plugins/autopeering/protocol/outgoing_ping_processor.go b/plugins/autopeering/protocol/outgoing_ping_processor.go
index e94a78cf9bc883aaeeb02ee2f594a64749766cb6..c10ac98efa280b78f243b11b78fa63ce6322011b 100644
--- a/plugins/autopeering/protocol/outgoing_ping_processor.go
+++ b/plugins/autopeering/protocol/outgoing_ping_processor.go
@@ -64,7 +64,7 @@ func pingPeers(plugin *node.Plugin, outgoingPing *ping.Ping) {
for i := 0; i < constants.PING_CONTACT_COUNT_PER_CYCLE; i++ {
randomNeighborHoodPeer := neighborhood.LIST_INSTANCE[rand.Intn(len(neighborhood.LIST_INSTANCE))]
- if randomNeighborHoodPeer.Identity.StringIdentifier != accountability.OWN_ID.StringIdentifier {
+ if randomNeighborHoodPeer.Identity.StringIdentifier != accountability.GetOwnId().StringIdentifier {
chosenPeers[randomNeighborHoodPeer.Identity.StringIdentifier] = randomNeighborHoodPeer
}
}
diff --git a/plugins/autopeering/protocol/outgoing_request_processor.go b/plugins/autopeering/protocol/outgoing_request_processor.go
index 617bfaa91f1a614acb29ad0f03407d2a7d8c5128..75961075040494b0809b79afe3fd1d8fa657cd75 100644
--- a/plugins/autopeering/protocol/outgoing_request_processor.go
+++ b/plugins/autopeering/protocol/outgoing_request_processor.go
@@ -60,7 +60,7 @@ func candidateShouldBeContacted(candidate *peer.Peer) bool {
nodeId := candidate.Identity.StringIdentifier
return (!acceptedneighbors.INSTANCE.Contains(nodeId) &&!chosenneighbors.INSTANCE.Contains(nodeId) &&
- accountability.OWN_ID.StringIdentifier != nodeId) && (
+ accountability.GetOwnId().StringIdentifier != nodeId) && (
len(chosenneighbors.INSTANCE.Peers) < constants.NEIGHBOR_COUNT / 2 ||
chosenneighbors.OWN_DISTANCE(candidate) < chosenneighbors.FURTHEST_NEIGHBOR_DISTANCE)
}
diff --git a/plugins/autopeering/types/peerregister/peer_register.go b/plugins/autopeering/types/peerregister/peer_register.go
index 6502155effa683ec470b7047ea1731656de7ac71..ea4221fda7806cb5a4ed3d629d30a9b7a0c97860 100644
--- a/plugins/autopeering/types/peerregister/peer_register.go
+++ b/plugins/autopeering/types/peerregister/peer_register.go
@@ -33,7 +33,7 @@ func (this *PeerRegister) AddOrUpdate(peer *peer.Peer, lock... bool) bool {
defer this.Lock()()
}
- if peer.Identity == nil || bytes.Equal(peer.Identity.Identifier, accountability.OWN_ID.Identifier) {
+ if peer.Identity == nil || bytes.Equal(peer.Identity.Identifier, accountability.GetOwnId().Identifier) {
return false
}
diff --git a/plugins/gossip/neighbors.go b/plugins/gossip/neighbors.go
index 47f0028c0027ab37f7ec8d3cb8e8d52eac5ebcbd..1d4a1d31c3eb4c8ede885e7e8596b57a938fc00b 100644
--- a/plugins/gossip/neighbors.go
+++ b/plugins/gossip/neighbors.go
@@ -156,7 +156,7 @@ func (neighbor *Neighbor) Connect() (*protocol, bool, errors.IdentifiableError)
// drop the "secondary" connection upon successful handshake
neighbor.InitiatedProtocol.Events.HandshakeCompleted.Attach(events.NewClosure(func() {
- if accountability.OWN_ID.StringIdentifier <= neighbor.Identity.StringIdentifier {
+ if accountability.GetOwnId().StringIdentifier <= neighbor.Identity.StringIdentifier {
neighbor.acceptedProtocolMutex.Lock()
var acceptedProtocolConn *network.ManagedConnection
if neighbor.AcceptedProtocol != nil {
diff --git a/plugins/gossip/protocol_v1.go b/plugins/gossip/protocol_v1.go
index 7e4bc5e405dbd5c4fbbf370ace459abbb2ac4222..52dce40c2837f9eea50a21be9448579d8733c006 100644
--- a/plugins/gossip/protocol_v1.go
+++ b/plugins/gossip/protocol_v1.go
@@ -15,7 +15,7 @@ import (
// region protocolV1 ///////////////////////////////////////////////////////////////////////////////////////////////////
func protocolV1(protocol *protocol) errors.IdentifiableError {
- if err := protocol.Send(accountability.OWN_ID); err != nil {
+ if err := protocol.Send(accountability.GetOwnId()); err != nil {
return err
}
diff --git a/plugins/gossip/server.go b/plugins/gossip/server.go
index 264fd0b06765e809583a4c3ea17caecc4ad18c04..3fa56b643b403549532cb3c5c74012cf110dec59 100644
--- a/plugins/gossip/server.go
+++ b/plugins/gossip/server.go
@@ -43,7 +43,7 @@ func configureServer(plugin *node.Plugin) {
// drop the "secondary" connection upon successful handshake
protocol.Events.HandshakeCompleted.Attach(events.NewClosure(func() {
- if protocol.Neighbor.Identity.StringIdentifier <= accountability.OWN_ID.StringIdentifier {
+ if protocol.Neighbor.Identity.StringIdentifier <= accountability.GetOwnId().StringIdentifier {
protocol.Neighbor.initiatedProtocolMutex.Lock()
var initiatedProtocolConn *network.ManagedConnection
if protocol.Neighbor.InitiatedProtocol != nil {
diff --git a/plugins/statusscreen/ui_header_bar.go b/plugins/statusscreen/ui_header_bar.go
index 60394449aa0112e79736dac5bd8c3f076755c244..3331532271639bcbc97370a74469dc811f1fb275 100644
--- a/plugins/statusscreen/ui_header_bar.go
+++ b/plugins/statusscreen/ui_header_bar.go
@@ -65,7 +65,7 @@ func (headerBar *UIHeaderBar) Update() {
fmt.Fprintln(headerBar.InfoContainer)
fmt.Fprintln(headerBar.InfoContainer)
fmt.Fprintln(headerBar.InfoContainer)
- fmt.Fprintf(headerBar.InfoContainer, "[::b]Node ID: [::d]%40v ", accountability.OWN_ID.StringIdentifier)
+ fmt.Fprintf(headerBar.InfoContainer, "[::b]Node ID: [::d]%40v ", accountability.GetOwnId().StringIdentifier)
fmt.Fprintln(headerBar.InfoContainer)
fmt.Fprintf(headerBar.InfoContainer, "[::b]Neighbors: [::d]%40v ", strconv.Itoa(len(chosenneighbors.INSTANCE.Peers)) + " chosen / " + strconv.Itoa(len(acceptedneighbors.INSTANCE.Peers)) + " accepted")
fmt.Fprintln(headerBar.InfoContainer)