| 255 | } |
| 256 | |
| 257 | Counter GetQueueTimeoutCnt(SdkTask* task) { |
| 258 | switch (task->Type()) { |
| 259 | case SdkTask::READ: |
| 260 | return reader_queue_timeout_cnt; |
| 261 | case SdkTask::MUTATION: |
| 262 | case SdkTask::BATCH_MUTATION: |
| 263 | return mutate_queue_timeout_cnt; |
| 264 | default: |
| 265 | abort(); |
| 266 | } |
| 267 | } |
| 268 | |
| 269 | Counter GetTaskCnt(SdkTask* task) { |
| 270 | switch (task->Type()) { |