Changeset 241 in code for trunk


Ignore:
Timestamp:
Apr 7, 2020, 12:42:13 PM (5 years ago)
Author:
contact
Message:

Remove Ring.Close

This is unused.

Location:
trunk
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • trunk/ring.go

    r232 r241  
    1515        cur       uint64
    1616        consumers []*RingConsumer
    17         closed    bool
    1817}
    1918
    … …  
    2827// Produce appends a new message to the ring buffer.
    2928func (r *Ring) Produce(msg *irc.Message) {
    30         if r.closed {
    31                 panic("soju: Ring.Produce called after Close")
    32         }
    33 
    3429        i := int(r.cur % r.cap)
    3530        r.buffer[i] = msg
    … …  
    3934func (r *Ring) Cur() uint64 {
    4035        return r.cur
    41 }
    42 
    43 func (r *Ring) Close() {
    44         if r.closed {
    45                 panic("soju: Ring.Close called twice")
    46         }
    47 
    48         r.closed = true
    4936}
    5037

  • trunk/user.go

    r237 r241  
    364364
    365365                net.Stop()
    366                 net.ring.Close()
    367366                u.networks = append(u.networks[:i], u.networks[i+1:]...)
    368367                return nil
Note: See TracChangeset for help on using the changeset viewer.