package com.planet_ink.coffee_mud.core.threads;
import com.planet_ink.coffee_mud.core.database.DBInterface;
import com.planet_ink.coffee_mud.core.http.ProcessHTTPrequest;
import com.planet_ink.coffee_mud.core.interfaces.*;
import com.planet_ink.coffee_mud.core.*;
import com.planet_ink.coffee_mud.Abilities.interfaces.*;
import com.planet_ink.coffee_mud.Areas.interfaces.*;
import com.planet_ink.coffee_mud.Behaviors.interfaces.*;
import com.planet_ink.coffee_mud.CharClasses.interfaces.*;
import com.planet_ink.coffee_mud.Commands.interfaces.*;
import com.planet_ink.coffee_mud.Common.interfaces.*;
import com.planet_ink.coffee_mud.Exits.interfaces.*;
import com.planet_ink.coffee_mud.Items.interfaces.*;
import com.planet_ink.coffee_mud.Locales.interfaces.*;
import com.planet_ink.coffee_mud.MOBS.interfaces.*;
import com.planet_ink.coffee_mud.Races.interfaces.*;
import java.util.*;
import com.planet_ink.coffee_mud.Libraries.interfaces.*;
/*
Copyright 2000-2006 Bo Zimmerman
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
public class ServiceEngine implements ThreadEngine
{
public static final long STATUS_ALLMISCTICKS=Tickable.STATUS_MISC|Tickable.STATUS_MISC2|Tickable.STATUS_MISC3|Tickable.STATUS_MISC4|Tickable.STATUS_MISC5|Tickable.STATUS_MISC6;
public String ID(){return "ServiceEngine";}
public CMObject newInstance(){try{return (CMObject)getClass().newInstance();}catch(Exception e){return new ServiceEngine();}}
public void initializeClass(){}
public CMObject copyOf(){try{return (CMObject)this.clone();}catch(Exception e){return newInstance();}}
public int compareTo(Object o){ return CMClass.classID(this).compareToIgnoreCase(CMClass.classID(o));}
protected Vector tickGroup=new Vector();
public Enumeration tickGroups(){return ((Vector)tickGroup.clone()).elements();}
private boolean isSuspended=false;
public void delTickGroup(Tick tock)
{
synchronized(tickGroup)
{
tickGroup.removeElement(tock);
}
}
public void addTickGroup(Tick tock)
{
synchronized(tickGroup)
{
tickGroup.addElement(tock);
}
}
public Tick confirmAndGetTickThread(Tickable E, long TICK_TIME, int tickID)
{
Tick tock=null;
Tick almostTock=null;
for(Enumeration v=tickGroups();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
if((tock==null)
&&(almostTock.TICK_TIME==TICK_TIME)
&&(!almostTock.solitaryTicker)
&&(almostTock.numTickers()<TickableGroup.MAX_TICK_CLIENTS))
tock=almostTock;
if(almostTock.contains(E,tickID))
return null;
}
if(tock!=null) return tock;
tock=new Tick(TICK_TIME);
addTickGroup(tock);
return tock;
}
public void startTickDown(Tickable E, int tickID, int numTicks)
{ startTickDown(E,tickID,Tickable.TIME_TICK,numTicks); }
public void startTickDown(Tickable E,
int tickID,
long TICK_TIME,
int numTicks)
{
Tick tock=confirmAndGetTickThread(E,TICK_TIME,tickID);
if(tock==null) return;
TockClient client=new TockClient(E,numTicks,tickID);
if(client!=null)
{
if((tickID&65536)==65536)
tock.solitaryTicker=true;
tock.addTicker(client);
}
}
public boolean deleteTick(Tickable E, int tickID)
{
Tick almostTock=null;
Iterator set=null;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
set=almostTock.getTickSet(E,tickID);
if(set!=null)
for(;set.hasNext();)
almostTock.delTicker((TockClient)set.next());
}
return false;
}
public boolean isTicking(Tickable E, int tickID)
{
Tick almostTock=null;
Iterator set;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
set=almostTock.getTickSet(E,tickID);
if(set!=null) return true;
}
return false;
}
public boolean isAllSuspended(){return isSuspended;}
public void suspendAll(){isSuspended=true;}
public void resumeAll(){isSuspended=false;}
public void suspendTicking(Tickable E, int tickID){suspendResumeTicking(E,tickID,true);}
public void resumeTicking(Tickable E, int tickID){suspendResumeTicking(E,tickID,false);}
protected boolean suspendResumeTicking(Tickable E, int tickID, boolean suspend)
{
Tick almostTock=null;
Iterator set=null;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
set=almostTock.getTickSet(E,tickID);
if(set!=null)
for(;set.hasNext();)
((TockClient)set.next()).suspended=suspend;
}
return false;
}
public boolean isSuspended(Tickable E, int tickID)
{
Tick almostTock=null;
Iterator set=null;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
set=almostTock.getTickSet(E,tickID);
if((set!=null)&&(set.hasNext())) return true;
}
return false;
}
public boolean isHere(Tickable E2, Room here)
{
if(E2==null)
return false;
else
if(E2==here)
return true;
else
if((E2 instanceof MOB)
&&(((MOB)E2).location()==here))
return true;
else
if((E2 instanceof Item)
&&(((Item)E2).owner()==here))
return true;
else
if((E2 instanceof Item)
&&(((Item)E2).owner()!=null)
&&(((Item)E2).owner() instanceof MOB)
&&(((MOB)((Item)E2).owner()).location()==here))
return true;
else
if(E2 instanceof Exit)
{
for(int d=0;d<Directions.NUM_DIRECTIONS;d++)
if(here.rawExits()[d]==E2)
return true;
}
return false;
}
public String systemReport(String itemCode)
{
long totalMOBMillis=0;
long totalMOBTicks=0;
long topMOBMillis=0;
long topMOBTicks=0;
MOB topMOBClient=null;
for(int s=0;s<CMLib.sessions().size();s++)
{
Session S=CMLib.sessions().elementAt(s);
totalMOBMillis+=S.getTotalMillis();
totalMOBTicks+=S.getTotalTicks();
if(S.getTotalMillis()>topMOBMillis)
{
topMOBMillis=S.getTotalMillis();
topMOBTicks=S.getTotalTicks();
topMOBClient=S.mob();
}
}
if(itemCode.equalsIgnoreCase("totalMOBMillis"))
return ""+totalMOBMillis;
else
if(itemCode.equalsIgnoreCase("totalMOBMillisTime"))
return CMLib.english().returnTime(totalMOBMillis,0);
else
if(itemCode.equalsIgnoreCase("totalMOBMillisTimePlusAverage"))
return CMLib.english().returnTime(totalMOBMillis,totalMOBTicks);
else
if(itemCode.equalsIgnoreCase("totalMOBTicks"))
return ""+totalMOBTicks;
else
if(itemCode.equalsIgnoreCase("topMOBMillis"))
return ""+topMOBMillis;
else
if(itemCode.equalsIgnoreCase("topMOBMillisTime"))
return CMLib.english().returnTime(topMOBMillis,0);
else
if(itemCode.equalsIgnoreCase("topMOBMillisTimePlusAverage"))
return CMLib.english().returnTime(topMOBMillis,topMOBTicks);
else
if(itemCode.equalsIgnoreCase("topMOBTicks"))
return ""+topMOBTicks;
else
if(itemCode.equalsIgnoreCase("topMOBClient"))
{
if(topMOBClient!=null)
return topMOBClient.Name();
return "";
}
int totalTickers=0;
long totalMillis=0;
long totalTicks=0;
int topGroupNumber=-1;
long topGroupMillis=-1;
long topGroupTicks=0;
long topObjectMillis=-1;
long topObjectTicks=0;
int topObjectGroup=0;
Tickable topObjectClient=null;
int num=0;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
Tick almostTock=(Tick)v.nextElement();
totalTickers+=almostTock.numTickers();
totalMillis+=almostTock.milliTotal;
totalTicks+=almostTock.tickTotal;
if(almostTock.milliTotal>topGroupMillis)
{
topGroupMillis=almostTock.milliTotal;
topGroupTicks=almostTock.tickTotal;
topGroupNumber=num;
}
try{
for(Iterator e=almostTock.tickers();e.hasNext();)
{
TockClient C=(TockClient)e.next();
if(C.milliTotal>topObjectMillis)
{
topObjectMillis=C.milliTotal;
topObjectTicks=C.tickTotal;
topObjectClient=C.clientObject;
topObjectGroup=num;
}
}
}catch(NoSuchElementException e){}
num++;
}
if(itemCode.equalsIgnoreCase("freeMemory"))
return ""+(Runtime.getRuntime().freeMemory()/1000);
else
if(itemCode.equalsIgnoreCase("totalMemory"))
return ""+(Runtime.getRuntime().totalMemory()/1000);
else
if(itemCode.equalsIgnoreCase("totalTime"))
return ""+CMLib.english().returnTime(System.currentTimeMillis()-CMSecurity.getStartTime(),0);
else
if(itemCode.equalsIgnoreCase("startTime"))
return CMLib.time().date2String(CMSecurity.getStartTime());
else
if(itemCode.equalsIgnoreCase("currentTime"))
return CMLib.time().date2String(System.currentTimeMillis());
else
if(itemCode.equalsIgnoreCase("totalTickers"))
return ""+totalTickers;
else
if(itemCode.equalsIgnoreCase("totalMillis"))
return ""+totalMillis;
else
if(itemCode.equalsIgnoreCase("totalMillisTime"))
return CMLib.english().returnTime(totalMillis,0);
else
if(itemCode.equalsIgnoreCase("totalMillisTimePlusAverage"))
return CMLib.english().returnTime(totalMillis,totalTicks);
else
if(itemCode.equalsIgnoreCase("totalTicks"))
return ""+totalTicks;
else
if(itemCode.equalsIgnoreCase("tickgroupsize"))
return ""+tickGroup.size();
else
if(itemCode.equalsIgnoreCase("topGroupNumber"))
return ""+topGroupNumber;
else
if(itemCode.equalsIgnoreCase("topGroupMillis"))
return ""+topGroupMillis;
else
if(itemCode.equalsIgnoreCase("topGroupMillisTime"))
return CMLib.english().returnTime(topGroupMillis,0);
else
if(itemCode.equalsIgnoreCase("topGroupMillisTimePlusAverage"))
return CMLib.english().returnTime(topGroupMillis,topGroupTicks);
else
if(itemCode.equalsIgnoreCase("topGroupTicks"))
return ""+topGroupTicks;
else
if(itemCode.equalsIgnoreCase("topObjectMillis"))
return ""+topObjectMillis;
else
if(itemCode.equalsIgnoreCase("topObjectMillisTime"))
return CMLib.english().returnTime(topObjectMillis,0);
else
if(itemCode.equalsIgnoreCase("topObjectMillisTimePlusAverage"))
return CMLib.english().returnTime(topObjectMillis,topObjectTicks);
else
if(itemCode.equalsIgnoreCase("topObjectTicks"))
return ""+topObjectTicks;
else
if(itemCode.equalsIgnoreCase("topObjectGroup"))
return ""+topObjectGroup;
else
if(itemCode.equalsIgnoreCase("saveThreadMilliTotal"))
return ""+SaveThread.milliTotal;
else
if(itemCode.equalsIgnoreCase("saveThreadStatus"))
return ""+SaveThread.status;
else
if(itemCode.equalsIgnoreCase("saveThreadMilliTotalTime"))
return CMLib.english().returnTime(SaveThread.milliTotal,0);
else
if(itemCode.equalsIgnoreCase("utilThreadMilliTotal"))
return ""+UtiliThread.milliTotal;
else
if(itemCode.equalsIgnoreCase("utilThreadStatus"))
return ""+UtiliThread.status;
else
if(itemCode.equalsIgnoreCase("utilThreadMilliTotalTime"))
return CMLib.english().returnTime(UtiliThread.milliTotal,0);
else
if(itemCode.equalsIgnoreCase("saveThreadMilliTotalTimePlusAverage"))
return CMLib.english().returnTime(SaveThread.milliTotal,SaveThread.tickTotal);
else
if(itemCode.equalsIgnoreCase("saveThreadTickTotal"))
return ""+SaveThread.tickTotal;
else
if(itemCode.equalsIgnoreCase("utilThreadMilliTotalTimePlusAverage"))
return CMLib.english().returnTime(UtiliThread.milliTotal,UtiliThread.tickTotal);
else
if(itemCode.equalsIgnoreCase("utilThreadTickTotal"))
return ""+UtiliThread.tickTotal;
else
if(itemCode.equalsIgnoreCase("topObjectClient"))
{
if(topObjectClient!=null)
return topObjectClient.name();
return "";
}
return "";
}
public void tickAllTickers(Room here)
{
Tick almostTock=null;
TockClient C=null;
Tickable E2=null;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
try
{
for(Iterator e=almostTock.tickers();e.hasNext();)
{
C=(TockClient)e.next();
E2=C.clientObject;
if(here==null)
{
if(Tick.tickTicker(C,false))
almostTock.delTicker(C);
}
else
if(isHere(E2,here))
{
if(Tick.tickTicker(C,isSuspended))
almostTock.delTicker(C);
}
else
if((E2 instanceof Ability)
&&(isHere(((Ability)E2).affecting(),here)))
{
if(Tick.tickTicker(C,isSuspended))
almostTock.delTicker(C);
}
}
}catch(NoSuchElementException e){}
}
}
public String tickInfo(String which)
{
int grpstart=-1;
for(int i=0;i<which.length();i++)
if(Character.isDigit(which.charAt(i)))
{
grpstart=i;
break;
}
if(which.equalsIgnoreCase("tickGroupSize"))
return ""+tickGroup.size();
else
if(which.toLowerCase().startsWith("tickerssize"))
{
if(grpstart<0) return"";
int group=CMath.s_int(which.substring(grpstart));
if((group>=0)&&(group<tickGroup.size()))
return ""+((Tick)tickGroup.elementAt(group)).numTickers();
return "";
}
int group=-1;
int client=-1;
int clistart=which.indexOf("-");
if((grpstart>=0)&&(clistart>grpstart))
{
group=CMath.s_int(which.substring(grpstart,clistart));
client=CMath.s_int(which.substring(clistart+1));
}
if((group<0)||(client<0)||(group>=tickGroup.size())) return "";
Tick almostTock=(Tick)tickGroup.elementAt(group);
if(client>=almostTock.numTickers()) return "";
TockClient C=almostTock.fetchTicker(client);
if(C==null) return "";
if(which.toLowerCase().startsWith("tickername"))
{
Tickable E=C.clientObject;
if((E instanceof Ability)&&(E.ID().equals("ItemRejuv")))
E=((Ability)E).affecting();
if(E instanceof Room)
return CMLib.map().getExtendedRoomID((Room)E);
if(E!=null) return E.name();
return "!NULL!";
}
else
if(which.toLowerCase().startsWith("tickerid"))
return ""+C.tickID;
else
if(which.toLowerCase().startsWith("tickerstatus"))
return ((C.clientObject==null)?"":(""+C.clientObject.getTickStatus()));
else
if(which.toLowerCase().startsWith("tickercodeword"))
return getTickStatusSummary(C.clientObject);
else
if(which.toLowerCase().startsWith("tickertickdown"))
return ""+C.tickDown;
else
if(which.toLowerCase().startsWith("tickerretickdown"))
return ""+C.reTickDown;
else
if(which.toLowerCase().startsWith("tickermillitotal"))
return ""+C.milliTotal;
else
if(which.toLowerCase().startsWith("tickermilliavg"))
{
if(C.tickTotal==0) return "0";
return ""+(C.milliTotal/C.tickTotal);
}
else
if(which.toLowerCase().startsWith("tickerlaststartmillis"))
return ""+C.lastStart;
else
if(which.toLowerCase().startsWith("tickerlaststopmillis"))
return ""+C.lastStop;
else
if(which.toLowerCase().startsWith("tickerlaststartdate"))
return CMLib.time().date2String(C.lastStart);
else
if(which.toLowerCase().startsWith("tickerlaststopdate"))
return CMLib.time().date2String(C.lastStop);
else
if(which.toLowerCase().startsWith("tickerlastduration"))
{
if(C.lastStop>=C.lastStart)
return CMLib.english().returnTime(C.lastStop-C.lastStart,0);
return CMLib.english().returnTime(System.currentTimeMillis()-C.lastStart,0);
}
else
if(which.toLowerCase().startsWith("tickersuspended"))
return ""+C.suspended;
return "";
}
public void shutdownAll()
{
int numTicks=tickGroup.size();
int which=0;
while(tickGroup.size()>0)
{
Log.sysOut("ServiceEngine","Shutting down all tick "+which+"/"+numTicks+"...");
Tick tock=null;
synchronized(tickGroup){tock=(Tick)tickGroup.elementAt(0);}
if(tock!=null) tock.shutdown();
try{Thread.sleep(100);}catch(Exception e){}
which++;
}
Log.sysOut("ServiceEngine","Shutdown complete.");
}
public synchronized void clearDebri(Room room, int taskCode)
{
Tick almostTock=null;
TockClient C=null;
ItemTicker I=null;
MOB mob=null;
Vector roomSet=null;
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
roomSet=almostTock.getLocalItems(taskCode,room);
if(roomSet!=null)
for(Enumeration e=roomSet.elements();e.hasMoreElements();)
{
C=(TockClient)e.nextElement();
if(C.clientObject instanceof ItemTicker)
{
I=(ItemTicker)C.clientObject;
almostTock.delTicker(C);
I.setProperLocation(null);
}
else
if(C.clientObject instanceof MOB)
{
mob=(MOB)C.clientObject;
if((mob.isMonster())&&(!room.isInhabitant(mob)))
{
mob.destroy();
almostTock.delTicker(C);
}
}
}
}
}
public Vector getNamedTickingObjects(String name)
{
Vector V=new Vector();
Tick almostTock=null;
TockClient C=null;
name=name.toUpperCase().trim();
for(Enumeration v=tickGroup.elements();v.hasMoreElements();)
{
almostTock=(Tick)v.nextElement();
for(Iterator e=almostTock.tickers();e.hasNext();)
{
C=(TockClient)e.next();
if((C.clientObject!=null)
&&(C.clientObject.name().toUpperCase().indexOf(name)>=0)
&&(!V.contains(C.clientObject)))
V.addElement(C.clientObject);
}
}
return V;
}
public String getTickStatusSummary(Tickable obj)
{
if(obj==null) return "";
long code=obj.getTickStatus();
if(obj instanceof Environmental)
{
if(CMath.bset(code,Tickable.STATUS_BEHAVIOR))
{
long b=(code-Tickable.STATUS_BEHAVIOR);
String codeWord="Behavior #"+b;
if((b>=0)&&(b<((Environmental)obj).numBehaviors()))
{
Behavior B=((Environmental)obj).fetchBehavior((int)b);
codeWord+=" ("+B.name()+": "+B.getTickStatus();
}
return codeWord;
}
else
if((code&STATUS_ALLMISCTICKS)>0)
{
long base=(code&STATUS_ALLMISCTICKS);
int num=0;
for(int i=1;i<6;i++)
if((1<<(10+i))==base)
{ num=i; break;}
return "Misc"+num+" Activity #"+(code-base);
}
else
if(CMath.bset(code,Tickable.STATUS_AFFECT))
{
long b=(code-Tickable.STATUS_AFFECT);
String codeWord="Effect #"+b;
if((b>=0)&&(b<((Environmental)obj).numEffects()))
{
Environmental E=((Environmental)obj).fetchEffect((int)b);
codeWord+=" ("+E.name()+": "+E.getTickStatus()+")";
}
return codeWord;
}
}
String codeWord=null;
if(CMath.bset(code,Tickable.STATUS_BEHAVIOR))
codeWord="Behavior?!";
else
if(CMath.bset(code,Tickable.STATUS_AFFECT))
codeWord="Effect?!";
else
switch((int)code)
{
case (int)Tickable.STATUS_ALIVE:
codeWord="Alive"; break;
case (int)Tickable.STATUS_REBIRTH:
codeWord="Rebirth"; break;
case (int)Tickable.STATUS_CLASS:
codeWord="Class"; break;
case (int)Tickable.STATUS_DEAD:
codeWord="Dead"; break;
case (int)Tickable.STATUS_END:
codeWord="End"; break;
case (int)Tickable.STATUS_FIGHT:
codeWord="Fighting"; break;
case (int)Tickable.STATUS_NOT:
codeWord="!"; break;
case (int)Tickable.STATUS_OTHER:
codeWord="Other"; break;
case (int)Tickable.STATUS_RACE:
codeWord="Race"; break;
case (int)Tickable.STATUS_START:
codeWord="Start"; break;
case (int)Tickable.STATUS_WEATHER:
codeWord="Weather"; break;
default:
codeWord="?"; break;
}
return codeWord;
}
public String getServiceThreadSummary(Thread T)
{
if(T instanceof UtiliThread)
return " ("+UtiliThread.status+")";
else
if(T instanceof SaveThread)
return " ("+SaveThread.status+")";
else
if(T instanceof MudHost)
return " ("+((MudHost)T).getStatus()+")";
else
if(T instanceof ExternalHTTPRequests)
return " ("+((ExternalHTTPRequests)T).getHTTPstatus()+" - "+((ExternalHTTPRequests)T).getHTTPstatusInfo()+")";
return "";
}
}
