Mirror.Unbatcher Class Reference

Public Member Functions
bool	AddBatch (ArraySegment< byte > batch)
bool	GetNextMessage (out NetworkReader message, out double remoteTimeStamp)

Properties
int	BatchesCount [get]

Detailed Description

Definition at line 13 of file Unbatcher.cs.

Member Function Documentation

AddBatch()

bool Mirror.Unbatcher.AddBatch

(

ArraySegment< byte >

batch

)

Definition at line 43 of file Unbatcher.cs.

        {
            // IMPORTANT: ArraySegment is only valid until returning. we copy it!
            //
            // NOTE: it's not possible to create empty ArraySegments, so we
            //       don't need to check against that.
 
            // make sure we have at least 8 bytes to read for tick timestamp
            if (batch.Count < Batcher.HeaderSize)
                return false;
 
            // put into a (pooled) writer
            // -> WriteBytes instead of WriteSegment because the latter
            //    would add a size header. we want to write directly.
            // -> will be returned to pool when sending!
            NetworkWriterPooled writer = NetworkWriterPool.Get();
            writer.WriteBytes(batch.Array, batch.Offset, batch.Count);
 
            // first batch? then point reader there
            if (batches.Count == 0)
                StartReadingBatch(writer);
 
            // add batch
            batches.Enqueue(writer);
            //Debug.Log($"Adding Batch {BitConverter.ToString(batch.Array, batch.Offset, batch.Count)} => batches={batches.Count} reader={reader}");
            return true;
        }

GetNextMessage()

bool Mirror.Unbatcher.GetNextMessage	(	out NetworkReader	message,
		out double	remoteTimeStamp
	)

Definition at line 73 of file Unbatcher.cs.

        {
            // getting messages would be easy via
            //   <<size, message, size, message, ...>>
            // but to save A LOT of bandwidth, we use
            //   <<message, message, ...>
            // in other words, we don't know where the current message ends
            //
            // BUT: it doesn't matter!
            // -> we simply return the reader
            //    * if we have one yet
            //    * and if there's more to read
            // -> the caller can then read one message from it
            // -> when the end is reached, we retire the batch!
            //
            // for example:
            //   while (GetNextMessage(out message))
            //       ProcessMessage(message);
            //
            message = null;
 
            // do nothing if we don't have any batches.
            // otherwise the below queue.Dequeue() would throw an
            // InvalidOperationException if operating on empty queue.
            if (batches.Count == 0)
            {
                remoteTimeStamp = 0;
                return false;
            }
 
            // was our reader pointed to anything yet?
            if (reader.Length == 0)
            {
                remoteTimeStamp = 0;
                return false;
            }
 
            // no more data to read?
            if (reader.Remaining == 0)
            {
                // retire the batch
                NetworkWriterPooled writer = batches.Dequeue();
                NetworkWriterPool.Return(writer);
 
                // do we have another batch?
                if (batches.Count > 0)
                {
                    // point reader to the next batch.
                    // we'll return the reader below.
                    NetworkWriterPooled next = batches.Peek();
                    StartReadingBatch(next);
                }
                // otherwise there's nothing more to read
                else
                {
                    remoteTimeStamp = 0;
                    return false;
                }
            }
 
            // use the current batch's remote timestamp
            // AFTER potentially moving to the next batch ABOVE!
            remoteTimeStamp = readerRemoteTimeStamp;
 
            // if we got here, then we have more data to read.
            message = reader;
            return true;
        }

Property Documentation

BatchesCount

int Mirror.Unbatcher.BatchesCount

get

Definition at line 19 of file Unbatcher.cs.