Return to remote.c CVS log

Up to [Research Unix] / researchv9 / jtools / src / pads / host

Annotation of researchv9/jtools/src/pads/host/remote.c, revision 1.1.1.1

1.1       root        1: #include <pads.pri>
                      2: #include <CC/sys/types.h>
                      3: #include <sgtty.h>
                      4: 
                      5: void Remote::checkproto(int p)         { if( get()!=p ) err();                 }
                      6: void Remote::put(char c)               { writebuffer[pktbase + pktsize++] = c; }
                      7: void Remote::proto(int p)              { put( p ); }
                      8: 
                      9: long Remote::rcvlong()                 { return (long)  shiftin( P_LONG  );    }
                     10: short Remote::rcvshort()               { return (short) shiftin( P_SHORT );    }
                     11: unsigned char Remote::rcvuchar()       { return (unsigned char) shiftin(P_UCHAR); }
                     12: 
                     13: void Remote::sendlong(long  x)         { shiftout( P_LONG, x );         }
                     14: void Remote::sendshort(short x)                { shiftout( P_SHORT, (long) x ); }
                     15: void Remote::senduchar(unsigned char x)        { shiftout( P_UCHAR, (long) x ); }
                     16: 
                     17: void Remote::pktstart(char c)          { if( pktsize ) err(); put(c);  }
                     18: void Remote::pktflush()                        { writesize = 0; pktend();      }
                     19: 
                     20: #define ADDRBITS  24
                     21: #define ALIGNBITS 2
                     22: #define OIDBITS   (32-(ADDRBITS-ALIGNBITS))
                     23: #define MASK(n)         ((1<<n)-1)
                     24: void Remote::sendobj(PadRcv *o)
                     25: {
                     26:        if( !o ){
                     27:                sendlong(0);
                     28:                return;
                     29:        }
                     30:        long l = (long) o;
                     31:        if( l & (~MASK(ADDRBITS)^MASK(ALIGNBITS)) ) abort();
                     32:        sendlong( (l<<(OIDBITS-ALIGNBITS)) | (o->oid&MASK(OIDBITS)) );
                     33: }
                     34: 
                     35: PadRcv *Remote::rcvobj()
                     36: {
                     37:        register long o = rcvlong(), a;
                     38:        a = o >> (OIDBITS-ALIGNBITS);
                     39:        a &= MASK(ADDRBITS)&~MASK(ALIGNBITS);
                     40:        PadRcv *obj = (PadRcv*) a;
                     41:        if( obj && (obj->oid&MASK(OIDBITS)) != (o&MASK(OIDBITS)) )
                     42:                obj = 0;
                     43:        return obj;
                     44: }
                     45: 
                     46: void Remote::err(char *e)
                     47: {
                     48:        if( !e ) e = "host/term protocol error";
                     49:        write(fd, e, strlen(e));
                     50: }
                     51: 
                     52: Remote::Remote(int opened)
                     53: {
                     54:        fd = opened;
                     55:        pktsize = writesize = pktbase = 0;
                     56: }
                     57: 
                     58: Remote::Remote(char *dev)
                     59: {
                     60:        struct sgttyb tty;
                     61: 
                     62:        fd = open(dev, 2);
                     63:        pktsize = writesize = pktbase = 0;
                     64: 
                     65:        trace( "%d.Remote(%d,%d)", this, in, out );
                     66:        if( ioctl(fd, TIOCGETP, &tty) ) err("tty ioctl: GETP failed");
                     67:        tty.sg_flags = (tty.sg_flags|CBREAK|RAW) & ~ECHO;
                     68:        if( ioctl(fd, TIOCSETP, &tty) ) err("tty ioctl: SETP failed");
                     69:        trace( "sg_flags=0x%X", tty.sg_flags );
                     70:        if( ioctl(fd, TIOCEXCL, 0)  ) err("tty ioctl: EXCL failed");
                     71: }
                     72: 
                     73: void Remote::share()
                     74: {
                     75:        trace( "%d.share()", this, );
                     76:        if( ioctl(fd, TIOCNXCL, 0)  ) err("tty ioctl: NXCL failed");
                     77: }      
                     78: 
                     79: long Remote::shiftin(register int bytes)
                     80: {
                     81:        register long shifter = 0;
                     82: 
                     83:        checkproto( bytes );
                     84:        while( bytes-- ) shifter = (shifter<<8) + (get()&0xFF);
                     85:        return shifter;
                     86: }
                     87: 
                     88: void Remote::shiftout( register bytes, register long shifter )
                     89: {
                     90:        proto( bytes );
                     91:        do { put( (char)(shifter>>( (--bytes)*8 )) ); } while( bytes );
                     92: }
                     93: 
                     94: long BytesToTerm;
                     95: void Remote::pktend()
                     96: {
                     97:        if( pktsize<=0 ) err();
                     98:        pktbase += pktsize;
                     99:        if( pktbase > writesize ){
                    100:                if( write(fd, (char*)writebuffer, pktbase) != pktbase ) abort();
                    101:                BytesToTerm += pktbase;
                    102:                pktbase = 0;
                    103:                writesize = 768;
                    104:        }
                    105:        pktsize = 0;
                    106: }
                    107: 
                    108: char *Remote::rcvstring( char *s0 )
                    109: {
                    110:        register char *s = s0;
                    111:        register unsigned char len;
                    112: 
                    113:        checkproto( P_STRING );
                    114:        len = rcvuchar();
                    115:        if( !s0 ) s = s0 = new char [len+1];
                    116:        while( len-->0 ) *s++ = get();
                    117:        *s = '\0';
                    118:        return s0;
                    119: }
                    120: 
                    121: void Remote::sendstring(register char *s)
                    122: {
                    123:        int len;
                    124: 
                    125:        proto( P_STRING );
                    126:        len =  strlen(s);
                    127:        if( len > 255 ) len = 255;
                    128:        senduchar( len );
                    129:        while( len-- ) put(*s++); 
                    130: }
                    131: 
                    132: long BytesFromTerm;
                    133: int Remote::get()
                    134: {
                    135:        char c;
                    136:        if( pktsize!=0 || read(fd, &c, 1)!=1 ) err();
                    137:        ++BytesFromTerm;
                    138:        return c;
                    139: }

This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.