Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

CBQE:0 Remove validate_last_checkpointed_seqno method. The logging ha…

…s changed, failing all tests

Change-Id: I5ae6f246dc8c1d79505edba79353e8b127e821ec
Reviewed-on: http://review.couchbase.org/39501
Reviewed-by: Aruna Piravi <aruna@couchbase.com>
Tested-by: Aruna Piravi <aruna@couchbase.com>
  • Loading branch information...
commit 2eb276643860129bc475f00771c17089f430a332 1 parent 29aef80
@arunapiravi arunapiravi authored arunapiravi committed
Showing with 0 additions and 19 deletions.
  1. +0 −19 pytests/xdcr/checkpointXDCR.py
View
19 pytests/xdcr/checkpointXDCR.py
@@ -113,8 +113,6 @@ def get_and_validate_latest_checkpoint(self):
self.log.info ("Verifying commitopaque/remote failover log ...")
if seqno != 0:
self.validate_remote_failover_log(commit_opaque[0], commit_opaque[1])
- self.log.info ("Verifying last checkpointed seqno ...")
- self.validate_last_checkpointed_seqno(int(seqno))
self.log.info ("Verifying local failover uuid ...")
local_vb_uuid, _ = self.get_failover_log(self.src_master)
self.assertTrue(int(local_vb_uuid) == int(failover_uuid),
@@ -140,23 +138,6 @@ def get_failover_log(self, master):
stats = MemcachedClientHelper.direct_client(vb0_active_node, 'default').stats('vbucket-seqno')
return stats['vb_0:uuid'], stats['vb_0:high_seqno']
- """ Checks if seqno in checkpoint record points to the """
- def validate_last_checkpointed_seqno(self, last_seqno=0):
- shell = RemoteMachineShellConnection(self.src_master)
- os_type = shell.extract_remote_info().distribution_type
- if os_type.lower() == 'windows':
- logs_dir = "C:/Program Files/Couchbase/Server/var/lib/couchbase/logs/xdcr.*"
- else:
- logs_dir = "/opt/couchbase/var/lib/couchbase/logs/xdcr.*"
- out, error = shell.execute_command("ls -rt %s | xargs grep \"source start sequence\" | tail -10" % (logs_dir))
- for replicated_seqnum in out:
- self.log.info(replicated_seqnum)
- out, error = shell.execute_command("ls -rt %s | xargs grep \"source start sequence\" | tail -1" % (logs_dir))
- self.log.info(out)
- seqno = int(out[0][-1])
- self.assertTrue(last_seqno == seqno,"The last checkpointed_seqno from record is %s, while log says %s"
- %(last_seqno, seqno))
-
""" Gets _commit_for_checkpoint call history recorded so far on a node """
def get_checkpoint_call_history(self, node):
shell = RemoteMachineShellConnection(node)
Please sign in to comment.
Something went wrong with that request. Please try again.