Feb 12, 2022 · Feb 9, 2022 · Feb 12, 2022
diff --git a/tests/ptrack.py b/tests/ptrack.py
            "postgres",
            "CREATE EXTENSION ptrack")

        ptrack_version = self.get_ptrack_version(node)

        # Create table
        node.safe_psql(
            "postgres",
        node.stop(['-m', 'immediate', '-D', node.data_dir])

        ptrack_map = os.path.join(node.data_dir, 'global', 'ptrack.map')
        ptrack_map_mmap = os.path.join(node.data_dir, 'global', 'ptrack.map.mmap')

        # Let`s do index corruption. ptrack.map, ptrack.map.mmap
        # Let`s do index corruption. ptrack.map
        with open(ptrack_map, "rb+", 0) as f:
            f.seek(42)
            f.write(b"blablahblahs")
            f.flush()
            f.close

        with open(ptrack_map_mmap, "rb+", 0) as f:
            f.seek(42)
            f.write(b"blablahblahs")
            f.flush()
            f.close

 #        os.remove(os.path.join(node.logs_dir, node.pg_log_name))

        try:
        if self.verbose:
            print('Ptrack version:', ptrack_version)
        if ptrack_version >= self.version_to_num("2.3"):
            node.slow_start()
            # we should die here because exception is what we expect to happen
            self.assertEqual(
                1, 0,
                "Expecting Error because ptrack.map is corrupted"
                "\n Output: {0} \n CMD: {1}".format(
                    repr(self.output), self.cmd))
        except StartNodeException as e:

            log_file = os.path.join(node.logs_dir, 'postgresql.log')
            with open(log_file, 'r') as f:
                log_content = f.read()

            self.assertIn(
                'Cannot start node',
                e.message,
                '\n Unexpected Error Message: {0}\n'
                ' CMD: {1}'.format(repr(e.message), self.cmd))
                'WARNING:  ptrack read map: incorrect checksum of file "{0}"'.format(ptrack_map),
                log_content)

        log_file = os.path.join(node.logs_dir, 'postgresql.log')
        with open(log_file, 'r') as f:
            log_content = f.read()
            node.stop(['-D', node.data_dir])
        else:
            try:
                node.slow_start()
                # we should die here because exception is what we expect to happen
                self.assertEqual(
                    1, 0,
                    "Expecting Error because ptrack.map is corrupted"
                    "\n Output: {0} \n CMD: {1}".format(
                        repr(self.output), self.cmd))
            except StartNodeException as e:
                self.assertIn(
                    'Cannot start node',
                    e.message,
                    '\n Unexpected Error Message: {0}\n'
                    ' CMD: {1}'.format(repr(e.message), self.cmd))

            log_file = os.path.join(node.logs_dir, 'postgresql.log')
            with open(log_file, 'r') as f:
                log_content = f.read()

        self.assertIn(
            'FATAL:  ptrack init: incorrect checksum of file "{0}"'.format(ptrack_map),
            log_content)
 self.assertIn(
 'FATAL:  ptrack init: incorrect checksum of file "{0}"'.format(ptrack_map),
 log_content)

        self.set_auto_conf(node, {'ptrack.map_size': '0'})

        node.slow_start()

        try:
Original file line number	Diff line number	Diff line change
Expand Up		@@ -4314,6 +4314,8 @@ def test_corrupt_ptrack_map(self):
		"postgres",
		"CREATE EXTENSION ptrack")

		ptrack_version = self.get_ptrack_version(node)

		# Create table
		node.safe_psql(
		"postgres",
Expand All		@@ -4338,48 +4340,55 @@ def test_corrupt_ptrack_map(self):
		node.stop(['-m', 'immediate', '-D', node.data_dir])

		ptrack_map = os.path.join(node.data_dir, 'global', 'ptrack.map')
		ptrack_map_mmap = os.path.join(node.data_dir, 'global', 'ptrack.map.mmap')

		# Let`s do index corruption. ptrack.map, ptrack.map.mmap
		# Let`s do index corruption. ptrack.map
		with open(ptrack_map, "rb+", 0) as f:
		f.seek(42)
		f.write(b"blablahblahs")
		f.flush()
		f.close

		with open(ptrack_map_mmap, "rb+", 0) as f:
		f.seek(42)
		f.write(b"blablahblahs")
		f.flush()
		f.close

		# os.remove(os.path.join(node.logs_dir, node.pg_log_name))

		try:
		if self.verbose:
		print('Ptrack version:', ptrack_version)
		if ptrack_version >= self.version_to_num("2.3"):
		node.slow_start()
		# we should die here because exception is what we expect to happen
		self.assertEqual(
		1, 0,
		"Expecting Error because ptrack.map is corrupted"
		"\n Output: {0} \n CMD: {1}".format(
		repr(self.output), self.cmd))
		except StartNodeException as e:

		log_file = os.path.join(node.logs_dir, 'postgresql.log')
		with open(log_file, 'r') as f:
		log_content = f.read()

		self.assertIn(
		'Cannot start node',
		e.message,
		'\n Unexpected Error Message: {0}\n'
		' CMD: {1}'.format(repr(e.message), self.cmd))
		'WARNING: ptrack read map: incorrect checksum of file "{0}"'.format(ptrack_map),
		log_content)

		log_file = os.path.join(node.logs_dir, 'postgresql.log')
		with open(log_file, 'r') as f:
		log_content = f.read()
		node.stop(['-D', node.data_dir])
		else:
		try:
		node.slow_start()
		# we should die here because exception is what we expect to happen
		self.assertEqual(
		1, 0,
		"Expecting Error because ptrack.map is corrupted"
		"\n Output: {0} \n CMD: {1}".format(
		repr(self.output), self.cmd))
		except StartNodeException as e:
		self.assertIn(
		'Cannot start node',
		e.message,
		'\n Unexpected Error Message: {0}\n'
		' CMD: {1}'.format(repr(e.message), self.cmd))

		log_file = os.path.join(node.logs_dir, 'postgresql.log')
		with open(log_file, 'r') as f:
		log_content = f.read()

		self.assertIn(
		'FATAL: ptrack init: incorrect checksum of file "{0}"'.format(ptrack_map),
		log_content)
		self.assertIn(
		'FATAL: ptrack init: incorrect checksum of file "{0}"'.format(ptrack_map),
		log_content)

		self.set_auto_conf(node, {'ptrack.map_size': '0'})

		node.slow_start()

		try:
Expand Down