2023-04-28 08:09:26 +02:00
/* Copyright (c) 2008, 2023, Oracle and/or its affiliates.
2012-08-01 17:27:34 +03:00
This program is free software ; you can redistribute it and / or modify
2020-01-19 12:52:07 +01:00
it under the terms of the GNU General Public License , version 2.0 ,
as published by the Free Software Foundation .
This program is also distributed with certain software ( including
but not limited to OpenSSL ) that is licensed under separate terms ,
as designated in a particular file or component or in included license
documentation . The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have included with MySQL .
2012-08-01 17:27:34 +03:00
This program is distributed in the hope that it will be useful ,
but WITHOUT ANY WARRANTY ; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the
2020-01-19 12:52:07 +01:00
GNU General Public License , version 2.0 , for more details .
2012-08-01 17:27:34 +03:00
You should have received a copy of the GNU General Public License
along with this program ; if not , write to the Free Software Foundation ,
2019-05-11 19:25:02 +03:00
51 Franklin Street , Fifth Floor , Boston , MA 02110 - 1335 USA */
2012-08-01 17:27:34 +03:00
/**
@ file storage / perfschema / table_socket_instances . cc
Table SOCKET_INSTANCES ( implementation ) .
*/
# include "my_global.h"
2019-12-10 15:35:00 +01:00
# include "my_thread.h"
2012-08-01 17:27:34 +03:00
# include "pfs_instr.h"
# include "pfs_column_types.h"
# include "pfs_column_values.h"
# include "table_socket_instances.h"
# include "pfs_global.h"
2019-12-10 15:35:00 +01:00
# include "pfs_buffer_container.h"
# include "field.h"
2012-08-01 17:27:34 +03:00
THR_LOCK table_socket_instances : : m_table_lock ;
2022-07-29 14:48:01 +02:00
PFS_engine_table_share_state
table_socket_instances : : m_share_state = {
false /* m_checked */
} ;
2012-08-01 17:27:34 +03:00
PFS_engine_table_share
table_socket_instances : : m_share =
{
{ C_STRING_WITH_LEN ( " socket_instances " ) } ,
& pfs_readonly_acl ,
2019-12-10 15:35:00 +01:00
table_socket_instances : : create ,
2012-08-01 17:27:34 +03:00
NULL , /* write_row */
NULL , /* delete_all_rows */
2019-12-10 15:35:00 +01:00
table_socket_instances : : get_row_count ,
2012-08-01 17:27:34 +03:00
sizeof ( PFS_simple_index ) ,
& m_table_lock ,
2014-08-19 15:18:18 +04:00
{ C_STRING_WITH_LEN ( " CREATE TABLE socket_instances( "
2021-05-02 15:43:04 -05:00
" EVENT_NAME VARCHAR(128) not null comment 'NAME from the setup_instruments table, and the name of the wait/io/socket/* instrument that produced the event.', "
" OBJECT_INSTANCE_BEGIN BIGINT unsigned not null comment 'Memory address of the object.', "
" THREAD_ID BIGINT unsigned comment 'Thread identifier that the server assigns to each socket.', "
" SOCKET_ID INTEGER not null comment 'The socket''s internal file handle.', "
" IP VARCHAR(64) not null comment 'Client IP address. Blank for Unix socket file, otherwise an IPv4 or IPv6 address. Together with the PORT identifies the connection.', "
" PORT INTEGER not null comment 'TCP/IP port number, from 0 to 65535. Together with the IP identifies the connection.', "
2021-09-10 17:16:18 +03:00
" STATE ENUM('IDLE','ACTIVE') not null comment 'Socket status, either IDLE if waiting to receive a request from a client, or ACTIVE') " ) } ,
2022-07-29 14:48:01 +02:00
false , /* m_perpetual */
false , /* m_optional */
& m_share_state
2012-08-01 17:27:34 +03:00
} ;
PFS_engine_table * table_socket_instances : : create ( void )
{
return new table_socket_instances ( ) ;
}
2019-12-10 15:35:00 +01:00
ha_rows
table_socket_instances : : get_row_count ( void )
{
return global_socket_container . get_row_count ( ) ;
}
2012-08-01 17:27:34 +03:00
table_socket_instances : : table_socket_instances ( )
: PFS_engine_table ( & m_share , & m_pos ) ,
m_row_exists ( false ) , m_pos ( 0 ) , m_next_pos ( 0 )
{ }
void table_socket_instances : : reset_position ( void )
{
m_pos . m_index = 0 ;
m_next_pos . m_index = 0 ;
}
int table_socket_instances : : rnd_next ( void )
{
PFS_socket * pfs ;
2019-12-10 15:35:00 +01:00
m_pos . set_at ( & m_next_pos ) ;
PFS_socket_iterator it = global_socket_container . iterate ( m_pos . m_index ) ;
pfs = it . scan_next ( & m_pos . m_index ) ;
if ( pfs ! = NULL )
2012-08-01 17:27:34 +03:00
{
2019-12-10 15:35:00 +01:00
make_row ( pfs ) ;
m_next_pos . set_after ( & m_pos ) ;
return 0 ;
2012-08-01 17:27:34 +03:00
}
return HA_ERR_END_OF_FILE ;
}
int table_socket_instances : : rnd_pos ( const void * pos )
{
PFS_socket * pfs ;
set_position ( pos ) ;
2019-12-10 15:35:00 +01:00
pfs = global_socket_container . get ( m_pos . m_index ) ;
if ( pfs ! = NULL )
{
make_row ( pfs ) ;
return 0 ;
}
2012-08-01 17:27:34 +03:00
2019-12-10 15:35:00 +01:00
return HA_ERR_RECORD_DELETED ;
2012-08-01 17:27:34 +03:00
}
void table_socket_instances : : make_row ( PFS_socket * pfs )
{
2019-12-10 15:35:00 +01:00
pfs_optimistic_state lock ;
2012-08-01 17:27:34 +03:00
PFS_socket_class * safe_class ;
m_row_exists = false ;
/* Protect this reader against a socket delete */
pfs - > m_lock . begin_optimistic_lock ( & lock ) ;
safe_class = sanitize_socket_class ( pfs - > m_class ) ;
if ( unlikely ( safe_class = = NULL ) )
return ;
/** Extract ip address and port from raw address */
m_row . m_ip_length = pfs_get_socket_address ( m_row . m_ip , sizeof ( m_row . m_ip ) ,
& m_row . m_port ,
& pfs - > m_sock_addr , pfs - > m_addr_len ) ;
m_row . m_event_name = safe_class - > m_name ;
m_row . m_event_name_length = safe_class - > m_name_length ;
m_row . m_identity = pfs - > m_identity ;
m_row . m_fd = pfs - > m_fd ;
m_row . m_state = ( pfs - > m_idle ? PSI_SOCKET_STATE_IDLE
: PSI_SOCKET_STATE_ACTIVE ) ;
PFS_thread * safe_thread = sanitize_thread ( pfs - > m_thread_owner ) ;
if ( safe_thread ! = NULL )
{
m_row . m_thread_id = safe_thread - > m_thread_internal_id ;
m_row . m_thread_id_set = true ;
}
else
m_row . m_thread_id_set = false ;
if ( pfs - > m_lock . end_optimistic_lock ( & lock ) )
m_row_exists = true ;
}
int table_socket_instances : : read_row_values ( TABLE * table ,
unsigned char * buf ,
Field * * fields ,
bool read_all )
{
Field * f ;
if ( unlikely ( ! m_row_exists ) )
return HA_ERR_RECORD_DELETED ;
/* Set the null bits */
2021-05-03 11:21:56 +02:00
assert ( table - > s - > null_bytes = = 1 ) ;
2012-08-01 17:27:34 +03:00
buf [ 0 ] = 0 ;
for ( ; ( f = * fields ) ; fields + + )
{
if ( read_all | | bitmap_is_set ( table - > read_set , f - > field_index ) )
{
switch ( f - > field_index )
{
case 0 : /* EVENT_NAME */
set_field_varchar_utf8 ( f , m_row . m_event_name , m_row . m_event_name_length ) ;
break ;
case 1 : /* OBJECT_INSTANCE_BEGIN */
set_field_ulonglong ( f , ( intptr ) m_row . m_identity ) ;
break ;
case 2 : /* THREAD_ID */
if ( m_row . m_thread_id_set )
2013-03-26 00:03:13 +02:00
set_field_ulonglong ( f , m_row . m_thread_id ) ;
2012-08-01 17:27:34 +03:00
else
f - > set_null ( ) ;
break ;
case 3 : /* SOCKET_ID */
set_field_ulong ( f , m_row . m_fd ) ;
break ;
case 4 : /* IP */
set_field_varchar_utf8 ( f , m_row . m_ip , m_row . m_ip_length ) ;
break ;
case 5 : /* PORT */
set_field_ulong ( f , m_row . m_port ) ;
break ;
case 6 : /* STATE */
set_field_enum ( f , m_row . m_state ) ;
break ;
default :
2021-05-03 11:21:56 +02:00
assert ( false ) ;
2012-08-01 17:27:34 +03:00
}
}
}
return 0 ;
}