565 #define ENQUEUE(up) \  argument
598           register struct arcunit *up = pp->unitptr;  in arc_event_handler()  local
605           c = up->cmdqueue[0];       /* Next char to be sent. */  in arc_event_handler()
608           { up->cmdqueue[i] = up->cmdqueue[i+1]; }  in arc_event_handler()
620           ENQUEUE(up);  in arc_event_handler()
632           register struct arcunit *up;  in arc_start()  local
705           up = emalloc_zero(sizeof(*up));  in arc_start()
714                     free(up);   in arc_start()
717           pp->unitptr = up;  in arc_start()
747           up->next_resync = current_time + INITIAL_RESYNC_DELAY + (67*unit)%1009;  in arc_start()
750           up->resyncing = 0;              /* Not resyncing yet. */  in arc_start()
751           up->saved_flags = 0;            /* Default is all flags off. */  in arc_start()
755                     for(i = CMDQUEUELEN; i >= 0; --i) { up->cmdqueue[i] = '\0'; }  in arc_start()
760           up->quality = QUALITY_UNKNOWN;  /* Trust the clock immediately. */  in arc_start()
762           up->quality = MIN_CLOCK_QUALITY;/* Don't trust the clock yet. */  in arc_start()
767           ENQUEUE(up);  in arc_start()
782           register struct arcunit *up;  in arc_shutdown()  local
788           up = pp->unitptr;  in arc_shutdown()
791           if (NULL != up)  in arc_shutdown()
792                     free(up);  in arc_shutdown()
800           register struct arcunit *up  in space_left()  argument
807           { if(up->cmdqueue[CMDQUEUELEN - 1 - spaceleft] != '\0') { break; } }  in space_left()
819           register struct arcunit *up,  in send_slow()  argument
825           int spaceleft = space_left(up);  in send_slow()
839           while(*s && spaceleft > 0) { up->cmdqueue[CMDQUEUELEN - spaceleft--] = *s++; }  in send_slow()
878           register struct arcunit *up;  in arc_receive()  local
893           up = pp->unitptr;  in arc_receive()
900           if((up->resyncing) && (space_left(up) == CMDQUEUELEN)) {  in arc_receive()
904                     send_slow(up, pp->io.fd, "g\r");  in arc_receive()
1003                     if(L_ISZERO(&(up->lastrec)) ||  in arc_receive()
1004                        L_ISGEQ(&(up->lastrec), &timestamp))  in arc_receive()
1011                                         if(!L_ISZERO(&(up->lastrec))) {  in arc_receive()
1013                                                   diff = up->lastrec;  in arc_receive()
1021                               up->lastrec = timestamp;  in arc_receive()
1055                               L_CLR(&(up->lastrec));  in arc_receive()
1079                               if (up->quality_stamp < current_time) {  in arc_receive()
1085                                         up->quality_stamp =   in arc_receive()
1096                     } else if( /* (r == '2') && */ up->resyncing) {  in arc_receive()
1097                               up->quality = quality_average;  in arc_receive()
1102                                                up->quality,  in arc_receive()
1103                                                quality_action(up->quality));  in arc_receive()
1108                                         up->quality,  in arc_receive()
1109                                         quality_action(up->quality));  in arc_receive()
1110                               up->resyncing = 0; /* Resync is over. */  in arc_receive()
1117                               if((up->quality == QUALITY_UNKNOWN) ||  in arc_receive()
1118                                  (up->quality < MIN_CLOCK_QUALITY_OK))  in arc_receive()
1119                               { up->next_resync = current_time + RETRY_RESYNC_TIME; }  in arc_receive()
1143           if(L_ISZERO(&(up->lastrec))) {  in arc_receive()
1157           pp->a_lastcode[pp->lencode] = ((up->quality == QUALITY_UNKNOWN) ?  in arc_receive()
1158                                                '6' : ('0' + up->quality));  in arc_receive()
1254                     if(status != up->status)  in arc_receive()
1257                     if(status != up->status) {  in arc_receive()
1260                               up->status = status;  in arc_receive()
1266           up->status = status;  in arc_receive()
1395                     if(up->quality == QUALITY_UNKNOWN) {   in arc_receive()
1405                     } else if (up->quality == QUALITY_UNKNOWN) {  in arc_receive()
1414           if(up->saved_flags != pp->sloppyclockflag) {  in arc_receive()
1426                     up->saved_flags = pp->sloppyclockflag;  in arc_receive()
1430           pp->lastrec = up->lastrec;  in arc_receive()
1470           register struct arcunit *up = pp->unitptr;  in request_time()  local
1474           if (!send_slow(up, pp->io.fd, "o\r")) {  in request_time()
1496           register struct arcunit *up;  in arc_poll()  local
1501           up = pp->unitptr;  in arc_poll()
1514                                 (up->next_resync <= current_time) );  in arc_poll()
1535              (!up->resyncing)) {          /* No resync in progress yet. */  in arc_poll()
1547                     up->quality = QUALITY_UNKNOWN;  in arc_poll()
1550                     up->resyncing = 1;  in arc_poll()
1557                     send_slow(up, pp->io.fd, "h\r");  in arc_poll()
1560                     up->next_resync = current_time + DEFAULT_RESYNC_TIME;  in arc_poll()
1572                     (up->quality != QUALITY_UNKNOWN) &&  in arc_poll()
1574                     (up->quality == QUALITY_UNKNOWN) ||  in arc_poll()
1576                     (up->quality < MIN_CLOCK_QUALITY_OK)) {  in arc_poll()
1579                               printf("arc: clock quality %d too poor.\n", up->quality);  in arc_poll()