Home
last modified time | relevance | path

Searched refs:cur_ts (Results 1 – 25 of 43) sorted by relevance

12

/mOS-networking-stack/core/src/include/
H A Dtcp_out.h19 uint32_t cur_ts, uint32_t echo_ts, uint16_t ip_id, int8_t in_ifidx);
23 uint32_t cur_ts, uint8_t flags, uint8_t *payload, uint16_t payloadlen);
27 struct mtcp_sender *sender, uint32_t cur_ts, int thresh);
31 struct mtcp_sender *sender, uint32_t cur_ts, int thresh);
35 struct mtcp_sender *sender, uint32_t cur_ts, int thresh);
38 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
54 tcp_stream *cur_stream, uint32_t cur_ts, uint8_t opt);
H A Dtimer.h45 AddtoTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
61 tcp_stream *cur_stream, uint32_t cur_ts);
64 CheckRtmTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
67 CheckTimewaitExpire(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
70 CheckConnectionTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
H A Darp.h20 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts);
23 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts,
36 ARPTimer(mtcp_manager_t mtcp, uint32_t cur_ts);
H A Dip_out.h20 struct pkt_ctx *pctx, uint32_t cur_ts);
24 struct pkt_ctx *pctx, uint32_t cur_ts);
H A Dtcp_in.h122 uint32_t cur_ts, uint8_t *tcpopt, int len);
125 ProcessTCPUplink(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream,
H A Deth_in.h8 uint32_t cur_ts, unsigned char *pkt_data, int len);
H A Deth_out.h18 uint32_t cur_ts);
/mOS-networking-stack/core/src/
H A Dtcp_out.c75 ts[0] = htonl(cur_ts); in GenerateTCPTimestamp()
198 ts[0] = htonl(cur_ts); in SendTCPPacketStandalone()
316 cur_stream->sndvar->ts_lastack_sent = cur_ts; in SendTCPPacket()
317 cur_stream->last_active_ts = cur_ts; in SendTCPPacket()
334 GenerateTCPOptions(cur_stream, cur_ts, flags, in SendTCPPacket()
498 sndlen = SendTCPPacket(mtcp, cur_stream, cur_ts, in FlushTCPSendingBuffer()
691 AddtoControlList(mtcp, cur_stream, cur_ts); in WriteTCPDataList()
766 cur_ts, TCP_FLAG_ACK, NULL, 0); in WriteTCPACKList()
801 AddtoControlList(mtcp, cur_stream, cur_ts); in WriteTCPACKList()
1001 cur_stream->last_active_ts = pctx->p.cur_ts; in UpdatePassiveSendTCPContext_SynSent()
[all …]
H A Deth_in.c13 FillInPacketEthContext (struct pkt_ctx *pctx, uint32_t cur_ts, int in_ifidx, in FillInPacketEthContext() argument
16 pctx->p.cur_ts = cur_ts; in FillInPacketEthContext()
29 uint32_t cur_ts, unsigned char *pkt_data, int len) in ProcessPacket() argument
54 FillInPacketEthContext(&pctx, cur_ts, ifidx, index, ethh, len); in ProcessPacket()
65 ret = ProcessARPPacket(mtcp, cur_ts, ifidx, pkt_data, len); in ProcessPacket()
H A Deth_out.c52 FillOutPacketEthContext(struct pkt_ctx *pctx, uint32_t cur_ts, int out_ifidx, in FillOutPacketEthContext() argument
55 pctx->p.cur_ts = cur_ts; in FillOutPacketEthContext()
65 uint32_t cur_ts) in EthernetOutput() argument
98 FillOutPacketEthContext(pctx, cur_ts, nif, in EthernetOutput()
H A Dip_out.c71 pctx->out_ifidx, pctx->p.cur_ts); in ForwardIPPacket()
95 pctx->out_ifidx, haddr, pctx->p.ip_len, pctx->p.cur_ts); in ForwardIPPacket()
124 struct pkt_ctx *pctx, uint32_t cur_ts) in IPOutputStandalone() argument
141 RequestARP(mtcp, daddr, nif, mtcp->cur_ts); in IPOutputStandalone()
152 ETH_P_IP, nif, haddr, tcplen + IP_HEADER_LEN, cur_ts); in IPOutputStandalone()
183 struct pkt_ctx *pctx, uint32_t cur_ts) in IPOutput() argument
204 RequestARP(mtcp, stream->daddr, stream->sndvar->nif_out, mtcp->cur_ts); in IPOutput()
214 stream->sndvar->nif_out, haddr, tcplen + IP_HEADER_LEN, cur_ts); in IPOutput()
H A Dtimer.c157 tcp_stream *cur_stream, uint32_t cur_ts) in UpdateRetransmissionTimer() argument
172 cur_stream->sndvar->ts_rto = cur_ts + cur_stream->sndvar->rto; in UpdateRetransmissionTimer()
183 HandleRTO(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream) in HandleRTO() argument
344 AddtoControlList(mtcp, cur_stream, cur_ts); in HandleRTO()
348 AddtoControlList(mtcp, cur_stream, cur_ts); in HandleRTO()
381 CheckRtmTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh) in CheckRtmTimeout() argument
398 if ((int32_t)(cur_ts - mtcp->rto_store->rto_now_ts) < 0) { in CheckRtmTimeout()
416 HandleRTO(mtcp, cur_ts, walk); in CheckRtmTimeout()
441 CheckTimewaitExpire(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh) in CheckTimewaitExpire() argument
466 if ((int32_t)(cur_ts - walk->rcvvar->ts_tw_expire) >= 0) { in CheckTimewaitExpire()
[all …]
H A Dcore.c98 struct timespec cur_ts; in HandleSignal() local
100 clock_gettime(CLOCK_REALTIME, &cur_ts); in HandleSignal()
315 mtcp->p_nstat_ts = cur_ts; in PrintNetworkStats()
547 mtcp->ts_last_event = cur_ts; in FlushEpollEvents()
858 struct timeval cur_ts = {0}; in RunMainLoop() local
867 gettimeofday(&cur_ts, NULL); in RunMainLoop()
872 prev_ts = cur_ts; in RunMainLoop()
887 gettimeofday(&cur_ts, NULL); in RunMainLoop()
891 prev_ts = cur_ts; in RunMainLoop()
894 ts = TIMEVAL_TO_TS(&cur_ts); in RunMainLoop()
[all …]
H A Darp.c185 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts) in RequestARP() argument
207 ent->ts_out = cur_ts; in RequestARP()
219 struct arphdr *arph, int nif, uint32_t cur_ts) in ProcessARPRequest() argument
236 ProcessARPReply(mtcp_manager_t mtcp, struct arphdr *arph, uint32_t cur_ts) in ProcessARPReply() argument
262 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts, in ProcessARPPacket() argument
285 ProcessARPRequest(mtcp, arph, ifidx, cur_ts); in ProcessARPPacket()
289 ProcessARPReply(mtcp, arph, cur_ts); in ProcessARPPacket()
313 ARPTimer(mtcp_manager_t mtcp, uint32_t cur_ts) in ARPTimer() argument
320 if (TS_GEQ(cur_ts, ent->ts_out + SEC_TO_TS(ARP_TIMEOUT_SEC))) { in ARPTimer()
H A Dtcp_in.c79 UpdateRetransmissionTimer(mtcp, cur_stream, pctx->p.cur_ts); in HandleActiveOpen()
122 cur_stream->rcvvar->ts_last_ts_upd = pctx->p.cur_ts; in ValidateSequence()
157 AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts); in ValidateSequence()
1152 AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1207 AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1261 AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1303 cur_stream->last_active_ts = pctx->p.cur_ts;
1381 AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1419 AddtoControlList(mtcp, cur_stream, pctx->p.cur_ts);
1427 NULL, 0, pctx->p.cur_ts, 0, 0, -1);
[all …]
H A Dicmp.c70 struct timeval cur_ts = {0}; in ICMPOutput() local
87 RequestARP(mtcp, daddr, nif, mtcp->cur_ts); in ICMPOutput()
96 gettimeofday(&cur_ts, NULL); in ICMPOutput()
97 ts = TIMEVAL_TO_TS(&cur_ts); in ICMPOutput()
H A Dtcp_util.c16 uint32_t cur_ts, uint8_t *tcpopt, int len) in ParseTCPOptions() argument
51 cur_stream->rcvvar->ts_last_ts_upd = cur_ts; in ParseTCPOptions()
H A Dtcp.c105 ParseTCPOptions(cur_stream, pctx->p.cur_ts, (uint8_t *)pctx->p.tcph + in CreateServerStream()
173 ParseTCPOptions(stream, pctx->p.cur_ts, in CreateMonitorStream()
336 ParseTCPOptions(recvside_stream, pctx->p.cur_ts, in UpdateMonitor()
507 NULL, 0, pctx->p.cur_ts, 0, 0, -1); in ProcessInTCPPacket()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dmod_trigger_b4_dl.c377 val.dptr = (char *)&(srv->cur_ts); in URIHANDLER_FUNC()
378 val.dsize = sizeof(srv->cur_ts); in URIHANDLER_FUNC()
402 (char *)&(srv->cur_ts), sizeof(srv->cur_ts), in URIHANDLER_FUNC()
444 if (srv->cur_ts - last_hit > p->conf.trigger_timeout) { in URIHANDLER_FUNC()
461 val.dptr = (char *)&(srv->cur_ts); in URIHANDLER_FUNC()
462 val.dsize = sizeof(srv->cur_ts); in URIHANDLER_FUNC()
510 (char *)&(srv->cur_ts), sizeof(srv->cur_ts), in URIHANDLER_FUNC()
534 if (srv->cur_ts % 60 != 0) return HANDLER_GO_ON; in TRIGGER_FUNC()
562 if (srv->cur_ts - last_hit > s->trigger_timeout) { in TRIGGER_FUNC()
571 if ((srv->cur_ts % (60 * 60 * 24) != 0)) gdbm_reorganize(s->db); in TRIGGER_FUNC()
H A Dserver.c264 srv->cur_ts = time(NULL); in server_init()
265 srv->startup_ts = srv->cur_ts; in server_init()
727 if (min_ts != srv->cur_ts) { in start_server()
744 srv->cur_ts = min_ts; in start_server()
762 if (srv->cur_ts - con->read_idle_ts > con->conf.max_read_idle) { in start_server()
772 if (srv->cur_ts - con->read_idle_ts > con->keep_alive_idle) { in start_server()
787 if (srv->cur_ts - con->write_request_ts > 60) { in start_server()
1963 if (min_ts != srv->cur_ts) { in main()
1980 srv->cur_ts = min_ts; in main()
2008 if (srv->cur_ts - con->read_idle_ts > con->keep_alive_idle) { in main()
[all …]
H A Dmod_secure_download.c240 if ( (srv->cur_ts > ts && (unsigned int) (srv->cur_ts - ts) > p->conf.timeout) || in URIHANDLER_FUNC()
241 (srv->cur_ts < ts && (unsigned int) (ts - srv->cur_ts) > p->conf.timeout) ) { in URIHANDLER_FUNC()
H A Dmod_expire.c314 expires = (ts + srv->cur_ts); in URIHANDLER_FUNC()
327 if (expires < srv->cur_ts) expires = srv->cur_ts; in URIHANDLER_FUNC()
343 …buffer_append_long(p->expire_tstmp, expires - srv->cur_ts); /* as expires >= srv->cur_ts the diffe… in URIHANDLER_FUNC()
H A Dconnections.c645 con->write_request_ts = srv->cur_ts;
662 con->write_request_ts = srv->cur_ts;
921 con->read_idle_ts = srv->cur_ts;
1293 con->close_timeout_ts = srv->cur_ts - (HTTP_LINGER_TIMEOUT+1);
1368 con->connection_start = srv->cur_ts;
1427 con->request_start = srv->cur_ts;
1428 con->read_idle_ts = srv->cur_ts;
1583 con->request_start = srv->cur_ts;
1584 con->read_idle_ts = srv->cur_ts;
1620 con->close_timeout_ts = srv->cur_ts;
[all …]
H A Dlog.c276 if (srv->cur_ts != srv->last_generated_debug_ts) { in log_error_write()
278 …v->ts_debug_str->ptr, srv->ts_debug_str->size - 1, "%Y-%m-%d %H:%M:%S", localtime(&(srv->cur_ts))); in log_error_write()
281 srv->last_generated_debug_ts = srv->cur_ts; in log_error_write()
H A Dmod_accesslog.c708 if (srv->cur_ts != *(p->conf.last_generated_accesslog_ts_ptr)) { in REQUESTDONE_FUNC()
717 localtime_r(&(srv->cur_ts), &tm); in REQUESTDONE_FUNC()
720 …->conf.ts_accesslog_str->size - 1, p->conf.ts_accesslog_fmt_str->ptr, localtime_r(&(srv->cur_ts))); in REQUESTDONE_FUNC()
741 gmtime_r(&(srv->cur_ts), &tm); in REQUESTDONE_FUNC()
744 …tr, p->conf.ts_accesslog_str->size - 1, p->conf.ts_accesslog_fmt_str->ptr, gmtime(&(srv->cur_ts))); in REQUESTDONE_FUNC()
749 *(p->conf.last_generated_accesslog_ts_ptr) = srv->cur_ts; in REQUESTDONE_FUNC()
834 buffer_append_long(b, srv->cur_ts - con->request_start); in REQUESTDONE_FUNC()

12