Method executedTwice

test/stats/TestQueryStats.java:259–282

()

  }
  
  @Test
  public void executedTwice() throws Exception {
    final TSQuery query = new TSQuery();
    query.setStart("1h-ago");
    QueryStats stats = new QueryStats(remote, query, headers);
    stats.markSerialized(HttpResponseStatus.REQUEST_TIMEOUT, null);
    Map<String, Object> map = QueryStats.getRunningAndCompleteStats();
    assertNotNull(map);
    assertEquals(0, ((List<Object>)map.get("running")).size());
    assertEquals(1, ((Collection<QueryStats>)map.get("completed")).size());
    QueryStats completed = ((Collection<QueryStats>)map.get("completed"))
        .iterator().next();
    assertEquals(1, completed.getExecuted());
    
    stats = new QueryStats(remote, query, headers);
    stats.markSerialized(HttpResponseStatus.REQUEST_TIMEOUT, null);
    map = QueryStats.getRunningAndCompleteStats();
    assertNotNull(map);
    assertEquals(0, ((List<Object>)map.get("running")).size());
    assertEquals(1, ((Collection<QueryStats>)map.get("completed")).size());
    completed = ((Collection<QueryStats>)map.get("completed"))
        .iterator().next();
    assertEquals(2, completed.getExecuted());
  }

  @Test
  public void getStat() throws Exception {