@@ -56,8 +56,6 @@ static void pglogical_write_update(StringInfo out, PGLogicalOutputData *data,
5656static void pglogical_write_delete (StringInfo out ,PGLogicalOutputData * data ,
5757Relation rel ,HeapTuple oldtuple );
5858
59- #define IS_REPLICA_IDENTITY 1
60-
6159static void pglogical_write_tuple (StringInfo out ,PGLogicalOutputData * data ,
6260Relation rel ,HeapTuple tuple );
6361static char decide_datum_transfer (Form_pg_attribute att ,
@@ -105,16 +103,8 @@ pglogical_write_begin(StringInfo out, PGLogicalOutputData *data,
105103if (MMIsLocalTransaction (txn -> xid )) {
106104mm -> isLocal = true;
107105 }else {
108- uint8 flags = 0 ;
109106mm -> isLocal = false;
110107pq_sendbyte (out ,'B' );/* BEGIN */
111-
112- /* send the flags field its self */
113- pq_sendbyte (out ,flags );
114-
115- /* fixed fields */
116- pq_sendint64 (out ,txn -> final_lsn );
117- pq_sendint64 (out ,txn -> commit_time );
118108pq_sendint (out ,txn -> xid ,4 );
119109 }
120110}
@@ -128,16 +118,7 @@ pglogical_write_commit(StringInfo out, PGLogicalOutputData *data,
128118{
129119PGLogicalProtoMM * mm = (PGLogicalProtoMM * )data -> api ;
130120if (!mm -> isLocal ) {
131- uint8 flags = 0 ;
132121pq_sendbyte (out ,'C' );/* sending COMMIT */
133-
134- /* send the flags field */
135- pq_sendbyte (out ,flags );
136-
137- /* send fixed fields */
138- pq_sendint64 (out ,commit_lsn );
139- pq_sendint64 (out ,txn -> end_lsn );
140- pq_sendint64 (out ,txn -> commit_time );
141122 }
142123}
143124