question: @ 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 ( ) ) ; } } } } }
target:  Processes cache query request.