"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "iogateway/MessageIOGateway.h" between
muscle7.61.zip and muscle7.62.zip

About: MUSCLE (Multi User Server Client Linking Environment) is a messaging server and networking API. The included server program ("muscled") lets its clients message each other, and/or store information in its serverside hierarchical database.

MessageIOGateway.h  (muscle7.61):MessageIOGateway.h  (muscle7.62)
skipping to change at line 160 skipping to change at line 160
* Instead, it sends the specified (requestMessage), and returns B_NO_ERROR if the Message successfully goes out * Instead, it sends the specified (requestMessage), and returns B_NO_ERROR if the Message successfully goes out
* over the TCP socket, or an error code otherwise. * over the TCP socket, or an error code otherwise.
* @param requestMessage the request Message to send * @param requestMessage the request Message to send
* @param targetIAP Where to connect to (via TCP) to send (requestMessage) * @param targetIAP Where to connect to (via TCP) to send (requestMessage)
* @param timeoutPeriod The maximum amount of time this function should wait for TCP to connect, before returning. * @param timeoutPeriod The maximum amount of time this function should wait for TCP to connect, before returning.
* @returns B_NO_ERROR if the Message was sent, or an error code if we could n't connect (or if we connected but couldn't send the data). * @returns B_NO_ERROR if the Message was sent, or an error code if we could n't connect (or if we connected but couldn't send the data).
* Note that there is no way to know what (if anything) the receivi ng client did with the Message. * Note that there is no way to know what (if anything) the receivi ng client did with the Message.
*/ */
status_t ExecuteSynchronousMessageSend(const Message & requestMessage, const IPAddressAndPort & targetIAP, uint64 timeoutPeriod = MUSCLE_TIME_NEVER); status_t ExecuteSynchronousMessageSend(const Message & requestMessage, const IPAddressAndPort & targetIAP, uint64 timeoutPeriod = MUSCLE_TIME_NEVER);
/** Calls through to our protected FlattenHeaderAndMessage() method. Provide
d for special-case classes that want to
* to access that functionality directly rather than going through the gatew
ay's usual DoOutput() interface.
* @param msgRef Reference to the Message object to flatten.
* @returns a Reference to a ByteBuffer containing the flattened bytes of bo
th the MessageIOGateway header
* and the passed-in Message object.
* @note see UnflattenHeaderAndMessage() for details.
*/
ByteBufferRef CallFlattenHeaderAndMessage(const MessageRef & msgRef) const {r
eturn FlattenHeaderAndMessage(msgRef);}
/** Calls through to our protected UnflattenHeaderAndMessage() method. Provi
ded for special-case classes that want to
* to access that functionality directly rather than going through the gatew
ay's usual DoInput() interface.
* @param bufRef Reference to a ByteBuffer object that contains the appropri
ate header
* bytes, followed by some flattened Message bytes.
* @returns a Reference to a Message object containing the Message that was
encoded in
* the ByteBuffer on success, or a NULL reference on failure.
* @note see UnflattenHeaderAndMessage() for details.
*/
MessageRef CallUnflattenHeaderAndMessage(const ConstByteBufferRef & bufRef) c
onst {return UnflattenHeaderAndMessage(bufRef);}
protected: protected:
virtual int32 DoOutputImplementation(uint32 maxBytes = MUSCLE_NO_LIMIT); virtual int32 DoOutputImplementation(uint32 maxBytes = MUSCLE_NO_LIMIT);
virtual int32 DoInputImplementation(AbstractGatewayMessageReceiver & receiver , uint32 maxBytes = MUSCLE_NO_LIMIT); virtual int32 DoInputImplementation(AbstractGatewayMessageReceiver & receiver , uint32 maxBytes = MUSCLE_NO_LIMIT);
/** /**
* Should flatten the specified Message object into a newly allocated ByteBuf fer * Should flatten the specified Message object into a newly allocated ByteBuf fer
* object and return the ByteBufferRef. The returned ByteBufferRef's content s * object and return the ByteBufferRef. The returned ByteBufferRef's content s
* should consist of (GetHeaderSize()) bytes of header, followed by the flatt ened * should consist of (GetHeaderSize()) bytes of header, followed by the flatt ened
* Message data. * Message data.
* @param msgRef Reference to a Message to flatten into a byte array. * @param msgRef Reference to a Message to flatten into a byte array.
 End of changes. 1 change blocks. 
0 lines changed or deleted 28 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)