Home
last modified time | relevance | path

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

12

/freebsd/tools/test/stress2/misc/
H A Dsocketpair2.sh95 size_t *rcvbuf, size_t *rcvbuf_set);
103 size_t sent, packetcount, sndbuf, sndbuf_set, rcvbuf, rcvbuf_set;
117 &rcvbuf, &rcvbuf_set);
124 (long)rcvbuf, (long)rcvbuf_set, (unsigned long)packetcount);
133 * Try the reverse. Perhaps this system wants a large rcvbuf rather than
149 &rcvbuf, &rcvbuf_set);
151 packetcount = MIN(rcvbuf, rcvbuf_set) / PACKETSIZE;
156 (long)rcvbuf, (long)rcvbuf_set, (unsigned long)packetcount);
159 if (sent >= (size_t)rcvbuf) {
169 setsockets(doreverse, packetsize, s, r, sndbuf, sndbuf_set, rcvbuf, rcvbuf_set)
[all …]
/freebsd/contrib/ofed/libibmad/
H A Dgs.c50 uint8_t *pma_query_via(void *rcvbuf, ib_portid_t * dest, int port, in pma_query_via() argument
71 mad_set_field(rcvbuf, 0, IB_PC_PORT_SELECT_F, port); in pma_query_via()
82 p_ret = mad_rpc(srcport, rpcold, dest, rcvbuf, rcvbuf); in pma_query_via()
87 uint8_t *performance_reset_via(void *rcvbuf, ib_portid_t * dest, in performance_reset_via() argument
111 memset(rcvbuf, 0, IB_MAD_SIZE); in performance_reset_via()
114 mad_set_field(rcvbuf, 0, IB_PC_PORT_SELECT_F, port); in performance_reset_via()
115 mad_set_field(rcvbuf, 0, IB_PC_COUNTER_SELECT_F, mask); in performance_reset_via()
118 mad_set_field(rcvbuf, 0, IB_PC_EXT_COUNTER_SELECT2_F, mask); in performance_reset_via()
120 mad_set_field(rcvbuf, 0, IB_PC_COUNTER_SELECT2_F, mask); in performance_reset_via()
130 p_ret = mad_rpc(srcport, rpcold, dest, rcvbuf, rcvbuf); in performance_reset_via()
H A Dsmp.c106 uint8_t *smp_query_status_via(void *rcvbuf, ib_portid_t * portid, in smp_query_status_via() argument
132 res = mad_rpc(srcport, &rpc, portid, rcvbuf, rcvbuf); in smp_query_status_via()
138 uint8_t *smp_query_via(void *rcvbuf, ib_portid_t * portid, unsigned attrid, in smp_query_via() argument
142 return smp_query_status_via(rcvbuf, portid, attrid, mod, timeout, NULL, in smp_query_via()
146 uint8_t *smp_query(void *rcvbuf, ib_portid_t * portid, unsigned attrid, in smp_query() argument
149 return smp_query_via(rcvbuf, portid, attrid, mod, timeout, ibmp); in smp_query()
H A Drpc.c129 _do_madrpc(int port_id, void *sndbuf, void *rcvbuf, int agentid, int len, in _do_madrpc() argument
171 if (umad_recv(port_id, rcvbuf, &length, timeout) < 0) { in _do_madrpc()
177 umad_addr_dump(umad_get_mad_addr(rcvbuf)); in _do_madrpc()
180 xdump(stderr, "rcv buf\n", umad_get_mad(rcvbuf), in _do_madrpc()
184 mad_get_field64(umad_get_mad(rcvbuf), 0, in _do_madrpc()
187 status = umad_status(rcvbuf); in _do_madrpc()
225 uint8_t sndbuf[1024], rcvbuf[1024], *mad; in mad_rpc() local
238 if ((len = _do_madrpc(port->port_id, sndbuf, rcvbuf, in mad_rpc()
250 mad = umad_get_mad(rcvbuf); in mad_rpc()
290 uint8_t sndbuf[1024], rcvbuf[1024], *mad; in mad_rpc_rmpp() local
[all …]
H A Dcc.c49 void *cc_query_status_via(void *rcvbuf, ib_portid_t * portid, in cc_query_status_via() argument
77 res = mad_rpc(srcport, (ib_rpc_t *)&rpc, portid, rcvbuf, rcvbuf); in cc_query_status_via()
84 void *cc_config_status_via(void *payload, void *rcvbuf, ib_portid_t * portid, in cc_config_status_via() argument
112 res = mad_rpc(srcport, (ib_rpc_t *)&rpc, portid, payload, rcvbuf); in cc_config_status_via()
H A Dsa.c49 uint8_t *sa_rpc_call(const struct ibmad_port *ibmad_port, void *rcvbuf, in sa_rpc_call() argument
77 p = mad_rpc_rmpp(ibmad_port, &rpc, portid, 0 /*&sa->rmpp */ , rcvbuf); /* TODO: RMPP */ in sa_rpc_call()
84 uint8_t *sa_call(void *rcvbuf, ib_portid_t * portid, ib_sa_call_t * sa, in sa_call() argument
87 return sa_rpc_call(ibmp, rcvbuf, portid, sa, timeout); in sa_call()
H A Dmad.h1686 MAD_EXPORT uint8_t *smp_query_status_via(void *rcvbuf, ib_portid_t * portid,
1698 MAD_EXPORT void *cc_query_status_via(void *rcvbuf, ib_portid_t * portid,
1703 MAD_EXPORT void *cc_config_status_via(void *payload, void *rcvbuf, ib_portid_t * portid,
1709 uint8_t *sa_call(void *rcvbuf, ib_portid_t * portid, ib_sa_call_t * sa,
1715 MAD_EXPORT uint8_t *sa_rpc_call(const struct ibmad_port *srcport, void *rcvbuf,
1752 MAD_EXPORT uint8_t *pma_query_via(void *rcvbuf, ib_portid_t * dest, int port,
1755 MAD_EXPORT uint8_t *performance_reset_via(void *rcvbuf, ib_portid_t * dest,
/freebsd/libexec/bootpd/tools/bootptest/
H A Dbootptest.c110 char *rcvbuf; /* Receive packet buffer */ variable
167 rcvbuf = malloc(BUFLEN); in main()
168 if (!sndbuf || !rcvbuf) { in main()
409 n = recvfrom(s, rcvbuf, BUFLEN, 0, in main()
424 snapend = (unsigned char *) rcvbuf + snaplen; in main()
425 bootp_print((struct bootp *)rcvbuf, n, sin_from.sin_port, 0); in main()
/freebsd/contrib/ntp/ntpd/
H A Drefclock_oncore.c359 #define rcvbuf instance->Rcvbuf macro
1468 if ((size_t)rcvptr + i >= sizeof(rcvbuf)) in oncore_receive()
1469 i = sizeof(rcvbuf) - rcvptr; /* and some char will be lost */ in oncore_receive()
1470 memcpy(rcvbuf+rcvptr, p, i); in oncore_receive()
1489 if (rcvbuf[0] != '@' || rcvbuf[1] != '@') { in oncore_consume()
1492 if (rcvbuf[i] == '@' && rcvbuf[i+1] == '@') in oncore_consume()
1501 memcpy(rcvbuf, rcvbuf in oncore_consume()
[all...]
/freebsd/tests/sys/kern/
H A Dunix_seqpacket_test.c240 char rcvbuf[pktsize]; in test_pipe_simulator() local
277 rsize = recv(sv[1], rcvbuf, pktsize, MSG_WAITALL); in test_pipe_simulator()
293 ATF_CHECK_EQ_MSG(0, memcmp(comparebuf, rcvbuf, in test_pipe_simulator()
336 char rcvbuf[td->pktsize]; in test_pipe_reader() local
343 rsize = recv(td->so, rcvbuf, td->pktsize, MSG_WAITALL); in test_pipe_reader()
351 d = memcmp(comparebuf, rcvbuf, td->pktsize); in test_pipe_reader()
625 int rcvbuf = 23456; in ATF_TC_BODY() local
646 if (setsockopt(s, SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)) != 0){ in ATF_TC_BODY()
665 int rcvbuf = 23456; in ATF_TC_BODY() local
698 err = setsockopt(sv[0], SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(rcvbuf)); in ATF_TC_BODY()
/freebsd/sys/dev/hyperv/hvsock/
H A Dhv_sock.c1400 unsigned int rcvbuf, sndbuf; in hvsock_open_channel() local
1406 rcvbuf = HVS_RINGBUF_RCV_SIZE; in hvsock_open_channel()
1411 rcvbuf = MAX(so->so_rcv.sb_hiwat, HVS_RINGBUF_RCV_SIZE); in hvsock_open_channel()
1412 rcvbuf = MIN(rcvbuf, HVS_RINGBUF_MAX_SIZE); in hvsock_open_channel()
1413 rcvbuf = rounddown2(rcvbuf, PAGE_SIZE); in hvsock_open_channel()
1422 ret = vmbus_chan_open(chan, sndbuf, rcvbuf, NULL, 0, in hvsock_open_channel()
1428 "rcvbuf = %u\n", __func__, sndbuf, rcvbuf); in hvsock_open_channel()
1432 "rcvbuf = %u\n", __func__, sndbuf, rcvbuf); in hvsock_open_channel()
/freebsd/contrib/ofed/infiniband-diags/src/
H A Dibqueryerrors.c652 uint8_t *reset_pc_ext(void *rcvbuf, ib_portid_t * dest, in reset_pc_ext() argument
673 memset(rcvbuf, 0, IB_MAD_SIZE); in reset_pc_ext()
676 mad_set_field(rcvbuf, 0, IB_PC_EXT_PORT_SELECT_F, port); in reset_pc_ext()
677 mad_set_field(rcvbuf, 0, IB_PC_EXT_COUNTER_SELECT_F, mask); in reset_pc_ext()
687 return mad_rpc(srcport, &rpc, dest, rcvbuf, rcvbuf); in reset_pc_ext()
H A Dperfquery.c529 static uint8_t *ext_speeds_reset_via(void *rcvbuf, ib_portid_t * dest, in ext_speeds_reset_via() argument
550 memset(rcvbuf, 0, IB_MAD_SIZE); in ext_speeds_reset_via()
552 mad_set_field(rcvbuf, 0, IB_PESC_PORT_SELECT_F, port); in ext_speeds_reset_via()
553 mad_set_field64(rcvbuf, 0, IB_PESC_COUNTER_SELECT_F, mask); in ext_speeds_reset_via()
563 return mad_rpc(srcport, &rpc, dest, rcvbuf, rcvbuf); in ext_speeds_reset_via()
/freebsd/sbin/ggate/shared/
H A Dggate.c272 unsigned rcvbuf = G_GATE_RCVBUF; variable
291 bsize = rcvbuf; in g_gate_socket_settings()
H A Dggate.h67 extern unsigned rcvbuf, sndbuf;
/freebsd/usr.sbin/flowctl/
H A Dflowctl.c116 int rcvbuf = SORCVBUF_SIZE; in main() local
142 if (setsockopt(cs, SOL_SOCKET, SO_RCVBUF, &rcvbuf, sizeof(int)) == -1) in main()
/freebsd/sbin/ggate/ggatec/
H A Dggatec.c617 rcvbuf = strtoul(optarg, NULL, 10); in main()
618 if (rcvbuf == 0 && errno != 0) in main()
/freebsd/contrib/unbound/contrib/
H A Dunbound.service.in66 # This breaks using socket options like 'so-rcvbuf'. Explicitly disable for visibility.
/freebsd/sys/netlink/
H A Dnetlink_snl.h270 int rcvbuf; in snl_init() local
271 if (getsockopt(ss->fd, SOL_SOCKET, SO_RCVBUF, &rcvbuf, &optlen) == -1) { in snl_init()
276 ss->bufsize = rcvbuf; in snl_init()
/freebsd/sbin/ggate/ggated/
H A Dggated.c1069 rcvbuf = strtoul(optarg, NULL, 10); in main()
1070 if (rcvbuf == 0 && errno != 0) in main()
/freebsd/contrib/bsnmp/snmpd/
H A Dmain.c660 snmp_input_finish(struct snmp_pdu *pdu, const u_char *rcvbuf, size_t rcvlen, in snmp_input_finish() argument
671 pdu_b.asn_cptr = rcvbuf; in snmp_input_finish()
/freebsd/contrib/unbound/util/
H A Dconfiglexer.lex282 so-rcvbuf{COLON} { YDVAR(1, VAR_SO_RCVBUF) }
/freebsd/contrib/unbound/doc/
H A Dexample.conf.in116 # so-rcvbuf: 0
/freebsd/contrib/ntp/sntp/libevent/
H A DChangeLog102 o evdns: add new options -- so-rcvbuf/so-sndbuf (546a366c Azat Khuzhin)
/freebsd/contrib/libevent/
H A DChangeLog102 o evdns: add new options -- so-rcvbuf/so-sndbuf (546a366c Azat Khuzhin)

12