Lines Matching refs:data
36 pfc->data->packet_no = pfc->data->compressed_envelope_packet_no = 0; in MYSQLND_METHOD()
60 …if (PASS == pfc->data->m.encode((compress_buf + COMPRESSED_HEADER_SIZE + MYSQLND_HEADER_SIZE), &tm… in write_compressed_packet()
72 int1store(compress_buf + 3, pfc->data->compressed_envelope_packet_no); in write_compressed_packet()
75 …ssize_t bytes_sent = vio->data->m.network_write(vio, compress_buf, payload_size + MYSQLND_HEADER_S… in write_compressed_packet()
76 pfc->data->compressed_envelope_packet_no++; in write_compressed_packet()
81 int error = pfc->data->m.decode(decompressed_data, decompressed_size, in write_compressed_packet()
128 DBG_INF_FMT("count=%zu compression=%u", count, pfc->data->compressed); in MYSQLND_METHOD()
130 if (pfc->data->compressed == TRUE) { in MYSQLND_METHOD()
140 DBG_INF_FMT("compressed_envelope_packet_no=%u", pfc->data->compressed_envelope_packet_no); in MYSQLND_METHOD()
141 DBG_INF_FMT("packet_no=%u", pfc->data->packet_no); in MYSQLND_METHOD()
143 if (pfc->data->compressed == TRUE) { in MYSQLND_METHOD()
147 int1store(uncompressed_payload + 3, pfc->data->packet_no); in MYSQLND_METHOD()
171 int1store(p + 3, pfc->data->packet_no); in MYSQLND_METHOD()
172 …bytes_sent = vio->data->m.network_write(vio, p, to_be_sent + MYSQLND_HEADER_SIZE, conn_stats, erro… in MYSQLND_METHOD()
174 pfc->data->compressed_envelope_packet_no++; in MYSQLND_METHOD()
176 pfc->data->packet_no++; in MYSQLND_METHOD()
190 DBG_INF_FMT("packet_size=%zu packet_no=%u", left, pfc->data->packet_no); in MYSQLND_METHOD()
226 …if (FAIL == vio->data->m.network_read(vio, comp_header, COMPRESSED_HEADER_SIZE, conn_stats, error_… in MYSQLND_METHOD()
236 …if (FAIL == vio->data->m.network_read(vio, compressed_data, net_payload_size, conn_stats, error_in… in MYSQLND_METHOD()
240 pfc->data->uncompressed_data = mysqlnd_create_read_buffer(decompressed_size); in MYSQLND_METHOD()
241 …retval = pfc->data->m.decode(pfc->data->uncompressed_data->data, decompressed_size, compressed_dat… in MYSQLND_METHOD()
247 pfc->data->uncompressed_data = mysqlnd_create_read_buffer(net_payload_size); in MYSQLND_METHOD()
248 …if (FAIL == vio->data->m.network_read(vio, pfc->data->uncompressed_data->data, net_payload_size, c… in MYSQLND_METHOD()
324 if (pfc->data->compressed) { in MYSQLND_METHOD()
325 if (pfc->data->uncompressed_data) { in MYSQLND_METHOD()
326 …size_t to_read_from_buffer = MIN(pfc->data->uncompressed_data->bytes_left(pfc->data->uncompressed_… in MYSQLND_METHOD()
329 …pfc->data->uncompressed_data->read(pfc->data->uncompressed_data, to_read_from_buffer, (zend_uchar … in MYSQLND_METHOD()
334 if (TRUE == pfc->data->uncompressed_data->is_empty(pfc->data->uncompressed_data)) { in MYSQLND_METHOD()
336 pfc->data->uncompressed_data->free_buffer(&pfc->data->uncompressed_data); in MYSQLND_METHOD()
344 …if (FAIL == vio->data->m.network_read(vio, net_header, MYSQLND_HEADER_SIZE, conn_stats, error_info… in MYSQLND_METHOD()
349 if (pfc->data->compressed_envelope_packet_no != packet_no) { in MYSQLND_METHOD()
351 pfc->data->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
354 pfc->data->compressed_envelope_packet_no, packet_no, net_payload_size); in MYSQLND_METHOD()
357 pfc->data->compressed_envelope_packet_no++; in MYSQLND_METHOD()
362 …pfc->data->m.read_compressed_packet_from_stream_and_fill_read_buffer(pfc, vio, net_payload_size, c… in MYSQLND_METHOD()
370 DBG_RETURN(pfc->data->m.receive(pfc, vio, p, to_read, conn_stats, error_info)); in MYSQLND_METHOD()
375 DBG_RETURN(vio->data->m.network_read(vio, p, to_read, conn_stats, error_info)); in MYSQLND_METHOD()
388 pfc->data->flags |= MYSQLND_PROTOCOL_FLAG_USE_COMPRESSION; in MYSQLND_METHOD()
392 if (pfc->data->sha256_server_public_key) { in MYSQLND_METHOD()
393 mnd_pefree(pfc->data->sha256_server_public_key, pers); in MYSQLND_METHOD()
395 pfc->data->sha256_server_public_key = value? mnd_pestrdup(value, pers) : NULL; in MYSQLND_METHOD()
427 if (pfc->data->uncompressed_data) { in MYSQLND_METHOD()
428 pfc->data->uncompressed_data->free_buffer(&pfc->data->uncompressed_data); in MYSQLND_METHOD()
431 if (pfc->data->sha256_server_public_key) { in MYSQLND_METHOD()
432 mnd_pefree(pfc->data->sha256_server_public_key, pfc->persistent); in MYSQLND_METHOD()
433 pfc->data->sha256_server_public_key = NULL; in MYSQLND_METHOD()
449 pfc->data->m.set_client_option(pfc, MYSQLND_OPT_NET_CMD_BUFFER_SIZE, (char *) &buf_size); in MYSQLND_METHOD()
462 pfc->data->m.free_contents(pfc); in MYSQLND_METHOD()
519 pfc->data->m.dtor(pfc, stats, error_info); in mysqlnd_pfc_free()
