me/p2p-rendering-computation
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added mutex to avoid race condition when writing to iptable file

Browse Source
This commit is contained in:
Akilan Selvacoumar
2023-01-25 20:46:58 +00:00
parent f82f5f9ec8
commit 256998d964
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
client/clientIPTable/Iptable.go
View File

@@ -10,10 +10,13 @@ import (
"mime/multipart"
"net/http"
"os"
"sync"
)
var mu sync.Mutex
// UpdateIpTable Does the following to update it's IP table
func UpdateIpTable(IpAddress string, serverPort string) error {
func UpdateIpTable(IpAddress string, serverPort string, wg *sync.WaitGroup) error {
config, err := config.ConfigInit()
if err != nil {
@@ -66,6 +69,8 @@ func UpdateIpTable(IpAddress string, serverPort string) error {
return err
}
wg.Done()
return nil
}
@@ -95,6 +100,8 @@ func UpdateIpTableListClient() error {
return err
}
var w sync.WaitGroup
// Run loop 2 times
for i := 0; i < 2; i++ {
// Gets information from IP table
@@ -127,11 +134,13 @@ func UpdateIpTableListClient() error {
continue
}
w.Add(1)
if Addresses.IpAddress[j].Ipv6 != "" {
go UpdateIpTable(Addresses.IpAddress[j].Ipv6, Addresses.IpAddress[j].ServerPort)
go UpdateIpTable(Addresses.IpAddress[j].Ipv6, Addresses.IpAddress[j].ServerPort, &w)
} else if Addresses.IpAddress[j].Ipv4 != currentIPV4 {
go UpdateIpTable(Addresses.IpAddress[j].Ipv4, Addresses.IpAddress[j].ServerPort)
go UpdateIpTable(Addresses.IpAddress[j].Ipv4, Addresses.IpAddress[j].ServerPort, &w)
}
w.Wait()
//Appends server1 IP address to variable DoNotRead
DoNotRead.IpAddress = append(DoNotRead.IpAddress, Addresses.IpAddress[j])