Home
last modified time | relevance | path

Searched refs:tcp_stream (Results 1 – 25 of 29) sorted by relevance

12

/mOS-networking-stack/core/src/include/
H A Dtcp_stream.h196 TAILQ_ENTRY(tcp_stream) control_link;
197 TAILQ_ENTRY(tcp_stream) send_link;
198 TAILQ_ENTRY(tcp_stream) ack_link;
218 typedef struct tcp_stream struct
283 } tcp_stream; argument
286 TCPStateToString(const tcp_stream *cur_stream);
304 tcp_stream *
309 extern inline tcp_stream *
313 extern inline tcp_stream *
317 extern inline tcp_stream *
[all …]
H A Dtcp_out.h22 SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream,
38 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
41 AddtoSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
44 RemoveFromControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
47 RemoveFromSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
50 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
54 tcp_stream *cur_stream, uint32_t cur_ts, uint8_t opt);
60 UpdatePassiveSendTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
65 struct tcp_stream *recvside_stream,
66 struct tcp_stream *sendside_stream);
H A Dtimer.h32 TAILQ_HEAD(rto_head , tcp_stream) rto_list[RTO_HASH+1];
39 AddtoRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
42 RemoveFromRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
45 AddtoTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
48 RemoveFromTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
51 AddtoTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
54 RemoveFromTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
57 UpdateTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
61 tcp_stream *cur_stream, uint32_t cur_ts);
H A Dfhash.h14 tcp_stream *tqh_first;
15 tcp_stream **tqh_last;
23 tcp_stream* ht_array[NUM_BINS][TCP_AR_CNT];
33 int HTInsert(struct hashtable *ht, tcp_stream *, unsigned int *hash);
34 void* HTRemove(struct hashtable *ht, tcp_stream *);
35 tcp_stream* HTSearch(struct hashtable *ht, const tcp_stream *, unsigned int *hash);
H A Dtcp_stream_queue.h41 struct tcp_stream **array;
57 StreamInternalEnqueue(stream_queue_int *sq, struct tcp_stream *stream);
59 struct tcp_stream *
69 StreamEnqueue(stream_queue_t sq, struct tcp_stream *stream);
71 struct tcp_stream *
H A Dtcp_in.h121 ParseTCPOptions(tcp_stream *cur_stream,
125 ProcessTCPUplink(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream,
130 UpdateRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
134 DoActionEndTCPPacket(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
141 UpdatePassiveRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
146 struct tcp_stream *recvside_stream);
H A Dtcp.h13 tcp_stream *cur_stream, int cpu);
23 UpdateMonitor(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream,
24 struct tcp_stream *recvside_stream, struct pkt_ctx *pctx,
H A Dtcp_util.h13 void ParseTCPOptions(tcp_stream *cur_stream,
17 ParseTCPTimestamp(tcp_stream *cur_stream,
22 ParseSACKOption(tcp_stream *cur_stream,
H A Dmtcp.h185 TAILQ_HEAD (control_head, tcp_stream) control_list;
186 TAILQ_HEAD (send_head, tcp_stream) send_list;
187 TAILQ_HEAD (ack_head, tcp_stream) ack_list;
263 TAILQ_HEAD (timewait_head, tcp_stream) timewait_list;
264 TAILQ_HEAD (timeout_head, tcp_stream) timeout_list;
H A Dtcp_ring_buffer.h28 struct tcp_stream;
75 int RBPut(rb_manager_t rbm, struct tcp_stream *cur_stream, void *data,
H A Dsocket.h80 struct tcp_stream *stream;
116 struct tcp_stream *stream;
H A Dip_out.h23 IPOutput(struct mtcp_manager *mtcp, tcp_stream *stream, uint16_t tcplen,
H A Dtcp_rb.h121 struct tcp_stream *recvside_stream);
/mOS-networking-stack/core/src/
H A Dtcp_stream_queue.c41 struct tcp_stream * volatile * _q;
54 sq->array = (tcp_stream **)calloc(size, sizeof(tcp_stream *)); in CreateInternalStreamQueue()
82 StreamInternalEnqueue(stream_queue_int *sq, struct tcp_stream *stream) in StreamInternalEnqueue()
101 struct tcp_stream *
104 struct tcp_stream *stream = NULL; in StreamInternalDequeue()
140 StreamMemoryBarrier(tcp_stream * volatile stream, volatile index_type index) in StreamMemoryBarrier()
154 sq->_q = (tcp_stream **)calloc(capacity + 1, sizeof(tcp_stream *)); in CreateStreamQueue()
181 StreamEnqueue(stream_queue_t sq, tcp_stream *stream) in StreamEnqueue()
198 tcp_stream *
205 tcp_stream *stream = sq->_q[h]; in StreamDequeue()
H A Dtcp_stream.c64 struct tcp_stream *stream; in GetFragInfo()
118 struct tcp_stream *stream; in GetBufInfo()
168 struct tcp_stream *stream; in DisableBuf()
426 tcp_stream *
431 tcp_stream *stream = NULL;
449 memset(stream, 0, sizeof(tcp_stream));
581 inline tcp_stream *
614 inline tcp_stream *
619 tcp_stream *cs;
649 inline tcp_stream *
[all …]
H A Dtcp.c87 static inline tcp_stream *
90 tcp_stream *cur_stream = NULL; in CreateServerStream()
111 static inline tcp_stream *
115 tcp_stream *stream = NULL; in CreateMonitorStream()
180 static inline struct tcp_stream *
183 struct tcp_stream temp_stream; in FindStream()
195 static inline struct tcp_stream *
198 tcp_stream *cur_stream = NULL; in CreateStream()
285 struct tcp_stream *recvside_stream, struct pkt_ctx *pctx, in UpdateMonitor()
379 struct tcp_stream *recvside_stream, struct pkt_ctx *pctx) in HandleMonitorStream()
[all …]
H A Dtcp_out.c392 struct tcp_stream *sendside_stream = cur_stream; in SendTCPPacket()
575 tcp_stream *cur_stream; in WriteTCPControlList()
576 tcp_stream *next, *last; in WriteTCPControlList()
625 tcp_stream *cur_stream; in WriteTCPDataList()
626 tcp_stream *next, *last; in WriteTCPDataList()
715 tcp_stream *cur_stream; in WriteTCPACKList()
716 tcp_stream *next, *last; in WriteTCPACKList()
824 GetSender(mtcp_manager_t mtcp, tcp_stream *cur_stream) in GetSender()
974 tcp_stream *stream; in DumpControlList()
1196 struct tcp_stream *recvside_stream, in PostSendTCPAction()
[all …]
H A Dfhash.c73 HashFlow(const tcp_stream *flow) in HashFlow()
121 HTInsert(struct hashtable *ht, tcp_stream *item, unsigned int *hash) in HTInsert()
160 HTRemove(struct hashtable *ht, tcp_stream *item) in HTRemove()
183 tcp_stream*
184 HTSearch(struct hashtable *ht, const tcp_stream *item, unsigned int *hash) in HTSearch()
186 tcp_stream *walk; in HTSearch()
H A Dtimer.c32 AddtoRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoRTOList()
70 RemoveFromRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromRTOList()
111 RemoveFromTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromTimewaitList()
124 AddtoTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoTimeoutList()
137 RemoveFromTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromTimeoutList()
147 UpdateTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in UpdateTimeoutList()
157 tcp_stream *cur_stream, uint32_t cur_ts) in UpdateRetransmissionTimer()
356 tcp_stream *walk, *next; in RearrangeRTOStore()
383 tcp_stream *walk, *next; in CheckRtmTimeout()
443 tcp_stream *walk, *next; in CheckTimewaitExpire()
[all …]
H A Dtcp_in.c23 Handle_TCP_ST_ESTABLISHED (mtcp_manager_t mtcp, tcp_stream* cur_stream,
62 HandleActiveOpen(mtcp_manager_t mtcp, tcp_stream *cur_stream, in HandleActiveOpen()
88 ValidateSequence(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ValidateSequence()
168 NotifyConnectionReset(mtcp_manager_t mtcp, tcp_stream *cur_stream) in NotifyConnectionReset()
176 ProcessRST(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessRST()
305 ProcessACK(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessACK()
547 ProcessTCPPayload(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessTCPPayload()
700 Handle_TCP_ST_LISTEN (mtcp_manager_t mtcp, tcp_stream* cur_stream, in Handle_TCP_ST_LISTEN()
730 Handle_TCP_ST_SYN_SENT (mtcp_manager_t mtcp, tcp_stream* cur_stream, in Handle_TCP_ST_SYN_SENT()
1223 Handle_TCP_ST_CLOSING (mtcp_manager_t mtcp, tcp_stream* cur_stream,
[all …]
H A Dmos_api.c247 struct tcp_stream *cur_stream; in mtcp_peek()
278 struct tcp_stream *mstrm = sock->monitor_stream->stream; in mtcp_peek()
365 struct tcp_stream *cur_stream; in mtcp_ppeek()
395 struct tcp_stream *mstrm = sock->monitor_stream->stream; in mtcp_ppeek()
490 struct tcp_stream *cur_stream; in mtcp_getlastpkt()
498 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_getlastpkt()
709 struct tcp_stream *stream; in mtcp_cb_stop()
781 SendRSTPacketStandalone(mtcp_manager_t mtcp, struct tcp_stream *stream) { in SendRSTPacketStandalone()
853 struct tcp_stream *stream; in mtcp_getpeername()
944 struct tcp_stream *cur_stream; in mtcp_setlastpkt()
[all …]
H A Dtcp_util.c15 ParseTCPOptions(tcp_stream *cur_stream, in ParseTCPOptions()
62 ParseTCPTimestamp(tcp_stream *cur_stream, in ParseTCPTimestamp()
96 ParseSACKOption(tcp_stream *cur_stream, in ParseSACKOption()
H A Dapi.c75 tcp_stream *cur_stream; in GetSocketError()
525 tcp_stream *cur_stream; in mtcp_ioctl()
823 tcp_stream *accepted = NULL; in mtcp_accept()
986 tcp_stream *cur_stream; in mtcp_connect()
1201 tcp_stream *cur_stream; in CloseStreamSocket()
1364 tcp_stream *cur_stream; in mtcp_abort()
1470 CopyToUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, char *buf, int len) in CopyToUser()
1506 tcp_stream *cur_stream; in mtcp_recv()
1622 tcp_stream *cur_stream; in mtcp_readv()
1774 tcp_stream *cur_stream; in mtcp_write()
[all …]
H A Dcore.c426 struct tcp_stream *cur_stream; in FlushMonitorReadEvents()
437 (struct tcp_stream *)mtcpq->events[mtcpq->start++].ev.data.ptr; in FlushMonitorReadEvents()
475 struct tcp_stream *cur_stream; in FlushBufferedReadEvents()
557 tcp_stream *stream; in HandleApplicationCalls()
796 tcp_stream *walk; in DestroyRemainingFlows()
1133 mtcp->flow_pool = MPCreate(sizeof(tcp_stream), in InitializeMTCPManager()
1134 sizeof(tcp_stream) * g_config.mos->max_concurrency, IS_HUGEPAGE); in InitializeMTCPManager()
H A DMakefile.in74 SRCS = core.c tcp_stream.c config.c api.c mos_api.c eventpoll.c socket.c pipe.c \

12