Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 28) sorted by relevance

12

/mOS-networking-stack/core/src/
H A Dtcp_stream.c184 stream = sock->monitor_stream->stream; in DisableBuf()
186 stream = stream->pair_stream; in DisableBuf()
223 if (!stream || !(stream = (side == stream->side) ? stream : stream->pair_stream)) in GetTCPState()
233 return (stream) ? state_str[stream->state] : NULL; in TCPStateToString()
358 s->monitor_stream->stream = stream; in AddMonitorStreamSockets()
507 socket->stream = stream;
528 stream->snd_nxt = stream->sndvar->iss;
529 stream->sndvar->snd_una = stream->sndvar->iss;
910 stream->id, stream->stream_type,
940 stream->on_rto_idx, stream->on_timewait_list, stream->on_timeout_list,
[all …]
H A Dcore.c557 tcp_stream *stream; in HandleApplicationCalls() local
566 TCPStateToString(stream)); in HandleApplicationCalls()
582 AddtoSendList(mtcp, stream); in HandleApplicationCalls()
587 stream->sndvar->on_ackq = FALSE; in HandleApplicationCalls()
601 sndvar->fss = stream->snd_nxt; in HandleApplicationCalls()
607 if (stream->have_reset) { in HandleApplicationCalls()
700 if (stream->have_reset) { in HandleApplicationCalls()
712 stream->sndvar->on_send_list || stream->sndvar->on_ack_list) { in HandleApplicationCalls()
737 stream->sndvar->on_send_list || stream->sndvar->on_ack_list) { in HandleApplicationCalls()
758 DestroyTCPStream(mtcp, stream); in HandleApplicationCalls()
[all …]
H A Dmos_api.c733 stream = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_cb_stop()
746 stream = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_cb_stop()
755 stream = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_cb_stop()
783 stream->saddr, stream->sport, stream->daddr, stream->dport, in SendRSTPacketStandalone()
881 stream = socket->monitor_stream->stream; in mtcp_getpeername()
895 stream->daddr : stream->saddr; in mtcp_getpeername()
897 stream->dport : stream->sport; in mtcp_getpeername()
909 stream->daddr : stream->saddr; in mtcp_getpeername()
911 stream->dport : stream->sport; in mtcp_getpeername()
916 stream->daddr : stream->saddr; in mtcp_getpeername()
[all …]
H A Dtcp_stream_queue.c91 sq->array[sq->last++] = stream; in StreamInternalEnqueue()
104 struct tcp_stream *stream = NULL; in StreamInternalDequeue() local
110 stream = sq->array[sq->first++]; in StreamInternalDequeue()
111 assert(stream != NULL); in StreamInternalDequeue()
118 return stream; in StreamInternalDequeue()
142 __asm__ volatile("" : : "m" (stream), "m" (index)); in StreamMemoryBarrier()
181 StreamEnqueue(stream_queue_t sq, tcp_stream *stream) in StreamEnqueue() argument
188 sq->_q[t] = stream; in StreamEnqueue()
205 tcp_stream *stream = sq->_q[h]; in StreamDequeue() local
208 assert(stream); in StreamDequeue()
[all …]
H A Dtcp.c115 tcp_stream *stream = NULL; in CreateMonitorStream() local
121 if (!stream) in CreateMonitorStream()
124 stream->side = MOS_SIDE_CLI; in CreateMonitorStream()
129 stream->rcv_nxt = stream->rcvvar->irs + 1; in CreateMonitorStream()
130 stream->sndvar->cwnd = 1; in CreateMonitorStream()
141 stream->buffer_mgmt = FALSE; in CreateMonitorStream()
150 stream->status_mgmt = 0; in CreateMonitorStream()
153 if (bm > stream->buffer_mgmt) { in CreateMonitorStream()
154 stream->buffer_mgmt = bm; in CreateMonitorStream()
157 stream->status_mgmt = 1; in CreateMonitorStream()
[all …]
H A Dip_out.c190 if (stream->sndvar->nif_out >= 0) { in IPOutput()
191 nif = stream->sndvar->nif_out; in IPOutput()
193 nif = GetOutputInterface(stream->daddr); in IPOutput()
194 stream->sndvar->nif_out = nif; in IPOutput()
197 haddr = GetDestinationHWaddr(stream->daddr); in IPOutput()
204 RequestARP(mtcp, stream->daddr, stream->sndvar->nif_out, mtcp->cur_ts); in IPOutput()
206 uint8_t *da = (uint8_t *)&stream->daddr; in IPOutput()
214 stream->sndvar->nif_out, haddr, tcplen + IP_HEADER_LEN, cur_ts); in IPOutput()
223 iph->id = htons(stream->sndvar->ip_id++); in IPOutput()
227 iph->saddr = stream->saddr; in IPOutput()
[all …]
H A Dapi.c77 if (!socket->stream) { in GetSocketError()
82 cur_stream = socket->stream; in GetSocketError()
528 cur_stream = socket->stream; in mtcp_ioctl()
880 socket->stream = accepted; in mtcp_accept()
1035 if (socket->stream) { in mtcp_connect()
1210 cur_stream = mtcp->smap[sockid].stream; in CloseStreamSocket()
1391 cur_stream = mtcp->smap[sockid].stream; in mtcp_abort()
1541 cur_stream = socket->stream; in mtcp_recv()
1653 cur_stream = socket->stream; in mtcp_readv()
1807 cur_stream = socket->stream; in mtcp_write()
[all …]
H A Deventpoll.c203 tcp_stream *stream = socket->stream; in RaisePendingStreamEvents() local
205 if (!stream) in RaisePendingStreamEvents()
207 if (stream->state < TCP_ST_ESTABLISHED) in RaisePendingStreamEvents()
211 stream->id, TCPStateToString(stream)); in RaisePendingStreamEvents()
215 struct tcp_recv_vars *rcvvar = stream->rcvvar; in RaisePendingStreamEvents()
219 } else if (stream->state == TCP_ST_CLOSE_WAIT) { in RaisePendingStreamEvents()
227 struct tcp_send_vars *sndvar = stream->sndvar; in RaisePendingStreamEvents()
H A Dsocket.c61 mstream->stream = NULL; in FreeMonStream()
111 socket->stream = NULL; in AllocateSocket()
158 mtcp->smap[sockid].stream = NULL; in FreeSocket()
H A Dtcp_out.c974 tcp_stream *stream; in DumpControlList() local
977 TAILQ_FOREACH(stream, &sender->control_list, sndvar->control_link) { in DumpControlList()
978 TRACE_DBG("Stream id: %u in control list\n", stream->id); in DumpControlList()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dstream.h9 } stream; typedef
11 int stream_open(stream *f, buffer *fn);
12 int stream_close(stream *f);
H A Dstream.c15 int stream_open(stream *f, buffer *fn) { in stream_open()
94 int stream_close(stream *f) { in stream_close()
H A DMakefile.in150 http_chunk.c stream.c fdevent.c stat_cache.c plugin.c \
164 liblightcomp_la-http_chunk.lo liblightcomp_la-stream.lo \
435 buffer.c log.c keyvalue.c chunk.c http_chunk.c stream.c \
448 chunk.$(OBJEXT) http_chunk.$(OBJEXT) stream.$(OBJEXT) \
753 http_chunk.c stream.c fdevent.c \
896 md5.h http_auth.h stream.h \
1252 @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/liblightcomp_la-stream.Plo@am__quote@
1311 @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/stream.Po@am__quote@
1369 liblightcomp_la-stream.lo: stream.c
1370 …omp_la-stream.lo -MD -MP -MF $(DEPDIR)/liblightcomp_la-stream.Tpo -c -o liblightcomp_la-stream.lo …
[all …]
H A DMakefile.am61 http_chunk.c stream.c fdevent.c \
272 md5.h http_auth.h stream.h \
H A Dmod_dirlisting.c539 stream s; in http_list_directory_header()
592 stream s; in http_list_directory_footer()
H A Dmod_cml_lua.c32 stream st;
H A DSConscript9 http_chunk.c stream.c fdevent.c \
H A Dhttp_auth.c154 stream f; in http_auth_get_password()
232 stream f; in http_auth_get_password()
H A Dmod_ssi.c958 stream s; in mod_ssi_handle_request()
/mOS-networking-stack/core/src/include/
H A Dtcp_stream.h293 RaiseReadEvent(mtcp_manager_t mtcp, tcp_stream *stream);
296 RaiseWriteEvent(mtcp_manager_t mtcp, tcp_stream *stream);
299 RaiseCloseEvent(mtcp_manager_t mtcp, tcp_stream *stream);
302 RaiseErrorEvent(mtcp_manager_t mtcp, tcp_stream *stream);
322 DestroyTCPStream(mtcp_manager_t mtcp, tcp_stream *stream);
325 DumpStream(mtcp_manager_t mtcp, tcp_stream *stream);
334 GetTCPState(struct tcp_stream *stream, int side,
341 GetLastTimestamp(struct tcp_stream *stream, uint32_t *usecs, socklen_t *sz);
H A Dtcp_stream_queue.h57 StreamInternalEnqueue(stream_queue_int *sq, struct tcp_stream *stream);
69 StreamEnqueue(stream_queue_t sq, struct tcp_stream *stream);
H A Dscalable_event.h22 #define RAISE_DEBUG_EVENT(mtcp, stream, format, args...) \ argument
27 HandleCallback(mtcp, MOS_NULL, walk, (stream)->side, \
H A Dsocket.h80 struct tcp_stream *stream; member
116 struct tcp_stream *stream; member
H A Dip_out.h23 IPOutput(struct mtcp_manager *mtcp, tcp_stream *stream, uint16_t tcplen,
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dconfiguration.txt474 NOTE: if no mapping is given "application/octet-stream" is used

12