()
| 1628 | } |
| 1629 | |
| 1630 | func (b *BinlogReader) GetQueueMem() int64 { |
| 1631 | if b != nil && b.binlogStreamer0 != nil { |
| 1632 | return b.binlogStreamer0.QueueMem() |
| 1633 | } else { |
| 1634 | return 0 |
| 1635 | } |
| 1636 | } |
| 1637 | |
| 1638 | func (b *BinlogReader) sqleExecDDL(currentSchema string, ast ast.Node) { |
| 1639 | if b.maybeSqleContext != nil { |