13 I/O

Size: px

Start display at page:

Download "13 I/O"

とらふみむこやま
4 years ago
Views:

1 13 I/O

2 Linux OS OS OS I/O I/O TS-I/O I/O I/O TS-I/O TS-I/O

4 Linux OS VxWorks ITRON LynxOS RT-Linux ART-Linux OS TS-I/O TS-I/O TS-I/O read gettbuf ioctl read gettbuf ioctl

5 TS-I/O

6 /dev/dsp

7 6 3.1 OS read gettbuf() Linux TS-I/O

8 7 1 Linux 2 Linux OS OS OS OS Linux OS

9 1 8 Linux I/O I/O TS-I/O (TimeStamp I/O) I/O I/O I/O I/O TS-I/O Linux read_gettbuf() I/O I/O TS-I/O OS TS-I/O 2 OS 3 OS 4 TS-I/O 5 TS-I/O 6

10 9 2 I/O OS 2.1 RAM 2.1 1

11 2 10 record machine buffer play trash 2.1: [10] AD DA D/A

12 2 11 DAC A/D ADC A/D CD CD 44,100 / CD / 44,100 / 2 / 2 = 635MB CD-ROM 640MB Linux UNIX OS open read write

13 2 12 ioctl read write close OS printf scanf read write /dev/dsp 2.2 /dev/dsp DSP A/D A/D A/D read DSP 2.3 2

14 2 13 kernel application read(); kernel buffer application buffer ADC analog data digital samples write(); kernel buffer application buffer DAC analog data digital samples 2.2: /dev/dsp A/D A/D A/D A/D A/D 1 2

15 Linux OS OS Linux Linux UNIX POSIX sched setscheduler [5] SCHED FIFO SCHED RR SCHED FIFO SCHED RR SCHED OTHER SCHED OTHER /* sched_setscheduler(); */ int sched_setscheduler(pid_t pid, int policy, struct sched_param *param); sched setscheduler 2 policy SCHED FIFO SCHED RR Linux 10ms ms s Linux Linux

16 2 15 Linux Linux OS Linux ms s Linux I/O

17 16 3 OS OS OS OS 3.1 [8] [8, 7]

18 3 17 OS(MVS VMS UNIX MacOS Windows Linux ) OS OS VxWorks psos VRTX ITRON Windows CE rate-monotonic(rm) earliest-deadline-first(edf) ms s

19 3 18 Linux Linux Linux 10msec Linux [13] Linux Linux Linux Linux OS 3.2 OS OS OS [6] CPU

20 3 19 OS VxWorks ITRON LynxOS OS RT-Linux ART-Linux VxWorks WindRiver [4] Vxworks Lab UNIX OS OS VxWorks UNIX LAN UNIX ROM OS TCP/IP API UNIX VxWorks Tornado Tornado Vxworks OS Windows Linux OS OS 1 1 Vxworks

21 ITRON ITRON[2] OS ITRON OS ITRON OS ITRON ITRON1 ITRON4 ITRON 8 32 RISC ITRON TCP/IP API ITRON TCP/IP API Java JTRON2.0 ITRON Vxworks OS LynxOS OS OS LynxOS LynxOS LynuxWorks[3] OS UNIX OS LynxOS

22 3 21 LynxOS UNIX LynxOS LynxOS OS LynxOS OS Windows OS OS Linux OS OS Linux 2 Linux RT-Linux RT-Linux[1] OS Linux OS RT-Linux Linux Linux Linux Linux RT-FIFO

23 3 22 Linux Linux Linux Linux RT-Linux VxWorks Linux Linux RT- FIFO Linux RT-FIFO [14, 8] RT-Linux RT-Linux ART-Linux RT-Linux Linux ART-Linux[12, 13, 11] ART-Linux Linux OS ART-Linux Linux ART-Linux ART-Linux

24 3 23 ART-Linux ART-Linux ART-Linux ART-Linux ART-Linux ART-Linux Linux ART-Linux ART-Linux ART-Linux CPU 3.3 OS OS OS 3.1 VxWorks ITRON OS

25 3 24 OS VxWorks ITRON LynxOS RT-Linux ART-Linux 3.1: OS LynxOS OS RT-Linux Linux OS RT-Linux Linux ART-Linux RT-Linux Linux OS OS RT-Linux ART-Linux RT-Linux ART-Linux OS [2] RT-Linux

26 3 25 RT-Linux RT-Linux ART-Linux OS OS OS OS

27 26 4 TS-I/O TS-I/O(TimeStamp I/O) OS I/O I/O TS-I/O 4.1 OS I/O I/O

28 4 TS-I/O TS-I/O TS-I/O TS-I/O Linux I/O TS-I/O 3 I/O I/O I/O Linux TS-I/O I/O TS-I/O I/O OS OS OS

29 4 TS-I/O 28 I/O I/O I/O OS I/O 4.3 TS-I/O TS-I/O read_gettbuf ioctl SNDCTL_DSP_EMPTYSET read gettbuf TS-I/O ioctl SNDCTL DSP EMPTYSET read gettbuf read gettbuf read gettbuf read read /* read_gettbuf(); */ ssize_t read_gettbuf(unsigned int fd, char *buf, struct tftbuf *fromtobuf, size_t count, int *pnt); /* read(); */ ssize_t read(unsigned int fd, char *buf, size_t count); read gettbuf read fromtobuf pnt fromtobuf 2 struct tftbuf

30 4 TS-I/O 29 /* * include/linux/tftbuf.h */ struct tftbuf { unsigned long from; unsigned long to; }; from to read gettbuf() fromtobuf - - read gettbuf() read gettbuf()

31 4 TS-I/O 30 Beffor record miss!! kernel buffer play application buffer After record miss!! kernel buffer play application buffer o o o o empty data 4.1:

32 4 TS-I/O 31 read gettbuf() <linux/read gettbuf.h> ioctl SNDCTL DSP EMPTYSET unsigned long arg = 10000; ioctl(fd, SNDCTL\_DSP\_EMPTYSET, &arg); = OS linux linux/drivers/sound/es1371.c I/O linux-2.4 es1371.c 1 read fs/read write.c sys read() es1371.c es1371 read() es1371.c open() write() ioctl() close() es1371 open() es1371 write() es1371 ioctl() es1371 release()

33 4 TS-I/O 32 es1371 read() es1371 read() /* es1371_read(); */ static ssize_t es1371_read(struct file *file, char *buffer, size_t count, loff_t *ppos) { struct es1371_state *s = (struct es1371_state *)file->private_data; unsigned swptr; int cnt;... while (count > 0) {... cnt =... /* * * */... if (cnt <= 0) {... schedule(); /* */... } /* * * buffer s->dma_adc.rawbuf + swptr * cnt */ if (copy_to_user(buffer, s->dma_adc.rawbuf + swptr, cnt)) {... }... count -= cnt; buffer += cnt;... }... } es1371 read() cnt schedule() schedule()

34 4 TS-I/O 33 CPU schedule() CPU CPU I/O es1371 interrupt() I/O es1371 interrupt() I/O I/O /* * linux/drivers/sound/es1371.c */ /* void es1371_interrupt(); */ static void es1371_interrupt(int irq, void *dev_id, struct pt_regs *regs) { struct es1371_state *s = (struct es1371_state *)dev_id;... es1371_update_ptr(s);... } /* es1371_update_ptr(); */ static void es1371_update_ptr(struct es1371_state *s) { int diff; /* update ADC pointer */ if (s->ctrl & CTRL_ADC_EN) { diff = get_hwptr(s, &s->dma_adc, ES1371_REG_ADC_FRAMECNT); s->dma_adc.total_bytes += diff; s->dma_adc.count += diff; /* */... } /* update DAC1 pointer */

35 4 TS-I/O 34 if (s->ctrl & CTRL_DAC1_EN) {... } /* update DAC2 pointer */ if (s->ctrl & CTRL_DAC2_EN) {... } } /* * get_hwptr(); * I/O */ extern inline unsigned get_hwptr(struct es1371_state *s, struct dmabuf *db, unsigned reg) { unsigned hwptr, diff; } outl((reg >> 8) & 15, s->io+es1371_reg_mempage); hwptr = (inl(s->io+(reg & 0xff)) >> 14) & 0x3fffc; diff = (db->dmasize + hwptr - db->hwptr) % db->dmasize; db->hwptr = hwptr; return diff; es1371 interrupt() es1371 update ptr() es1371 update ptr() get hwptr() s->dma adc.count es1371 read() test timer() /* * test_timer(); */ unsigned long long test_timer() { struct timeval tv; do_gettimeofday(&tv); return (unsigned long long)(tv.tv_sec)* tv.tv_usec;

36 4 TS-I/O 35 } test timer() gettimeofday do gettimeofday() gettimeofday UNIX UNIX UNIX UNIX es1371.c es1371 interrupt() test timer() test timer() 0 I/O I/O I/O 4.2 I/O Line1 Line2 48,000Hz 16bit 3 3 3sec 48,000sample/sec 16bit/sample 8bit/byte 2channel = 576,000byte

37 4 TS-I/O 36 (bit) Line Line sec 2sec 3sec 3.5sec 4.2: 5,333 sec 5,333 sec 1,024byte Line1 Line2 Line2 100,000 sec Line2 3 3 I/O I/O /* * linux/drivers/sound/es1371.c */ <linux/timefromtofile.h> static void es1371_update_ptr(struct es1371_state *s)

38 4 TS-I/O 37 { int diff; unsigned rate, size, channels; /* update ADC pointer */ if (s->ctrl & CTRL_ADC_EN) { /* * * s->dma_adc.timestart es1371_read() */ s->dma_adc.timeofnow = (unsigned long) (test_timer() - s->dma_adc.timestart); diff = get_hwptr(s, &s->dma_adc, ES1371_REG_ADC_FRAMECNT);... /* * read_gettbuf() * s->settimestamp es1371_gettbuf() */ if(s->settimestamp > 0){ rate = s->adcrate; /* sample rate */ size = s->adcsize; /* sample size */ channels = s->adcchannels; /* sample channels */ /* * * * sec= sec/sec bit/byte /channels sec/ channels * byte /bit */ difftime = * 8 / size / channels * diff / rate; /* * * s->time_interval es1371_ioctl() SNDCTL_DSP_EMPTYSET * */ if((s->dma_adc.timeofnow - s->dma_adc.timeofprev) >= s->time_interval + difftime){ /* */ timefromtobuf[s->dma_adc.timefromtocnt].from = s->dma_adc.timeofprev; /* */ timefromtobuf[s->dma_adc.timefromtocnt].to = s->dma_adc.timeofnow - difftime; /* * * * */ s->dma_adc.empty_sounddata[s->dma_adc.empty_sound_number] = rate*size*channels/8/1000

39 4 TS-I/O 38 } *(timefromtobuf[s->dma_adc.timefromtocnt].to - timefromtobuf[s->dma_adc.timefromtocnt].from)/1000;... s->dma_adc.timefromtocnt ++; s->dma_adc.empty_sound_number ++; } } s->dma_adc.timeofprev = s->dma_adc.timeofnow; /* I/O */ s->dma_adc.sounddata[s->dma_adc.empty_sound_number] += diff;... }... test timer() read gettbuf() s->settimestamp difftime I/O diff s->dma adc.timeofprev s- >dma adc.timeofnow I/O s- >interval s->interval timefromtobuf es1371 read() es1371 read I/O s->dma adc.copy number I/O

40 4 TS-I/O 39 /* es1371_read(); */ static ssize_t es1371_read(struct file *file, char *buffer, size_t count, loff_t *ppos) {... while (count > 0) {... /* * s->settimestamp: * copy_number: * I/O * copy_number */ if (s->settimestamp > 0 && s->dma_adc.empty_sounddata[s->dma_adc. copy_number] > 0 && s->dma_adc.sounddata[s->dma_adc.copy_number] <= 0) { cnt = s->dma_adc.empty_sounddata[s->dma_adc.copy_number]; if (cnt > count) cnt = count; /* * * = * case 16bit: 0 * case 8bit: 128 */ if (s->adcsize == AFMT_S16_LE) memset(buffer, 0, cnt); else memset(buffer, 128, cnt); } spin_lock_irqsave(&s->lock, flags); s->dma_adc.empty_sounddata[s->dma_adc.copy_number] -= cnt; /* */ if (s->dma_adc.empty_sounddata[s->dma_adc.copy_number] <= 0) s->dma_adc.copy_number ++; spin_unlock_irqrestore(&s->lock, flags); } else { /* I/O */... if (copy_to_user(buffer, s->dma_adc.rawbuf + swptr, cnt)) {... } }... count -= cnt; buffer += cnt;... }

41 4 TS-I/O I/O read gettbuf read read gettbuf read gettbuf linux/fs/read write.c /* * linux/fs/read_write.c */ #include <linux/read_gettbuf.h> #include <linux/timefromtofile.h> /* */ struct tftbuf timefromtobuf[500]; /* sys_read adding gettimebuf */ asmlinkage ssize_t sys_read_gettbuf(unsigned int fd, char * buf, struct tftbuf * fromtobuf, size_t count, int * pnt) { ssize_t ret; struct file * file; ssize_t (*read)(struct file *, char *, size_t, loff_t *); int (*gettbuf)(struct file *); int empty_num1, empty_num2, copy_num; int i;... if (!file->f_op!(gettbuf = file->f_op->gettbuf)) goto out; empty_num1 = gettbuf(file); if (!file->f_op!(read = file->f_op->read)) goto out; ret = read(file, buf, count, &file->f_pos);

42 4 TS-I/O 41 if (!file->f_op!(gettbuf = file->f_op->gettbuf)) goto out; empty_num2 = gettbuf(file); if (*pnt > empty_num2 - empty_num1) copy_num = empty_num2 - empty_num1; else copy_num = *pnt; /* * * fromtobuf timefromtobuf * */ for(i = 0; i < copy_num; i++) { copy_to_user(fromtobuf+i, timefromtobuf+empty_num1+i, sizeof(*fromtobuf)); } *pnt -= copy_num; out: fput(file); bad_file: unlock_kernel(); return ret; } read gettbuf sys read gettbuf es1371.c read es1371 read() gettbuf() es1371.c es1371 gettbuf() read gettbuf empty num1 empty num2 read pnt pnt pnt pnt

43 4 TS-I/O 42 read read gettbuf *pnt ioctl SNDCTL DSP EMPTYSET include/linux/soundcard.h es1371.c es1371 ioctl() es1371 ioctl() SNDCTL DSP EMPTYSET /* es1371_ioctl(); */ /* 4 arg int unsigned long */ static int es1371_ioctl(struct inode *inode, struct file *file, unsigned int cmd, unsigned long arg) { struct es1371_state *s = (struct es1371_state *)file->private_data;... unsigned long longval; /* unsigned long */... switch (cmd) { case /* SNDCTL_DSP_EMPTYSET */ case SNDCTL_DSP_EMPTYSET: /* longval *arg */ if (get_user(longval, (unsigned long *)arg)) return -EFAULT; if (longval >= 0) { if (file->f_mode & FMODE_READ) { stop_adc(s); s->dma_adc.ready = 0;

44 4 TS-I/O 43 } }... s->time_interval = longval; } if (file->f_mode & FMODE_WRITE) { stop_dac2(s); s->dma_dac2.ready = 0; s->time_interval = longval; } } /* *arg s->time_interval */ return put_user(s->time_interval, (unsigned long *)arg); es1371 ioctl arg int unsigned logn arg int 100,000 1,000,000 unsigned long get user() 1 2 put user() 1 2 SNDCTL DSP EMPTYSET es1371 state s- time interval 4.5 TS-I/O read gettbuf TS-I/O

45 4 TS-I/O 44 TS-I/O TS-I/O TS-I/O 9 record read size=9 miss!! kernel buffer copy size = 7 application buffer empty datao o play o o :

46 45 5 TS-I/O 5.1 TS-I/O TS-I/O Hz 16bit

47 sec 5.1: empty data empty data sec 5.2:

48 sec 5.3: deadline miss sec 5.4:

49 read deadline miss ??????

50 5 49 L L R R 5.5: d1 d2 d3 d4 d1 d2 d3 d

51 d d1 d2 d : [9] : Pentium III 733MHz 512MB :pifftc : read gettbuf n 10 pi fftc read gettbuf 10 n 48000Hz 16bit read gettbuf read gettbuf

52 5 51 nice 0 nice 5 nice 10 nice 15 nice 20 n=1 pi5 pi4 pi4 pi3 n=10000 pi4 pi4 pi3 pi2 n= pi6 pi4 pi3 pi1 - n= pi3 pi n= pi : read gettbuf() nice read gettbuf nice pi fftc pi pi fftc n= read gettbuf I/O

53 52 6 OS OS OS OS OS OS I/O TS-I/O I/O I/O 4-5 TS-I/O Linux ( 6.1) TS-I/O I/O OS Linux OS RT-Linux ART-Linux TS-I/O I/O 6.1: Linux TS-I/O

54 6 53 I/O I/O TS-I/O

55 54 [1] : FSMLabs Community, [2] : ITRON Project Home Page (in Japanese), u-tokyo.ac.jp/tron/itron/home-j.html/. [3] : Lynux Works, [4] :, [5] Beck, M., Dziadzka, M., Magnus, R., Kunitz, U., Dirk Verworner, : Linux, (1999). [6] : PC, 03postpc/. [7] : Linux,, Vol. 25, No. 11, pp (1999). [8] :,, Vol. 26, No. 6, pp (2000). [9] : FFT AGM, kurims.kyoto-u.ac.jp/~ooura/pi_fft-j.html. [10] Jeff Tranter, : Linux, (1997). [11] : ART-Linux Linux kernel 2.2, art-linux/rlc200101/text.html. [12] : ART-Linux,, Vol. 25, No. 11, pp (1999).

56 6 55 [13] : ART-Linux,, Vol. 25, No. 11, pp (1999). [14] : OS Linux,, Vol. 27, No. 6, pp (2000).

tutorial_lc.dvi

tutorial_lc.dvi 00 Linux v.s. RT Linux v.s. ART-Linux Linux RT-Linux ART-Linux Linux kumagai@emura.mech.tohoku.ac.jp 1 1.1 Linux Yes, No.,. OS., Yes. Linux,.,, Linux., Linux.,, Linux. Linux.,,. Linux,.,, 0..,. RT-Linux