NotificationsYou must be signed in to change notification settings
Fork0
Star0

Commit4919915

authored

Merge pull requestpythonnet#836 from QuantConnect/fix-for-memory-leak-finalizer

Fix memory leak in finalizer

2 parentsf83c884 +885cd3e commit4919915Copy full SHA for 4919915

File tree

1 file changed

+30

-20

lines changed

src/runtime
- finalizer.cs

1 file changed

+30

-20

lines changed

`‎src/runtime/finalizer.cs`

Lines changed: 30 additions & 20 deletions

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ struct PendingArgs`
`41`	`41`	`privateConcurrentQueue<IPyDisposable>_objQueue=newConcurrentQueue<IPyDisposable>();`
`42`	`42`	`privatebool_pending=false;`
`43`	`43`	`privatereadonlyobject_collectingLock=newobject();`
`44`		`-privateIntPtr_pendingArgs;`
	`44`	`+privateIntPtr_pendingArgs=IntPtr.Zero;`
`45`	`45`
`46`	`46`	`#region FINALIZER_CHECK`
`47`	`47`
`@@ -128,7 +128,7 @@ internal void AddFinalizedObject(IPyDisposable obj)`
`128`	`128`	`_objQueue.Enqueue(obj);`
`129`	`129`	`}`
`130`	`130`	`GC.ReRegisterForFinalize(obj);`
`131`		`-if(_objQueue.Count>=Threshold)`
	`131`	`+if(!_pending&&_objQueue.Count>=Threshold)`
`132`	`132`	`{`
`133`	`133`	`AddPendingCollect();`
`134`	`134`	`}`
`@@ -164,26 +164,28 @@ internal static void Shutdown()`
`164`	`164`
`165`	`165`	`privatevoidAddPendingCollect()`
`166`	`166`	`{`
`167`		`-if(_pending)`
	`167`	`+if(Monitor.TryEnter(_collectingLock))`
`168`	`168`	`{`
`169`		`-return;`
`170`		`-}`
`171`		`-lock(_collectingLock)`
`172`		`-{`
`173`		`-if(_pending)`
	`169`	`+try`
`174`	`170`	`{`
`175`		`-return;`
	`171`	`+if(!_pending)`
	`172`	`+{`
	`173`	`+_pending=true;`
	`174`	`+varargs=newPendingArgs{cancelled=false};`
	`175`	`+_pendingArgs=Marshal.AllocHGlobal(Marshal.SizeOf(typeof(PendingArgs)));`
	`176`	`+Marshal.StructureToPtr(args,_pendingArgs,false);`
	`177`	`+IntPtrfunc=Marshal.GetFunctionPointerForDelegate(_collectAction);`
	`178`	`+if(Runtime.Py_AddPendingCall(func,_pendingArgs)!=0)`
	`179`	`+{`
	`180`	`+// Full queue, append next time`
	`181`	`+FreePendingArgs();`
	`182`	`+_pending=false;`
	`183`	`+}`
	`184`	`+}`
`176`	`185`	`}`
`177`		`-_pending=true;`
`178`		`-varargs=newPendingArgs(){cancelled=false};`
`179`		`-IntPtrp=Marshal.AllocHGlobal(Marshal.SizeOf(typeof(PendingArgs)));`
`180`		`-Marshal.StructureToPtr(args,p,false);`
`181`		`-_pendingArgs=p;`
`182`		`-IntPtrfunc=Marshal.GetFunctionPointerForDelegate(_collectAction);`
`183`		`-if(Runtime.Py_AddPendingCall(func,p)!=0)`
	`186`	`+finally`
`184`	`187`	`{`
`185`		`-// Full queue, append next time`
`186`		`-_pending=false;`
	`188`	`+Monitor.Exit(_collectingLock);`
`187`	`189`	`}`
`188`	`190`	`}`
`189`	`191`	`}`
`@@ -205,8 +207,8 @@ private static int OnPendingCollect(IntPtr arg)`
`205`	`207`	`}`
`206`	`208`	`finally`
`207`	`209`	`{`
	`210`	`+Instance.FreePendingArgs();`
`208`	`211`	`Instance.ResetPending();`
`209`		`-Marshal.FreeHGlobal(arg);`
`210`	`212`	`}`
`211`	`213`	`return0;`
`212`	`214`	`}`
`@@ -244,12 +246,20 @@ private void DisposeAll()`
`244`	`246`	`}`
`245`	`247`	`}`
`246`	`248`
	`249`	`+privatevoidFreePendingArgs()`
	`250`	`+{`
	`251`	`+if(_pendingArgs!=IntPtr.Zero)`
	`252`	`+{`
	`253`	`+Marshal.FreeHGlobal(_pendingArgs);`
	`254`	`+_pendingArgs=IntPtr.Zero;`
	`255`	`+}`
	`256`	`+}`
	`257`	`+`
`247`	`258`	`privatevoidResetPending()`
`248`	`259`	`{`
`249`	`260`	`lock(_collectingLock)`
`250`	`261`	`{`
`251`	`262`	`_pending=false;`
`252`		`-_pendingArgs=IntPtr.Zero;`
`253`	`263`	`}`
`254`	`264`	`}`
`255`	`265`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit4919915

File tree

1 file changed

1 file changed

`‎src/runtime/finalizer.cs`

0 commit comments