Lines Matching full:parse
60 #include "parse.h"
69 "parse", /* module name */
80 "PARSE - NTP reference", /* name this baby - keep room for revision number */
215 static struct streamtab parseinfo = /* stream info element for parse driver */
290 pprintf(DD_OPEN,"parse: SETUP_STREAM - setting up stream for q=%x\n", q); in setup_stream()
311 pprintf(DD_OPEN, "parse: setup_stream - FAILED - no MEMORY for allocb\n"); in setup_stream()
326 register parsestream_t *parse; in parseopen() local
329 pprintf(DD_OPEN, "parse: OPEN - q=%x\n", q); in parseopen()
333 pprintf(DD_OPEN, "parse: OPEN - FAILED - not MODOPEN\n"); in parseopen()
339 pprintf(DD_OPEN, "parse: OPEN - FAILED - EXCLUSIVE ONLY\n"); in parseopen()
349 pprintf(DD_OPEN, "parse: OPEN - parse area q=%x, q->q_ptr=%x\n", q, q->q_ptr); in parseopen()
351 pprintf(DD_OPEN, "parse: OPEN - WQ parse area q=%x, q->q_ptr=%x\n", WR(q), WR(q)->q_ptr); in parseopen()
353 parse = (parsestream_t *) q->q_ptr; in parseopen()
354 bzero((caddr_t)parse, sizeof(*parse)); in parseopen()
355 parse->parse_queue = q; in parseopen()
356 parse->parse_status = PARSE_ENABLE; in parseopen()
357 parse->parse_ppsclockev.tv.tv_sec = 0; in parseopen()
358 parse->parse_ppsclockev.tv.tv_usec = 0; in parseopen()
359 parse->parse_ppsclockev.serial = 0; in parseopen()
363 pprintf(DD_OPEN, "parse: OPEN - initializing io subsystem q=%x\n", q); in parseopen()
365 if (!parse_ioinit(&parse->parse_io)) in parseopen()
372 kmem_free((caddr_t)parse, sizeof(parsestream_t)); in parseopen()
377 pprintf(DD_OPEN, "parse: OPEN - initializing stream q=%x\n", q); in parseopen()
382 pprintf(DD_OPEN, "parse: OPEN - SUCCEEDED\n"); in parseopen()
400 kmem_free((caddr_t)parse, sizeof(parsestream_t)); in parseopen()
413 register parsestream_t *parse = (parsestream_t *)q->q_ptr; in parseclose() local
416 pprintf(DD_CLOSE, "parse: CLOSE\n"); in parseclose()
422 if (parse->parse_dqueue) in parseclose()
423 close_linemon(parse->parse_dqueue, q); in parseclose()
424 parse->parse_dqueue = (queue_t *)0; in parseclose()
428 parse_ioend(&parse->parse_io); in parseclose()
430 kmem_free((caddr_t)parse, sizeof(parsestream_t)); in parseclose()
453 pprintf(DD_RSVC, "parse: RSVC - putnext\n"); in parsersvc()
458 pprintf(DD_RSVC, "parse: RSVC - flow control wait\n"); in parsersvc()
479 parsestream_t *parse = (parsestream_t *)q->q_ptr; in parsewput() local
481 pprintf(DD_WPUT, "parse: parsewput\n"); in parsewput()
494 pprintf(DD_WPUT, "parse: parsewput - forward M_IOCTL\n"); in parsewput()
515 *(struct ppsclockev *)(void *)datap->b_wptr = parse->parse_ppsclockev; in parsewput()
526 parse->parse_status = (parse->parse_status & (unsigned)~PARSE_ENABLE) | in parsewput()
529 if (!setup_stream(RD(q), (parse->parse_status & PARSE_ENABLE) ? in parsewput()
553 pprintf(DD_WPUT, "parse: parsewput - PARSEIOC_TIMECODE\n"); in parsewput()
554 ok = parse_timecode(dct, &parse->parse_io); in parsewput()
558 pprintf(DD_WPUT, "parse: parsewput - PARSEIOC_SETFMT\n"); in parsewput()
559 ok = parse_setfmt(dct, &parse->parse_io); in parsewput()
563 pprintf(DD_WPUT, "parse: parsewput - PARSEIOC_GETFMT\n"); in parsewput()
564 ok = parse_getfmt(dct, &parse->parse_io); in parsewput()
568 pprintf(DD_WPUT, "parse: parsewput - PARSEIOC_SETCS\n"); in parsewput()
569 ok = parse_setcs(dct, &parse->parse_io); in parsewput()
578 …pprintf(DD_WPUT, "parse: parsewput qreply - %s\n", (mp->b_datap->db_type == M_IOCNAK) ? "M_IOCNAK"… in parsewput()
630 pprintf(DD_RPUT, "parse: parserput - forward type 0x%x\n", type); in parserput()
643 register parsestream_t * parse = (parsestream_t *)q->q_ptr; in parserput() local
656 if (!(parse->parse_status & PARSE_ENABLE)) in parserput()
658 pprintf(DD_RPUT, "parse: parserput - parser disabled - forward type 0x%x\n", type); in parserput()
668 pprintf(DD_RPUT, "parse: parserput - M_%s\n", (type == M_DATA) ? "DATA" : "BREAK"); in parserput()
672 * parse packet looking for start an end characters in parserput()
677 if (ch != ~0 && parse_ioread(&parse->parse_io, (unsigned int)ch, &c_time)) in parserput()
684 if (canputnext(parse->parse_queue) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED))) in parserput()
686 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t)); in parserput()
688 putnext(parse->parse_queue, nmp); in parserput()
692 parse_iodone(&parse->parse_io); in parserput()
698 if (parse_ioread(&parse->parse_io, (unsigned int)0, &c_time)) in parserput()
705 if (canputnext(parse->parse_queue) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED))) in parserput()
707 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t)); in parserput()
709 putnext(parse->parse_queue, nmp); in parserput()
713 parse_iodone(&parse->parse_io); in parserput()
727 register parsestream_t * parse = (parsestream_t *)q->q_ptr; in parserput() local
737 pprintf(DD_RPUT, "parse: parserput - M_%sHANGUP\n", (type == M_HANGUP) ? "" : "UN"); in parserput()
739 if ((parse->parse_status & PARSE_ENABLE) && in parserput()
740 parse_iopps(&parse->parse_io, status ? SYNC_ONE : SYNC_ZERO, &c_time)) in parserput()
743 if (canputnext(parse->parse_queue) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED))) in parserput()
745 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t)); in parserput()
747 putnext(parse->parse_queue, nmp); in parserput()
751 parse_iodone(&parse->parse_io); in parserput()
764 parse->parse_ppsclockev.tv = c_time.tv; in parserput()
765 ++(parse->parse_ppsclockev.serial); in parserput()