Skip to content

Commit 4d4e599

Browse files
committed
CC5 fix NPE in Stage methods
1 parent d612ea9 commit 4d4e599

File tree

1 file changed

+3
-3
lines changed
  • src/java/org/apache/cassandra/concurrent

1 file changed

+3
-3
lines changed

src/java/org/apache/cassandra/concurrent/Stage.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ public void execute(Runnable command)
170170
{
171171
if (!CUSTOM_TASK_EXECUTION_CALLBACK_CLASS.isPresent())
172172
{
173-
executor.execute(command);
173+
executor().execute(command);
174174
return;
175175
}
176176
long enqueueStartTime = Clock.Global.nanoTime();
@@ -181,7 +181,7 @@ public void execute(Runnable command, ExecutorLocals locals)
181181
{
182182
if (!CUSTOM_TASK_EXECUTION_CALLBACK_CLASS.isPresent())
183183
{
184-
executor.execute(locals, command);
184+
executor().execute(locals, command);
185185
return;
186186
}
187187
long enqueueStartTime = Clock.Global.nanoTime();
@@ -192,7 +192,7 @@ public void maybeExecuteImmediately(Runnable command)
192192
{
193193
if (!CUSTOM_TASK_EXECUTION_CALLBACK_CLASS.isPresent())
194194
{
195-
executor.execute(command);
195+
executor().execute(command);
196196
return;
197197
}
198198
long enqueueStartTime = Clock.Global.nanoTime();

0 commit comments

Comments
 (0)