Skip to content

Commit

Permalink
update sidecar
Browse files Browse the repository at this point in the history
  • Loading branch information
@ProjectsByJackHe
ProjectsByJackHe committed Sep 2, 2023
1 parent ec387f9 commit 9dbfc0b
Show file tree
Hide file tree
Showing 4 changed files with 135 additions and 65 deletions.
4 changes: 2 additions & 2 deletions src/core/stream_recv.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -206,7 +206,7 @@ QuicStreamProcessReliableResetFrame(
Stream->Flags.LocalCloseAcked = TRUE;
Stream->Flags.RemoteCloseAcked = TRUE;
QuicTraceLogStreamVerbose(

Check warning on line 208 in src/core/stream_recv.c

View check run for this annotation

Codecov / codecov/patch

src/core/stream_recv.c#L205-L208 

Added lines #L205 - L208 were not covered by tests
StreamProcessReliableReset,
ProcessReliableReset,
Stream,
"Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
Expand Down Expand Up @@ -1163,7 +1163,7 @@ QuicStreamReceiveComplete(
Stream->Flags.LocalCloseAcked = TRUE;
Stream->Flags.RemoteCloseAcked = TRUE;
QuicTraceLogStreamVerbose(
StreamReliableResetReceiveComplete,
ReliableResetReceiveComplete,
Stream,
"Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
Expand Down
70 changes: 38 additions & 32 deletions src/generated/linux/stream_recv.c.clog.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -216,35 +216,20 @@ tracepoint(CLOG_STREAM_RECV_C, QueueRecvFlush , arg1);\


/*----------------------------------------------------------
// Decoder Ring for StreamProcessReliableReset
// [strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side.
// Decoder Ring for ProcessReliableReset
// [strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu
// QuicTraceLogStreamVerbose(
StreamProcessReliableReset,
ProcessReliableReset,
Stream,
"Shutting down stream from Process Reliable Reset Frame. Recv Side.");
"Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
// arg1 = arg1 = Stream = arg1
// arg3 = arg3 = Stream->RecvBuffer.BaseOffset = arg3
// arg4 = arg4 = Stream->RecvMaxLength = arg4
----------------------------------------------------------*/
#ifndef _clog_3_ARGS_TRACE_StreamProcessReliableReset
#define _clog_3_ARGS_TRACE_StreamProcessReliableReset(uniqueId, arg1, encoded_arg_string)\
tracepoint(CLOG_STREAM_RECV_C, StreamProcessReliableReset , arg1);\

#endif




/*----------------------------------------------------------
// Decoder Ring for IndicatePeerSendShutdown
// [strm][%p] Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN
// QuicTraceLogStreamVerbose(
IndicatePeerSendShutdown,
Stream,
"Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN");
// arg1 = arg1 = Stream = arg1
----------------------------------------------------------*/
#ifndef _clog_3_ARGS_TRACE_IndicatePeerSendShutdown
#define _clog_3_ARGS_TRACE_IndicatePeerSendShutdown(uniqueId, arg1, encoded_arg_string)\
tracepoint(CLOG_STREAM_RECV_C, IndicatePeerSendShutdown , arg1);\
#ifndef _clog_5_ARGS_TRACE_ProcessReliableReset
#define _clog_5_ARGS_TRACE_ProcessReliableReset(uniqueId, arg1, encoded_arg_string, arg3, arg4)\
tracepoint(CLOG_STREAM_RECV_C, ProcessReliableReset , arg1, arg3, arg4);\

#endif

Expand Down Expand Up @@ -469,6 +454,24 @@ tracepoint(CLOG_STREAM_RECV_C, IgnoreRecvFlush , arg1);\



/*----------------------------------------------------------
// Decoder Ring for IndicatePeerSendShutdown
// [strm][%p] Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN
// QuicTraceLogStreamVerbose(
IndicatePeerSendShutdown,
Stream,
"Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN");
// arg1 = arg1 = Stream = arg1
----------------------------------------------------------*/
#ifndef _clog_3_ARGS_TRACE_IndicatePeerSendShutdown
#define _clog_3_ARGS_TRACE_IndicatePeerSendShutdown(uniqueId, arg1, encoded_arg_string)\
tracepoint(CLOG_STREAM_RECV_C, IndicatePeerSendShutdown , arg1);\

#endif




/*----------------------------------------------------------
// Decoder Ring for StreamReliableResetRecvGraceful
// [strm][%p] Shutting down stream [gracefully] Recv Side.
Expand All @@ -488,17 +491,20 @@ tracepoint(CLOG_STREAM_RECV_C, StreamReliableResetRecvGraceful , arg1);\


/*----------------------------------------------------------
// Decoder Ring for StreamReliableResetReceiveComplete
// [strm][%p] Shutting down stream from ReceiveComplete Recv Side.
// Decoder Ring for ReliableResetReceiveComplete
// [strm][%p] Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu
// QuicTraceLogStreamVerbose(
StreamReliableResetReceiveComplete,
ReliableResetReceiveComplete,
Stream,
"Shutting down stream from ReceiveComplete Recv Side.");
"Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
// arg1 = arg1 = Stream = arg1
// arg3 = arg3 = Stream->RecvBuffer.BaseOffset = arg3
// arg4 = arg4 = Stream->RecvMaxLength = arg4
----------------------------------------------------------*/
#ifndef _clog_3_ARGS_TRACE_StreamReliableResetReceiveComplete
#define _clog_3_ARGS_TRACE_StreamReliableResetReceiveComplete(uniqueId, arg1, encoded_arg_string)\
tracepoint(CLOG_STREAM_RECV_C, StreamReliableResetReceiveComplete , arg1);\
#ifndef _clog_5_ARGS_TRACE_ReliableResetReceiveComplete
#define _clog_5_ARGS_TRACE_ReliableResetReceiveComplete(uniqueId, arg1, encoded_arg_string, arg3, arg4)\
tracepoint(CLOG_STREAM_RECV_C, ReliableResetReceiveComplete , arg1, arg3, arg4);\

#endif

Expand Down
76 changes: 45 additions & 31 deletions src/generated/linux/stream_recv.c.clog.h.lttng.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -196,38 +196,26 @@ TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, QueueRecvFlush,


/*----------------------------------------------------------
// Decoder Ring for StreamProcessReliableReset
// [strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side.
// Decoder Ring for ProcessReliableReset
// [strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu
// QuicTraceLogStreamVerbose(
StreamProcessReliableReset,
ProcessReliableReset,
Stream,
"Shutting down stream from Process Reliable Reset Frame. Recv Side.");
"Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
// arg1 = arg1 = Stream = arg1
// arg3 = arg3 = Stream->RecvBuffer.BaseOffset = arg3
// arg4 = arg4 = Stream->RecvMaxLength = arg4
----------------------------------------------------------*/
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, StreamProcessReliableReset,
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, ProcessReliableReset,
TP_ARGS(
const void *, arg1),
TP_FIELDS(
ctf_integer_hex(uint64_t, arg1, arg1)
)
)



/*----------------------------------------------------------
// Decoder Ring for IndicatePeerSendShutdown
// [strm][%p] Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN
// QuicTraceLogStreamVerbose(
IndicatePeerSendShutdown,
Stream,
"Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN");
// arg1 = arg1 = Stream = arg1
----------------------------------------------------------*/
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, IndicatePeerSendShutdown,
TP_ARGS(
const void *, arg1),
const void *, arg1,
unsigned long long, arg3,
unsigned long long, arg4),
TP_FIELDS(
ctf_integer_hex(uint64_t, arg1, arg1)
ctf_integer(uint64_t, arg3, arg3)
ctf_integer(uint64_t, arg4, arg4)
)
)

Expand Down Expand Up @@ -482,6 +470,25 @@ TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, IgnoreRecvFlush,



/*----------------------------------------------------------
// Decoder Ring for IndicatePeerSendShutdown
// [strm][%p] Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN
// QuicTraceLogStreamVerbose(
IndicatePeerSendShutdown,
Stream,
"Indicating QUIC_STREAM_EVENT_PEER_SEND_SHUTDOWN");
// arg1 = arg1 = Stream = arg1
----------------------------------------------------------*/
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, IndicatePeerSendShutdown,
TP_ARGS(
const void *, arg1),
TP_FIELDS(
ctf_integer_hex(uint64_t, arg1, arg1)
)
)



/*----------------------------------------------------------
// Decoder Ring for StreamReliableResetRecvGraceful
// [strm][%p] Shutting down stream [gracefully] Recv Side.
Expand All @@ -502,19 +509,26 @@ TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, StreamReliableResetRecvGraceful,


/*----------------------------------------------------------
// Decoder Ring for StreamReliableResetReceiveComplete
// [strm][%p] Shutting down stream from ReceiveComplete Recv Side.
// Decoder Ring for ReliableResetReceiveComplete
// [strm][%p] Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu
// QuicTraceLogStreamVerbose(
StreamReliableResetReceiveComplete,
ReliableResetReceiveComplete,
Stream,
"Shutting down stream from ReceiveComplete Recv Side.");
"Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
Stream->RecvBuffer.BaseOffset, Stream->RecvMaxLength);
// arg1 = arg1 = Stream = arg1
// arg3 = arg3 = Stream->RecvBuffer.BaseOffset = arg3
// arg4 = arg4 = Stream->RecvMaxLength = arg4
----------------------------------------------------------*/
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, StreamReliableResetReceiveComplete,
TRACEPOINT_EVENT(CLOG_STREAM_RECV_C, ReliableResetReceiveComplete,
TP_ARGS(
const void *, arg1),
const void *, arg1,
unsigned long long, arg3,
unsigned long long, arg4),
TP_FIELDS(
ctf_integer_hex(uint64_t, arg1, arg1)
ctf_integer(uint64_t, arg3, arg3)
ctf_integer(uint64_t, arg4, arg4)
)
)

Expand Down
50 changes: 50 additions & 0 deletions src/manifest/clog.sidecar
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8838,6 +8838,26 @@
],
"macroName": "QuicTraceLogInfo"
},
"ProcessReliableReset": {
"ModuleProperites": {},
"TraceString": "[strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
"UniqueId": "ProcessReliableReset",
"splitArgs": [
{
"DefinationEncoding": "p",
"MacroVariableName": "arg1"
},
{
"DefinationEncoding": "llu",
"MacroVariableName": "arg3"
},
{
"DefinationEncoding": "llu",
"MacroVariableName": "arg4"
}
],
"macroName": "QuicTraceLogStreamVerbose"
},
"QueueDatagrams": {
"ModuleProperites": {},
"TraceString": "[conn][%p] Queuing %u UDP datagrams",
Expand Down Expand Up @@ -9258,6 +9278,26 @@
],
"macroName": "QuicTraceLogStreamVerbose"
},
"ReliableResetReceiveComplete": {
"ModuleProperites": {},
"TraceString": "[strm][%p] Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu",
"UniqueId": "ReliableResetReceiveComplete",
"splitArgs": [
{
"DefinationEncoding": "p",
"MacroVariableName": "arg1"
},
{
"DefinationEncoding": "llu",
"MacroVariableName": "arg3"
},
{
"DefinationEncoding": "llu",
"MacroVariableName": "arg4"
}
],
"macroName": "QuicTraceLogStreamVerbose"
},
"ReliableSendOffsetSet": {
"ModuleProperites": {},
"TraceString": "[strm][%p] Reliable send offset set to %llu",
Expand Down Expand Up @@ -15574,6 +15614,11 @@
"TraceID": "ProcessorInfoV2",
"EncodingString": "[ dll] Proc[%u] Group[%hu] Index[%u] Active=%hhu"
},
{
"UniquenessHash": "518b5117-c14d-ee4e-47c5-8264735c8638",
"TraceID": "ProcessReliableReset",
"EncodingString": "[strm][%p] Shutting down stream from Process Reliable Reset Frame. Recv Side. BaseOffset: %llu, RecvMaxLength: %llu"
},
{
"UniquenessHash": "18ef147d-5376-d7f2-f624-3b27af96dd05",
"TraceID": "QueueDatagrams",
Expand Down Expand Up @@ -15709,6 +15754,11 @@
"TraceID": "ReliableResetOnStreamAck",
"EncodingString": "[strm][%p] Shutting down stream [reliable] from OnStreamAck. Send side."
},
{
"UniquenessHash": "6ea13123-905c-3439-77cb-45bbd050b9bc",
"TraceID": "ReliableResetReceiveComplete",
"EncodingString": "[strm][%p] Shutting down stream from ReceiveComplete Recv Side. BaseOffset: %llu, RecvMaxLength: %llu"
},
{
"UniquenessHash": "84836f4f-d47f-cc00-7cb2-530ac90c70d3",
"TraceID": "ReliableSendOffsetSet",
Expand Down

0 comments on commit 9dbfc0b

Please sign in to comment.