//Given a QbsRestPut return a RestPut
181346
func QbsWrapPut(puter QbsRestPut, s *QbsStore) RestPut {
	return &qbsWrapped{put: puter, store: s}
}
479002
func (cln *Client) ReadRSSI() int {
	rsp := cln.conn.sendReq(44, xpc.Dict{"kCBMsgArgDeviceUUID": cln.id})
	if rsp.err() != nil {
		return 0
	}
	return rsp.rssi()
}
986244
func GetFromResponse(resp *http.Response) (string, error) {
	if resp == nil {
		return "", errors.New("nil response")
	}

	nonce := resp.Header.Get("Replay-Nonce")
	if nonce == "" {
		return "", fmt.Errorf("server did not respond with a proper nonce header")
	}

	return nonce, nil
}
514936
func (r *Request) QClass() uint16 {
	if r.Req == nil {
		return 0
	}
	if len(r.Req.Question) == 0 {
		return 0
	}

	return r.Req.Question[0].Qclass

}
623747
func (u *Ugen) Sumsqr(val Input) Input {
	return binOpSumsqr(u.Rate, u, val, u.NumOutputs)
}
434332
func QbsWrapDeleteUdid(deler QbsRestDeleteUdid, s *QbsStore) RestDeleteUdid {
	return &qbsWrappedUdid{del: deler, store: s}
}
1064691
func parseApnsBatchResponse(resp []byte) (*ApnsBatchResponse, error) {

	result := new(ApnsBatchResponse)
	if err := json.Unmarshal(resp, &result); err != nil {
		return nil, err
	}

	return result, nil

}
1182223
func (s *Server) HandlePutShortcut(c web.C, w http.ResponseWriter, r *http.Request) {
	shortcut := Shortcut{}
	if err := json.NewDecoder(r.Body).Decode(&shortcut); err != nil {
		http.Error(w, http.StatusText(http.StatusBadRequest), http.StatusBadRequest)
		return
	}
	shortcut.Name = c.URLParams["id"]

	err := s.Store.Put(fmt.Sprintf("/shortcuts/%s", c.URLParams["id"]), &shortcut)
	if err != nil {
		http.Error(w, http.StatusText(http.StatusInternalServerError), http.StatusInternalServerError)
		return
	}
	w.WriteHeader(http.StatusNoContent)
}
1116059
func (q *QueryDsl) Qs(qs *QueryString) *QueryDsl {
	q.QueryEmbed.Qs = qs
	return q
}
546937
func guessIsMetricsReq(req *http.Request) bool {
	if req == nil {
		return false
	}
	aType := getRequestAuthType(req)
	return aType == authTypeAnonymous &&
		req.URL.Path == minioReservedBucketPath+prometheusMetricsPath
}
208212
func (res *Resolver) RestAXFR(req *restful.Request, resp *restful.Response) {
	records := res.records()

	AXFRRecords := models.AXFRRecords{
		SRVs:  records.SRVs.ToAXFRResourceRecordSet(),
		As:    records.As.ToAXFRResourceRecordSet(),
		AAAAs: records.AAAAs.ToAXFRResourceRecordSet(),
	}
	AXFR := models.AXFR{
		Records:        AXFRRecords,
		Serial:         atomic.LoadUint32(&res.config.SOASerial),
		Mname:          res.config.SOAMname,
		Rname:          res.config.SOARname,
		TTL:            res.config.TTL,
		RefreshSeconds: res.config.RefreshSeconds,
		Domain:         res.config.Domain,
	}

	if err := resp.WriteAsJson(AXFR); err != nil {
		logging.Error.Println(err)
	}
}
1126963
func (u *User) RequestStats() {
	packet := MumbleProto.UserStats{
		Session: &u.Session,
	}
	u.client.Conn.WriteProto(&packet)
}
174284
func (obj *Global) GetSupportedCodePagesRaw(ctx context.Context) (json.RawMessage, error) {
	result := &struct {
		CodePages json.RawMessage	`json:"qCodePages"`
	} {}
	err := obj.rpc(ctx, "GetSupportedCodePages", result)
	return result.CodePages, err 
}
909481
func (s *CountService) Q(q string) *CountService {
	s.q = q
	return s
}
1098137
func (c C) Sumsqr(val Input) Input {
	return c.Squared().Add(val.Squared())
}
237744
func (c *CrV1Client) RESTClient() rest.Interface {
	if c == nil {
		return nil
	}
	return c.restClient
}
510384
func (c *SecondExampleClient) RESTClient() rest.Interface {
	if c == nil {
		return nil
	}
	return c.restClient
}