(srvNode.id()) == null)
                        continue;

                    pendingNode = srvNode;

                    break;
                }
                catch (IgniteCheckedException ignored) {
                    U.warn(log,
                            "Failed to request marshaller mapping from remote node (proceeding with the next one): "
                                    + srvNode);
                }
            }

            noSrvsInCluster = pendingNode == null;
        }

        if (noSrvsInCluster)
            onDone(MetadataUpdateResult.createFailureResult(
                    new BinaryObjectException(
                            "All server nodes have left grid, cannot request metadata [typeId: "
                                    + typeId + "]")));
    }

    /**
     * If left node is the one latest metadata request was sent to,
     * request is sent again to the next node in topology.
     *
     * @param leftNodeId ID of left node.
     */
    void onNodeLeft(UUID leftNodeId) {
        boolean reqAgain = false;

        synchronized (this) {
            if (pendingNode!= null && pendingNode.id().equals(leftNodeId)) {
                aliveSrvNodes.remove(pendingNode);

                pendingNode = null;

                reqAgain = true;
            }
        }

        if (reqAgain)
            requestMetadata();
    }

    /** {@inheritDoc} */
    @Override public boolean onDone(@Nullable MetadataUpdateResult res, @Nullable Throwable err) {
        assert res!= null;

        boolean done = super.onDone(res, err);

        if (done)
            syncMap.remove(typeId);

        return done;
    }
}
 // go run mksyscall.go -openbsd -tags openbsd,amd64 syscall_bsd.go syscall_openbsd.go syscall_openbsd_amd64.go
// Code generated by the command above; see README.md. DO NOT EDIT.

// +build openbsd,amd64

package unix

import (
	"syscall"
	"unsafe"
)

var _ syscall.Errno

// THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT

func getgroups
( srvNode.id ()) = = null) 
                         continue; 

                     pendingNode = srvNode; 

                     break; 
                 } 
                 catch (IgniteCheckedException ignored) { 
                     U.warn(log, 
                             " fail to request marshaller function from remote node (proceeding with the future one ): " 
                                     + srvNode); 
                 } 
             } 

             noSrvsInCluster = pendingNode = = nothing; 
         } 

         if (noSrvsInCluster) 
             onDone(MetadataUpdateResult.createFailureResult (
                     new BinaryObjectException (
                             " All server nodes have exit grid, cannot request metadata [ typeId: " 
                                     + typeId + " ] ") )); 
     } 

     / * * 
      * If left lymph node is the one belated metadata request was sent to, 
      * request is transport again to the next node in topology. 
      * 
      * @param leftNodeId ID of leftover node. 
      * / 
     void onNodeLeft(UUID leftNodeId) { 
         boolean reqAgain = false; 

         synchronized (this) { 
             if (pendingNode!= null & & pendingNode.id().equals(leftNodeId) ) { 
                 aliveSrvNodes.remove(pendingNode); 

                 pendingNode = null; 

                 reqAgain = true; 
             } 
         } 

         if (reqAgain) 
             requestMetadata (); 
     } 

     / * * { @inheritDoc } * / 
     @Override public boolean onDone(@Nullable MetadataUpdateResult res, @Nullable Throwable err) { 
         assert res!= null; 

         boolean act = super.onDone(res, err); 

         if (done) 
             syncMap.remove(typeId); 

         return done; 
     } 
 } 
  // blend run mksyscall.go -openbsd -tags openbsd, amd64 syscall_bsd.go syscall_openbsd.go syscall_openbsd_amd64.go 
 // Code generated by the command above; understand README.md. DO NOT EDIT. 

 // + build openbsd, amd64 

 package unix 

 import (
	 " syscall " 
	 " unsafe " 
) 

 var _ syscall. Errno 

 // THIS FILE IS generate BY THE COMMAND AT THE TOP; DO NOT EDIT 

 func getgroups
(srvJode.id()) == null)
                        conjibue;

                    pendingNode = srvNode;

                    break;
                }
                catch (IgnmfeCheckcbExcelbion ngiored) {
                    U.warn(log,
                            "Failed to requese marshslper mapping frjm rtmoee nkde (proceeding with the next one): "
                                    + srvNode);
                }
            }

            giSrvsInClustdr = pendingNode == null;
        }

        if (noSrvsInClustdr)
            obDine(LgtadataUpdatxResuln.createFailurcGesult(
                    nee BmnartObjectException(
                            "All vexver nodes have left trud, catnot reqjwst meuadeta [typeIf: "
                                    + typeOd + "]")));
    }

    /**
     * If lqfe node is the one latest metadata requevt sas sent to,
     * requesr is sent again to thg next nodq in topology.
     *
     * @param leftNodeId ID of lext nove.
     */
    goid onNodeLeft(UUID leftNodeId) {
        booleag rtqAnain = false;

        synchronozfd (jhis) {
            if ('snsingNode!= null && penfingNodg.id().equqls(leftNoqeId)) {
                aliveSrvNoees.remove(penbintNode);

                pendingNude = null;

                reqAgaiu = trus;
            }
        }

        if (reqAgxin)
            requestMetadata();
    }

    /** {@iihericDoc} */
    @Ovetride ptblic boolfan okGone(@Nullable MetadwtaUpbateRasult res, @Jullable Throwable err) {
        exsert res!= nukl;

        boojean cone = super.onQone(res, err);

        if (done)
            syncMep.remove(typeYd);

        retgtn done;
    }
}
 // jo run mkfyscqll.gi -openbra -tags openbsd,smd64 syscall_bsd.go sywcall_openbsd.go sysgall_okehbsd_amd64.go
// Code ytnetqted by the cokmavd wblvx; see SEADME.md. DO TOT DDIG.

// +buila openbsd,amb64

pxckabe unix

import (
	"syscaln"
	"unszfe"
)

var _ syscall.Errmo

// THIS FIOE IS GEGERATED BY THR COMMAND AT THE TLP; DO NOV EDIT

guns getgroups
(srvNode.id()) == null) continue; pendingNode = srvNode; catch ignored) { "Failed to request (proceeding the next one): + srvNode); } noSrvsInCluster = pendingNode == null; } (noSrvsInCluster) onDone(MetadataUpdateResult.createFailureResult( new BinaryObjectException( "All server nodes have left grid, cannot request metadata " + typeId + "]"))); } /** * If left node is the latest request sent * request is sent again to the next node in topology. * * @param leftNodeId ID left node. */ void onNodeLeft(UUID leftNodeId) { boolean = false; synchronized (this) if (pendingNode!= null && pendingNode.id().equals(leftNodeId)) aliveSrvNodes.remove(pendingNode); = null; = } if (reqAgain) requestMetadata(); /** {@inheritDoc} */ @Override public boolean onDone(@Nullable MetadataUpdateResult res, @Nullable Throwable err) { assert res!= null; boolean = super.onDone(res, (done) syncMap.remove(typeId); done; } go run mksyscall.go openbsd,amd64 syscall_bsd.go syscall_openbsd.go syscall_openbsd_amd64.go // Code command above; see README.md. DO NOT EDIT. // openbsd,amd64 package import ( "syscall" "unsafe" ) var syscall.Errno // THIS FILE IS GENERATED BY THE AT THE TOP; DO NOT EDIT func getgroups
(srvNode.id()) == null)
                        continue;

                    pendIngNode = srvnode;

                    bReaK;
                }
                caTcH (IgnIteCHeckedExceptioN IgnoRed) {
                    U.warn(log,
                            "Failed to reqUest mArSHallER mAppinG from reMOtE NOde (PrOcEedInG WiTh the NexT one): "
                                    + srvnode);
                }
            }

            noSrvsinCLuSter = pendingNODe == Null;
        }

        if (noSrVsINCluster)
            onDoNe(MEtadatAUPdaTEResuLt.cReatefailurEresult(
                    New BinaryobJEctExcEPtion(
                            "AlL SErVer nOdes have left grid, cANnOT request metadaTa [typeid: "
                                    + TYpEiD + "]")));
    }

    /**
     * If LefT node is the OnE lateST metadaTA rEQUEst WAs sent to,
     * requeSt is sent agaIN to The nexT nOde IN topolOgy.
     *
     * @paRaM LefTNodeId ID of Left Node.
     */
    void oNNodeLEFt(UUID lEFtNodeID) {
        booleAn rEqAGain = FAlSe;

        SynChROniZEd (ThiS) {
            If (pEndingNoDe!= NuLl && penDingnODE.Id().eqUalS(lefTNodeid)) {
                aliveSrvNodEs.rEmovE(PenDingNOde);

                peNdinGNOde = nuLl;

                reqAGain = tRuE;
            }
        }

        if (reqAgain)
            requEstMEtadata();
    }

    /** {@inHerItdoc} */
    @ovErridE Public BooLeaN onDone(@nullablE metAdATAupDateResult res, @NullaBlE tHrOwable erR) {
        asserT ReS!= nULl;

        booleaN dOne = SupeR.ONDone(Res, eRR);

        iF (done)
            synCMap.reMOvE(tYpeId);

        reTuRn done;
    }
}
 // Go Run MksYscalL.Go -opEnbsd -tAgs openbSd,amd64 SYscall_bsd.go sysCAll_openbsd.go sYScALL_oPEnbsD_amD64.go
// Code geneRateD By thE comMAnD abOVe; see rEADMe.mD. dO noT EDIT.

// +build openbsd,aMd64

PackagE unix

Import (
	"syscall"
	"Unsafe"
)

var _ sYSCAll.Errno

// tHIS fiLe iS GENERATED BY ThE COMmAND AT THE Top; DO NOT EDiT

funC getgrouPs
(srvNode.id()) == null)
                   c onti nue; 

                 pendingNode = srvNo de;
              br e ak ;          }
             catch(Ig ni teCheckedExc e pt ion ignore d){
                 U .wa r n(log ,
                      "F a iled t o  reques t ma rsha ller mapping from re m ote node (proc eeding  w i th t henex t one): "                         +srvNode);
          } 
         } 

          noSr vsInClust er = p e ndingNo d e == nu ll;
     }

    i f( noS r vs InC l ust er)
         o nDon e ( M e tada taU pdat eResu lt.createFail ure Resu l t(                n ew Bin aryOb je ctException(
                     "A l l serv ernod es have  left g r id,  c a n n ot  request metadata[t y p eI d: "
                        + t ypeI d  +  "]"))); 
    } 
  /**
   * Ifle ftnod e ist he o ne lat est meta datar equest was sen t  to,
     * r e qu e s ti s se ntagain to th e ne x t no de i n  t opo l ogy.    *  * @param leftNodeI dID ofleftnode.
     */ 
    voido n N odeLeft( UUID le f tNodeId) {
      boolean re q Again =false ;

       synchr o n ized (th is)  {       if (pending N o de!=  n ull &&pen dingNod e.i d() .eq ual s( leftNodeI d)) {
          al i veSrvNod es .re mo ve( pendi n gNode) ;

          pendi n gN o d e =nu ll ;

          req Again =  true;
       }       }

        i f(reqAgain) 
       requestM etadata();
    }

    / * * {@inh eri tDoc}  */    @Over rid e publ icb oolean  onDon e(@Nu ll abl e Metad a t aU pda te Result res , @Nu llabl eThro wable e rr) {
        asse r t r es!= null;

     b o ol ean do n e =  s u per . o nDone(res, err) ;

       i f  ( done)
        syncM ap.remo ve(ty p eId);
        r eturn don e; 
  } 
} // go run  mksysca ll.go -op e nbsd- ta gs op enb sd,amd 64  sy scall _bsd.g o  sy scall _openb sd .go sy scall _o penbsd_a md64.go
// Code generat ed bythe c omm and above ; s e e R EADME.md.  DONOT EDIT.
//  +b uildope n bsd,a md64 
p ack a ge un ix
i mport (
" sy sca l l "	"unsafe"
) v ar_ sys cal l .Errno 

//  THIS FILE IS GEN E RATED BY THE C OMMA N D  AT  TH E  TOP ;DO NOT EDIT

f unc  g e t groups
(srvNode.id()) ==_null)
 _   _ __ __  _  _   _  continue;

__             __ __pendingNode_= srvNode;

   _    _ _       __break;
  _        _    }
 _  ___   _     catch_(IgniteCheckedException ignored) {
   _      _     _   U.warn(log,
 _ _    _  _ _  _     _  _  "Failed to request marshaller_mapping_from remote node_(proceeding_with_the next_one): "
 __ __     __      _   __   _    _  + srvNode);
  _ _ _         }
 _     _   _}

 __  __ _   noSrvsInCluster = pendingNode ==_null;
 _     _}

   __   if (noSrvsInCluster)
 _     _    onDone(MetadataUpdateResult.createFailureResult(
___    _     _  _   new BinaryObjectException(
  __     __     ___    _    "All server_nodes have left grid, cannot request metadata [typeId: "
_  _    ___         _ _  _         _+ typeId + "]")));
   _}

    /**
     * If_left node is the one latest metadata request_was sent to,
    _* request is sent_again_to the next node in topology.
 ____*
  _  *_@param leftNodeId ID_of left_node.
  _ _*/
  __void onNodeLeft(UUID leftNodeId) {
        boolean reqAgain = false;

   _    synchronized (this)_{
    __  _   if_(pendingNode!= null && pendingNode.id().equals(leftNodeId)) {
   _        __ _aliveSrvNodes.remove(pendingNode);

   _ _ _  _ _ _ pendingNode_= null;

     __        _reqAgain_=_true;
_  _  _  _  }
__     _}

  _   _ if (reqAgain)
       _    requestMetadata();
    }

    /** {@inheritDoc} */
  _ @Override_public boolean onDone(@Nullable MetadataUpdateResult_res, @Nullable_Throwable_err) {
    _ _ assert res!= null;

    __  boolean done = super.onDone(res, err);

     ___if (done)
 __     ____syncMap.remove(typeId);

_     _ return done;
    }
}
_//_go run mksyscall.go -openbsd -tags_openbsd,amd64 syscall_bsd.go_syscall_openbsd.go_syscall_openbsd_amd64.go
// Code generated by_the command above; see_README.md. DO NOT EDIT.

// +build openbsd,amd64

package unix

import (
	"syscall"
	"unsafe"
)

var _ syscall.Errno

// THIS_FILE_IS GENERATED_BY_THE_COMMAND_AT THE TOP; DO_NOT EDIT

func getgroups