Method prepTxnClient

ais/prxtxn.go:976–998

misc helpers and utilities

(msg *apc.ActionMsg, bck *cluster.Bck, waitmsync bool)

///

func (p *proxy) prepTxnClient(msg *apc.ActionMsg, bck *cluster.Bck, waitmsync bool) *txnClientCtx {
	c := &txnClientCtx{p: p, uuid: cos.GenUUID(), smap: p.owner.smap.get()}
	c.msg = p.newAmsg(msg, nil, c.uuid)
	body := cos.MustMarshal(c.msg)

	query := make(url.Values, 2)
	if bck == nil {
		c.path = apc.URLPathTxn.S
	} else {
		c.path = apc.URLPathTxn.Join(bck.Name)
		query = bck.AddToQuery(query)
	}
	config := cmn.GCO.Get()
	c.timeout.netw = 2 * config.Timeout.MaxKeepalive.D()
	c.timeout.host = config.Timeout.MaxHostBusy.D()
	if !waitmsync { // when commit does not block behind metasync
		query.Set(apc.QparamNetwTimeout, cos.UnixNano2S(int64(c.timeout.netw)))
	}
	query.Set(apc.QparamHostTimeout, cos.UnixNano2S(int64(c.timeout.host)))

	c.req = cmn.HreqArgs{Method: http.MethodPost, Query: query, Body: body}
	return c
}

// rollback create-bucket
func (p *proxy) undoCreateBucket(msg *apc.ActionMsg, bck *cluster.Bck) {