From 4e39ff9fe2409eb110fc7de814362c81b8ff1c13 Mon Sep 17 00:00:00 2001 From: xieguigang Date: Mon, 14 Mar 2022 00:44:48 +0800 Subject: [PATCH] Call RegisterDiagnoseBuffer() --- Parallel/Extensions.vb | 78 ++++++++++++---------- Parallel/IpcParallel/Stream/EmitHandler.vb | 4 +- 2 files changed, 43 insertions(+), 39 deletions(-) diff --git a/Parallel/Extensions.vb b/Parallel/Extensions.vb index 0a03a41..0396d4b 100644 --- a/Parallel/Extensions.vb +++ b/Parallel/Extensions.vb @@ -1,45 +1,51 @@ #Region "Microsoft.VisualBasic::6899da998f0554355d5fe6b72ae3dc0c, Parallel\Extensions.vb" - ' Author: - ' - ' asuka (amethyst.asuka@gcmodeller.org) - ' xie (genetics@smrucc.org) - ' xieguigang (xie.guigang@live.com) - ' - ' Copyright (c) 2018 GPL3 Licensed - ' - ' - ' GNU GENERAL PUBLIC LICENSE (GPL3) - ' - ' - ' This program is free software: you can redistribute it and/or modify - ' it under the terms of the GNU General Public License as published by - ' the Free Software Foundation, either version 3 of the License, or - ' (at your option) any later version. - ' - ' This program is distributed in the hope that it will be useful, - ' but WITHOUT ANY WARRANTY; without even the implied warranty of - ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - ' GNU General Public License for more details. - ' - ' You should have received a copy of the GNU General Public License - ' along with this program. If not, see . - - - - ' /********************************************************************************/ - - ' Summaries: - - ' Module Extensions - ' - ' - ' - ' /********************************************************************************/ +' Author: +' +' asuka (amethyst.asuka@gcmodeller.org) +' xie (genetics@smrucc.org) +' xieguigang (xie.guigang@live.com) +' +' Copyright (c) 2018 GPL3 Licensed +' +' +' GNU GENERAL PUBLIC LICENSE (GPL3) +' +' +' This program is free software: you can redistribute it and/or modify +' it under the terms of the GNU General Public License as published by +' the Free Software Foundation, either version 3 of the License, or +' (at your option) any later version. +' +' This program is distributed in the hope that it will be useful, +' but WITHOUT ANY WARRANTY; without even the implied warranty of +' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +' GNU General Public License for more details. +' +' You should have received a copy of the GNU General Public License +' along with this program. If not, see . + + + +' /********************************************************************************/ + +' Summaries: + +' Module Extensions +' +' +' +' /********************************************************************************/ #End Region +Imports Microsoft.VisualBasic.Data.IO.MessagePack + Public Module Extensions + Public Sub RegisterDiagnoseBuffer() + Call MsgPackSerializer.DefaultContext.RegisterSerializer(New Serialization.StackFrameBuffer) + Call MsgPackSerializer.DefaultContext.RegisterSerializer(New Serialization.StackMethodBuffer) + End Sub End Module diff --git a/Parallel/IpcParallel/Stream/EmitHandler.vb b/Parallel/IpcParallel/Stream/EmitHandler.vb index 06c80a5..1645713 100644 --- a/Parallel/IpcParallel/Stream/EmitHandler.vb +++ b/Parallel/IpcParallel/Stream/EmitHandler.vb @@ -52,7 +52,6 @@ Imports System.IO Imports System.Runtime.CompilerServices Imports System.Text -Imports Microsoft.VisualBasic.Data.IO.MessagePack Imports Microsoft.VisualBasic.ValueTypes Namespace IpcStream @@ -63,8 +62,7 @@ Namespace IpcStream Public Delegate Function loadBuffer(buf As Stream) As Object Sub New() - Call MsgPackSerializer.DefaultContext.RegisterSerializer(New Serialization.StackFrameBuffer) - Call MsgPackSerializer.DefaultContext.RegisterSerializer(New Serialization.StackMethodBuffer) + Call RegisterDiagnoseBuffer() End Sub Public Iterator Function PopulatePrimitiveHandles() As IEnumerable(Of (target As Type, emit As toBuffer))