Home
last modified time | relevance | path

Searched refs:rbufp (Results 1 – 25 of 47) sorted by relevance

12

/freebsd/contrib/ntp/ntpd/
H A Drefclock_leitch.c390 struct recvbuf *rbufp in leitch_receive() argument
393 struct leitchunit *leitch = rbufp->recv_peer->procptr->unitptr; in leitch_receive()
398 rbufp->recv_length, rbufp->recv_length, in leitch_receive()
399 rbufp->recv_buffer); in leitch_receive()
401 if (rbufp->recv_length != 7) in leitch_receive()
409 if (!leitch_get_date(rbufp,leitch)) { in leitch_receive()
421 if (!leitch_get_time(rbufp,leitch,1)) { in leitch_receive()
424 leitch->second, 1, rbufp->recv_time.l_ui, in leitch_receive()
435 leitch->codetime1 = rbufp->recv_time; in leitch_receive()
439 if (!leitch_get_time(rbufp,leitch,2)) { in leitch_receive()
[all …]
H A Dntp_monitor.c23 * receive procedure calls us with the incoming rbufp before it does
312 struct recvbuf *rbufp, in ntp_monitor() argument
330 REQUIRE(rbufp != NULL); in ntp_monitor()
335 pkt = &rbufp->recv_pkt; in ntp_monitor()
336 hash = MON_HASH(&rbufp->recv_srcadr); in ntp_monitor()
347 if (SOCK_EQ(&mon->rmtadr, &rbufp->recv_srcadr)) { in ntp_monitor()
352 interval_fp = rbufp->recv_time; in ntp_monitor()
357 mon->last = rbufp->recv_time; in ntp_monitor()
358 NSRCPORT(&mon->rmtadr) = NSRCPORT(&rbufp->recv_srcadr); in ntp_monitor()
449 interval_fp = rbufp in ntp_monitor()
[all...]
H A Dntp_proto.c210 nak_code valid_NAK (struct peer *peer, struct recvbuf *rbufp, u_char hismode);
300 struct recvbuf *rbufp, in valid_NAK() argument
314 if (rbufp->recv_length == base_packet_length) { in valid_NAK()
318 remainder_size = rbufp->recv_length - base_packet_length; in valid_NAK()
340 rpkt = &rbufp->recv_pkt; in valid_NAK()
627 struct recvbuf *rbufp in receive() argument
687 if (0 == SRCPORT(&rbufp->recv_srcadr) || rbufp->recv_length < 2) { in receive()
691 restrictions(&rbufp->recv_srcadr, &r4a); in receive()
694 pkt = &rbufp->recv_pkt; in receive()
709 process_private(rbufp, !(RES_NOMODIFY & restrict_mask)); in receive()
[all …]
H A Drefclock_zyfer.c204 struct recvbuf *rbufp in zyfer_receive() argument
219 peer = rbufp->recv_peer; in zyfer_receive()
222 p = (u_char *) &rbufp->recv_space; in zyfer_receive()
225 * - if *rbufp->recv_space is ! in zyfer_receive()
243 pp->lencode = refclock_gtlin(rbufp, pp->a_lastcode, in zyfer_receive()
248 memcpy(pp->a_lastcode + pp->lencode, p, rbufp->recv_length); in zyfer_receive()
249 pp->lencode += rbufp->recv_length; in zyfer_receive()
H A Dntp_signd.c124 struct recvbuf *rbufp, /* receive packet pointer */ in send_via_ntp_signd() argument
222 sendpkt(&rbufp->recv_srcadr, rbufp->dstadr, 0, xpkt, sendlen); in send_via_ntp_signd()
227 current_time, ntoa(&rbufp->dstadr->sin), in send_via_ntp_signd()
228 ntoa(&rbufp->recv_srcadr), xmode, xkeyid, sendlen); in send_via_ntp_signd()
H A Dntp_control.c944 struct recvbuf *rbufp, in save_config()
1004 stoa(&rbufp->recv_srcadr)); in save_config()
1016 stoa(&rbufp->recv_srcadr)); in save_config()
1041 stoa(&rbufp->recv_srcadr)); in save_config()
1086 stoa(&rbufp->recv_srcadr)); in save_config()
1103 stoa(&rbufp->recv_srcadr)); in save_config()
1118 stoa(&rbufp->recv_srcadr)); in save_config()
1133 stoa(&rbufp->recv_srcadr)); in save_config()
1138 fullpath, stoa(&rbufp->recv_srcadr)); in save_config()
1166 struct recvbuf *rbufp, in process_control()
945 save_config(struct recvbuf * rbufp,int restrict_mask) save_config() argument
1167 process_control(struct recvbuf * rbufp,int restrict_mask) process_control() argument
3196 control_unspec(struct recvbuf * rbufp,int restrict_mask) control_unspec() argument
3227 read_status(struct recvbuf * rbufp,int restrict_mask) read_status() argument
3407 read_variables(struct recvbuf * rbufp,int restrict_mask) read_variables() argument
3425 write_variables(struct recvbuf * rbufp,int restrict_mask) write_variables() argument
3529 configure(struct recvbuf * rbufp,int restrict_mask) configure() argument
3699 generate_nonce(struct recvbuf * rbufp,char * nonce,size_t nonce_octets) generate_nonce() argument
3722 validate_nonce(const char * pnonce,struct recvbuf * rbufp) validate_nonce() argument
3967 read_mru_list(struct recvbuf * rbufp,int restrict_mask) read_mru_list() argument
4358 read_ifstats(struct recvbuf * rbufp) read_ifstats() argument
4516 read_addr_restrictions(struct recvbuf * rbufp) read_addr_restrictions() argument
4533 read_ordlist(struct recvbuf * rbufp,int restrict_mask) read_ordlist() argument
4575 req_nonce(struct recvbuf * rbufp,int restrict_mask) req_nonce() argument
4593 read_clockstatus(struct recvbuf * rbufp,int restrict_mask) read_clockstatus() argument
4705 write_clockstatus(struct recvbuf * rbufp,int restrict_mask) write_clockstatus() argument
4722 set_trap(struct recvbuf * rbufp,int restrict_mask) set_trap() argument
4759 unset_trap(struct recvbuf * rbufp,int restrict_mask) unset_trap() argument
[all...]
H A Drefclock_fg.c216 struct recvbuf *rbufp in fg_receive() argument
228 peer = rbufp->recv_peer; in fg_receive()
241 if (rbufp->recv_length < (LENFG - 2)) { in fg_receive()
251 bpt = (char *)rbufp->recv_buffer; in fg_receive()
317 pp->lastrec = rbufp->recv_time; /* Is it better than get_systime()? */ in fg_receive()
H A Drefclock_chu.c423 static void chu_audio_receive (struct recvbuf *rbufp);
428 static void chu_serial_receive (struct recvbuf *rbufp);
616 struct recvbuf *rbufp /* receive buffer structure pointer */ in chu_receive() argument
624 peer = rbufp->recv_peer; in chu_receive()
637 chu_audio_receive(rbufp); in chu_receive()
639 chu_serial_receive(rbufp); in chu_receive()
641 chu_serial_receive(rbufp); in chu_receive()
652 struct recvbuf *rbufp /* receive buffer structure pointer */ in chu_audio_receive() argument
664 peer = rbufp->recv_peer; in chu_audio_receive()
672 DTOLFP((double)rbufp->recv_length / SECOND, &ltemp); in chu_audio_receive()
[all …]
H A Drefclock_arc.c870 struct recvbuf *rbufp in arc_receive() argument
889 peer = rbufp->recv_peer; in arc_receive()
915 arc_last_offset = pp->lencode+rbufp->recv_length - 1; in arc_receive()
936 c = rbufp->recv_buffer[0]; in arc_receive()
945 timestamp = rbufp->recv_time; in arc_receive()
950 rbufp->recv_length); in arc_receive()
980 ((rbufp->recv_length > 1) ? "*** " : ""), in arc_receive()
981 rbufp->recv_length, in arc_receive()
1030 if(debug && (rbufp->recv_buffer[0] != '\r')) in arc_receive()
1038 for(i = 0; i < rbufp in arc_receive()
[all...]
H A Drefclock_datum.c485 struct recvbuf *rbufp in datum_pts_receive() argument
508 p = rbufp->recv_peer; in datum_pts_receive()
510 dpt = (char *)&rbufp->recv_space; in datum_pts_receive()
511 dpend = rbufp->recv_length; in datum_pts_receive()
532 datum_pts->lastrec = rbufp->recv_time; in datum_pts_receive()
H A Drefclock_palisade.c126 static void praecis_parse(struct recvbuf *rbufp, struct peer *peer);
1242 struct recvbuf *rbufp, in praecis_parse() argument
1252 if (p + rbufp->recv_length >= sizeof buf) { in praecis_parse()
1282 memcpy(buf+p, rbufp->recv_buffer, rbufp->recv_length); in praecis_parse()
1283 p += rbufp->recv_length; in praecis_parse()
1303 struct recvbuf *rbufp in palisade_io() argument
1315 peer = rbufp->recv_peer; in palisade_io()
1321 praecis_parse(rbufp,peer); in palisade_io()
1326 c = (char *) &rbufp in palisade_io()
[all...]
H A Dntp_refclock.c723 struct recvbuf *rbufp, /* receive buffer pointer */
738 sp = (const char *)rbufp->recv_buffer; in refclock_gtlin()
739 spend = sp + rbufp->recv_length; in refclock_gtlin()
755 *tsptr = rbufp->recv_time; in refclock_gtlin()
757 rbufp->fd, ulfptoa(&rbufp->recv_time, 6), dlen, in refclock_gtlin()
782 struct recvbuf *rbufp, /* receive buffer pointer */
791 if (bmax > rbufp->recv_length) in refclock_gtraw()
792 bmax = rbufp->recv_length; in refclock_gtraw()
793 memcpy(lineptr, rbufp in refclock_gtraw()
725 refclock_gtlin(struct recvbuf * rbufp,char * lineptr,int bmax,l_fp * tsptr) refclock_gtlin() argument
784 refclock_gtraw(struct recvbuf * rbufp,char * lineptr,int bmax,l_fp * tsptr) refclock_gtraw() argument
[all...]
H A Drefclock_heath.c272 struct recvbuf *rbufp in heath_receive() argument
285 peer = rbufp->recv_peer; in heath_receive()
287 pp->lencode = refclock_gtlin(rbufp, pp->a_lastcode, BMAX, in heath_receive()
H A Drefclock_pst.c188 struct recvbuf *rbufp in pst_receive() argument
204 peer = rbufp->recv_peer; in pst_receive()
207 up->lastptr += refclock_gtlin(rbufp, up->lastptr, pp->a_lastcode in pst_receive()
H A Drefclock_irig.c407 struct recvbuf *rbufp /* receive buffer structure pointer */ in irig_receive() argument
422 peer = rbufp->recv_peer; in irig_receive()
430 DTOLFP((double)rbufp->recv_length / SECOND, &ltemp); in irig_receive()
431 L_SUB(&rbufp->recv_time, &ltemp); in irig_receive()
432 up->timestamp = rbufp->recv_time; in irig_receive()
433 dpt = rbufp->recv_buffer; in irig_receive()
434 for (bufcnt = 0; bufcnt < rbufp->recv_length; bufcnt++) { in irig_receive()
H A Drefclock_hopfser.c204 struct recvbuf *rbufp in hopfserial_receive() argument
220 peer = rbufp->recv_peer; in hopfserial_receive()
229 pp->lencode = (u_short)refclock_gtlin(rbufp, pp->a_lastcode, in hopfserial_receive()
H A Drefclock_as2201.c228 struct recvbuf *rbufp in as2201_receive() argument
240 peer = rbufp->recv_peer; in as2201_receive()
243 pp->lencode = refclock_gtlin(rbufp, pp->a_lastcode, BMAX, &trtmp); in as2201_receive()
H A Drefclock_dumbclock.c187 struct recvbuf *rbufp in dumbclock_receive() argument
204 peer = rbufp->recv_peer; in dumbclock_receive()
207 temp = refclock_gtlin(rbufp, pp->a_lastcode, BMAX, &trtmp); in dumbclock_receive()
H A Drefclock_chronolog.c170 struct recvbuf *rbufp in chronolog_receive() argument
187 peer = rbufp->recv_peer; in chronolog_receive()
190 temp = refclock_gtlin(rbufp, pp->a_lastcode, BMAX, &trtmp); in chronolog_receive()
H A Drefclock_ulink.c187 struct recvbuf *rbufp in ulink_receive() argument
206 peer = rbufp->recv_peer; in ulink_receive()
209 temp = refclock_gtlin(rbufp, pp->a_lastcode, BMAX, &trtmp); in ulink_receive()
H A Dntp_peer.c302 struct recvbuf *rbufp, in findpeer() argument
314 srcadr = &rbufp->recv_srcadr; in findpeer()
320 if (p->hmode != MODE_BCLIENT && p->dstadr != rbufp->dstadr) in findpeer()
342 pkt = &rbufp->recv_pkt; in findpeer()
345 findmanycastpeer(rbufp)) in findpeer()
1130 struct recvbuf *rbufp /* receive buffer pointer */
1147 pkt = &rbufp->recv_pkt;
1075 findmanycastpeer(struct recvbuf * rbufp) findmanycastpeer() argument
H A Drefclock_jjy.c600 jjy_receive ( struct recvbuf *rbufp ) in jjy_receive() argument
619 peer = rbufp->recv_peer ; in jjy_receive()
628 pp->lencode = refclock_gtraw ( rbufp, pp->a_lastcode, BMAX-1, &tRecvTimestamp ) ; in jjy_receive()
646 pp->lencode = refclock_gtlin ( rbufp, pp->a_lastcode, BMAX, &tRecvTimestamp ) ; in jjy_receive()
772 rc = jjy_receive_tristate_jjy01 ( rbufp ) ; in jjy_receive()
776 rc = jjy_receive_cdex_jst2000 ( rbufp ) ; in jjy_receive()
780 rc = jjy_receive_echokeisokuki_lt2000 ( rbufp ) ; in jjy_receive()
784 rc = jjy_receive_citizentic_jjy200 ( rbufp ) ; in jjy_receive()
788 rc = jjy_receive_tristate_gpsclock01 ( rbufp ) ; in jjy_receive()
792 rc = jjy_receive_seiko_tsys_tdc_300 ( rbufp ) ; in jjy_receive()
1176 jjy_receive_tristate_jjy01(struct recvbuf * rbufp) jjy_receive_tristate_jjy01() argument
1501 jjy_receive_cdex_jst2000(struct recvbuf * rbufp) jjy_receive_cdex_jst2000() argument
1664 jjy_receive_echokeisokuki_lt2000(struct recvbuf * rbufp) jjy_receive_echokeisokuki_lt2000() argument
1877 jjy_receive_citizentic_jjy200(struct recvbuf * rbufp) jjy_receive_citizentic_jjy200() argument
2058 jjy_receive_tristate_gpsclock01(struct recvbuf * rbufp) jjy_receive_tristate_gpsclock01() argument
2384 jjy_receive_seiko_tsys_tdc_300(struct recvbuf * rbufp) jjy_receive_seiko_tsys_tdc_300() argument
2849 jjy_receive_telephone(struct recvbuf * rbufp) jjy_receive_telephone() argument
3881 modem_receive(struct recvbuf * rbufp) modem_receive() argument
[all...]
/freebsd/contrib/ntp/libntp/
H A Drecvbuff.c323 recvbuf_t *rbufp; in purge_recv_buffers_for_fd()
334 for (rbufp = HEAD_FIFO(full_recv_fifo); in purge_recv_buffers_for_fd()
335 rbufp != NULL; in purge_recv_buffers_for_fd()
336 rbufp = next) in purge_recv_buffers_for_fd()
338 next = rbufp->link; in purge_recv_buffers_for_fd()
340 if (rbufp->dstadr == NULL && rbufp->fd == fd) in purge_recv_buffers_for_fd()
342 if (rbufp->fd == fd) in purge_recv_buffers_for_fd()
346 rbufp, link, recvbuf_t); in purge_recv_buffers_for_fd()
347 INSIST(punlinked == rbufp); in purge_recv_buffers_for_fd()
310 recvbuf_t *rbufp; purge_recv_buffers_for_fd() local
[all...]
/freebsd/lib/libc/db/hash/
H A Dhash.c571 BUFHEAD *rbufp; in hash_access() local
585 rbufp = __get_buf(hashp, __call_hash(hashp, kp, size), NULL, 0); in hash_access()
586 if (!rbufp) in hash_access()
588 save_bufp = rbufp; in hash_access()
591 rbufp->flags |= BUF_PIN; in hash_access()
592 for (bp = (u_int16_t *)rbufp->page, n = *bp++, ndx = 1; ndx < n;) in hash_access()
596 memcmp(kp, rbufp->page + *bp, size) == 0) in hash_access()
605 rbufp = __get_buf(hashp, *bp, rbufp, 0); in hash_access()
606 if (!rbufp) { in hash_access()
611 bp = (u_int16_t *)rbufp->page; in hash_access()
[all …]
H A Dhash_bigkey.c194 BUFHEAD *last_bfp, *rbufp; in __big_delete() local
198 rbufp = bufp; in __big_delete()
216 rbufp->flags |= BUF_MOD; in __big_delete()
217 rbufp = __get_buf(hashp, pageno, rbufp, 0); in __big_delete()
220 last_bfp = rbufp; in __big_delete()
221 if (!rbufp) in __big_delete()
223 bp = (u_int16_t *)rbufp->page; in __big_delete()
243 bufp->ovfl = rbufp->ovfl; in __big_delete()
253 if (rbufp) in __big_delete()
254 __free_ovflpage(hashp, rbufp); in __big_delete()
[all …]

12