Lines Matching refs:conn

127 mysqlnd_local_infile_default(MYSQLND_CONN_DATA * conn)  in mysqlnd_local_infile_default()  argument
129 conn->infile.local_infile_init = mysqlnd_local_infile_init; in mysqlnd_local_infile_default()
130 conn->infile.local_infile_read = mysqlnd_local_infile_read; in mysqlnd_local_infile_default()
131 conn->infile.local_infile_error = mysqlnd_local_infile_error; in mysqlnd_local_infile_default()
132 conn->infile.local_infile_end = mysqlnd_local_infile_end; in mysqlnd_local_infile_default()
142 mysqlnd_handle_local_infile(MYSQLND_CONN_DATA * conn, const char * const filename, zend_bool * is_w… in mysqlnd_handle_local_infile() argument
152 MYSQLND_PFC * net = conn->protocol_frame_codec; in mysqlnd_handle_local_infile()
153 MYSQLND_VIO * vio = conn->vio; in mysqlnd_handle_local_infile()
157 if (!(conn->options->flags & CLIENT_LOCAL_FILES)) { in mysqlnd_handle_local_infile()
159 SET_CLIENT_ERROR(conn->error_info, CR_UNKNOWN_ERROR, UNKNOWN_SQLSTATE, in mysqlnd_handle_local_infile()
162 ret = net->data->m.send(net, vio, empty_packet, 0, conn->stats, conn->error_info); in mysqlnd_handle_local_infile()
167 infile = conn->infile; in mysqlnd_handle_local_infile()
175 char tmp_buf[sizeof(conn->error_info->error)]; in mysqlnd_handle_local_infile()
180 SET_CLIENT_ERROR(conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); in mysqlnd_handle_local_infile()
182 ret = net->data->m.send(net, vio, empty_packet, 0, conn->stats, conn->error_info); in mysqlnd_handle_local_infile()
188 if ((ret = net->data->m.send(net, vio, buf, bufsize, conn->stats, conn->error_info)) == 0) { in mysqlnd_handle_local_infile()
190 SET_CLIENT_ERROR(conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); in mysqlnd_handle_local_infile()
196 if ((ret = net->data->m.send(net, vio, empty_packet, 0, conn->stats, conn->error_info)) == 0) { in mysqlnd_handle_local_infile()
197 SET_CLIENT_ERROR(conn->error_info, CR_SERVER_LOST, UNKNOWN_SQLSTATE, lost_conn); in mysqlnd_handle_local_infile()
203 char tmp_buf[sizeof(conn->error_info->error)]; in mysqlnd_handle_local_infile()
208 SET_CLIENT_ERROR(conn->error_info, tmp_error_no, UNKNOWN_SQLSTATE, tmp_buf); in mysqlnd_handle_local_infile()
216 if (FAIL == conn->payload_decoder_factory->m.send_command_handle_response( in mysqlnd_handle_local_infile()
217 conn->payload_decoder_factory, in mysqlnd_handle_local_infile()
219 conn->error_info, in mysqlnd_handle_local_infile()
220 conn->upsert_status, in mysqlnd_handle_local_infile()
221 &conn->last_message)) { in mysqlnd_handle_local_infile()
225 (*conn->infile.local_infile_end)(info); in mysqlnd_handle_local_infile()