#include <u.h>#include <libc.h>#include <auth.h>#include <fcall.h>#include "../boot/boot.h" static Fcall hdr; static voidrpc(int fd, int type){ int n, l; char buf[128], *p; hdr.type = type; hdr.tag = NOTAG; n = convS2M(&hdr, buf); if(write(fd, buf, n) != n) fatal("write rpc"); print("..."); p = buf; l = 0; while(l < 3) { n = read(fd, p, 3); if(n <= 0) fatal("read rpc"); if(n == 2 && l == 0 && buf[0] == 'O' && buf[1] == 'K') continue; p += n; l += n; } if(convM2S(buf, &hdr, n) == 0){ print("%ux %ux %ux\n", buf[0], buf[1], buf[2]); fatal("rpc format"); } if(hdr.tag != NOTAG) fatal("rpc tag not NOTAG"); if(hdr.type == Rerror){ print("error %s;", hdr.ename); fatal("remote error"); } if(hdr.type != type+1) fatal("not reply");} voidnop(int fd){ print("nop"); rpc(fd, Tnop);}
#include <u.h>
#include <libc.h>
#include <auth.h>
#include <fcall.h>
#include "../boot/boot.h"
static Fcall hdr;
static void
rpc(int fd, int type)
{
int n, l;
char buf[128], *p;
hdr.type = type;
hdr.tag = NOTAG;
n = convS2M(&hdr, buf);
if(write(fd, buf, n) != n)
fatal("write rpc");
print("...");
p = buf;
l = 0;
while(l < 3) {
n = read(fd, p, 3);
if(n <= 0)
fatal("read rpc");
if(n == 2 && l == 0 && buf[0] == 'O' && buf[1] == 'K')
continue;
p += n;
l += n;
}
if(convM2S(buf, &hdr, n) == 0){
print("%ux %ux %ux\n", buf[0], buf[1], buf[2]);
fatal("rpc format");
}
if(hdr.tag != NOTAG)
fatal("rpc tag not NOTAG");
if(hdr.type == Rerror){
print("error %s;", hdr.ename);
fatal("remote error");
}
if(hdr.type != type+1)
fatal("not reply");
}
void
nop(int fd)
{
print("nop");
rpc(fd, Tnop);
}