Lines Matching refs:net
86 MYSQLND_METHOD(mysqlnd_net, network_read_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, co… in MYSQLND_METHOD()
90 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD()
98 net_stream->chunk_size = MIN(to_read, net->data->options.net_read_buffer_size); in MYSQLND_METHOD()
117 MYSQLND_METHOD(mysqlnd_net, network_write_ex)(MYSQLND_NET * const net, const zend_uchar * const buf… in MYSQLND_METHOD()
123 ret = php_stream_write(net->data->m.get_stream(net), (char *)buffer, count); in MYSQLND_METHOD()
131 MYSQLND_METHOD(mysqlnd_net, open_pipe)(MYSQLND_NET * const net, const char * const scheme, const si… in MYSQLND_METHOD()
171 MYSQLND_METHOD(mysqlnd_net, open_tcp_or_unix)(MYSQLND_NET * const net, const char * const scheme, c… in MYSQLND_METHOD()
191 net->data->stream = NULL; in MYSQLND_METHOD()
194 hashed_details_len = mnd_sprintf(&hashed_details, 0, "%p", net); in MYSQLND_METHOD()
198 if (net->data->options.timeout_connect) { in MYSQLND_METHOD()
199 tv.tv_sec = net->data->options.timeout_connect; in MYSQLND_METHOD()
205 hashed_details, (net->data->options.timeout_connect) ? &tv : NULL, in MYSQLND_METHOD()
267 MYSQLND_METHOD(mysqlnd_net, post_connect_set_opt)(MYSQLND_NET * const net, in MYSQLND_METHOD()
271 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD()
274 if (net->data->options.timeout_read) { in MYSQLND_METHOD()
276 DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read); in MYSQLND_METHOD()
277 tv.tv_sec = net->data->options.timeout_read; in MYSQLND_METHOD()
297 MYSQLND_METHOD(mysqlnd_net, get_open_stream)(MYSQLND_NET * const net, const char * const scheme, co… in MYSQLND_METHOD()
303 ret = net->data->m.open_pipe; in MYSQLND_METHOD()
308 ret = net->data->m.open_tcp_or_unix; in MYSQLND_METHOD()
322 MYSQLND_METHOD(mysqlnd_net, connect_ex)(MYSQLND_NET * const net, const char * const scheme, const s… in MYSQLND_METHOD()
330 net->packet_no = net->compressed_envelope_packet_no = 0; in MYSQLND_METHOD()
332 net->data->m.close_stream(net, conn_stats, error_info); in MYSQLND_METHOD()
334 open_stream = net->data->m.get_open_stream(net, scheme, scheme_len, error_info); in MYSQLND_METHOD()
336 …php_stream * net_stream = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info); in MYSQLND_METHOD()
338 (void) net->data->m.set_stream(net, net_stream); in MYSQLND_METHOD()
339 net->data->m.post_connect_set_opt(net, scheme, scheme_len, conn_stats, error_info); in MYSQLND_METHOD()
371 MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, const size… in MYSQLND_METHOD()
383 DBG_INF_FMT("count=" MYSQLND_SZ_T_SPEC " compression=%u", count, net->data->compressed); in MYSQLND_METHOD()
385 if (net->data->compressed == TRUE) { in MYSQLND_METHOD()
395 DBG_INF_FMT("compressed_envelope_packet_no=%u", net->compressed_envelope_packet_no); in MYSQLND_METHOD()
396 DBG_INF_FMT("packet_no=%u", net->packet_no); in MYSQLND_METHOD()
398 if (net->data->compressed == TRUE) { in MYSQLND_METHOD()
406 int1store(uncompressed_payload + 3, net->packet_no); in MYSQLND_METHOD()
407 …if (PASS == net->data->m.encode((compress_buf + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE), &tm… in MYSQLND_METHOD()
420 int1store(compress_buf + 3, net->packet_no); in MYSQLND_METHOD()
422 …bytes_sent = net->data->m.network_write_ex(net, compress_buf, payload_size + MYSQLND_HEADER_SIZE +… in MYSQLND_METHOD()
424 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
429 int error = net->data->m.decode(decompressed_data, decompressed_size, in MYSQLND_METHOD()
453 int1store(p + 3, net->packet_no); in MYSQLND_METHOD()
454 …bytes_sent = net->data->m.network_write_ex(net, p, to_be_sent + MYSQLND_HEADER_SIZE, conn_stats, e… in MYSQLND_METHOD()
456 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
458 net->packet_no++; in MYSQLND_METHOD()
472 DBG_INF_FMT("packet_size="MYSQLND_SZ_T_SPEC" packet_no=%u", left, net->packet_no); in MYSQLND_METHOD()
561 …(MYSQLND_NET * net, size_t net_payload_size, MYSQLND_STATS * conn_stats, MYSQLND_ERROR_INFO * erro… in MYSQLND_METHOD()
570 …if (FAIL == net->data->m.network_read_ex(net, comp_header, COMPRESSED_HEADER_SIZE, conn_stats, err… in MYSQLND_METHOD()
580 …if (FAIL == net->data->m.network_read_ex(net, compressed_data, net_payload_size, conn_stats, error… in MYSQLND_METHOD()
584 net->uncompressed_data = mysqlnd_create_read_buffer(decompressed_size); in MYSQLND_METHOD()
585 …retval = net->data->m.decode(net->uncompressed_data->data, decompressed_size, compressed_data, net… in MYSQLND_METHOD()
591 net->uncompressed_data = mysqlnd_create_read_buffer(net_payload_size); in MYSQLND_METHOD()
592 …if (FAIL == net->data->m.network_read_ex(net, net->uncompressed_data->data, net_payload_size, conn… in MYSQLND_METHOD()
660 MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, const s… in MYSQLND_METHOD()
668 if (net->data->compressed) { in MYSQLND_METHOD()
669 if (net->uncompressed_data) { in MYSQLND_METHOD()
670 …size_t to_read_from_buffer = MIN(net->uncompressed_data->bytes_left(net->uncompressed_data), to_re… in MYSQLND_METHOD()
673 net->uncompressed_data->read(net->uncompressed_data, to_read_from_buffer, (zend_uchar *) p); in MYSQLND_METHOD()
678 if (TRUE == net->uncompressed_data->is_empty(net->uncompressed_data)) { in MYSQLND_METHOD()
680 net->uncompressed_data->free_buffer(&net->uncompressed_data); in MYSQLND_METHOD()
688 …if (FAIL == net->data->m.network_read_ex(net, net_header, MYSQLND_HEADER_SIZE, conn_stats, error_i… in MYSQLND_METHOD()
693 if (net->compressed_envelope_packet_no != packet_no) { in MYSQLND_METHOD()
695 net->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
698 net->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
701 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
706 …net->data->m.read_compressed_packet_from_stream_and_fill_read_buffer(net, net_payload_size, conn_s… in MYSQLND_METHOD()
714 DBG_RETURN(net->data->m.receive_ex(net, p, to_read, conn_stats, error_info)); in MYSQLND_METHOD()
719 DBG_RETURN(net->data->m.network_read_ex(net, p, to_read, conn_stats, error_info)); in MYSQLND_METHOD()
726 MYSQLND_METHOD(mysqlnd_net, set_client_option)(MYSQLND_NET * const net, enum mysqlnd_option option,… in MYSQLND_METHOD()
736 net->cmd_buffer.length = *(unsigned int*) value; in MYSQLND_METHOD()
737 DBG_INF_FMT("new_length="MYSQLND_SZ_T_SPEC, net->cmd_buffer.length); in MYSQLND_METHOD()
738 if (!net->cmd_buffer.buffer) { in MYSQLND_METHOD()
739 net->cmd_buffer.buffer = mnd_pemalloc(net->cmd_buffer.length, net->persistent); in MYSQLND_METHOD()
741 …net->cmd_buffer.buffer = mnd_perealloc(net->cmd_buffer.buffer, net->cmd_buffer.length, net->persis… in MYSQLND_METHOD()
746 net->data->options.net_read_buffer_size = *(unsigned int*) value; in MYSQLND_METHOD()
747 DBG_INF_FMT("new_length="MYSQLND_SZ_T_SPEC, net->data->options.net_read_buffer_size); in MYSQLND_METHOD()
751 net->data->options.timeout_connect = *(unsigned int*) value; in MYSQLND_METHOD()
755 zend_bool pers = net->persistent; in MYSQLND_METHOD()
756 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
757 mnd_pefree(net->data->options.ssl_key, pers); in MYSQLND_METHOD()
759 net->data->options.ssl_key = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
764 zend_bool pers = net->persistent; in MYSQLND_METHOD()
765 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
766 mnd_pefree(net->data->options.ssl_cert, pers); in MYSQLND_METHOD()
768 net->data->options.ssl_cert = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
773 zend_bool pers = net->persistent; in MYSQLND_METHOD()
774 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
775 mnd_pefree(net->data->options.ssl_ca, pers); in MYSQLND_METHOD()
777 net->data->options.ssl_ca = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
782 zend_bool pers = net->persistent; in MYSQLND_METHOD()
783 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
784 mnd_pefree(net->data->options.ssl_capath, pers); in MYSQLND_METHOD()
786 net->data->options.ssl_capath = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
791 zend_bool pers = net->persistent; in MYSQLND_METHOD()
792 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
793 mnd_pefree(net->data->options.ssl_cipher, pers); in MYSQLND_METHOD()
795 net->data->options.ssl_cipher = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
800 zend_bool pers = net->persistent; in MYSQLND_METHOD()
801 if (net->data->options.ssl_passphrase) { in MYSQLND_METHOD()
802 mnd_pefree(net->data->options.ssl_passphrase, pers); in MYSQLND_METHOD()
804 net->data->options.ssl_passphrase = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
826 net->data->options.ssl_verify_peer = val; in MYSQLND_METHOD()
830 net->data->options.timeout_read = *(unsigned int*) value; in MYSQLND_METHOD()
834 net->data->options.timeout_write = *(unsigned int*) value; in MYSQLND_METHOD()
838 net->data->options.flags |= MYSQLND_NET_FLAG_USE_COMPRESSION; in MYSQLND_METHOD()
842 zend_bool pers = net->persistent; in MYSQLND_METHOD()
843 if (net->data->options.sha256_server_public_key) { in MYSQLND_METHOD()
844 mnd_pefree(net->data->options.sha256_server_public_key, pers); in MYSQLND_METHOD()
846 net->data->options.sha256_server_public_key = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
858 MYSQLND_METHOD(mysqlnd_net, consume_uneaten_data)(MYSQLND_NET * const net, enum php_mysqlnd_server_… in MYSQLND_METHOD()
871 php_stream * net_stream = net->data->get_stream(net); in MYSQLND_METHOD()
890 bytes_consumed, mysqlnd_command_to_text[net->last_command]); in MYSQLND_METHOD()
893 bytes_consumed, mysqlnd_command_to_text[net->last_command]); in MYSQLND_METHOD()
896 net->last_command = cmd; in MYSQLND_METHOD()
910 MYSQLND_METHOD(mysqlnd_net, enable_ssl)(MYSQLND_NET * const net) in MYSQLND_METHOD()
914 php_stream * net_stream = net->data->m.get_stream(net); in MYSQLND_METHOD()
922 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
924 ZVAL_STRING(&key_zval, net->data->options.ssl_key); in MYSQLND_METHOD()
929 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
931 ZVAL_STRING(&cert_zval, net->data->options.ssl_cert); in MYSQLND_METHOD()
933 if (!net->data->options.ssl_key) { in MYSQLND_METHOD()
939 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
941 ZVAL_STRING(&cafile_zval, net->data->options.ssl_ca); in MYSQLND_METHOD()
945 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
947 ZVAL_STRING(&capath_zval, net->data->options.ssl_capath); in MYSQLND_METHOD()
952 if (net->data->options.ssl_passphrase) { in MYSQLND_METHOD()
954 ZVAL_STRING(&passphrase_zval, net->data->options.ssl_passphrase); in MYSQLND_METHOD()
959 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
961 ZVAL_STRING(&cipher_zval, net->data->options.ssl_cipher); in MYSQLND_METHOD()
970 if (net->data->options.ssl_verify_peer == MYSQLND_SSL_PEER_DEFAULT) { in MYSQLND_METHOD()
971 …net->data->options.ssl_verify_peer = any_flag? MYSQLND_SSL_PEER_DEFAULT_ACTION:MYSQLND_SSL_PEER_DO… in MYSQLND_METHOD()
974 verify = net->data->options.ssl_verify_peer == MYSQLND_SSL_PEER_VERIFY? TRUE:FALSE; in MYSQLND_METHOD()
980 if (net->data->options.ssl_verify_peer == MYSQLND_SSL_PEER_DONT_VERIFY) { in MYSQLND_METHOD()
997 net->data->ssl = TRUE; in MYSQLND_METHOD()
1011 if (net->data->options.timeout_read) { in MYSQLND_METHOD()
1013 DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read); in MYSQLND_METHOD()
1014 tv.tv_sec = net->data->options.timeout_read; in MYSQLND_METHOD()
1031 MYSQLND_METHOD(mysqlnd_net, disable_ssl)(MYSQLND_NET * const net) in MYSQLND_METHOD()
1041 MYSQLND_METHOD(mysqlnd_net, free_contents)(MYSQLND_NET * net) in MYSQLND_METHOD()
1043 zend_bool pers = net->persistent; in MYSQLND_METHOD()
1047 if (net->uncompressed_data) { in MYSQLND_METHOD()
1048 net->uncompressed_data->free_buffer(&net->uncompressed_data); in MYSQLND_METHOD()
1051 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
1052 mnd_pefree(net->data->options.ssl_key, pers); in MYSQLND_METHOD()
1053 net->data->options.ssl_key = NULL; in MYSQLND_METHOD()
1055 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
1056 mnd_pefree(net->data->options.ssl_cert, pers); in MYSQLND_METHOD()
1057 net->data->options.ssl_cert = NULL; in MYSQLND_METHOD()
1059 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
1060 mnd_pefree(net->data->options.ssl_ca, pers); in MYSQLND_METHOD()
1061 net->data->options.ssl_ca = NULL; in MYSQLND_METHOD()
1063 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
1064 mnd_pefree(net->data->options.ssl_capath, pers); in MYSQLND_METHOD()
1065 net->data->options.ssl_capath = NULL; in MYSQLND_METHOD()
1067 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
1068 mnd_pefree(net->data->options.ssl_cipher, pers); in MYSQLND_METHOD()
1069 net->data->options.ssl_cipher = NULL; in MYSQLND_METHOD()
1071 if (net->data->options.sha256_server_public_key) { in MYSQLND_METHOD()
1072 mnd_pefree(net->data->options.sha256_server_public_key, pers); in MYSQLND_METHOD()
1073 net->data->options.sha256_server_public_key = NULL; in MYSQLND_METHOD()
1083 MYSQLND_METHOD(mysqlnd_net, close_stream)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYS… in MYSQLND_METHOD()
1087 if (net && (net_stream = net->data->m.get_stream(net))) { in MYSQLND_METHOD()
1088 zend_bool pers = net->persistent; in MYSQLND_METHOD()
1103 (void) net->data->m.set_stream(net, NULL); in MYSQLND_METHOD()
1113 MYSQLND_METHOD(mysqlnd_net, init)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYSQLND_ERR… in MYSQLND_METHOD()
1119 net->data->m.set_client_option(net, MYSQLND_OPT_NET_CMD_BUFFER_SIZE, (char *) &buf_size); in MYSQLND_METHOD()
1122 net->data->m.set_client_option(net, MYSQLND_OPT_NET_READ_BUFFER_SIZE, (char *)&buf_size); in MYSQLND_METHOD()
1125 net->data->m.set_client_option(net, MYSQL_OPT_READ_TIMEOUT, (char *)&buf_size); in MYSQLND_METHOD()
1134 MYSQLND_METHOD(mysqlnd_net, dtor)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYSQLND_ERR… in MYSQLND_METHOD()
1137 if (net) { in MYSQLND_METHOD()
1138 net->data->m.free_contents(net); in MYSQLND_METHOD()
1139 net->data->m.close_stream(net, stats, error_info); in MYSQLND_METHOD()
1141 if (net->cmd_buffer.buffer) { in MYSQLND_METHOD()
1143 mnd_pefree(net->cmd_buffer.buffer, net->persistent); in MYSQLND_METHOD()
1144 net->cmd_buffer.buffer = NULL; in MYSQLND_METHOD()
1147 mnd_pefree(net->data, net->data->persistent); in MYSQLND_METHOD()
1148 mnd_pefree(net, net->persistent); in MYSQLND_METHOD()
1157 MYSQLND_METHOD(mysqlnd_net, get_stream)(const MYSQLND_NET * const net) in MYSQLND_METHOD()
1160 DBG_INF_FMT("%p", net? net->data->stream:NULL); in MYSQLND_METHOD()
1161 DBG_RETURN(net? net->data->stream:NULL); in MYSQLND_METHOD()
1168 MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream) in MYSQLND_METHOD()
1172 if (net) { in MYSQLND_METHOD()
1173 net->data->stream = net_stream; in MYSQLND_METHOD()
1174 ret = net->data->stream; in MYSQLND_METHOD()
1220 MYSQLND_NET * net; in mysqlnd_net_init() local
1222 …net = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).get_io_channel(persistent, stats, er… in mysqlnd_net_init()
1223 DBG_RETURN(net); in mysqlnd_net_init()
1230 mysqlnd_net_free(MYSQLND_NET * const net, MYSQLND_STATS * stats, MYSQLND_ERROR_INFO * error_info) in mysqlnd_net_free() argument
1233 if (net) { in mysqlnd_net_free()
1234 net->data->m.dtor(net, stats, error_info); in mysqlnd_net_free()
