(request_id)
| 2259 | |
| 2260 | # Cause a server error on getmore. |
| 2261 | def receive_message(request_id): |
| 2262 | # Discard the actual server response. |
| 2263 | Connection.receive_message(conn, request_id) |
| 2264 | |
| 2265 | # responseFlags bit 1 is QueryFailure. |
| 2266 | msg = struct.pack("<iiiii", 1 << 1, 0, 0, 0, 0) |
| 2267 | msg += encode({"$err": "mock err", "code": 0}) |
| 2268 | return message._OpReply.unpack(msg) |
| 2269 | |
| 2270 | conn.receive_message = receive_message |
| 2271 | with self.assertRaises(OperationFailure): |