package com.floyd.bukkit.petition;
import java.io.File;
import java.io.PrintStream;
import java.util.HashMap;
import java.util.concurrent.ConcurrentHashMap;
import org.bukkit.Server;
import org.bukkit.entity.Player;
public class NotifierThread extends Thread
{
private Boolean stop = Boolean.valueOf(false);
private Long interval = Long.valueOf(300000L);
private HashMap, Integer count = new HashMap();
private PetitionPlugin plugin = null;
private String baseDir = \"plugins/PetitionPlugin\";
private Player player = null;
public NotifierThread(PetitionPlugin owner) {
this.plugin = owner;
}
public void run()
{
System.out.println(\"[Pe] NotifierThread started\");
while (!this.stop.booleanValue())
{
try {
sleep(this.interval.longValue());
} catch (InterruptedException e) {
System.out.println(\"[Pe] NotifierThread sleep interrupted\");
}
this.count.clear();
File dir = new File(this.baseDir);
for (String filename : dir.list()) {
if (this.stop.booleanValue()) return;
if (filename.endsWith(\".ticket\")) {
String[] parts = filename.split(\"[\'.\']\");
Integer id = Integer.valueOf(parts[0]);
try {
while (!this.plugin.SetPetitionLock(id, \"*NotifierThread*\", Boolean.valueOf(false)))
try {
Thread.sleep(100L);
}
catch (InterruptedException localInterruptedException1)
{
}
PetitionObject petition = new PetitionObject(id);
if (petition.isValid()) {
Integer found = (Integer)this.count.get(petition.Owner());
if (found == null) found = Integer.valueOf(0);
this.count.put(petition.Owner(), Integer.valueOf(found.intValue() + 1));
}
}
finally {
this.plugin.SetPetitionLock(id, \"*NotifierThread*\", Boolean.valueOf(true));
}
}
}
Integer total = Integer.valueOf(0);
for (String name : this.count.keySet()) {
Integer found = (Integer)this.count.get(name);
total = Integer.valueOf(total.intValue() + found.intValue());
Player p = this.plugin.getServer().getPlayer(name);
if (p != null) {
if (found.intValue() == 1)
p.sendMessage(\"[Pe]