D受信全パケットを受信して​​いません

Question

私は現在ゲーム用に小さなUDPサーバーを作成するためにDを使用しています。問題は、受信した一部のパケットが実際のパケットの長さに一致しないことです（wireshark経由で表示）。

たとえば、クライアントはネットワーク経由で110バイトのパケットを送信します。これはwiresharkの下に表示されます。しかし、Dコードは7バイトしか受信しません！他の7バイトのパケットは、クライアントからネットワークを介して送信されることはありません。

Dからの7バイトは、110バイトパケットから最初の7バイトに一致します。私はこの問題を引き起こす可能性のあることは考えられないので、ソケットライブラリの問題だと思う。

問題は、常に同じポイントとまったく同じパケットで発生します。無視すると、問題は特定のパケットに対して継続されます。

このプロジェクトでは、複数のファイルがあることに注意してください、私は以下のコードの切れ端含めてください：

this(in Logger logger, string bindInterface = "0.0.0.0", ushort bindPort = 19132) { 
    this.logger = logger; 
    socket = new UdpSocket(AddressFamily.INET); 
    bindAddress = new InternetAddress(bindInterface, bindPort); 
} 

void bind(uint sendBufferSize = 1024 * 1024, uint recvBufferSize = 1024 * 1024) { 
    socket.bind(bindAddress); 

    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.BROADCAST, true); 
    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.SNDBUF, sendBufferSize); 
    socket.setOption(SocketOptionLevel.SOCKET, SocketOption.RCVBUF, recvBufferSize); 
    socket.blocking = false; 
} 

bool recv(ref Address address, ref byte[] buffer) { 
    auto length = socket.receiveFrom(buffer, SocketFlags.NONE, address); 
    if(length > 0) { 
     buffer.length = length; 
     debug logger.logDebug(to!string(length) ~ " Packet IN: " ~ to!string(cast(ubyte[]) buffer)); 
     return true; 
    } 
    buffer = null; 
    return false; 
} 

を...

Address a; 
    byte[] data = new byte[1024 * 1024]; 
    while(max-- > 0 && socket.recv(a, data)) { 
     handlePacket(a, data); 
    } 

完全なソースはhere.

を見つけることができます

ご協力いただければ幸いです。 refで

bool recv(ref Address address, ref byte[] buffer) 

あなたはスライスを作成しませんが、前のパケットが7bytes限り、あなたはより多くを受け取ることができないよりもあるので、もしあなたが本当に元のバッファを変更します。

クライアントは

Answer 1

問題は、この行にされていますより7つのバイトはもう

は、だから、REFを削除し、代わりにプレーンなブール値の長さを返すようにコードを変更することができます

size_t recv(ref Address address, byte[] buffer); 

、その後：

Address a; 
byte[] data = new byte[1024 * 1024]; 
size_t len; 
while(max-- > 0 && (len = socket.recv(a, data))) { 
    handlePacket(a, data[0 .. len]); 
} 

しかし、これはおそらく別のrefのごhandlePacket機能が動作しないだろうので、別の変形例では、コードのあなたのrecvなく、一部だけがhandlePacket

Address a; 
byte[] data = new byte[1024 * 1024]; 
size_t arr = data[]; 
while(max-- > 0 && socket.recv(a, arr)) { 
    handlePacket(a, arr); 
    arr = data[]; 
} 

をarount変更しないことです