@@ -47,6 +47,7 @@ module Control.Distributed.Process.Internal.Primitives
47 , handleMessage_
47 , handleMessage_
48 , handleMessageIf_
48 , handleMessageIf_
50 , delegate
51 , delegate
@@ -473,6 +474,26 @@ forward msg them = do
473 liftIO $ traceEvent (localEventBus node)
474 liftIO $ traceEvent (localEventBus node)
474 (MxSent them us msg)
475 (MxSent them us msg)
477+-- | Forward a raw 'Message' to the given 'ProcessId'.
479+-- Unlike 'forward', this function is insensitive to 'reconnect'. It will
480+-- try to send the message regardless of the history of connection failures
481+-- between the nodes.
482+uforward :: Message -> ProcessId -> Process ()
483+uforward msg them = do
485+ let node = processNode proc
487+ nid = localNodeId node
488+ destNode = (processNodeId them) in do
489+ case destNode == nid of
490+ True -> sendCtrlMsg Nothing (LocalSend them msg)
491+ False -> sendCtrlMsg (Just destNode) $ UnreliableSend (processLocalId them)
493+ -- We do not fire the trace event until after the sending is complete;
494+ -- In the remote case, 'sendCtrlMsg' can block in the networking stack.
495+ liftIO $ traceEvent (localEventBus node)
496+ (MxSent them us msg)
477-- | Wrap a 'Serializable' value in a 'Message'. Note that 'Message's are
498-- | Wrap a 'Serializable' value in a 'Message'. Note that 'Message's are
478-- 'Serializable' - like the datum they contain - but also note, deserialising
499-- 'Serializable' - like the datum they contain - but also note, deserialising