Name our invokers.
git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@4777 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -158,7 +158,7 @@ public class PeerManager
|
|||||||
// register ourselves with the node table
|
// register ourselves with the node table
|
||||||
final NodeRecord record = new NodeRecord(
|
final NodeRecord record = new NodeRecord(
|
||||||
_nodeName, hostName, (publicHostName == null) ? hostName : publicHostName, port);
|
_nodeName, hostName, (publicHostName == null) ? hostName : publicHostName, port);
|
||||||
_invoker.postUnit(new Invoker.Unit() {
|
_invoker.postUnit(new Invoker.Unit("registerNode") {
|
||||||
public boolean invoke () {
|
public boolean invoke () {
|
||||||
try {
|
try {
|
||||||
_noderepo.updateNode(record);
|
_noderepo.updateNode(record);
|
||||||
@@ -204,7 +204,7 @@ public class PeerManager
|
|||||||
PresentsServer.clmgr.removeClientObserver(this);
|
PresentsServer.clmgr.removeClientObserver(this);
|
||||||
|
|
||||||
// clear our record from the node table
|
// clear our record from the node table
|
||||||
_invoker.postUnit(new Invoker.Unit() {
|
_invoker.postUnit(new Invoker.Unit("deleteNode") {
|
||||||
public boolean invoke () {
|
public boolean invoke () {
|
||||||
try {
|
try {
|
||||||
_noderepo.deleteNode(_nodeName);
|
_noderepo.deleteNode(_nodeName);
|
||||||
@@ -624,7 +624,7 @@ public class PeerManager
|
|||||||
protected void refreshPeers ()
|
protected void refreshPeers ()
|
||||||
{
|
{
|
||||||
// load up information on our nodes
|
// load up information on our nodes
|
||||||
_invoker.postUnit(new Invoker.Unit() {
|
_invoker.postUnit(new Invoker.Unit("refreshPeers") {
|
||||||
public boolean invoke () {
|
public boolean invoke () {
|
||||||
try {
|
try {
|
||||||
// let the world know that we're alive
|
// let the world know that we're alive
|
||||||
|
|||||||
Reference in New Issue
Block a user