anchor.diff:  clocksi_iread({_, _, CoordFsmPid}, Key, Type) ->
       case materializer:check_operations([{read, {Key, Type}}]) of
           ok ->
  -            case  gen_fsm:sync_send_event(CoordFsmPid, {read, {Key, Type}}) of
  +            case  gen_fsm:sync_send_event(CoordFsmPid, {read, {Key, Type}}, ?OP_TIMEOUT) of
                   {ok, Res} -> {ok, Res};
                   {error, Reason} -> {error, Reason}
               end;
  
positive.code: %%      but should be changed when the new transaction api is decided
  -spec clocksi_full_icommit(txid()) -> {aborted, txid()} | {ok, {txid(), snapshot_time()}} | {error, reason()}.
  clocksi_full_icommit({_, _, CoordFsmPid})->
      case gen_fsm:sync_send_event(CoordFsmPid, {prepare, empty}) of
          {ok,_PrepareTime} ->
              gen_fsm:sync_send_event(CoordFsmPid, commit);
          Msg ->
              Msg
      end.
  
  -spec clocksi_iprepare(txid()) -> {aborted, txid()} | {ok, non_neg_integer()}.
  clocksi_iprepare({_, _, CoordFsmPid})->
      gen_fsm:sync_send_event(CoordFsmPid, {prepare, two_phase}).
  
  -spec clocksi_icommit(txid()) -> {aborted, txid()} | {ok, {txid(), snapshot_time()}}.
  clocksi_icommit({_, _, CoordFsmPid})->
      gen_fsm:sync_send_event(CoordFsmPid, commit).
  
negative.code:     case materializer:check_operations([{update, {Key, Type, OpParams}}]) of
          ok ->
              case gen_fsm:sync_send_event(CoordFsmPid,
                                           {update, {Key, Type, OpParams}}, ?OP_TIMEOUT) of
                  ok -> ok;
                  {aborted, _} -> {error, aborted};
                  {error, Reason} -> {error, Reason}
  