fix crash on x86_64 android emulators (#4233)

Due to presence of syscall to `epoll_wait` android emulators after Android 10 would crash.
This commit has added `amd64` fallback implementations in 2 spots

- `tcp-shaker` ref : status-im/tcp-shaker@571aa46
- `notify` ref : status-im/notify@0eb36e6

The build flags are updated for fallback implementation to only be used in case of `x86_64` simulators.

status-mobile PR : status-im/status-mobile#17773

go.mod

@@ -4,6 +4,8 @@ go 1.19
 
 replace github.com/ethereum/go-ethereum v1.10.26 => github.com/status-im/go-ethereum v1.10.25-status.11
 
+replace github.com/rjeczalik/notify => github.com/status-im/notify v1.0.2-status
+
 replace github.com/docker/docker => github.com/docker/engine v1.4.2-0.20190717161051-705d9623b7c1
 
 replace github.com/nfnt/resize => github.com/status-im/resize v0.0.0-20201215164250-7c6d9f0d3088
@@ -51,7 +53,7 @@ require (
 	github.com/status-im/migrate/v4 v4.6.2-status.3
 	github.com/status-im/rendezvous v1.3.7
 	github.com/status-im/status-go/extkeys v1.1.2
-	github.com/status-im/tcp-shaker v0.0.0-20191114194237-215893130501
+	github.com/status-im/tcp-shaker v1.1.1-status
 	github.com/status-im/zxcvbn-go v0.0.0-20220311183720-5e8676676857
 	github.com/stretchr/testify v1.8.4
 	github.com/syndtr/goleveldb v1.0.1-0.20220614013038-64ee5596c38a

go.sum

@@ -1855,10 +1855,6 @@ github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qq
 github.com/retailnext/hllpp v1.0.1-0.20180308014038-101a6d2f8b52/go.mod h1:RDpi1RftBQPUCDRw6SmxeaREsAaRKnOclghuzp/WRzc=
 github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
-github.com/rjeczalik/notify v0.9.1/go.mod h1:rKwnCoCGeuQnwBtTSPL9Dad03Vh2n40ePRrjvIXnJho=
-github.com/rjeczalik/notify v0.9.2/go.mod h1:aErll2f0sUX9PXZnVNyeiObbmTlk5jnMoCa4QEjJeqM=
-github.com/rjeczalik/notify v0.9.3 h1:6rJAzHTGKXGj76sbRgDiDcYj/HniypXmSJo1SWakZeY=
-github.com/rjeczalik/notify v0.9.3/go.mod h1:gF3zSOrafR9DQEWSE8TjfI9NkooDxbyT4UgRGKZA0lc=
 github.com/robertkrimen/godocdown v0.0.0-20130622164427-0bfa04905481/go.mod h1:C9WhFzY47SzYBIvzFqSvHIR6ROgDo4TtdTuRaOMjF/s=
 github.com/rogpeppe/fastuuid v0.0.0-20150106093220-6724a57986af/go.mod h1:XWv6SoW27p1b0cqNHllgS5HIMJraePCO15w5zCzIWYg=
 github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ=
@@ -1998,14 +1994,16 @@ github.com/status-im/markdown v0.0.0-20231114210825-6c2d15b5dc57/go.mod h1:5rjPy
 github.com/status-im/migrate/v4 v4.6.2-status.2/go.mod h1:c/kc90n47GZu/58nnz1OMLTf7uE4Da4gZP5qmU+A/v8=
 github.com/status-im/migrate/v4 v4.6.2-status.3 h1:Khwjb59NzniloUr5i9s9AtkEyqBbQFt1lkoAu66sAu0=
 github.com/status-im/migrate/v4 v4.6.2-status.3/go.mod h1:c/kc90n47GZu/58nnz1OMLTf7uE4Da4gZP5qmU+A/v8=
+github.com/status-im/notify v1.0.2-status h1:x8wev0Sh8H8KAf4bVcv+L0dVHldBESOKUlqRqRY7uL8=
+github.com/status-im/notify v1.0.2-status/go.mod h1:gF3zSOrafR9DQEWSE8TjfI9NkooDxbyT4UgRGKZA0lc=
 github.com/status-im/rendezvous v1.3.7 h1:rZGWsFCjPV3MWeUkLkZSOGTAvyRf+rxx5hnEGLE4OHg=
 github.com/status-im/rendezvous v1.3.7/go.mod h1:r0vCbQJByTteMajN0f+Mcet/Vd7uAXxFPfewNpI2iXQ=
 github.com/status-im/resize v0.0.0-20201215164250-7c6d9f0d3088 h1:ClCAP2FPCvl8hGMhbUx/tq/sOu2wibztAa5jAvQEe4Q=
 github.com/status-im/resize v0.0.0-20201215164250-7c6d9f0d3088/go.mod h1:+92j1tN27DypDeBFxkg0uzkqfh1bNHTZe3Bv2PjvxpM=
 github.com/status-im/status-go/extkeys v1.1.2 h1:FSjARgDathJ3rIapJt851LsIXP9Oyuu2M2jPJKuzloU=
 github.com/status-im/status-go/extkeys v1.1.2/go.mod h1:hCmFzb2jiiVF2voZKYbzuhOQiHHCmyLJsZJXrFFg7BY=
-github.com/status-im/tcp-shaker v0.0.0-20191114194237-215893130501 h1:oa0KU5jJRNtXaM/P465MhvSFo/HM2O8qi2DDuPcd7ro=
-github.com/status-im/tcp-shaker v0.0.0-20191114194237-215893130501/go.mod h1:RYo/itke1oU5k/6sj9DNM3QAwtE5rZSgg5JnkOv83hk=
+github.com/status-im/tcp-shaker v1.1.1-status h1:TnVeeWlq2SKCWotHc4Vi6qZQfY8TTe3VLmu1xpEFYhg=
+github.com/status-im/tcp-shaker v1.1.1-status/go.mod h1:RYo/itke1oU5k/6sj9DNM3QAwtE5rZSgg5JnkOv83hk=
 github.com/status-im/zxcvbn-go v0.0.0-20220311183720-5e8676676857 h1:sPkzT7Z7uLmejOsBRlZ0kwDWpqjpHJsp834o5nbhqho=
 github.com/status-im/zxcvbn-go v0.0.0-20220311183720-5e8676676857/go.mod h1:lq9I5ROto5tcua65GmCE6SIW7VE0ucdEBs1fn4z7uWU=
 github.com/stefanberger/go-pkcs11uri v0.0.0-20201008174630-78d3cae3a980/go.mod h1:AO3tvPzVZ/ayst6UlUKUv6rcPQInYe3IknH3jYhAKu8=

protocol/messenger_mailserver_cycle.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"math"
 	"math/big"
+	"runtime"
 	"sort"
 	"strings"
 	"time"
@@ -22,6 +23,8 @@ import (
 
 const defaultBackoff = 10 * time.Second
 const graylistBackoff = 3 * time.Minute
+const isAndroidEmulator = runtime.GOOS == "android" && runtime.GOARCH == "amd64"
+const findNearestMailServer = !isAndroidEmulator
 
 func (m *Messenger) mailserversByFleet(fleet string) []mailservers.Mailserver {
 	var items []mailservers.Mailserver
@@ -235,76 +238,104 @@ func (m *Messenger) findNewMailserver() error {
 
 	allMailservers := m.mailserverCycle.allMailservers
 
-	m.logger.Info("Finding a new mailserver...")
+	//	TODO: remove this check once sockets are stable on x86_64 emulators
+	if findNearestMailServer {
+		m.logger.Info("Finding a new mailserver...")
 
-	var mailserverStr []string
-	for _, m := range allMailservers {
-		mailserverStr = append(mailserverStr, m.Address)
-	}
+		var mailserverStr []string
+		for _, m := range allMailservers {
+			mailserverStr = append(mailserverStr, m.Address)
+		}
 
-	if len(allMailservers) == 0 {
-		m.logger.Warn("no mailservers available") // Do nothing...
-		return nil
+		if len(allMailservers) == 0 {
+			m.logger.Warn("no mailservers available") // Do nothing...
+			return nil
 
-	}
+		}
 
-	var parseFn func(string) (string, error)
-	if allMailservers[0].Version == 2 {
-		parseFn = mailservers.MultiAddressToAddress
-	} else {
-		parseFn = mailservers.EnodeStringToAddr
-	}
+		var parseFn func(string) (string, error)
+		if allMailservers[0].Version == 2 {
+			parseFn = mailservers.MultiAddressToAddress
+		} else {
+			parseFn = mailservers.EnodeStringToAddr
+		}
 
-	pingResult, err := mailservers.DoPing(context.Background(), mailserverStr, 500, parseFn)
-	if err != nil {
-		return err
-	}
+		pingResult, err := mailservers.DoPing(context.Background(), mailserverStr, 500, parseFn)
+		if err != nil {
+			// pinging mailservers might fail, but we don't care
+			m.logger.Warn("mailservers.DoPing failed with", zap.Error(err))
+		}
 
-	var availableMailservers []*mailservers.PingResult
-	for _, result := range pingResult {
-		if result.Err != nil {
-			m.logger.Info("connecting error", zap.String("err", *result.Err))
-			continue // The results with error are ignored
+		var availableMailservers []*mailservers.PingResult
+		for _, result := range pingResult {
+			if result.Err != nil {
+				m.logger.Info("connecting error", zap.String("err", *result.Err))
+				continue // The results with error are ignored
+			}
+			availableMailservers = append(availableMailservers, result)
 		}
-		availableMailservers = append(availableMailservers, result)
-	}
 
-	if len(availableMailservers) == 0 {
-		m.logger.Warn("No mailservers available") // Do nothing...
-		return nil
-	}
+		if len(availableMailservers) == 0 {
+			m.logger.Warn("No mailservers available") // Do nothing...
+			return nil
+		}
 
-	mailserversByAddress := make(map[string]mailservers.Mailserver)
-	for idx := range allMailservers {
-		mailserversByAddress[allMailservers[idx].Address] = allMailservers[idx]
-	}
-	var sortedMailservers []SortedMailserver
-	for _, ping := range availableMailservers {
-		address := ping.Address
-		ms := mailserversByAddress[address]
-		sortedMailserver := SortedMailserver{
-			Address: address,
-			RTTMs:   *ping.RTTMs,
+		mailserversByAddress := make(map[string]mailservers.Mailserver)
+		for idx := range allMailservers {
+			mailserversByAddress[allMailservers[idx].Address] = allMailservers[idx]
 		}
-		m.mailPeersMutex.Lock()
-		pInfo, ok := m.mailserverCycle.peers[ms.ID]
-		m.mailPeersMutex.Unlock()
-		if ok {
-			if time.Now().Before(pInfo.canConnectAfter) {
-				continue // We can't connect to this node yet
+		var sortedMailservers []SortedMailserver
+		for _, ping := range availableMailservers {
+			address := ping.Address
+			ms := mailserversByAddress[address]
+			sortedMailserver := SortedMailserver{
+				Address: address,
+				RTTMs:   *ping.RTTMs,
+			}
+			m.mailPeersMutex.Lock()
+			pInfo, ok := m.mailserverCycle.peers[ms.ID]
+			m.mailPeersMutex.Unlock()
+			if ok {
+				if time.Now().Before(pInfo.canConnectAfter) {
+					continue // We can't connect to this node yet
+				}
 			}
+
+			sortedMailservers = append(sortedMailservers, sortedMailserver)
+
 		}
+		sort.Sort(byRTTMsAndCanConnectBefore(sortedMailservers))
 
-		sortedMailservers = append(sortedMailservers, sortedMailserver)
+		// Picks a random mailserver amongs the ones with the lowest latency
+		// The pool size is 1/4 of the mailservers were pinged successfully
+		pSize := poolSize(len(sortedMailservers) - 1)
+		if pSize <= 0 {
+			pSize = len(sortedMailservers)
+			if pSize <= 0 {
+				m.logger.Warn("No mailservers available") // Do nothing...
+				return nil
+			}
+		}
+
+		r, err := rand.Int(rand.Reader, big.NewInt(int64(pSize)))
+		if err != nil {
+			return err
+		}
 
+		msPing := sortedMailservers[r.Int64()]
+		ms := mailserversByAddress[msPing.Address]
+		m.logger.Info("connecting to mailserver", zap.String("address", ms.Address))
+		return m.connectToMailserver(ms)
 	}
-	sort.Sort(byRTTMsAndCanConnectBefore(sortedMailservers))
 
-	// Picks a random mailserver amongs the ones with the lowest latency
-	// The pool size is 1/4 of the mailservers were pinged successfully
-	pSize := poolSize(len(sortedMailservers) - 1)
+	mailserversByAddress := make(map[string]mailservers.Mailserver)
+	for idx := range allMailservers {
+		mailserversByAddress[allMailservers[idx].Address] = allMailservers[idx]
+	}
+
+	pSize := poolSize(len(allMailservers) - 1)
 	if pSize <= 0 {
-		pSize = len(sortedMailservers)
+		pSize = len(allMailservers)
 		if pSize <= 0 {
 			m.logger.Warn("No mailservers available") // Do nothing...
 			return nil
@@ -316,10 +347,11 @@ func (m *Messenger) findNewMailserver() error {
 		return err
 	}
 
-	msPing := sortedMailservers[r.Int64()]
+	msPing := allMailservers[r.Int64()]
 	ms := mailserversByAddress[msPing.Address]
 	m.logger.Info("connecting to mailserver", zap.String("address", ms.Address))
 	return m.connectToMailserver(ms)
+
 }
 
 func (m *Messenger) activeMailserverStatus() (connStatus, error) {