/dports/security/snort3/snort3-3.1.19.0/src/service_inspectors/http2_inspect/ |
H A D | http2_stream_splitter_impl.cc | 72 if (!stream || !stream->is_open(source_id)) in data_frame_header_checks() 126 session_data->header_octets_seen[source_id] = 0; in non_data_scan() 156 if (session_data->preface[source_id]) in implement_scan() 189 switch(session_data->scan_state[source_id]) in implement_scan() 226 scan_frame_header[source_id]); in implement_scan() 229 scan_frame_header[source_id]); in implement_scan() 325 scan_frame_header[source_id]); in implement_scan() 335 if (stream && stream->is_open(source_id) && !stream->is_discard_set(source_id)) in implement_scan() 386 HttpCommon::SourceId source_id) in implement_reassemble() argument 516 session_data->frame_data[source_id] = session_data->frame_reassemble[source_id]; in implement_reassemble() [all …]
|
H A D | http2_data_cutter.cc | 37 session_data(_session_data), source_id(src_id) in Http2DataCutter() 46 assert(session_data->frame_lengths[source_id].size() == 1); in scan() 47 data_len = session_data->frame_lengths[source_id].front() - in scan() 48 session_data->padding_length[source_id]; in scan() 109 session_data->header_octets_seen[source_id] = 0; in scan() 110 session_data->scan_state[source_id] = SCAN_FRAME_HEADER; in scan() 116 session_data->current_stream[source_id]); in scan() 121 stream->set_end_stream_on_data_flush(source_id); in scan() 133 session_data->payload_discard[source_id] = true; in scan() 135 session_data->frame_lengths[source_id].pop(); in scan() [all …]
|
H A D | http2_stream_splitter.cc | 101 if (session_data->abort_flow[source_id]) in scan() 111 session_data->abort_flow[source_id] = true; in scan() 148 flags, source_id, tcp_close); in reassemble() 163 if (session_data->abort_flow[source_id]) in reassemble() 171 if (session_data->payload_discard[source_id]) in reassemble() 176 session_data->bytes_scanned[source_id] = 0; in reassemble() 215 if (session_data->abort_flow[source_id]) in finish() 218 if (session_data->tcp_close[source_id]) in finish() 221 session_data->abort_flow[source_id] = true; in finish() 224 session_data->tcp_close[source_id] = true; in finish() [all …]
|
H A D | http2_flow_data.cc | 135 *infractions[source_id] += INF_TOO_MANY_STREAMS; in get_processing_stream() 136 events[source_id]->create_event(EVENT_TOO_MANY_STREAMS); in get_processing_stream() 157 if (key <= max_stream_id[source_id]) in get_processing_stream() 164 max_stream_id[source_id] = key; in get_processing_stream() 216 return find_stream(current_stream[source_id]); in find_current_stream() 231 void Http2FlowData::set_processing_stream_id(const SourceId source_id) in set_processing_stream_id() argument 234 if (frame_type[source_id] == FT_PUSH_PROMISE) in set_processing_stream_id() 236 events[source_id], infractions[source_id], frame_data[source_id], in set_processing_stream_id() 237 frame_data_size[source_id]); in set_processing_stream_id() 239 processing_stream_id = current_stream[source_id]; in set_processing_stream_id() [all …]
|
H A D | http2_headers_frame_trailer.cc | 51 *session_data->infractions[source_id] += INF_TRAILERS_NOT_END; in Http2HeadersFrameTrailer() 52 session_data->events[source_id]->create_event(EVENT_TRAILERS_NOT_END); in Http2HeadersFrameTrailer() 63 *session_data->infractions[source_id] += INF_FRAME_SEQUENCE; in valid_sequence() 64 session_data->events[source_id]->create_event(EVENT_FRAME_SEQUENCE); in valid_sequence() 75 if (http_flow->get_type_expected(source_id) != HttpEnums::SEC_TRAILER) in analyze_http1() 84 session_data->hi_ss[source_id]->reassemble(session_data->flow, in analyze_http1() 99 stream->set_state(source_id, STREAM_ERROR); in analyze_http1() 108 stream->set_state(source_id, STREAM_ERROR); in analyze_http1() 112 process_decoded_headers(http_flow, source_id); in analyze_http1() 117 switch (stream->get_state(source_id)) in update_stream_state() [all …]
|
H A D | http2_stream.h | 41 uint32_t data_len, HttpCommon::SourceId source_id); 53 { return state[source_id]; } in get_state() 54 bool is_open(HttpCommon::SourceId source_id); 55 void set_end_stream_on_data_flush(HttpCommon::SourceId source_id) in set_end_stream_on_data_flush() argument 56 { end_stream_on_data_flush[source_id] = true; } in set_end_stream_on_data_flush() 57 bool is_end_stream_on_data_flush(HttpCommon::SourceId source_id) in is_end_stream_on_data_flush() argument 58 { return end_stream_on_data_flush[source_id]; } in is_end_stream_on_data_flush() 61 void set_discard(HttpCommon::SourceId source_id) in set_discard() argument 62 { discard[source_id] = true; } in set_discard() 63 bool is_discard_set(HttpCommon::SourceId source_id) in is_discard_set() argument [all …]
|
H A D | http2_frame.cc | 45 SourceId source_id, Http2Stream* stream_) : in Http2Frame() argument 46 session_data(session_data), source_id(source_id), stream(stream_) in Http2Frame() 63 switch(session_data->frame_type[source_id]) in new_frame() 68 session_data, source_id, stream); in new_frame() 71 session_data, source_id, stream); in new_frame() 75 source_id, stream); in new_frame() 83 source_id, stream); in new_frame() 87 source_id, stream); in new_frame() 91 source_id, stream); in new_frame() 95 source_id, stream); in new_frame() [all …]
|
H A D | http2_push_promise_frame.cc | 51 if (source_id == SRC_SERVER and stream->get_stream_id() % 2 != 0) in Http2PushPromiseFrame() 53 *session_data->infractions[source_id] += INF_INVALID_STREAM_ID; in Http2PushPromiseFrame() 54 session_data->events[source_id]->create_event(EVENT_INVALID_STREAM_ID); in Http2PushPromiseFrame() 60 *session_data->infractions[source_id] += INF_PUSH_WHEN_PROHIBITED; in Http2PushPromiseFrame() 64 session_data->infractions[source_id]); in Http2PushPromiseFrame() 76 if (source_id == SRC_CLIENT) in valid_sequence() 78 *session_data->infractions[source_id] += INF_C2S_PUSH; in valid_sequence() 79 session_data->events[source_id]->create_event(EVENT_C2S_PUSH); in valid_sequence() 87 *session_data->infractions[source_id] += INF_INVALID_PROMISED_STREAM; in valid_sequence() 98 *session_data->infractions[source_id] += INF_BAD_PUSH_SEQUENCE; in valid_sequence() [all …]
|
/dports/security/snort3/snort3-3.1.19.0/src/service_inspectors/http_inspect/ |
H A D | http_stream_splitter_finish.cc | 65 source_id); in finish() 76 if (session_data->tcp_close[source_id]) in finish() 83 session_data->tcp_close[source_id] = true; in finish() 101 if ((session_data->cutter[source_id] != nullptr) && in finish() 103 session_data->partial_raw_bytes[source_id])) in finish() 121 delete session_data->cutter[source_id]; in finish() 122 session_data->cutter[source_id] = nullptr; in finish() 131 (session_data->cutter[source_id] == nullptr)) in finish() 148 if (!session_data->mime_state[source_id]) in finish() 159 get_header(source_id); in finish() [all …]
|
H A D | http_stream_splitter_reassemble.cc | 102 session_data->compression[source_id], session_data->compress_stream[source_id], in chunk_spray() 132 session_data->compression[source_id], session_data->compress_stream[source_id], in chunk_spray() 252 flags, source_id, tcp_close); in reassemble() 312 session_data->running_total[source_id] += len; in reassemble() 313 if (session_data->running_total[source_id] > total) in reassemble() 335 session_data->running_total[source_id] = 0; in reassemble() 345 session_data->half_reset(source_id); in reassemble() 394 session_data->compression[source_id], session_data->compress_stream[source_id], in reassemble() 416 session_data->section_offset[source_id] - session_data->num_excess[source_id]; in reassemble() 418 if (session_data->partial_flush[source_id]) in reassemble() [all …]
|
H A D | http_flow_data.cc | 147 assert((source_id == SRC_CLIENT) || (source_id == SRC_SERVER)); in half_reset() 163 compression[source_id] = CMP_NONE; in half_reset() 172 delete mime_state[source_id]; in half_reset() 175 delete infractions[source_id]; in half_reset() 177 section_offset[source_id] = 0; in half_reset() 181 if (source_id == SRC_CLIENT) in half_reset() 348 assert(transaction[source_id]->get_infractions(source_id) != nullptr); in get_infractions() 349 return transaction[source_id]->get_infractions(source_id); in get_infractions() 357 h2_body_state[source_id] = state; in finish_h2_body() 358 partial_flush[source_id] = false; in finish_h2_body() [all …]
|
H A D | http_msg_header.cc | 55 transaction->set_header(this, source_id); in HttpMsgHeader() 151 if (source_id == SRC_CLIENT) in gen_events() 176 if (source_id == SRC_CLIENT) in gen_events() 272 if ((source_id == SRC_SERVER) && in update_flow() 418 if (source_id == SRC_CLIENT) in update_flow() 469 if (source_id == SRC_CLIENT) in prepare_body() 497 if (source_id == SRC_CLIENT) in setup_file_processing() 661 if (source_id == SRC_CLIENT || in setup_file_decompression() 686 memcpy(data, (void*)&source_id, sizeof(source_id)); in set_multi_file_processing_id() 687 uint32_t offset = sizeof(source_id); in set_multi_file_processing_id() [all …]
|
H A D | http_msg_body.cc | 48 body_octets(session_data->body_octets[source_id]), in HttpMsgBody() 49 first_body(session_data->body_octets[source_id] == 0) in HttpMsgBody() 97 if (session_data->partial_flush[source_id]) in clean_partial() 100 if (session_data->detect_depth_remaining[source_id] > 0) in clean_partial() 123 && session_data->partial_flush[source_id]) in analyze() 145 if (session_data->file_depth_remaining[source_id] > 0 or in analyze() 199 if (!session_data->partial_flush[source_id]) in analyze() 365 auto back = !session_data->partial_flush[source_id]; in do_enhanced_js_normalization() 366 auto http_header = get_header(source_id); in do_enhanced_js_normalization() 392 transaction->get_infractions(source_id), session_data->events[source_id], in do_legacy_js_normalization() [all …]
|
H A D | http_stream_splitter_scan.cc | 44 session_data->num_excess[source_id] = num_excess; in prepare_flush() 77 session_data->data_length[source_id], in get_cutter() 80 session_data->compression[source_id]); in get_cutter() 86 session_data->compression[source_id]); in get_cutter() 91 session_data->compression[source_id]); in get_cutter() 94 session_data->data_length[source_id], in get_cutter() 97 session_data->compression[source_id]); in get_cutter() 189 if (session_data->tcp_close[source_id]) in scan() 225 if (source_id == SRC_CLIENT) in scan() 258 max_length, session_data->get_infractions(source_id), session_data->events[source_id], in scan() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/viz/common/frame_sinks/ |
H A D | begin_frame_source_unittest.cc | 34 EXPECT_NE(source1.source_id(), source2.source_id()); in TEST() 35 EXPECT_NE(source1.source_id(), source3.source_id()); in TEST() 36 EXPECT_NE(source2.source_id(), source3.source_id()); in TEST() 94 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 98 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 2, 1100, in TEST_F() 109 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 127 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 143 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 160 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 2, 1110, in TEST_F() 170 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() [all …]
|
H A D | begin_frame_args.cc | 55 : source_id(source_id), sequence_number(sequence_number) {} in BeginFrameId() 58 if (source_id == other.source_id) in operator <() 60 return (source_id < other.source_id); in operator <() 64 return (source_id == other.source_id && in operator ==() 72 return (source_id == previous.source_id && in IsNextInSequenceTo() 82 value.SetInteger("source_id", source_id); in ToString() 96 BeginFrameArgs::BeginFrameArgs(uint64_t source_id, in BeginFrameArgs() argument 145 state->SetInteger("source_id", frame_id.source_id); in AsValueInto() 161 state->set_source_id(frame_id.source_id); in AsProtozeroInto() 191 : BeginFrameAck(args.frame_id.source_id, in BeginFrameAck() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/viz/common/frame_sinks/ |
H A D | begin_frame_source_unittest.cc | 34 EXPECT_NE(source1.source_id(), source2.source_id()); in TEST() 35 EXPECT_NE(source1.source_id(), source3.source_id()); in TEST() 36 EXPECT_NE(source2.source_id(), source3.source_id()); in TEST() 94 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 98 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 2, 1100, in TEST_F() 109 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 127 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 143 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() 160 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 2, 1110, in TEST_F() 170 EXPECT_BEGIN_FRAME_USED(*obs_, source_->source_id(), 1, 1000, in TEST_F() [all …]
|
H A D | begin_frame_args.cc | 55 : source_id(source_id), sequence_number(sequence_number) {} in BeginFrameId() 58 if (source_id == other.source_id) in operator <() 60 return (source_id < other.source_id); in operator <() 64 return (source_id == other.source_id && in operator ==() 72 return (source_id == previous.source_id && in IsNextInSequenceTo() 82 value.SetInteger("source_id", source_id); in ToString() 96 BeginFrameArgs::BeginFrameArgs(uint64_t source_id, in BeginFrameArgs() argument 145 state->SetInteger("source_id", frame_id.source_id); in AsValueInto() 160 state->set_source_id(frame_id.source_id); in AsProtozeroInto() 190 : BeginFrameAck(args.frame_id.source_id, in BeginFrameAck() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/metrics/public/cpp/ |
H A D | delegating_ukm_recorder.cc | 43 GetSourceIdType(source_id) == SourceIdType::APP_ID) { in UpdateSourceURL() 51 iterator.second.UpdateSourceURL(source_id, url); in UpdateSourceURL() 55 SourceId source_id, in RecordNavigation() argument 75 iterator.second.UpdateAppURL(source_id, url); in UpdateAppURL() 93 iterator.second.MarkSourceForDeletion(source_id); in MarkSourceForDeletion() 109 ptr_->UpdateSourceURL(source_id, url); in UpdateSourceURL() 120 ptr_->UpdateAppURL(source_id, url); in UpdateAppURL() 128 ukm::SourceId source_id, in RecordNavigation() argument 131 ptr_->RecordNavigation(source_id, navigation_data); in RecordNavigation() 149 ukm::SourceId source_id) { in MarkSourceForDeletion() argument [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/metrics/public/cpp/ |
H A D | delegating_ukm_recorder.cc | 43 GetSourceIdType(source_id) == SourceIdType::APP_ID) { in UpdateSourceURL() 51 iterator.second.UpdateSourceURL(source_id, url); in UpdateSourceURL() 55 SourceId source_id, in RecordNavigation() argument 71 if (GetSourceIdType(source_id) != SourceIdType::APP_ID) { in UpdateAppURL() 95 iterator.second.MarkSourceForDeletion(source_id); in MarkSourceForDeletion() 111 ptr_->UpdateSourceURL(source_id, url); in UpdateSourceURL() 123 ptr_->UpdateAppURL(source_id, url, app_type); in UpdateAppURL() 132 ukm::SourceId source_id, in RecordNavigation() argument 135 ptr_->RecordNavigation(source_id, navigation_data); in RecordNavigation() 153 ukm::SourceId source_id) { in MarkSourceForDeletion() argument [all …]
|
H A D | ukm_recorder.cc | 38 ukm::SourceId source_id = ukm::SourceIdObj::FromOtherId( in GetSourceIdForPaymentAppFromScope() local 42 return source_id; in GetSourceIdForPaymentAppFromScope() 48 ukm::SourceId source_id = in GetSourceIdForWebApkManifestUrl() local 52 ukm_recorder->UpdateSourceURL(source_id, manifest_url); in GetSourceIdForWebApkManifestUrl() 53 return source_id; in GetSourceIdForWebApkManifestUrl() 59 ukm::SourceId source_id = in GetSourceIdForDesktopWebAppStartUrl() local 64 ukm_recorder->UpdateSourceURL(source_id, start_url); in GetSourceIdForDesktopWebAppStartUrl() 65 return source_id; in GetSourceIdForDesktopWebAppStartUrl() 69 UpdateSourceURL(source_id.ToInt64(), url); in RecordOtherURL() 72 void UkmRecorder::RecordAppURL(ukm::SourceIdObj source_id, in RecordAppURL() argument [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/chrome/common/media_router/providers/cast/ |
H A D | cast_media_source_unittest.cc | 15 MediaSource::Id source_id("cast:ABCDEFAB"); in TEST() local 17 CastMediaSource::FromMediaSourceId(source_id); in TEST() 19 EXPECT_EQ(source_id, source->source_id()); in TEST() 34 MediaSource::Id source_id( in TEST() local 43 CastMediaSource::FromMediaSourceId(source_id); in TEST() 45 EXPECT_EQ(source_id, source->source_id()); in TEST() 63 MediaSource::Id source_id( in TEST() local 76 EXPECT_EQ(source_id, source->source_id()); in TEST() 99 EXPECT_EQ(source_id, source->source_id()); in TEST() 115 EXPECT_EQ(source_id, source->source_id()); in TEST() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/shared_highlighting/core/common/ |
H A D | shared_highlighting_metrics_unittest.cc | 38 EXPECT_EQ(source_id, entry->source_id); in ValidateLinkOpenedUkm() 141 ukm::SourceId source_id = 1; in TEST_F() local 152 ukm::SourceId source_id = 1; in TEST_F() local 163 ukm::SourceId source_id = 1; in TEST_F() local 174 ukm::SourceId source_id = 1; in TEST_F() local 199 ukm::SourceId source_id = 1; in TEST_F() local 215 ukm::SourceId source_id = 1; in TEST_F() local 223 EXPECT_EQ(source_id, entry->source_id); in TEST_F() 230 ukm::SourceId source_id = 1; in TEST_F() local 239 EXPECT_EQ(source_id, entry->source_id); in TEST_F() [all …]
|
H A D | shared_highlighting_metrics.cc | 85 void LogLinkOpenedUkmEvent(ukm::SourceId source_id, in LogLinkOpenedUkmEvent() argument 92 ukm::SourceId source_id, in LogLinkOpenedUkmEvent() argument 96 if (source_id != ukm::kInvalidSourceId) { in LogLinkOpenedUkmEvent() 97 ukm::builders::SharedHighlights_LinkOpened(source_id) in LogLinkOpenedUkmEvent() 104 void LogLinkGeneratedSuccessUkmEvent(ukm::SourceId source_id) { in LogLinkGeneratedSuccessUkmEvent() argument 111 if (source_id != ukm::kInvalidSourceId) { in LogLinkGeneratedSuccessUkmEvent() 112 ukm::builders::SharedHighlights_LinkGenerated(source_id) in LogLinkGeneratedSuccessUkmEvent() 118 void LogLinkGeneratedErrorUkmEvent(ukm::SourceId source_id, in LogLinkGeneratedErrorUkmEvent() argument 124 ukm::SourceId source_id, in LogLinkGeneratedErrorUkmEvent() argument 127 if (source_id != ukm::kInvalidSourceId) { in LogLinkGeneratedErrorUkmEvent() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/media_router/common/providers/cast/ |
H A D | cast_media_source_unittest.cc | 17 MediaSource::Id source_id("cast:ABCDEFAB"); in TEST() local 19 CastMediaSource::FromMediaSourceId(source_id); in TEST() 21 EXPECT_EQ(source_id, source->source_id()); in TEST() 41 MediaSource::Id source_id( in TEST() local 55 CastMediaSource::FromMediaSourceId(source_id); in TEST() 57 EXPECT_EQ(source_id, source->source_id()); in TEST() 83 MediaSource::Id source_id( in TEST() local 96 EXPECT_EQ(source_id, source->source_id()); in TEST() 120 EXPECT_EQ(source_id, source->source_id()); in TEST() 137 EXPECT_EQ(source_id, source->source_id()); in TEST() [all …]
|