Commits on Apr 8, 2015

1. producer: fix connection race …

   Prior to this change, it is possible for more than one goroutine to
   check:
   
   	if atomic.LoadInt32(&w.state) != StateConnected {
   
   ...thereafter calling w.connect.  w.connect first grabs a lock on
   w.guard, and then asserts that it be the only goroutine attempting a
   connection:
   
   	if !atomic.CompareAndSwapInt32(&w.state, StateInit, StateConnected) {
   		return ErrNotConnected
   	}
   
   This means if there are two parallel actions which attempt to initiate
   the connection, one of them will return ErrNotConnected if the first
   succesfully connected.

   

   jeddenlea committed Apr 8, 2015
   Configuration menu

   • View commit details
   • Copy full SHA for 79c45bd
   • Browse repository at this point

   Copy the full SHA

   79c45bd View commit details

   Browse the repository at this point in the history