123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217 |
- package door
- import (
- "bufio"
- "bytes"
- "log"
- "syscall"
- "time"
- "unicode"
- )
- var ReaderInterval = time.Duration(200) * time.Millisecond
- var ReaderTimeval syscall.Timeval = syscall.Timeval{0, 200}
- func clearAll(fdSetPtr *syscall.FdSet) {
- for index := range (*fdSetPtr).Bits {
- (*fdSetPtr).Bits[index] = 0
- }
- }
- func set(fdSetPtr *syscall.FdSet, fd int) {
- (*fdSetPtr).Bits[fd/64] |= 1 << uint64(fd%64)
- }
- const READ_SIZE = 16
- func Reader(d *Door) {
-
-
-
-
- defer func() {
- log.Printf("~Reader\n")
- if d.ReaderCanClose {
- d.wg.Done()
- }
- }()
- defer func() {
- if err := recover(); err != nil {
- log.Printf("Reader: %#v\n", err)
- }
- }()
- var fdset syscall.FdSet
- var readone []byte = make([]byte, READ_SIZE)
-
- var readbuffer bytes.Buffer
- var runeread = bufio.NewReaderSize(&readbuffer, 1)
-
- for {
- clearAll(&fdset)
- set(&fdset, d.READFD)
- v, err := syscall.Select(d.READFD+1, &fdset, nil, nil, &ReaderTimeval)
- if err == syscall.EINTR {
- continue
- }
-
- if v == -1 {
- log.Printf("Reader ERR: %#v\n", err)
- d.readerMutex.Lock()
- if !d.ReaderClosed {
- d.ReaderClosed = true
- close(d.readerChannel)
- }
- return
- }
- if v == 0 {
-
-
- continue
- }
- log.Println("syscall.Read:", len(readone), cap(readone))
-
- r, err := syscall.Read(d.READFD, readone)
- if r == -1 {
- log.Println("Read -1 (closed)")
- d.readerMutex.Lock()
- defer d.readerMutex.Unlock()
- if !d.ReaderClosed {
- d.ReaderClosed = true
- d.Disconnected = true
- close(d.readerChannel)
- }
- return
- }
- if r == 0 {
- log.Printf("Select said ready, but: %#v %#v\n", r, err)
- d.readerMutex.Lock()
- defer d.readerMutex.Unlock()
- if !d.ReaderClosed {
- d.ReaderClosed = true
- d.Disconnected = true
- close(d.readerChannel)
- }
- return
- }
-
- if DEBUG_INPUT {
- log.Printf("Reader << %d, %#v\n", r, readone[:r])
- }
-
- readbuffer.Write(readone[:r])
-
-
- log.Println("readone:", len(readone), cap(readone))
- var input rune
- RuneRead:
- input, _, err = runeread.ReadRune()
- if err != nil {
- log.Printf("ReadRune: %#v\n", err)
-
- continue
- }
- if input == unicode.ReplacementChar {
- runeread.UnreadRune()
- b, _ := runeread.ReadByte()
- if DEBUG_INPUT {
- log.Printf("Reader (byte) >> %x\n", b)
- }
- d.readerChannel <- rune(b)
- } else {
- if DEBUG_INPUT {
- log.Printf("Reader >> %x\n", input)
- }
- d.readerChannel <- input
- }
- goto RuneRead
-
-
-
- }
- }
|