Attachment #117 for bug #228

View | Details | Raw Unified
Collapse All | Expand All




SlonikScript *parser_script = NULL;
int			parser_errors = 0;
int			current_try_level;
int			block_stmt_no=0;
int last_event_node=-1;
int auto_wait_disabled=0;


			break;
	}	
	free(events);
	block_stmt_no=0;
	while (hdr && errors == 0)
	{
		hdr->script = script;
		block_stmt_no++;

		switch (hdr->stmt_type)
		{

					SlonikStmt_try *stmt =
					(SlonikStmt_try *) hdr;
					int			rc;
					int saved_stmt_no;

					current_try_level++;
					saved_stmt_no=block_stmt_no;
					rc = script_exec_stmts(script, stmt->try_block);
					current_try_level--;
					block_stmt_no=saved_stmt_no;

					if (rc < 0)
					{

					printf("%s:%d: %s\n",
						   stmt->hdr.stmt_filename, stmt->hdr.stmt_lno,
						   stmt->str);
					block_stmt_no--;
				}
				break;


					printf("%s:%d: %s\n",
					       stmt->hdr.stmt_filename, stmt->hdr.stmt_lno,
					       outstr);
					block_stmt_no--;
				}
				break;



		if(current_try_level > 0)
		{
			if(current_try_level == 1 && block_stmt_no==1)
			{
				/**
				 * on the first command of the try block we can 
				 * still a abort the txn and restart it later, 
				 * after the wait for has been complete.
				 */			
			}
			else
			{
				printf("%s:%d Error: a subscription is in progress. "
					   "slonik can not wait for it to finish inside of a "
					   "try block",stmt->hdr.stmt_filename, stmt->hdr.stmt_lno);
				return -1;
			}
		}

		if (db_begin_xact((SlonikStmt *) stmt, adminfo1,false) < 0)

							  int suppress_wait_for)
{
	int rc;
	int recreate_txn=0;

	if ( last_event_node >= 0 &&
		 last_event_node != adminfo->no_id
		&& ! suppress_wait_for )

		
		if( current_try_level != 0)
		{
			if( current_try_level==1 && block_stmt_no == 1)
			{
				recreate_txn=1;
				db_rollback_xact(stmt,adminfo);
			}
			else 
			{
				printf("%s:%d Error: the event origin can not be changed "
					   "inside of a try block",
					   stmt->stmt_filename, stmt->stmt_lno);
				return -1;
			}
		}

		/**

		wait_event.wait_confirmed=adminfo->no_id;
		wait_event.wait_timeout=0;
		rc = slonik_wait_event(&wait_event);
		if (recreate_txn)
		{
			db_begin_xact(stmt,adminfo,false);
		}
		if(rc < 0) 
			return rc;
		

	int64* behind_nodes=NULL;
	int idx;
	int cur_array_idx;
	int recreate_txn=0;

	/**
	 * an array that stores a node_id, last_event.
	 * or the last event seen for each admin conninfo


	if( current_try_level != 0)
	{
	  if( current_try_level==1 && block_stmt_no ==1)
	  {
		  /**
		   * The first statement in the try block requires
		   * a wait for.  the code below will rollback the txn.
		   * we set a flag so we know to create a new one 
		   * when we are done.
		   */
		  recreate_txn=1;
	  }
	  else 
	  {
		  printf("%s:%d Error: WAIT operation forbidden inside a try block\n",
				 stmt->stmt_filename, stmt->stmt_lno);
		  return -1;
	  }
	}

	for( curAdmInfo = stmt->script->adminfo_list;

	 if(result != NULL)
			 PQclear(result);    
	 dstring_terminate(&event_list);
	 dstring_terminate(&is_caughtup_query);	 
	 free(last_event_array);
	 
	 if(recreate_txn)
	 {
		 db_begin_xact(stmt,adminfo1,false);
	 }

	 return 0;

}