Michael Bayne
c27356b4c3
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@4766 542714f4-19e9-0310-aa3c-eee0fc999fb1
308 lines
11 KiB
Java
308 lines
11 KiB
Java
//
|
|
// $Id$
|
|
//
|
|
// Narya library - tools for developing networked games
|
|
// Copyright (C) 2002-2007 Three Rings Design, Inc., All Rights Reserved
|
|
// http://www.threerings.net/code/narya/
|
|
//
|
|
// This library is free software; you can redistribute it and/or modify it
|
|
// under the terms of the GNU Lesser General Public License as published
|
|
// by the Free Software Foundation; either version 2.1 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// This library 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
|
|
// Lesser General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Lesser General Public
|
|
// License along with this library; if not, write to the Free Software
|
|
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
package com.threerings.presents.peer.data;
|
|
|
|
import com.samskivert.util.ObjectUtil;
|
|
|
|
import com.threerings.io.SimpleStreamableObject;
|
|
import com.threerings.io.Streamable;
|
|
|
|
import com.threerings.presents.dobj.DObject;
|
|
import com.threerings.presents.dobj.DSet;
|
|
|
|
/**
|
|
* Contains information that one node published for all of its peers.
|
|
*/
|
|
public class NodeObject extends DObject
|
|
{
|
|
// AUTO-GENERATED: FIELDS START
|
|
/** The field name of the <code>peerService</code> field. */
|
|
public static final String PEER_SERVICE = "peerService";
|
|
|
|
/** The field name of the <code>clients</code> field. */
|
|
public static final String CLIENTS = "clients";
|
|
|
|
/** The field name of the <code>locks</code> field. */
|
|
public static final String LOCKS = "locks";
|
|
|
|
/** The field name of the <code>acquiringLock</code> field. */
|
|
public static final String ACQUIRING_LOCK = "acquiringLock";
|
|
|
|
/** The field name of the <code>releasingLock</code> field. */
|
|
public static final String RELEASING_LOCK = "releasingLock";
|
|
|
|
/** The field name of the <code>cacheData</code> field. */
|
|
public static final String CACHE_DATA = "cacheData";
|
|
// AUTO-GENERATED: FIELDS END
|
|
|
|
/** Identifies a locked resource. */
|
|
public static class Lock extends SimpleStreamableObject
|
|
implements Comparable<Lock>, DSet.Entry
|
|
{
|
|
/** The resource type. Only resources of the same type will have their ids compared. */
|
|
public String type;
|
|
|
|
/** The resource identifier, which can be <code>null</code> for singleton resources. */
|
|
public Comparable id;
|
|
|
|
public Lock ()
|
|
{
|
|
}
|
|
|
|
public Lock (String type, Comparable id)
|
|
{
|
|
this.type = type;
|
|
this.id = id;
|
|
}
|
|
|
|
// documentation inherited from interface Comparable
|
|
public int compareTo (Lock olock)
|
|
{
|
|
int v1 = type.compareTo(olock.type);
|
|
if (v1 != 0 || id == null) {
|
|
return v1;
|
|
}
|
|
@SuppressWarnings("unchecked") int v2 = id.compareTo(olock.id);
|
|
return v2;
|
|
}
|
|
|
|
// documentation inherited from interface DSet.Entry
|
|
public Comparable getKey ()
|
|
{
|
|
return this;
|
|
}
|
|
|
|
@Override // documentation inherited
|
|
public int hashCode ()
|
|
{
|
|
return type.hashCode() + (id == null ? 0 : id.hashCode());
|
|
}
|
|
|
|
@Override // documentation inherited
|
|
public boolean equals (Object other)
|
|
{
|
|
Lock olock = (Lock)other;
|
|
return type.equals(olock.type) && ObjectUtil.equals(id, olock.id);
|
|
}
|
|
}
|
|
|
|
/** Used for informing peers of changes to persistent data. */
|
|
public static class CacheData extends SimpleStreamableObject
|
|
{
|
|
/** The cache that should be purged. */
|
|
public String cache;
|
|
|
|
/** The stale data in the cache. */
|
|
public Streamable data;
|
|
|
|
public CacheData ()
|
|
{
|
|
}
|
|
|
|
public CacheData (String cache, Streamable data)
|
|
{
|
|
this.cache = cache;
|
|
this.data = data;
|
|
}
|
|
}
|
|
|
|
/** The service used to make requests of the node. */
|
|
public PeerMarshaller peerService;
|
|
|
|
/** Contains information on all clients connected to this node. */
|
|
public DSet<ClientInfo> clients = new DSet<ClientInfo>();
|
|
|
|
/** The set of locks held by this node. */
|
|
public DSet<Lock> locks = new DSet<Lock>();
|
|
|
|
/** Used to broadcast a node's desire to acquire a lock. */
|
|
public Lock acquiringLock;
|
|
|
|
/** Used to broadcast a node's desire to release a lock. */
|
|
public Lock releasingLock;
|
|
|
|
/** A field we use to broadcast changes to possible cached data. */
|
|
public CacheData cacheData;
|
|
|
|
// AUTO-GENERATED: METHODS START
|
|
/**
|
|
* Requests that the <code>peerService</code> field be set to the
|
|
* specified value. The local value will be updated immediately and an
|
|
* event will be propagated through the system to notify all listeners
|
|
* that the attribute did change. Proxied copies of this object (on
|
|
* clients) will apply the value change when they received the
|
|
* attribute changed notification.
|
|
*/
|
|
public void setPeerService (PeerMarshaller value)
|
|
{
|
|
PeerMarshaller ovalue = this.peerService;
|
|
requestAttributeChange(
|
|
PEER_SERVICE, value, ovalue);
|
|
this.peerService = value;
|
|
}
|
|
|
|
/**
|
|
* Requests that the specified entry be added to the
|
|
* <code>clients</code> set. The set will not change until the event is
|
|
* actually propagated through the system.
|
|
*/
|
|
public void addToClients (ClientInfo elem)
|
|
{
|
|
requestEntryAdd(CLIENTS, clients, elem);
|
|
}
|
|
|
|
/**
|
|
* Requests that the entry matching the supplied key be removed from
|
|
* the <code>clients</code> set. The set will not change until the
|
|
* event is actually propagated through the system.
|
|
*/
|
|
public void removeFromClients (Comparable key)
|
|
{
|
|
requestEntryRemove(CLIENTS, clients, key);
|
|
}
|
|
|
|
/**
|
|
* Requests that the specified entry be updated in the
|
|
* <code>clients</code> set. The set will not change until the event is
|
|
* actually propagated through the system.
|
|
*/
|
|
public void updateClients (ClientInfo elem)
|
|
{
|
|
requestEntryUpdate(CLIENTS, clients, elem);
|
|
}
|
|
|
|
/**
|
|
* Requests that the <code>clients</code> field be set to the
|
|
* specified value. Generally one only adds, updates and removes
|
|
* entries of a distributed set, but certain situations call for a
|
|
* complete replacement of the set value. The local value will be
|
|
* updated immediately and an event will be propagated through the
|
|
* system to notify all listeners that the attribute did
|
|
* change. Proxied copies of this object (on clients) will apply the
|
|
* value change when they received the attribute changed notification.
|
|
*/
|
|
public void setClients (DSet<com.threerings.presents.peer.data.ClientInfo> value)
|
|
{
|
|
requestAttributeChange(CLIENTS, value, this.clients);
|
|
@SuppressWarnings("unchecked") DSet<com.threerings.presents.peer.data.ClientInfo> clone =
|
|
(value == null) ? null : value.typedClone();
|
|
this.clients = clone;
|
|
}
|
|
|
|
/**
|
|
* Requests that the specified entry be added to the
|
|
* <code>locks</code> set. The set will not change until the event is
|
|
* actually propagated through the system.
|
|
*/
|
|
public void addToLocks (NodeObject.Lock elem)
|
|
{
|
|
requestEntryAdd(LOCKS, locks, elem);
|
|
}
|
|
|
|
/**
|
|
* Requests that the entry matching the supplied key be removed from
|
|
* the <code>locks</code> set. The set will not change until the
|
|
* event is actually propagated through the system.
|
|
*/
|
|
public void removeFromLocks (Comparable key)
|
|
{
|
|
requestEntryRemove(LOCKS, locks, key);
|
|
}
|
|
|
|
/**
|
|
* Requests that the specified entry be updated in the
|
|
* <code>locks</code> set. The set will not change until the event is
|
|
* actually propagated through the system.
|
|
*/
|
|
public void updateLocks (NodeObject.Lock elem)
|
|
{
|
|
requestEntryUpdate(LOCKS, locks, elem);
|
|
}
|
|
|
|
/**
|
|
* Requests that the <code>locks</code> field be set to the
|
|
* specified value. Generally one only adds, updates and removes
|
|
* entries of a distributed set, but certain situations call for a
|
|
* complete replacement of the set value. The local value will be
|
|
* updated immediately and an event will be propagated through the
|
|
* system to notify all listeners that the attribute did
|
|
* change. Proxied copies of this object (on clients) will apply the
|
|
* value change when they received the attribute changed notification.
|
|
*/
|
|
public void setLocks (DSet<com.threerings.presents.peer.data.NodeObject.Lock> value)
|
|
{
|
|
requestAttributeChange(LOCKS, value, this.locks);
|
|
@SuppressWarnings("unchecked") DSet<com.threerings.presents.peer.data.NodeObject.Lock> clone =
|
|
(value == null) ? null : value.typedClone();
|
|
this.locks = clone;
|
|
}
|
|
|
|
/**
|
|
* Requests that the <code>acquiringLock</code> field be set to the
|
|
* specified value. The local value will be updated immediately and an
|
|
* event will be propagated through the system to notify all listeners
|
|
* that the attribute did change. Proxied copies of this object (on
|
|
* clients) will apply the value change when they received the
|
|
* attribute changed notification.
|
|
*/
|
|
public void setAcquiringLock (NodeObject.Lock value)
|
|
{
|
|
NodeObject.Lock ovalue = this.acquiringLock;
|
|
requestAttributeChange(
|
|
ACQUIRING_LOCK, value, ovalue);
|
|
this.acquiringLock = value;
|
|
}
|
|
|
|
/**
|
|
* Requests that the <code>releasingLock</code> field be set to the
|
|
* specified value. The local value will be updated immediately and an
|
|
* event will be propagated through the system to notify all listeners
|
|
* that the attribute did change. Proxied copies of this object (on
|
|
* clients) will apply the value change when they received the
|
|
* attribute changed notification.
|
|
*/
|
|
public void setReleasingLock (NodeObject.Lock value)
|
|
{
|
|
NodeObject.Lock ovalue = this.releasingLock;
|
|
requestAttributeChange(
|
|
RELEASING_LOCK, value, ovalue);
|
|
this.releasingLock = value;
|
|
}
|
|
|
|
/**
|
|
* Requests that the <code>cacheData</code> field be set to the
|
|
* specified value. The local value will be updated immediately and an
|
|
* event will be propagated through the system to notify all listeners
|
|
* that the attribute did change. Proxied copies of this object (on
|
|
* clients) will apply the value change when they received the
|
|
* attribute changed notification.
|
|
*/
|
|
public void setCacheData (NodeObject.CacheData value)
|
|
{
|
|
NodeObject.CacheData ovalue = this.cacheData;
|
|
requestAttributeChange(
|
|
CACHE_DATA, value, ovalue);
|
|
this.cacheData = value;
|
|
}
|
|
// AUTO-GENERATED: METHODS END
|
|
}
|