1 #Region "Microsoft.VisualBasic::9360e36192cb0edd2e56d81eaabfaa19, Microsoft.VisualBasic.Core\Serialization\BinaryDumping\Buffer.vb"
2
3     ' Author:
4     
5     '       asuka (amethyst.asuka@gcmodeller.org)
6     '       xie (genetics@smrucc.org)
7     '       xieguigang (xie.guigang@live.com)
8     
9     ' Copyright (c) 2018 GPL3 Licensed
10     
11     
12     ' GNU GENERAL PUBLIC LICENSE (GPL3)
13     
14     
15     ' This program is free software: you can redistribute it and/or modify
16     ' it under the terms of the GNU General Public License as published by
17     ' the Free Software Foundation, either version 3 of the License, or
18     ' (at your option) any later version.
19     
20     ' This program is distributed in the hope that it will be useful,
21     ' but WITHOUT ANY WARRANTY; without even the implied warranty of
22     ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
23     ' GNU General Public License for more details.
24     
25     ' You should have received a copy of the GNU General Public License
26     ' along with this program. If not, see <http://www.gnu.org/licenses/>.
27
28
29
30     ' /********************************************************************************/
31
32     ' Summaries:
33
34     '     Structure Buffer
35     
36     '         Properties: TotalBytes
37     
38     '         Constructor: (+1 OverloadsSub New
39     '         Function: Serialize, ToString
40     
41     '     Delegate Function
42     
43     
44     '     Delegate Function
45     
46     
47     '     Module BufferAPI
48     
49     '         Function: CreateBuffer, GetBuffer
50     
51     
52     
53     
54     
55     ' /********************************************************************************/
56
57 #End Region
58
59 Imports Microsoft.VisualBasic.Language
60 Imports Microsoft.VisualBasic.Linq
61 Imports Microsoft.VisualBasic.Net.Protocols
62
63 Namespace Serialization.BinaryDumping
64
65     Public Structure Buffer : Implements ISerializable
66
67         Dim Length As Long
68         Dim buffer As Byte()
69
70         Sub New(buf As Byte())
71             Length = buf.Length
72             buffer = buf
73         End Sub
74
75         Public ReadOnly Property TotalBytes As Long
76             Get
77                 Return Length + RawStream.INT64
78             End Get
79         End Property
80
81         Public Overrides Function ToString() As String
82             Return $"{Length} bytes..."
83         End Function
84
85         Public Function Serialize() As Byte() Implements ISerializable.Serialize
86             Dim buffer As Byte() = New Byte(TotalBytes - 1) {}
87             Call Array.ConstrainedCopy(BitConverter.GetBytes(Length), Scan0, buffer, Scan0, RawStream.INT64)
88             Call Array.ConstrainedCopy(Me.buffer, Scan0, buffer, RawStream.INT64, Me.buffer.Length)
89             Return buffer
90         End Function
91     End Structure
92
93     Public Delegate Function IGetBuffer(Of T)(x As T) As Byte()
94     Public Delegate Function IGetObject(Of T)(buf As Byte()) As T
95
96     ''' <summary>
97     ''' 适用于对变长的流的操作
98     ''' </summary>
99     Public Module BufferAPI
100
101         Public Function CreateBuffer(Of T)(source As IEnumerable(Of T), getBuf As IGetBuffer(Of T)) As Byte()
102             Dim array As Buffer() = source.Select(Function(x) New Buffer(getBuf(x))).ToArray
103             Dim buffer As Byte() = New Byte(array.Sum(Function(x) x.TotalBytes) - 1L) {}
104             Dim i As Integer
105
106             For Each x As Buffer In array
107                 Call System.Array.ConstrainedCopy(x.Serialize, Scan0, buffer, i, x.TotalBytes)
108                 i += x.TotalBytes
109             Next
110
111             Return buffer
112         End Function
113
114         Public Iterator Function GetBuffer(Of T)(raw As Byte(), getObj As IGetObject(Of T)) As IEnumerable(Of T)
115             Dim length As Byte() = New Byte(RawStream.INT64 - 1) {}
116             Dim l As Long
117             Dim i As int = 0
118             Dim temp As Byte()
119             Dim x As T
120
121             Do While True
122                 Call Array.ConstrainedCopy(raw, i + RawStream.INT64, length, Scan0, RawStream.INT64)
123                 l = BitConverter.ToInt64(length, Scan0)
124                 temp = New Byte(l - 1) {}
125                 Call Array.ConstrainedCopy(raw, i + l, temp, Scan0, l)
126                 x = getObj(temp)
127                 Yield x
128
129                 If i >= raw.Length - 1 Then
130                     Exit Do
131                 End If
132             Loop
133         End Function
134     End Module
135 End Namespace