@@ -74,7 +74,7 @@ QuicStreamInitialize(
7474 Connection -> Settings .StreamMultiReceiveEnabled &&
7575 !Stream -> Flags .UseAppOwnedRecvBuffers ;
7676 Stream -> RecvMaxLength = UINT64_MAX ;
77- Stream -> RefCount = 1 ;
77+ CxPlatRefInitialize ( & Stream -> RefCount ) ;
7878 Stream -> SendRequestsTail = & Stream -> SendRequests ;
7979 Stream -> SendPriority = QUIC_STREAM_PRIORITY_DEFAULT ;
8080 CxPlatDispatchLockInitialize (& Stream -> ApiSendRequestLock );
@@ -89,8 +89,8 @@ QuicStreamInitialize(
8989 Stream -> ReceiveCompleteOperation -> API_CALL .Context -> Type = QUIC_API_TYPE_STRM_RECV_COMPLETE ;
9090 Stream -> ReceiveCompleteOperation -> API_CALL .Context -> STRM_RECV_COMPLETE .Stream = Stream ;
9191#if DEBUG
92- CxPlatRefInitializeMultiple (Stream -> RefTypeBiasCount , QUIC_STREAM_REF_COUNT );
93- CxPlatRefIncrement (& Stream -> RefTypeBiasCount [QUIC_STREAM_REF_APP ]);
92+ CxPlatRefInitializeMultiple (Stream -> RefTypeBiasedCount , QUIC_STREAM_REF_COUNT );
93+ CxPlatRefIncrement (& Stream -> RefTypeBiasedCount [QUIC_STREAM_REF_APP ]);
9494#endif
9595
9696 if (Stream -> Flags .Unidirectional ) {
@@ -174,7 +174,7 @@ QuicStreamInitialize(
174174
175175 if (Stream ) {
176176#if DEBUG
177- CxPlatRefDecrement (& Stream -> RefTypeBiasCount [QUIC_STREAM_REF_APP ]);
177+ CXPLAT_DBG_ASSERT (! CxPlatRefDecrement (& Stream -> RefTypeBiasedCount [QUIC_STREAM_REF_APP ]) );
178178 CxPlatDispatchLockAcquire (& Connection -> Streams .AllStreamsLock );
179179 CxPlatListEntryRemove (& Stream -> AllStreamsLink );
180180 CxPlatDispatchLockRelease (& Connection -> Streams .AllStreamsLock );
0 commit comments