Home
last modified time | relevance | path

Searched refs:ri (Results 1 – 25 of 29) sorted by relevance

12

/f-stack/app/redis-5.0.5/src/
H A Dsentinel.c618 ri->name, ri->addr->ip, ri->addr->port, in sentinelEvent()
623 ri->name, ri->addr->ip, ri->addr->port); in sentinelEvent()
1002 if (ri && ri->link->cc) { in releaseInstanceLink()
1203 ri = zmalloc(sizeof(*ri)); in createSentinelRedisInstance()
1255 dictAdd(table, ri->name, ri); in createSentinelRedisInstance()
1269 releaseInstanceLink(ri->link,ri); in releaseSentinelRedisInstance()
1284 if ((ri->flags & SRI_SLAVE) && (ri->flags & SRI_PROMOTED) && ri->master) in releaseSentinelRedisInstance()
1605 if (ri->master) ri = ri->master; in sentinelInstanceMapCommand()
1875 master->name, ri->addr->ip, ri->addr->port, ri->runid); in rewriteConfigSentinelOption()
2568 sentinelRedisInstance *master = (ri->flags & SRI_MASTER) ? ri : ri->master; in sentinelSendHello()
[all …]
H A Dt_stream.c193 raxStop(&ri); in streamAppendItem()
390 raxRemove(s->rax,ri.key,ri.key_len,NULL); in streamTrimByLength()
391 raxSeek(&ri,">=",ri.key,ri.key_len); in streamTrimByLength()
457 raxInsert(s->rax,ri.key,ri.key_len,lp,NULL); in streamTrimByLength()
511 if (raxEOF(&si->ri)) raxSeek(&si->ri,"^",NULL,0); in streamIteratorStart()
519 if (raxEOF(&si->ri)) raxSeek(&si->ri,"$",NULL,0); in streamIteratorStart()
1025 if (end && memcmp(ri.key,end,ri.key_len) > 0) break; in streamReplyWithRangeFromConsumerPEL()
1685 raxRemove(cg->pel,ri.key,ri.key_len,NULL); in streamDelConsumer()
1998 addReplyBulkCBuffer(c,ri.key,ri.key_len); in xpendingCommand()
2032 while(count && raxNext(&ri) && memcmp(ri.key,endkey,ri.key_len) <= 0) { in xpendingCommand()
[all …]
H A Ddefrag.c609 raxIterator ri; in scanLaterStraemListpacks() local
617 raxStart(&ri,s->rax); in scanLaterStraemListpacks()
637 while (raxNext(&ri)) { in scanLaterStraemListpacks()
640 raxSetData(ri.node, ri.data=newdata), (*defragged)++; in scanLaterStraemListpacks()
644 memcpy(last,ri.key,ri.key_len); in scanLaterStraemListpacks()
651 raxStop(&ri); in scanLaterStraemListpacks()
666 raxIterator ri; in defragRadixTree() local
671 raxStart(&ri,rax); in defragRadixTree()
682 raxSetData(ri.node, ri.data=newdata), defragged++; in defragRadixTree()
684 raxStop(&ri); in defragRadixTree()
[all …]
H A Drdb.c689 raxIterator ri; in rdbSaveStreamPEL() local
690 raxStart(&ri,pel); in rdbSaveStreamPEL()
692 while(raxNext(&ri)) { in rdbSaveStreamPEL()
710 raxStop(&ri); in rdbSaveStreamPEL()
725 raxIterator ri; in rdbSaveStreamConsumers() local
732 if ((n = rdbSaveRawString(rdb,ri.key,ri.key_len)) == -1) return -1; in rdbSaveStreamConsumers()
748 raxStop(&ri); in rdbSaveStreamConsumers()
904 raxIterator ri; in rdbSaveObject() local
910 if ((n = rdbSaveRawString(rdb,ri.key,ri.key_len)) == -1) return -1; in rdbSaveObject()
915 raxStop(&ri); in rdbSaveObject()
[all …]
H A Dobject.c876 raxIterator ri; in objectComputeSize() local
877 raxStart(&ri,s->rax); in objectComputeSize()
878 raxSeek(&ri,"^",NULL,0); in objectComputeSize()
892 raxSeek(&ri,"$",NULL,0); in objectComputeSize()
893 raxNext(&ri); in objectComputeSize()
894 asize += lpBytes(ri.data); in objectComputeSize()
896 raxStop(&ri); in objectComputeSize()
903 raxStart(&ri,s->cgroups); in objectComputeSize()
904 raxSeek(&ri,"^",NULL,0); in objectComputeSize()
905 while(raxNext(&ri)) { in objectComputeSize()
[all …]
H A Dmodule.c272 raxIterator ri; member
4309 raxIterator ri; in moduleTimerHandler() local
4310 raxStart(&ri,Timers); in moduleTimerHandler()
4328 raxRemove(Timers,(unsigned char*)ri.key,ri.key_len,NULL); in moduleTimerHandler()
4335 raxStop(&ri); in moduleTimerHandler()
4368 raxIterator ri; in RM_CreateTimer() local
4371 raxNext(&ri); in RM_CreateTimer()
4378 raxStop(&ri); in RM_CreateTimer()
4560 raxStop(&di->ri); in RM_DictIteratorStop()
4610 return di->ri.key; in RM_DictNextC()
[all …]
H A Daof.c1212 raxIterator ri; in rewriteStreamObject() local
1213 raxStart(&ri,s->cgroups); in rewriteStreamObject()
1214 raxSeek(&ri,"^",NULL,0); in rewriteStreamObject()
1215 while(raxNext(&ri)) { in rewriteStreamObject()
1216 streamCG *group = ri.data; in rewriteStreamObject()
1222 if (rioWriteBulkString(r,(char*)ri.key,ri.key_len) == 0) return 0; in rewriteStreamObject()
1240 if (rioWriteStreamPendingEntry(r,key,(char*)ri.key, in rewriteStreamObject()
1241 ri.key_len,consumer, in rewriteStreamObject()
1251 raxStop(&ri); in rewriteStreamObject()
H A Dstream.h39 raxIterator ri; /* Rax iterator. */ member
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Dzcp.c782 if (ri->zri_canceled || in zcp_lua_counthook()
795 if (ri->zri_maxinstrs != 0 && ri->zri_curinstrs > ri->zri_maxinstrs) { in zcp_lua_counthook()
822 ri->zri_tx = tx; in zcp_eval_impl()
887 ri->zri_result = 0; in zcp_eval_impl()
910 if (ri->zri_timed_out) { in zcp_eval_impl()
921 if (ri->zri_result == ETIME && ri->zri_outnvl != NULL) { in zcp_eval_impl()
966 zcp_convert_return_values(ri->zri_state, ri->zri_outnvl, in zcp_pool_error()
998 zcp_eval_impl(tx, ri); in zcp_eval_sync()
1030 zcp_eval_impl(tx, ri); in zcp_eval_open()
1186 zcp_run_info_t *ri; in zcp_run_info() local
[all …]
H A Dzcp_synctask.c80 zcp_run_info_t *ri = zcp_run_info(state); in zcp_sync_task() local
82 err = checkfunc(arg, ri->zri_tx); in zcp_sync_task()
86 if (!ri->zri_sync) { in zcp_sync_task()
94 syncfunc(arg, ri->zri_tx); in zcp_sync_task()
188 ddpa.cr = ri->zri_cred; in zcp_synctask_promote()
189 ddpa.proc = ri->zri_proc; in zcp_synctask_promote()
272 ddsa.ddsa_cr = ri->zri_cred; in zcp_synctask_snapshot()
273 ddsa.ddsa_proc = ri->zri_proc; in zcp_synctask_snapshot()
477 dsl_pool_t *dp = ri->zri_pool; in zcp_synctask_wrapper()
490 ri->zri_space_used; in zcp_synctask_wrapper()
[all …]
H A Dzcp_set.c89 zcp_run_info_t *ri = zcp_run_info(args->state); in zcp_set_prop_sync() local
90 dsl_pool_t *dp = ri->zri_pool; in zcp_set_prop_sync()
H A Dzcp_iter.c243 zcp_run_info_t *ri = zcp_run_info(state); in zcp_children_iter() local
244 dsl_pool_t *dp = ri->zri_pool; in zcp_children_iter()
/f-stack/dpdk/app/test/
H A Dtest_acl.c91 ro->data = ri->data; in acl_ipv4vlan_convert_rule()
104 ri->domain_mask; in acl_ipv4vlan_convert_rule()
106 ri->src_mask_len; in acl_ipv4vlan_convert_rule()
109 ri->src_port_high; in acl_ipv4vlan_convert_rule()
111 ri->dst_port_high; in acl_ipv4vlan_convert_rule()
592 ro->data = ri->data; in convert_rule()
605 ri->domain_mask; in convert_rule()
607 ri->src_mask_len; in convert_rule()
610 ri->src_port_high; in convert_rule()
612 ri->dst_port_high; in convert_rule()
[all …]
/f-stack/freebsd/net/route/
H A Dmpath_ctl.c154 struct rt_match_info *ri = (struct rt_match_info *)_data; in gw_filter_func() local
156 return (check_info_match_nhop(ri->info, ri->rt, nh) == 0); in gw_filter_func()
169 struct rt_match_info ri = { .info = info, .rt = rt }; in del_route_mpath() local
184 error = nhgrp_get_filtered_group(rh, nhg, gw_filter_func, (void *)&ri, in del_route_mpath()
/f-stack/freebsd/net/
H A Dnetmap_user.h1023 ri = d->cur_tx_ring; in nm_inject() local
1031 if (ri > d->last_tx_ring) in nm_inject()
1032 ri = d->first_tx_ring; in nm_inject()
1056 d->cur_tx_ring = ri; in nm_inject()
1084 if (ri > d->last_rx_ring) in nm_dispatch()
1085 ri = d->first_rx_ring; in nm_dispatch()
1099 d->cur_rx_ring = ri; in nm_dispatch()
1133 int ri = d->cur_rx_ring; in nm_nextpkt() local
1152 d->cur_rx_ring = ri; in nm_nextpkt()
1155 ri++; in nm_nextpkt()
[all …]
H A Diflib.c1146 struct if_rxd_info ri; in iflib_netmap_rxsync() local
1194 rxd_info_zero(&ri); in iflib_netmap_rxsync()
1198 ri.iri_cidx = *cidxp; in iflib_netmap_rxsync()
2661 len = ri->iri_len - ri->iri_pad; in rxd_frag_to_sd()
2720 pf_rv_ptr, ri); in assemble_segments()
2744 padlen = ri->iri_pad; in assemble_segments()
2784 &pf_rv, ri); in iflib_rxd_pkt_get()
2876 struct if_rxd_info ri; in iflib_rxeof() local
2917 rxd_info_zero(&ri); in iflib_rxeof()
2919 ri.iri_cidx = *cidxp; in iflib_rxeof()
[all …]
/f-stack/dpdk/drivers/bus/pci/linux/
H A Dpci_vfio.c622 ri = malloc(sizeof(*ri)); in pci_vfio_get_region_info()
623 if (ri == NULL) { in pci_vfio_get_region_info()
628 memset(ri, 0, argsz); in pci_vfio_get_region_info()
629 ri->argsz = argsz; in pci_vfio_get_region_info()
630 ri->index = region; in pci_vfio_get_region_info()
634 free(ri); in pci_vfio_get_region_info()
637 if (ri->argsz != argsz) { in pci_vfio_get_region_info()
640 argsz = ri->argsz; in pci_vfio_get_region_info()
645 free(ri); in pci_vfio_get_region_info()
649 ri = tmp; in pci_vfio_get_region_info()
[all …]
/f-stack/dpdk/examples/ipsec-secgw/
H A Dsp4.c140 uint32_t *ri = NULL; /* rule index */ in parse_sp4_tokens() local
156 ri = &nb_acl4_rules_in; in parse_sp4_tokens()
162 rule_ipv4 = &acl4_rules_in[*ri]; in parse_sp4_tokens()
165 ri = &nb_acl4_rules_out; in parse_sp4_tokens()
171 rule_ipv4 = &acl4_rules_out[*ri]; in parse_sp4_tokens()
429 *ri = *ri + 1; in parse_sp4_tokens()
H A Dsp6.c188 uint32_t *ri = NULL; /* rule index */ in parse_sp6_tokens() local
204 ri = &nb_acl6_rules_in; in parse_sp6_tokens()
210 rule_ipv6 = &acl6_rules_in[*ri]; in parse_sp6_tokens()
213 ri = &nb_acl6_rules_out; in parse_sp6_tokens()
219 rule_ipv6 = &acl6_rules_out[*ri]; in parse_sp6_tokens()
534 *ri = *ri + 1; in parse_sp6_tokens()
H A Dsa.c289 uint32_t *ri /*rule index*/; in parse_sa_tokens() local
303 ri = &nb_sa_in; in parse_sa_tokens()
307 rule = &sa_in[*ri]; in parse_sa_tokens()
310 ri = &nb_sa_out; in parse_sa_tokens()
314 rule = &sa_out[*ri]; in parse_sa_tokens()
801 *ri = *ri + 1; in parse_sa_tokens()
/f-stack/freebsd/mips/include/
H A Dpmc_mdep.h74 uint32_t mips_get_perfctl(int cpu, int ri, uint32_t event, uint32_t caps);
/f-stack/freebsd/contrib/device-tree/Bindings/serial/
H A Dsnps-dw-apb-uart.yaml93 ri-override:
116 ri-override;
/f-stack/freebsd/netpfil/ipfw/
H A Dip_fw_table_algo.c2686 struct numarray *ri; in numarray_find() local
2691 return (ri); in numarray_find()
2698 struct numarray *ri; in ta_lookup_numarray() local
2702 if (ri != NULL) { in ta_lookup_numarray()
2703 *val = ri->value; in ta_lookup_numarray()
2783 struct numarray *ri; in ta_add_numarray() local
2795 if (ri != NULL) { in ta_add_numarray()
2800 value = ri->value; in ta_add_numarray()
2833 struct numarray *ri; in ta_del_numarray() local
2840 if (ri == NULL) in ta_del_numarray()
[all …]
/f-stack/freebsd/netgraph/
H A Dng_macfilter.c373 macfilter_find_mac(macfilter_p mfp, const u_char *ether, u_int *ri) in macfilter_find_mac() argument
383 *ri = middle; in macfilter_find_mac()
393 *ri = base; in macfilter_find_mac()
/f-stack/freebsd/sys/
H A Dpmc.h911 #define PMC_PHW_INDEX_TO_STATE(ri) ((ri) & PMC_PHW_RI_MASK) argument

12