Skip to content

Commit

Permalink
better mps counting
Browse files Browse the repository at this point in the history
  • Loading branch information
Orbiter committed Jan 7, 2017
1 parent 6a9ef86 commit 8ed10ef
Showing 1 changed file with 3 additions and 9 deletions.
12 changes: 3 additions & 9 deletions src/org/loklak/data/DAO.java
Original file line number Diff line number Diff line change
Expand Up @@ -815,7 +815,7 @@ private static long countLocalHourMessages(final long millis, boolean created_at
if (millis > 3600000L) return countLocalDayMessages(millis, created_at);
if (created_at && millis == 3600000L) return elasticsearch_client.count(IndexName.messages_hour.name());
return elasticsearch_client.count(
created_at ? IndexName.messages_hour.name() : IndexName.messages_day.name(),
created_at ? IndexName.messages_hour.name() : IndexName.messages_week.name(),
created_at ? AbstractObjectEntry.CREATED_AT_FIELDNAME : AbstractObjectEntry.TIMESTAMP_FIELDNAME,
millis);
}
Expand All @@ -824,7 +824,7 @@ private static long countLocalDayMessages(final long millis, boolean created_at)
if (millis > 86400000L) return countLocalWeekMessages(millis, created_at);
if (created_at && millis == 86400000L) return elasticsearch_client.count(IndexName.messages_hour.name());
return elasticsearch_client.count(
created_at ? IndexName.messages_day.name() : IndexName.messages_week.name(),
created_at ? IndexName.messages_day.name() : IndexName.messages.name(),
created_at ? AbstractObjectEntry.CREATED_AT_FIELDNAME : AbstractObjectEntry.TIMESTAMP_FIELDNAME,
millis);
}
Expand All @@ -850,13 +850,7 @@ public static long countLocalMessages(final long millis, boolean created_at) {
created_at ? AbstractObjectEntry.CREATED_AT_FIELDNAME : AbstractObjectEntry.TIMESTAMP_FIELDNAME,
millis == Long.MAX_VALUE ? -1 : millis);
}
/*
*
long countLocalMinMessages = DAO.countLocalMessages(60000L);
long countLocalHourMessages = DAO.countLocalMessages(3600000L);
long countLocalDayMessages = DAO.countLocalMessages(86400000L);
long countLocalWeekMessages = DAO.countLocalMessages(604800000L);
*/

public static long countLocalMessages() {
return elasticsearch_client.count(IndexName.messages.name(), AbstractObjectEntry.TIMESTAMP_FIELDNAME, -1);
}
Expand Down

0 comments on commit 8ed10ef

Please sign in to comment.