nagai/fune
3
0
Fork 0
forked from mirrors/gecko-dev
Code Pull requests Activity

Bug 1944126: Update WebTransportChild r=saschanaz, a=dmeehan

Browse source 
Differential Revision: https://phabricator.services.mozilla.com/D236002
This commit is contained in:
Randell Jesup 2025-02-03 18:40:56 +00:00
parent 879ae06a1d
commit 836cb2bb61
1 changed files with 10 additions and 5 deletions
repo.diff.show_diff_stats Download patch file Download diff file Expand all files Collapse all files

15
dom/webtransport/child/WebTransportChild.cpp
View file

@ -34,7 +34,8 @@ void WebTransportChild::CloseAll() {
::mozilla::ipc::IPCResult WebTransportChild::RecvRemoteClosed( ::mozilla::ipc::IPCResult WebTransportChild::RecvRemoteClosed(
const bool& aCleanly, const uint32_t& aCode, const nsACString& aReason) { const bool& aCleanly, const uint32_t& aCode, const nsACString& aReason) {
if (mTransport) { if (mTransport) {
mTransport->RemoteClosed(aCleanly, aCode, aReason); RefPtr<WebTransport> self(mTransport);
self->RemoteClosed(aCleanly, aCode, aReason);
} }
return IPC_OK(); return IPC_OK();
} }
@ -43,7 +44,8 @@ void WebTransportChild::CloseAll() {
const uint64_t& aStreamId, const RefPtr<DataPipeReceiver>& aIncoming, const uint64_t& aStreamId, const RefPtr<DataPipeReceiver>& aIncoming,
const RefPtr<DataPipeSender>& aOutgoing) { const RefPtr<DataPipeSender>& aOutgoing) {
if (mTransport) { if (mTransport) {
mTransport->NewBidirectionalStream(aStreamId, aIncoming, aOutgoing); RefPtr<WebTransport> self(mTransport);
self->NewBidirectionalStream(aStreamId, aIncoming, aOutgoing);
} }
return IPC_OK(); return IPC_OK();
} }
@ -51,7 +53,8 @@ void WebTransportChild::CloseAll() {
::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingUnidirectionalStream( ::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingUnidirectionalStream(
const uint64_t& aStreamId, const RefPtr<DataPipeReceiver>& aStream) { const uint64_t& aStreamId, const RefPtr<DataPipeReceiver>& aStream) {
if (mTransport) { if (mTransport) {
mTransport->NewUnidirectionalStream(aStreamId, aStream); RefPtr<WebTransport> self(mTransport);
self->NewUnidirectionalStream(aStreamId, aStream);
} }
return IPC_OK(); return IPC_OK();
} }
@ -59,7 +62,8 @@ void WebTransportChild::CloseAll() {
::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingDatagram( ::mozilla::ipc::IPCResult WebTransportChild::RecvIncomingDatagram(
nsTArray<uint8_t>&& aData, const TimeStamp& aRecvTimeStamp) { nsTArray<uint8_t>&& aData, const TimeStamp& aRecvTimeStamp) {
if (mTransport) { if (mTransport) {
mTransport->NewDatagramReceived(std::move(aData), aRecvTimeStamp); RefPtr<WebTransport> self(mTransport);
self->NewDatagramReceived(std::move(aData), aRecvTimeStamp);
} }
return IPC_OK(); return IPC_OK();
} }
@ -67,7 +71,8 @@ void WebTransportChild::CloseAll() {
::mozilla::ipc::IPCResult WebTransportChild::RecvOnStreamResetOrStopSending( ::mozilla::ipc::IPCResult WebTransportChild::RecvOnStreamResetOrStopSending(
const uint64_t& aStreamId, const StreamResetOrStopSendingError& aError) { const uint64_t& aStreamId, const StreamResetOrStopSendingError& aError) {
if (mTransport) { if (mTransport) {
mTransport->OnStreamResetOrStopSending(aStreamId, aError); RefPtr<WebTransport> self(mTransport);
self->OnStreamResetOrStopSending(aStreamId, aError);
} }
return IPC_OK(); return IPC_OK();
} }