Commit391daa9

committed

Trace more information

1 parent0d78873 commit391daa9Copy full SHA for 391daa9

File tree

-1

lines changed

-1

lines changed

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1238,6 +1238,9 @@ static void MMProcessUtility(Node parsetree, const char queryString,`
`1238`	`1238`	`break;`
`1239`	`1239`	`}`
`1240`	`1240`	`if (skipCommand\|\|IsTransactionBlock()) {`
	`1241`	`+if (!skipCommand) {`
	`1242`	`+elog(WARNING,"Statement '%s' is in transaction block at node %d",queryString,MMNodeId);`
	`1243`	`+ }`
`1241`	`1244`	`if (PreviousProcessUtilityHook!=NULL)`
`1242`	`1245`	`{`
`1243`	`1246`	`PreviousProcessUtilityHook(parsetree,queryString,context,`
`@@ -1259,6 +1262,8 @@ static void MMProcessUtility(Node parsetree, const char queryString,`
`1259`	`1262`	`charconst*errorMsg=NULL;`
`1260`	`1263`	`PGconn**conns;`
`1261`	`1264`	`conns=palloc(sizeof(PGconn)MMNodes);`
	`1265`	`+`
	`1266`	`+elog(WARNING,"Broadcast utility statement '%s' at node %d",queryString,MMNodeId);`
`1262`	`1267`
`1263`	`1268`	`while (conn_str<conn_str_end) {`
`1264`	`1269`	`char*p=strchr(conn_str,',');`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,6 @@ static int resolve_host_by_name(const char hostname, unsigned addrs, unsigned*`
`92`	`92`
`93`	`93`	`staticvoidclose_socket(Shub*shub,intfd)`
`94`	`94`	`{`
`95`		`-close(fd);`
`96`	`95`	`#ifdefUSE_EPOLL`
`97`	`96`	`if (epoll_ctl(shub->epollfd,EPOLL_CTL_DEL,fd,NULL)<0) {`
`98`	`97`	`charbuf[ERR_BUF_SIZE];`
`@@ -102,6 +101,7 @@ static void close_socket(Shub* shub, int fd)`
`102`	`101`	`#else`
`103`	`102`	`FD_CLR(fd,&shub->inset);`
`104`	`103`	`#endif`
	`104`	`+close(fd);`
`105`	`105`	`}`
`106`	`106`
`107`	`107`	`intShubReadSocketEx(intsd,void*buf,intmin_size,intmax_size)`

Comments

(0)