@SuppressWarnings("unchecked") @Override void processQueryRequest(UUID sndId,GridCacheQueryRequest req){
  if (req.cancel()) {
    cancelIds.add(new CancelMessageId(req.id(),sndId));
    if (req.fields())     removeFieldsQueryResult(sndId,req.id());
 else     removeQueryResult(sndId,req.id());
  }
 else {
    if (!cancelIds.contains(new CancelMessageId(req.id(),sndId))) {
      if (!F.eq(req.cacheName(),cctx.name())) {
        GridCacheQueryResponse res=new GridCacheQueryResponse(cctx.cacheId(),req.id(),new IgniteCheckedException("Received request for incorrect cache [expected=" + cctx.name() + ", actual="+ req.cacheName()),cctx.deploymentEnabled());
        sendQueryResponse(sndId,res,0);
      }
 else {
        threads.put(req.id(),Thread.currentThread());
        try {
          GridCacheQueryInfo info=distributedQueryInfo(sndId,req);
          if (info == null)           return;
          if (req.fields())           runFieldsQuery(info);
 else           runQuery(info);
        }
 catch (        Throwable e) {
          U.error(log(),"Failed to run query.",e);
          sendQueryResponse(sndId,new GridCacheQueryResponse(cctx.cacheId(),req.id(),e.getCause(),cctx.deploymentEnabled()),0);
          if (e instanceof Error)           throw (Error)e;
        }
 finally {
          threads.remove(req.id());
        }
      }
    }
  }
}

@ SuppressWarnings ( "unchecked" ) @ Override void processQueryRequest ( UUID sndId , GridCacheQueryRequest req ) { if ( req . cancel ( ) ) { cancelIds . add ( new CancelMessageId ( req . id ( ) , sndId ) ) ; if ( req . fields ( ) ) removeFieldsQueryResult ( sndId , req . id ( ) ) ; else removeQueryResult ( sndId , req . id ( ) ) ; } else { if ( ! cancelIds . contains ( new CancelMessageId ( req . id ( ) , sndId ) ) ) { if ( ! F . eq ( req . cacheName ( ) , cctx . name ( ) ) ) { GridCacheQueryResponse res = new GridCacheQueryResponse ( cctx . cacheId ( ) , req . id ( ) , new IgniteCheckedException ( "Received request for incorrect cache [expected=" + cctx . name ( ) + ", actual=" + req . cacheName ( ) ) , cctx . deploymentEnabled ( ) ) ; sendQueryResponse ( sndId , res , 0 ) ; } else { threads . put ( req . id ( ) , Thread . currentThread ( ) ) ; try { GridCacheQueryInfo info = distributedQueryInfo ( sndId , req ) ; if ( info == null ) return ; if ( req . fields ( ) ) runFieldsQuery ( info ) ; else runQuery ( info ) ; } catch ( Throwable e ) { U . error ( log ( ) , "Failed to run query." , e ) ; sendQueryResponse ( sndId , new GridCacheQueryResponse ( cctx . cacheId ( ) , req . id ( ) , e . getCause ( ) , cctx . deploymentEnabled ( ) ) , 0 ) ; if ( e instanceof Error ) throw ( Error ) e ; } finally { threads . remove ( req . id ( ) ) ; } } } } }
processes cache query request .
