@@ -7583,7 +7583,7 @@ int User_var_log_event::pack_info(Protocol* protocol)
7583
7583
else
7584
7584
{
7585
7585
switch (type) {
7586
- case REAL_RESULT :
7586
+ case REAL_TYPE :
7587
7587
double real_val;
7588
7588
float8get (&real_val, val);
7589
7589
if (!(buf= (char *) my_malloc (key_memory_log_event,
@@ -7593,15 +7593,15 @@ int User_var_log_event::pack_info(Protocol* protocol)
7593
7593
event_len+= my_gcvt (real_val, MY_GCVT_ARG_DOUBLE, MY_GCVT_MAX_FIELD_WIDTH,
7594
7594
buf + val_offset, NULL );
7595
7595
break ;
7596
- case INT_RESULT :
7596
+ case INT_TYPE :
7597
7597
if (!(buf= (char *) my_malloc (key_memory_log_event,
7598
7598
val_offset + 22 , MYF (MY_WME))))
7599
7599
return 1 ;
7600
7600
event_len= longlong10_to_str (uint8korr (val), buf + val_offset,
7601
7601
((flags & User_var_log_event::UNSIGNED_F) ?
7602
7602
10 : -10 ))-buf;
7603
7603
break ;
7604
- case DECIMAL_RESULT :
7604
+ case DECIMAL_TYPE :
7605
7605
{
7606
7606
if (!(buf= (char *) my_malloc (key_memory_log_event,
7607
7607
val_offset + DECIMAL_MAX_STR_LENGTH + 1 ,
@@ -7615,7 +7615,7 @@ int User_var_log_event::pack_info(Protocol* protocol)
7615
7615
event_len= str.length () + val_offset;
7616
7616
break ;
7617
7617
}
7618
- case STRING_RESULT :
7618
+ case STRING_TYPE :
7619
7619
/* 15 is for 'COLLATE' and other chars */
7620
7620
buf= (char *) my_malloc (key_memory_log_event,
7621
7621
event_len+val_len*2 +1 +2 *MY_CS_NAME_SIZE+15 ,
@@ -7636,7 +7636,7 @@ int User_var_log_event::pack_info(Protocol* protocol)
7636
7636
event_len= p-buf;
7637
7637
}
7638
7638
break ;
7639
- case ROW_RESULT :
7639
+ case ROW_TYPE :
7640
7640
default :
7641
7641
DBUG_ASSERT (1 );
7642
7642
return 1 ;
@@ -7690,14 +7690,14 @@ bool User_var_log_event::write(IO_CACHE* file)
7690
7690
int4store (buf1 + 2 , charset_number);
7691
7691
7692
7692
switch (type) {
7693
- case REAL_RESULT :
7693
+ case REAL_TYPE :
7694
7694
float8store (buf2, *(double *) val);
7695
7695
break ;
7696
- case INT_RESULT :
7696
+ case INT_TYPE :
7697
7697
int8store (buf2, *(longlong*) val);
7698
7698
unsigned_len= 1 ;
7699
7699
break ;
7700
- case DECIMAL_RESULT :
7700
+ case DECIMAL_TYPE :
7701
7701
{
7702
7702
my_decimal *dec= (my_decimal *)val;
7703
7703
dec->sanity_check ();
@@ -7707,10 +7707,10 @@ bool User_var_log_event::write(IO_CACHE* file)
7707
7707
val_len= decimal_bin_size (buf2[0 ], buf2[1 ]) + 2 ;
7708
7708
break ;
7709
7709
}
7710
- case STRING_RESULT :
7710
+ case STRING_TYPE :
7711
7711
pos= (uchar*) val;
7712
7712
break ;
7713
- case ROW_RESULT :
7713
+ case ROW_TYPE :
7714
7714
default :
7715
7715
DBUG_ASSERT (1 );
7716
7716
return 0 ;
@@ -7895,7 +7895,7 @@ int User_var_log_event::do_apply_event(Relay_log_info const *rli)
7895
7895
else
7896
7896
{
7897
7897
switch (type) {
7898
- case REAL_RESULT :
7898
+ case REAL_TYPE :
7899
7899
if (val_len != 8 )
7900
7900
{
7901
7901
rli->report (ERROR_LEVEL, ER_SLAVE_FATAL_ERROR,
@@ -7908,7 +7908,7 @@ int User_var_log_event::do_apply_event(Relay_log_info const *rli)
7908
7908
val= (char *) &real_val; // Pointer to value in native format
7909
7909
val_len= 8 ;
7910
7910
break ;
7911
- case INT_RESULT :
7911
+ case INT_TYPE :
7912
7912
if (val_len != 8 )
7913
7913
{
7914
7914
rli->report (ERROR_LEVEL, ER_SLAVE_FATAL_ERROR,
@@ -7921,7 +7921,7 @@ int User_var_log_event::do_apply_event(Relay_log_info const *rli)
7921
7921
val= (char *) &int_val; // Pointer to value in native format
7922
7922
val_len= 8 ;
7923
7923
break ;
7924
- case DECIMAL_RESULT :
7924
+ case DECIMAL_TYPE :
7925
7925
{
7926
7926
if (val_len < 3 )
7927
7927
{
@@ -7936,10 +7936,10 @@ int User_var_log_event::do_apply_event(Relay_log_info const *rli)
7936
7936
val_len= sizeof (my_decimal);
7937
7937
break ;
7938
7938
}
7939
- case STRING_RESULT :
7939
+ case STRING_TYPE :
7940
7940
it= new Item_string (val, val_len, charset);
7941
7941
break ;
7942
- case ROW_RESULT :
7942
+ case ROW_TYPE :
7943
7943
default :
7944
7944
DBUG_ASSERT (1 );
7945
7945
DBUG_RETURN (0 );
0 commit comments