Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- private static Response processSingleCall(ReplicableCommand command, long timeout,
- Address destination, ResponseMode mode,
- Marshaller marshaller, CommandAwareRpcDispatcher card, boolean oob,
- JGroupsTransport transport) throws Exception {
- if (trace) log.tracef("Replication task sending %s to single recipient %s with response mode %s", command, destination, mode);
- boolean rsvp = isRsvpCommand(command);
- boolean noFlowControl = isTopologyCommand(command);
- ...
- }
- protected static Message constructMessage(Buffer buf, Address recipient, boolean oob, ResponseMode mode, boolean rsvp,
- boolean totalOrder, boolean noFlowControl) {
- Message msg = new Message();
- msg.setBuffer(buf);
- if (oob) msg.setFlag(Message.Flag.OOB);
- //some issues with the new bundler. put back the DONT_BUNDLE flag.
- if (oob || mode != ResponseMode.GET_NONE) msg.setFlag(Message.Flag.DONT_BUNDLE);
- if (rsvp) msg.setFlag(Message.Flag.RSVP);
- if (noFlowControl) msg.setFlag(Message.Flag.NO_FC);
- //In total order protocol, the sequencer is in the protocol stack so we need to bypass the protocol
- if(!totalOrder) {
- msg.setFlag(Message.Flag.NO_TOTAL_ORDER);
- } else {
- msg.clearFlag(Message.Flag.OOB);
- }
- if (recipient != null) msg.setDest(recipient);
- return msg;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement