File tree 1 file changed +1
-4
lines changed
src/csharp/Microsoft.Spark/Interop/Ipc
1 file changed +1
-4
lines changed Original file line number Diff line number Diff line change @@ -109,13 +109,13 @@ private bool TryDisposeJvmThread(int threadId)
109
109
if ( ( bool ) _jvmBridge . CallStaticJavaMethod ( "DotnetHandler" , "rmThread" , threadId ) )
110
110
{
111
111
_loggerService . LogDebug ( $ "GC'd JVM thread { threadId } .") ;
112
+ return true ;
112
113
}
113
114
else
114
115
{
115
116
_loggerService . LogWarn (
116
117
$ "rmThread returned false for JVM thread { threadId } . " +
117
118
$ "Either thread does not exist or has already been GC'd.") ;
118
- return false ;
119
119
}
120
120
}
121
121
@@ -127,7 +127,6 @@ private bool TryDisposeJvmThread(int threadId)
127
127
/// </summary>
128
128
private void GCThreads ( )
129
129
{
130
- _loggerService . LogDebug ( "Starting JVM thread GC." ) ;
131
130
foreach ( KeyValuePair < int , Thread > kvp in _activeThreads )
132
131
{
133
132
if ( ! kvp . Value . IsAlive )
@@ -145,8 +144,6 @@ private void GCThreads()
145
144
_activeThreadGCTimer = null ;
146
145
}
147
146
}
148
-
149
- _loggerService . LogDebug ( "JVM thread GC complete." ) ;
150
147
}
151
148
}
152
149
}
You can’t perform that action at this time.
0 commit comments