123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384 |
- package door
- import (
- "log"
- "strings"
- "sync/atomic"
- "syscall"
- )
- func Writer(d *Door) {
- var handle int = d.Config.Comm_handle
- log.Println("Writer")
- defer d.wg.Done()
- for {
- select {
- case <-d.closeChannel:
- close(d.writerChannel)
- log.Println("~Writer")
- return
- default:
- }
- select {
- case <-d.closeChannel:
- close(d.writerChannel)
- log.Println("~Writer")
- return
- case output, ok := <-d.writerChannel:
- if !ok {
- log.Println("closeChannel")
- if !d.Disconnect() {
-
- atomic.StoreInt32(&d.Disconnected, 1)
-
-
- }
- log.Println("~Writer")
- return
-
-
- } else {
-
-
- if strings.HasSuffix(output, RestorePos) {
- output += Color(d.LastColor...)
- } else {
- d.UpdateLastColor(output, &d.LastColor)
- }
-
- buffer := []byte(output)
- n, err := syscall.Write(handle, buffer)
- if (err != nil) || (n != len(buffer)) {
- log.Println("closeChannel")
- if !d.Disconnect() {
-
- atomic.StoreInt32(&d.Disconnected, 1)
- close(d.writerChannel)
- }
- log.Println("~Writer")
- return
- }
- }
- }
- }
- }
|