Lines Matching refs:net
66 MYSQLND_METHOD(mysqlnd_net, network_read_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, co… in MYSQLND_METHOD()
70 php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); in MYSQLND_METHOD()
78 net_stream->chunk_size = MIN(to_read, net->data->options.net_read_buffer_size); in MYSQLND_METHOD()
97 MYSQLND_METHOD(mysqlnd_net, network_write_ex)(MYSQLND_NET * const net, const zend_uchar * const buf… in MYSQLND_METHOD()
102 ret = php_stream_write(net->data->m.get_stream(net TSRMLS_CC), (char *)buffer, count); in MYSQLND_METHOD()
109 MYSQLND_METHOD(mysqlnd_net, open_pipe)(MYSQLND_NET * const net, const char * const scheme, const si… in MYSQLND_METHOD()
147 MYSQLND_METHOD(mysqlnd_net, open_tcp_or_unix)(MYSQLND_NET * const net, const char * const scheme, c… in MYSQLND_METHOD()
166 net->data->stream = NULL; in MYSQLND_METHOD()
169 hashed_details_len = mnd_sprintf(&hashed_details, 0, "%p", net); in MYSQLND_METHOD()
173 if (net->data->options.timeout_connect) { in MYSQLND_METHOD()
174 tv.tv_sec = net->data->options.timeout_connect; in MYSQLND_METHOD()
180 hashed_details, (net->data->options.timeout_connect) ? &tv : NULL, in MYSQLND_METHOD()
236 MYSQLND_METHOD(mysqlnd_net, post_connect_set_opt)(MYSQLND_NET * const net, in MYSQLND_METHOD()
240 php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); in MYSQLND_METHOD()
243 if (net->data->options.timeout_read) { in MYSQLND_METHOD()
245 DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read); in MYSQLND_METHOD()
246 tv.tv_sec = net->data->options.timeout_read; in MYSQLND_METHOD()
264 MYSQLND_METHOD(mysqlnd_net, get_open_stream)(MYSQLND_NET * const net, const char * const scheme, co… in MYSQLND_METHOD()
270 ret = net->data->m.open_pipe; in MYSQLND_METHOD()
275 ret = net->data->m.open_tcp_or_unix; in MYSQLND_METHOD()
289 MYSQLND_METHOD(mysqlnd_net, connect_ex)(MYSQLND_NET * const net, const char * const scheme, const s… in MYSQLND_METHOD()
297 net->packet_no = net->compressed_envelope_packet_no = 0; in MYSQLND_METHOD()
299 net->data->m.close_stream(net, conn_stats, error_info TSRMLS_CC); in MYSQLND_METHOD()
301 open_stream = net->data->m.get_open_stream(net, scheme, scheme_len, error_info TSRMLS_CC); in MYSQLND_METHOD()
303 …php_stream * net_stream = open_stream(net, scheme, scheme_len, persistent, conn_stats, error_info … in MYSQLND_METHOD()
305 (void) net->data->m.set_stream(net, net_stream TSRMLS_CC); in MYSQLND_METHOD()
306 net->data->m.post_connect_set_opt(net, scheme, scheme_len, conn_stats, error_info TSRMLS_CC); in MYSQLND_METHOD()
338 MYSQLND_METHOD(mysqlnd_net, send_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, const size… in MYSQLND_METHOD()
350 DBG_INF_FMT("count=" MYSQLND_SZ_T_SPEC " compression=%u", count, net->data->compressed); in MYSQLND_METHOD()
352 if (net->data->compressed == TRUE) { in MYSQLND_METHOD()
361 if (net->data->compressed == TRUE) { in MYSQLND_METHOD()
369 int1store(uncompressed_payload + 3, net->packet_no); in MYSQLND_METHOD()
370 …if (PASS == net->data->m.encode((compress_buf + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE), &tm… in MYSQLND_METHOD()
383 int1store(compress_buf + 3, net->packet_no); in MYSQLND_METHOD()
385 …bytes_sent = net->data->m.network_write_ex(net, compress_buf, payload_size + MYSQLND_HEADER_SIZE +… in MYSQLND_METHOD()
387 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
392 int error = net->data->m.decode(decompressed_data, decompressed_size, in MYSQLND_METHOD()
416 int1store(p + 3, net->packet_no); in MYSQLND_METHOD()
417 …bytes_sent = net->data->m.network_write_ex(net, p, to_be_sent + MYSQLND_HEADER_SIZE, conn_stats, e… in MYSQLND_METHOD()
419 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
421 net->packet_no++; in MYSQLND_METHOD()
435 DBG_INF_FMT("packet_size="MYSQLND_SZ_T_SPEC" packet_no=%u", left, net->packet_no); in MYSQLND_METHOD()
524 …(MYSQLND_NET * net, size_t net_payload_size, MYSQLND_STATS * conn_stats, MYSQLND_ERROR_INFO * erro… in MYSQLND_METHOD()
533 …if (FAIL == net->data->m.network_read_ex(net, comp_header, COMPRESSED_HEADER_SIZE, conn_stats, err… in MYSQLND_METHOD()
543 …if (FAIL == net->data->m.network_read_ex(net, compressed_data, net_payload_size, conn_stats, error… in MYSQLND_METHOD()
547 net->uncompressed_data = mysqlnd_create_read_buffer(decompressed_size TSRMLS_CC); in MYSQLND_METHOD()
548 …retval = net->data->m.decode(net->uncompressed_data->data, decompressed_size, compressed_data, net… in MYSQLND_METHOD()
554 net->uncompressed_data = mysqlnd_create_read_buffer(net_payload_size TSRMLS_CC); in MYSQLND_METHOD()
555 …if (FAIL == net->data->m.network_read_ex(net, net->uncompressed_data->data, net_payload_size, conn… in MYSQLND_METHOD()
623 MYSQLND_METHOD(mysqlnd_net, receive_ex)(MYSQLND_NET * const net, zend_uchar * const buffer, const s… in MYSQLND_METHOD()
631 if (net->data->compressed) { in MYSQLND_METHOD()
632 if (net->uncompressed_data) { in MYSQLND_METHOD()
633 …size_t to_read_from_buffer = MIN(net->uncompressed_data->bytes_left(net->uncompressed_data), to_re… in MYSQLND_METHOD()
636 net->uncompressed_data->read(net->uncompressed_data, to_read_from_buffer, (zend_uchar *) p); in MYSQLND_METHOD()
641 if (TRUE == net->uncompressed_data->is_empty(net->uncompressed_data)) { in MYSQLND_METHOD()
643 net->uncompressed_data->free_buffer(&net->uncompressed_data TSRMLS_CC); in MYSQLND_METHOD()
651 …if (FAIL == net->data->m.network_read_ex(net, net_header, MYSQLND_HEADER_SIZE, conn_stats, error_i… in MYSQLND_METHOD()
656 if (net->compressed_envelope_packet_no != packet_no) { in MYSQLND_METHOD()
658 net->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
661 net->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
664 net->compressed_envelope_packet_no++; in MYSQLND_METHOD()
669 …net->data->m.read_compressed_packet_from_stream_and_fill_read_buffer(net, net_payload_size, conn_s… in MYSQLND_METHOD()
677 DBG_RETURN(net->data->m.receive_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC)); in MYSQLND_METHOD()
682 DBG_RETURN(net->data->m.network_read_ex(net, p, to_read, conn_stats, error_info TSRMLS_CC)); in MYSQLND_METHOD()
689 MYSQLND_METHOD(mysqlnd_net, set_client_option)(MYSQLND_NET * const net, enum mysqlnd_option option,… in MYSQLND_METHOD()
699 net->cmd_buffer.length = *(unsigned int*) value; in MYSQLND_METHOD()
700 DBG_INF_FMT("new_length="MYSQLND_SZ_T_SPEC, net->cmd_buffer.length); in MYSQLND_METHOD()
701 if (!net->cmd_buffer.buffer) { in MYSQLND_METHOD()
702 net->cmd_buffer.buffer = mnd_pemalloc(net->cmd_buffer.length, net->persistent); in MYSQLND_METHOD()
704 …net->cmd_buffer.buffer = mnd_perealloc(net->cmd_buffer.buffer, net->cmd_buffer.length, net->persis… in MYSQLND_METHOD()
709 net->data->options.net_read_buffer_size = *(unsigned int*) value; in MYSQLND_METHOD()
710 DBG_INF_FMT("new_length="MYSQLND_SZ_T_SPEC, net->data->options.net_read_buffer_size); in MYSQLND_METHOD()
714 net->data->options.timeout_connect = *(unsigned int*) value; in MYSQLND_METHOD()
718 zend_bool pers = net->persistent; in MYSQLND_METHOD()
719 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
720 mnd_pefree(net->data->options.ssl_key, pers); in MYSQLND_METHOD()
722 net->data->options.ssl_key = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
727 zend_bool pers = net->persistent; in MYSQLND_METHOD()
728 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
729 mnd_pefree(net->data->options.ssl_cert, pers); in MYSQLND_METHOD()
731 net->data->options.ssl_cert = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
736 zend_bool pers = net->persistent; in MYSQLND_METHOD()
737 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
738 mnd_pefree(net->data->options.ssl_ca, pers); in MYSQLND_METHOD()
740 net->data->options.ssl_ca = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
745 zend_bool pers = net->persistent; in MYSQLND_METHOD()
746 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
747 mnd_pefree(net->data->options.ssl_capath, pers); in MYSQLND_METHOD()
749 net->data->options.ssl_capath = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
754 zend_bool pers = net->persistent; in MYSQLND_METHOD()
755 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
756 mnd_pefree(net->data->options.ssl_cipher, pers); in MYSQLND_METHOD()
758 net->data->options.ssl_cipher = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
763 zend_bool pers = net->persistent; in MYSQLND_METHOD()
764 if (net->data->options.ssl_passphrase) { in MYSQLND_METHOD()
765 mnd_pefree(net->data->options.ssl_passphrase, pers); in MYSQLND_METHOD()
767 net->data->options.ssl_passphrase = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
771 net->data->options.ssl_verify_peer = value? ((*(zend_bool *)value)? TRUE:FALSE): FALSE; in MYSQLND_METHOD()
774 net->data->options.timeout_read = *(unsigned int*) value; in MYSQLND_METHOD()
778 net->data->options.timeout_write = *(unsigned int*) value; in MYSQLND_METHOD()
782 net->data->options.flags |= MYSQLND_NET_FLAG_USE_COMPRESSION; in MYSQLND_METHOD()
786 zend_bool pers = net->persistent; in MYSQLND_METHOD()
787 if (net->data->options.sha256_server_public_key) { in MYSQLND_METHOD()
788 mnd_pefree(net->data->options.sha256_server_public_key, pers); in MYSQLND_METHOD()
790 net->data->options.sha256_server_public_key = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
802 MYSQLND_METHOD(mysqlnd_net, consume_uneaten_data)(MYSQLND_NET * const net, enum php_mysqlnd_server_… in MYSQLND_METHOD()
815 php_stream * net_stream = net->data->get_stream(net TSRMLS_CC); in MYSQLND_METHOD()
834 bytes_consumed, mysqlnd_command_to_text[net->last_command]); in MYSQLND_METHOD()
837 bytes_consumed, mysqlnd_command_to_text[net->last_command]); in MYSQLND_METHOD()
840 net->last_command = cmd; in MYSQLND_METHOD()
854 MYSQLND_METHOD(mysqlnd_net, enable_ssl)(MYSQLND_NET * const net TSRMLS_DC) in MYSQLND_METHOD()
858 php_stream * net_stream = net->data->m.get_stream(net TSRMLS_CC); in MYSQLND_METHOD()
865 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
867 ZVAL_STRING(&key_zval, net->data->options.ssl_key, 0); in MYSQLND_METHOD()
870 if (net->data->options.ssl_verify_peer) { in MYSQLND_METHOD()
875 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
877 ZVAL_STRING(&cert_zval, net->data->options.ssl_cert, 0); in MYSQLND_METHOD()
879 if (!net->data->options.ssl_key) { in MYSQLND_METHOD()
883 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
885 ZVAL_STRING(&cafile_zval, net->data->options.ssl_ca, 0); in MYSQLND_METHOD()
888 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
890 ZVAL_STRING(&capath_zval, net->data->options.ssl_capath, 0); in MYSQLND_METHOD()
893 if (net->data->options.ssl_passphrase) { in MYSQLND_METHOD()
895 ZVAL_STRING(&passphrase_zval, net->data->options.ssl_passphrase, 0); in MYSQLND_METHOD()
898 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
900 ZVAL_STRING(&cipher_zval, net->data->options.ssl_cipher, 0); in MYSQLND_METHOD()
911 net->data->ssl = TRUE; in MYSQLND_METHOD()
921 if (net->data->options.timeout_read) { in MYSQLND_METHOD()
923 DBG_INF_FMT("setting %u as PHP_STREAM_OPTION_READ_TIMEOUT", net->data->options.timeout_read); in MYSQLND_METHOD()
924 tv.tv_sec = net->data->options.timeout_read; in MYSQLND_METHOD()
941 MYSQLND_METHOD(mysqlnd_net, disable_ssl)(MYSQLND_NET * const net TSRMLS_DC) in MYSQLND_METHOD()
951 MYSQLND_METHOD(mysqlnd_net, free_contents)(MYSQLND_NET * net TSRMLS_DC) in MYSQLND_METHOD()
953 zend_bool pers = net->persistent; in MYSQLND_METHOD()
957 if (net->uncompressed_data) { in MYSQLND_METHOD()
958 net->uncompressed_data->free_buffer(&net->uncompressed_data TSRMLS_CC); in MYSQLND_METHOD()
961 if (net->data->options.ssl_key) { in MYSQLND_METHOD()
962 mnd_pefree(net->data->options.ssl_key, pers); in MYSQLND_METHOD()
963 net->data->options.ssl_key = NULL; in MYSQLND_METHOD()
965 if (net->data->options.ssl_cert) { in MYSQLND_METHOD()
966 mnd_pefree(net->data->options.ssl_cert, pers); in MYSQLND_METHOD()
967 net->data->options.ssl_cert = NULL; in MYSQLND_METHOD()
969 if (net->data->options.ssl_ca) { in MYSQLND_METHOD()
970 mnd_pefree(net->data->options.ssl_ca, pers); in MYSQLND_METHOD()
971 net->data->options.ssl_ca = NULL; in MYSQLND_METHOD()
973 if (net->data->options.ssl_capath) { in MYSQLND_METHOD()
974 mnd_pefree(net->data->options.ssl_capath, pers); in MYSQLND_METHOD()
975 net->data->options.ssl_capath = NULL; in MYSQLND_METHOD()
977 if (net->data->options.ssl_cipher) { in MYSQLND_METHOD()
978 mnd_pefree(net->data->options.ssl_cipher, pers); in MYSQLND_METHOD()
979 net->data->options.ssl_cipher = NULL; in MYSQLND_METHOD()
981 if (net->data->options.sha256_server_public_key) { in MYSQLND_METHOD()
982 mnd_pefree(net->data->options.sha256_server_public_key, pers); in MYSQLND_METHOD()
983 net->data->options.sha256_server_public_key = NULL; in MYSQLND_METHOD()
993 MYSQLND_METHOD(mysqlnd_net, close_stream)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYS… in MYSQLND_METHOD()
997 if (net && (net_stream = net->data->m.get_stream(net TSRMLS_CC))) { in MYSQLND_METHOD()
998 zend_bool pers = net->persistent; in MYSQLND_METHOD()
1013 (void) net->data->m.set_stream(net, NULL TSRMLS_CC); in MYSQLND_METHOD()
1023 MYSQLND_METHOD(mysqlnd_net, init)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYSQLND_ERR… in MYSQLND_METHOD()
1029 net->data->m.set_client_option(net, MYSQLND_OPT_NET_CMD_BUFFER_SIZE, (char *) &buf_size TSRMLS_CC); in MYSQLND_METHOD()
1032 net->data->m.set_client_option(net, MYSQLND_OPT_NET_READ_BUFFER_SIZE, (char *)&buf_size TSRMLS_CC); in MYSQLND_METHOD()
1035 net->data->m.set_client_option(net, MYSQL_OPT_READ_TIMEOUT, (char *)&buf_size TSRMLS_CC); in MYSQLND_METHOD()
1044 MYSQLND_METHOD(mysqlnd_net, dtor)(MYSQLND_NET * const net, MYSQLND_STATS * const stats, MYSQLND_ERR… in MYSQLND_METHOD()
1047 if (net) { in MYSQLND_METHOD()
1048 net->data->m.free_contents(net TSRMLS_CC); in MYSQLND_METHOD()
1049 net->data->m.close_stream(net, stats, error_info TSRMLS_CC); in MYSQLND_METHOD()
1051 if (net->cmd_buffer.buffer) { in MYSQLND_METHOD()
1053 mnd_pefree(net->cmd_buffer.buffer, net->persistent); in MYSQLND_METHOD()
1054 net->cmd_buffer.buffer = NULL; in MYSQLND_METHOD()
1057 mnd_pefree(net->data, net->data->persistent); in MYSQLND_METHOD()
1058 mnd_pefree(net, net->persistent); in MYSQLND_METHOD()
1067 MYSQLND_METHOD(mysqlnd_net, get_stream)(const MYSQLND_NET * const net TSRMLS_DC) in MYSQLND_METHOD()
1070 DBG_INF_FMT("%p", net? net->data->stream:NULL); in MYSQLND_METHOD()
1071 DBG_RETURN(net? net->data->stream:NULL); in MYSQLND_METHOD()
1078 MYSQLND_METHOD(mysqlnd_net, set_stream)(MYSQLND_NET * const net, php_stream * net_stream TSRMLS_DC) in MYSQLND_METHOD()
1082 if (net) { in MYSQLND_METHOD()
1083 net->data->stream = net_stream; in MYSQLND_METHOD()
1084 ret = net->data->stream; in MYSQLND_METHOD()
1130 MYSQLND_NET * net; in mysqlnd_net_init() local
1132 …net = MYSQLND_CLASS_METHOD_TABLE_NAME(mysqlnd_object_factory).get_io_channel(persistent, stats, er… in mysqlnd_net_init()
1133 DBG_RETURN(net); in mysqlnd_net_init()
1140 mysqlnd_net_free(MYSQLND_NET * const net, MYSQLND_STATS * stats, MYSQLND_ERROR_INFO * error_info TS… in mysqlnd_net_free() argument
1143 if (net) { in mysqlnd_net_free()
1144 net->data->m.dtor(net, stats, error_info TSRMLS_CC); in mysqlnd_net_free()
