@!@!@STARTMSG 2110:1 @!@!@
Invariant SourceTargetEquality is violated.
@!@!@ENDMSG 2110 @!@!@
@!@!@STARTMSG 2121:1 @!@!@
The behavior up to this point is:
@!@!@ENDMSG 2121 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
1: <Initial predicate>
/\ lastSuccessfulPK = 0
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = defaultInitValue
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_loop" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<NoRecordHere, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
2: <tblit_loop line 451, col 15 to line 461, col 41 of module ghostferry>
/\ lastSuccessfulPK = 0
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = defaultInitValue
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_r" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<NoRecordHere, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
3: <tblit_r line 463, col 12 to line 470, col 80 of module ghostferry>
/\ lastSuccessfulPK = 0
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r0
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<NoRecordHere, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
4: <tblit_w line 472, col 12 to line 483, col 60 of module ghostferry>
/\ lastSuccessfulPK = 0
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r0
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_upkey" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
5: <tblit_upkey line 485, col 16 to line 493, col 64 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r0
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_loop" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
6: <tblit_loop line 451, col 15 to line 461, col 41 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r0
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_r" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
7: <tblit_r line 463, col 12 to line 470, col 80 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
8: <binlog_loop line 497, col 16 to line 507, col 42 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_read" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
9: <binlog_writer_loop line 545, col 23 to line 557, col 49 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_read" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
10: <app_loop line 579, col 13 to line 588, col 81 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = defaultInitValue
/\ SourceBinlog = <<>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_write" @@
  BinlogStreamer :> "binlog_read" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = defaultInitValue
/\ oldRecord = defaultInitValue
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r1, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
11: <app_write line 590, col 14 to line 616, col 50 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_read" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = defaultInitValue
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
12: <binlog_read line 509, col 16 to line 520, col 53 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_queue" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
13: <binlog_queue line 522, col 17 to line 530, col 65 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_upkey" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 0

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
14: <binlog_upkey line 532, col 17 to line 540, col 54 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
15: <binlog_write line 559, col 17 to line 575, col 65 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_w" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, NoRecordHere, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
16: <tblit_w line 472, col 12 to line 483, col 60 of module ghostferry>
/\ lastSuccessfulPK = 1
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_upkey" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
17: <tblit_upkey line 485, col 16 to line 493, col 64 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "tblit_loop" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
18: <tblit_loop line 451, col 15 to line 461, col 41 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_write" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
19: <binlog_write line 559, col 17 to line 575, col 65 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_setro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = FALSE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
20: <ferry_setro line 620, col 16 to line 629, col 42 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_waitro" @@
  Application :> "app_loop" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
21: <app_loop line 579, col 13 to line 588, col 81 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_waitro" @@
  Application :> "Done" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
22: <ferry_waitro line 631, col 17 to line 640, col 43 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_binlogpos" @@
  Application :> "Done" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 0
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
23: <ferry_binlogpos line 642, col 20 to line 651, col 68 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = FALSE
/\ pc = ( Ferry :> "ferry_binlogstop" @@
  Application :> "Done" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 1
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
24: <ferry_binlogstop line 653, col 21 to line 662, col 47 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = TRUE
/\ pc = ( Ferry :> "Done" @@
  Application :> "Done" @@
  BinlogStreamer :> "binlog_loop" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 1
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
25: <binlog_loop line 497, col 16 to line 507, col 42 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = TRUE
/\ pc = ( Ferry :> "Done" @@
  Application :> "Done" @@
  BinlogStreamer :> "Done" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "binlog_writer_loop" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 1
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2217:4 @!@!@
26: <binlog_writer_loop line 545, col 23 to line 557, col 49 of module ghostferry>
/\ lastSuccessfulPK = 2
/\ CurrentMaxPrimaryKey = 2
/\ BinlogWriteQueue = <<>>
/\ chosenPK = 2
/\ SourceBinlog = <<[pk |-> 2, oldr |-> r1, newr |-> r0]>>
/\ currentRow = r1
/\ BinlogStreamingStopRequested = TRUE
/\ pc = ( Ferry :> "Done" @@
  Application :> "Done" @@
  BinlogStreamer :> "Done" @@
  TableIterator :> "Done" @@
  BinlogWriter :> "Done" )
/\ newRecord = r0
/\ oldRecord = r1
/\ TargetTable = <<r0, r1, NoRecordHere>>
/\ TargetBinlogPos = 1
/\ currentBinlogEntry = [pk |-> 2, oldr |-> r1, newr |-> r0]
/\ ApplicationReadonly = TRUE
/\ SourceTable = <<r0, r0, NoRecordHere>>
/\ lastSuccessfulBinlogPos = 1

@!@!@ENDMSG 2217 @!@!@
@!@!@STARTMSG 2201:0 @!@!@
The coverage statistics at 2020-04-09 17:41:42