BNetEx sending packets

BlitzMax Forums/BlitzMax Programming/BNetEx sending packets

Volker

(Posted 2009) [#1]

I have a problem with the BNetEx mod by vertex.

Sending and receiving lines (strings) works fine.
I want to send packets over the stream, but that works only if I
set a delay between sending them. Else most of the packets
just dissapear (only 2 packets get through).
I've modified the examples to show it.
To start change the ip, start the server and then the client.

tcpserver.bmx:

SuperStrict

Framework vertex.BNetEx

Import brl.LinkedList
Import brl.StandardIO
Import brl.PolledInput

Global Server:TTCPStream
Global Clients:TList
Global Client:TTCPStream

Server = New TTCPStream
Server.Init()
Server.SetLocalPort(1234)
Server.Listen()

Clients = CreateList()

While Not KeyDown(KEY_ESCAPE)
	Client = Server.Accept()

	If Client Then
		Print "New Client:"
		Print " - IP:" + TNetwork.StringIP(Client.GetLocalIP())
		Print " - Port:" + Client.GetLocalPort()
		Clients.AddLast(Client)
	EndIf

	For Client = EachIn Clients
		If Client.GetState() <> 1 Then
			Print "Client disconnected:"
			Print " - IP:" + TNetwork.StringIP(Client.GetLocalIP())
			Print " - Port:" + Client.GetLocalPort()
			Client.Close()
			Clients.remove(Client)
			Continue
		EndIf

		If Clients.Count() <> 0
			
			For Local c:TTCPStream = EachIn Clients ' send 10 packs to each client
				For Local p:Int = 1 To 10
					Local pack:TPack = New TPack
					Pack.int1 = p ' number the pack
					pack.Send(c)
					Print "sended pack:" + p
					'Delay 200  ' *** remove this delay and only 1 or 2 packet gets through ***
				Next
			Next			
			Delay 5500
			End
		End If
	Next
Wend

Server.Close()
End

Type TPack
	Field Header:String
	Field int1:Int
	Field int2:Int
	Field float1:Float
	Field float2:Float
	
	Method Send(stream:TTCPStream)
		stream.WriteLine(Self.Header)
		stream.WriteInt(Self.int1)
		stream.WriteInt(Self.int1)
		stream.WriteFloat(Self.float2)
		stream.WriteFloat(Self.float2)
		'
		stream.SendMsg()
	End Method

	Method read(stream:TTCPStream)
		Self.Header = stream.ReadLine()
		Self.int1 = stream.ReadInt()
		Self.int2 = stream.ReadInt()
		Self.float1 = stream.ReadFloat()
		Self.float2 = stream.ReadFloat()
	End Method
End Type

tcpclient.bmx

SuperStrict

Framework vertex.BNetEx

Import Brl.LinkedList
Import Brl.StandardIO
Import Brl.PolledInput

Global Client:TTCPStream

Client = New TTCPStream
Client.Init()
Client.SetLocalPort()
Client.SetRemoteIP(TNetwork.intip("192.168.1.99")) ' * change this to your local ip *

Client.SetRemotePort(1234)
Client.Connect()


While Not KeyDown(KEY_ESCAPE)
	If Client.GetState() <> 1 Then
		Print "Disconnected"
		Exit
	EndIf
	If Client.RecvAvail()
		If Client.RecvMsg() > 0 Then
			Local p:TPack = New TPack
			p.read(Client) ' read a pack from stream
			Print p.int1
		End If
	End If
	Delay 1
Wend

Client.Close()
Type TPack
	Field Header:String
	Field int1:Int
	Field int2:Int
	Field float1:Float
	Field float2:Float
	
	Method Send(stream:TTCPStream)
		stream.WriteLine(Self.Header)
		stream.WriteInt(Self.int1)
		stream.WriteInt(Self.int1)
		stream.WriteFloat(Self.float2)
		stream.WriteFloat(Self.float2)
		'
		stream.SendMsg()	
	End Method

	Method read(stream:TTCPStream)
		Self.Header = stream.ReadLine()
		Self.int1 = stream.ReadInt()
		Self.int2 = stream.ReadInt()
		Self.float1 = stream.ReadFloat()
		Self.float2 = stream.ReadFloat()		
	End Method
End Type