Skip to content

Commit

Permalink
Merge pull request #17 from michalpristas/master
Browse files Browse the repository at this point in the history
int63 changed to int32
  • Loading branch information
chzyer committed Nov 20, 2015
2 parents 4dffd60 + 4bc3b1f commit ee4d466
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions terminal.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,11 @@ type Terminal struct {
cfg *Config
state *terminal.State
outchan chan rune
closed int64
closed int32
stopChan chan struct{}
kickChan chan struct{}
wg sync.WaitGroup
isReading int64
isReading int32
}

func NewTerminal(cfg *Config) (*Terminal, error) {
Expand Down Expand Up @@ -72,7 +72,7 @@ func (t *Terminal) ReadRune() rune {
}

func (t *Terminal) IsReading() bool {
return atomic.LoadInt64(&t.isReading) == 1
return atomic.LoadInt32(&t.isReading) == 1
}

func (t *Terminal) KickRead() {
Expand All @@ -94,10 +94,10 @@ func (t *Terminal) ioloop() {
buf := bufio.NewReader(Stdin)
for {
if !expectNextChar {
atomic.StoreInt64(&t.isReading, 0)
atomic.StoreInt32(&t.isReading, 0)
select {
case <-t.kickChan:
atomic.StoreInt64(&t.isReading, 1)
atomic.StoreInt32(&t.isReading, 1)
case <-t.stopChan:
return
}
Expand Down Expand Up @@ -143,7 +143,7 @@ func (t *Terminal) Bell() {
}

func (t *Terminal) Close() error {
if atomic.SwapInt64(&t.closed, 1) != 0 {
if atomic.SwapInt32(&t.closed, 1) != 0 {
return nil
}
t.stopChan <- struct{}{}
Expand Down

0 comments on commit ee4d466

Please sign in to comment.