Test transferring a big message.
(self)
| 1229 | self.testSendQueuedMultiFrameMessages(sendSingleFrameMsg=True) |
| 1230 | |
| 1231 | def testBigMessage(self): |
| 1232 | """ |
| 1233 | Test transferring a big message. |
| 1234 | """ |
| 1235 | self.snd, self.rcv = self.link("test-link") |
| 1236 | self.c1 = self.snd.session.connection |
| 1237 | self.c2 = self.rcv.session.connection |
| 1238 | self.snd.open() |
| 1239 | self.rcv.open() |
| 1240 | self.pump() |
| 1241 | |
| 1242 | self.rcv.flow(2) |
| 1243 | self.snd.delivery("tag") |
| 1244 | msg = self.message(1024 * 256) |
| 1245 | n = self.snd.send(msg) |
| 1246 | assert n == len(msg) |
| 1247 | assert self.snd.advance() |
| 1248 | |
| 1249 | self.pump() |
| 1250 | |
| 1251 | binary = self.rcv.recv(1024 * 256) |
| 1252 | assert binary == msg |
| 1253 | |
| 1254 | binary = self.rcv.recv(1024) |
| 1255 | assert binary is None |
| 1256 | |
| 1257 | def testMaxFrameAbort(self): |
| 1258 | self.snd, self.rcv = self.link("test-link", max_frame=[0, 512]) |