zishuo/hyprspace
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Performance Fixes

Browse Source
This commit is contained in:
Alec Scott
2021-06-09 21:28:39 -07:00
parent 82ba8d357f
commit 6eb4b47e37
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cli/root.go
View File

@@ -19,7 +19,7 @@ var Root *cmd.Root
func init() { func init() {
Root = &cmd.Root{ Root = &cmd.Root{
Name: "hypr", Name: "hyprspace",
Short: "Hyprspace Distributed Network", Short: "Hyprspace Distributed Network",
Flags: &GlobalFlags{}, Flags: &GlobalFlags{},
} }

16
cli/up.go
View File

@@ -98,7 +98,7 @@ func UpRun(r *cmd.Root, c *cmd.Sub) {
iface, err = tun.New(Global.Interface.Name) iface, err = tun.New(Global.Interface.Name)
checkErr(err) checkErr(err)
// Set TUN MTU // Set TUN MTU
tun.SetMTU(Global.Interface.Name, 1500) tun.SetMTU(Global.Interface.Name, 1420)
// Add Address to Interface // Add Address to Interface
tun.SetAddress(Global.Interface.Name, Global.Interface.Address) tun.SetAddress(Global.Interface.Name, Global.Interface.Address)
@@ -141,23 +141,23 @@ func UpRun(r *cmd.Root, c *cmd.Sub) {
fmt.Println("[+] Network Setup Complete...Waiting on Node Discovery") fmt.Println("[+] Network Setup Complete...Waiting on Node Discovery")
// Listen For New Packets on TUN Interface // Listen For New Packets on TUN Interface
packet := make([]byte, 1500) packet := make([]byte, 1420)
var stream network.Stream
var header *ipv4.Header
var plen int
for { for {
plen, err := iface.Read(packet) plen, err = iface.Read(packet)
checkErr(err) checkErr(err)
header, _ := ipv4.ParseHeader(packet[:plen]) header, _ = ipv4.ParseHeader(packet)
_, ok := Global.Peers[header.Dst.String()] _, ok := Global.Peers[header.Dst.String()]
if ok { if ok {
stream, err := host.NewStream(context.Background(), peerTable[header.Dst.String()], p2p.Protocol) stream, err = host.NewStream(ctx, peerTable[header.Dst.String()], p2p.Protocol)
if err != nil { if err != nil {
log.Println(err) log.Println(err)
continue continue
} }
go func() {
stream.Write(packet[:plen]) stream.Write(packet[:plen])
stream.Close() stream.Close()
}()
} }
} }
} }