(final boolean ok)
| 545 | } |
| 546 | |
| 547 | void close(final boolean ok) { |
| 548 | if (LOG.isDebugEnabled()) { |
| 549 | LOG.debug("Finished multiget on concurrency index: " + concurrency_index |
| 550 | + ", seq id: " + seq_id + ". Fetched rows: " + mul_get_number_row_fetched |
| 551 | + ", cells: " + mul_get_number_column_fetched + ", mget time(ms): " |
| 552 | + mul_get_time / 1000000 + " and " + ok); |
| 553 | } |
| 554 | |
| 555 | if (query_stats != null) { |
| 556 | query_stats.addScannerStat(query_index, seq_id, QueryStat.SCANNER_TIME, |
| 557 | DateTime.nanoTime() - mul_get_start_time); |
| 558 | |
| 559 | // Scanner Stats |
| 560 | query_stats.addScannerStat(query_index, seq_id, QueryStat.ROWS_FROM_STORAGE, |
| 561 | mul_get_number_row_fetched); |
| 562 | |
| 563 | query_stats.addScannerStat(query_index, seq_id, QueryStat.COLUMNS_FROM_STORAGE, |
| 564 | mul_get_number_column_fetched); |
| 565 | |
| 566 | query_stats.addScannerStat(query_index, seq_id, QueryStat.BYTES_FROM_STORAGE, |
| 567 | mul_get_number_byte_fetched); |
| 568 | |
| 569 | query_stats.addScannerStat(query_index, seq_id, QueryStat.HBASE_TIME, |
| 570 | mul_get_time); |
| 571 | query_stats.addScannerStat(query_index, seq_id, QueryStat.SUCCESSFUL_SCAN, |
| 572 | ok ? 1 : 0); |
| 573 | |
| 574 | // Post Scan stats |
| 575 | query_stats.addScannerStat(query_index, seq_id, QueryStat.ROWS_POST_FILTER, |
| 576 | mul_get_rows_post_filter); |
| 577 | query_stats.addScannerStat(query_index, seq_id, QueryStat.DPS_POST_FILTER, |
| 578 | mul_get_dps_post_filter); |
| 579 | query_stats.addScannerStat(query_index, seq_id, QueryStat.SCANNER_UID_TO_STRING_TIME, |
| 580 | mul_get_uid_resolved_time); |
| 581 | query_stats.addScannerStat(query_index, seq_id, QueryStat.UID_PAIRS_RESOLVED, |
| 582 | mul_get_uids_resolved); |
| 583 | query_stats.addScannerStat(query_index, seq_id, QueryStat.COMPACTION_TIME, |
| 584 | mul_get_compaction_time); |
| 585 | } |
| 586 | |
| 587 | if (ok) { |
| 588 | validateMultigetData(keyValues, annotations, histograms); |
| 589 | } |
| 590 | else { |
| 591 | finished_multi_get_cnt.incrementAndGet(); |
| 592 | } |
| 593 | |
| 594 | // check we have finished all the multi get |
| 595 | if (!checkAllFinishAndTriggerCallback()) { |
| 596 | // check to fire a new multi get in this concurrency bucket |
| 597 | List<MultiGetTask> salt_mul_get_tasks = multi_get_tasks.get(concurrency_index); |
| 598 | int task_index = multi_get_indexs.get(concurrency_index).incrementAndGet(); |
| 599 | if (task_index < salt_mul_get_tasks.size()) { |
| 600 | MultiGetTask task = salt_mul_get_tasks.get(task_index); |
| 601 | MulGetCB mgcb = new MulGetCB(concurrency_index, task.getTSUIDs(), task.getGets()); |
| 602 | mgcb.fetch(); |
| 603 | } |
| 604 | } |
no test coverage detected