_test_multiprocessing.py - OpenGrok cross reference for /third_party/python/Lib/test/_test

Lines Matching defs:connection
45 import multiprocessing.connection
132 from multiprocessing.connection import wait
3063             # Close the connection.Listener socket which gets opened as a part
3205         # We test that a pipe connection can be closed by parent
3372         for family in self.connection.families:
3373             l = self.connection.Listener(family=family)
3375             self.assertRaises(OSError, self.connection.Listener,
3379         with self.connection.Listener() as l:
3380             with self.connection.Client(l.address) as c:
3391         with self.connection.Listener("\0something") as listener:
3392             with self.connection.Client(listener.address) as client:
3407         conn = cls.connection.Client(address)
3412         for family in self.connection.families:
3413             l = self.connection.Listener(family=family)
3423         l = self.connection.Listener()
3439         for fam in self.connection.families:
3440             l = self.connection.Listener(family=fam)
3441             c = self.connection.Client(l.address)
3528 # Test of sending connection and socket objects between processes
3545             l = cls.connection.Listener(family=fam)
3564             client = cls.connection.Client(address)
3577         families = self.connection.families
3592             msg = ('This connection uses family %s' % fam).encode('ascii')
3600         msg = latin('This connection uses a normal socket')
4082         # maintain its connection with the current process, and success when
4627         conn = multiprocessing.connection.Connection(44977608)
4638                           multiprocessing.connection.Connection, -1)
4652                           multiprocessing.connection.deliver_challenge,
4662                     return multiprocessing.connection.CHALLENGE
4669                           multiprocessing.connection.answer_challenge,
4785         from multiprocessing.connection import wait
4825         from multiprocessing.connection import wait
4866         from multiprocessing.connection import wait
4894         from multiprocessing.connection import wait
4937         from multiprocessing.connection import wait
4956             multiprocessing.connection.Listener(r'\\.\test')
4961             multiprocessing.connection.Listener('/var/test.pipe')
5005         conn = multiprocessing.connection.Client(address)
5014             l = multiprocessing.connection.Listener(family='AF_INET')
5190         with multiprocessing.connection.Listener() as l:
5208             client = multiprocessing.connection.Client(address)
5845     connection = multiprocessing.connection
5931     connection = multiprocessing.dummy.connection