AfflictionNetworks/narya
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use an ObserverList.

Browse Source 
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@1838 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
Walter Korman
2002-10-27 02:03:13 +00:00
parent 76ba2840c4
commit 28a3cde90b
1 changed files with 39 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/java/com/threerings/crowd/client/OccupantDirector.java
+39 -20
View File
@@ -1,13 +1,17 @@
// //
// $Id: OccupantDirector.java,v 1.3 2002/10/27 01:25:08 mdb Exp $ // $Id: OccupantDirector.java,v 1.4 2002/10/27 02:03:13 shaper Exp $
package com.threerings.crowd.client; package com.threerings.crowd.client;
import java.util.ArrayList;
import java.util.Iterator; import java.util.Iterator;
import com.samskivert.util.HashIntMap; import com.samskivert.util.HashIntMap;
import com.threerings.presents.dobj.*; import com.samskivert.util.ObserverList;
import com.threerings.presents.dobj.EntryAddedEvent;
import com.threerings.presents.dobj.EntryRemovedEvent;
import com.threerings.presents.dobj.EntryUpdatedEvent;
import com.threerings.presents.dobj.SetListener;
import com.threerings.crowd.Log; import com.threerings.crowd.Log;
import com.threerings.crowd.data.OccupantInfo; import com.threerings.crowd.data.OccupantInfo;
@@ -147,15 +151,17 @@ public class OccupantDirector
} }
// put the info in our cache for use when we get a left event // put the info in our cache for use when we get a left event
OccupantInfo info = (OccupantInfo)event.getEntry(); final OccupantInfo info = (OccupantInfo)event.getEntry();
int bodyOid = info.getBodyOid(); int bodyOid = info.getBodyOid();
_ocache.put(bodyOid, info); _ocache.put(bodyOid, info);
// now let the occupant observers know what's up // now let the occupant observers know what's up
for (int i = 0; i < _observers.size(); i++) { _observers.apply(new ObserverList.ObserverOp() {
OccupantObserver obs = (OccupantObserver)_observers.get(i); public boolean apply (Object observer) {
obs.occupantEntered(info); ((OccupantObserver)observer).occupantEntered(info);
} return true;
}
});
} }
/** /**
@@ -168,12 +174,14 @@ public class OccupantDirector
return; return;
} }
OccupantInfo info = (OccupantInfo)event.getEntry(); Log.info("entryUpdated [event=" + event + "].");
final OccupantInfo info = (OccupantInfo)event.getEntry();
int bodyOid = info.getBodyOid(); int bodyOid = info.getBodyOid();
// grab the old info to give observers a chance to figure out what // grab the old info to give observers a chance to figure out what
// changed // changed
OccupantInfo oinfo = (OccupantInfo)_ocache.get(bodyOid); final OccupantInfo oinfo = (OccupantInfo)_ocache.get(bodyOid);
if (oinfo == null) { if (oinfo == null) {
Log.warning("Urk! Occupant updated for whom we we have no " + Log.warning("Urk! Occupant updated for whom we we have no " +
"prior info record [info=" + info + "]."); "prior info record [info=" + info + "].");
@@ -183,10 +191,12 @@ public class OccupantDirector
_ocache.put(bodyOid, info); _ocache.put(bodyOid, info);
// now let the occupant observers know what's up // now let the occupant observers know what's up
for (int i = 0; i < _observers.size(); i++) { _observers.apply(new ObserverList.ObserverOp() {
OccupantObserver obs = (OccupantObserver)_observers.get(i); public boolean apply (Object observer) {
obs.occupantUpdated(oinfo, info); ((OccupantObserver)observer).occupantUpdated(oinfo, info);
} return true;
}
});
} }
/** /**
@@ -201,7 +211,7 @@ public class OccupantDirector
int bodyOid = ((Integer)event.getKey()).intValue(); int bodyOid = ((Integer)event.getKey()).intValue();
// see if we have an occupant object for this body // see if we have an occupant object for this body
OccupantInfo info = (OccupantInfo)_ocache.get(bodyOid); final OccupantInfo info = (OccupantInfo)_ocache.get(bodyOid);
if (info == null) { if (info == null) {
Log.warning("Occupant removed but no cached info for them? " + Log.warning("Occupant removed but no cached info for them? " +
"[boid=" + bodyOid + ", place=" + _place + "]."); "[boid=" + bodyOid + ", place=" + _place + "].");
@@ -209,13 +219,22 @@ public class OccupantDirector
} }
// let the occupant observers know what's up // let the occupant observers know what's up
for (int i = 0; i < _observers.size(); i++) { _observers.apply(new ObserverList.ObserverOp() {
OccupantObserver obs = (OccupantObserver)_observers.get(i); public boolean apply (Object observer) {
obs.occupantLeft(info); ((OccupantObserver)observer).occupantLeft(info);
} return true;
}
});
} }
protected ArrayList _observers = new ArrayList(); /** The occupant observers to keep abreast of occupant antics. */
protected ObserverList _observers =
new ObserverList(ObserverList.SAFE_IN_ORDER_NOTIFY);
/** The user's current location. */
protected PlaceObject _place; protected PlaceObject _place;
/** A cache of the occupant info for all users in our current
* location. */
protected HashIntMap _ocache = new HashIntMap(); protected HashIntMap _ocache = new HashIntMap();
} }