Skip to content

Commit a96b9df

Browse files
authored
Merge pull request #179 from dotnet-campus/t/shs/request
兼容旧版本 2.0.0-alpha412 的行为,MessageReceived 中收到的是已经去掉 Request 头的数据
2 parents 5d8d864 + 1e7c890 commit a96b9df

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

src/dotnetCampus.Ipc/Pipes/IpcMessageRequestManager.cs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -141,23 +141,20 @@ private void HandleRequest(PeerStreamMessageArgs args)
141141
// 标记在这一级消费
142142
args.SetHandle(message: nameof(HandleRequest));
143143

144-
var currentPosition = message.Position;
145-
146144
var binaryReader = new BinaryReader(message);
147145
var messageId = binaryReader.ReadUInt64();
148146
var requestMessageLength = binaryReader.ReadInt32();
147+
// 兼容旧版本 2.0.0-alpha412 的行为,MessageReceived 中收到的是已经去掉 Request 头的数据
148+
var currentPosition = message.Position;
149149

150-
var headLength = sizeof(ulong)/*messageId*/ + sizeof(int)/*requestMessageLength*/;
151150
try
152151
{
153152
IpcMessageBody ipcBufferMessage;
154153
if (message is ByteListMessageStream byteListMessageStream)
155154
{
156155
var messageBuffer = byteListMessageStream.IpcMessageContext.MessageBuffer;
157-
// 开始等于原来读取掉的,加上当前的头的长度
158-
var start = (int) currentPosition + headLength;
159156

160-
ipcBufferMessage = new IpcMessageBody(messageBuffer, start, requestMessageLength);
157+
ipcBufferMessage = new IpcMessageBody(messageBuffer, (int) currentPosition, requestMessageLength);
161158
}
162159
else
163160
{

0 commit comments

Comments
 (0)