FlightSim-Streaming/Remote-Gameplay
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added changes to test p2prc

Browse Source
This commit is contained in:
Akilan Selvacoumar
2025-02-12 19:52:56 +00:00
parent 29371b33cd
commit 58fa867235
3 changed files with 66 additions and 70 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
.DS_Store vendored
View File

Binary file not shown.

109
core/escape-NAT.go
View File

@@ -1,62 +1,57 @@
package core package core
import (
"github.com/Akilan1999/p2p-rendering-computation/p2p/frp"
"time"
)
// EscapeNAT Func to escape NAT // EscapeNAT Func to escape NAT
// - 1 port for server // - 1 port for server
// - 2 port for barrierKVM // - 2 port for barrierKVM
func EscapeNAT(ScreenSharePort, GameplayServerPort string) (ServerPort string, ScreensharePort string, err error) { //func EscapeNAT(ScreenSharePort, GameplayServerPort string) (ServerPort string, ScreensharePort string, err error) {
// Get free port from P2PRC server node // // Get free port from P2PRC server node
serverPort, err := frp.GetFRPServerPort("http://64.227.168.102:8088") // serverPort, err := frp.GetFRPServerPort("http://64.227.168.102:8088")
//
if err != nil { // if err != nil {
return // return
} // }
//
time.Sleep(1 * time.Second) // time.Sleep(1 * time.Second)
//
// port for the remote gameplay server // // port for the remote gameplay server
ServerPort, err = frp.StartFRPClientForServer("64.227.168.102", serverPort, GameplayServerPort) // ServerPort, err = frp.StartFRPClientForServer("64.227.168.102", serverPort, GameplayServerPort)
if err != nil { // if err != nil {
return // return
} // }
//
// Get free port from P2PRC server node // // Get free port from P2PRC server node
ScreensharePortFRP, err := frp.GetFRPServerPort("http://64.227.168.102:8088") // ScreensharePortFRP, err := frp.GetFRPServerPort("http://64.227.168.102:8088")
//
if err != nil { // if err != nil {
return // return
} // }
//
time.Sleep(1 * time.Second) // time.Sleep(1 * time.Second)
//
// port for the screenshare port // // port for the screenshare port
ScreensharePort, err = frp.StartFRPClientForServer("64.227.168.102", ScreensharePortFRP, ScreenSharePort) // ScreensharePort, err = frp.StartFRPClientForServer("64.227.168.102", ScreensharePortFRP, ScreenSharePort)
if err != nil { // if err != nil {
return // return
} // }
//
return // return
} //}
//
func EscapeNATBarrier() (barrierKVMport string, err error) { //func EscapeNATBarrier() (barrierKVMport string, err error) {
// Get free port from P2PRC server node // // Get free port from P2PRC server node
serverPort, err := frp.GetFRPServerPort("http://64.227.168.102:8088") // serverPort, err := frp.GetFRPServerPort("http://64.227.168.102:8088")
//
if err != nil { // if err != nil {
return // return
} // }
//
time.Sleep(1 * time.Second) // time.Sleep(1 * time.Second)
//
//port for the barrierKVM server // //port for the barrierKVM server
barrierKVMport, err = frp.StartFRPClientForServer("64.227.168.102", serverPort, "24798") // barrierKVMport, err = frp.StartFRPClientForServer("64.227.168.102", serverPort, "24798")
if err != nil { // if err != nil {
return // return
} // }
//
return // return
} //}

27
main.go
View File

@@ -51,12 +51,13 @@ func main() {
// if barrier flag is provided // if barrier flag is provided
if *barrier { if *barrier {
natBarrier, err := core.EscapeNATBarrier() //natBarrier, err := core.EscapeNATBarrier()
if err != nil { //if err != nil {
fmt.Println(err) // fmt.Println(err)
return // return
} //}
Config.NATEscapeBarrierPort = natBarrier //Config.NATEscapeBarrierPort = natBarrier
Config.NATEscapeBarrierPort = "0"
err = Config.WriteConfig() err = Config.WriteConfig()
if err != nil { if err != nil {
return return
@@ -114,14 +115,14 @@ func main() {
} }
// running implementation to escape NAT // running implementation to escape NAT
GameServerPort, ScreenSharePort, err := core.EscapeNAT(Config.InternalScreenSharePort, Config.InternalGameServerPort) //GameServerPort, ScreenSharePort, err := core.EscapeNAT(Config.InternalScreenSharePort, Config.InternalGameServerPort)
if err != nil { //if err != nil {
log.Fatalln(err) // log.Fatalln(err)
} //}
Config.IPAddress = "64.227.168.102" //Config.IPAddress = "64.227.168.102"
Config.NATEscapeGameServerPort = GameServerPort //Config.NATEscapeGameServerPort = GameServerPort
Config.NATEscapeScreenSharePort = ScreenSharePort //Config.NATEscapeScreenSharePort = ScreenSharePort
Config.NATEscapeBarrierPort = "" Config.NATEscapeBarrierPort = ""
err = Config.WriteConfig() err = Config.WriteConfig()