[Pgcluster-general] pgcluster 1.5.0-rc14 problems

a.mitani at sra-europe.com a.mitani at sra-europe.com
Thu Feb 15 17:08:59 UTC 2007


Hi,

Would you try to set "no" to <Use_Replication_Log> , if you do not have a
lower replication server.

At.Mitani


>  Hi guys,
>
>  I'm trying to use pgcluster 1.5.0-rc14 (with postgresql 8.1.7 and
> 8.1.8 - same issue) but for some reason it does not work properly.
>
>  My setup:
>
>  - two postgresql servers, 10.100.103.1 and .2 running postgresql
> on port 5433, recovery port 7001 (default);
>  - one replicator running on the first server (10.100.103.1) on
> port 8001, recovery port 8101 (all default);
>  - one balancer running on 10.100.103.1 as well (this one is not
> important).
>
>  The pgreplicate.conf file looks like this:
>
> ## pgreplicate.conf begin
> <Cluster_Server_Info>
>      <Host_Name>   10.100.103.1  </Host_Name>
>      <Port>        5433                </Port>
>      <Recovery_Port>       7001        </Recovery_Port>
> </Cluster_Server_Info>
> <Cluster_Server_Info>
>      <Host_Name>   10.100.103.2 </Host_Name>
>      <Port>        5433                </Port>
>      <Recovery_Port>       7001        </Recovery_Port>
> </Cluster_Server_Info>
>
> <Host_Name> 10.100.103.1        </Host_Name>
> <Replication_Port>              8001            </Replication_Port>
> <Recovery_Port>                 8101            </Recovery_Port>
> <RLOG_Port>                             8301            </RLOG_Port>
> <Response_Mode>                 normal          </Response_Mode>
> <Use_Replication_Log>   yes                     </Use_Replication_Log>
> <Replication_Timeout>   5s              </Replication_Timeout>
> <Log_File_Info>
>          <File_Name> /tmp/pgreplicate.log </File_Name>
>          <File_Size> 100M </File_Size>
>          <Rotate> 8 </Rotate>
> </Log_File_Info>
>
> ## === pgreplicate.conf end
>
>  The cluster.conf file for the two servers is identical:
>
> ## === cluster.conf file
> <Replicate_Server_Info>
>          <Host_Name> 10.100.103.1 </Host_Name>
>          <Port> 8001 </Port>
>          <Recovery_Port> 8101 </Recovery_Port>
> </Replicate_Server_Info>
>
> <Recovery_Port>7001</Recovery_Port>
> <Rsync_Path>/usr/bin/rsync</Rsync_Path>
> <Rsync_Option>ssh</Rsync_Option>
> <Rsync_Compress>yes</Rsync_Compress>
> <Pg_Dump_Path>/usr/bin/pg_dump</Pg_Dump_Path>
> <When_Stand_Alone>read_write</When_Stand_Alone>
> <Replication_Timeout>1min</Replication_Timeout>
>
> ## === end of cluster.conf file
>
>  What happens: if I try to create a table the "CREATE TABLE"
> command does not return unless I kill the pgreplicate service. I'm
> surprised in the end that the table is created on both servers though.
>  If I try to insert something in that table after a while the
> records are inserted many times on both sides. Something happens with the
> replicator, it does not manage to get the right status from the postgres
> servers:
>
> pgbench=> select * from t;
>   i
> ---
> (0 rows)
>
> pgbench=> select now(); insert into t(i) values (1);
>                now
> -------------------------------
>   2007-02-15 16:34:27.156815+02
> (1 row)
>
> [waiting...]
> [ in the meanwhile, on the other postgres server:]
> pgbench=> select * from t;
>   i
> ---
>   1
> (1 row)
>
>  !!
>  And after a minute:
> pgbench=> select * from t;
>   i
> ---
>   1
>   1
> (2 rows)
>
>  ...while the insert command didn't finish on the first server. At
> this point (after about two minutes) I'll kill the replicator:
>
> INSERT 0 1
> pgbench=> select * from t;
>   i
> ---
>   1
>   1
>   1
>   1
> (4 rows)
>
>  I attach bellow the logs of the pgreplicate server (from the
> moment I executed the insert and until I've killed the replicator), maybe
> someone has a clue about what I'm doing wrong or about what is wrong with
> this and why the replicator gets status "not replicated" on these queries:
>
> Thu Feb 15 16:34:27 2007  PGRread_packet():PG_read_query returns insert
> into t(i) values (1).
> Thu Feb 15 16:34:27 2007  PGRreturn_result():PGRreturn_result[1]
> Thu Feb 15 16:34:27 2007  PGRreturn_result():128 send
> Thu Feb 15 16:34:27 2007  PGRread_packet():PG_read_query returns insert
> into t(i) values (1).
> Thu Feb 15 16:34:27 2007  PGRdo_replicate():query :: insert into t(i)
> values (1)Thu Feb 15 16:34:27 2007  cmdSts=Q
> Thu Feb 15 16:34:27 2007  cmdType=I
> Thu Feb 15 16:34:27 2007  rlog=0
> Thu Feb 15 16:34:27 2007  port=5433
> Thu Feb 15 16:34:27 2007  pid=5801
> Thu Feb 15 16:34:27 2007  from_host=10.100.100.129
> Thu Feb 15 16:34:27 2007  dbName=pgbench
> Thu Feb 15 16:34:27 2007  userName=pgbench
> Thu Feb 15 16:34:27 2007  recieve sec=1171550067
> Thu Feb 15 16:34:27 2007  recieve usec=158458
> Thu Feb 15 16:34:27 2007  query_size=27
> Thu Feb 15 16:34:27 2007  request_id=3
> Thu Feb 15 16:34:27 2007  replicate_id=0
> Thu Feb 15 16:34:27 2007  recovery_status=0
> Thu Feb 15 16:34:27 2007  query=insert into t(i) values (1)
> Thu Feb 15 16:34:27 2007  sem_lock [1] req
> Thu Feb 15 16:34:27 2007  sem_lock [1] got it
> Thu Feb 15 16:34:27 2007  PGRset_rlog():set rlog insert into t(i) values
> (1)
> Thu Feb 15 16:34:27 2007  PGRset_rlog():PGRsend_lower_cascade failed
> Thu Feb 15 16:34:27 2007  PGRwrite_rlog():set_query_log
> Thu Feb 15 16:34:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.1]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:34:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:34:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.2]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:34:27 2007  start thread_send_cluster()
> Thu Feb 15 16:34:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550067,158458,8,1,2) )
> Thu Feb 15 16:34:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,2,0,1) )
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:34:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:34:27 2007  start thread_send_cluster()
> Thu Feb 15 16:34:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550067,158458,8,1,2) )
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:34:27 2007  thread_send_cluster():return value from
> send_replicate _packet_to_server() is 0
> Thu Feb 15 16:34:27 2007  thread_send_cluster():pthread_exit[0]
> Thu Feb 15 16:34:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,2,0,1) )
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:34:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:34:27 2007  thread_send_cluster():return value from
> send_replicate_packet_to_server() is 0
> Thu Feb 15 16:34:27 2007  thread_send_cluster():pthread_exit[1]
> Thu Feb 15 16:34:27 2007  unset rlog insert into t(i) values (1)
> Thu Feb 15 16:34:27 2007  PGRsend_lower_cascade recv failed
> Thu Feb 15 16:34:27 2007  PGRwrite_rlog():delete_query_log
> Thu Feb 15 16:34:27 2007  get_qurey_log: comparing in log is
> 134217728,header is 134217728
> Thu Feb 15 16:34:27 2007  sem_unlock[1]
> Thu Feb 15 16:35:27 2007  replicate_loop():session closed
> Thu Feb 15 16:35:27 2007  PGRdo_replicate():query :: PGR_CLOSE_CONNECTION
> Thu Feb 15 16:35:27 2007  cmdSts=O
> Thu Feb 15 16:35:27 2007  cmdType=x
> Thu Feb 15 16:35:27 2007  rlog=0
> Thu Feb 15 16:35:27 2007  port=5433
> Thu Feb 15 16:35:27 2007  pid=5801
> Thu Feb 15 16:35:27 2007  from_host=10.100.100.129
> Thu Feb 15 16:35:27 2007  dbName=pgbench
> Thu Feb 15 16:35:27 2007  userName=pgbench
> Thu Feb 15 16:35:27 2007  PGRread_packet():PG_read_query returns SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(2,10.100.103.1,8001,8101).
> Thu Feb 15 16:35:27 2007  recieve sec=1171550127
> Thu Feb 15 16:35:27 2007  recieve usec=143830
> Thu Feb 15 16:35:27 2007  PGRread_packet():PG_read_query returns insert
> into t(i) values (1).
> Thu Feb 15 16:35:27 2007  PGRdo_replicate():query :: insert into t(i)
> values (1)Thu Feb 15 16:35:27 2007  PGRread_packet():PG_read_query returns
> .
> Thu Feb 15 16:35:27 2007  do_rlog():got result:cmdSys='R'
> Thu Feb 15 16:35:27 2007  PGRwrite_rlog():delete_query_log
> Thu Feb 15 16:35:27 2007  do_rlog():process result done:cmdSys='R'
> Thu Feb 15 16:35:27 2007  cmdSts=Q
> Thu Feb 15 16:35:27 2007  cmdType=I
> Thu Feb 15 16:35:27 2007  rlog=3
> Thu Feb 15 16:35:27 2007  query_size=21
> Thu Feb 15 16:35:27 2007  request_id=3
> Thu Feb 15 16:35:27 2007  replicate_id=0
> Thu Feb 15 16:35:27 2007  recovery_status=0
> Thu Feb 15 16:35:27 2007  query=PGR_CLOSE_CONNECTION
> Thu Feb 15 16:35:27 2007  sem_lock [1] req
> Thu Feb 15 16:35:27 2007  sem_lock [1] got it
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.1]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:35:27 2007  port=5433
> Thu Feb 15 16:35:27 2007  pid=5801
> Thu Feb 15 16:35:27 2007  from_host=10.100.100.129
> Thu Feb 15 16:35:27 2007  dbName=pgbench
> Thu Feb 15 16:35:27 2007  userName=pgbench
> Thu Feb 15 16:35:27 2007  recieve sec=1171550127
> Thu Feb 15 16:35:27 2007  recieve usec=144692
> Thu Feb 15 16:35:27 2007  query_size=0
> Thu Feb 15 16:35:27 2007  request_id=3
> Thu Feb 15 16:35:27 2007  replicate_id=0
> Thu Feb 15 16:35:27 2007  recovery_status=0
> Thu Feb 15 16:35:27 2007  query=insert into t(i) values (1)
> Thu Feb 15 16:35:27 2007  sem_lock [1] req
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:35:27 2007  replicate_packet_send_internal():connect
> db:pgbench port:5433 user:pgbench host:10.100.103.1
> query:PGR_CLOSE_CONNECTION
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.2]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:35:27 2007  start thread_send_cluster()
> Thu Feb 15 16:35:27 2007  PGR_Notice_Abort():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(7))
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:35:27 2007  replicate_packet_send_internal():connect
> db:pgbench port:5433 user:pgbench host:10.100.103.2
> query:PGR_CLOSE_CONNECTION
> Thu Feb 15 16:35:27 2007  start thread_send_cluster()
> Thu Feb 15 16:35:27 2007  PGR_Notice_Abort():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(7))
> Thu Feb 15 16:35:27 2007  sem_unlock[1]
> Thu Feb 15 16:35:27 2007  sem_lock [1] got it
> Thu Feb 15 16:35:27 2007  replicate_loop():replicate loop exit
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.1]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.2]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:35:27 2007  start thread_send_cluster()
> Thu Feb 15 16:35:27 2007  is_executed_query():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(9,1171550127,144692,0,1) )
> Thu Feb 15 16:35:27 2007  is_executed_query():PQcmdStatus
> return[SYSTEM_COMMAND]
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():check
> replication log issue , id=0,rlog=3,query=insert into t(i) values (1)
> status=not_replicated
> Thu Feb 15 16:35:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550127,144692,0,1,4) )
> Thu Feb 15 16:35:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,4,0,1) )
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:35:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:35:27 2007  start thread_send_cluster()
> Thu Feb 15 16:35:27 2007  is_executed_query():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(9,1171550127,144692,0,1) )
> Thu Feb 15 16:35:27 2007  is_executed_query():PQcmdStatus
> return[SYSTEM_COMMAND]
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():check
> replication log issue , id=0,rlog=3,query=insert into t(i) values (1)
> status=not_replicated
> Thu Feb 15 16:35:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550127,144692,0,1,4) )
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:35:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,4,0,1) )
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:35:27 2007  thread_send_cluster():return value from
> send_replicate_packet_to_server() is 0
> Thu Feb 15 16:35:27 2007  thread_send_cluster():pthread_exit[0]
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:35:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:35:27 2007  thread_send_cluster():return value from
> send_replicate_packet_to_server() is 0
> Thu Feb 15 16:35:27 2007  thread_send_cluster():pthread_exit[1]
> Thu Feb 15 16:35:27 2007  sem_unlock[1]
> Thu Feb 15 16:36:27 2007  replicate_loop():session closed
> Thu Feb 15 16:36:27 2007  PGRdo_replicate():query :: PGR_CLOSE_CONNECTION
> Thu Feb 15 16:36:27 2007  PGRread_packet():PG_read_query returns .
> Thu Feb 15 16:36:27 2007  PGRread_packet():PG_read_query returns SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(2,10.100.103.1,8001,8101).
> Thu Feb 15 16:36:27 2007  do_rlog():got result:cmdSys='R'
> Thu Feb 15 16:36:27 2007  PGRread_packet():PG_read_query returns insert
> into t(i) values (1).
> Thu Feb 15 16:36:27 2007  cmdSts=O
> Thu Feb 15 16:36:27 2007  cmdType=x
> Thu Feb 15 16:36:27 2007  PGRdo_replicate():query :: insert into t(i)
> values (1)Thu Feb 15 16:36:27 2007  rlog=3
> Thu Feb 15 16:36:27 2007  port=5433
> Thu Feb 15 16:36:27 2007  pid=5801
> Thu Feb 15 16:36:27 2007  from_host=10.100.100.129
> Thu Feb 15 16:36:27 2007  dbName=pgbench
> Thu Feb 15 16:36:27 2007  userName=pgbench
> Thu Feb 15 16:36:27 2007  recieve sec=1171550187
> Thu Feb 15 16:36:27 2007  recieve usec=130726
> Thu Feb 15 16:36:27 2007  query_size=0
> Thu Feb 15 16:36:27 2007  request_id=3
> Thu Feb 15 16:36:27 2007  replicate_id=0
> Thu Feb 15 16:36:27 2007  recovery_status=0
> Thu Feb 15 16:36:27 2007  query=PGR_CLOSE_CONNECTION
> Thu Feb 15 16:36:27 2007  sem_lock [1] req
> Thu Feb 15 16:36:27 2007  sem_lock [1] got it
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.1]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:36:27 2007  PGRwrite_rlog():delete_query_log
> Thu Feb 15 16:36:27 2007  do_rlog():process result done:cmdSys='R'
> Thu Feb 15 16:36:27 2007  PGRread_packet():PG_read_query returns .
> Thu Feb 15 16:36:27 2007  do_rlog():got result:cmdSys='R'
> Thu Feb 15 16:36:27 2007  PGRwrite_rlog():delete_query_log
> Thu Feb 15 16:36:27 2007  do_rlog():process result done:cmdSys='R'
> Thu Feb 15 16:36:27 2007  cmdSts=Q
> Thu Feb 15 16:36:27 2007  cmdType=I
> Thu Feb 15 16:36:27 2007  rlog=3
> Thu Feb 15 16:36:27 2007  port=5433
> Thu Feb 15 16:36:27 2007  pid=5801
> Thu Feb 15 16:36:27 2007  from_host=10.100.100.129
> Thu Feb 15 16:36:27 2007  dbName=pgbench
> Thu Feb 15 16:36:27 2007  userName=pgbench
> Thu Feb 15 16:36:27 2007  recieve sec=1171550187
> Thu Feb 15 16:36:27 2007  recieve usec=131819
> Thu Feb 15 16:36:27 2007  query_size=0
> Thu Feb 15 16:36:27 2007  request_id=3
> Thu Feb 15 16:36:27 2007  replicate_id=0
> Thu Feb 15 16:36:27 2007  recovery_status=0
> Thu Feb 15 16:36:27 2007  query=insert into t(i) values (1)
> Thu Feb 15 16:36:27 2007  sem_lock [1] req
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:36:27 2007  replicate_packet_send_internal():connect
> db:pgbench port:5433 user:pgbench host:10.100.103.1
> query:PGR_CLOSE_CONNECTION
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.2]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:36:27 2007  start thread_send_cluster()
> Thu Feb 15 16:36:27 2007  PGR_Notice_Abort():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(7))
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:36:27 2007  replicate_packet_send_internal():connect
> db:pgbench port:5433 user:pgbench host:10.100.103.2
> query:PGR_CLOSE_CONNECTION
> Thu Feb 15 16:36:27 2007  start thread_send_cluster()
> Thu Feb 15 16:36:27 2007  PGR_Notice_Abort():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(7))
> Thu Feb 15 16:36:27 2007  sem_unlock[1]
> Thu Feb 15 16:36:27 2007  replicate_loop():replicate loop exit
> Thu Feb 15 16:36:27 2007  sem_lock [1] got it
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.1]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin host[10.100.103.2]
> port[5433] db[pgbench] user[pgbench]
> Thu Feb 15 16:36:27 2007  start thread_send_cluster()
> Thu Feb 15 16:36:27 2007  is_executed_query():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(9,1171550187,131819,0,1) )
> Thu Feb 15 16:36:27 2007  is_executed_query():PQcmdStatus
> return[SYSTEM_COMMAND]
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():check
> replication log issue , id=0,rlog=3,query=insert into t(i) values (1)
> status=not_replicated
> Thu Feb 15 16:36:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550187,131819,0,1,6) )
> Thu Feb 15 16:36:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,6,0,1) )
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:36:27 2007  pgr_createConn():PQsetdbLogin ok!!
> Thu Feb 15 16:36:27 2007  start thread_send_cluster()
> Thu Feb 15 16:36:27 2007  is_executed_query():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(9,1171550187,131819,0,1) )
> Thu Feb 15 16:36:27 2007  is_executed_query():PQcmdStatus
> return[SYSTEM_COMMAND]
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():check
> replication log issue , id=0,rlog=3,query=insert into t(i) values (1)
> status=not_replicated
> Thu Feb 15 16:36:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(3,1171550187,131819,0,1,6) )
> Thu Feb 15 16:36:27 2007
> send_replicate_packet_to_server():sync_command(SELECT
> PGR_SYSTEM_COMMAND_FUNCTION(8,6,0,1) )
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():sync_command
> returns SYSTEM_COMMAND
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:36:27 2007  thread_send_cluster():return value from
> send_replicate_packet_to_server() is 0
> Thu Feb 15 16:36:27 2007  thread_send_cluster():pthread_exit[0]
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():PQexec send
> :insert into t(i) values (1)
> Thu Feb 15 16:36:27 2007  send_replicate_packet_to_server():PQexec returns
> :INSERT 0 1
> Thu Feb 15 16:36:27 2007  thread_send_cluster():return value from
> send_replicate_packet_to_server() is 0
> Thu Feb 15 16:36:27 2007  thread_send_cluster():pthread_exit[1]
> Thu Feb 15 16:36:27 2007  sem_unlock[1]
> Thu Feb 15 16:36:42 2007  quick_exit:signo = 2
> Thu Feb 15 16:36:42 2007  quick_exit:signo = 2
>
>
> --
> Victor Tarhon-Onu
> Lead Systems Administrator
> ActiveMedia Technology
> http://www.activemediatech.com
> .............................................................................
> This communication contains information that is confidential and may also
> be
> privileged. It is for the exclusive use of the intended recipient(s). If
> you
> are not the intended recipient(s) please note that any form of
> distribution,
> copying or use of this communication or the information in it is strictly
> prohibited and may be unlawful. If you have received this communication in
> error kindly notify the sender immediately and delete it from your system.
> _______________________________________________
> Pgcluster-general mailing list
> Pgcluster-general at pgfoundry.org
> http://pgfoundry.org/mailman/listinfo/pgcluster-general
>



More information about the Pgcluster-general mailing list