Mercurial > hg > Members > menikon > CbC_xv6

annotate src/impl/file_impl_pipe.cbc @ 184:8c39a36878b1

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix_include_context_file_at_file_impl
author anatofuz
date Mon, 20 Jan 2020 17:45:25 +0900
parents 2842d9e65751
children 00e5213ebabe
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
184
8c39a36878b1 fix_include_context_file_at_file_impl
anatofuz
parents: 179
diff changeset
1 #include "../../context.h"
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
2 #interface "file.h"
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
3
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
4 // ----
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
5 // typedef struct pipe<Impl, Isa> impl file {
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
6 // #define PIPESIZE 512
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
7 // struct spinlock lock;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
8 // char data[PIPESIZE];
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
9 // uint nread; // number of bytes read
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
10 // uint nwrite; // number of bytes written
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
11 // int readopen; // read fd is still open
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
12 // int writeopen; // write fd is still open
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
13 // } pipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
14 // ----
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
15
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
16 file* createpipe(struct Context* cbc_context) {
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
17 struct file* file = new file();
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
18 struct pipe* pipe = new pipe();
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
19 file->file = (union Data*)pipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
20 pipe->lock = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
21 pipe->spinlock = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
22 pipe->data = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
23 pipe->nread = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
24 pipe->nwrite = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
25 pipe->readopen = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
26 pipe->writeopen = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
27 file->off = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
28 file->st = NULL;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
29 file->addr = NULL;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
30 file->n = 0;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
31 file->stat = C_statpipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
32 file->read = C_readpipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
33 file->write = C_writepipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
34 file->close = C_closepipe;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
35 return file;
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
36 }
179
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
37 //Skip: generate_context
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
38 __code statpipe(struct pipe* file, struct stat* st, __code next(...)) { //:skip
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
39
170
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
40 goto next(...);
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
41 }
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
42
165
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
43 __code readpipe(struct pipe* file, char* addr, int n, __code next(...)) {
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
44 acquire(&p->lock);
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
45 goto cbc_piperead1(file,addr,n,next);
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
46 }
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
47
165
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
48 __code piperead1(struct pipe* p, char* addr, int n, __code next(...)) {
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
49 if (p->nread == p->nwrite && p->writeopen){
177
anatofuz
parents: 176
diff changeset
50 goto cbc_piperead2(p,addr,n,next);
165
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
51 }
21e83548d738 def file_impl_pipe.cbc private code gears
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 164
diff changeset
52 n = 0;
177
anatofuz
parents: 176
diff changeset
53 goto cbc_piperead3(p,addr,n,next);
anatofuz
parents: 176
diff changeset
54 }
anatofuz
parents: 176
diff changeset
55
anatofuz
parents: 176
diff changeset
56 __code piperead2(struct pipe* p, char* addr, int n, __code next(...)) {
anatofuz
parents: 176
diff changeset
57 if(proc->killed){
anatofuz
parents: 176
diff changeset
58 release(&p->lock);
anatofuz
parents: 176
diff changeset
59 goto cbc_context->error();
anatofuz
parents: 176
diff changeset
60 }
anatofuz
parents: 176
diff changeset
61 goto cbc_sleep(p,&p->nread, &p->lock, next,cbc_piperead1);
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
62 }
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
63
179
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
64
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
65 //Skip: generate_context
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
66 __code cbc_sleep(struct pipe* p, unit* nread, struct spinlock* lock, __code next(...), __code pread(...)){ //:skip
166
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
67 if(proc == 0) {
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
68 goto cbc_context->panic("sleep");
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
69 }
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
70
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
71 if(lk == 0) {
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
72 goto cbc_context->panic("sleep without lk");
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
73 }
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
74
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
75 if(lk != &ptable.lock){ //DOC: sleeplock0
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
76 acquire(&ptable.lock); //DOC: sleeplock1
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
77 release(lk);
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
78 }
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
79 goto cbc_sched(cbc_sleep1);
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
80 }
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
81
179
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
82 //Skip: generate_context
2842d9e65751 fix_skip_codegear
anatofuz
parents: 177
diff changeset
83 __code cbc_sched_stub(struct pipe* p, unit* nread, struct spinlock* lock, __code next(...), __code pread(...)){ //:skip
166
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
84 proc->chan = chan;
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
85 proc->state = SLEEPING;
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
86 proc->lk = lk;
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
87 proc->cbc_next = next1;
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
88 }
a70c436936e4 impl cbc_sleep
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 165
diff changeset
89
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
90 __code writepipe(struct pipe* file, char* addr, int n, __code next(...)) {
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
91
176
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
92 goto next(...);
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
93 }
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
94
169
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 166
diff changeset
95 __code closepipe(struct pipe* file,int fd,__code next(...)) {
170
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
96 proc->ofile[fd] = 0;
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
97 goto cbc_fileclose(f,next);
164
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
98 }
9c501dca25e3 add file_impl_pipe.cbc
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents:
diff changeset
99
169
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 166
diff changeset
100
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 166
diff changeset
101 __code cbc_fileclose(struct file* file, __code next(...)) {
170
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
102 struct file ff;
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
103 acquire(*ftable.loc)
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
104
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
105 if (f->ref < 1) {
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
106 goto cbc_context->kernel_error->panic("file close");
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
107 }
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
108 goto cbc_fileclose2(f,ff,next);
169
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 166
diff changeset
109 }
170
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
110
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
111 __code cbc_fileclose2(struct file* file, struct file* ff,__code next(...)) {
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
112 if (--f->ref > 0) {
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
113 release(&ftable.lock);
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
114 goto cbc_context->return();
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
115 }
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
116 goto cbc_fileclose3(f,ff,next);
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
117 }
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
118
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
119 __code cbc_fileclose3(struct file* file, struct file* ff,__code next(...)) {
176
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
120 *ff = *f;
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
121 f->ref = 0;
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
122 f->type = FD_NONE;
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
123 relsease(&ftable.lock);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
124
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
125 goto cbc_pipe_close(ff.pipe,ff.writable,next);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
126 }
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
127
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
128 __code cbc_pipe_close(struct pipe* p, int writable, __code next(...)) {
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
129 acquire(&p->lock);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
130 if (writable) {
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
131 goto cbc_pipe_close_writeopen(p,next);
170
anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp>
parents: 169
diff changeset
132 }
176
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
133 goto cbc_pipe_close_readopen(p,next);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
134 }
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
135
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
136
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
137 __code cbc_pipe_close_writeopen(struct pipe* p, __code next(...)) {
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
138 p->writeopen = 0;
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
139 goto cbc_wakeup(&p->nread,p,cbc_pipe_release,next);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
140 }
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
141
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
142 __code cbc_pipe_close_readopen(struct pipe* p, __code next(...)) {
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
143 p->writeopen = 0;
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
144 goto cbc_->wakeup(&p->nwrite,p,cbc_pipe_release,next);
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
145 }
da4c83ae7ada impl_close_pipe
anatofuz
parents: 170
diff changeset
146