# let's clear the response queue
self.clearToResponderQueue()
- # we might be already blocked, but we should have been able to send
+ # we might be already truncated, but we should have been able to send
# at least self._dynBlockQPS queries
self.assertGreaterEqual(allowed, self._dynBlockQPS)
(_, receivedResponse) = self.sendUDPQuery(query, response=None, useQueue=False)
self.assertEquals(receivedResponse, truncatedResponse)
+ # check over TCP, which should not be truncated
+ (receivedQuery, receivedResponse) = self.sendTCPQuery(query, response)
+
+ self.assertEquals(query, receivedQuery)
+ self.assertEquals(receivedResponse, response)
+
# wait until we are not blocked anymore
time.sleep(self._dynBlockDuration + self._dynBlockPeriod)