I’ve been trying to figure out the Distributed Networking system based on what’s in the documentation and the few samples I’ve been able to find. I’ve gotten the samples working fine, but I’m still puzzled as to how exactly to apply them to my project.
Right now, I’m trying to set up a very basic system with a DistributedNode object on a server. At this point, I’m having trouble getting a ServerRepository object set up - I’m not sure what I’m missing, but I’m getting
TypeError: ConnectionReader.addConnection() argument 1 must be Connection, not NoneTypeThis is the code I’ve got so far:
nettest.py:
from direct.directbase.DirectStart import *
from direct.distributed.DistributedNode import *
from direct.distributed.ClientRepository import *
from direct.distributed.ServerRepository import *
from direct.distributed.ServerRepository import ServerRepository
from direct.distributed.DistributedNodeAI import DistributedNodeAI
import sys
class DistributedThingy(DistributedNode):
def __init__(self, cr):
DistributedNode.__init__(self, cr)
def generate(self):
print 'Thingy generated!'
class DistributedThingyAI(DistributedNodeAI):
""" This is the AI-side implementation of DistributedThingy. """
def __init__(self, cr):
DistributedNodeAI.__init__(self, cr)
print 'ThingyAI inited!'
class MyServerRepository(ServerRepository):
def __init__(self):
tcpPort = base.config.GetInt('server-port', 4288)
dcFileNames = ['direct.dc']
ServerRepository.__init__(self, tcpPort = tcpPort, serverAddress = '', dcFileNames = dcFileNames)
class Server:
def __init__(self):
self.sr = MyServerRepository()
print '-s to start server instance, -c to start client instance'
if len(sys.argv) > 1:
if sys.argv[1] == '-s':
s = Server()
print 'Server started!'
run()
if sys.argv[1] == '-c':
print 'Client not yet implemented...'and my direct.dc file:
keyword broadcast;
keyword ram;
keyword p2p;
from direct.distributed import DistributedObject/AI
from direct.distributed import TimeManager/AI
from direct.distributed import DistributedNode/AI
from direct.distributed import DistributedSmoothNode/AI
import nettest.py
struct BarrierData {
uint16 context;
string name;
uint32 avIds[];
};
// The most fundamental class
dclass DistributedObject {
// These are used to support DistributedObjectAI.beginBarrier() and
// the matching DistributedObject.doneBarrier(). If you don't call
// these functions, you don't care about these distributed methods.
// (Actually, you probably don't care anyway.)
setBarrierData(BarrierData data[]) broadcast ram;
setBarrierReady(uint16 context);
};
dclass DistributedNode: DistributedObject {
setX(int16 / 10) broadcast ram;
setY(int16 / 10) broadcast ram;
setZ(int16 / 10) broadcast ram;
setH(int16 % 360 / 10) broadcast ram;
setP(int16 % 360 / 10) broadcast ram;
setR(int16 % 360 / 10) broadcast ram;
setPos: setX, setY, setZ;
setHpr: setH, setP, setR;
setPosHpr: setX, setY, setZ, setH, setP, setR;
setXY: setX, setY;
setXZ: setX, setZ;
setXYH: setX, setY, setH;
setXYZH: setX, setY, setZ, setH;
};
dclass DistributedSmoothNode: DistributedNode {
// Component set pos and hpr functions.
setComponentL(uint64) broadcast ram;
setComponentX(int16 / 10) broadcast ram;
setComponentY(int16 / 10) broadcast ram;
setComponentZ(int16 / 10) broadcast ram;
setComponentH(int16 % 360 / 10) broadcast ram;
setComponentP(int16 % 360 / 10) broadcast ram;
setComponentR(int16 % 360 / 10) broadcast ram;
setComponentT(int16 timestamp) broadcast ram;
// Composite set pos and hpr functions. These map to combinations
// of one or more of the above components. They all include
// setComponentT(), which must be called last.
setSmStop: setComponentT;
setSmH: setComponentH, setComponentT;
setSmZ: setComponentZ, setComponentT;
setSmXY: setComponentX, setComponentY, setComponentT;
setSmXZ: setComponentX, setComponentZ, setComponentT;
setSmPos: setComponentX, setComponentY, setComponentZ, setComponentT;
setSmHpr: setComponentH, setComponentP, setComponentR, setComponentT;
setSmXYH: setComponentX, setComponentY, setComponentH, setComponentT;
setSmXYZH: setComponentX, setComponentY, setComponentZ, setComponentH, setComponentT;
setSmPosHpr: setComponentX, setComponentY, setComponentZ, setComponentH, setComponentP, setComponentR, setComponentT;
// special update if L (being location, such as zoneId) changes, send everything, intended to
// keep position and 'location' in sync
setSmPosHprL: setComponentL, setComponentX, setComponentY, setComponentZ, setComponentH, setComponentP, setComponentR, setComponentT;
clearSmoothing(int8 bogus) broadcast;
suggestResync(uint32 avId, int16 timestampA, int16 timestampB,
int32 serverTimeSec, uint16 serverTimeUSec,
uint16 / 100 uncertainty);
returnResync(uint32 avId, int16 timestampB,
int32 serverTimeSec, uint16 serverTimeUSec,
uint16 / 100 uncertainty);
};
dclass DistributedThingy: DistributedNode {
};I’m suspect I’m doing something out of sequence, but I can’t work out where the issue is.
“import nettest.py” is what I get for coding after a long workday…
