Skip to content

Commit

Permalink
Remove references to senderToken
Browse files Browse the repository at this point in the history
This was replaced with senderLock at some point during the development,
but some old comments weren't fixed.
  • Loading branch information
johto committed Feb 8, 2014
1 parent e8f3925 commit fc6c729
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions notify.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,6 @@ func (l *ListenerConn) acquireSenderLock() error {
return nil
}

// Release senderLock
func (l *ListenerConn) releaseSenderLock() {
l.senderLock.Unlock()
}
Expand Down Expand Up @@ -237,7 +236,8 @@ func (l *ListenerConn) Ping() error {

// Attempt to send a query on the connection. Returns an error if sending the
// query failed, and the caller should initiate closure of this connection.
// The caller must be holding senderToken (see acquireToken and releaseToken).
// The caller must be holding senderLock (see acquireSenderLock and
// releaseSenderLock).
func (l *ListenerConn) sendSimpleQuery(q string) (err error) {
defer errRecover(&err)

Expand Down Expand Up @@ -280,8 +280,7 @@ func (l *ListenerConn) ExecSimpleQuery(q string) (executed bool, err error) {
l.connectionLock.Lock()
defer l.connectionLock.Unlock()
// Set the error pointer if it hasn't been set already; see
// listenerConnMain. We also don't have to close the senderToken
// channel here; that's always handled in the main loop.
// listenerConnMain.
if l.err == nil {
l.err = err
}
Expand Down

0 comments on commit fc6c729

Please sign in to comment.