-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathsegment_iterator.go
220 lines (193 loc) · 4.81 KB
/
segment_iterator.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
package goip
type singleSegmentIterator struct {
original *AddressSegment
}
func (it *singleSegmentIterator) HasNext() bool {
return it.original != nil
}
func (it *singleSegmentIterator) Next() (res *AddressSegment) {
if it.HasNext() {
res = it.original.toAddressSegment()
it.original = nil
}
return
}
type segmentIterator struct {
done bool
current SegInt
last SegInt
creator segderiver
segmentPrefixLength PrefixLen
}
func (it *segmentIterator) HasNext() bool {
return !it.done
}
func (it *segmentIterator) Next() (res *AddressSegment) {
if it.HasNext() {
cur := it.current
res = createAddressSegment(
it.creator.deriveNewSeg(
cur,
it.segmentPrefixLength))
cur++
if cur > it.last {
it.done = true
} else {
it.current = cur
}
}
return
}
type segmentPrefBlockIterator struct {
segmentIterator
upperShiftMask SegInt
shiftAdjustment BitCount
}
func (it *segmentPrefBlockIterator) Next() (res *AddressSegment) {
if it.HasNext() {
cur := it.current
blockLow := cur << uint(it.shiftAdjustment)
res = createAddressSegment(
it.creator.deriveNewMultiSeg(
blockLow,
blockLow|it.upperShiftMask,
it.segmentPrefixLength))
cur++
if cur > it.last {
it.done = true
} else {
it.current = cur
}
}
return
}
type segmentPrefIterator struct {
segmentPrefBlockIterator
originalLower SegInt
originalUpper SegInt
notFirst bool
}
func (it *segmentPrefIterator) Next() (res *AddressSegment) {
if it.HasNext() {
var low, high SegInt
cur := it.current
blockLow := cur << uint(it.shiftAdjustment)
blockHigh := blockLow | it.upperShiftMask
cur++
it.current = cur
if it.notFirst {
low = blockLow
} else {
low = it.originalLower
it.notFirst = true
}
if cur <= it.last {
high = blockHigh
} else {
high = it.originalUpper
it.done = true
}
res = createAddressSegment(
it.creator.deriveNewMultiSeg(
low,
high,
it.segmentPrefixLength))
}
return
}
type macSegmentIterator struct {
Iterator[*AddressSegment]
}
func (iter macSegmentIterator) Next() *MACAddressSegment {
return iter.Iterator.Next().ToMAC()
}
type ipv4SegmentIterator struct {
Iterator[*AddressSegment]
}
func (iter ipv4SegmentIterator) Next() *IPv4AddressSegment {
return iter.Iterator.Next().ToIPv4()
}
type ipSegmentIterator struct {
Iterator[*AddressSegment]
}
func (iter ipSegmentIterator) Next() *IPAddressSegment {
return iter.Iterator.Next().ToIP()
}
// wrappedSegmentIterator converts an IP address segment iterator to an address segment iterator
type wrappedSegmentIterator[T AddressSegmentType] struct {
Iterator[T]
}
func (iter wrappedSegmentIterator[T]) Next() *AddressSegment {
return iter.Iterator.Next().ToSegmentBase()
}
type ipv6SegmentIterator struct {
Iterator[*AddressSegment]
}
func (iter ipv6SegmentIterator) Next() *IPv6AddressSegment {
return iter.Iterator.Next().ToIPv6()
}
func segIterator(
original *addressSegmentInternal,
originalLower,
originalUpper SegInt,
bitCount BitCount,
creator segderiver,
segmentPrefixLength PrefixLen,
isPrefixIterator, isBlockIterator bool) Iterator[*AddressSegment] {
var shiftAdjustment BitCount
var shiftMask, upperShiftMask SegInt
if segmentPrefixLength == nil {
isPrefixIterator = false // prefixBlockIterator() in which seg has no prefix
isBlockIterator = false
}
if isPrefixIterator {
prefLen := segmentPrefixLength.bitCount()
prefLen = checkBitCount(bitCount, prefLen)
shiftAdjustment = bitCount - prefLen
shiftMask = ^SegInt(0) << uint(shiftAdjustment)
upperShiftMask = ^shiftMask
}
if original != nil && !original.isMultiple() {
seg := original.toAddressSegment()
if isBlockIterator {
seg = createAddressSegment(
creator.deriveNewMultiSeg(
originalLower&shiftMask,
originalUpper|upperShiftMask,
segmentPrefixLength))
}
return &singleSegmentIterator{original: seg}
}
if isPrefixIterator {
current := originalLower >> uint(shiftAdjustment)
last := originalUpper >> uint(shiftAdjustment)
segIterator := segmentIterator{
current: current,
last: last,
creator: creator,
segmentPrefixLength: segmentPrefixLength,
}
prefBlockIterator := segmentPrefBlockIterator{
segmentIterator: segIterator,
upperShiftMask: upperShiftMask,
shiftAdjustment: shiftAdjustment,
}
if isBlockIterator {
return &prefBlockIterator
}
return &segmentPrefIterator{
segmentPrefBlockIterator: prefBlockIterator,
originalLower: originalLower,
originalUpper: originalUpper,
}
}
return &segmentIterator{
current: originalLower,
last: originalUpper,
creator: creator,
segmentPrefixLength: segmentPrefixLength,
}
}
func nilSegIterator() Iterator[*AddressSegment] {
return &singleSegmentIterator{}
}