Home
last modified time | relevance | path

Searched refs:side (Results 1 – 25 of 26) sorted by relevance

12

/mOS-networking-stack/core/src/
H A Dmos_api.c272 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in mtcp_peek()
279 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_peek()
389 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in mtcp_ppeek()
396 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_ppeek()
492 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in mtcp_getlastpkt()
499 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_getlastpkt()
887 switch (side) { in mtcp_getpeername()
894 sin->sin_addr.s_addr = (stream->side == side) ? in mtcp_getpeername()
896 sin->sin_port = (stream->side == side)? in mtcp_getpeername()
966 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in mtcp_setlastpkt()
[all …]
H A Dtcp_stream.c70 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in GetFragInfo()
77 stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in GetFragInfo()
130 if (side != MOS_SIDE_CLI && side != MOS_SIDE_SVR) { in GetBufInfo()
137 stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in GetBufInfo()
173 if (side == MOS_SIDE_CLI) in DisableBuf()
175 else if (side == MOS_SIDE_SVR) in DisableBuf()
185 if (stream->side != side) in DisableBuf()
187 assert(stream->side == side); in DisableBuf()
223 if (!stream || !(stream = (side == stream->side) ? stream : stream->pair_stream)) in GetTCPState()
628 cs->side = MOS_SIDE_CLI;
[all …]
H A Dtcp.c124 stream->side = MOS_SIDE_CLI; in CreateMonitorStream()
125 stream->pair_stream->side = MOS_SIDE_SVR; in CreateMonitorStream()
307 if (sendside_stream->side == MOS_SIDE_CLI) { in UpdateMonitor()
309 HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side, in UpdateMonitor()
314 HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side, in UpdateMonitor()
323 assert(sendside_stream->side == MOS_SIDE_CLI); in UpdateMonitor()
359 if (recvside_stream->side == MOS_SIDE_CLI) { in UpdateMonitor()
361 HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side, in UpdateMonitor()
366 HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side, in UpdateMonitor()
H A Dapi.c43 mtcp_cb_stop(mctx_t mctx, int sock, int side);
309 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
323 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
347 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
357 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
376 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
386 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
413 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
440 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
1127 cur_stream->side = MOS_SIDE_CLI; in mtcp_connect()
[all …]
H A Dscalable_event.c881 HandleCb(mctx_t const mctx, int sock, int side, in HandleCb() argument
908 walk->ft(mctx, sock, side, walk->ev, &walk->arg) == false) { in HandleCb()
915 walk->cb(mctx, sock, side, walk->ev, &walk->arg); in HandleCb()
1025 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events) in HandleCallback() argument
1037 if (side == MOS_SIDE_CLI && socket->monitor_stream->client_mon == 0) in HandleCallback()
1040 else if (side == MOS_SIDE_SVR && socket->monitor_stream->server_mon == 0) in HandleCallback()
1086 HandleCb(mctx, socket->id, side, stree, events); in HandleCallback()
H A Devent_callback.c598 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events) in HandleCallback() argument
615 if (side == MOS_SIDE_CLI && socket->monitor_stream->client_mon == 0) in HandleCallback()
618 else if (side == MOS_SIDE_SVR && socket->monitor_stream->server_mon == 0) in HandleCallback()
688 evt->ent[ev_idx].cb(mctx, socket->id, side, ev, data); in HandleCallback()
712 (tmpdata.u64 = g_udes[ude_id - UDE_OFFSET].ft(mctx, socket->id, side, ev, data))) { in HandleCallback()
H A Dtcp_in.c572 if (cur_stream->side == MOS_SIDE_CLI) { in ProcessTCPPayload()
574 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
579 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
630 if (cur_stream->side == MOS_SIDE_CLI) { in ProcessTCPPayload()
632 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
634 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
639 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
641 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in ProcessTCPPayload()
H A Dcore.c445 if (cur_stream->side == MOS_SIDE_CLI) { in FlushMonitorReadEvents()
448 cur_stream->side, NULL, in FlushMonitorReadEvents()
454 cur_stream->side, NULL, in FlushMonitorReadEvents()
498 if (cur_stream->side == MOS_SIDE_CLI) { in FlushBufferedReadEvents()
500 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in FlushBufferedReadEvents()
505 HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side, in FlushBufferedReadEvents()
H A Dtcp_rb.c912 if (recvside_stream->side == MOS_SIDE_CLI) { in tcp_rb_overlapchk()
915 recvside_stream->side, in tcp_rb_overlapchk()
921 recvside_stream->side, in tcp_rb_overlapchk()
/mOS-networking-stack/core/src/include/
H A Dmos_api.h175 int side; /* which side does this sequence number change apply to? */ member
291 typedef void (*callback_t)(mctx_t mctx, int sock, int side,
294 typedef bool (*filter_t)(mctx_t mctx, int sock, int side,
423 mtcp_peek(mctx_t mctx, int sock, int side,
446 ssize_t mtcp_ppeek(mctx_t mctx, int sock, int side,
463 mtcp_getlastpkt(mctx_t mctx, int sock, int side, struct pkt_info *p);
501 mtcp_getpeername(mctx_t mctx, int sock, struct sockaddr *saddr, socklen_t *addrlen, int side);
527 mtcp_setlastpkt(mctx_t mctx, int sock, int side, off_t offset,
H A Dtcp_stream.h264 side:2, member
328 GetFragInfo(socket_map_t sock, int side, void *optval, socklen_t *optlen);
331 GetBufInfo(socket_map_t sock, int side, void *optval, socklen_t *optlen);
334 GetTCPState(struct tcp_stream *stream, int side,
338 DisableBuf(socket_map_t sock, int side);
H A Dscalable_event.h27 HandleCallback(mtcp, MOS_NULL, walk, (stream)->side, \
75 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
H A Devent_callback.h78 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
/mOS-networking-stack/core/include/
H A Dmos_api.h175 int side; /* which side does this sequence number change apply to? */ member
291 typedef void (*callback_t)(mctx_t mctx, int sock, int side,
294 typedef bool (*filter_t)(mctx_t mctx, int sock, int side,
423 mtcp_peek(mctx_t mctx, int sock, int side,
446 ssize_t mtcp_ppeek(mctx_t mctx, int sock, int side,
463 mtcp_getlastpkt(mctx_t mctx, int sock, int side, struct pkt_info *p);
501 mtcp_getpeername(mctx_t mctx, int sock, struct sockaddr *saddr, socklen_t *addrlen, int side);
527 mtcp_setlastpkt(mctx_t mctx, int sock, int side, off_t offset,
/mOS-networking-stack/samples/nat/
H A Dnat.c122 translate_addr(mctx_t mctx, int sock, int side, uint64_t events, in translate_addr() argument
131 if (side == MOS_SIDE_CLI) { in translate_addr()
137 mtcp_setlastpkt(mctx, sock, side, 0, NULL, 0, MOS_DROP) < 0) in translate_addr()
146 TRACE_ERROR("mtcp_getpeer() failed sock=%d side=%d\n", sock, side); in translate_addr()
152 mtcp_setlastpkt(mctx, sock, side, 0, NULL, 0, MOS_DROP) < 0) in translate_addr()
158 release_port(mctx_t mctx, int sock, int side, uint64_t events, in release_port() argument
/mOS-networking-stack/samples/midstat/
H A Dmidstat.c71 cb_creation(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_creation() argument
95 cb_destroy(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_destroy() argument
108 cb_st_chg(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_st_chg() argument
116 if (side == MOS_SIDE_CLI) { in cb_st_chg()
155 cb_printstat(mctx_t mctx, int sock, int side, in cb_printstat() argument
/mOS-networking-stack/core/test/scalable_event/
H A Dtest.c27 HandleCb(mctx_t mctx, int sock, int side, stree_t *stree, event_t events);
46 cb(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in cb() argument
53 ft(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in ft() argument
60 ft_prob(mctx_t mctx, int sockid, int side, uint64_t events, filter_arg_t *arg) in ft_prob() argument
88 ft_ac_match(mctx_t mctx, int sock, int side, uint64_t ev, filter_arg_t *arg) in ft_ac_match() argument
/mOS-networking-stack/samples/simple_firewall/
H A Dsimple_firewall.c79 DumpFWRuleTable(mctx_t mctx, int sock, int side, in DumpFWRuleTable() argument
333 ApplyActionPerFlow(mctx_t mctx, int msock, int side, in ApplyActionPerFlow() argument
342 if (mtcp_getlastpkt(mctx, msock, side, &p) < 0) in ApplyActionPerFlow()
350 mtcp_setlastpkt(mctx, msock, side, 0, NULL, 0, MOS_DROP); in ApplyActionPerFlow()
364 int side, uint64_t events, filter_arg_t *arg) in CatchInitSYN() argument
368 if (mtcp_getlastpkt(mctx, sockid, side, &p) < 0) in CatchInitSYN()
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dssi.txt14 The module for server-side includes provides a compatability
H A Dstatus.txt92 add JavaScript which allows client-side sorting for the connection overview
H A Dcml.txt14 …to describe the dependencies of a page at one side and building a page from its fragments on the o…
H A Dstate.txt97 other way to handle the issue (e.g. client-side close of the connection).
H A Dmagnet.txt199 Your side might be on maintainance from time to time. Instead of shutting down the server confusing…
/mOS-networking-stack/samples/lighttpd-1.4.32/
H A Ddepcomp38 as side-effects.
H A Daclocal.m4535 # side effect of compilation, but ICC will put the dependencies in
583 # After this tag, mechanisms are not by side-effect, so they'll

12