| 1060 | # |
| 1061 | |
| 1062 | class _UpperCaser(multiprocessing.Process): |
| 1063 | |
| 1064 | def __init__(self): |
| 1065 | multiprocessing.Process.__init__(self) |
| 1066 | self.child_conn, self.parent_conn = multiprocessing.Pipe() |
| 1067 | |
| 1068 | def run(self): |
| 1069 | self.parent_conn.close() |
| 1070 | for s in iter(self.child_conn.recv, None): |
| 1071 | self.child_conn.send(s.upper()) |
| 1072 | self.child_conn.close() |
| 1073 | |
| 1074 | def submit(self, s): |
| 1075 | assert type(s) is str |
| 1076 | self.parent_conn.send(s) |
| 1077 | return self.parent_conn.recv() |
| 1078 | |
| 1079 | def stop(self): |
| 1080 | self.parent_conn.send(None) |
| 1081 | self.parent_conn.close() |
| 1082 | self.child_conn.close() |
| 1083 | |
| 1084 | class _TestSubclassingProcess(BaseTestCase): |
| 1085 |
no outgoing calls
searching dependent graphs…