155 virtual BError init(
BString boapNsHost =
"",
int port = 0,
int threaded = 0,
int isBoapns = 0);
BError process(BoapServerConnection *conn, BoapPacket &rx, BoapPacket &tx)
Definition: Boap.cpp:961
BError pingLocked(BUInt32 &apiVersion)
Definition: Boap.cpp:254
BoapPacket()
Definition: Boap.cpp:54
BError(BoapServiceObject::* BoapFunc)(BoapServerConnection *conn, BoapPacket &rx, BoapPacket &tx)
Definition: Boap.h:200
BoapPacket orx
Definition: Boap.h:88
virtual BError process(BoapServerConnection *conn, BoapPacket &rx, BoapPacket &tx)
Definition: Boap.cpp:784
BoapPacket orx
Definition: Boap.h:101
This class provides an interface for sending simple integer events via a file descriptor....
Definition: BEvent1.h:60
virtual BError validate()
Validate the connection.
Definition: Boap.cpp:606
virtual BError processEvent(BString objectName, BString name, BInt32 arg)
Definition: Boap.cpp:996
int oreconnect
Handle an automatic reconnect on timeout.
Definition: Boap.h:91
BUInt32 omaxLength
Definition: Boap.h:86
BError sendEvent(BString signalName, BInt32 arg)
Definition: Boap.cpp:977
BoapServiceObject * oobject
Definition: Boap.h:118
virtual void setMaxLength(BUInt32 maxLength)
Definition: Boap.cpp:594
BString getHostName()
Definition: Boap.cpp:859
BString oname
Definition: Boap.h:81
BoapPacket otx
Definition: Boap.h:87
BUInt32 oapiVersion
Definition: Boap.h:229
void setTimeout(int timeout)
Sets the timeout in micro seconds. -1 is wait indefinitely.
Definition: Boap.cpp:324
~BoapPacket()
Definition: Boap.cpp:56
BUInt32 BoapService
Definition: Boap.h:24
virtual BError process()
Definition: Boap.cpp:510
int peekHead(BoapPacketHead &head)
Definition: Boap.cpp:86
BoapServer()
Definition: Boap.cpp:624
BUInt32 service
Definition: Boap.h:31
BError performSend(BoapPacket &tx)
Performs a send to the named service.
Definition: Boap.cpp:345
BoapSignalObject()
Definition: Boap.cpp:468
uint64_t BUInt64
Definition: BTypes.h:23
BUInt8 cmd
Definition: BoapMc.h:385
BoapMc1PacketHead head
Definition: BoapMc1.h:20
virtual ~BoapClientObject()
Definition: Boap.cpp:125
BUInt32 length
Definition: Boap.h:30
BString oname
Definition: Boap.h:228
BoapServiceEntry(BoapService service=0, BoapServiceObject *object=0)
Definition: Boap.h:113
BError ping(BUInt32 &apiVersion)
Pings the connection and finds the remotes version number.
Definition: Boap.cpp:244
BoapType
Definition: Boap.h:23
BError connectService(BString name)
Connects to the named service.
Definition: Boap.cpp:128
int popHead(BoapPacketHead &head)
Definition: Boap.cpp:95
BoapPriority
Definition: Boap.h:25
BList< BoapFuncEntry > ofuncList
Definition: Boap.h:230
virtual ~BoapServiceObject()
Definition: Boap.cpp:901
BSocket & getSocket()
Definition: Boap.cpp:851
BError doConnectionPriority(BoapServerConnection *conn, BoapPacket &rx, BoapPacket &tx)
Definition: Boap.cpp:933
BUInt32 oapiVersion
Definition: Boap.h:82
BString name()
Definition: Boap.cpp:912
BError performRecv(BoapPacket &rx)
Performs a receive.
Definition: Boap.cpp:362
BoapPacket otx
Definition: Boap.h:100
BError setName(BString name)
Definition: Boap.cpp:904
BSocket & getEventSocket()
Definition: Boap.cpp:855
BoapService oservice
Definition: Boap.h:84
int getConnectionsNumber()
Definition: Boap.cpp:863
This class provides an interface for polling a number of file descriptors. It uses round robin pollin...
Definition: BPoll.h:43
BString getServiceName()
Get the name of the service.
Definition: Boap.cpp:240
BMutex olock
Definition: Boap.h:89
BError setConnectionPriority(BoapPriority priority)
Sets the connection priority.
Definition: Boap.cpp:280
BUInt32 ocmd
Definition: Boap.h:205
int32_t BInt32
Definition: BTypes.h:20
virtual ~BoapServer()
Definition: Boap.cpp:632
uint32_t BUInt32
Definition: BTypes.h:21
BError run()
Definition: BoapSimple.cc:443
BoapService oservice
Definition: Boap.h:117
virtual BError handleReconnect(BError err)
Handle a reconnect performing autorisaztion if required.
Definition: Boap.cpp:463
virtual BError init(BString boapNsHost="", int port=0, int threaded=0, int isBoapns=0)
Definition: Boap.cpp:636
virtual BError processEvent(BoapPacket &rx)
Definition: Boap.cpp:799
BoapFunc ofunc
Definition: Boap.h:206
BError performSend(BoapPacket &tx)
Definition: Boap.cpp:472
BoapClientObject(BString name="")
Definition: Boap.cpp:115
int pushHead(BoapPacketHead &head)
Definition: Boap.cpp:75
virtual BSocket & getSocket()
Definition: Boap.cpp:590
virtual BError getHead(BoapPacketHead &head)
Definition: Boap.cpp:598
void setMaxLength(BUInt32 maxLength)
Sets the maximum packet length.
Definition: Boap.cpp:320
BUInt32 cmd
Definition: Boap.h:32
const BUInt32 apiVersion
Definition: BoapnsC.h:20
virtual void clientGone(BoapServerConnection *client)
Definition: Boap.cpp:693
BUInt64 onumOperations
Definition: Boap.h:191
virtual BError sendEvent(BoapPacket &tx)
Definition: Boap.cpp:829
BError checkApiVersion()
Definition: Boap.cpp:328
int otimeout
Definition: Boap.h:90
BoapServerConnection(BoapServer &boapServer, int fd)
Definition: Boap.cpp:496
int oconnected
Definition: Boap.h:85
BUInt32 address
Definition: BFirmware.h:53
IP aware socket address.
Definition: BSocket.h:57
BError disconnectService()
Disconnects from the named service.
Definition: Boap.cpp:228
virtual BoapServerConnection * newConnection(int fd, BSocketAddressINET address)
Definition: Boap.cpp:882
BoapServiceObject(BoapServer &server, BString name="")
Definition: Boap.cpp:894
BError doPing(BoapServerConnection *conn, BoapPacket &rx, BoapPacket &tx)
Definition: Boap.cpp:916
virtual BError init()
Initialise connection.
Definition: Boap.cpp:504
void closeConnections()
Definition: Boap.cpp:869
const BUInt32 BoapMagic
Definition: Boap.h:22
BUInt32 type
Definition: Boap.h:29
BError performCall(BoapPacket &tx, BoapPacket &rx)
Performs a RPC call to the named service.
Definition: Boap.cpp:421
BoapPriority opriority
Definition: Boap.h:83
BUInt32 getCmd()
Definition: Boap.cpp:67
virtual BError addObject(BoapServiceObject *object)
Definition: Boap.cpp:776
BoapFuncEntry(int cmd, BoapFunc func)
Definition: Boap.cpp:890
BoapServer & oserver
Definition: Boap.h:227
void updateHead()
Definition: Boap.cpp:59
virtual ~BoapServerConnection()
Definition: Boap.cpp:501