Lines Matching refs:parse
92 #include "parse.h"
368 static char mn[] = "parse";
465 parseprintf(DD_OPEN,("parse: setup_stream - FAILED - no MEMORY for allocb\n"));
479 register parsestream_t *parse;
482 parseprintf(DD_OPEN,("parse: OPEN\n"));
486 parseprintf(DD_OPEN,("parse: OPEN - FAILED - not MODOPEN\n"));
493 parseprintf(DD_OPEN,("parse: OPEN - FAILED - EXCLUSIVE ONLY\n"));
504 parseprintf(DD_OPEN,("parse: OPEN - FAILED - no memory\n"));
512 parse = (parsestream_t *)(void *)q->q_ptr;
513 bzero((caddr_t)parse, sizeof(*parse));
514 parse->parse_queue = q;
515 parse->parse_status = PARSE_ENABLE;
516 parse->parse_ppsclockev.tv.tv_sec = 0;
517 parse->parse_ppsclockev.tv.tv_usec = 0;
518 parse->parse_ppsclockev.serial = 0;
520 if (!parse_ioinit(&parse->parse_io))
525 kmem_free((caddr_t)parse, sizeof(parsestream_t));
536 parseprintf(DD_OPEN,("parse: OPEN - SUCCEEDED\n"));
556 kmem_free((caddr_t)parse, sizeof(parsestream_t));
572 register parsestream_t *parse = (parsestream_t *)(void *)q->q_ptr;
575 parseprintf(DD_CLOSE,("parse: CLOSE\n"));
579 if (parse->parse_dqueue)
580 close_linemon(parse->parse_dqueue, q);
581 parse->parse_dqueue = (queue_t *)0;
585 parse_ioend(&parse->parse_io);
587 kmem_free((caddr_t)parse, sizeof(parsestream_t));
613 parseprintf(DD_RSVC,("parse: RSVC - putnext\n"));
618 parseprintf(DD_RSVC,("parse: RSVC - flow control wait\n"));
639 parsestream_t *parse = (parsestream_t *)(void *)q->q_ptr;
641 parseprintf(DD_WPUT,("parse: parsewput\n"));
654 parseprintf(DD_WPUT,("parse: parsewput - forward M_IOCTL\n"));
674 *(struct ppsclockev *)(void *)datap->b_wptr = parse->parse_ppsclockev;
685 parse->parse_status = (parse->parse_status & (unsigned)~PARSE_ENABLE) |
688 if (!setup_stream(RD(q), (parse->parse_status & PARSE_ENABLE) ?
712 parseprintf(DD_WPUT,("parse: parsewput - PARSEIOC_TIMECODE\n"));
713 ok = parse_timecode(dct, &parse->parse_io);
717 parseprintf(DD_WPUT,("parse: parsewput - PARSEIOC_SETFMT\n"));
718 ok = parse_setfmt(dct, &parse->parse_io);
722 parseprintf(DD_WPUT,("parse: parsewput - PARSEIOC_GETFMT\n"));
723 ok = parse_getfmt(dct, &parse->parse_io);
727 parseprintf(DD_WPUT,("parse: parsewput - PARSEIOC_SETCS\n"));
728 ok = parse_setcs(dct, &parse->parse_io);
737 parseprintf(DD_WPUT,("parse: parsewput qreply - %s\n", (mp->b_datap->db_type == M_IOCNAK) ? "M_IOCNAK" : "M_IOCACK"));
788 parseprintf(DD_RPUT,("parse: parserput - forward type 0x%x\n", type));
800 register parsestream_t * parse = (parsestream_t *)(void *)q->q_ptr;
810 if (!(parse->parse_status & PARSE_ENABLE))
812 parseprintf(DD_RPUT,("parse: parserput - parser disabled - forward type 0x%x\n", type));
822 parseprintf(DD_RPUT,("parse: parserput - M_%s\n", (type == M_DATA) ? "DATA" : "BREAK"));
827 * parse packet looking for start an end characters
832 if (ch != ~0 && parse_ioread(&parse->parse_io, (unsigned int)ch, &ctime))
839 if (canput(parse->parse_queue->q_next) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED)))
841 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t));
843 putnext(parse->parse_queue, nmp);
847 parse_iodone(&parse->parse_io);
853 if (parse_ioread(&parse->parse_io, (unsigned int)0, &ctime))
860 if (canput(parse->parse_queue->q_next) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED)))
862 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t));
864 putnext(parse->parse_queue, nmp);
868 parse_iodone(&parse->parse_io);
882 register parsestream_t * parse = (parsestream_t *)(void *)q->q_ptr;
889 parseprintf(DD_RPUT,("parse: parserput - M_%sHANGUP\n", (type == M_HANGUP) ? "" : "UN"));
891 if ((parse->parse_status & PARSE_ENABLE) &&
892 parse_iopps(&parse->parse_io, (int)(status ? SYNC_ONE : SYNC_ZERO), &ctime))
895 if (canput(parse->parse_queue->q_next) && (nmp = allocb(sizeof(parsetime_t), BPRI_MED)))
897 bcopy((caddr_t)&parse->parse_io.parse_dtime, (caddr_t)nmp->b_rptr, sizeof(parsetime_t));
899 putnext(parse->parse_queue, nmp);
903 parse_iodone(&parse->parse_io);
916 parse->parse_ppsclockev.tv = ctime.tv;
917 ++(parse->parse_ppsclockev.serial);