Home
last modified time | relevance | path

Searched refs:source_id (Results 1 – 25 of 2235) sorted by relevance

12345678910>>...90

/dports/security/snort3/snort3-3.1.19.0/src/service_inspectors/http2_inspect/
H A Dhttp2_stream_splitter_impl.cc72 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 Dhttp2_data_cutter.cc37 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 Dhttp2_stream_splitter.cc101 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 Dhttp2_flow_data.cc135 *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 Dhttp2_headers_frame_trailer.cc51 *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 Dhttp2_stream.h41 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 Dhttp2_frame.cc45 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 Dhttp2_push_promise_frame.cc51 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 Dhttp_stream_splitter_finish.cc65 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 Dhttp_stream_splitter_reassemble.cc102 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 Dhttp_flow_data.cc147 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 Dhttp_msg_header.cc55 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 Dhttp_msg_body.cc48 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 Dhttp_stream_splitter_scan.cc44 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 Dbegin_frame_source_unittest.cc34 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 Dbegin_frame_args.cc55 : 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 Dbegin_frame_source_unittest.cc34 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 Dbegin_frame_args.cc55 : 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 Ddelegating_ukm_recorder.cc43 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 Ddelegating_ukm_recorder.cc43 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 Dukm_recorder.cc38 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 Dcast_media_source_unittest.cc15 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 Dshared_highlighting_metrics_unittest.cc38 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 Dshared_highlighting_metrics.cc85 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 Dcast_media_source_unittest.cc17 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 …]

12345678910>>...90