@@ -374,7 +374,6 @@ private void connect(ActionListener<Void> connectListener, boolean forceRun) {
374
374
375
375
private void forkConnect (final Collection <ActionListener <Void >> toNotify ) {
376
376
ThreadPool threadPool = transportService .getThreadPool ();
377
- assert threadPool .getThreadContext ().isSystemContext () == false : "context is a system context" ;
378
377
ExecutorService executor = threadPool .executor (ThreadPool .Names .MANAGEMENT );
379
378
executor .submit (new AbstractRunnable () {
380
379
@ Override
@@ -451,7 +450,6 @@ void collectRemoteNodes(Iterator<DiscoveryNode> seedNodes,
451
450
// due to an already closed connection.
452
451
ThreadPool threadPool = transportService .getThreadPool ();
453
452
ThreadContext threadContext = threadPool .getThreadContext ();
454
- assert threadContext .isSystemContext () == false : "context is a system context" ;
455
453
TransportService .ContextRestoreResponseHandler <ClusterStateResponse > responseHandler = new TransportService
456
454
.ContextRestoreResponseHandler <>(threadContext .newRestorableContext (false ),
457
455
new SniffClusterStateResponseHandler (transportService , connection , listener , seedNodes ,
@@ -530,7 +528,6 @@ public ClusterStateResponse newInstance() {
530
528
531
529
@ Override
532
530
public void handleResponse (ClusterStateResponse response ) {
533
- assert transportService .getThreadPool ().getThreadContext ().isSystemContext () == false : "context is a system context" ;
534
531
try {
535
532
if (remoteClusterName .get () == null ) {
536
533
assert response .getClusterName ().value () != null ;
@@ -570,7 +567,6 @@ public void handleResponse(ClusterStateResponse response) {
570
567
571
568
@ Override
572
569
public void handleException (TransportException exp ) {
573
- assert transportService .getThreadPool ().getThreadContext ().isSystemContext () == false : "context is a system context" ;
574
570
logger .warn (() -> new ParameterizedMessage ("fetching nodes from external cluster {} failed" , clusterAlias ), exp );
575
571
try {
576
572
IOUtils .closeWhileHandlingException (connection );
0 commit comments