console.c 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319
  1. /*
  2. * This file is part of the UCB release of Plan 9. It is subject to the license
  3. * terms in the LICENSE file found in the top-level directory of this
  4. * distribution and at http://akaros.cs.berkeley.edu/files/Plan9License. No
  5. * part of the UCB release of Plan 9, including this file, may be copied,
  6. * modified, propagated, or distributed except according to the terms contained
  7. * in the LICENSE file.
  8. */
  9. #include "all.h"
  10. #include "9p1.h"
  11. void
  12. fcall9p1(Chan *cp, Fcall *in, Fcall *ou)
  13. {
  14. int t;
  15. rlock(&mainlock);
  16. t = in->type;
  17. if(t < 0 || t >= MAXSYSCALL || (t&1) || !call9p1[t]) {
  18. print("bad message type %d\n", t);
  19. panic("");
  20. }
  21. ou->type = t+1;
  22. ou->err = 0;
  23. rlock(&cp->reflock);
  24. (*call9p1[t])(cp, in, ou);
  25. runlock(&cp->reflock);
  26. if(ou->err && CHAT(cp))
  27. print("\terror: %s\n", errstr9p[ou->err]);
  28. runlock(&mainlock);
  29. }
  30. int
  31. con_session(void)
  32. {
  33. Fcall in, ou;
  34. in.type = Tsession;
  35. fcall9p1(cons.chan, &in, &ou);
  36. return ou.err;
  37. }
  38. int
  39. con_attach(int fid, char *uid, char *arg)
  40. {
  41. Fcall in, ou;
  42. in.type = Tattach;
  43. in.fid = fid;
  44. strncpy(in.uname, uid, NAMELEN);
  45. strncpy(in.aname, arg, NAMELEN);
  46. fcall9p1(cons.chan, &in, &ou);
  47. return ou.err;
  48. }
  49. int
  50. con_clone(int fid1, int fid2)
  51. {
  52. Fcall in, ou;
  53. in.type = Tclone;
  54. in.fid = fid1;
  55. in.newfid = fid2;
  56. fcall9p1(cons.chan, &in, &ou);
  57. return ou.err;
  58. }
  59. int
  60. con_walk(int fid, char *name)
  61. {
  62. Fcall in, ou;
  63. in.type = Twalk;
  64. in.fid = fid;
  65. strncpy(in.name, name, NAMELEN);
  66. fcall9p1(cons.chan, &in, &ou);
  67. return ou.err;
  68. }
  69. int
  70. con_open(int fid, int mode)
  71. {
  72. Fcall in, ou;
  73. in.type = Topen;
  74. in.fid = fid;
  75. in.mode = mode;
  76. fcall9p1(cons.chan, &in, &ou);
  77. return ou.err;
  78. }
  79. int
  80. con_read(int fid, char *data, Off offset, int count)
  81. {
  82. Fcall in, ou;
  83. in.type = Tread;
  84. in.fid = fid;
  85. in.offset = offset;
  86. in.count = count;
  87. ou.data = data;
  88. fcall9p1(cons.chan, &in, &ou);
  89. if(ou.err)
  90. return 0;
  91. return ou.count;
  92. }
  93. int
  94. con_write(int fid, char *data, Off offset, int count)
  95. {
  96. Fcall in, ou;
  97. in.type = Twrite;
  98. in.fid = fid;
  99. in.data = data;
  100. in.offset = offset;
  101. in.count = count;
  102. fcall9p1(cons.chan, &in, &ou);
  103. if(ou.err)
  104. return 0;
  105. return ou.count;
  106. }
  107. int
  108. con_remove(int fid)
  109. {
  110. Fcall in, ou;
  111. in.type = Tremove;
  112. in.fid = fid;
  113. fcall9p1(cons.chan, &in, &ou);
  114. return ou.err;
  115. }
  116. int
  117. con_create(int fid, char *name, int uid, int gid, int32_t perm,
  118. int mode)
  119. {
  120. Fcall in, ou;
  121. in.type = Tcreate;
  122. in.fid = fid;
  123. strncpy(in.name, name, NAMELEN);
  124. in.perm = perm;
  125. in.mode = mode;
  126. cons.uid = uid; /* beyond ugly */
  127. cons.gid = gid;
  128. fcall9p1(cons.chan, &in, &ou);
  129. return ou.err;
  130. }
  131. int
  132. doclri(File *f)
  133. {
  134. Iobuf *p, *p1;
  135. Dentry *d, *d1;
  136. int err;
  137. err = 0;
  138. p = 0;
  139. p1 = 0;
  140. if(f->fs->dev->type == Devro) {
  141. err = Eronly;
  142. goto out;
  143. }
  144. /*
  145. * check on parent directory of file to be deleted
  146. */
  147. if(f->wpath == 0 || f->wpath->addr == f->addr) {
  148. err = Ephase;
  149. goto out;
  150. }
  151. p1 = getbuf(f->fs->dev, f->wpath->addr, Brd);
  152. d1 = getdir(p1, f->wpath->slot);
  153. if(!d1 || checktag(p1, Tdir, QPNONE) || !(d1->mode & DALLOC)) {
  154. err = Ephase;
  155. goto out;
  156. }
  157. accessdir(p1, d1, FWRITE, 0);
  158. putbuf(p1);
  159. p1 = 0;
  160. /*
  161. * check on file to be deleted
  162. */
  163. p = getbuf(f->fs->dev, f->addr, Brd);
  164. d = getdir(p, f->slot);
  165. /*
  166. * do it
  167. */
  168. memset(d, 0, sizeof(Dentry));
  169. settag(p, Tdir, QPNONE);
  170. freewp(f->wpath);
  171. freefp(f);
  172. out:
  173. if(p1)
  174. putbuf(p1);
  175. if(p)
  176. putbuf(p);
  177. return err;
  178. }
  179. void
  180. f_fstat(Chan *cp, Fcall *in, Fcall *ou)
  181. {
  182. File *f;
  183. Iobuf *p;
  184. Dentry *d;
  185. int i;
  186. if(CHAT(cp)) {
  187. print("c_fstat %d\n", cp->chan);
  188. print("\tfid = %d\n", in->fid);
  189. }
  190. p = 0;
  191. f = filep(cp, in->fid, 0);
  192. if(!f) {
  193. ou->err = Efid;
  194. goto out;
  195. }
  196. p = getbuf(f->fs->dev, f->addr, Brd);
  197. d = getdir(p, f->slot);
  198. if(d == 0)
  199. goto out;
  200. print("name = %.*s\n", NAMELEN, d->name);
  201. print("uid = %d; gid = %d; muid = %d\n", d->uid, d->gid, d->muid);
  202. print("size = %lld; qid = %llux/%lx\n", (Wideoff)d->size,
  203. (Wideoff)d->qid.path, d->qid.version);
  204. print("atime = %ld; mtime = %ld\n", d->atime, d->mtime);
  205. print("dblock =");
  206. for(i=0; i<NDBLOCK; i++)
  207. print(" %lld", (Wideoff)d->dblock[i]);
  208. for (i = 0; i < NIBLOCK; i++)
  209. print("; iblocks[%d] = %lld", i, (Wideoff)d->iblocks[i]);
  210. print("\n\n");
  211. out:
  212. if(p)
  213. putbuf(p);
  214. ou->fid = in->fid;
  215. if(f)
  216. qunlock(f);
  217. }
  218. void
  219. f_clri(Chan *cp, Fcall *in, Fcall *ou)
  220. {
  221. File *f;
  222. if(CHAT(cp)) {
  223. print("c_clri %d\n", cp->chan);
  224. print("\tfid = %d\n", in->fid);
  225. }
  226. f = filep(cp, in->fid, 0);
  227. if(!f) {
  228. ou->err = Efid;
  229. goto out;
  230. }
  231. ou->err = doclri(f);
  232. out:
  233. ou->fid = in->fid;
  234. if(f)
  235. qunlock(f);
  236. }
  237. int
  238. con_clri(int fid)
  239. {
  240. Fcall in, ou;
  241. Chan *cp;
  242. in.type = Tremove;
  243. in.fid = fid;
  244. cp = cons.chan;
  245. rlock(&mainlock);
  246. ou.type = Tremove+1;
  247. ou.err = 0;
  248. rlock(&cp->reflock);
  249. f_clri(cp, &in, &ou);
  250. runlock(&cp->reflock);
  251. runlock(&mainlock);
  252. return ou.err;
  253. }
  254. int
  255. con_fstat(int fid)
  256. {
  257. Fcall in, ou;
  258. Chan *cp;
  259. in.type = Tstat;
  260. in.fid = fid;
  261. cp = cons.chan;
  262. rlock(&mainlock);
  263. ou.type = Tstat+1;
  264. ou.err = 0;
  265. rlock(&cp->reflock);
  266. f_fstat(cp, &in, &ou);
  267. runlock(&cp->reflock);
  268. runlock(&mainlock);
  269. return ou.err;
  270. }