Home
last modified time | relevance | path

Searched refs:stream_id (Results 1 – 25 of 32) sorted by relevance

12

/external/chromium/net/tools/flip_server/
Dspdy_interface.cc158 << syn_stream->stream_id() << ")"; in SpdyHandleNewStream()
193 NewStream(syn_stream->stream_id(), in SpdyHandleNewStream()
252 stream_to_smif_[syn_stream->stream_id()] = sm_http_interface; in OnControl()
253 sm_http_interface->SetStreamID(syn_stream->stream_id()); in OnControl()
263 reinterpret_cast<const SpdySynReplyControlFrame*>(frame)->stream_id() in OnControl()
271 << rst_stream->stream_id() << ")"; in OnControl()
272 client_output_ordering_.RemoveStreamId(rst_stream ->stream_id()); in OnControl()
281 bool SpdySM::OnControlFrameHeaderData(spdy::SpdyStreamId stream_id, in OnControlFrameHeaderData() argument
292 void SpdySM::OnStreamFrameData(SpdyStreamId stream_id, in OnStreamFrameData() argument
294 VLOG(2) << ACCEPTOR_CLIENT_IDENT << "SpdySM: StreamData(" << stream_id in OnStreamFrameData()
[all …]
Dhttp_interface.cc97 void HttpSM::SendOKResponse(uint32 stream_id, std::string* output) { in SendOKResponse() argument
98 SendOKResponseImpl(stream_id, output); in SendOKResponse()
150 void HttpSM::SetStreamID(uint32 stream_id) { in SetStreamID() argument
151 stream_id_ = stream_id; in SetStreamID()
200 void HttpSM::NewStream(uint32 stream_id, uint32 priority, in NewStream() argument
203 mci.stream_id = stream_id; in NewStream()
208 SendErrorNotFound(stream_id); in NewStream()
214 void HttpSM::SendEOF(uint32 stream_id) { in SendEOF() argument
215 SendEOFImpl(stream_id); in SendEOF()
221 void HttpSM::SendErrorNotFound(uint32 stream_id) { in SendErrorNotFound() argument
[all …]
Dspdy_interface.h65 virtual bool OnControlFrameHeaderData(spdy::SpdyStreamId stream_id,
69 virtual void OnStreamFrameData(spdy::SpdyStreamId stream_id,
76 virtual void SetStreamID(uint32 stream_id) {} in SetStreamID() argument
90 virtual void NewStream(uint32 stream_id,
94 virtual void SendEOF(uint32 stream_id);
95 virtual void SendErrorNotFound(uint32 stream_id);
96 void SendOKResponse(uint32 stream_id, std::string* output);
97 virtual size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers);
98 virtual size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers);
99 virtual void SendDataFrame(uint32 stream_id, const char* data, int64 len,
[all …]
Dstreamer_interface.h47 virtual void SetStreamID(uint32 stream_id) {} in SetStreamID() argument
55 virtual void NewStream(uint32 stream_id, uint32 priority, in NewStream() argument
57 virtual void SendEOF(uint32 stream_id) {} in SendEOF() argument
58 virtual void SendErrorNotFound(uint32 stream_id) {} in SendErrorNotFound() argument
59 virtual void SendOKResponse(uint32 stream_id, std::string output) {} in SendOKResponse() argument
60 virtual size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers);
61 virtual size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers);
62 virtual void SendDataFrame(uint32 stream_id, const char* data, int64 len, in SendDataFrame() argument
71 void SendEOFImpl(uint32 stream_id) {} in SendEOFImpl() argument
72 void SendErrorNotFoundImpl(uint32 stream_id) {} in SendErrorNotFoundImpl() argument
[all …]
Dhttp_interface.h70 void SendOKResponse(uint32 stream_id, std::string* output);
88 virtual void SetStreamID(uint32 stream_id);
97 virtual void NewStream(uint32 stream_id, uint32 priority,
99 virtual void SendEOF(uint32 stream_id);
100 virtual void SendErrorNotFound(uint32 stream_id);
101 virtual size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers);
102 virtual size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers);
103 virtual void SendDataFrame(uint32 stream_id, const char* data, int64 len,
107 void SendEOFImpl(uint32 stream_id);
108 void SendErrorNotFoundImpl(uint32 stream_id);
[all …]
Dsm_interface.h34 virtual void SetStreamID(uint32 stream_id) = 0;
49 virtual void NewStream(uint32 stream_id, uint32 priority,
51 virtual void SendEOF(uint32 stream_id) = 0;
52 virtual void SendErrorNotFound(uint32 stream_id) = 0;
53 virtual size_t SendSynStream(uint32 stream_id,
55 virtual size_t SendSynReply(uint32 stream_id,
57 virtual void SendDataFrame(uint32 stream_id, const char* data, int64 len,
Doutput_ordering.cc38 bool OutputOrdering::ExistsInPriorityMaps(uint32 stream_id) { in ExistsInPriorityMaps() argument
39 StreamIdToPriorityMap::iterator sitpmi = stream_ids_.find(stream_id); in ExistsInPriorityMaps()
92 if (ExistsInPriorityMaps(mci.stream_id)) in AddToOutputOrder()
111 std::pair<uint32, PriorityMapPointer>(mci.stream_id, in AddToOutputOrder()
132 StreamIdToPriorityMap::iterator sitpmi = stream_ids_.find(mci.stream_id); in SpliceToPriorityRing()
165 void OutputOrdering::RemoveStreamId(uint32 stream_id) { in RemoveStreamId() argument
166 StreamIdToPriorityMap::iterator sitpmi = stream_ids_.find(stream_id); in RemoveStreamId()
Dmem_cache.h85 stream_id(0), in MemCacheIter()
93 stream_id(0), in MemCacheIter()
100 uint32 stream_id; variable
Doutput_ordering.h47 bool ExistsInPriorityMaps(uint32 stream_id);
74 void RemoveStreamId(uint32 stream_id);
Dstreamer_interface.cc144 size_t StreamerSM::SendSynStream(uint32 stream_id, in SendSynStream() argument
149 size_t StreamerSM::SendSynReply(uint32 stream_id, const BalsaHeaders& headers) { in SendSynReply() argument
/external/chromium/net/spdy/
Dspdy_session.cc109 NetLogSpdyWindowUpdateParameter(spdy::SpdyStreamId stream_id, in NetLogSpdyWindowUpdateParameter() argument
112 : stream_id_(stream_id), delta_(delta), window_size_(window_size) {} in NetLogSpdyWindowUpdateParameter()
133 NetLogSpdyDataParameter(spdy::SpdyStreamId stream_id, in NetLogSpdyDataParameter() argument
136 : stream_id_(stream_id), size_(size), flags_(flags) {} in NetLogSpdyDataParameter()
157 NetLogSpdyRstParameter(spdy::SpdyStreamId stream_id, int status) in NetLogSpdyRstParameter() argument
158 : stream_id_(stream_id), status_(status) {} in NetLogSpdyRstParameter()
469 const spdy::SpdyStreamId stream_id = GetNewStreamId(); in CreateStreamImpl() local
472 stream_id, in CreateStreamImpl()
489 DCHECK_EQ(active_streams_[stream_id].get(), stream.get()); in CreateStreamImpl()
494 spdy::SpdyStreamId stream_id, in WriteSynStream() argument
[all …]
Dspdy_test_util.h126 int stream_id,
135 int stream_id,
173 spdy::SpdyFrame* ConstructSpdyRstStream(spdy::SpdyStreamId stream_id,
194 int stream_id,
204 int stream_id,
215 int stream_id,
222 int stream_id);
230 int stream_id,
234 int stream_id,
239 int stream_id,
[all …]
Dspdy_test_util.cc214 const spdy::SpdyStreamId stream_id, uint32 delta_window_size) { in ConstructSpdyWindowUpdate() argument
216 return framer.CreateWindowUpdate(stream_id, delta_window_size); in ConstructSpdyWindowUpdate()
221 spdy::SpdyFrame* ConstructSpdyRstStream(spdy::SpdyStreamId stream_id, in ConstructSpdyRstStream() argument
224 return framer.CreateRstStream(stream_id, status); in ConstructSpdyRstStream()
270 int stream_id, in ConstructSpdyControlFrame() argument
279 stream_id, in ConstructSpdyControlFrame()
291 int stream_id, in ConstructSpdyControlFrame() argument
300 stream_id, // Stream ID in ConstructSpdyControlFrame()
325 int stream_id, in ConstructSpdyGet() argument
329 stream_id, // Stream ID in ConstructSpdyGet()
[all …]
Dspdy_framer.cc535 SpdyStreamId stream_id, SpdyStreamId associated_stream_id, int priority, in CreateSynStream() argument
539 DCHECK_GT(stream_id, static_cast<SpdyStreamId>(0)); in CreateSynStream()
540 DCHECK_EQ(0u, stream_id & ~kStreamIdMask); in CreateSynStream()
546 frame.WriteUInt32(stream_id); in CreateSynStream()
577 SpdySynReplyControlFrame* SpdyFramer::CreateSynReply(SpdyStreamId stream_id, in CreateSynReply() argument
579 DCHECK_GT(stream_id, 0u); in CreateSynReply()
580 DCHECK_EQ(0u, stream_id & ~kStreamIdMask); in CreateSynReply()
587 frame.WriteUInt32(stream_id); in CreateSynReply()
618 SpdyRstStreamControlFrame* SpdyFramer::CreateRstStream(SpdyStreamId stream_id, in CreateRstStream() argument
620 DCHECK_GT(stream_id, 0u); in CreateRstStream()
[all …]
Dspdy_protocol_test.cc87 EXPECT_EQ(12345u, data_frame.stream_id()); in TEST()
99 EXPECT_EQ(123u, syn_frame->stream_id()); in TEST()
105 EXPECT_EQ(123u, syn_frame->stream_id()); in TEST()
113 EXPECT_EQ(123u, syn_reply->stream_id()); in TEST()
122 EXPECT_EQ(123u, rst_frame->stream_id()); in TEST()
140 EXPECT_EQ(123u, window_update_frame->stream_id()); in TEST()
149 EXPECT_EQ(0u, frame.stream_id()); in TEST()
152 EXPECT_EQ(~0 & kStreamIdMask, frame.stream_id()); in TEST()
261 EXPECT_EQ(0u, frame->stream_id()); in TEST()
264 EXPECT_EQ(kStreamIdMask, frame->stream_id()); in TEST()
[all …]
Dspdy_framer.h74 virtual bool OnControlFrameHeaderData(SpdyStreamId stream_id,
89 virtual void OnStreamFrameData(SpdyStreamId stream_id,
186 SpdySynStreamControlFrame* CreateSynStream(SpdyStreamId stream_id,
199 SpdySynReplyControlFrame* CreateSynReply(SpdyStreamId stream_id,
204 static SpdyRstStreamControlFrame* CreateRstStream(SpdyStreamId stream_id,
228 SpdyHeadersControlFrame* CreateHeaders(SpdyStreamId stream_id,
236 SpdyStreamId stream_id,
251 SpdyDataFrame* CreateDataFrame(SpdyStreamId stream_id, const char* data,
Dspdy_session.h109 spdy::SpdyStreamId stream_id,
116 int WriteStreamData(spdy::SpdyStreamId stream_id, net::IOBuffer* data,
121 void CloseStream(spdy::SpdyStreamId stream_id, int status);
126 void ResetStream(spdy::SpdyStreamId stream_id, spdy::SpdyStatusCodes status);
129 bool IsStreamActive(spdy::SpdyStreamId stream_id) const;
168 void SendWindowUpdate(spdy::SpdyStreamId stream_id, int delta_window_size);
370 virtual void OnStreamFrameData(spdy::SpdyStreamId stream_id,
375 virtual bool OnControlFrameHeaderData(spdy::SpdyStreamId stream_id,
Dspdy_stream.h94 spdy::SpdyStreamId stream_id,
111 spdy::SpdyStreamId stream_id() const { return stream_id_; } in stream_id() function
112 void set_stream_id(spdy::SpdyStreamId stream_id) { stream_id_ = stream_id; } in set_stream_id() argument
Dspdy_protocol.h406 SpdyStreamId stream_id() const { in stream_id() function
502 SpdyStreamId stream_id() const { in stream_id() function
552 SpdyStreamId stream_id() const { in stream_id() function
589 SpdyStreamId stream_id() const { in stream_id() function
726 SpdyStreamId stream_id() const { in stream_id() function
764 SpdyStreamId stream_id() const { in stream_id() function
Dspdy_stream.cc18 NetLogSpdyStreamWindowUpdateParameter(spdy::SpdyStreamId stream_id, in NetLogSpdyStreamWindowUpdateParameter() argument
21 : stream_id_(stream_id), delta_(delta), window_size_(window_size) {} in NetLogSpdyStreamWindowUpdateParameter()
39 spdy::SpdyStreamId stream_id, in SpdyStream() argument
43 stream_id_(stream_id), in SpdyStream()
/external/chromium/net/tools/spdyshark/
Dpacket-spdy.c80 guint32 stream_id; member
332 guint32 stream_id, in spdy_save_stream_info() argument
341 if (stream_id < conv_data->streams->len) in spdy_save_stream_info()
342 DISSECTOR_ASSERT(g_array_index(conv_data->streams, spdy_stream_info_t*, stream_id) == NULL); in spdy_save_stream_info()
344 g_array_set_size(conv_data->streams, stream_id+1); in spdy_save_stream_info()
352 g_array_index(conv_data->streams, spdy_stream_info_t*, stream_id) = si; in spdy_save_stream_info()
354 printf("Saved stream info for ID %u, content type %s\n", stream_id, content_type); in spdy_save_stream_info()
358 spdy_get_stream_info(spdy_conv_t *conv_data, guint32 stream_id) in spdy_get_stream_info() argument
360 if (conv_data->streams == NULL || stream_id >= conv_data->streams->len) in spdy_get_stream_info()
363 return g_array_index(conv_data->streams, spdy_stream_info_t*, stream_id); in spdy_get_stream_info()
[all …]
/external/linux-tools-perf/util/
Devsel.c315 sample->stream_id = *array; in perf_event__parse_id_sample()
356 data->stream_id = data->id = data->time = -1ULL; in perf_event__parse_sample()
398 data->stream_id = *array; in perf_event__parse_sample()
Dpython.c20 u64 stream_id; member
48 sample_member_def(sample_stream_id, stream_id, T_ULONGLONG, "event stream id"), \
166 member_def(throttle_event, stream_id, T_ULONGLONG, "event stream id"),
177 te->time, te->id, te->stream_id); in pyrf_throttle_event__repr()
Devent.h77 u64 stream_id; member
/external/esd/include/
Desd.h294 int esd_set_stream_pan( int esd, int stream_id,

12