Home
last modified time | relevance | path

Searched refs:replica (Results 1 – 25 of 2727) sorted by relevance

12345678910>>...110

/dports/www/gallery2/gallery2/modules/replica/
H A DMANIFEST5 modules/replica/module.inc 188009325 2969428092 3634 3748
7 modules/replica/po/af.mo 1648518768 1648518768 1231 1231
8 modules/replica/po/af.po 290238438 153599591 3176 3308
9 modules/replica/po/ar.mo 136048569 136048569 1195 1195
10 modules/replica/po/ar.po 2962499312 1468570640 3177 3308
12 modules/replica/po/bg.po 932054677 3003304309 3380 3513
13 modules/replica/po/ca.mo 298332217 298332217 1209 1209
14 modules/replica/po/ca.po 1876656539 142524970 3150 3281
17 modules/replica/po/da.mo 838331293 838331293 2913 2913
20 modules/replica/po/de.po 63923991 1014163754 4261 4402
[all …]
/dports/net/pacemaker2/pacemaker-Pacemaker-2.1.1/lib/pengine/
H A Dbundle.c813 replica->node->details->remote_rsc = replica->remote; in create_remote_resource()
816 replica->remote->container = replica->container; in create_remote_resource()
871 if (replica->child && replica->ipaddr) { in create_container()
1397 CRM_ASSERT(replica && replica->node); in pe__find_bundle_replica()
1938 replica->ip->fns->free(replica->ip); in free_bundle_replica()
1944 replica->container->fns->free(replica->container); in free_bundle_replica()
1950 replica->remote->fns->free(replica->remote); in free_bundle_replica()
2028 replica->ip->fns->count(replica->ip); in pe__count_bundle()
2031 replica->child->fns->count(replica->child); in pe__count_bundle()
2037 replica->remote->fns->count(replica->remote); in pe__count_bundle()
[all …]
/dports/net/pacemaker2/pacemaker-Pacemaker-2.1.1/lib/pacemaker/
H A Dpcmk_sched_bundle.c137 replica->ip->cmds->allocate(replica->ip, prefer, data_set); in pcmk__bundle_allocate()
155 replica->remote->cmds->allocate(replica->remote, prefer, in pcmk__bundle_allocate()
177 replica->child->cmds->allocate(replica->child, replica->node, in pcmk__bundle_allocate()
222 replica->ip->cmds->create_actions(replica->ip, data_set); in pcmk__bundle_create_actions()
225 replica->container->cmds->create_actions(replica->container, in pcmk__bundle_create_actions()
327 replica->remote->cmds->internal_constraints(replica->remote, in pcmk__bundle_internal_constraints()
892 replica->ip->cmds->rsc_location(replica->ip, constraint); in pcmk__bundle_rsc_location()
923 if (replica->remote && replica->container in pcmk__bundle_expand()
967 replica->ip->cmds->expand(replica->ip, data_set); in pcmk__bundle_expand()
973 replica->remote->cmds->expand(replica->remote, data_set); in pcmk__bundle_expand()
[all …]
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/shortcircuit/
H A DShortCircuitCache.java412 (replica.refCount - 1) + " -> " + replica.refCount + in ref()
418 (replica.refCount - 1) + " -> " + replica.refCount + in ref()
465 replica, replica.getEvictableTimeNs()); in unref()
481 " for %s)", replica.refCount, replica); in unref()
532 munmap(replica); in demoteOldEvictableMmaped()
562 purge(replica); in trimEvictionMaps()
572 replica.munmap(); in munmap()
668 unref(replica); in purge()
766 purge(replica); in fetch()
769 ref(replica); in fetch()
[all …]
/dports/devel/raknet/raknet-3.9.2_10,1/Source/
H A DReplicaManager.cpp151 replicaAndCommand.replica=replicatedObjects[i].replica; in AddParticipant()
186 replicaAndCommand.replica=replica; in Construct()
316 replicaAndTime.replica=replica; in ReferencePointer()
372 replicaAndCommand.replica=replica; in SetScope()
423 replicaAndCommand.replica=replica; in SignalSerializeNeeded()
555 replicaAndCommand.replica=replica; in SignalSerializationFlags()
611 replicaAndCommand.replica=replica; in AccessSerializationFlags()
806 remoteObject.replica=replica; in Update()
822 remoteObject.replica=replica; in Update()
854 remoteObject.replica=replica; in Update()
[all …]
H A DReplicaManager3.cpp31 replica=0; in LastSerializationResult()
565 RakNet::Replica3 *replica = lsr->replica; in AutoConstructByQuery() local
822 Replica3 *replica; in OnConstruction() local
849 if (replica==0) in OnConstruction()
937 if (replica==0) in OnConstruction()
991 Replica3 *replica; in OnSerialize() local
996 if (replica) in OnSerialize()
1106 Replica3 *replica; in OnLocalConstructionAccepted() local
1533 lsr->replica=replica3; in OnLocalReference()
1596 lsr->replica=replica3; in OnDownloadFromThisSystem()
[all …]
/dports/devel/php-ice37/ice-3.7.2/cpp/test/IceStorm/rep1/
H A Dtest.py55 instance=None if replica is None else self.icestorm[replica],
64 instance=None if replica is None else self.icestorm[replica],
69 if replica is None:
82 for replica in range(0, 3):
90 for replica in range(0, 3):
100 for replica in range(1, 3):
119 for replica in range(0, 2):
137 for replica in range(1, 3):
182 rununsub2(replica)
208 rununsub2(replica)
[all …]
/dports/devel/ice37/ice-3.7.2/cpp/test/IceStorm/rep1/
H A Dtest.py55 instance=None if replica is None else self.icestorm[replica],
64 instance=None if replica is None else self.icestorm[replica],
69 if replica is None:
82 for replica in range(0, 3):
90 for replica in range(0, 3):
100 for replica in range(1, 3):
119 for replica in range(0, 2):
137 for replica in range(1, 3):
182 rununsub2(replica)
208 rununsub2(replica)
[all …]
/dports/devel/py-ice37/ice-3.7.2/cpp/test/IceStorm/rep1/
H A Dtest.py55 instance=None if replica is None else self.icestorm[replica],
64 instance=None if replica is None else self.icestorm[replica],
69 if replica is None:
82 for replica in range(0, 3):
90 for replica in range(0, 3):
100 for replica in range(1, 3):
119 for replica in range(0, 2):
137 for replica in range(1, 3):
182 rununsub2(replica)
208 rununsub2(replica)
[all …]
/dports/net/samba412/samba-4.12.15/source4/wrepl_server/
H A Dwrepl_apply_records.c681 rec->name = &replica->name; in r_do_add()
682 rec->type = replica->type; in r_do_add()
683 rec->state = replica->state; in r_do_add()
684 rec->node = replica->node; in r_do_add()
726 rec->name = &replica->name; in r_do_replace()
727 rec->type = replica->type; in r_do_replace()
728 rec->state = replica->state; in r_do_replace()
729 rec->node = replica->node; in r_do_replace()
890 struct wrepl_name replica; member
1052 state->replica = *replica; in r_do_challenge()
[all …]
/dports/net-mgmt/wmi-client/wmi-1.3.16/Samba/source/wrepl_server/
H A Dwrepl_apply_records.c680 rec->name = &replica->name; in r_do_add()
681 rec->type = replica->type; in r_do_add()
682 rec->state = replica->state; in r_do_add()
683 rec->node = replica->node; in r_do_add()
725 rec->name = &replica->name; in r_do_replace()
726 rec->type = replica->type; in r_do_replace()
727 rec->state = replica->state; in r_do_replace()
728 rec->node = replica->node; in r_do_replace()
831 merge->node = replica->node; in r_do_mhomed_merge()
889 struct wrepl_name replica; member
[all …]
/dports/net/liveMedia/live/liveMedia/
H A DStreamReplicator.cpp71 replica->handleClosure(); in getNextFrame()
84 fPrimaryReplica = replica; in getNextFrame()
233 StreamReplica* replica; in onSourceClosure() local
236 replica->fNext = NULL; in onSourceClosure()
237 replica->handleClosure(); in onSourceClosure()
241 replica->fNext = NULL; in onSourceClosure()
242 replica->handleClosure(); in onSourceClosure()
246 replica->handleClosure(); in onSourceClosure()
254 StreamReplica* replica; in deliverReceivedFrame() local
257 replica->fNext = NULL; in deliverReceivedFrame()
[all …]
/dports/devel/p5-App-SD/App-SD-0.75/bin/
H A Dgit-sd3 replica=$(git config --get sd.local-replica)
4 if [ -z "$replica" ]; then
16 replica="$gitdir/sd"
18 echo "Setting it to '$replica':"
20 echo " git config --add sd.local-replica $replica"
22 git config --add sd.local-replica "$replica"
31 if [ -n "$gitemail" ] && [ ! -e "$replica/config" ]; then
35 if [ ! -d "$replica" ]; then
36 mkdir "$replica"
48 SD_REPO="$replica" sd clone --from "github:$gitorigin"
[all …]
/dports/databases/redis-devel/redis-0e5b813/tests/cluster/tests/
H A D16-transactions-on-replica.tcl14 set replica [Rn 1]
18 wait_for_ofs_sync $primary $replica
19 catch {$replica GET a} err
24 $replica READONLY
25 assert {[$replica GET a] eq {1}}
32 wait_for_ofs_sync $primary $replica
33 assert {[$replica HGET h a] eq {1}}
39 $replica MULTI
47 $replica MULTI
48 catch {$replica HSET h b 4} err
[all …]
H A D17-diskless-load-swapdb.tcl19 set replica [Rn 1]
23 $replica READONLY
24 $replica config set repl-diskless-load swapdb
25 $replica config set appendonly no
26 $replica config set save ""
27 $replica config rewrite
39 wait_for_ofs_sync $master $replica
40 assert_equal {1} [$replica get $slot0_key]
44 $replica save
64 $replica READONLY
[all …]
/dports/databases/redis6/redis-6.0.16/tests/cluster/tests/
H A D16-transactions-on-replica.tcl14 set replica [Rn 1]
18 wait_for_ofs_sync $primary $replica
19 catch {$replica GET a} err
24 $replica READONLY
25 assert {[$replica GET a] eq {1}}
32 wait_for_ofs_sync $primary $replica
33 assert {[$replica HGET h a] eq {1}}
39 $replica MULTI
47 $replica MULTI
48 catch {$replica HSET h b 4} err
[all …]
H A D17-diskless-load-swapdb.tcl19 set replica [Rn 1]
23 $replica READONLY
24 $replica config set repl-diskless-load swapdb
25 $replica config set appendonly no
26 $replica config set save ""
27 $replica config rewrite
40 assert_equal {1} [$replica get $slot0_key]
41 assert_equal $slot0_key [$replica CLUSTER GETKEYSINSLOT 0 1]
44 $replica save
64 $replica READONLY
[all …]
/dports/www/elixir-phoenix_pubsub/phoenix_pubsub-1.0.2/lib/phoenix/tracker/
H A Dreplica.ex50 downtime = now - replica.last_heartbeat_at
52 downtime > perm_interval -> {Map.delete(replicas, replica.name), replica, permdown(replica)}
54 updated_replica = down(replica)
55 {Map.put(replicas, replica.name, updated_replica), replica, updated_replica}
56 true -> {replicas, replica, replica}
61 Fetches a replica from the map with matching name and version from the ref.
66 {:ok, %Replica{vsn: ^vsn} = replica} -> {:ok, replica}
72 defp permdown(replica), do: %Replica{replica | status: :permdown}
74 defp down(replica), do: %Replica{replica | status: :down}
76 defp touch_last_heartbeat(replica) do
[all …]
/dports/databases/xapian-core12/xapian-core-1.2.25/tests/
H A Dapi_replicate.cc162 Xapian::DatabaseReplica & replica, in apply_changeset() argument
175 replica.set_read_fd(fd); in apply_changeset()
201 Xapian::DatabaseReplica & replica, in replicate() argument
233 postlist_to_string(replica, *t)); in check_equal_dbs()
314 replica.close(); in DEFINE_TESTCASE()
339 replica.close(); in DEFINE_TESTCASE()
438 replica.close(); in DEFINE_TESTCASE()
527 replica.close(); in DEFINE_TESTCASE()
617 replica.close(); in DEFINE_TESTCASE()
748 replica.close(); in DEFINE_TESTCASE()
[all …]
/dports/databases/xapian-core/xapian-core-1.4.18/tests/
H A Dapi_replicate.cc142 Xapian::DatabaseReplica & replica, in get_changeset() argument
165 Xapian::DatabaseReplica & replica, in apply_changeset() argument
177 replica.set_read_fd(fd); in apply_changeset()
203 Xapian::DatabaseReplica & replica, in replicate() argument
227 Xapian::Database replica(replicapath); in check_equal_dbs() local
235 postlist_to_string(replica, *t)); in check_equal_dbs()
274 Xapian::DatabaseReplica replica(replicapath); in DEFINE_TESTCASE() local
302 Xapian::DatabaseReplica replica(replicapath); in DEFINE_TESTCASE() local
350 Xapian::DatabaseReplica replica(replicapath); in DEFINE_TESTCASE() local
440 Xapian::DatabaseReplica & replica, in replicate_with_brokenness() argument
[all …]
/dports/databases/p5-Prophet/Prophet-0.751/doc/
H A Dforeign-replicas12 A foreign replica is a (possibly read-only) data store that is not a Prophet
13 replica (such as RT or Twitter). A Prophet replica can act as a gateway to a
14 foreign replica.
18 replica must act as a gateway to a foreign replica. It would be great if Prophet could, in a gener…
25 …replica, we use metadata stored in bob's replica to interact with the foreign replica. _merge_tick…
32 doesn't have a full replica, it ends up accidentally using Bob's
41 <Sartak> can't it be a replica we just don't propagate?
43 <Sartak> we're being bitten by reusing the Prophet replica's records
44 <Sartak> if the foreign replica had its own replica, then there would be no overlap and this issue …
45 <Sartak> the foreign replica is using the real replica's _merge_ticket records
[all …]
/dports/databases/redis-devel/redis-0e5b813/tests/unit/moduleapi/
H A Dtestrdb.tcl53 set replica [srv 0 client]
64 $replica config set repl-diskless-load swapdb
66 $replica config set hz 500
68 $replica config set dynamic-hz no
84 $replica replicaof $master_host $master_port
108 $master client kill type replica
141 set replica [srv 0 client]
157 $replica config set save ""
171 $replica testrdb.set.before value1_replica
175 $replica debug populate 200 slave 10
[all …]
/dports/databases/redis-devel/redis-0e5b813/tests/integration/
H A Dpsync2-master-restart.tcl8 set replica [srv -1 client]
15 $replica replicaof $master_host $master_port
19 [status $replica master_link_status] eq {up} &&
42 $replica config resetstat
68 assert {[status $replica sync_partial_ok] == 1}
89 $replica config resetstat
109 assert {[status $replica sync_partial_ok] == 1}
112 assert {$digest eq [$replica debug digest]}
136 $replica config resetstat
154 assert {[status $replica sync_full] == 1}
[all …]
/dports/devel/ice37/ice-3.7.2/scripts/
H A DIceStormUtil.py16 self.replica = replica
58 props['IceStorm.NodeId'] = self.replica
72 manager = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 0) argument
73 …publish = lambda replica: "{0}:{1}".format(current.getTestEndpoint(self.portnum + replica * 4 + 1), argument
75 node = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 2) argument
76 admin = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 3) argument
80 "IceStorm.TopicManager.Endpoints" : manager(self.replica),
81 "IceStorm.Publish.Endpoints" : publish(self.replica),
82 "Ice.Admin.Endpoints" : admin(self.replica),
87 props['IceStorm.Node.Endpoints'] = node(self.replica)
[all …]
/dports/devel/php-ice37/ice-3.7.2/scripts/
H A DIceStormUtil.py16 self.replica = replica
58 props['IceStorm.NodeId'] = self.replica
72 manager = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 0) argument
73 …publish = lambda replica: "{0}:{1}".format(current.getTestEndpoint(self.portnum + replica * 4 + 1), argument
75 node = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 2) argument
76 admin = lambda replica: current.getTestEndpoint(self.portnum + replica * 4 + 3) argument
80 "IceStorm.TopicManager.Endpoints" : manager(self.replica),
81 "IceStorm.Publish.Endpoints" : publish(self.replica),
82 "Ice.Admin.Endpoints" : admin(self.replica),
87 props['IceStorm.Node.Endpoints'] = node(self.replica)
[all …]

12345678910>>...110