lightcontainer/StoreBackEnd
2
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Changement pour n'accepter qu'un seul client

Browse Source
This commit is contained in:
Benjamin Lejeune 2022-02-20 11:41:41 +01:00
parent f58890ead1
commit 815da08c8d
2 changed files with 14 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cmd/main.go
View File

@ -5,19 +5,18 @@ import (
) )
const ( const (
MULTICAST_ADDRESS = "226.0.0.1:42500" MULTICAST_ADDRESS = "226.66.66.1:42500"
MULTICAST_SECOND = 10 MULTICAST_SECOND = 10 // TODO : Changer en 30 secondes
UNICAST_ADDRESS = "0.0.0.0:58000"
) )
func main() { func main() {
println("StorBackEnd started !") println("StorBackEnd started !")
//multicast := network.CreateClientMulticast(MULTICAST_ADDRESS, MULTICAST_SECOND) multicast := network.CreateClientMulticast(MULTICAST_ADDRESS, MULTICAST_SECOND)
go multicast.Run()
/* go */ server := network.ServerUnicast{Network: "tcp", Address: UNICAST_ADDRESS}
//multicast.Run()
server := network.ServerUnicast{Network: "tcp", Address: "0.0.0.0:58000"}
server.Run() server.Run()
} }

7
pkg/network/ServerUnicast.go
View File

@ -20,15 +20,14 @@ func (server ServerUnicast) Run() {
return return
} }
// go serverConsole(&cManager) // Attente connexion du FileFrontEnd
for {
con, err := listen.Accept() con, err := listen.Accept()
if err != nil { if err != nil {
fmt.Printf("Error while accepting client : %s\n", err) fmt.Printf("Error while accepting client : %s\n", err)
return return
} else { } else {
line, err := bufio.NewReader(con).ReadString('\n') line, err := bufio.NewReader(con).ReadString('\n')
if err != nil { if err != nil {
return return
@ -37,6 +36,4 @@ func (server ServerUnicast) Run() {
fmt.Printf("MESSAGE : %s\n", line) fmt.Printf("MESSAGE : %s\n", line)
} }
}
} }