OpenSim
/
OpenSimMirror
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

lludp GenericMessage enconding

0.9.1.0-post-fixes
UbitUmarov 2019-03-18 22:19:23 +00:00
parent 606d096709
commit 37619443a7
1 changed files with 132 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

154
OpenSim/Region/ClientStack/Linden/UDP/LLClientView.cs
View File

@ -1074,44 +1074,154 @@ namespace OpenSim.Region.ClientStack.LindenUDP
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown); m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown);
} }
static private readonly byte[] GenericMessageHeader = new byte[] {
Helpers.MSG_RELIABLE, //| Helpers.MSG_ZEROCODED, not doing spec zeroencode on this
0, 0, 0, 0, // sequence number
0, // extra
0xff, 0xff, 1, 5 // ID 261 (low frequency bigendian)
};
public void SendGenericMessage(string method, UUID invoice, List<string> message) public void SendGenericMessage(string method, UUID invoice, List<string> message)
{ {
GenericMessagePacket gmp = new GenericMessagePacket(); UDPPacketBuffer buf = m_udpServer.GetNewUDPBuffer(m_udpClient.RemoteEndPoint);
byte[] data = buf.Data;
gmp.AgentData.AgentID = AgentId; //setup header
gmp.AgentData.SessionID = m_sessionId; Buffer.BlockCopy(GenericMessageHeader, 0, data, 0, 10);
gmp.AgentData.TransactionID = invoice;
gmp.MethodData.Method = Util.StringToBytes256(method); //agentdata block
gmp.ParamList = new GenericMessagePacket.ParamListBlock[message.Count]; m_agentId.ToBytes(data, 10); // 26
int i = 0; m_sessionId.ToBytes(data, 26); // 42 sessionID zero?? TO check
foreach (string val in message) UUID.Zero.ToBytes(data, 42); // 58
int pos = 58;
//method block
byte[] tmp = Util.StringToBytes256(method);
int len = tmp.Length;
data[pos++] = (byte)len;
if (len > 0)
Buffer.BlockCopy(tmp, 0, data, pos, len); pos += len;
invoice.ToBytes(data, pos); pos += 16;
//ParamList block
if (message.Count == 0)
{ {
gmp.ParamList[i] = new GenericMessagePacket.ParamListBlock(); data[pos++] = 0;
gmp.ParamList[i++].Parameter = Util.StringToBytes256(val); buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown);
return;
} }
OutPacket(gmp, ThrottleOutPacketType.Task); int countpos = pos;
++pos;
int count = 0;
foreach (string val in message)
{
tmp = Util.StringToBytes256(val);
len = tmp.Length;
if (pos + len >= LLUDPServer.MAXPAYLOAD)
{
data[countpos] = (byte)count;
buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Task, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Task);
UDPPacketBuffer newbuf = m_udpServer.GetNewUDPBuffer(m_udpClient.RemoteEndPoint);
Buffer.BlockCopy(data, 0, newbuf.Data, 0, countpos);
pos = countpos + 1;
data = buf.Data;
count = 1;
}
else
++count;
data[pos++] = (byte)len;
if (len > 0)
Buffer.BlockCopy(tmp, 0, data, pos, len); pos += len;
}
if (count > 0)
{
data[countpos] = (byte)count;
buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown);
}
} }
public void SendGenericMessage(string method, UUID invoice, List<byte[]> message) public void SendGenericMessage(string method, UUID invoice, List<byte[]> message)
{ {
GenericMessagePacket gmp = new GenericMessagePacket(); UDPPacketBuffer buf = m_udpServer.GetNewUDPBuffer(m_udpClient.RemoteEndPoint);
byte[] data = buf.Data;
gmp.AgentData.AgentID = AgentId; //setup header
gmp.AgentData.SessionID = m_sessionId; Buffer.BlockCopy(GenericMessageHeader, 0, data, 0, 10);
gmp.AgentData.TransactionID = invoice;
gmp.MethodData.Method = Util.StringToBytes256(method); //agentdata block
gmp.ParamList = new GenericMessagePacket.ParamListBlock[message.Count]; m_agentId.ToBytes(data, 10); // 26
int i = 0; m_sessionId.ToBytes(data, 26); // 42 sessionID zero?? TO check
foreach (byte[] val in message) UUID.Zero.ToBytes(data, 42); // 58
int pos = 58;
//method block
byte[] tmp = Util.StringToBytes256(method);
int len = tmp.Length;
data[pos++] = (byte)len;
if (len > 0)
Buffer.BlockCopy(tmp, 0, data, pos, len); pos += len;
invoice.ToBytes(data, pos); pos += 16;
//ParamList block
if (message.Count == 0)
{ {
gmp.ParamList[i] = new GenericMessagePacket.ParamListBlock(); data[pos++] = 0;
gmp.ParamList[i++].Parameter = val; buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown);
return;
} }
OutPacket(gmp, ThrottleOutPacketType.Task); int countpos = pos;
++pos;
int count = 0;
foreach (byte[] val in message)
{
len = val.Length;
if(len > 255)
len = 255;
if (pos + len >= LLUDPServer.MAXPAYLOAD)
{
data[countpos] = (byte)count;
buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Task, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Task);
UDPPacketBuffer newbuf = m_udpServer.GetNewUDPBuffer(m_udpClient.RemoteEndPoint);
Buffer.BlockCopy(data, 0, newbuf.Data, 0, countpos);
pos = countpos + 1;
data = buf.Data;
count = 1;
}
else
++count;
data[pos++] = (byte)len;
if (len > 0)
Buffer.BlockCopy(val, 0, data, pos, len); pos += len;
}
if (count > 0)
{
data[countpos] = (byte)count;
buf.DataLength = pos;
//m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown, null, false, true);
m_udpServer.SendUDPPacket(m_udpClient, buf, ThrottleOutPacketType.Unknown);
}
} }
public void SendGroupActiveProposals(UUID groupID, UUID transactionID, GroupActiveProposals[] Proposals) public void SendGroupActiveProposals(UUID groupID, UUID transactionID, GroupActiveProposals[] Proposals)