Lines Matching refs:row_packet

831 	MYSQLND_PACKET_ROW * row_packet;  in mysqlnd_stmt_fetch_row_unbuffered()  local
850 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_stmt_fetch_row_unbuffered()
855 row_packet->skip_extraction = stmt && stmt->result_bind? FALSE:TRUE; in mysqlnd_stmt_fetch_row_unbuffered()
864 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
867 if (!row_packet->skip_extraction) { in mysqlnd_stmt_fetch_row_unbuffered()
870 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_stmt_fetch_row_unbuffered()
871 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_stmt_fetch_row_unbuffered()
872 row_packet->fields = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
873 row_packet->row_buffer.ptr = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
877 row_packet->field_count, in mysqlnd_stmt_fetch_row_unbuffered()
878 row_packet->fields_metadata, in mysqlnd_stmt_fetch_row_unbuffered()
910 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_stmt_fetch_row_unbuffered()
911 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_stmt_fetch_row_unbuffered()
912 row_packet->row_buffer.ptr = NULL; in mysqlnd_stmt_fetch_row_unbuffered()
918 if (row_packet->error_info.error_no) { in mysqlnd_stmt_fetch_row_unbuffered()
919 COPY_CLIENT_ERROR(conn->error_info, row_packet->error_info); in mysqlnd_stmt_fetch_row_unbuffered()
921 COPY_CLIENT_ERROR(stmt->error_info, row_packet->error_info); in mysqlnd_stmt_fetch_row_unbuffered()
928 } else if (row_packet->eof) { in mysqlnd_stmt_fetch_row_unbuffered()
933 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_stmt_fetch_row_unbuffered()
934 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_stmt_fetch_row_unbuffered()
1000 MYSQLND_PACKET_ROW * row_packet; in mysqlnd_fetch_stmt_row_cursor() local
1016 if (!(row_packet = result->unbuf->row_packet)) { in mysqlnd_fetch_stmt_row_cursor()
1028 row_packet->skip_extraction = stmt->result_bind? FALSE:TRUE; in mysqlnd_fetch_stmt_row_cursor()
1031 if (PASS == (ret = PACKET_READ(conn, row_packet)) && !row_packet->eof) { in mysqlnd_fetch_stmt_row_cursor()
1035 if (!row_packet->skip_extraction) { in mysqlnd_fetch_stmt_row_cursor()
1038 result->unbuf->last_row_data = row_packet->fields; in mysqlnd_fetch_stmt_row_cursor()
1039 result->unbuf->last_row_buffer = row_packet->row_buffer; in mysqlnd_fetch_stmt_row_cursor()
1040 row_packet->fields = NULL; in mysqlnd_fetch_stmt_row_cursor()
1041 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1045 row_packet->field_count, in mysqlnd_fetch_stmt_row_cursor()
1046 row_packet->fields_metadata, in mysqlnd_fetch_stmt_row_cursor()
1081 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_fetch_stmt_row_cursor()
1082 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_fetch_stmt_row_cursor()
1083 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1086 ret = PACKET_READ(conn, row_packet); in mysqlnd_fetch_stmt_row_cursor()
1087 if (row_packet->row_buffer.ptr) { in mysqlnd_fetch_stmt_row_cursor()
1088 row_packet->result_set_memory_pool->free_chunk( in mysqlnd_fetch_stmt_row_cursor()
1089 row_packet->result_set_memory_pool, row_packet->row_buffer.ptr); in mysqlnd_fetch_stmt_row_cursor()
1090 row_packet->row_buffer.ptr = NULL; in mysqlnd_fetch_stmt_row_cursor()
1098 UPSERT_STATUS_SET_WARNINGS(stmt->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1099 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1101 UPSERT_STATUS_SET_SERVER_STATUS(stmt->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1102 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1104 result->unbuf->eof_reached = row_packet->eof; in mysqlnd_fetch_stmt_row_cursor()
1106 UPSERT_STATUS_SET_WARNINGS(stmt->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1107 UPSERT_STATUS_SET_WARNINGS(conn->upsert_status, row_packet->warning_count); in mysqlnd_fetch_stmt_row_cursor()
1109 UPSERT_STATUS_SET_SERVER_STATUS(stmt->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1110 UPSERT_STATUS_SET_SERVER_STATUS(conn->upsert_status, row_packet->server_status); in mysqlnd_fetch_stmt_row_cursor()
1114 row_packet->server_status, row_packet->warning_count, in mysqlnd_fetch_stmt_row_cursor()