@@ -34,7 +34,8 @@ ::mozilla::ipc::IPCResult WebTransportChild::RecvCloseAll(
34
34
::mozilla::ipc::IPCResult WebTransportChild::RecvRemoteClosed (
35
35
const bool & aCleanly, const uint32_t & aCode, const nsACString& aReason) {
36
36
if (mTransport ) {
37
- mTransport ->RemoteClosed (aCleanly, aCode, aReason);
37
+ RefPtr<WebTransport> self (mTransport );
38
+ self->RemoteClosed (aCleanly, aCode, aReason);
38
39
}
39
40
return IPC_OK ();
40
41
}
@@ -43,31 +44,35 @@ ::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingBidirectionalStream(
43
44
const uint64_t & aStreamId, const RefPtr<DataPipeReceiver>& aIncoming,
44
45
const RefPtr<DataPipeSender>& aOutgoing) {
45
46
if (mTransport ) {
46
- mTransport ->NewBidirectionalStream (aStreamId, aIncoming, aOutgoing);
47
+ RefPtr<WebTransport> self (mTransport );
48
+ self->NewBidirectionalStream (aStreamId, aIncoming, aOutgoing);
47
49
}
48
50
return IPC_OK ();
49
51
}
50
52
51
53
::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingUnidirectionalStream (
52
54
const uint64_t & aStreamId, const RefPtr<DataPipeReceiver>& aStream) {
53
55
if (mTransport ) {
54
- mTransport ->NewUnidirectionalStream (aStreamId, aStream);
56
+ RefPtr<WebTransport> self (mTransport );
57
+ self->NewUnidirectionalStream (aStreamId, aStream);
55
58
}
56
59
return IPC_OK ();
57
60
}
58
61
59
62
::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingDatagram (
60
63
nsTArray<uint8_t >&& aData, const TimeStamp& aRecvTimeStamp) {
61
64
if (mTransport ) {
62
- mTransport ->NewDatagramReceived (std::move (aData), aRecvTimeStamp);
65
+ RefPtr<WebTransport> self (mTransport );
66
+ self->NewDatagramReceived (std::move (aData), aRecvTimeStamp);
63
67
}
64
68
return IPC_OK ();
65
69
}
66
70
67
71
::mozilla::ipc::IPCResult WebTransportChild::RecvOnStreamResetOrStopSending (
68
72
const uint64_t & aStreamId, const StreamResetOrStopSendingError& aError) {
69
73
if (mTransport ) {
70
- mTransport ->OnStreamResetOrStopSending (aStreamId, aError);
74
+ RefPtr<WebTransport> self (mTransport );
75
+ self->OnStreamResetOrStopSending (aStreamId, aError);
71
76
}
72
77
return IPC_OK ();
73
78
}
0 commit comments