database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!2116 opengauss-server 数据库多协议支持增强

Browse Source 
Merge pull request !2116 from zhaojun/protocol-extension
This commit is contained in:
opengauss-bot
2022-09-21 10:00:15 +00:00
committed by Gitee
parent 137a724c43 f71428f183
commit ece73c7d60
25 changed files with 299 additions and 157 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/gausskernel/process/threadpool/threadpool_worker.cpp
View File

@ -907,7 +907,7 @@ static bool InitSession(knl_session_context* session)
(unsigned int)maxChunksPerProcess << (chunkSizeInBits - BITS_IN_MB))));
}
ReadyForQuery((CommandDest)t_thrd.postgres_cxt.whereToSendOutput);
session->proc_cxt.MyProcPort->protocol_config->fn_send_ready_for_query((CommandDest)t_thrd.postgres_cxt.whereToSendOutput);
return true;
}
@ -937,12 +937,12 @@ static void SendSessionIdxToClient()
GenerateCancelKey(true);
if (t_thrd.postgres_cxt.whereToSendOutput == DestRemote && PG_PROTOCOL_MAJOR(FrontendProtocol) >= 2) {
StringInfoData buf;
pq_beginmessage(&buf, 'K');
pq_sendint32(&buf, (uint32)u_sess->session_ctr_index);
pq_sendint32(&buf, (uint32)u_sess->cancel_key);
pq_endmessage(&buf);
Port* MyProcPort = u_sess->proc_cxt.MyProcPort;
if (MyProcPort && MyProcPort->protocol_config->fn_send_cancel_key) {
MyProcPort->protocol_config->fn_send_cancel_key((uint32)u_sess->session_ctr_index,
(uint32)u_sess->cancel_key);
}
}
}