| /freebsd/contrib/unbound/services/cache/ |
| H A D | dns.c | 78 store_rrsets(struct module_env* env, struct reply_info* rep, time_t now, in store_rrsets() argument 83 time_t ttl, min_ttl = rep->ttl; in store_rrsets() 85 for(i=0; i<rep->rrset_count; i++) { in store_rrsets() 86 rep->ref[i].key = rep->rrsets[i]; in store_rrsets() 87 rep->ref[i].id = rep->rrsets[i]->id; in store_rrsets() 89 switch(rrset_cache_update(env->rrset_cache, &rep->ref[i], in store_rrsets() 90 env->alloc, ((ntohs(rep->ref[i].key->rk.type)== in store_rrsets() 97 lock_rw_rdlock(&rep->ref[i].key->entry.lock); in store_rrsets() 99 if(rep->ref[i].key->id == 0 || in store_rrsets() 100 rep->ref[i].id != rep->ref[i].key->id) in store_rrsets() [all …]
|
| /freebsd/contrib/unbound/iterator/ |
| H A D | iter_resptype.c | 57 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_NXDOMAIN) in response_type_from_cache() 64 if(msg->rep->an_numrrsets > 0) { in response_type_from_cache() 72 for(i=0; i<msg->rep->an_numrrsets; i++) { in response_type_from_cache() 73 struct ub_packed_rrset_key* s = msg->rep->rrsets[i]; in response_type_from_cache() 120 if((msg->rep->flags & BIT_TC)) in response_type_from_server() 124 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_NXDOMAIN) { in response_type_from_server() 126 if( (msg->rep->flags&BIT_RA) && in response_type_from_server() 127 !(msg->rep->flags&BIT_AA) && !rdset) in response_type_from_server() 130 for(i=0; i<msg->rep->an_numrrsets; i++) { in response_type_from_server() 131 s = msg->rep->rrsets[i]; in response_type_from_server() [all …]
|
| H A D | iter_utils.c | 750 if(!parse_create_msg(pkt, msg, NULL, &m->qinfo, &m->rep, region)) { in dns_alloc_msg() 768 if(!(m->rep = reply_info_copy(from->rep, NULL, region))) in dns_copy_msg() 956 if(msg && msg->rep && in iter_indicates_dnssec() 957 reply_find_rrset_section_ns(msg->rep, dp->name, dp->namelen, in iter_indicates_dnssec() 984 if(!msg || !msg->rep) in iter_msg_has_dnssec() 986 for(i=0; i<msg->rep->an_numrrsets + msg->rep->ns_numrrsets; i++) { in iter_msg_has_dnssec() 987 if(((struct packed_rrset_data*)msg->rep->rrsets[i]-> in iter_msg_has_dnssec() 999 if(!msg || !dp || !msg->rep || !dp->name) in iter_msg_from_zone() 1002 if(reply_find_rrset_section_an(msg->rep, dp->name, dp->namelen, in iter_msg_from_zone() 1004 reply_find_rrset_section_ns(msg->rep, dp->name, dp->namelen, in iter_msg_from_zone() [all …]
|
| H A D | iterator.c | 316 struct reply_info* rep = (struct reply_info*)msg->entry.data; in error_response_cache() local 317 if(qstate->env->cfg->serve_expired && rep) { in error_response_cache() 320 > rep->serve_expired_ttl) { in error_response_cache() 323 rep->serve_expired_ttl = *qstate->env->now + in error_response_cache() 328 rep->serve_expired_norec_ttl = NORR_TTL + in error_response_cache() 331 if(rep && (FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 333 FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 335 FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 338 *qstate->env->now <= rep->ttl)) { in error_response_cache() 398 msg->rep->rrset_count > RR_COUNT_MAX) return 0; /* overflow */ in iter_prepend() [all …]
|
| /freebsd/contrib/llvm-project/compiler-rt/lib/tsan/rtl/ |
| H A D | tsan_report.cpp | 264 static ReportStack *ChooseSummaryStack(const ReportDesc *rep) { in ChooseSummaryStack() 265 if (rep->mops.Size()) in ChooseSummaryStack() 266 return rep->mops[0]->stack; in ChooseSummaryStack() 267 if (rep->stacks.Size()) in ChooseSummaryStack() 268 return rep->stacks[0]; in ChooseSummaryStack() 269 if (rep->mutexes.Size()) in ChooseSummaryStack() 270 return rep->mutexes[0]->stack; in ChooseSummaryStack() 271 if (rep->threads.Size()) in ChooseSummaryStack() 272 return rep->threads[0]->stack; in ChooseSummaryStack() 282 void PrintReport(const ReportDesc *rep) { in FrameIsInternal() 262 ChooseSummaryStack(const ReportDesc * rep) ChooseSummaryStack() argument 296 PrintReport(const ReportDesc * rep) PrintReport() argument 443 PrintReport(const ReportDesc * rep) PrintReport() argument [all...] |
| H A D | tsan_debugging.cpp | 79 const ReportDesc *rep = (ReportDesc *)report; in __tsan_get_report_data() 80 *description = ReportTypeDescription(rep->typ); in __tsan_get_report_data() 81 *count = rep->count; in __tsan_get_report_data() 82 *stack_count = rep->stacks.Size(); in __tsan_get_report_data() 83 *mop_count = rep->mops.Size(); in __tsan_get_report_data() 84 *loc_count = rep->locs.Size(); in __tsan_get_report_data() 85 *mutex_count = rep->mutexes.Size(); in __tsan_get_report_data() 86 *thread_count = rep->threads.Size(); in __tsan_get_report_data() 87 *unique_tid_count = rep->unique_tids.Size(); in __tsan_get_report_data() 88 if (rep in __tsan_get_report_data() 77 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_data() local 92 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_tag() local 100 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_stack() local 111 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_mop() local 128 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_loc() local 145 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_loc_object_type() local 155 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_mutex() local 169 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_thread() local 183 const ReportDesc *rep = (ReportDesc *)report; __tsan_get_report_unique_tid() local [all...] |
| /freebsd/contrib/unbound/util/data/ |
| H A D | msgreply.c | 104 struct reply_info* rep; in construct_reply_info_base() local 110 rep = (struct reply_info*)regional_alloc(region, s); in construct_reply_info_base() 111 else rep = (struct reply_info*)malloc(s + in construct_reply_info_base() 113 if(!rep) in construct_reply_info_base() 115 rep->flags = flags; in construct_reply_info_base() 116 rep->qdcount = qd; in construct_reply_info_base() 117 rep->ttl = ttl; in construct_reply_info_base() 118 rep->prefetch_ttl = prettl; in construct_reply_info_base() 119 rep->serve_expired_ttl = expttl; in construct_reply_info_base() 120 rep->serve_expired_norec_ttl = norecttl; in construct_reply_info_base() [all …]
|
| H A D | msgreply.h | 303 struct query_info* qinf, struct reply_info** rep, 323 struct reply_info** rep, struct regional* region); 333 void reply_info_sortref(struct reply_info* rep); 341 void reply_info_set_ttls(struct reply_info* rep, time_t timenow); 350 void reply_info_absolute_ttls(struct reply_info* rep, time_t ttl, time_t ttl_add); 358 void reply_info_parsedelete(struct reply_info* rep, struct alloc_cache* alloc); 406 struct reply_info* reply_info_copy(struct reply_info* rep, 421 int reply_info_alloc_rrset_keys(struct reply_info* rep, 431 int reply_info_can_answer_expired(struct reply_info* rep, time_t timenow); 440 int reply_info_could_use_expired(struct reply_info* rep, time_t timenow); [all …]
|
| H A D | msgencode.c | 573 insert_section(struct reply_info* rep, size_t num_rrsets, uint16_t* num_rrs, in insert_section() argument 591 if((r=packed_rrset_encode(rep->rrsets[rrsets_before+i], in insert_section() 604 if((r=packed_rrset_encode(rep->rrsets[rrsets_before+i], in insert_section() 615 if((r=packed_rrset_encode(rep->rrsets[rrsets_before+i], in insert_section() 652 positive_answer(struct reply_info* rep, uint16_t qtype) { in positive_answer() argument 654 if (FLAGS_GET_RCODE(rep->flags) != LDNS_RCODE_NOERROR) in positive_answer() 657 for(i=0;i<rep->an_numrrsets; i++) { in positive_answer() 658 if(ntohs(rep->rrsets[i]->rk.type) == qtype) { in positive_answer() 665 for(i=rep->an_numrrsets; i<rep->an_numrrsets+ in positive_answer() 666 rep->ns_numrrsets; i++) { in positive_answer() [all …]
|
| /freebsd/contrib/unbound/validator/ |
| H A D | val_utils.c | 67 struct query_info* qinf, struct reply_info* rep, size_t skip) in val_classify_response() argument 69 int rcode = (int)FLAGS_GET_RCODE(rep->flags); in val_classify_response() 74 if(rcode == LDNS_RCODE_NXDOMAIN && rep->an_numrrsets == 0) in val_classify_response() 78 if(!(query_flags&BIT_RD) && rep->an_numrrsets == 0 && in val_classify_response() 85 for(i=0; i<rep->ns_numrrsets; i++) { in val_classify_response() 86 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_SOA) in val_classify_response() 88 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_DS) in val_classify_response() 90 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_NS) in val_classify_response() 96 if(!(query_flags&BIT_RD) && rep->ns_numrrsets == 0 && in val_classify_response() 97 rep->an_numrrsets == 1 && rcode == LDNS_RCODE_NOERROR && in val_classify_response() [all …]
|
| H A D | val_neg.c | 331 static size_t calc_data_need(struct reply_info* rep) in calc_data_need() argument 336 for(i=rep->an_numrrsets; i<rep->an_numrrsets+rep->ns_numrrsets; i++) { in calc_data_need() 337 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_NSEC) { in calc_data_need() 338 d = rep->rrsets[i]->rk.dname; in calc_data_need() 339 len = rep->rrsets[i]->rk.dname_len; in calc_data_need() 573 static struct ub_packed_rrset_key* reply_find_soa(struct reply_info* rep) in reply_find_soa() argument 576 for(i=rep->an_numrrsets; i< rep->an_numrrsets+rep->ns_numrrsets; i++){ in reply_find_soa() 577 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_SOA) in reply_find_soa() 578 return rep->rrsets[i]; in reply_find_soa() 584 static int reply_has_nsec(struct reply_info* rep) in reply_has_nsec() argument [all …]
|
| H A D | validator.c | 82 update_reason_bogus(struct reply_info* rep, sldns_ede_code reason_bogus) in update_reason_bogus() argument 86 && rep->reason_bogus != LDNS_EDE_NONE in update_reason_bogus() 87 && rep->reason_bogus != LDNS_EDE_DNSSEC_BOGUS) return; in update_reason_bogus() 88 rep->reason_bogus = reason_bogus; in update_reason_bogus() 294 vq->orig_msg->rep = (struct reply_info*)regional_alloc( in val_new_getmsg() 296 if(!vq->orig_msg->rep) in val_new_getmsg() 298 memset(vq->orig_msg->rep, 0, sizeof(struct reply_info)); in val_new_getmsg() 299 vq->orig_msg->rep->flags = (uint16_t)(qstate->return_rcode&0xf) in val_new_getmsg() 301 vq->orig_msg->rep->qdcount = 1; in val_new_getmsg() 302 vq->orig_msg->rep->reason_bogus = LDNS_EDE_NONE; in val_new_getmsg() [all …]
|
| /freebsd/sys/contrib/openzfs/module/zstd/lib/compress/ |
| H A D | zstd_lazy.h | 41 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 44 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 47 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 50 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 53 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 56 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 59 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 62 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 86 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 89 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], [all …]
|
| /freebsd/sys/contrib/zstd/lib/compress/ |
| H A D | zstd_lazy.h | 40 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 43 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 46 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 49 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 52 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 55 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 58 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 61 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 85 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], 88 ZSTD_MatchState_t* ms, SeqStore_t* seqStore, U32 rep[ZSTD_REP_NUM], [all …]
|
| /freebsd/contrib/unbound/cachedb/ |
| H A D | redis.c | 192 redisReply* rep; in redis_connect() local 193 rep = redisCommand(ctx, "AUTH %s", password); in redis_connect() 194 if(!rep || rep->type == REDIS_REPLY_ERROR) { in redis_connect() 196 freeReplyObject(rep); in redis_connect() 199 freeReplyObject(rep); in redis_connect() 202 redisReply* rep; in redis_connect() local 203 rep = redisCommand(ctx, "SELECT %d", logical_db); in redis_connect() 204 if(!rep || rep->type == REDIS_REPLY_ERROR) { in redis_connect() 207 freeReplyObject(rep); in redis_connect() 210 freeReplyObject(rep); in redis_connect() [all …]
|
| H A D | cachedb.c | 393 if(!qstate->return_msg || !qstate->return_msg->rep) in prep_data() 397 if(FLAGS_GET_RCODE(qstate->return_msg->rep->flags) != in prep_data() 399 FLAGS_GET_RCODE(qstate->return_msg->rep->flags) != in prep_data() 401 FLAGS_GET_RCODE(qstate->return_msg->rep->flags) != in prep_data() 406 if(qstate->return_msg->rep->ttl == 0) in prep_data() 410 if (qstate->env->cfg->ede && qstate->return_msg->rep->reason_bogus != LDNS_EDE_NONE) { in prep_data() 412 qstate->return_msg->rep->reason_bogus, in prep_data() 413 qstate->return_msg->rep->reason_bogus_str); in prep_data() 418 qstate->return_msg->rep); in prep_data() 420 qstate->return_msg->rep, 0, qstate->query_flags, in prep_data() [all …]
|
| /freebsd/contrib/llvm-project/libcxx/src/include/ |
| H A D | refstring.h | 51 inline char* data_from_rep(_Rep_base* rep) noexcept { in data_from_rep() argument 52 char* data = reinterpret_cast<char*>(rep); in data_from_rep() 53 return data + sizeof(*rep); in data_from_rep() 80 _Rep_base* rep = static_cast<_Rep_base*>(::operator new(sizeof(*rep) + len + 1)); in __libcpp_refstring() local 81 rep->len = len; in __libcpp_refstring() 82 rep->cap = len; in __libcpp_refstring() 83 rep->count = 0; in __libcpp_refstring() 84 char* data = data_from_rep(rep); in __libcpp_refstring() 110 _Rep_base* rep = rep_from_data(__imp_); in ~__libcpp_refstring() local 111 if (__libcpp_atomic_add(&rep->count, count_t(-1)) < 0) { in ~__libcpp_refstring() [all …]
|
| /freebsd/crypto/heimdal/lib/krb5/ |
| H A D | send_to_kdc.c | 54 krb5_data *rep) in recv_loop() argument 67 krb5_data_zero(rep); in recv_loop() 84 krb5_data_free (rep); in recv_loop() 91 nbytes = min((size_t)nbytes, limit - rep->length); in recv_loop() 93 tmp = realloc (rep->data, rep->length + nbytes); in recv_loop() 95 krb5_data_free (rep); in recv_loop() 98 rep->data = tmp; in recv_loop() 99 ret = recv (fd, (char*)tmp + rep->length, nbytes, 0); in recv_loop() 101 krb5_data_free (rep); in recv_loop() 104 rep->length += ret; in recv_loop() [all …]
|
| H A D | ticket.c | 376 krb5_kdc_rep *rep, in check_server_referral() argument 391 if (rep->kdc_rep.padata == NULL) in check_server_referral() 394 pa = krb5_find_padata(rep->kdc_rep.padata->val, in check_server_referral() 395 rep->kdc_rep.padata->len, in check_server_referral() 509 krb5_kdc_rep *rep, in check_client_referral() argument 522 if (rep->kdc_rep.padata == NULL) in check_client_referral() 525 pa = krb5_find_padata(rep->kdc_rep.padata->val, in check_client_referral() 526 rep->kdc_rep.padata->len, in check_client_referral() 651 krb5_kdc_rep *rep, in _krb5_extract_ticket() argument 673 ret = (*decrypt_proc)(context, key, key_usage, decryptarg, rep); in _krb5_extract_ticket() [all …]
|
| H A D | free.c | 37 krb5_free_kdc_rep(krb5_context context, krb5_kdc_rep *rep) in krb5_free_kdc_rep() argument 39 free_KDC_REP(&rep->kdc_rep); in krb5_free_kdc_rep() 40 free_EncTGSRepPart(&rep->enc_part); in krb5_free_kdc_rep() 41 free_KRB_ERROR(&rep->error); in krb5_free_kdc_rep() 42 memset(rep, 0, sizeof(*rep)); in krb5_free_kdc_rep()
|
| /freebsd/usr.bin/gzip/ |
| H A D | unlz.c | 432 unsigned rep[4] = { 0 }; in lz_decode_member() local 448 int peek = lz_peek(lz, rep[0]); in lz_decode_member() 464 lz_put(lz, lz_peek(lz, rep[0])); in lz_decode_member() 472 distance = rep[1]; in lz_decode_member() 477 distance = rep[2]; in lz_decode_member() 479 distance = rep[3]; in lz_decode_member() 480 rep[3] = rep[2]; in lz_decode_member() 482 rep[2] = rep[1]; in lz_decode_member() 484 rep[1] = rep[0]; in lz_decode_member() 485 rep[0] = distance; in lz_decode_member() [all …]
|
| /freebsd/crypto/heimdal/kdc/ |
| H A D | kx509.c | 103 Kx509Response *rep) in calculate_reply_hash() argument 117 ret = krb5_data_alloc(rep->hash, HMAC_size(ctx)); in calculate_reply_hash() 125 if (rep->error_code) { in calculate_reply_hash() 126 int32_t t = *rep->error_code; in calculate_reply_hash() 133 if (rep->certificate) in calculate_reply_hash() 134 HMAC_Update(ctx, rep->certificate->data, rep->certificate->length); in calculate_reply_hash() 135 if (rep->e_text) in calculate_reply_hash() 136 HMAC_Update(ctx, (unsigned char *)*rep->e_text, strlen(*rep->e_text)); in calculate_reply_hash() 138 HMAC_Final(ctx, rep->hash->data, 0); in calculate_reply_hash() 302 Kx509Response rep; in _kdc_do_kx509() local [all …]
|
| /freebsd/contrib/llvm-project/libcxx/src/filesystem/ |
| H A D | time_utils.h | 122 template <class FileTimeT, class TimeT, bool IsFloat = is_floating_point<typename FileTimeT::rep>::… 124 using rep = typename FileTimeT::rep; member 126 using fs_seconds = duration<rep>; 127 using fs_nanoseconds = duration<rep, nano>; 128 using fs_microseconds = duration<rep, micro>; 130 static constexpr rep max_seconds = duration_cast<fs_seconds>(FileTimeT::duration::max()).count(); 132 static constexpr rep max_nsec = 135 static constexpr rep min_seconds = duration_cast<fs_seconds>(FileTimeT::duration::min()).count(); 137 static constexpr rep min_nsec_timespec = 149 if (sizeof(TimeT) == sizeof(rep)) { in check_range() [all …]
|
| /freebsd/crypto/openssl/crypto/cmp/ |
| H A D | cmp_client.c | 32 const OSSL_CMP_MSG *rep, in unprotected_exception() argument 36 int rcvd_type = OSSL_CMP_MSG_get_bodytype(rep /* may be NULL */); in unprotected_exception() 39 if (!ossl_assert(ctx != NULL && rep != NULL)) in unprotected_exception() 50 OSSL_CMP_PKISI *si = ossl_cmp_revrepcontent_get_pkisi(rep->body->value.rp, in unprotected_exception() 65 OSSL_CMP_CERTREPMESSAGE *crepmsg = rep->body->value.ip; in unprotected_exception() 140 OSSL_CMP_MSG **rep, int expected_type) in send_receive_check() argument 157 *rep = NULL; in send_receive_check() 182 *rep = (*transfer_cb)(ctx, req); in send_receive_check() 185 if (*rep == NULL) { in send_receive_check() 194 bt = OSSL_CMP_MSG_get_bodytype(*rep); in send_receive_check() [all …]
|
| /freebsd/contrib/unbound/services/ |
| H A D | mesh.c | 367 if(must_validate && (msg->rep->security == sec_status_bogus || in mesh_serve_expired_lookup() 368 msg->rep->security == sec_status_secure_sentinel_fail)) { in mesh_serve_expired_lookup() 371 } else if(msg->rep->security == sec_status_unchecked && must_validate) { in mesh_serve_expired_lookup() 375 } else if(msg->rep->security == sec_status_secure && in mesh_serve_expired_lookup() 376 !reply_all_rrsets_secure(msg->rep) && must_validate) { in mesh_serve_expired_lookup() 429 struct edns_data* edns, struct comm_reply* rep, uint16_t qid, in mesh_new_client() argument 439 struct sldns_buffer* r_buffer = rep->c->buffer; in mesh_new_client() 441 if(rep->c->tcp_req_info) { in mesh_new_client() 442 r_buffer = rep->c->tcp_req_info->spool_buffer; in mesh_new_client() 444 if(!infra_wait_limit_allowed(mesh->env->infra_cache, rep, in mesh_new_client() [all …]
|