sample repro

gistfile1.py

  def test_stream_request_MB_13286(self):


        dcp_client2 = DcpClient(self.host, self.port)
        doc_count = 100

	# load docs
        for i in range(doc_count):
            self.mcd_client.set('key' + str(i), 0, 0, 'value', 0)


        self.dcp_client = DcpClient(self.host, self.port)
        response = self.dcp_client.open_producer("producer")
        assert response['status'] == SUCCESS


        stream = self.dcp_client.stream_req(0, 0, 0, doc_count, 0)
        assert stream.status == SUCCESS
	# stream 1/2 docs 
        response = dcp_client2.open_producer("producer")
        for i in range(doc_count/2):
            resp = stream.next_response()
            print resp
            # expecting no-op
            if 'status' in resp and resp['status'] != SUCCESS:
                import pdb; pdb.set_trace() 
            #assert resp['status'] == SUCCESS

        # stream remaining with new connection
        stream = dcp_client2.stream_req(0, 0, 0, doc_count, 0)
        assert stream.status == SUCCESS
        stream.run()
        assert stream.last_by_seqno == doc_count
        dcp_client2.close()