/* * This program is free software: you can redistribute it and/or modify it under * the terms of the GNU General Public License as published by the Free Software * Foundation, either version 3 of the License, or (at your option) any later * version. * * This program is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more * details. * * You should have received a copy of the GNU General Public License along with * this program. If not, see . */ package com.l2jserver.gameserver.taskmanager; import java.util.Collection; import java.util.logging.Logger; import com.l2jserver.Config; import com.l2jserver.gameserver.ThreadPoolManager; import com.l2jserver.gameserver.model.L2Object; import com.l2jserver.gameserver.model.L2World; import com.l2jserver.gameserver.model.L2WorldRegion; import com.l2jserver.gameserver.model.actor.L2Character; import com.l2jserver.gameserver.model.actor.L2Playable; import com.l2jserver.gameserver.model.actor.instance.L2GuardInstance; public class KnownListUpdateTaskManager { protected static final Logger _log = Logger.getLogger(KnownListUpdateTaskManager.class.getName()); private final static int FULL_UPDATE_TIMER = 100; private Object syncObject = new Object(); public static boolean updatePass = true; // Do full update every FULL_UPDATE_TIMER * KNOWNLIST_UPDATE_INTERVAL public static int _fullUpdateTimer = FULL_UPDATE_TIMER; private KnownListUpdateTaskManager() { ThreadPoolManager.getInstance().scheduleAi(new KnownListUpdate(), 1000); } public static KnownListUpdateTaskManager getInstance() { return SingletonHolder._instance; } public Object getSync() { return syncObject; } private class KnownListUpdate implements Runnable { public KnownListUpdate() { } public void run() { try { for (L2WorldRegion regions[] : L2World.getInstance().getAllWorldRegions()) { for (L2WorldRegion r : regions) // go through all world regions { // avoid stopping update if something went wrong in updateRegion() try { if (r.isActive()) // and check only if the region is active { updateRegion(r, (_fullUpdateTimer == FULL_UPDATE_TIMER), updatePass); } } catch (Exception e) { e.printStackTrace(); } } } } catch (Exception e) { _log.warning(e.toString()); } updatePass = !updatePass; if (_fullUpdateTimer > 0) _fullUpdateTimer--; else _fullUpdateTimer = FULL_UPDATE_TIMER; ThreadPoolManager.getInstance().scheduleAi(new KnownListUpdate(), Config.KNOWNLIST_UPDATE_INTERVAL); } } public void updateRegion(L2WorldRegion region, boolean fullUpdate, boolean forgetObjects) { // synchronized (syncObject) { Collection vObj = region.getVisibleObjects().values(); // synchronized (region.getVisibleObjects()) { for (L2Object object : vObj) // and for all members in region { if (object == null || !object.isVisible()) continue; // skip dying objects if (forgetObjects) { object.getKnownList().forgetObjects((object instanceof L2Playable || (Config.GUARD_ATTACK_AGGRO_MOB && object instanceof L2GuardInstance) || fullUpdate)); continue; } if (object instanceof L2Playable || (Config.GUARD_ATTACK_AGGRO_MOB && object instanceof L2GuardInstance) || fullUpdate) { for (L2WorldRegion regi : region.getSurroundingRegions()) { Collection inrObj = regi.getVisibleObjects().values(); // synchronized (regi.getVisibleObjects()) { for (L2Object _object : inrObj) if (_object != object) object.getKnownList().addKnownObject(_object); } } } else if (object instanceof L2Character) { for (L2WorldRegion regi : region.getSurroundingRegions()) { Collection inrPls = regi.getVisiblePlayable().values(); // synchronized (regi.getVisiblePlayable()) { if (regi.isActive()) for (L2Object _object : inrPls) if (_object != object) object.getKnownList().addKnownObject(_object); } } } } } } } @SuppressWarnings("synthetic-access") private static class SingletonHolder { protected static final KnownListUpdateTaskManager _instance = new KnownListUpdateTaskManager(); } }