summaryrefslogtreecommitdiff
path: root/databases/pgcluster/files/patch-replicate.c
diff options
context:
space:
mode:
Diffstat (limited to 'databases/pgcluster/files/patch-replicate.c')
-rw-r--r--databases/pgcluster/files/patch-replicate.c293
1 files changed, 0 insertions, 293 deletions
diff --git a/databases/pgcluster/files/patch-replicate.c b/databases/pgcluster/files/patch-replicate.c
deleted file mode 100644
index c99f7b21eda6..000000000000
--- a/databases/pgcluster/files/patch-replicate.c
+++ /dev/null
@@ -1,293 +0,0 @@
---- src/pgcluster/pgrp/replicate.c.orig Fri Feb 20 11:38:40 2004
-+++ src/pgcluster/pgrp/replicate.c Sat Feb 21 20:50:01 2004
-@@ -133,7 +133,7 @@
- ptr = Dbserver_Tbl_Begin;
- while (ptr != NULL)
- {
--show_debug("search host(%d):port(%d):db(%s)",ptr->hostIP,ptr->port,ptr->dbName);
-+show_debug("search host(%08x):port(%d):db(%s)",ptr->hostIP,ptr->port,ptr->dbName);
- if ((ptr->useFlag == DB_TBL_USE) &&
- (ptr->hostIP == host) &&
- (ptr->port == host_ptr->port) &&
-@@ -165,7 +165,7 @@
- hostName = host_ptr->hostName;
-
-
-- show_debug("host:%s dbName:%s\n",hostName,dbName);
-+ show_debug("host:%s dbName:%s",hostName,dbName);
- if ((hostName == NULL ) || (dbName == NULL))
- {
- show_error("hostName or dbName is NULL");
-@@ -215,7 +215,7 @@
-
- if ((host_ptr == (HostTbl *)NULL) || (datap == (DBServerTbl*)NULL))
- {
-- show_error("insertDBServerTbl datap error\n");
-+ show_error("insertDBServerTbl datap error");
- return (DBServerTbl *)NULL;
- }
- workp = Dbserver_Tbl_End;
-@@ -258,7 +258,7 @@
- if ((host1[0] == '\0' ) || (host2[0] == '\0') ||
- (port1 <= 0) || (port2 <= 0))
- {
-- show_debug("not same host:\n");
-+ show_debug("not same host:");
- return false;
- }
- ip1 = get_ip_by_name( host1);
-@@ -266,10 +266,10 @@
-
- if ((ip1 == ip2) && (port1 == port2))
- {
-- show_debug("same host:%d@%x - %d@%x\n",port1,ip1,port2,ip2);
-+ show_debug("same host:%d@%x - %d@%x",port1,ip1,port2,ip2);
- return true;
- }
-- show_debug("not same host:%d@%x - %d@%x\n",port1,ip1,port2,ip2);
-+ show_debug("not same host:%d@%x - %d@%x",port1,ip1,port2,ip2);
- return false;
- }
-
-@@ -326,7 +326,7 @@
- }
- cnt ++;
- }
-- show_debug("PQsetdbLogin ok!!\n");
-+ show_debug("PQsetdbLogin ok!!");
- return conn;
- }
-
-@@ -379,6 +379,7 @@
- show_error("insertTransactionTbl failed");
- return (TransactionTbl *)NULL;
- }
-+ show_debug("setTransactionTbl return %p (hostIP=%08x, port=%d, srcHostIP=%08x", ptr, work.hostIP, work.port, work.srcHostIP);
- return ptr;
- }
-
-@@ -451,12 +452,12 @@
- (!memcmp(ptr->dbName,header->dbName,strlen(ptr->dbName))) &&
- (ptr->pid == header->pid))
- {
-- show_debug("hit !! transaction tbl host %s db:%s pid:%d\n",host_ptr->hostName,ptr->dbName,ptr->pid);
-+ show_debug("hit !! transaction tbl host %s db:%s pid:%d",host_ptr->hostName,ptr->dbName,ptr->pid);
- return ptr;
- }
- ptr = (TransactionTbl*)ptr->next;
- }
-- show_debug("not found in transaction tbl host %s db:%s pid:%d\n",header->from_host,header->dbName,header->pid);
-+ show_debug("not found in transaction tbl host %s db:%s pid:%d",header->from_host,header->dbName,header->pid);
- return (TransactionTbl * )NULL;
- }
-
-@@ -561,8 +562,10 @@
- set_function("PGRadd_HostTbl");
-
- ptr = PGRget_HostTbl(conf_data->hostName, conf_data->port);
-+ set_function("PGRadd_HostTbl");
- if (ptr != (HostTbl*)NULL)
- {
-+ show_debug("found ptr");
- PGRset_host_status(ptr,useFlag);
- return ptr;
- }
-@@ -586,6 +589,7 @@
- {
- (ptr + 1) -> useFlag = DB_TBL_END;
- }
-+ show_debug("not found, allocate new one");
- ptr->hostNum = cnt;
- memcpy(ptr->hostName,conf_data->hostName,sizeof(ptr->hostName));
- ptr->port = conf_data->port;
-@@ -604,19 +608,22 @@
- set_function("PGRget_master");
-
- host_tbl = Host_Tbl_Begin;
-+ show_debug("start get_master loop");
- while(host_tbl->useFlag != DB_TBL_END)
- {
-- show_debug("name %s flg %d port %d recoveryPort %d \n",
-+ show_debug(" %s:%d flg %d recoveryPort %d",
- host_tbl->hostName,
-- host_tbl->useFlag,
- host_tbl->port,
-+ host_tbl->useFlag,
- host_tbl->recoveryPort);
- if (host_tbl->useFlag == DB_TBL_USE)
- {
-+ show_debug("found master");
- return host_tbl;
- }
- host_tbl ++;
- }
-+ show_debug("not found master");
- return (HostTbl *)NULL;
- }
-
-@@ -629,6 +636,9 @@
- PGRsem_lock(SemID,SEM_NUM_OF_RECOVERY);
- if (Recovery_Status_Inf != (RecoveryStatusInf *)NULL)
- {
-+ if (Recovery_Status_Inf->recovery_status != status) {
-+ show_debug("status change %d -> %d", Recovery_Status_Inf->recovery_status, status);
-+ }
- Recovery_Status_Inf->recovery_status = status;
- }
- PGRsem_unlock(SemID,SEM_NUM_OF_RECOVERY);
-@@ -763,7 +773,7 @@
- {
- if (Recovery_Status_Inf->useFlag != DB_TBL_FREE)
- {
-- show_debug("check recovered host %d\n",Recovery_Status_Inf->useFlag);
-+ show_debug("check recovered host (useFlag=%d)",Recovery_Status_Inf->useFlag);
- ptr = PGRadd_HostTbl((HostTbl *)&(Recovery_Status_Inf->target_host),Recovery_Status_Inf->useFlag);
- if (ptr == (HostTbl *) NULL)
- {
-@@ -792,6 +802,8 @@
- if (target != (HostTbl*)NULL)
- {
- memcpy((HostTbl *)&(Recovery_Status_Inf->target_host),target,sizeof(HostTbl));
-+ set_function("PGRset_recovered_host");
-+ show_debug("status=%d", useFlag);
- PGRset_host_status(target,useFlag);
- }
-
-@@ -961,6 +973,7 @@
- return STATUS_ERROR;
- }
- host_ptr->useFlag = status;
-+ show_debug("hostName=%s, port=%d, recoveryPort=%d, hostNum=%d, useFlag=%d", host_ptr->hostName, host_ptr->port, host_ptr->recoveryPort, host_ptr->hostNum, host_ptr->useFlag);
- switch( host_ptr->useFlag)
- {
- case DB_TBL_FREE:
-@@ -990,7 +1003,6 @@
- host_ptr->hostName);
- break;
- }
--
- return STATUS_OK;
- }
-
-@@ -1144,7 +1156,7 @@
- /*
- * re-use the connection data
- */
-- show_debug("find conn in db_server_tbl %d\n",db_server_tbl->conn);
-+ show_debug("find conn in db_server_tbl %d",db_server_tbl->conn);
- if ((db_server_tbl->conn != (PGconn *)NULL) &&
- (db_server_tbl->conn->sock <= 0) )
- {
-@@ -1153,17 +1165,18 @@
- }
- }
- conn = db_server_tbl->conn;
-- show_debug("send_replicate_packet_to_server query=%s\n",query);
-+ show_debug("send_replicate_packet_to_server query=%s",query);
- }
-
-+ set_function("PGRsend_replicate_packet_to_server");
- if (conn == NULL)
- {
-- show_error("conn is null\n");
-+ show_error("conn is null");
- PGRset_host_status(host_ptr,DB_TBL_ERROR);
- return STATUS_ERROR;
- }
-
-- show_debug("db:%s port:%s user:%s host:%s query:%s\n",
-+ show_debug("db:%s port:%s user:%s host:%s query:%s",
- database,port,userName,host,query);
- /*
- * execute query
-@@ -1184,7 +1197,7 @@
- (header->cmdType == CMD_TYPE_COPY_DATA_END))
- {
- /* copy data replication */
-- show_debug("query(%s) size(%d)\n",query,header->query_size);
-+ show_debug("query(%s) size(%d)",query,header->query_size);
- rtn =PQputnbytes(conn, query,header->query_size);
- if (header->cmdType == CMD_TYPE_COPY_DATA_END)
- {
-@@ -1201,11 +1214,11 @@
-
- if (res == NULL)
- {
-- show_error("PQexec error \n");
-+ show_error("PQexec error");
- PGRset_host_status(host_ptr,DB_TBL_ERROR);
- return STATUS_ERROR;
- }
-- show_debug("PQexec send :%s\n",query);
-+ show_debug("PQexec send :%s",query);
-
- str = PQcmdStatus(res);
- if ((str == NULL) || (*str == '\0'))
-@@ -1258,7 +1271,7 @@
- }
- }
- }
-- show_debug("PQexec end\n");
-+ show_debug("PQexec end");
- if ((! strcmp(database,"template1")) ||
- (! strcmp(database,"template0")))
- {
-@@ -1337,12 +1350,12 @@
- * send header data to queue
- */
- rtn = msgsnd(RecoveryMsgid, msg_header, sizeof(ReplicateHeader), IPC_NOWAIT);
-- show_debug("msgsnd header rtn:%d\n",rtn);
-+ show_debug("msgsnd header rtn:%d",rtn);
- /*
- * send query data to queue
- */
- rtn = msgsnd(RecoveryMsgid, msg_query, header->query_size, IPC_NOWAIT);
-- show_debug("msgsnd query rtn:%d\n",rtn);
-+ show_debug("msgsnd query rtn:%d",rtn);
-
- /*
- * release memory
-@@ -1364,6 +1377,7 @@
-
- len = strlen(hostName);
- ptr = Host_Tbl_Begin;
-+ show_debug("hostName=%s, port=%d", hostName, port);
- if (len > sizeof(ptr->hostName))
- {
- len = sizeof(ptr->hostName);
-@@ -1379,10 +1393,12 @@
- }
- if (ptr->useFlag != DB_TBL_END)
- {
-+ show_debug("found: %s:%d", ptr->hostName, ptr->port);
- return ptr;
- }
- else
- {
-+ show_debug("not found");
- return (HostTbl*)NULL;
- }
- }
-@@ -1392,7 +1408,6 @@
- {
- char buf[256];
- char log[288];
-- int len1;
- char * p;
- va_list ap;
- time_t t;
-@@ -1410,13 +1425,12 @@
- {
- *p = ' ';
- }
-- len1 = strlen(log);
- va_start(ap,fmt);
- vsnprintf(buf,sizeof(buf),fmt,ap);
- va_end(ap);
- strcat(log,buf);
- strcat(log,"\n");
-- if (fputs(log,LogFp) > 0)
-+ if (fputs(log,LogFp) >= 0)
- {
- fflush(LogFp);
- }
generated by cgit v1.2.3 (git 2.25.1) at 2025-06-08 16:02:45 +0000