← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/innobase/trx/trx0roll.c

  • Committer: Brian Aker
  • Date: 2010-12-19 06:20:54 UTC
  • mfrom: (2005.1.1 bug673105)
  • Revision ID: brian@tangent.org-20101219062054-1kt0l3dxs4z2z8md
Merge Dave.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/innobase/trx/trx0roll.c
93
93
 
94
94
        thr = pars_complete_graph_for_exec(roll_node, trx, heap);
95
95
 
96
 
        ut_a(thr == que_fork_start_command(static_cast<que_fork_t *>(que_node_get_parent(thr))));
 
96
        ut_a(thr == que_fork_start_command(que_node_get_parent(thr)));
97
97
        que_run_threads(thr);
98
98
 
99
99
        mutex_enter(&kernel_mutex);
336
336
 
337
337
        /* Create a new savepoint and add it as the last in the list */
338
338
 
339
 
        savep = static_cast<trx_named_savept_t *>(mem_alloc(sizeof(trx_named_savept_t)));
 
339
        savep = mem_alloc(sizeof(trx_named_savept_t));
340
340
 
341
341
        savep->name = mem_strdup(savepoint_name);
342
342
 
610
610
os_thread_ret_t
611
611
trx_rollback_or_clean_all_recovered(
612
612
/*================================*/
613
 
        void*   /*arg*/)
 
613
        void*   arg __attribute__((unused)))
614
614
                        /*!< in: a dummy parameter required by
615
615
                        os_thread_create */
616
616
{
642
642
 
643
643
        heap = mem_heap_create(1024);
644
644
 
645
 
        arr = static_cast<trx_undo_arr_t *>(mem_heap_alloc(heap, sizeof(trx_undo_arr_t)));
 
645
        arr = mem_heap_alloc(heap, sizeof(trx_undo_arr_t));
646
646
 
647
 
        arr->infos = static_cast<trx_undo_inf_t *>(mem_heap_alloc(heap, sizeof(trx_undo_inf_t)
648
 
                                                                  * UNIV_MAX_PARALLELISM));
 
647
        arr->infos = mem_heap_alloc(heap, sizeof(trx_undo_inf_t)
 
648
                                    * UNIV_MAX_PARALLELISM);
649
649
        arr->n_cells = UNIV_MAX_PARALLELISM;
650
650
        arr->n_used = 0;
651
651
 
1298
1298
{
1299
1299
        roll_node_t*    node;
1300
1300
 
1301
 
        
1302
 
        node = static_cast<roll_node_t *>(mem_heap_alloc(heap, sizeof(roll_node_t)));
 
1301
        node = mem_heap_alloc(heap, sizeof(roll_node_t));
1303
1302
        node->common.type = QUE_NODE_ROLLBACK;
1304
1303
        node->state = ROLL_NODE_SEND;
1305
1304
 
1321
1320
        ulint           sig_no;
1322
1321
        trx_savept_t*   savept;
1323
1322
 
1324
 
        node = static_cast<roll_node_t *>(thr->run_node);
 
1323
        node = thr->run_node;
1325
1324
 
1326
1325
        ut_ad(que_node_get_type(node) == QUE_NODE_ROLLBACK);
1327
1326