← Back to branch summary

~maria-captains/maria/5.5-cassandra-parallel

« back to all changes in this revision

Viewing changes to storage/cassandra/ha_cassandra.cc

  • Committer: Sergey Petrunya
  • Date: 2012-09-20 14:32:37 UTC
  • Revision ID: psergey@askmonty.org-20120920143237-og4d9qh8uiojasmi
Casandra SE:
- Introduce asynchronous operations
- parallel INSERT operation.

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/cassandra/ha_cassandra.cc
1119
1119
    res= 0;
1120
1120
    if (++insert_rows_batched >= THDVAR(table->in_use, insert_batch_size))
1121
1121
    {
1122
 
      res= se->do_insert();
 
1122
      res= se->do_insert(false); //dont flush
1123
1123
      insert_rows_batched= 0;
1124
1124
    }
1125
1125
  }
1126
1126
  else
1127
 
    res= se->do_insert();
 
1127
    res= se->do_insert(true); // flush
1128
1128
 
1129
1129
  if (res)
1130
1130
    my_error(ER_INTERNAL_ERROR, MYF(0), se->error_str());
1148
1148
  
1149
1149
  /* Flush out the insert buffer */
1150
1150
  doing_insert_batch= false;
1151
 
  bool bres= se->do_insert();
 
1151
  bool bres= se->do_insert(true);
1152
1152
  se->clear_insert_buffer();
1153
1153
 
1154
1154
  DBUG_RETURN(bres? HA_ERR_INTERNAL_ERROR: 0);