Skip to content

Commit dcd6357

Browse files
committed
Merge branch 'sq-ccs_ex_charm4py' of https://github.com/charmplusplus/charm4py into sq-ccs_ex_charm4py
2 parents db9256d + dcf2f3d commit dcd6357

File tree

1 file changed

+12
-3
lines changed

1 file changed

+12
-3
lines changed

examples/ccs/ccs_server.py

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,11 @@
1-
from charm4py import charm, Chare, Array
1+
from charm4py import charm, Chare, Array, Future, Reducer, Group
2+
3+
class RegisterPerChare(Chare):
4+
5+
def register(self, return_future):
6+
charm.CcsRegisterHandler("ping2", handler)
7+
charm.CcsRegisterHandler("ping", handler)
8+
self.reduce(return_future, Reducer.nop)
29

310
def handler(msg):
411
if charm.CcsIsRemoteRequest():
@@ -10,8 +17,10 @@ def handler(msg):
1017
def main(args):
1118
# No need to initialize converse, because charm.start does this
1219
# just register the handler
13-
charm.CcsRegisterHandler("ping2", handler)
14-
charm.CcsRegisterHandler("ping", handler)
20+
reg_wait = Future()
21+
registers = Group(RegisterPerChare)
22+
registers.register(reg_wait)
23+
reg_wait.get()
1524
print("CCS Handlers registered . Waiting for net requests...")
1625

1726

0 commit comments

Comments
 (0)