else
rep->msize = req->msize;
rep->version = "9P2000";
+ if(strncmp(req->version, "9P", 2) != 0)
+ rep->version = "unknown";
}
void
return respond(x, &t, "version: message size too small");
messagesize = x->msize;
t.msize = messagesize;
- if(strncmp(x->version, "9P2000", 6) != 0)
- return respond(x, &t, "unrecognized 9P version");
t.version = "9P2000";
+ if(strncmp(x->version, "9P", 2) != 0)
+ t.version = "unknown";
return respond(x, &t, nil);
}
else
thdr.msize = rhdr.msize;
messagesize = thdr.msize;
- if(strncmp(rhdr.version, "9P2000", 6) != 0)
- return "bad 9P version";
thdr.version = "9P2000";
+ if(strncmp(rhdr.version, "9P", 2) != 0)
+ thdr.version = "unknown";
return 0;
}
}
if(n == 0)
print("server eof\n");
- else
+ else if(n == -1)
print("read9pmsg from server: %r\n");
}
if(messagesize > 8192+IOHDRSZ)
messagesize = 8192+IOHDRSZ;
r->f.msize = messagesize;
- if(strncmp(r->f.version, "9P2000", 6) != 0){
- fsreply(fs, r, "unrecognized 9P version");
- return;
- }
- r->f.version = "9P2000";
-
+ if(strncmp(r->f.version, "9P", 2) != 0)
+ r->f.version = "unknown";
+ else
+ r->f.version = "9P2000";
fsreply(fs, r, nil);
}
if(messagesize > r->f.msize)
messagesize = r->f.msize;
r->f.msize = messagesize;
- r->f.version = "9P2000";
+ if(strncmp(r->f.version, "9P", 2) != 0)
+ r->f.version = "unknown";
+ else
+ r->f.version = "9P2000";
fsreply(fs, r, nil);
}
if(rpc->msize > messagesize)
rpc->msize = messagesize;
messagesize = rpc->msize;
- if(strncmp(rpc->version, "9P2000", 6) != 0)
- return "unrecognized 9P version";
- rpc->version = "9P2000";
+ if(strncmp(rpc->version, "9P", 2) != 0)
+ rpc->version = "unknown";
+ else
+ rpc->version = "9P2000";
return nil;
}
char Eisopen[] = "file already open for I/O";
char Excl[] = "exclusive use file already open";
char Ename[] = "illegal name";
-char Eversion[] = "unknown 9P version";
int debug;
else
rhdr.msize = thdr.msize;
messagesize = rhdr.msize;
- if(strncmp(thdr.version, "9P2000", 6) != 0)
- return Eversion;
rhdr.version = "9P2000";
+ if(strncmp(thdr.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
return 0;
}
else
rep->msize = req->msize;
rep->version = "9P2000";
+ if(strncmp(req->version, "9P", 2) != 0)
+ rep->version = "unknown";
}
void
char Emip[] = "Mount in progress";
char Enopsmt[] = "Out of pseudo mount points";
char Enomem[] = "No memory";
-char Eversion[] = "Bad 9P2000 version";
char Ereadonly[] = "File system read only";
char Enoprocs[] = "Out of processes";
if(t->work.msize > messagesize)
t->work.msize = messagesize;
messagesize = t->work.msize;
- if(strncmp(t->work.version, "9P2000", 6) != 0){
- reply(&t->work, &rhdr, Eversion);
- putsbuf(t);
- return;
- }
- rhdr.version = "9P2000";
rhdr.msize = t->work.msize;
+ rhdr.version = "9P2000";
+ if(strncmp(t->work.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
reply(&t->work, &rhdr, 0);
putsbuf(t);
}
rhdr.msize = thdr.msize;
messagesize = rhdr.msize;
- if(strncmp(thdr.version, "9P2000", 6) != 0)
- return "unknown 9P version";
rhdr.version = "9P2000";
+ if(strncmp(thdr.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
return nil;
}
char Eisopen[] = "file already open for I/O";
char Excl[] = "exclusive use file already open";
char Ename[] = "illegal name";
-char Eversion[] = "unknown 9P version";
void
usage(void)
else
rhdr.msize = thdr.msize;
messagesize = rhdr.msize;
- if(strncmp(thdr.version, "9P2000", 6) != 0)
- return Eversion;
rhdr.version = "9P2000";
+ if(strncmp(thdr.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
return nil;
}
job->reply.msize = IOHDRSZ + Maxfdata;
else
job->reply.msize = job->request.msize;
- if(strncmp(job->request.version, "9P2000", 6) != 0)
- sendmsg(job, "unknown 9P version");
- else{
- job->reply.version = "9P2000";
- sendmsg(job, nil);
- }
+ job->reply.version = "9P2000";
+ if(strncmp(job->request.version, "9P", 2) != 0)
+ job->reply.version = "unknown";
+ sendmsg(job, nil);
}
void
job->reply.msize = IOHDRSZ + Maxfdata;
else
job->reply.msize = job->request.msize;
- if(strncmp(job->request.version, "9P2000", 6) != 0)
- sendmsg(job, "unknown 9P version");
- else{
- job->reply.version = "9P2000";
- sendmsg(job, 0);
- }
+ job->reply.version = "9P2000";
+ if(strncmp(job->request.version, "9P", 2) != 0)
+ job->reply.version = "unknown";
+ sendmsg(job, nil);
}
void
char Ename[] = "illegal name";
char Erdonly[] = "read only file system";
char Ebadblock[] = "bad block";
-char Eversion[] = "bad version of P9";
char Edirtoobig[] = "directory entry too big";
int debug;
thdr.msize = mesgsize;
else
thdr.msize = rhdr.msize;
- if(strcmp(rhdr.version, "9P2000") != 0)
- return Eversion;
thdr.version = "9P2000";
+ if(strncmp(rhdr.version, "9P", 2) != 0)
+ thdr.version = "unknown";
return 0;
}
if(t->msize < messagesize)
messagesize = t->msize;
t->msize = messagesize;
- if(strncmp(t->version, "9P2000", 6) != 0){
- fsysrespond(t, buf, "unrecognized 9P version");
- return t;
- }
- t->version = "9P2000";
+ if(strncmp(t->version, "9P", 2) != 0)
+ t->version = "unknown";
+ else
+ t->version = "9P2000";
fsysrespond(t, buf, nil);
return t;
}
static void
rversion(Fcall *f)
{
- f->version = "9P2000";
+ if(f->msize < 256){
+ reply(f, "version: message size too small");
+ return;
+ }
if(f->msize > MAXRPC)
f->msize = MAXRPC;
+ if(strncmp(f->version, "9P", 2) != 0)
+ f->version = "unknown";
+ else
+ f->version = "9P2000";
reply(f, 0);
}
return filsysrespond(x->fs, x, &t, "version: message size too small");
messagesize = x->msize;
t.msize = messagesize;
- if(strncmp(x->version, "9P2000", 6) != 0)
- return filsysrespond(x->fs, x, &t, "unrecognized 9P version");
t.version = "9P2000";
+ if(strncmp(x->version, "9P", 2) != 0)
+ t.version = "unknown";
return filsysrespond(fs, x, &t, nil);
}
else
messagesize = rhdr.msize;
thdr.msize = messagesize;
- if(strncmp(rhdr.version, "9P2000", 6) != 0)
- return "unrecognized 9P version";
thdr.version = "9P2000";
+ if(strncmp(rhdr.version, "9P", 2) != 0)
+ thdr.version = "unknown";
for(f = fids; f; f = f->next)
if(f->busy)
if(messagesize > sizeof mdata)
messagesize = sizeof mdata;
rhdr.msize = messagesize;
- if(strncmp(thdr.version, "9P2000", 6) != 0)
- return "unrecognized 9P version";
rhdr.version = "9P2000";
+ if(strncmp(thdr.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
return 0;
}
if(thdr.msize < messagesize)
messagesize = thdr.msize;
rhdr.msize = messagesize;
- if(strncmp(thdr.version, "9P2000", 6) != 0)
- return "unknown 9P version";
- else
- rhdr.version = "9P2000";
+ rhdr.version = "9P2000";
+ if(strncmp(thdr.version, "9P", 2) != 0)
+ rhdr.version = "unknown";
+
for(f = fids; f; f = f->next)
if(f->busy)
rclunk(f);
if(messagesize > sizeof mdata)
messagesize = sizeof mdata;
thdr.msize = messagesize;
- if(strncmp(rhdr.version, "9P2000", 6) != 0)
- return vtstrdup("unrecognized 9P version");
- thdr.version = "9P2000";
+ if(strncmp(rhdr.version, "9P", 2) != 0)
+ thdr.version = "unknown";
if(strncmp(rhdr.version, "9P2000.u", 8) == 0){
dotu = 1;
thdr.version = "9P2000.u";
- }
+ }else
+ thdr.version = "9P2000";
return nil;
}