test/cetus
1
0
Fork 0
mirror of https://gitee.com/wangbin579/cetus.git synced 2024-12-02 03:47:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge master

Browse Source
This commit is contained in:
lazio579 2019-01-25 17:22:55 +08:00
commit d30745ef8f
2 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -118,6 +118,8 @@ Cetus分为读写分离和分库两个版本。
4. [Cetus Docker镜像使用](./doc/cetus-docker.md)
5. [Cetus 图形化Web管理界面](https://github.com/Lede-Inc/Cetus-GUI)
### Cetus测试
[Cetus 测试报告](./doc/cetus-test.md)

11
src/network-mysqld.c
View File

@ -2347,6 +2347,7 @@ disp_query_after_consistant_attr(network_mysqld_con *con)
}
}
static
void log_slowquery(int interval_ms, char* ip, char* domain, char* user, char* sql)
{
uint64_t usec;
@ -2373,15 +2374,7 @@ handle_query_time_stats(network_mysqld_con *con)
diff = MAX(0, diff);
if (diff >= con->srv->long_query_time) {
gchar **ip = g_strsplit_set(con->client->src->name->str, ":", -1);
struct sockaddr_in addr;
memset(&addr,0,sizeof(addr));
addr.sin_addr.s_addr = inet_addr(ip[0]);
struct hostent *host = gethostbyaddr((char*)&addr.sin_addr,4,AF_INET);
gchar *domain = NULL;
if(host) {
domain = host->h_name;
}
log_slowquery(diff, ip[0], domain,
log_slowquery(diff, ip[0], NULL,
con->client->response->username->str, con->orig_sql->str);
g_strfreev(ip);
diff = con->srv->long_query_time - 1;