You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mi...@apache.org on 2016/01/25 18:04:04 UTC

[20/51] [partial] hbase-site git commit: Published site at a87d9560fcf4803bdd7a01b6e4ec21435d4e11b9.

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f8d6f420/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/Procedure.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/Procedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/Procedure.html
index 8737ad5..6535576 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/Procedure.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/Procedure.html
@@ -648,152 +648,141 @@
 <span class="sourceLineNo">640</span>   */<a name="line.640"></a>
 <span class="sourceLineNo">641</span>  @InterfaceAudience.Private<a name="line.641"></a>
 <span class="sourceLineNo">642</span>  public static ProcedureInfo createProcedureInfo(final Procedure proc, final NonceKey nonceKey) {<a name="line.642"></a>
-<span class="sourceLineNo">643</span>    RemoteProcedureException exception;<a name="line.643"></a>
-<span class="sourceLineNo">644</span><a name="line.644"></a>
-<span class="sourceLineNo">645</span>    if (proc.hasException()) {<a name="line.645"></a>
-<span class="sourceLineNo">646</span>      exception = proc.getException();<a name="line.646"></a>
-<span class="sourceLineNo">647</span>    } else {<a name="line.647"></a>
-<span class="sourceLineNo">648</span>      exception = null;<a name="line.648"></a>
-<span class="sourceLineNo">649</span>    }<a name="line.649"></a>
-<span class="sourceLineNo">650</span>    ProcedureInfo procInfo = new ProcedureInfo(<a name="line.650"></a>
-<span class="sourceLineNo">651</span>      proc.getProcId(),<a name="line.651"></a>
-<span class="sourceLineNo">652</span>      proc.toStringClass(),<a name="line.652"></a>
-<span class="sourceLineNo">653</span>      proc.getOwner(),<a name="line.653"></a>
-<span class="sourceLineNo">654</span>      proc.getState(),<a name="line.654"></a>
-<span class="sourceLineNo">655</span>      proc.hasParent() ? proc.getParentProcId() : -1,<a name="line.655"></a>
-<span class="sourceLineNo">656</span>      exception != null ?<a name="line.656"></a>
-<span class="sourceLineNo">657</span>          RemoteProcedureException.toProto(exception.getSource(), exception.getCause()) : null,<a name="line.657"></a>
-<span class="sourceLineNo">658</span>      proc.getLastUpdate(),<a name="line.658"></a>
-<span class="sourceLineNo">659</span>      proc.getStartTime(),<a name="line.659"></a>
-<span class="sourceLineNo">660</span>      proc.getResult());<a name="line.660"></a>
-<span class="sourceLineNo">661</span><a name="line.661"></a>
-<span class="sourceLineNo">662</span>    if (nonceKey != null) {<a name="line.662"></a>
-<span class="sourceLineNo">663</span>      procInfo.setNonceKey(nonceKey);<a name="line.663"></a>
-<span class="sourceLineNo">664</span>    }<a name="line.664"></a>
-<span class="sourceLineNo">665</span><a name="line.665"></a>
-<span class="sourceLineNo">666</span>    return procInfo;<a name="line.666"></a>
-<span class="sourceLineNo">667</span>  }<a name="line.667"></a>
-<span class="sourceLineNo">668</span><a name="line.668"></a>
-<span class="sourceLineNo">669</span>  /**<a name="line.669"></a>
-<span class="sourceLineNo">670</span>   * Helper to convert the procedure to protobuf.<a name="line.670"></a>
-<span class="sourceLineNo">671</span>   * Used by ProcedureStore implementations.<a name="line.671"></a>
-<span class="sourceLineNo">672</span>   */<a name="line.672"></a>
-<span class="sourceLineNo">673</span>  @InterfaceAudience.Private<a name="line.673"></a>
-<span class="sourceLineNo">674</span>  public static ProcedureProtos.Procedure convert(final Procedure proc)<a name="line.674"></a>
-<span class="sourceLineNo">675</span>      throws IOException {<a name="line.675"></a>
-<span class="sourceLineNo">676</span>    Preconditions.checkArgument(proc != null);<a name="line.676"></a>
-<span class="sourceLineNo">677</span>    validateClass(proc);<a name="line.677"></a>
+<span class="sourceLineNo">643</span>    RemoteProcedureException exception = proc.hasException() ? proc.getException() : null;<a name="line.643"></a>
+<span class="sourceLineNo">644</span>    return new ProcedureInfo(<a name="line.644"></a>
+<span class="sourceLineNo">645</span>      proc.getProcId(),<a name="line.645"></a>
+<span class="sourceLineNo">646</span>      proc.toStringClass(),<a name="line.646"></a>
+<span class="sourceLineNo">647</span>      proc.getOwner(),<a name="line.647"></a>
+<span class="sourceLineNo">648</span>      proc.getState(),<a name="line.648"></a>
+<span class="sourceLineNo">649</span>      proc.hasParent() ? proc.getParentProcId() : -1,<a name="line.649"></a>
+<span class="sourceLineNo">650</span>      nonceKey,<a name="line.650"></a>
+<span class="sourceLineNo">651</span>      exception != null ?<a name="line.651"></a>
+<span class="sourceLineNo">652</span>          RemoteProcedureException.toProto(exception.getSource(), exception.getCause()) : null,<a name="line.652"></a>
+<span class="sourceLineNo">653</span>      proc.getLastUpdate(),<a name="line.653"></a>
+<span class="sourceLineNo">654</span>      proc.getStartTime(),<a name="line.654"></a>
+<span class="sourceLineNo">655</span>      proc.getResult());<a name="line.655"></a>
+<span class="sourceLineNo">656</span>  }<a name="line.656"></a>
+<span class="sourceLineNo">657</span><a name="line.657"></a>
+<span class="sourceLineNo">658</span>  /**<a name="line.658"></a>
+<span class="sourceLineNo">659</span>   * Helper to convert the procedure to protobuf.<a name="line.659"></a>
+<span class="sourceLineNo">660</span>   * Used by ProcedureStore implementations.<a name="line.660"></a>
+<span class="sourceLineNo">661</span>   */<a name="line.661"></a>
+<span class="sourceLineNo">662</span>  @InterfaceAudience.Private<a name="line.662"></a>
+<span class="sourceLineNo">663</span>  public static ProcedureProtos.Procedure convert(final Procedure proc)<a name="line.663"></a>
+<span class="sourceLineNo">664</span>      throws IOException {<a name="line.664"></a>
+<span class="sourceLineNo">665</span>    Preconditions.checkArgument(proc != null);<a name="line.665"></a>
+<span class="sourceLineNo">666</span>    validateClass(proc);<a name="line.666"></a>
+<span class="sourceLineNo">667</span><a name="line.667"></a>
+<span class="sourceLineNo">668</span>    ProcedureProtos.Procedure.Builder builder = ProcedureProtos.Procedure.newBuilder()<a name="line.668"></a>
+<span class="sourceLineNo">669</span>      .setClassName(proc.getClass().getName())<a name="line.669"></a>
+<span class="sourceLineNo">670</span>      .setProcId(proc.getProcId())<a name="line.670"></a>
+<span class="sourceLineNo">671</span>      .setState(proc.getState())<a name="line.671"></a>
+<span class="sourceLineNo">672</span>      .setStartTime(proc.getStartTime())<a name="line.672"></a>
+<span class="sourceLineNo">673</span>      .setLastUpdate(proc.getLastUpdate());<a name="line.673"></a>
+<span class="sourceLineNo">674</span><a name="line.674"></a>
+<span class="sourceLineNo">675</span>    if (proc.hasParent()) {<a name="line.675"></a>
+<span class="sourceLineNo">676</span>      builder.setParentId(proc.getParentProcId());<a name="line.676"></a>
+<span class="sourceLineNo">677</span>    }<a name="line.677"></a>
 <span class="sourceLineNo">678</span><a name="line.678"></a>
-<span class="sourceLineNo">679</span>    ProcedureProtos.Procedure.Builder builder = ProcedureProtos.Procedure.newBuilder()<a name="line.679"></a>
-<span class="sourceLineNo">680</span>      .setClassName(proc.getClass().getName())<a name="line.680"></a>
-<span class="sourceLineNo">681</span>      .setProcId(proc.getProcId())<a name="line.681"></a>
-<span class="sourceLineNo">682</span>      .setState(proc.getState())<a name="line.682"></a>
-<span class="sourceLineNo">683</span>      .setStartTime(proc.getStartTime())<a name="line.683"></a>
-<span class="sourceLineNo">684</span>      .setLastUpdate(proc.getLastUpdate());<a name="line.684"></a>
-<span class="sourceLineNo">685</span><a name="line.685"></a>
-<span class="sourceLineNo">686</span>    if (proc.hasParent()) {<a name="line.686"></a>
-<span class="sourceLineNo">687</span>      builder.setParentId(proc.getParentProcId());<a name="line.687"></a>
-<span class="sourceLineNo">688</span>    }<a name="line.688"></a>
-<span class="sourceLineNo">689</span><a name="line.689"></a>
-<span class="sourceLineNo">690</span>    if (proc.hasTimeout()) {<a name="line.690"></a>
-<span class="sourceLineNo">691</span>      builder.setTimeout(proc.getTimeout());<a name="line.691"></a>
+<span class="sourceLineNo">679</span>    if (proc.hasTimeout()) {<a name="line.679"></a>
+<span class="sourceLineNo">680</span>      builder.setTimeout(proc.getTimeout());<a name="line.680"></a>
+<span class="sourceLineNo">681</span>    }<a name="line.681"></a>
+<span class="sourceLineNo">682</span><a name="line.682"></a>
+<span class="sourceLineNo">683</span>    if (proc.hasOwner()) {<a name="line.683"></a>
+<span class="sourceLineNo">684</span>      builder.setOwner(proc.getOwner());<a name="line.684"></a>
+<span class="sourceLineNo">685</span>    }<a name="line.685"></a>
+<span class="sourceLineNo">686</span><a name="line.686"></a>
+<span class="sourceLineNo">687</span>    int[] stackIds = proc.getStackIndexes();<a name="line.687"></a>
+<span class="sourceLineNo">688</span>    if (stackIds != null) {<a name="line.688"></a>
+<span class="sourceLineNo">689</span>      for (int i = 0; i &lt; stackIds.length; ++i) {<a name="line.689"></a>
+<span class="sourceLineNo">690</span>        builder.addStackId(stackIds[i]);<a name="line.690"></a>
+<span class="sourceLineNo">691</span>      }<a name="line.691"></a>
 <span class="sourceLineNo">692</span>    }<a name="line.692"></a>
 <span class="sourceLineNo">693</span><a name="line.693"></a>
-<span class="sourceLineNo">694</span>    if (proc.hasOwner()) {<a name="line.694"></a>
-<span class="sourceLineNo">695</span>      builder.setOwner(proc.getOwner());<a name="line.695"></a>
-<span class="sourceLineNo">696</span>    }<a name="line.696"></a>
-<span class="sourceLineNo">697</span><a name="line.697"></a>
-<span class="sourceLineNo">698</span>    int[] stackIds = proc.getStackIndexes();<a name="line.698"></a>
-<span class="sourceLineNo">699</span>    if (stackIds != null) {<a name="line.699"></a>
-<span class="sourceLineNo">700</span>      for (int i = 0; i &lt; stackIds.length; ++i) {<a name="line.700"></a>
-<span class="sourceLineNo">701</span>        builder.addStackId(stackIds[i]);<a name="line.701"></a>
-<span class="sourceLineNo">702</span>      }<a name="line.702"></a>
+<span class="sourceLineNo">694</span>    if (proc.hasException()) {<a name="line.694"></a>
+<span class="sourceLineNo">695</span>      RemoteProcedureException exception = proc.getException();<a name="line.695"></a>
+<span class="sourceLineNo">696</span>      builder.setException(<a name="line.696"></a>
+<span class="sourceLineNo">697</span>        RemoteProcedureException.toProto(exception.getSource(), exception.getCause()));<a name="line.697"></a>
+<span class="sourceLineNo">698</span>    }<a name="line.698"></a>
+<span class="sourceLineNo">699</span><a name="line.699"></a>
+<span class="sourceLineNo">700</span>    byte[] result = proc.getResult();<a name="line.700"></a>
+<span class="sourceLineNo">701</span>    if (result != null) {<a name="line.701"></a>
+<span class="sourceLineNo">702</span>      builder.setResult(ByteStringer.wrap(result));<a name="line.702"></a>
 <span class="sourceLineNo">703</span>    }<a name="line.703"></a>
 <span class="sourceLineNo">704</span><a name="line.704"></a>
-<span class="sourceLineNo">705</span>    if (proc.hasException()) {<a name="line.705"></a>
-<span class="sourceLineNo">706</span>      RemoteProcedureException exception = proc.getException();<a name="line.706"></a>
-<span class="sourceLineNo">707</span>      builder.setException(<a name="line.707"></a>
-<span class="sourceLineNo">708</span>        RemoteProcedureException.toProto(exception.getSource(), exception.getCause()));<a name="line.708"></a>
+<span class="sourceLineNo">705</span>    ByteString.Output stateStream = ByteString.newOutput();<a name="line.705"></a>
+<span class="sourceLineNo">706</span>    proc.serializeStateData(stateStream);<a name="line.706"></a>
+<span class="sourceLineNo">707</span>    if (stateStream.size() &gt; 0) {<a name="line.707"></a>
+<span class="sourceLineNo">708</span>      builder.setStateData(stateStream.toByteString());<a name="line.708"></a>
 <span class="sourceLineNo">709</span>    }<a name="line.709"></a>
 <span class="sourceLineNo">710</span><a name="line.710"></a>
-<span class="sourceLineNo">711</span>    byte[] result = proc.getResult();<a name="line.711"></a>
-<span class="sourceLineNo">712</span>    if (result != null) {<a name="line.712"></a>
-<span class="sourceLineNo">713</span>      builder.setResult(ByteStringer.wrap(result));<a name="line.713"></a>
+<span class="sourceLineNo">711</span>    if (proc.getNonceKey() != null) {<a name="line.711"></a>
+<span class="sourceLineNo">712</span>      builder.setNonceGroup(proc.getNonceKey().getNonceGroup());<a name="line.712"></a>
+<span class="sourceLineNo">713</span>      builder.setNonce(proc.getNonceKey().getNonce());<a name="line.713"></a>
 <span class="sourceLineNo">714</span>    }<a name="line.714"></a>
 <span class="sourceLineNo">715</span><a name="line.715"></a>
-<span class="sourceLineNo">716</span>    ByteString.Output stateStream = ByteString.newOutput();<a name="line.716"></a>
-<span class="sourceLineNo">717</span>    proc.serializeStateData(stateStream);<a name="line.717"></a>
-<span class="sourceLineNo">718</span>    if (stateStream.size() &gt; 0) {<a name="line.718"></a>
-<span class="sourceLineNo">719</span>      builder.setStateData(stateStream.toByteString());<a name="line.719"></a>
-<span class="sourceLineNo">720</span>    }<a name="line.720"></a>
-<span class="sourceLineNo">721</span><a name="line.721"></a>
-<span class="sourceLineNo">722</span>    if (proc.getNonceKey() != null) {<a name="line.722"></a>
-<span class="sourceLineNo">723</span>      builder.setNonceGroup(proc.getNonceKey().getNonceGroup());<a name="line.723"></a>
-<span class="sourceLineNo">724</span>      builder.setNonce(proc.getNonceKey().getNonce());<a name="line.724"></a>
-<span class="sourceLineNo">725</span>    }<a name="line.725"></a>
-<span class="sourceLineNo">726</span><a name="line.726"></a>
-<span class="sourceLineNo">727</span>    return builder.build();<a name="line.727"></a>
-<span class="sourceLineNo">728</span>  }<a name="line.728"></a>
-<span class="sourceLineNo">729</span><a name="line.729"></a>
-<span class="sourceLineNo">730</span>  /**<a name="line.730"></a>
-<span class="sourceLineNo">731</span>   * Helper to convert the protobuf procedure.<a name="line.731"></a>
-<span class="sourceLineNo">732</span>   * Used by ProcedureStore implementations.<a name="line.732"></a>
-<span class="sourceLineNo">733</span>   *<a name="line.733"></a>
-<span class="sourceLineNo">734</span>   * TODO: OPTIMIZATION: some of the field never change during the execution<a name="line.734"></a>
-<span class="sourceLineNo">735</span>   *                     (e.g. className, procId, parentId, ...).<a name="line.735"></a>
-<span class="sourceLineNo">736</span>   *                     We can split in 'data' and 'state', and the store<a name="line.736"></a>
-<span class="sourceLineNo">737</span>   *                     may take advantage of it by storing the data only on insert().<a name="line.737"></a>
-<span class="sourceLineNo">738</span>   */<a name="line.738"></a>
-<span class="sourceLineNo">739</span>  @InterfaceAudience.Private<a name="line.739"></a>
-<span class="sourceLineNo">740</span>  public static Procedure convert(final ProcedureProtos.Procedure proto)<a name="line.740"></a>
-<span class="sourceLineNo">741</span>      throws IOException {<a name="line.741"></a>
-<span class="sourceLineNo">742</span>    // Procedure from class name<a name="line.742"></a>
-<span class="sourceLineNo">743</span>    Procedure proc = Procedure.newInstance(proto.getClassName());<a name="line.743"></a>
-<span class="sourceLineNo">744</span><a name="line.744"></a>
-<span class="sourceLineNo">745</span>    // set fields<a name="line.745"></a>
-<span class="sourceLineNo">746</span>    proc.setProcId(proto.getProcId());<a name="line.746"></a>
-<span class="sourceLineNo">747</span>    proc.setState(proto.getState());<a name="line.747"></a>
-<span class="sourceLineNo">748</span>    proc.setStartTime(proto.getStartTime());<a name="line.748"></a>
-<span class="sourceLineNo">749</span>    proc.setLastUpdate(proto.getLastUpdate());<a name="line.749"></a>
-<span class="sourceLineNo">750</span><a name="line.750"></a>
-<span class="sourceLineNo">751</span>    if (proto.hasParentId()) {<a name="line.751"></a>
-<span class="sourceLineNo">752</span>      proc.setParentProcId(proto.getParentId());<a name="line.752"></a>
-<span class="sourceLineNo">753</span>    }<a name="line.753"></a>
-<span class="sourceLineNo">754</span><a name="line.754"></a>
-<span class="sourceLineNo">755</span>    if (proto.hasOwner()) {<a name="line.755"></a>
-<span class="sourceLineNo">756</span>      proc.setOwner(proto.getOwner());<a name="line.756"></a>
-<span class="sourceLineNo">757</span>    }<a name="line.757"></a>
-<span class="sourceLineNo">758</span><a name="line.758"></a>
-<span class="sourceLineNo">759</span>    if (proto.hasTimeout()) {<a name="line.759"></a>
-<span class="sourceLineNo">760</span>      proc.setTimeout(proto.getTimeout());<a name="line.760"></a>
+<span class="sourceLineNo">716</span>    return builder.build();<a name="line.716"></a>
+<span class="sourceLineNo">717</span>  }<a name="line.717"></a>
+<span class="sourceLineNo">718</span><a name="line.718"></a>
+<span class="sourceLineNo">719</span>  /**<a name="line.719"></a>
+<span class="sourceLineNo">720</span>   * Helper to convert the protobuf procedure.<a name="line.720"></a>
+<span class="sourceLineNo">721</span>   * Used by ProcedureStore implementations.<a name="line.721"></a>
+<span class="sourceLineNo">722</span>   *<a name="line.722"></a>
+<span class="sourceLineNo">723</span>   * TODO: OPTIMIZATION: some of the field never change during the execution<a name="line.723"></a>
+<span class="sourceLineNo">724</span>   *                     (e.g. className, procId, parentId, ...).<a name="line.724"></a>
+<span class="sourceLineNo">725</span>   *                     We can split in 'data' and 'state', and the store<a name="line.725"></a>
+<span class="sourceLineNo">726</span>   *                     may take advantage of it by storing the data only on insert().<a name="line.726"></a>
+<span class="sourceLineNo">727</span>   */<a name="line.727"></a>
+<span class="sourceLineNo">728</span>  @InterfaceAudience.Private<a name="line.728"></a>
+<span class="sourceLineNo">729</span>  public static Procedure convert(final ProcedureProtos.Procedure proto)<a name="line.729"></a>
+<span class="sourceLineNo">730</span>      throws IOException {<a name="line.730"></a>
+<span class="sourceLineNo">731</span>    // Procedure from class name<a name="line.731"></a>
+<span class="sourceLineNo">732</span>    Procedure proc = Procedure.newInstance(proto.getClassName());<a name="line.732"></a>
+<span class="sourceLineNo">733</span><a name="line.733"></a>
+<span class="sourceLineNo">734</span>    // set fields<a name="line.734"></a>
+<span class="sourceLineNo">735</span>    proc.setProcId(proto.getProcId());<a name="line.735"></a>
+<span class="sourceLineNo">736</span>    proc.setState(proto.getState());<a name="line.736"></a>
+<span class="sourceLineNo">737</span>    proc.setStartTime(proto.getStartTime());<a name="line.737"></a>
+<span class="sourceLineNo">738</span>    proc.setLastUpdate(proto.getLastUpdate());<a name="line.738"></a>
+<span class="sourceLineNo">739</span><a name="line.739"></a>
+<span class="sourceLineNo">740</span>    if (proto.hasParentId()) {<a name="line.740"></a>
+<span class="sourceLineNo">741</span>      proc.setParentProcId(proto.getParentId());<a name="line.741"></a>
+<span class="sourceLineNo">742</span>    }<a name="line.742"></a>
+<span class="sourceLineNo">743</span><a name="line.743"></a>
+<span class="sourceLineNo">744</span>    if (proto.hasOwner()) {<a name="line.744"></a>
+<span class="sourceLineNo">745</span>      proc.setOwner(proto.getOwner());<a name="line.745"></a>
+<span class="sourceLineNo">746</span>    }<a name="line.746"></a>
+<span class="sourceLineNo">747</span><a name="line.747"></a>
+<span class="sourceLineNo">748</span>    if (proto.hasTimeout()) {<a name="line.748"></a>
+<span class="sourceLineNo">749</span>      proc.setTimeout(proto.getTimeout());<a name="line.749"></a>
+<span class="sourceLineNo">750</span>    }<a name="line.750"></a>
+<span class="sourceLineNo">751</span><a name="line.751"></a>
+<span class="sourceLineNo">752</span>    if (proto.getStackIdCount() &gt; 0) {<a name="line.752"></a>
+<span class="sourceLineNo">753</span>      proc.setStackIndexes(proto.getStackIdList());<a name="line.753"></a>
+<span class="sourceLineNo">754</span>    }<a name="line.754"></a>
+<span class="sourceLineNo">755</span><a name="line.755"></a>
+<span class="sourceLineNo">756</span>    if (proto.hasException()) {<a name="line.756"></a>
+<span class="sourceLineNo">757</span>      assert proc.getState() == ProcedureState.FINISHED ||<a name="line.757"></a>
+<span class="sourceLineNo">758</span>             proc.getState() == ProcedureState.ROLLEDBACK :<a name="line.758"></a>
+<span class="sourceLineNo">759</span>             "The procedure must be failed (waiting to rollback) or rolledback";<a name="line.759"></a>
+<span class="sourceLineNo">760</span>      proc.setFailure(RemoteProcedureException.fromProto(proto.getException()));<a name="line.760"></a>
 <span class="sourceLineNo">761</span>    }<a name="line.761"></a>
 <span class="sourceLineNo">762</span><a name="line.762"></a>
-<span class="sourceLineNo">763</span>    if (proto.getStackIdCount() &gt; 0) {<a name="line.763"></a>
-<span class="sourceLineNo">764</span>      proc.setStackIndexes(proto.getStackIdList());<a name="line.764"></a>
+<span class="sourceLineNo">763</span>    if (proto.hasResult()) {<a name="line.763"></a>
+<span class="sourceLineNo">764</span>      proc.setResult(proto.getResult().toByteArray());<a name="line.764"></a>
 <span class="sourceLineNo">765</span>    }<a name="line.765"></a>
 <span class="sourceLineNo">766</span><a name="line.766"></a>
-<span class="sourceLineNo">767</span>    if (proto.hasException()) {<a name="line.767"></a>
-<span class="sourceLineNo">768</span>      assert proc.getState() == ProcedureState.FINISHED ||<a name="line.768"></a>
-<span class="sourceLineNo">769</span>             proc.getState() == ProcedureState.ROLLEDBACK :<a name="line.769"></a>
-<span class="sourceLineNo">770</span>             "The procedure must be failed (waiting to rollback) or rolledback";<a name="line.770"></a>
-<span class="sourceLineNo">771</span>      proc.setFailure(RemoteProcedureException.fromProto(proto.getException()));<a name="line.771"></a>
-<span class="sourceLineNo">772</span>    }<a name="line.772"></a>
-<span class="sourceLineNo">773</span><a name="line.773"></a>
-<span class="sourceLineNo">774</span>    if (proto.hasResult()) {<a name="line.774"></a>
-<span class="sourceLineNo">775</span>      proc.setResult(proto.getResult().toByteArray());<a name="line.775"></a>
-<span class="sourceLineNo">776</span>    }<a name="line.776"></a>
-<span class="sourceLineNo">777</span><a name="line.777"></a>
-<span class="sourceLineNo">778</span>    if (proto.getNonce() != HConstants.NO_NONCE) {<a name="line.778"></a>
-<span class="sourceLineNo">779</span>      NonceKey nonceKey = new NonceKey(proto.getNonceGroup(), proto.getNonce());<a name="line.779"></a>
-<span class="sourceLineNo">780</span>      proc.setNonceKey(nonceKey);<a name="line.780"></a>
-<span class="sourceLineNo">781</span>    }<a name="line.781"></a>
-<span class="sourceLineNo">782</span><a name="line.782"></a>
-<span class="sourceLineNo">783</span>    // we want to call deserialize even when the stream is empty, mainly for testing.<a name="line.783"></a>
-<span class="sourceLineNo">784</span>    proc.deserializeStateData(proto.getStateData().newInput());<a name="line.784"></a>
-<span class="sourceLineNo">785</span><a name="line.785"></a>
-<span class="sourceLineNo">786</span>    return proc;<a name="line.786"></a>
-<span class="sourceLineNo">787</span>  }<a name="line.787"></a>
-<span class="sourceLineNo">788</span>}<a name="line.788"></a>
+<span class="sourceLineNo">767</span>    if (proto.getNonce() != HConstants.NO_NONCE) {<a name="line.767"></a>
+<span class="sourceLineNo">768</span>      NonceKey nonceKey = new NonceKey(proto.getNonceGroup(), proto.getNonce());<a name="line.768"></a>
+<span class="sourceLineNo">769</span>      proc.setNonceKey(nonceKey);<a name="line.769"></a>
+<span class="sourceLineNo">770</span>    }<a name="line.770"></a>
+<span class="sourceLineNo">771</span><a name="line.771"></a>
+<span class="sourceLineNo">772</span>    // we want to call deserialize even when the stream is empty, mainly for testing.<a name="line.772"></a>
+<span class="sourceLineNo">773</span>    proc.deserializeStateData(proto.getStateData().newInput());<a name="line.773"></a>
+<span class="sourceLineNo">774</span><a name="line.774"></a>
+<span class="sourceLineNo">775</span>    return proc;<a name="line.775"></a>
+<span class="sourceLineNo">776</span>  }<a name="line.776"></a>
+<span class="sourceLineNo">777</span>}<a name="line.777"></a>