Home
last modified time | relevance | path

Searched refs:slaves (Results 1 – 25 of 72) sorted by relevance

123

/f-stack/app/redis-5.0.5/tests/integration/
H A Dreplication.tcl169 lassign $res role offset slaves
172 assert {[llength $slaves] == 1}
173 lassign [lindex $slaves 0] master_host master_port slave_offset
192 set slaves {}
199 lappend slaves [srv 0 client]
201 lappend slaves [srv 0 client]
203 lappend slaves [srv 0 client]
249 [$master dbsize] == [[lindex $slaves 2] dbsize]
256 set digest0 [[lindex $slaves 0] debug digest]
257 set digest1 [[lindex $slaves 1] debug digest]
[all …]
H A Dreplication-2.tcl23 test {No write if min-slaves-to-write is < attached slaves} {
54 test {min-slaves-to-write is ignored by slaves} {
/f-stack/dpdk/drivers/net/bonding/
H A Deth_bond_private.h79 uint16_t slaves[RTE_MAX_ETHPORTS]; /**< Slave port id array */ member
105 uint16_t slave_count, uint16_t *slaves);
141 struct bond_slave_details slaves[RTE_MAX_ETHPORTS]; member
197 find_slave_by_id(uint16_t *slaves, uint16_t slaves_count, uint16_t slave_id) { in find_slave_by_id() argument
201 if (slave_id == slaves[pos]) in find_slave_by_id()
259 uint16_t slave_count, uint16_t *slaves);
263 uint16_t slave_count, uint16_t *slaves);
267 uint16_t slave_count, uint16_t *slaves);
H A Drte_eth_bond_pmd.c289 uint16_t slaves[RTE_MAX_ETHPORTS]; in rx_burst_8023ad() local
577 uint16_t slaves[RTE_MAX_ETHPORTS]; in bond_ethdev_tx_burst_round_robin() local
731 slaves[i] = hash % slave_count; in burst_xmit_l23_hash()
805 slaves[i] = hash % slave_count; in burst_xmit_l34_hash()
921 uint16_t slaves[RTE_MAX_ETHPORTS]; in bond_ethdev_tx_burst_tlb() local
1518 internals->slaves[i].port_id, in mac_address_slaves_update()
1871 memmove(&internals->slaves[i], &internals->slaves[i + 1], in slave_remove()
1872 sizeof(internals->slaves[0]) * in slave_remove()
1991 internals->slaves[i].port_id); in bond_ethdev_start()
2181 slave = internals->slaves[idx]; in bond_ethdev_info()
[all …]
H A Drte_eth_bond_flow.c73 ret = rte_flow_validate(internals->slaves[i].port_id, attr, in bond_flow_validate()
101 flow->flows[i] = rte_flow_create(internals->slaves[i].port_id, in bond_flow_create()
115 rte_flow_destroy(internals->slaves[i].port_id, in bond_flow_create()
135 lret = rte_flow_destroy(internals->slaves[i].port_id, in bond_flow_destroy()
185 ret = rte_flow_query(internals->slaves[i].port_id, in bond_flow_query_count()
225 ret = rte_flow_isolate(internals->slaves[i].port_id, set, err); in bond_flow_isolate()
H A Drte_eth_bond_api.c52 if (valid_bonded_port_id(internals->slaves[i].port_id) == 0) in check_for_master_bonded_ethdev()
237 uint16_t slave_port_id = internals->slaves[slave_id].port_id; in slave_rte_flow_prepare()
651 if (internals->slaves[i].port_id == slave_port_id) { in __eth_bond_slave_remove_lock_free()
670 &(internals->slaves[slave_idx].persisted_mac_addr)); in __eth_bond_slave_remove_lock_free()
697 internals->current_primary_port = internals->slaves[0].port_id; in __eth_bond_slave_remove_lock_free()
823 if (slaves == NULL) in rte_eth_bond_slaves_get()
832 slaves[i] = internals->slaves[i].port_id; in rte_eth_bond_slaves_get()
846 if (slaves == NULL) in rte_eth_bond_active_slaves_get()
854 memcpy(slaves, internals->active_slaves, in rte_eth_bond_active_slaves_get()
908 if (internals->slaves[slave_port].port_id == in rte_eth_bond_mac_address_reset()
[all …]
H A Drte_eth_bond.h197 rte_eth_bond_slaves_get(uint16_t bonded_port_id, uint16_t slaves[],
213 rte_eth_bond_active_slaves_get(uint16_t bonded_port_id, uint16_t slaves[],
H A Drte_eth_bond_8023ad.c684 uint16_t *slaves; in selection_logic() local
692 slaves = internals->active_slaves; in selection_logic()
698 agg = &bond_mode_8023ad_ports[slaves[i]]; in selection_logic()
700 if (agg->aggregator_port_id != slaves[i]) in selection_logic()
707 slaves[i], rte_strerror(-ret)); in selection_logic()
733 new_agg_id = slaves[agg_new_idx]; in selection_logic()
737 new_agg_id = slaves[agg_new_idx]; in selection_logic()
741 new_agg_id = slaves[slave_id]; in selection_logic()
743 new_agg_id = slaves[default_slave]; in selection_logic()
747 new_agg_id = slaves[slave_id]; in selection_logic()
[all …]
/f-stack/app/redis-5.0.5/tests/cluster/
H A Dcluster.tcl102 proc cluster_allocate_slaves {masters slaves} { argument
103 for {set j 0} {$j < $slaves} {incr j} {
112 proc create_cluster {masters slaves} { argument
114 if {$slaves} {
115 cluster_allocate_slaves $masters $slaves
/f-stack/dpdk/doc/guides/prog_guide/
H A Dlink_bonding_poll_mode_drv_lib.rst157 intended to provide RSS configuration on slaves transparent for client
170 changed on the slaves and default key for device is used.
180 - Create the flow in all slaves.
181 - Save all the slaves created flows objects in bonding internal flow
184 - Failure in flow creation for new slaves in slave adding time rejects
188 - Destroy the flow in all slaves and release the bond internal flow
192 - Destroy all the bonding PMD flows in all the slaves.
200 - Summarize flow counters from all the slaves, relevant only for
204 - Call to flow isolate for all slaves.
210 in one direction (from bonding to slaves).
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dreplication.c215 listRewind(slaves,&li); in replicationFeedSlaves()
255 listRewind(slaves,&li); in replicationFeedSlaves()
294 listRewind(slaves,&li); in replicationFeedSlavesFromMasterStream()
513 listAddNodeTail(server.slaves,c); in masterTryPartialResynchronization()
948 listRewind(server.slaves,&li); in updateSlavesWaitingBgsave()
2083 int slaves = 0; in roleCommand() local
2104 slaves++; in roleCommand()
2288 listRewind(server.slaves,&li); in refreshGoodSlavesCount()
2424 listRewind(server.slaves,&li); in replicationCountAcksByOffset()
2595 listLength(server.slaves)) in replicationCron()
[all …]
H A Devict.c354 int slaves = listLength(server.slaves); in freeMemoryGetNotCountedMemory() local
356 if (slaves) { in freeMemoryGetNotCountedMemory()
360 listRewind(server.slaves,&li); in freeMemoryGetNotCountedMemory()
454 int slaves = listLength(server.slaves); in freeMemoryIfNeeded() local
586 if (slaves) flushSlavesOutputBuffers(); in freeMemoryIfNeeded()
H A Dsentinel.c1266 dictRelease(ri->slaves); in releaseSentinelRedisInstance()
1425 dictRelease(ri->slaves); in sentinelResetMaster()
1487 sentinelAddr **slaves = NULL; in sentinelResetMasterAndChangeAddress() local
1497 di = dictGetIterator(master->slaves); in sentinelResetMasterAndChangeAddress()
1502 slaves = zrealloc(slaves,sizeof(sentinelAddr*)*(numslaves+1)); in sentinelResetMasterAndChangeAddress()
1512 slaves = zrealloc(slaves,sizeof(sentinelAddr*)*(numslaves+1)); in sentinelResetMasterAndChangeAddress()
1530 releaseSentinelAddr(slaves[j]); in sentinelResetMasterAndChangeAddress()
1533 zfree(slaves); in sentinelResetMasterAndChangeAddress()
3371 dictSize(ri->slaves), in sentinelInfoCommand()
4105 di = dictGetIterator(master->slaves); in sentinelSelectSlave()
[all …]
H A Dcluster.c707 node->slaves = NULL; in createClusterNode()
823 if (master->slaves[j] == slave) { in clusterNodeRemoveSlave()
826 memmove(master->slaves+j,master->slaves+(j+1), in clusterNodeRemoveSlave()
844 master->slaves = zrealloc(master->slaves, in clusterNodeAddSlave()
846 master->slaves[master->numslaves] = slave; in clusterNodeAddSlave()
868 n->slaves[j]->slaveof = NULL; in freeClusterNode()
881 zfree(n->slaves); in freeClusterNode()
2832 if (master->slaves[j] != myself && in clusterGetSlaveRank()
3652 int slaves = 0; in clusterMastersHaveSlaves() local
3657 slaves += node->numslaves; in clusterMastersHaveSlaves()
[all …]
/f-stack/freebsd/contrib/device-tree/Bindings/fsi/
H A Dfsi.txt4 The FSI bus is probe-able, so the OS is able to enumerate FSI slaves, and
5 engines within those slaves. However, we have a facility to match devicetree
16 represent the FSI slaves and their slave engines. As a basic outline:
66 FSI slaves
94 Engines are identified by their address under the slaves' address spaces. We
115 The FSI master may be connected to additional slaves, and slaves may have
/f-stack/dpdk/app/test/
H A Dtest_link_bonding.c283 slaves, RTE_MAX_ETHPORTS); in test_create_bonded_device()
343 slaves, RTE_MAX_ETHPORTS); in test_add_slave_to_bonded_device()
391 slaves, RTE_MAX_ETHPORTS); in test_remove_slave_from_bonded_device()
451 slaves, RTE_MAX_ETHPORTS); in test_add_already_bonded_slave_to_bonded_device()
489 slaves, RTE_MAX_ETHPORTS); in test_get_slaves_from_bonded_device()
575 slaves, RTE_MAX_ETHPORTS); in test_start_bonded_device()
629 slaves, RTE_MAX_ETHPORTS); in test_stop_bonded_device()
1255 slaves, RTE_MAX_ETHPORTS); in test_status_interrupt()
1283 slaves, RTE_MAX_ETHPORTS); in test_status_interrupt()
1919 slaves, RTE_MAX_ETHPORTS); in test_roundrobin_verify_slave_link_status_change_behaviour()
[all …]
/f-stack/freebsd/contrib/openzfs/contrib/dracut/02zfsexpandknowledge/
H A Dmodule-setup.sh.in110 if [[ -d /sys/dev/block/$majmin/slaves ]] ; then
111 for _depdev in /sys/dev/block/$majmin/slaves/*; do
/f-stack/freebsd/contrib/device-tree/Bindings/net/
H A Dcpsw.txt19 - slaves : Specifies number for slaves
81 slaves = <2>;
112 slaves = <2>;
/f-stack/dpdk/examples/bond/
H A Dmain.c110 uint16_t slaves[RTE_MAX_ETHPORTS]; variable
260 if (rte_eth_bond_slave_add(BOND_PORT, slaves[i]) == -1) in bond_port_init()
262 slaves[i], BOND_PORT); in bond_port_init()
747 uint16_t slaves[16] = {0}; in cmd_show_parsed() local
770 rte_eth_bond_active_slaves_get(BOND_PORT, slaves, len), in cmd_show_parsed()
844 slaves[i] = i; in main()
/f-stack/dpdk/doc/guides/rel_notes/
H A Drelease_1_8.rst16 …* Support for slaves devices which do not support link status change interrupts in the link bond…
/f-stack/freebsd/contrib/device-tree/Bindings/fpga/
H A Daltera-passive-serial.txt6 circuits in order to play nicely with other SPI slaves on the same bus.
H A Dxilinx-slave-serial.txt6 circuits in order to play nicely with other SPI slaves on the same bus.
/f-stack/freebsd/contrib/device-tree/Bindings/spi/
H A Dqcom,spi-qcom-qspi.yaml15 dual, or quad wire transmission modes for read/write access to slaves such
/f-stack/app/redis-5.0.5/tests/cluster/tests/
H A D04-resharding.tcl155 lassign $role myrole myoffset slaves
/f-stack/freebsd/contrib/device-tree/src/arm/
H A Ddra72-evm.dts73 slaves = <1>;

123