1 | /*!
|
---|
2 | @brief このファイルでは、ABのガベージコレクションの実装を行います。
|
---|
3 | */
|
---|
4 |
|
---|
5 |
|
---|
6 | /*
|
---|
7 | ※これらの変数はコンパイラが自動的に定義します。
|
---|
8 | Dim _System_gc_StackRoot_StartPtr As VoidPtr
|
---|
9 | */
|
---|
10 |
|
---|
11 | Function _System_GetSp() As LONG_PTR 'dummy
|
---|
12 | End Function
|
---|
13 |
|
---|
14 |
|
---|
15 | Const _System_GC_FLAG_ATOMIC = 1
|
---|
16 | Const _System_GC_FLAG_NEEDFREE = 2
|
---|
17 | Const _System_GC_FLAG_INITZERO = 4
|
---|
18 | Const _System_GC_FLAG_OBJECT = 8
|
---|
19 |
|
---|
20 | Type _System_GlobalRoot
|
---|
21 | ptr As *LONG_PTR
|
---|
22 | count As Long
|
---|
23 | End Type
|
---|
24 |
|
---|
25 | Type _System_MemoryObject
|
---|
26 | ptr As VoidPtr
|
---|
27 | size As Long
|
---|
28 | flags As DWord
|
---|
29 | generationCount As Long
|
---|
30 | End Type
|
---|
31 |
|
---|
32 | Class _System_CGarbageCollection
|
---|
33 |
|
---|
34 | pMemoryObjects As *_System_MemoryObject ' メモリオブジェクト
|
---|
35 | countOfMemoryObjects As Long ' 管理するメモリオブジェクトの個数
|
---|
36 |
|
---|
37 | iAllSize As SIZE_T
|
---|
38 |
|
---|
39 | isSweeping As Boolean ' スウィープ中かどうか
|
---|
40 |
|
---|
41 | ' クリティカルセクション
|
---|
42 | CriticalSection As CRITICAL_SECTION
|
---|
43 |
|
---|
44 | ' メモリの上限値(この値を超えるとGCが発動します)
|
---|
45 | limitMemorySize As LONG_PTR ' バイト単位
|
---|
46 | limitMemoryObjectNum As Long ' メモリオブジェクトの個数単位
|
---|
47 |
|
---|
48 | isFinish As Boolean ' GC管理が終了したかどうか
|
---|
49 |
|
---|
50 |
|
---|
51 | ' Global Root
|
---|
52 | pGlobalRoots As *_System_GlobalRoot
|
---|
53 | globalRootNum As Long
|
---|
54 | Sub AddGlobalRootPtr( ptr As *LONG_PTR, count As Long )
|
---|
55 | pGlobalRoots = _System_realloc( pGlobalRoots, (globalRootNum + 1) * SizeOf(_System_GlobalRoot) )
|
---|
56 | pGlobalRoots[globalRootNum].ptr = ptr
|
---|
57 | pGlobalRoots[globalRootNum].count = count
|
---|
58 | globalRootNum++
|
---|
59 | End Sub
|
---|
60 |
|
---|
61 | Sub RegisterGlobalRoots()
|
---|
62 | ' このメソッドの実装はコンパイラが自動生成する
|
---|
63 |
|
---|
64 | ' AddGlobalRootPtr(...)
|
---|
65 | ' ...
|
---|
66 | End Sub
|
---|
67 |
|
---|
68 | ' 特殊クラスのため、コンストラクタ・デストラクタは呼ばれません
|
---|
69 | Sub _System_CGarbageCollection()
|
---|
70 | End Sub
|
---|
71 | Sub ~_System_CGarbageCollection()
|
---|
72 | End Sub
|
---|
73 |
|
---|
74 | Public
|
---|
75 |
|
---|
76 | /*!
|
---|
77 | @brief 環境変数にGCを登録する
|
---|
78 | @author Daisuke Yamamoto
|
---|
79 | @date 2007/10/21
|
---|
80 | */
|
---|
81 | Static Sub Initialize()
|
---|
82 | Dim temporary[255] As Char
|
---|
83 | If GetEnvironmentVariable( "ActiveBasicGarbageCollection", temporary, 255 ) Then
|
---|
84 | ' 既にGCがプロセスに存在するとき
|
---|
85 | _stscanf( temporary, "%08x", VarPtr( _System_pGC ) )
|
---|
86 | MessageBox(0,temporary,"GetEnvironmentVariable",0)
|
---|
87 | Else
|
---|
88 | _System_pGC = _System_calloc( SizeOf( _System_CGarbageCollection ) )
|
---|
89 | _System_pGC->Begin()
|
---|
90 |
|
---|
91 | ' GCをプロセスに登録する
|
---|
92 | _stprintf( temporary, "%08x", _System_pGC )
|
---|
93 | SetEnvironmentVariable( "ActiveBasicGarbageCollection", temporary )
|
---|
94 | End If
|
---|
95 | End Sub
|
---|
96 |
|
---|
97 | /*!
|
---|
98 | @brief メモリサイズの上限を指定する
|
---|
99 | @param limitMemorySize メモリサイズの上限(単位はバイト)
|
---|
100 | limitMemoryObjectNum メモリ個数の上限
|
---|
101 | @author Daisuke Yamamoto
|
---|
102 | @date 2007/10/21
|
---|
103 | */
|
---|
104 | Sub SetLimit( limitMemorySize As LONG_PTR, limitMemoryObjectNum As Long )
|
---|
105 | This.limitMemorySize = limitMemorySize
|
---|
106 | This.limitMemoryObjectNum = limitMemoryObjectNum
|
---|
107 | End Sub
|
---|
108 |
|
---|
109 | /*!
|
---|
110 | @brief 初期化
|
---|
111 | @author Daisuke Yamamoto
|
---|
112 | @date 2007/10/21
|
---|
113 | */
|
---|
114 | Sub Begin()
|
---|
115 | If pMemoryObjects Then Exit Sub
|
---|
116 |
|
---|
117 | isFinish = False
|
---|
118 |
|
---|
119 | 'メモリの上限値(この値を超えるとGCが発動します)
|
---|
120 | SetLimit(
|
---|
121 | 1024*1024, ' バイト単位
|
---|
122 | 2000 ' メモリオブジェクトの個数単位
|
---|
123 | )
|
---|
124 |
|
---|
125 | pMemoryObjects = _System_calloc( 1 )
|
---|
126 | countOfMemoryObjects=0
|
---|
127 |
|
---|
128 | ' Global Root
|
---|
129 | pGlobalRoots = _System_calloc( 1 )
|
---|
130 | globalRootNum = 0
|
---|
131 | RegisterGlobalRoots()
|
---|
132 |
|
---|
133 | iAllSize=0
|
---|
134 |
|
---|
135 | ' スウィープ中かどうか
|
---|
136 | isSweeping = False
|
---|
137 |
|
---|
138 | 'クリティカルセッションを生成
|
---|
139 | InitializeCriticalSection(CriticalSection)
|
---|
140 |
|
---|
141 |
|
---|
142 | '---------------------------
|
---|
143 | ' 開始時のスレッドを通知
|
---|
144 | '---------------------------
|
---|
145 | Dim hTargetThread As HANDLE
|
---|
146 | DuplicateHandle(GetCurrentProcess(),
|
---|
147 | GetCurrentThread(),
|
---|
148 | GetCurrentProcess(),
|
---|
149 | hTargetThread, 0, FALSE, DUPLICATE_SAME_ACCESS) 'カレントスレッドのハンドルを複製
|
---|
150 |
|
---|
151 | ' スレッド管理用オブジェクトを生成
|
---|
152 | _System_pobj_AllThreads = New _System_CThreadCollection()
|
---|
153 |
|
---|
154 | ' 自身のThreadオブジェクトを生成
|
---|
155 | Dim thread As Thread(hTargetThread,GetCurrentThreadId(),0)
|
---|
156 | thread.Name = "main"
|
---|
157 |
|
---|
158 | _System_pobj_AllThreads->BeginThread(ObjPtr( thread ),_System_gc_StackRoot_StartPtr As *LONG_PTR)
|
---|
159 |
|
---|
160 | End Sub
|
---|
161 |
|
---|
162 | /*!
|
---|
163 | @brief 終了処理
|
---|
164 | @author Daisuke Yamamoto
|
---|
165 | @date 2007/10/21
|
---|
166 | */
|
---|
167 | Sub Finish()
|
---|
168 | If pMemoryObjects = NULL Then Exit Sub
|
---|
169 |
|
---|
170 | isFinish = True
|
---|
171 |
|
---|
172 | ' スレッド管理用オブジェクトを破棄
|
---|
173 | Delete _System_pobj_AllThreads
|
---|
174 |
|
---|
175 | ' 自分以外のスレッドを一時停止
|
---|
176 | '_System_pobj_AllThreads->SuspendAnotherThread()
|
---|
177 |
|
---|
178 | _System_DebugOnly_OutputDebugString( Ex"garbage colletion sweeping all memory objects!\r\n" )
|
---|
179 | DeleteAllGarbageMemories()
|
---|
180 |
|
---|
181 | ' 未解放のメモリオブジェクトをトレース
|
---|
182 | DumpMemoryLeaks()
|
---|
183 |
|
---|
184 | ' 自分以外のスレッドを再開
|
---|
185 | '_System_pobj_AllThreads->ResumeAnotherThread()
|
---|
186 |
|
---|
187 | _System_free( pMemoryObjects )
|
---|
188 | pMemoryObjects = NULL
|
---|
189 |
|
---|
190 | _System_free( pGlobalRoots )
|
---|
191 | pGlobalRoots = NULL
|
---|
192 |
|
---|
193 | 'クリティカルセッションを破棄
|
---|
194 | DeleteCriticalSection(CriticalSection)
|
---|
195 |
|
---|
196 | End Sub
|
---|
197 |
|
---|
198 | /*!
|
---|
199 | @brief メモリオブジェクトからインデックスを取得する
|
---|
200 | @param new_ptr メモリオブジェクトへのポインタ
|
---|
201 | @author Daisuke Yamamoto
|
---|
202 | @date 2007/10/21
|
---|
203 | */
|
---|
204 | Function GetMemoryObjectPtr( ptr As VoidPtr ) As *_System_MemoryObject
|
---|
205 | ' メモリオブジェクトの先頭部分からインデックスを取得する
|
---|
206 | Dim index = Get_LONG_PTR( ptr - SizeOf(LONG_PTR) ) As Long
|
---|
207 |
|
---|
208 | If pMemoryObjects[index].ptr <> ptr Then
|
---|
209 | ' メモリイメージが壊れている(先頭に存在するインデックスの整合性が取れない)
|
---|
210 | Dim temporary[1024] As Char
|
---|
211 | #ifdef _WIN64
|
---|
212 | 'wsprintfでは、Windows 2000以降でしか%pが使えない。
|
---|
213 | wsprintf( temporary, Ex"indexOfMemoryObjects: %d\r\npMemoryObjects[index].ptr: &H%p\r\nptr: &H%p\r\n",
|
---|
214 | index,
|
---|
215 | pMemoryObjects[index].ptr,
|
---|
216 | ptr )
|
---|
217 | #else
|
---|
218 | wsprintf( temporary, Ex"indexOfMemoryObjects: %d\r\npMemoryObjects[index].ptr: &H%08x\r\nptr: &H%08x\r\n",
|
---|
219 | index,
|
---|
220 | pMemoryObjects[index].ptr,
|
---|
221 | ptr )
|
---|
222 | #endif
|
---|
223 | _System_DebugOnly_OutputDebugString( temporary )
|
---|
224 | debug
|
---|
225 | End If
|
---|
226 |
|
---|
227 | Return VarPtr( pMemoryObjects[index] )
|
---|
228 | End Function
|
---|
229 |
|
---|
230 | /*!
|
---|
231 | @brief メモリオブジェクトを追加する
|
---|
232 | @param new_ptr メモリオブジェクトへのポインタ
|
---|
233 | size メモリオブジェクトのサイズ
|
---|
234 | flags メモリオブジェクトの属性
|
---|
235 | @author Daisuke Yamamoto
|
---|
236 | @date 2007/10/21
|
---|
237 | */
|
---|
238 | Sub add(new_ptr As VoidPtr, size As SIZE_T, flags As DWord)
|
---|
239 | EnterCriticalSection(CriticalSection)
|
---|
240 | iAllSize+=size
|
---|
241 |
|
---|
242 | ' メモリオブジェクトインスタンスの先頭にインデックスをセットする
|
---|
243 | Set_LONG_PTR( new_ptr - SizeOf( LONG_PTR ), countOfMemoryObjects )
|
---|
244 |
|
---|
245 | pMemoryObjects = _System_realloc( pMemoryObjects, (countOfMemoryObjects+1)*SizeOf(_System_MemoryObject) )
|
---|
246 | pMemoryObjects[countOfMemoryObjects].ptr = new_ptr
|
---|
247 | pMemoryObjects[countOfMemoryObjects].size = size
|
---|
248 | pMemoryObjects[countOfMemoryObjects].flags = flags
|
---|
249 | pMemoryObjects[countOfMemoryObjects].generationCount = 0
|
---|
250 |
|
---|
251 | countOfMemoryObjects++
|
---|
252 | LeaveCriticalSection(CriticalSection)
|
---|
253 |
|
---|
254 | /*
|
---|
255 | ' デバッグ用
|
---|
256 | If countOfMemoryObjects = 1996 Then
|
---|
257 | debug
|
---|
258 | End If
|
---|
259 | */
|
---|
260 | End Sub
|
---|
261 |
|
---|
262 |
|
---|
263 | /*!
|
---|
264 | @brief メモリオブジェクトを確保する
|
---|
265 | @param size メモリオブジェクトのサイズ
|
---|
266 | flags メモリオブジェクトの属性
|
---|
267 | @author Daisuke Yamamoto
|
---|
268 | @date 2007/10/21
|
---|
269 | */
|
---|
270 | Function __malloc(size As SIZE_T,flags As Byte) As VoidPtr
|
---|
271 | Dim dwFlags As DWord
|
---|
272 | If flags and _System_GC_FLAG_INITZERO Then
|
---|
273 | dwFlags=HEAP_ZERO_MEMORY
|
---|
274 | Else
|
---|
275 | dwFlags=0
|
---|
276 | End If
|
---|
277 |
|
---|
278 | ' 実際のメモリバッファはインデックスの分だけ多めに確保する
|
---|
279 | Dim ptr = HeapAlloc( _System_hProcessHeap, dwFlags, size + SizeOf( LONG_PTR ) ) + SizeOf( LONG_PTR )
|
---|
280 |
|
---|
281 | ' 管理対象のメモリオブジェクトとして追加
|
---|
282 | add( ptr, size, flags )
|
---|
283 |
|
---|
284 | Return ptr
|
---|
285 | End Function
|
---|
286 |
|
---|
287 | /*!
|
---|
288 | @brief メモリオブジェクトを再確保する
|
---|
289 | @param lpMem メモリオブジェクトへのポインタ
|
---|
290 | size メモリオブジェクトのサイズ
|
---|
291 | flags メモリオブジェクトの属性
|
---|
292 | @author Daisuke Yamamoto
|
---|
293 | @date 2007/10/21
|
---|
294 | */
|
---|
295 | Function __realloc(lpMem As VoidPtr, size As SIZE_T) As VoidPtr
|
---|
296 | EnterCriticalSection(CriticalSection)
|
---|
297 |
|
---|
298 | ' メモリオブジェクトを取得
|
---|
299 | Dim pTempMemoryObject = GetMemoryObjectPtr( lpMem )
|
---|
300 |
|
---|
301 | iAllSize += size - pTempMemoryObject->size
|
---|
302 |
|
---|
303 | pTempMemoryObject->size = size
|
---|
304 | pTempMemoryObject->ptr = HeapReAlloc( _System_hProcessHeap, HEAP_ZERO_MEMORY, pTempMemoryObject->ptr - SizeOf(LONG_PTR), size + SizeOf(LONG_PTR) ) + SizeOf(LONG_PTR)
|
---|
305 |
|
---|
306 | LeaveCriticalSection(CriticalSection)
|
---|
307 | Return pTempMemoryObject->ptr
|
---|
308 | End Function
|
---|
309 |
|
---|
310 | /*!
|
---|
311 | @brief メモリオブジェクトを解放する
|
---|
312 | @param lpMem メモリオブジェクトへのポインタ
|
---|
313 | isSweeping スウィープ中にこのメソッドが呼ばれるときはTrue、それ以外はFalse
|
---|
314 | @author Daisuke Yamamoto
|
---|
315 | @date 2007/10/21
|
---|
316 | */
|
---|
317 | Sub __free_ex(lpMem As VoidPtr, isSweeping As Boolean)
|
---|
318 | EnterCriticalSection(CriticalSection)
|
---|
319 |
|
---|
320 | ' メモリオブジェクトを取得
|
---|
321 | Dim pTempMemoryObject = GetMemoryObjectPtr( lpMem )
|
---|
322 |
|
---|
323 | If (pTempMemoryObject->flags and _System_GC_FLAG_NEEDFREE)<>0 or isSweeping Then
|
---|
324 | iAllSize -= pTempMemoryObject->size
|
---|
325 |
|
---|
326 | HeapFree( _System_hProcessHeap, 0, pTempMemoryObject->ptr - SizeOf(LONG_PTR) )
|
---|
327 | pTempMemoryObject->ptr = NULL
|
---|
328 | pTempMemoryObject->size = 0
|
---|
329 | Else
|
---|
330 | If isFinish = False Then
|
---|
331 | _System_DebugOnly_OutputDebugString( Ex"heap free missing!\r\n" )
|
---|
332 | End If
|
---|
333 | End If
|
---|
334 | LeaveCriticalSection(CriticalSection)
|
---|
335 | End Sub
|
---|
336 |
|
---|
337 | /*!
|
---|
338 | @brief メモリオブジェクトを解放する
|
---|
339 | @param lpMem メモリオブジェクトへのポインタ
|
---|
340 | @author Daisuke Yamamoto
|
---|
341 | @date 2007/10/21
|
---|
342 | */
|
---|
343 | Sub __free(lpMem As VoidPtr)
|
---|
344 | __free_ex( lpMem, False )
|
---|
345 | End Sub
|
---|
346 |
|
---|
347 | /*!
|
---|
348 | @brief 必要であればスウィープする
|
---|
349 | @author Daisuke Yamamoto
|
---|
350 | @date 2007/10/21
|
---|
351 | */
|
---|
352 | Sub TrySweep()
|
---|
353 | If isSweeping <> False or (iAllSize<limitMemorySize and countOfMemoryObjects<limitMemoryObjectNum) Then
|
---|
354 | 'メモリ使用量が上限値を超えていないとき
|
---|
355 | Exit Sub
|
---|
356 | End If
|
---|
357 |
|
---|
358 | Sweep()
|
---|
359 | End Sub
|
---|
360 |
|
---|
361 | /*!
|
---|
362 | @brief スウィープする
|
---|
363 | @author Daisuke Yamamoto
|
---|
364 | @date 2007/10/21
|
---|
365 | */
|
---|
366 | Sub Sweep()
|
---|
367 | Dim hThread As HANDLE
|
---|
368 | Dim ThreadId As DWord
|
---|
369 | hThread=_beginthreadex(NULL,0,AddressOf(SweepOnOtherThread),VarPtr(This),0,ThreadId)
|
---|
370 | WaitForSingleObject(hThread,INFINITE)
|
---|
371 | CloseHandle(hThread)
|
---|
372 | isSweeping = False
|
---|
373 | End Sub
|
---|
374 |
|
---|
375 | Private
|
---|
376 |
|
---|
377 | Static Function IsNull( object As Object ) As Boolean
|
---|
378 | Return Object.ReferenceEquals(object, Nothing)
|
---|
379 | End Function
|
---|
380 |
|
---|
381 | /*!
|
---|
382 | @brief メモリオブジェクトの生存検地
|
---|
383 | @param pSample メモリオブジェクトへのポインタ
|
---|
384 | @author Daisuke Yamamoto
|
---|
385 | @date 2007/10/21
|
---|
386 | */
|
---|
387 | Function HitTest(pSample As VoidPtr) As Long
|
---|
388 | If pSample = NULL Then
|
---|
389 | Return -1
|
---|
390 | End If
|
---|
391 |
|
---|
392 | Dim i As Long
|
---|
393 | For i=0 To ELM(countOfMemoryObjects)
|
---|
394 | If (pMemoryObjects[i].ptr As LONG_PTR)<=(pSample As LONG_PTR) and (pSample As LONG_PTR)<((pMemoryObjects[i].ptr As LONG_PTR)+pMemoryObjects[i].size) Then
|
---|
395 | Return i
|
---|
396 | End If
|
---|
397 | Next
|
---|
398 | Return -1
|
---|
399 | End Function
|
---|
400 |
|
---|
401 | /*!
|
---|
402 | @brief オブジェクトのスキャン
|
---|
403 | @param pObject オブジェクトへのポインタ
|
---|
404 | pbMark マークリスト
|
---|
405 | @author Daisuke Yamamoto
|
---|
406 | @date 2007/10/21
|
---|
407 | */
|
---|
408 | Function ScanObject(pObject As *Object, pbMark As *Byte) As Boolean
|
---|
409 | Dim classTypeInfo = Nothing As ActiveBasic.Core._System_TypeForClass
|
---|
410 | classTypeInfo = pObject->GetType() As ActiveBasic.Core._System_TypeForClass
|
---|
411 |
|
---|
412 | If IsNull( classTypeInfo ) Then
|
---|
413 | Return False
|
---|
414 | End If
|
---|
415 |
|
---|
416 | /*
|
---|
417 | _System_DebugOnly_OutputDebugString( " (scanning object)" )
|
---|
418 | _System_DebugOnly_OutputDebugString( classTypeInfo.Name )
|
---|
419 | _System_DebugOnly_OutputDebugString( Ex"\r\n" )
|
---|
420 | */
|
---|
421 |
|
---|
422 | Dim i As Long
|
---|
423 | For i = 0 To ELM(classTypeInfo.numOfReference)
|
---|
424 | Scan( (pObject + classTypeInfo.referenceOffsets[i]) As *LONG_PTR, 1, pbMark )
|
---|
425 | Next
|
---|
426 |
|
---|
427 | Return True
|
---|
428 | End Function
|
---|
429 |
|
---|
430 | /*!
|
---|
431 | @brief メモリオブジェクトのスキャン
|
---|
432 | @param pStartPtr メモリオブジェクトへのポインタ
|
---|
433 | maxNum スキャンするメモリオブジェクトの個数
|
---|
434 | pbMark マークリスト
|
---|
435 | @author Daisuke Yamamoto
|
---|
436 | @date 2007/10/21
|
---|
437 | */
|
---|
438 | Sub Scan(pStartPtr As *LONG_PTR, maxNum As Long, pbMark As *Byte)
|
---|
439 | Dim i As Long, index As Long
|
---|
440 |
|
---|
441 | For i=0 To ELM(maxNum)
|
---|
442 | index=HitTest(pStartPtr[i] As VoidPtr)
|
---|
443 | If index<>-1 Then
|
---|
444 | If pbMark[index]=0 Then
|
---|
445 | pbMark[index]=1
|
---|
446 |
|
---|
447 | ' ジェネレーションカウントを増やす
|
---|
448 | pMemoryObjects[index].generationCount ++
|
---|
449 |
|
---|
450 | If pMemoryObjects[index].flags and _System_GC_FLAG_OBJECT Then
|
---|
451 | ' オブジェクトの場合
|
---|
452 | If ScanObject( (pMemoryObjects[index].ptr + 4*SizeOf(LONG_PTR)) As *Object, pbMark) = False Then
|
---|
453 | Dim maxNum = (pMemoryObjects[index].size\SizeOf(LONG_PTR)) As Long
|
---|
454 | Scan(pMemoryObjects[index].ptr As *LONG_PTR, maxNum, pbMark)
|
---|
455 | End If
|
---|
456 |
|
---|
457 | ElseIf (pMemoryObjects[index].flags and _System_GC_FLAG_ATOMIC)=0 Then
|
---|
458 | ' ヒープ領域がポインタ値を含む可能性があるとき
|
---|
459 | If pMemoryObjects[index].ptr = NULL Then
|
---|
460 | 'エラー
|
---|
461 |
|
---|
462 | End If
|
---|
463 |
|
---|
464 | Dim maxNum = (pMemoryObjects[index].size\SizeOf(LONG_PTR)) As Long
|
---|
465 | Scan(pMemoryObjects[index].ptr As *LONG_PTR, maxNum, pbMark)
|
---|
466 | End If
|
---|
467 | End If
|
---|
468 | End If
|
---|
469 | Next
|
---|
470 | End Sub
|
---|
471 |
|
---|
472 | /*!
|
---|
473 | @brief グローバル領域をルートに指定してスキャン
|
---|
474 | @param pbMark マークリスト
|
---|
475 | @author Daisuke Yamamoto
|
---|
476 | @date 2007/10/21
|
---|
477 | */
|
---|
478 | Sub GlobalScan( pbMark As *Byte )
|
---|
479 | Dim i As Long
|
---|
480 | For i = 0 To ELM( globalRootNum )
|
---|
481 | Scan( pGlobalRoots[i].ptr, pGlobalRoots[i].count, pbMark )
|
---|
482 | Next
|
---|
483 | End Sub
|
---|
484 |
|
---|
485 | /*!
|
---|
486 | @brief ローカル領域をルートに指定してスキャン
|
---|
487 | @param pbMark マークリスト
|
---|
488 | @author Daisuke Yamamoto
|
---|
489 | @date 2007/10/21
|
---|
490 | */
|
---|
491 | Sub LocalScan( pbMark As *Byte )
|
---|
492 | Dim Context As CONTEXT
|
---|
493 | Dim NowSp As *LONG_PTR
|
---|
494 | Dim size As LONG_PTR
|
---|
495 | Dim i As Long
|
---|
496 | For i=0 To ELM(_System_pobj_AllThreads->ThreadNum)
|
---|
497 | Dim thread = _System_pobj_AllThreads->ppobj_Thread[i]
|
---|
498 | If thread Then
|
---|
499 | FillMemory(VarPtr(Context),SizeOf(CONTEXT),0)
|
---|
500 | Context.ContextFlags=CONTEXT_CONTROL
|
---|
501 | If thread->__GetContext(Context)=0 Then
|
---|
502 | _System_DebugOnly_OutputDebugString(Ex"レジスタ情報の取得に失敗しました。\r\n")
|
---|
503 | End If
|
---|
504 |
|
---|
505 | #ifdef _WIN64
|
---|
506 | NowSp=Context.Rsp As *LONG_PTR
|
---|
507 | #else
|
---|
508 | NowSp=Context.Esp As *LONG_PTR
|
---|
509 | #endif
|
---|
510 |
|
---|
511 | Dim size=(_System_pobj_AllThreads->pStackBase[i] As LONG_PTR)-(NowSp As LONG_PTR)
|
---|
512 | Dim maxNum = (size\SizeOf(LONG_PTR)) As Long
|
---|
513 |
|
---|
514 | If NowSp = 0 Then
|
---|
515 | debug
|
---|
516 | Exit Sub
|
---|
517 | End If
|
---|
518 |
|
---|
519 | /*
|
---|
520 | _System_DebugOnly_OutputDebugString( "(scanning thread local)" )
|
---|
521 | _System_DebugOnly_OutputDebugString( thread.Name )
|
---|
522 | _System_DebugOnly_OutputDebugString( Ex"\r\n" )
|
---|
523 | */
|
---|
524 |
|
---|
525 | Scan( NowSp, maxNum, pbMark )
|
---|
526 | End If
|
---|
527 | Next
|
---|
528 | End Sub
|
---|
529 |
|
---|
530 | /*!
|
---|
531 | @brief 生存していないメモリオブジェクトを解放する
|
---|
532 | @param pbMark マークリスト
|
---|
533 | @author Daisuke Yamamoto
|
---|
534 | @date 2007/10/21
|
---|
535 | */
|
---|
536 | Sub DeleteGarbageMemories( pbMark As *Byte )
|
---|
537 |
|
---|
538 | Dim isAllDelete = False
|
---|
539 | If pbMark = NULL Then
|
---|
540 | ' すべてを破棄するとき
|
---|
541 | isAllDelete = True
|
---|
542 | pbMark = _System_calloc( countOfMemoryObjects )
|
---|
543 | End If
|
---|
544 |
|
---|
545 | Dim i As Long
|
---|
546 | For i=0 To ELM(countOfMemoryObjects)
|
---|
547 | If pbMark[i]=0 and pMemoryObjects[i].ptr<>0 and (pMemoryObjects[i].flags and _System_GC_FLAG_NEEDFREE)=0 Then
|
---|
548 | If pMemoryObjects[i].ptr = NULL Then
|
---|
549 | If isAllDelete Then
|
---|
550 | Continue
|
---|
551 | Else
|
---|
552 | debug
|
---|
553 | End If
|
---|
554 | End If
|
---|
555 |
|
---|
556 | Dim ptr = pMemoryObjects[i].ptr
|
---|
557 | Dim size = pMemoryObjects[i].size
|
---|
558 |
|
---|
559 | If (pMemoryObjects[i].flags and _System_GC_FLAG_OBJECT) <> 0 Then
|
---|
560 | /* ・オブジェクトの個数
|
---|
561 | ・オブジェクトのサイズ
|
---|
562 | ・デストラクタの関数ポインタ
|
---|
563 | ・リザーブ領域
|
---|
564 | を考慮 */
|
---|
565 | _System_SweepingDelete (ptr + SizeOf( LONG_PTR ) * 4 )
|
---|
566 | Else
|
---|
567 | __free_ex( ptr, True )
|
---|
568 | End If
|
---|
569 | End If
|
---|
570 | Next
|
---|
571 |
|
---|
572 | If isAllDelete Then
|
---|
573 | _System_free( pbMark )
|
---|
574 | End If
|
---|
575 |
|
---|
576 | End Sub
|
---|
577 |
|
---|
578 | /*!
|
---|
579 | @brief GCが管理するすべてのメモリオブジェクトを解放する
|
---|
580 | @author Daisuke Yamamoto
|
---|
581 | @date 2007/10/21
|
---|
582 | */
|
---|
583 | Sub DeleteAllGarbageMemories()
|
---|
584 | DeleteGarbageMemories( NULL )
|
---|
585 | End Sub
|
---|
586 |
|
---|
587 | /*!
|
---|
588 | @brief コンパクション
|
---|
589 | @author Daisuke Yamamoto
|
---|
590 | @date 2007/10/21
|
---|
591 | */
|
---|
592 | Sub Compaction()
|
---|
593 | Dim i As Long, i2 = 0 As Long
|
---|
594 | For i=0 To ELM(countOfMemoryObjects)
|
---|
595 | pMemoryObjects[i2] = pMemoryObjects[i]
|
---|
596 |
|
---|
597 | If pMemoryObjects[i2].ptr Then
|
---|
598 | ' メモリオブジェクトの先頭部分にあるインデックスを書き換える
|
---|
599 | Set_LONG_PTR( pMemoryObjects[i2].ptr - SizeOf(LONG_PTR), i2 )
|
---|
600 |
|
---|
601 | i2++
|
---|
602 | End If
|
---|
603 | Next
|
---|
604 | countOfMemoryObjects = i2
|
---|
605 | End Sub
|
---|
606 |
|
---|
607 | /*!
|
---|
608 | @brief スウィープ(新規スレッドで呼び出す必要あり)
|
---|
609 | @author Daisuke Yamamoto
|
---|
610 | @date 2007/10/21
|
---|
611 | */
|
---|
612 | Function SweepOnOtherThread() As Long
|
---|
613 | EnterCriticalSection(CriticalSection)
|
---|
614 |
|
---|
615 |
|
---|
616 | Dim startTime = GetTickCount()
|
---|
617 |
|
---|
618 | _System_DebugOnly_OutputDebugString( Ex"garbage colletion sweep start!\r\n" )
|
---|
619 |
|
---|
620 |
|
---|
621 | 'If isSweeping <> False or (iAllSize<limitMemorySize and countOfMemoryObjects<limitMemoryObjectNum) Then
|
---|
622 | ' ExitThread(0)
|
---|
623 | 'End If
|
---|
624 | isSweeping = True
|
---|
625 |
|
---|
626 | ' すべてのスレッドを一時停止
|
---|
627 | _System_pobj_AllThreads->SuspendAllThread()
|
---|
628 |
|
---|
629 | ' マークリストを生成
|
---|
630 | Dim pbMark = HeapAlloc(_System_hProcessHeap,HEAP_ZERO_MEMORY,countOfMemoryObjects*SizeOf(Byte)) As *Byte
|
---|
631 |
|
---|
632 | ' グローバル領域をルートに指定してスキャン
|
---|
633 | GlobalScan( pbMark )
|
---|
634 |
|
---|
635 | ' ローカル領域をルートに指定してスキャン
|
---|
636 | LocalScan( pbMark )
|
---|
637 |
|
---|
638 | ' スウィープ前のメモリサイズを退避
|
---|
639 | Dim iBackAllSize = iAllSize
|
---|
640 |
|
---|
641 | ' スウィープ前のメモリオブジェクトの数
|
---|
642 | Dim iBeforeN = countOfMemoryObjects
|
---|
643 |
|
---|
644 | '使われていないメモリを解放する
|
---|
645 | DeleteGarbageMemories(pbMark)
|
---|
646 |
|
---|
647 | 'コンパクション
|
---|
648 | Compaction()
|
---|
649 |
|
---|
650 | 'マークリストを解放
|
---|
651 | HeapFree(_System_hProcessHeap,0,pbMark)
|
---|
652 |
|
---|
653 | If iBackAllSize <= iAllSize * 2 Then
|
---|
654 | If iAllSize > limitMemorySize Then
|
---|
655 | limitMemorySize = iAllSize
|
---|
656 | End If
|
---|
657 |
|
---|
658 | '許容量を拡張する
|
---|
659 | limitMemorySize *= 2
|
---|
660 | limitMemoryObjectNum *= 2
|
---|
661 |
|
---|
662 | _System_DebugOnly_OutputDebugString( Ex"memory size is extended for gc!\r\n" )
|
---|
663 | End If
|
---|
664 |
|
---|
665 | Dim temp[100] As Char
|
---|
666 | wsprintf(temp,Ex"object items ... %d -> %d ( %d MB -> %d MB )\r\n",iBeforeN,countOfMemoryObjects, iBackAllSize\1024\1024, iAllSize\1024\1024)
|
---|
667 | _System_DebugOnly_OutputDebugString( temp )
|
---|
668 | wsprintf(temp,Ex"limit size of memory ... %d\r\n",limitMemorySize)
|
---|
669 | _System_DebugOnly_OutputDebugString( temp )
|
---|
670 | wsprintf(temp,Ex"garbage colletion sweep finish! (%d ms)\r\n\r\n", GetTickCount()-startTime)
|
---|
671 | _System_DebugOnly_OutputDebugString( temp )
|
---|
672 |
|
---|
673 |
|
---|
674 | '-------------------------------------
|
---|
675 | ' すべてのスレッドを再開
|
---|
676 | '-------------------------------------
|
---|
677 | _System_pobj_AllThreads->ResumeAllThread()
|
---|
678 |
|
---|
679 | LeaveCriticalSection(CriticalSection)
|
---|
680 | End Function
|
---|
681 |
|
---|
682 | /*!
|
---|
683 | @brief 未解放のメモリオブジェクトをデバッグ出力する
|
---|
684 | @author Daisuke Yamamoto
|
---|
685 | @date 2007/10/21
|
---|
686 | */
|
---|
687 | Sub DumpMemoryLeaks()
|
---|
688 | Dim isLeak = False
|
---|
689 | Dim i As Long
|
---|
690 | For i=0 To ELM(countOfMemoryObjects)
|
---|
691 | If pMemoryObjects[i].ptr Then
|
---|
692 | If (pMemoryObjects[i].flags and _System_GC_FLAG_NEEDFREE)<>0 Then
|
---|
693 | If isLeak = False Then
|
---|
694 | _System_DebugOnly_OutputDebugString( Ex"Detected memory leaks!\r\n" )
|
---|
695 | isLeak = True
|
---|
696 | End If
|
---|
697 |
|
---|
698 | Dim temp[100] As Char
|
---|
699 | _System_DebugOnly_OutputDebugString( Ex"heap free missing!\r\n" )
|
---|
700 | #ifdef _WIN64
|
---|
701 | wsprintf(temp,Ex"{%d} normal block at &H%p, %d bytes long.\r\n", i, pMemoryObjects[i].ptr, pMemoryObjects[i].size)
|
---|
702 | #else
|
---|
703 | wsprintf(temp,Ex"{%d} normal block at &H%08X, %d bytes long.\r\n", i, pMemoryObjects[i].ptr, pMemoryObjects[i].size)
|
---|
704 | #endif
|
---|
705 | _System_DebugOnly_OutputDebugString( temp )
|
---|
706 | End If
|
---|
707 | End If
|
---|
708 | Next
|
---|
709 |
|
---|
710 | If isLeak Then
|
---|
711 | _System_DebugOnly_OutputDebugString( Ex"Object dump complete.\r\n" )
|
---|
712 | End If
|
---|
713 |
|
---|
714 | End Sub
|
---|
715 |
|
---|
716 | End Class
|
---|
717 |
|
---|
718 | 'GC管理用の特殊なシステムオブジェクト(デストラクタは最終のタイミングで呼び出されます)
|
---|
719 | Dim _System_pGC As *_System_CGarbageCollection
|
---|
720 |
|
---|
721 |
|
---|
722 |
|
---|
723 | Function GC_malloc(size As Long) As VoidPtr
|
---|
724 | ' sweep
|
---|
725 | _System_pGC->TrySweep()
|
---|
726 |
|
---|
727 | 'allocate
|
---|
728 | Return _System_pGC->__malloc(size,0)
|
---|
729 | End Function
|
---|
730 |
|
---|
731 | Function GC_malloc_atomic(size As Long) As VoidPtr
|
---|
732 | ' sweep
|
---|
733 | _System_pGC->TrySweep()
|
---|
734 |
|
---|
735 | 'allocate
|
---|
736 | Return _System_pGC->__malloc(size,_System_GC_FLAG_ATOMIC)
|
---|
737 | End Function
|
---|
738 |
|
---|
739 | Function _System_GC_malloc_ForObject(size As Long) As VoidPtr
|
---|
740 | ' sweep
|
---|
741 | _System_pGC->TrySweep()
|
---|
742 |
|
---|
743 | 'allocate
|
---|
744 | Return _System_pGC->__malloc(size,_System_GC_FLAG_OBJECT or _System_GC_FLAG_INITZERO)
|
---|
745 | End Function
|
---|
746 |
|
---|
747 | Function _System_GC_malloc_ForObjectPtr(size As Long) As VoidPtr
|
---|
748 | ' sweep
|
---|
749 | _System_pGC->TrySweep()
|
---|
750 |
|
---|
751 | 'allocate
|
---|
752 | Return _System_pGC->__malloc(size,_System_GC_FLAG_OBJECT or _System_GC_FLAG_INITZERO or _System_GC_FLAG_NEEDFREE)
|
---|
753 | End Function
|
---|
754 |
|
---|
755 | Function _System_GC_free_for_SweepingDelete( ptr As *Object )
|
---|
756 | ' free
|
---|
757 | _System_pGC->__free_ex( ptr, True )
|
---|
758 | End Function
|
---|