mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
@@ -98,13 +98,6 @@ var outMsgPool = sync.Pool{
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create a new outMsg.
|
|
||||||
func newOutMsg(index uint64, entries []*Entry) *CommittedEntry {
|
|
||||||
ce := cePool.Get().(*CommittedEntry)
|
|
||||||
ce.Index, ce.Entries = index, entries
|
|
||||||
return ce
|
|
||||||
}
|
|
||||||
|
|
||||||
func (sq *sendq) send(subj, rply string, hdr, msg []byte) {
|
func (sq *sendq) send(subj, rply string, hdr, msg []byte) {
|
||||||
if sq == nil {
|
if sq == nil {
|
||||||
return
|
return
|
||||||
|
|||||||
Reference in New Issue
Block a user