Source files: 340

Clones detected: 1392

6751 of 37417 lines are duplicates (18.04%)

Parameters
clustering_threshold = 10
distance_threshold = 5
size_threshold = 5
hashing_depth = 1
clusterize_using_hash = False
clusterize_using_dcup = False

Clone # 1
Distance between two fragments = 0
Clone size = 81

Source file "./spacewalk/common/rhn_mpm.py" The first line is 176		Source file "./server/handlers/app/rhn_mpm.py" The first line is 153
def _read_bytes(self, stream, amt):     ret = ''     while amt:         buf = stream.read(min(amt, self._buffer_size))         if not buf:             return ret         ret = (ret) + (buf)         amt = (amt) - (len(buf))     return ret		def _read_bytes(self, stream, amt):     ret = ''     while amt:         buf = stream.read(min(amt, self._buffer_size))         if not buf:             return ret         ret = (ret) + (buf)         amt = (amt) - (len(buf))     return ret
def _read_header(self, header_data, header_flags):     if (header_flags) & (MPM_HEADER_COMPRESSED_GZIP):         t = cStringIO.StringIO(header_data)         g = gzip.GzipFile(None, 'r', 0, t)         header_data = g.read()         g.close()         t.close()     try:         params, foo = xmlrpclib.loads(header_data)     except:         raise     self.header = MPM_Header(params[0])		def _read_header(self, header_data, header_flags):     if (header_flags) & (MPM_HEADER_COMPRESSED_GZIP):         t = cStringIO.StringIO(header_data)         g = gzip.GzipFile(None, 'r', 0, t)         header_data = g.read()         g.close()         t.close()     try:         params, foo = xmlrpclib.loads(header_data)     except:         raise     self.header = MPM_Header(params[0])
def _read_payload(self, payload_stream, payload_flags):     payload_stream.seek(0, 0)     if (payload_flags) & (MPM_PAYLOAD_COMPRESSED_GZIP):         g = gzip.GzipFile(None, 'r', 0, payload_stream)         t = tempfile.TemporaryFile()         self.stream_copy(g, t)         g.close()         payload_stream = t     self.payload_stream = payload_stream		def _read_payload(self, payload_stream, payload_flags):     payload_stream.seek(0, 0)     if (payload_flags) & (MPM_PAYLOAD_COMPRESSED_GZIP):         g = gzip.GzipFile(None, 'r', 0, payload_stream)         t = tempfile.TemporaryFile()         self.stream_copy(g, t)         g.close()         payload_stream = t     self.payload_stream = payload_stream
def write(self, output_stream):     if self.header is None:         raise Exception()     header_stream, header_size = self._encode_header()     payload_stream, payload_size = self._encode_payload()     lead_arr = (self._magic, 1, ('\x00') * (3), self.header_flags, self.payload_flags, header_size, payload_size, ('\x00') * (92))     lead = apply(struct.pack, ((self._lead_format)) + (lead_arr))     output_stream.write(lead)     self.stream_copy(header_stream, output_stream)     self.stream_copy(payload_stream, output_stream)		def write(self, output_stream):     if self.header is None:         raise Exception()     header_stream, header_size = self._encode_header()     payload_stream, payload_size = self._encode_payload()     lead_arr = (self._magic, 1, ('\x00') * (3), self.header_flags, self.payload_flags, header_size, payload_size, ('\x00') * (92))     lead = apply(struct.pack, ((self._lead_format)) + (lead_arr))     output_stream.write(lead)     self.stream_copy(header_stream, output_stream)     self.stream_copy(payload_stream, output_stream)
def add_header_flag(self, flag):     self.header_flags = (self.header_flags) | (flag)		def add_header_flag(self, flag):     self.header_flags = (self.header_flags) | (flag)
def add_payload_flag(self, flag):     self.payload_flags = (self.payload_flags) | (flag)		def add_payload_flag(self, flag):     self.payload_flags = (self.payload_flags) | (flag)
def reset_header_flags(self):     self.header_flags = 0		def reset_header_flags(self):     self.header_flags = 0
def reset_payload_flags(self):     self.payload_flags = 0		def reset_payload_flags(self):     self.payload_flags = 0
def _encode_header(self):     assert self.header is not None     stream = tempfile.TemporaryFile()     data = xmlrpclib.dumps((_replace_null(self.header)))     if (self.header_flags) & (MPM_HEADER_COMPRESSED_GZIP):         f = gzip.GzipFile(None, 'wb', 9, stream)         f.write(data)         f.close()     else:         stream.write(data)     stream.flush()     stream.seek(0, 2)     size = stream.tell()     stream.seek(0, 0)     return (stream, size)		def _encode_header(self):     assert self.header is not None     stream = tempfile.TemporaryFile()     data = xmlrpclib.dumps((_replace_null(self.header)))     if (self.header_flags) & (MPM_HEADER_COMPRESSED_GZIP):         f = gzip.GzipFile(None, 'wb', 9, stream)         f.write(data)         f.close()     else:         stream.write(data)     stream.flush()     stream.seek(0, 2)     size = stream.tell()     stream.seek(0, 0)     return (stream, size)
def _encode_payload(self):     assert self.payload_stream is not None     stream = tempfile.TemporaryFile()     if (self.payload_flags) & (MPM_PAYLOAD_COMPRESSED_GZIP):         f = gzip.GzipFile(None, 'wb', 9, stream)         self.stream_copy(self.payload_stream, f)         f.close()     else:         stream = self.payload_stream     stream.flush()     stream.seek(0, 2)     size = stream.tell()     stream.seek(0, 0)     return (stream, size)		def _encode_payload(self):     assert self.payload_stream is not None     stream = tempfile.TemporaryFile()     if (self.payload_flags) & (MPM_PAYLOAD_COMPRESSED_GZIP):         f = gzip.GzipFile(None, 'wb', 9, stream)         self.stream_copy(self.payload_stream, f)         f.close()     else:         stream = self.payload_stream     stream.flush()     stream.seek(0, 2)     size = stream.tell()     stream.seek(0, 0)     return (stream, size)
def stream_copy(self, source, dest):     while 1:         buf = source.read(self._buffer_size)         if not buf:             break         dest.write(buf)		def stream_copy(self, source, dest):     while 1:         buf = source.read(self._buffer_size)         if not buf:             break         dest.write(buf)

Clone # 2
Distance between two fragments = 4
Clone size = 78

Source file "./server/test/unit-test/misc_functions.py" The first line is 25		Source file "./server/test/misc_functions.py" The first line is 48
def create_new_org():     org_name = ('unittest-org-%.3f') % (time.time())     org_password = ('unittest-password-%.3f') % (time.time())     org_id = rhnServerGroup.create_new_org(org_name, org_password)     rhnSQL.commit()     return org_id		def create_new_org():     org_name = ('unittest-org-%.3f') % (time.time())     org_password = ('unittest-password-%.3f') % (time.time())     org_id = rhnServerGroup.create_new_org(org_name, org_password)     rhnSQL.commit()     return (org_id, org_name, org_password)
def _create_server_group(org_id, name, description, max_members):     s = rhnServerGroup.ServerGroup()     s.set_org_id(org_id)     s.set_name(name)     s.set_description(description)     s.set_max_members(max_members)     s.save()     rhnSQL.commit()     return s		def _create_server_group(org_id, name, description, max_members):     s = rhnServerGroup.ServerGroup()     s.set_org_id(org_id)     s.set_name(name)     s.set_description(description)     s.set_max_members(max_members)     s.save()     rhnSQL.commit()     return s
def create_server_group(params):     return apply(_create_server_group, (), params)		def create_server_group(params):     return apply(_create_server_group, (), params)
def fetch_server_group(org_id, name):     s = rhnServerGroup.ServerGroup()     s.load(org_id, name)     return s		def fetch_server_group(org_id, name):     s = rhnServerGroup.ServerGroup()     s.load(org_id, name)     return s
_query_fetch_server_groups = rhnSQL.Statement('\n select sgm.server_group_id\n from rhnServerGroupMembers sgm,\n rhnServerGroup sg\n where sgm.server_id = :server_id\n and sgm.server_group_id = sg.id\n and sg.group_type is null\n')		_query_fetch_server_groups = rhnSQL.Statement('\n select sgm.server_group_id\n from rhnServerGroupMembers sgm,\n rhnServerGroup sg\n where sgm.server_id = :server_id\n and sgm.server_group_id = sg.id\n and sg.group_type is null\n')
def fetch_server_groups(server_id):     h = rhnSQL.prepare(_query_fetch_server_groups)     h.execute(server_id=server_id)     groups = map(lambda x: x['server_group_id'], (h.fetchall_dict()) or ([]))     groups.sort()     return groups		def fetch_server_groups(server_id):     h = rhnSQL.prepare(_query_fetch_server_groups)     h.execute(server_id=server_id)     groups = map(lambda x: x['server_group_id'], (h.fetchall_dict()) or ([]))     groups.sort()     return groups
def build_server_group_params(**kwargs):     params = {'org_id': 'no such org', 'name': ('unittest group name %.3f') % (time.time()), 'description': ('unittest group description %.3f') % (time.time()), 'max_members': 1001}     params.update(kwargs)     return params		def build_server_group_params(**kwargs):     params = {'org_id': 'no such org', 'name': ('unittest group name %.3f') % (time.time()), 'description': ('unittest group description %.3f') % (time.time()), 'max_members': 1001}     params.update(kwargs)     return params
def create_new_user(org_id=None, username=None, password=None, roles=None):     if org_id is None:         org_id = create_new_org()     else:         org_id = lookup_org_id(org_id)     if username is None:         username = ('unittest-user-%.3f') % (time.time())     if password is None:         password = ('unittest-password-%.3f') % (time.time())     if roles is None:         roles = []     u = rhnUser.User(username, password)     u.set_org_id(org_id)     u.save()     u.contact['password'] = password     u.save()     user_id = u.getid()     h = rhnSQL.prepare('\n select ug.id\n from rhnUserGroupType ugt, rhnUserGroup ug\n where ug.org_id = :org_id\n and ug.group_type = ugt.id\n and ugt.label = :role\n ')     create_ugm = rhnSQL.Procedure('rhn_user.add_to_usergroup')     for role in roles:         h.execute(org_id=org_id, role=role)         row = h.fetchone_dict()         if not row:             raise InvalidRoleError(org_id, role)         user_group_id = row['id']         create_ugm(user_id, user_group_id)     rhnSQL.commit()     return u		def create_new_user(org_id=None, username=None, password=None, roles=None):     if org_id is None:         org_id = create_new_org()     else:         org_id = lookup_org_id(org_id)     if username is None:         username = ('unittest-user-%.3f') % (time.time())     if password is None:         password = ('unittest-password-%.3f') % (time.time())     if roles is None:         roles = []     u = rhnUser.User(username, password)     u.set_org_id(org_id)     u.save()     u.contact['password'] = password     u.save()     user_id = u.getid()     h = rhnSQL.prepare('\n select ug.id\n from rhnUserGroupType ugt, rhnUserGroup ug\n where ug.org_id = :org_id\n and ug.group_type = ugt.id\n and ugt.label = :role\n ')     create_ugm = rhnSQL.Procedure('rhn_user.add_to_usergroup')     for role in roles:         h.execute(org_id=org_id, role=role)         row = h.fetchone_dict()         if not row:             raise InvalidRoleError(org_id, role)         user_group_id = row['id']         create_ugm(user_id, user_group_id)     rhnSQL.commit()     return u
def lookup_org_id(org_id):     if isinstance(org_id, types.StringType):         u = rhnUser.search(org_id)         if not u:             raise rhnServerGroup.InvalidUserError(org_id)         return u.contact['org_id']     t = rhnSQL.Table('web_customer', 'id')     row = t[org_id]     if not row:         raise rhnServerGroup.InvalidOrgError(org_id)     return row['id']		def lookup_org_id(org_id):     if isinstance(org_id, types.StringType):         u = rhnUser.search(org_id)         if not u:             raise rhnServerGroup.InvalidUserError(org_id)         return u.contact['org_id']     t = rhnSQL.Table('web_customer', 'id')     row = t[org_id]     if not row:         raise rhnServerGroup.InvalidOrgError(org_id)     return row['id']
class InvalidEntitlementError(Exception):     pass		class InvalidRoleError(Exception):     pass

Clone # 3
Distance between two fragments = 0
Clone size = 35

Source file "./server/test/unit-test/misc_functions.py" The first line is 150		Source file "./server/test/misc_functions.py" The first line is 349
def create_activation_key(org_id=None, user_id=None, groups=None, channels=None, entitlement_level=None, note=None, server_id=None):     if org_id is None:         need_user = 1         org_id = create_new_org()     else:         need_user = 0     if user_id is None:         if need_user:             u = create_new_user(org_id=org_id)             user_id = u.getid()     else:         u = rhnUser.User('', '')         u.reload(user_id)     if groups is None:         groups = []         for i in range(3):             params = build_server_group_params(org_id=org_id)             sg = create_server_group(params)             groups.append(sg.get_id())     if channels is None:         channels = ['rhel-i386-as-3-beta', 'rhel-i386-as-2.1-beta']     if entitlement_level is None:         entitlement_level = 'provisioning_entitled'     if note is None:         note = ('Test activation key %d') % (int(time.time()))     a = rhnActivationKey.ActivationKey()     a.set_user_id(user_id)     a.set_org_id(org_id)     a.set_entitlement_level(entitlement_level)     a.set_note(note)     a.set_server_groups(groups)     a.set_channels(channels)     a.set_server_id(server_id)     a.save()     rhnSQL.commit()     return a		def create_activation_key(org_id=None, user_id=None, groups=None, channels=None, entitlement_level=None, note=None, server_id=None):     if org_id is None:         need_user = 1         org_id = create_new_org()     else:         need_user = 0     if user_id is None:         if need_user:             u = create_new_user(org_id=org_id)             user_id = u.getid()     else:         u = rhnUser.User('', '')         u.reload(user_id)     if groups is None:         groups = []         for i in range(3):             params = build_server_group_params(org_id=org_id)             sg = create_server_group(params)             groups.append(sg.get_id())     if channels is None:         channels = ['rhel-i386-as-3-beta', 'rhel-i386-as-2.1-beta']     if entitlement_level is None:         entitlement_level = 'provisioning_entitled'     if note is None:         note = ('Test activation key %d') % (int(time.time()))     a = rhnActivationKey.ActivationKey()     a.set_user_id(user_id)     a.set_org_id(org_id)     a.set_entitlement_level(entitlement_level)     a.set_note(note)     a.set_server_groups(groups)     a.set_channels(channels)     a.set_server_id(server_id)     a.save()     rhnSQL.commit()     return a

Clone # 4
Distance between two fragments = 4
Clone size = 33

Source file "./server/test/test_solve_dependencies.py" The first line is 378		Source file "./server/test/test_solve_dependencies.py" The first line is 317
def testUp2dateFilterGTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)		def testUp2dateFilterGTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)
def testUp2dateFilterLT1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterLT(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1
def testUp2dateFilterLTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)		def testUp2dateFilterLTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)

Clone # 5
Distance between two fragments = 3
Clone size = 26

Source file "./satellite_tools/satsync.py" The first line is 1279		Source file "./satellite_tools/satsync.py" The first line is 1103
for channel, pids in missing_packages.items():     package_count = len(pids)     log(1, (messages.package_parsing) % ((channel, (package_count) or ('NONE RELEVANT'))))     if not package_count:         continue     log(1, ' * WARNING: this may be a very slow process.')     pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)     if CFG.DEBUG > 2:         pb.redrawYN = 0     pb.printAll(1)     ss = SequenceServer(pids[:], nevermorethan=self._batch_size)     while not ss.doneYN():         chunk = ss.getChunk()         item_count = len(chunk)         stream_loader.process(chunk)         ss.clearChunk()         pb.addTo(item_count)         pb.printIncrement()     pb.printComplete()		for channel, pids in missing_packages.items():     package_count = len(pids)     log(1, (messages.package_parsing) % ((channel, (package_count) or ('NONE RELEVANT'))))     if not package_count:         continue     log(1, messages.warning_slow)     pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)     if CFG.DEBUG > 2:         pb.redrawYN = 0     pb.printAll(1)     ss = SequenceServer(pids[:], nevermorethan=self._batch_size)     while not ss.doneYN():         chunk = ss.getChunk()         item_count = len(chunk)         stream_loader.process(chunk)         ss.clearChunk()         pb.addTo(item_count)         pb.printIncrement()     pb.printComplete()
h.close()		h.close()
missing_packages = self._compute_not_cached_source_packages()		missing_packages = self._missing_not_cached_packages()
for channel, pids in missing_packages.items():     if pids:         raise ReprocessingNeeded		for channel, pids in missing_packages.items():     if pids:         raise ReprocessingNeeded

Clone # 6
Distance between two fragments = 4
Clone size = 26

Source file "./server/importlib/channelImport.py" The first line is 345		Source file "./server/importlib/channelImport.py" The first line is 304
def preprocess(self):     for rcm in self.batch:         self.arches[rcm['arch']] = None         self.channels[rcm['channel']] = None		def preprocess(self):     for dcm in self.batch:         self.arches[dcm['arch']] = None         self.channels[dcm['channel']] = None
def fix(self):     self.backend.lookupChannelArches(self.arches)     self.backend.lookupChannels(self.channels)     for dcm in self.batch:         arch = self.arches[rcm['arch']]         if arch is None:             rcm.ignored = 1             raise InvalidArchError(rcm['arch'], ('Invalid release_channel_map arch %s') % (rcm['arch']))         channel = self.channels[rcm['channel']]         if channel is None:             rcm.ignored = 1             raise InvalidChannelError(rcm['channel'], ('Invalid release_channel_map channel %s') % (rcm['channel']))         rcm['arch'] = arch         rcm['channel_id'] = channel['id']		def fix(self):     self.backend.lookupChannelArches(self.arches)     self.backend.lookupChannels(self.channels)     for dcm in self.batch:         arch = self.arches[dcm['arch']]         if arch is None:             dcm.ignored = 1             raise InvalidArchError(dcm['arch'], ('Invalid dist_channel_map arch %s') % (dcm['arch']))         channel = self.channels[dcm['channel']]         if channel is None:             dcm.ignored = 1             raise InvalidChannelError(dcm['channel'], ('Invalid dist_channel_map channel %s') % (dcm['channel']))         dcm['arch'] = arch         dcm['channel_id'] = channel['id']
def submit(self):     try:         self.backend.processReleaseChannelMap(self.batch)     except:         self.backend.rollback()         raise     self.backend.commit()		def submit(self):     try:         self.backend.processDistChannelMap(self.batch)     except:         self.backend.rollback()         raise     self.backend.commit()

Clone # 7
Distance between two fragments = 2
Clone size = 24

Source file "./server/handlers/app/packages.py" The first line is 521		Source file "./server/handlers/app/packages.py" The first line is 357
if (pkg_info.has_key('checksum')) and (CFG.ENABLE_NVREA):     checksum_exists = 1     _checksum_sql_filter = 'and c.checksum = :checksum\n and c.checksum_type = :checksum_type'		if (package.has_key('checksum')) and (CFG.ENABLE_NVREA):     checksum_exists = 1     _checksum_sql_filter = 'and c.checksum = :checksum\n and c.checksum_type = :checksum_type'
h = rhnSQL.prepare((self._get_pkg_info_query) % (_checksum_sql_filter))		h = rhnSQL.prepare((self._get_pkg_info_query) % (_checksum_sql_filter))
pkg_epoch = None		pkg_epoch = None
if pkg_info['epoch'] != '':     pkg_epoch = pkg_info['epoch']		if package['epoch'] != '':     pkg_epoch = package['epoch']
if checksum_exists:     h.execute(pkg_name=pkg_info['name'], pkg_epoch=pkg_epoch, pkg_version=pkg_info['version'], pkg_rel=pkg_info['release'], pkg_arch=pkg_info['arch'], orgid=org_id, checksum_type=pkg_info['checksum_type'], checksum=pkg_info['checksum']) else:     h.execute(pkg_name=pkg_info['name'], pkg_epoch=pkg_epoch, pkg_version=pkg_info['version'], pkg_rel=pkg_info['release'], pkg_arch=pkg_info['arch'], orgid=org_id)		if checksum_exists:     h.execute(pkg_name=package['name'], pkg_epoch=pkg_epoch, pkg_version=package['version'], pkg_rel=package['release'], pkg_arch=package['arch'], orgid=org_id, checksum_type=package['checksum_type'], checksum=package['checksum']) else:     h.execute(pkg_name=package['name'], pkg_epoch=pkg_epoch, pkg_version=package['version'], pkg_rel=package['release'], pkg_arch=package['arch'], orgid=org_id)
row = h.fetchone_dict()		row = h.fetchone_dict()

Clone # 8
Distance between two fragments = 4
Clone size = 22

Source file "./server/handlers/app/packages.py" The first line is 613		Source file "./server/handlers/app/packages.py" The first line is 447
def getSourcePackageMD5sum(self, username, password, info):     log_debug(3)     self._MD5sum2Checksum_info(info)     return self._Checksum2MD5sum_list(self.getSourcePackageChecksum(username, password, info))		def getPackageMD5sum(self, username, password, info):     log_debug(3)     self._MD5sum2Checksum_info(info)     return self._Checksum2MD5sum_list(self.getPackageChecksum(username, password, info))
def getSourcePackageChecksumBySession(self, session_string, info):     log_debug(3)     pkg_infos = info.get('packages')     channels = info.get('channels', [])     force = info.get('force', 0)     orgid = info.get('org_id')     try:         if orgid == 'null':             null_org = 1         else:             null_org = None         org_id, force = rhnPackageUpload.authenticate_session(session_string, channels=channels, null_org=null_org, force=force)     except rhnSession.InvalidSessionError:         raise rhnFault(33)     except rhnSession.ExpiredSessionError:         raise rhnFault(34)     return self._getSourcePackageChecksum(org_id, pkg_infos)		def getPackageChecksumBySession(self, session_string, info):     log_debug(3)     pkg_infos = info.get('packages')     channels = info.get('channels', [])     force = info.get('force', 0)     orgid = info.get('org_id')     try:         if orgid == 'null':             null_org = 1         else:             null_org = None         org_id, force = rhnPackageUpload.authenticate_session(session_string, channels=channels, null_org=null_org, force=force)     except rhnSession.InvalidSessionError:         raise rhnFault(33)     except rhnSession.ExpiredSessionError:         raise rhnFault(34)     return self._getPackageChecksum(org_id, pkg_infos)

Clone # 9
Distance between two fragments = 1
Clone size = 20

Source file "./common/test/unit-test/test_gettext.py" The first line is 130		Source file "./common/test/unit-test/test_gettext.py" The first line is 74
def test_go_1(self):     lang = 'en'     s = 'Good day'     target = s     self._test(lang, s, target)		def test_en_1(self):     lang = 'en'     s = 'Good day'     target = s     self._test(lang, s, target)
def test_en_2(self):     lang = 'en'     s = 'How do you do?'     target = s     self._test(lang, s, target)		def test_en_2(self):     lang = 'en'     s = 'How do you do?'     target = s     self._test(lang, s, target)
def test_en_3(self):     lang = 'en'     s = 'What should I do now?'     target = s     self._test(lang, s, target)		def test_en_3(self):     lang = 'en'     s = 'What should I do now?'     target = s     self._test(lang, s, target)
def test_en_missing_1(self):     lang = 'en'     s = "This string doesn't exist in the translation"     target = s     self._test(lang, s, target)		def test_en_missing_1(self):     lang = 'en'     s = "This string doesn't exist in the translation"     target = s     self._test(lang, s, target)

Clone # 10
Distance between two fragments = 2
Clone size = 20

Source file "./server/handlers/xmlrpc/up2date.py" The first line is 463		Source file "./server/handlers/xmlrpc/up2date.py" The first line is 432
def __solveDep_arch(self, system_id, deps, action, clientVersion):     log_debug(5, system_id, deps, action, clientVersion)     faultString = _('Invalid value %s (%s)')     if type(deps) not in (ListType, TupleType):         log_error('Invalid argument type', type(deps))         raise rhnFault(30, (faultString) % ((deps, type(deps))))     for dep in deps:         if type(dep) is not StringType:             log_error('Invalid dependency member', type(dep))             raise rhnFault(30, (faultString) % ((dep, type(dep))))     deps = filter(len, deps)     if not deps:         return []     server = self.auth_system(system_id)     log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))     result = rhnDependency.solve_dependencies_arch(self.server_id, deps, clientVersion)     transport = rhnFlags.get('outputTransportOptions')     transport['X-RHN-Action'] = action     return result		def __solveDep(self, system_id, deps, action, clientVersion):     log_debug(5, system_id, deps, action, clientVersion)     faultString = _('Invalid value %s (%s)')     if type(deps) not in (ListType, TupleType):         log_error('Invalid argument type', type(deps))         raise rhnFault(30, (faultString) % ((deps, type(deps))))     for dep in deps:         if type(dep) is not StringType:             log_error('Invalid dependency member', type(dep))             raise rhnFault(30, (faultString) % ((dep, type(dep))))     deps = filter(len, deps)     if not deps:         return []     server = self.auth_system(system_id)     log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))     result = rhnDependency.solve_dependencies(self.server_id, deps, clientVersion)     transport = rhnFlags.get('outputTransportOptions')     transport['X-RHN-Action'] = action     return result

Clone # 11
Distance between two fragments = 3
Clone size = 19

Source file "./server/test/unit-test/test_server_registration.py" The first line is 225		Source file "./server/test/misc_functions.py" The first line is 294
class Counter:     _counter = 0     def value(self):         val = self._counter         self._counter = (val) + (1)         return val		class Counter:     _counter = 0     def value(self):         val = self._counter         self._counter = (val) + (1)         return val
def build_new_system_params_with_username(**kwargs):     import time     val = Counter().value()     rnd_string = ('%d-%d') % ((int(time.time()), val))     params = {'os_release': '9', 'architecture': 'i686-redhat-linux', 'profile_name': ('unittest server ') + (rnd_string), 'username': 'no such user', 'password': 'no such password'}     params.update(kwargs)     if params.has_key('token'):         params['token']     return params		def build_sys_params_with_username(**kwargs):     val = Counter().value()     rnd_string = ('%s%s') % ((int(time.time()), val))     params = {'os_release': '9', 'architecture': 'i386', 'profile_name': ('unittest server ') + (rnd_string), 'username': 'no such user', 'password': 'no such password'}     params.update(kwargs)     if params.has_key('token'):         params['token']     return params

Clone # 12
Distance between two fragments = 3
Clone size = 19

Source file "./server/rhnChannel.py" The first line is 583		Source file "./server/rhnChannel.py" The first line is 561
def delete_channel_families(entries):     if not isinstance(entries, ListType):         raise InvalidEntryError(entries, 'Not a list')     ret = []     for e in entries:         if not isinstance(e, DictType):             raise InvalidEntryError(e, 'Entry is not a dictionary')         label = e.get('label')         if not label:             raise InvalidEntryError(e, 'Missing required field label')         c = ChannelFamily()         c.load_by_label(label)         if not c.exists():             ret.append(label)             continue         msg = _delete_channel_family(c)         if msg is not None:             ret.append(msg)     return ret		def delete_channels(entries):     if not isinstance(entries, ListType):         raise InvalidEntryError(entries, 'Not a list')     ret = []     for e in entries:         if not isinstance(e, DictType):             raise InvalidEntryError(e, 'Entry is not a dictionary')         label = e.get('label')         if not label:             raise InvalidEntryError(e, 'Missing required field label')         c = Channel()         c.load_by_label(label)         if not c.exists():             ret.append(label)             continue         msg = _delete_channel(c)         if msg is not None:             ret.append(msg)     return ret

Clone # 13
Distance between two fragments = 4
Clone size = 17

Source file "./server/rhnChannel.py" The first line is 670		Source file "./server/rhnChannel.py" The first line is 646
if pattern:     query = '\n select id \n from rhnChannel\n where label like :pattern\n '     h = rhnSQL.prepare(query)     h.execute(pattern=pattern) else:     query = 'select id from rhnChannel'     h = rhnSQL.prepare(query)     h.execute()		if pattern:     query = '\n select id \n from rhnChannelFamily \n where org_id is null\n and label like :pattern\n '     h = rhnSQL.prepare(query)     h.execute(pattern=pattern) else:     query = 'select id from rhnChannelFamily where org_id is null'     h = rhnSQL.prepare(query)     h.execute()
ret = []		ret = []
while 1:     row = h.fetchone_dict()     if not row:         break     channel_id = row['id']     c = Channel().load_by_id(channel_id)     ret.append(c.as_dict())		while 1:     row = h.fetchone_dict()     if not row:         break     channel_family_id = row['id']     c = ChannelFamily().load_by_id(channel_family_id)     ret.append(c.as_dict())
return ret		return ret

Clone # 14
Distance between two fragments = 0
Clone size = 17

Source file "./common/rhn_memusage.py" The first line is 18		Source file "./server/test/test-cx_Oracle-memleak.py" The first line is 24
def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])		def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])
def _line_value(line):     arr = string.split(line, ':', 1)     if len(arr) == 1:         return None     return string.strip(arr[1])		def _line_value(line):     arr = string.split(line, ':', 1)     if len(arr) == 1:         return None     return string.strip(arr[1])

Clone # 15
Distance between two fragments = 1
Clone size = 17

Source file "./server/importlib/packageImport.py" The first line is 531		Source file "./server/importlib/packageImport.py" The first line is 308
def submit(self):     upload_force = self.uploadForce     if (not upload_force) and (self._update_last_modified):         upload_force = 0.5     try:         self.backend.processSourcePackages(self.batch, uploadForce=upload_force, forceVerify=self.forceVerify, ignoreUploaded=self.ignoreUploaded, transactional=self.transactional)     except:         self.backend.rollback()         raise     self.backend.commit()     if not self._update_last_modified:         for p in self.batch:             if (p.diff) and (p.diff.level == 0.5):                 p.diff = None		def submit(self):     upload_force = self.uploadForce     if (not upload_force) and (self._update_last_modified):         upload_force = 0.5     try:         self.backend.processPackages(self.batch, uploadForce=upload_force, forceVerify=self.forceVerify, ignoreUploaded=self.ignoreUploaded, transactional=self.transactional)     except:         self.backend.rollback()         raise     self.backend.commit()     if not self._update_last_modified:         for p in self.batch:             if (p.diff) and (p.diff.level == 0.5):                 p.diff = None

Clone # 16
Distance between two fragments = 1
Clone size = 16

Source file "./server/handlers/xmlrpc/up2date.py" The first line is 536		Source file "./server/rhnSQL/sql_lib.py" The first line is 76
def __check_Int_String(name, value, package=package):     if type(value) not in (StringType, IntType):         log_error(("Field %s (%s)=`%s' in %s does not pass type checks") % ((name, type(value), str(value), str(package))))         raise rhnFault(30, (_('Invalid value for %s in package tuple: %s (%s)')) % ((name, value, type(value))))     value = str(value)     if not len(value):         log_error(('Field %s has an EMPTY value in %s') % ((value, package)))     return value		def __check_Int_String(name, value, package=package):     if type(value) not in (StringType, IntType):         log_error(("Field %s (%s) = `%s' in %s does not pass type checks") % ((name, type(value), str(value), str(package))))         raise rhnFault(30, (_('Invalid value for %s in package tuple: %s (%s)')) % ((name, value, type(value))))     value = str(value)     if not len(value):         log_error(('Field %s has an EMPTY value in %s') % ((value, package)))     return value
log_debug(4, package)		log_debug(4, package)
if (type(package) not in (ListType, TupleType)) or (len(package) < 3):     log_error(('Package argument %s (len = %d) does not pass type checks') % ((str(package), len(package))))     raise rhnFault(30, (_('Invalid package parameter %s (%s)')) % ((package, type(package))))		if (type(package) not in (ListType, TupleType)) or (len(package) < 3):     log_error(('Package argument %s (len = %d) does not pass type checks') % ((str(package), len(package))))     raise rhnFault(30, (_('Invalid package parameter %s (%s)')) % ((package, type(package))))

Clone # 17
Distance between two fragments = 3
Clone size = 16

Source file "./server/test/test_leak4.py" The first line is 21		Source file "./server/test/test_leak2.py" The first line is 22
db = connect('rhnuser/rhnuser@webdev')		dbh = Connect('rhnuser/rhnuser@webdev')
c = db.prepare('select 1 from dual')		h = dbh.prepare('select 1 from dual')
start = time.time()		start = time.time()
i = 0		i = 0
write = sys.stderr.write		write = sys.stderr.write
while i < 10000:     c.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)		while i < 10000:     h.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)

Clone # 18
Distance between two fragments = 2
Clone size = 15

Source file "./server/handlers/app/channel.py" The first line is 525		Source file "./server/handlers/app/channel.py" The first line is 497
def revokeChannelPermission(self, label, role, commit, username, password):     log_debug(3)     self._auth(username, password)     h = rhnSQL.prepare('\n delete from rhnchannelpermission\n where (channel_id, role_id, user_id) in\n (select c.id, cpr.id, wc.id\n from rhnchannelpermissionrole cpr,\n rhnchannel c,\n web_contact wc\n where wc.login = :username\n and c.label = :label\n and cpr.label = :role_label)\n ')     try:         h.execute(username=username, label=label, role_label=role)     except rhnSQL.SQLError, e:         rhnSQL.rollback()         raise rhnFault(23, str(e.args[1]), explain=0)     if commit:         rhnSQL.commit()     else:         rhnSQL.rollback()         return 1     return 0		def channelManagePermission(self, label, role, commit, username, password):     log_debug(3)     self._auth(username, password)     h = rhnSQL.prepare('\n insert into rhnChannelPermission\n (channel_id, role_id, user_id)\n (select c.id, cpr.id, wc.id\n from rhnchannelpermissionrole cpr,\n rhnchannel c,\n web_contact wc\n where wc.login = :username \n and c.label = :label\n and cpr.label = :role_label)\n ')     try:         h.execute(username=username, label=label, role_label=role)     except rhnSQL.SQLError, e:         rhnSQL.rollback()         raise rhnFault(23, str(e.args[1]), explain=0)     if commit:         rhnSQL.commit()     else:         rhnSQL.rollback()         return 1     return 0

Clone # 19
Distance between two fragments = 0
Clone size = 15

Source file "./spacewalk/common/rhn_mpm.py" The first line is 127		Source file "./server/handlers/app/rhn_mpm.py" The first line is 103
_lead_format = '!16sB3s4L92s'		_lead_format = '!16sB3s4L92s'
_magic = 'mpmpackage012345'		_magic = 'mpmpackage012345'
def __init__(self):     self.header = None     self.payload_stream = None     self.header_flags = MPM_HEADER_COMPRESSED_GZIP     self.payload_flags = 0     assert len(self._magic) == 16     self._buffer_size = 16384		def __init__(self):     self.header = None     self.payload_stream = None     self.header_flags = MPM_HEADER_COMPRESSED_GZIP     self.payload_flags = 0     assert len(self._magic) == 16     self._buffer_size = 16384
def _read_lead(self, stream):     lead = self._read_bytes(stream, 128)     if len(lead) != 128:         raise InvalidPackageError()     arr = struct.unpack(self._lead_format, lead)     return arr		def _read_lead(self, stream):     lead = self._read_bytes(stream, 128)     if len(lead) != 128:         raise InvalidPackageError()     arr = struct.unpack(self._lead_format, lead)     return arr

Clone # 20
Distance between two fragments = 0
Clone size = 15

Source file "./satellite_tools/satComputePkgHeaders.py" The first line is 28		Source file "./_apache.py" The first line is 21
SERVER_RETURN = 0		SERVER_RETURN = 0
def log_error(*args):     pass		def log_error(*args):     pass
def make_table(*args):     pass		def make_table(*args):     pass
def parse_qs(*args):     pass		def parse_qs(*args):     pass
def parse_qsl(*args):     pass		def parse_qsl(*args):     pass
status = None		status = None
table = None		table = None
config_tree = None		config_tree = None
server_root = None		server_root = None
mpm_query = None		mpm_query = None
exists_config_define = None		exists_config_define = None

Clone # 21
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 378		Source file "./satellite_tools/sync_handlers.py" The first line is 292
class ErrataContainer(xmlSource.ErrataContainer):     def endItemCallback(self):         xmlSource.ErrataContainer.endItemCallback(self)         if not self.batch:             return None         c = ErrataCollection()         c.add_erratum(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class PackageContainer(xmlSource.PackageContainer):     def endItemCallback(self):         xmlSource.PackageContainer.endItemCallback(self)         if not self.batch:             return None         c = PackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_errata_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ErrataContainer())     return handler		def get_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(PackageContainer())     return handler

Clone # 22
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 378		Source file "./satellite_tools/sync_handlers.py" The first line is 410
class ErrataContainer(xmlSource.ErrataContainer):     def endItemCallback(self):         xmlSource.ErrataContainer.endItemCallback(self)         if not self.batch:             return None         c = ErrataCollection()         c.add_erratum(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class KickstartableTreesContainer(xmlSource.KickstartableTreesContainer):     def endItemCallback(self):         xmlSource.KickstartableTreesContainer.endItemCallback(self)         if not self.batch:             return None         c = KickstartableTreesCollection()         c.add_item(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_errata_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ErrataContainer())     return handler		def get_kickstarts_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(KickstartableTreesContainer())     return handler

Clone # 23
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 378		Source file "./satellite_tools/sync_handlers.py" The first line is 163
class ErrataContainer(xmlSource.ErrataContainer):     def endItemCallback(self):         xmlSource.ErrataContainer.endItemCallback(self)         if not self.batch:             return None         c = ErrataCollection()         c.add_erratum(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ChannelContainer(xmlSource.ChannelContainer):     def endItemCallback(self):         xmlSource.ChannelContainer.endItemCallback(self)         if not self.batch:             return None         c = ChannelCollection()         c.add_channel(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_errata_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ErrataContainer())     return handler		def get_channel_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ChannelContainer())     return handler

Clone # 24
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 378		Source file "./satellite_tools/sync_handlers.py" The first line is 319
class ErrataContainer(xmlSource.ErrataContainer):     def endItemCallback(self):         xmlSource.ErrataContainer.endItemCallback(self)         if not self.batch:             return None         c = ErrataCollection()         c.add_erratum(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class SourcePackageContainer(xmlSource.SourcePackageContainer):     def endItemCallback(self):         xmlSource.SourcePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = SourcePackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_errata_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ErrataContainer())     return handler		def get_source_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(SourcePackageContainer())     return handler

Clone # 25
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 292		Source file "./satellite_tools/sync_handlers.py" The first line is 263
class PackageContainer(xmlSource.PackageContainer):     def endItemCallback(self):         xmlSource.PackageContainer.endItemCallback(self)         if not self.batch:             return None         c = PackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ShortPackageContainer(xmlSource.IncompletePackageContainer):     def endItemCallback(self):         xmlSource.IncompletePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = ShortPackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(PackageContainer())     return handler		def get_short_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ShortPackageContainer())     return handler

Clone # 26
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 292		Source file "./satellite_tools/sync_handlers.py" The first line is 410
class PackageContainer(xmlSource.PackageContainer):     def endItemCallback(self):         xmlSource.PackageContainer.endItemCallback(self)         if not self.batch:             return None         c = PackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class KickstartableTreesContainer(xmlSource.KickstartableTreesContainer):     def endItemCallback(self):         xmlSource.KickstartableTreesContainer.endItemCallback(self)         if not self.batch:             return None         c = KickstartableTreesCollection()         c.add_item(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(PackageContainer())     return handler		def get_kickstarts_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(KickstartableTreesContainer())     return handler

Clone # 27
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 292		Source file "./satellite_tools/sync_handlers.py" The first line is 163
class PackageContainer(xmlSource.PackageContainer):     def endItemCallback(self):         xmlSource.PackageContainer.endItemCallback(self)         if not self.batch:             return None         c = PackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ChannelContainer(xmlSource.ChannelContainer):     def endItemCallback(self):         xmlSource.ChannelContainer.endItemCallback(self)         if not self.batch:             return None         c = ChannelCollection()         c.add_channel(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(PackageContainer())     return handler		def get_channel_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ChannelContainer())     return handler

Clone # 28
Distance between two fragments = 3
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 292		Source file "./satellite_tools/sync_handlers.py" The first line is 319
class PackageContainer(xmlSource.PackageContainer):     def endItemCallback(self):         xmlSource.PackageContainer.endItemCallback(self)         if not self.batch:             return None         c = PackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class SourcePackageContainer(xmlSource.SourcePackageContainer):     def endItemCallback(self):         xmlSource.SourcePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = SourcePackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(PackageContainer())     return handler		def get_source_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(SourcePackageContainer())     return handler

Clone # 29
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 263		Source file "./satellite_tools/sync_handlers.py" The first line is 319
class ShortPackageContainer(xmlSource.IncompletePackageContainer):     def endItemCallback(self):         xmlSource.IncompletePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = ShortPackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class SourcePackageContainer(xmlSource.SourcePackageContainer):     def endItemCallback(self):         xmlSource.SourcePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = SourcePackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_short_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ShortPackageContainer())     return handler		def get_source_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(SourcePackageContainer())     return handler

Clone # 30
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 410		Source file "./satellite_tools/sync_handlers.py" The first line is 163
class KickstartableTreesContainer(xmlSource.KickstartableTreesContainer):     def endItemCallback(self):         xmlSource.KickstartableTreesContainer.endItemCallback(self)         if not self.batch:             return None         c = KickstartableTreesCollection()         c.add_item(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ChannelContainer(xmlSource.ChannelContainer):     def endItemCallback(self):         xmlSource.ChannelContainer.endItemCallback(self)         if not self.batch:             return None         c = ChannelCollection()         c.add_channel(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_kickstarts_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(KickstartableTreesContainer())     return handler		def get_channel_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ChannelContainer())     return handler

Clone # 31
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 410		Source file "./satellite_tools/sync_handlers.py" The first line is 319
class KickstartableTreesContainer(xmlSource.KickstartableTreesContainer):     def endItemCallback(self):         xmlSource.KickstartableTreesContainer.endItemCallback(self)         if not self.batch:             return None         c = KickstartableTreesCollection()         c.add_item(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class SourcePackageContainer(xmlSource.SourcePackageContainer):     def endItemCallback(self):         xmlSource.SourcePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = SourcePackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_kickstarts_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(KickstartableTreesContainer())     return handler		def get_source_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(SourcePackageContainer())     return handler

Clone # 32
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/sync_handlers.py" The first line is 163		Source file "./satellite_tools/sync_handlers.py" The first line is 319
class ChannelContainer(xmlSource.ChannelContainer):     def endItemCallback(self):         xmlSource.ChannelContainer.endItemCallback(self)         if not self.batch:             return None         c = ChannelCollection()         c.add_channel(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class SourcePackageContainer(xmlSource.SourcePackageContainer):     def endItemCallback(self):         xmlSource.SourcePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = SourcePackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass
def get_channel_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(ChannelContainer())     return handler		def get_source_package_handler():     handler = xmlSource.SatelliteDispatchHandler()     handler.set_container(SourcePackageContainer())     return handler

Clone # 33
Distance between two fragments = 0
Clone size = 14

Source file "./server/handlers/xmlrpc/up2date.py" The first line is 500		Source file "./server/handlers/xmlrpc/up2date.py" The first line is 468
log_debug(5, system_id, deps, action, clientVersion)		log_debug(5, system_id, deps, action, clientVersion)
faultString = _('Invalid value %s (%s)')		faultString = _('Invalid value %s (%s)')
if type(deps) not in (ListType, TupleType):     log_error('Invalid argument type', type(deps))     raise rhnFault(30, (faultString) % ((deps, type(deps))))		if type(deps) not in (ListType, TupleType):     log_error('Invalid argument type', type(deps))     raise rhnFault(30, (faultString) % ((deps, type(deps))))
for dep in deps:     if type(dep) is not StringType:         log_error('Invalid dependency member', type(dep))         raise rhnFault(30, (faultString) % ((dep, type(dep))))		for dep in deps:     if type(dep) is not StringType:         log_error('Invalid dependency member', type(dep))         raise rhnFault(30, (faultString) % ((dep, type(dep))))
deps = filter(len, deps)		deps = filter(len, deps)
if not deps:     return []		if not deps:     return []
server = self.auth_system(system_id)		server = self.auth_system(system_id)
log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))		log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))

Clone # 34
Distance between two fragments = 0
Clone size = 14

Source file "./server/handlers/xmlrpc/up2date.py" The first line is 500		Source file "./server/handlers/xmlrpc/up2date.py" The first line is 437
log_debug(5, system_id, deps, action, clientVersion)		log_debug(5, system_id, deps, action, clientVersion)
faultString = _('Invalid value %s (%s)')		faultString = _('Invalid value %s (%s)')
if type(deps) not in (ListType, TupleType):     log_error('Invalid argument type', type(deps))     raise rhnFault(30, (faultString) % ((deps, type(deps))))		if type(deps) not in (ListType, TupleType):     log_error('Invalid argument type', type(deps))     raise rhnFault(30, (faultString) % ((deps, type(deps))))
for dep in deps:     if type(dep) is not StringType:         log_error('Invalid dependency member', type(dep))         raise rhnFault(30, (faultString) % ((dep, type(dep))))		for dep in deps:     if type(dep) is not StringType:         log_error('Invalid dependency member', type(dep))         raise rhnFault(30, (faultString) % ((dep, type(dep))))
deps = filter(len, deps)		deps = filter(len, deps)
if not deps:     return []		if not deps:     return []
server = self.auth_system(system_id)		server = self.auth_system(system_id)
log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))		log_debug(1, self.server_id, action, ('items: %d') % (len(deps)))

Clone # 35
Distance between two fragments = 2
Clone size = 14

Source file "./satellite_tools/satsync.py" The first line is 1669		Source file "./satellite_tools/satsync.py" The first line is 1398
pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=erratum_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=kt_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(erratum_ids[:], nevermorethan=self._batch_size)		ss = SequenceServer(ktids[:], nevermorethan=self._batch_size)
while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()		while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 36
Distance between two fragments = 2
Clone size = 14

Source file "./satellite_tools/satsync.py" The first line is 1669		Source file "./satellite_tools/satsync.py" The first line is 1288
pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=erratum_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(erratum_ids[:], nevermorethan=self._batch_size)		ss = SequenceServer(pids[:], nevermorethan=self._batch_size)
while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()		while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 37
Distance between two fragments = 2
Clone size = 14

Source file "./satellite_tools/satsync.py" The first line is 1669		Source file "./satellite_tools/satsync.py" The first line is 1112
pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=erratum_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(erratum_ids[:], nevermorethan=self._batch_size)		ss = SequenceServer(pids[:], nevermorethan=self._batch_size)
while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()		while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 38
Distance between two fragments = 2
Clone size = 14

Source file "./satellite_tools/satsync.py" The first line is 1398		Source file "./satellite_tools/satsync.py" The first line is 1288
pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=kt_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(ktids[:], nevermorethan=self._batch_size)		ss = SequenceServer(pids[:], nevermorethan=self._batch_size)
while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()		while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 39
Distance between two fragments = 2
Clone size = 14

Source file "./satellite_tools/satsync.py" The first line is 1398		Source file "./satellite_tools/satsync.py" The first line is 1112
pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=kt_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(ktids[:], nevermorethan=self._batch_size)		ss = SequenceServer(pids[:], nevermorethan=self._batch_size)
while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()		while not ss.doneYN():     chunk = ss.getChunk()     item_count = len(chunk)     stream_loader.process(chunk)     ss.clearChunk()     pb.addTo(item_count)     pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 40
Distance between two fragments = 4
Clone size = 14

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 502		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 478
print '\n'		print '\n'
log2stdout(1, 'Exporting arches extra...')		log2stdout(1, 'Exporting arches...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getArchesExtraFile())		self.set_filename(self.fm.getArchesFile())
dumper.XML_Dumper.dump_server_group_type_server_arches(self)		dumper.XML_Dumper.dump_arches(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()
log2stdout(4, ('Arches Extra exported to %s') % (self.fm.getArchesExtraFile()))		log2stdout(4, ('Arches exported to %s') % (self.fm.getArchesFile()))

Clone # 41
Distance between two fragments = 4
Clone size = 14

Source file "./server/handlers/config_mgmt/rhn_config_management.py" The first line is 486		Source file "./server/handlers/config_mgmt/rhn_config_management.py" The first line is 460
fdst = self._get_file(config_channel_dst, path, revision=revision_dst)		fsrc = self._get_file(config_channel_src, path, revision=revision_src)
if not fdst:     raise rhnFault(4011, ('File %s (revision %s) does not exist in channel %s') % ((path, revision_dst, config_channel_dst)), explain=0)		if not fsrc:     raise rhnFault(4011, ('File %s (revision %s) does not exist in channel %s') % ((path, revision_src, config_channel_src)), explain=0)
if fdst['is_binary'] == 'Y':     raise rhnFault(4004, ('File %s (revision %s) seems to contain binary data') % ((path, revision_dst)), explain=0)		if fsrc['is_binary'] == 'Y':     raise rhnFault(4004, ('File %s (revision %s) seems to contain binary data') % ((path, revision_src)), explain=0)
fd, filename_dst = tempfile.mkstemp(prefix='/tmp/rhncfg-')		fd, filename_src = tempfile.mkstemp(prefix='/tmp/rhncfg-')
fc_lob = fdst['file_contents']		fc_lob = fsrc['file_contents']
if fc_lob:     os.write(fd, rhnSQL.read_lob(fc_lob))		if fc_lob:     os.write(fd, rhnSQL.read_lob(fc_lob))
os.close(fd)		os.close(fd)

Clone # 42
Distance between two fragments = 1
Clone size = 14

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 91		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 47
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
for k, v in vdict.items():     method = getattr(c, ('set_') + (k))     method(v)		for k, v in vdict.items():     method = getattr(c, ('set_') + (k))     method(v)
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c

Clone # 43
Distance between two fragments = 0
Clone size = 14

Source file "./server/handlers/app/packages.py" The first line is 677		Source file "./server/handlers/app/packages.py" The first line is 549
row = h.fetchone_dict()		row = h.fetchone_dict()
if not row:     row_list[pkg] = ''     continue		if not row:     row_list[pkg] = ''     continue
if row.has_key('path'):     filePath = os.path.join(CFG.MOUNT_POINT, row['path'])     if os.access(filePath, os.R_OK):         if row.has_key('checksum'):             row_list[pkg] = (row['checksum_type'], row['checksum'])         else:             row_list[pkg] = 'on-disk'     else:         log_error('Package not found', filePath)         row_list[pkg] = '' else:     log_error('Package path null for package', filePath)     row_list[pkg] = ''		if row.has_key('path'):     filePath = os.path.join(CFG.MOUNT_POINT, row['path'])     if os.access(filePath, os.R_OK):         if row.has_key('checksum'):             row_list[pkg] = (row['checksum_type'], row['checksum'])         else:             row_list[pkg] = 'on-disk'     else:         log_error('Package not found', filePath)         row_list[pkg] = '' else:     log_error('Package path null for package', filePath)     row_list[pkg] = ''

Clone # 44
Distance between two fragments = 0
Clone size = 13

Source file "./satellite_exporter/handlers/non_auth_dumper.py" The first line is 324		Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 264
val = rhnCache.get(key, compressed=0, raw=1, modified=last_modified)		val = rhnCache.get(key, compressed=0, raw=1, modified=last_modified)
if val is None:     log_debug(4, ('Cache MISS for %s (%s)') % ((channel_label, channel_id)))     stream = self._cache_channel_packages_short(channel_id, key, last_modified) else:     log_debug(4, ('Cache HIT for %s (%s)') % ((channel_label, channel_id)))     temp_stream = tempfile.TemporaryFile()     temp_stream.write(val)     temp_stream.flush()     stream = self._normalize_compressed_stream(temp_stream)		if val is None:     log_debug(4, ('Cache MISS for %s (%s)') % ((channel_label, channel_id)))     stream = self._cache_channel_packages_short(channel_id, key, last_modified) else:     log_debug(4, ('Cache HIT for %s (%s)') % ((channel_label, channel_id)))     temp_stream = tempfile.TemporaryFile()     temp_stream.write(val)     temp_stream.flush()     stream = self._normalize_compressed_stream(temp_stream)
buffer_size = 16384		buffer_size = 16384

Clone # 45
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 550		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 526
print '\n'		print '\n'
log2stdout(1, 'Exporting channel families...')		log2stdout(1, 'Exporting blacklists...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getChannelFamiliesFile())		self.set_filename(self.fm.getBlacklistsFile())
dumper.XML_Dumper.dump_channel_families(self)		dumper.XML_Dumper.dump_blacklist_obsoletes(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 46
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 550		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 502
print '\n'		print '\n'
log2stdout(1, 'Exporting channel families...')		log2stdout(1, 'Exporting arches extra...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getChannelFamiliesFile())		self.set_filename(self.fm.getArchesExtraFile())
dumper.XML_Dumper.dump_channel_families(self)		dumper.XML_Dumper.dump_server_group_type_server_arches(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 47
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 550		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 478
print '\n'		print '\n'
log2stdout(1, 'Exporting channel families...')		log2stdout(1, 'Exporting arches...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getChannelFamiliesFile())		self.set_filename(self.fm.getArchesFile())
dumper.XML_Dumper.dump_channel_families(self)		dumper.XML_Dumper.dump_arches(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 48
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 526		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 502
print '\n'		print '\n'
log2stdout(1, 'Exporting blacklists...')		log2stdout(1, 'Exporting arches extra...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getBlacklistsFile())		self.set_filename(self.fm.getArchesExtraFile())
dumper.XML_Dumper.dump_blacklist_obsoletes(self)		dumper.XML_Dumper.dump_server_group_type_server_arches(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 49
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/iss.py" The first line is 526		Source file "./satellite_tools/disk_dumper/iss.py" The first line is 478
print '\n'		print '\n'
log2stdout(1, 'Exporting blacklists...')		log2stdout(1, 'Exporting arches...')
pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)		pb = progress_bar.ProgressBar(self.pb_label, self.pb_complete, 1, self.pb_length, self.pb_char)
pb.printAll(1)		pb.printAll(1)
self.set_filename(self.fm.getBlacklistsFile())		self.set_filename(self.fm.getArchesFile())
dumper.XML_Dumper.dump_blacklist_obsoletes(self)		dumper.XML_Dumper.dump_arches(self)
pb.addTo(1)		pb.addTo(1)
pb.printIncrement()		pb.printIncrement()
pb.printComplete()		pb.printComplete()

Clone # 50
Distance between two fragments = 4
Clone size = 13

Source file "./server/rhnChannel.py" The first line is 1672		Source file "./server/rhnChannel.py" The first line is 1554
log_debug(3, channel)		log_debug(3, channel)
c_info = channel_info(channel)		c_info = channel_info(channel)
if not c_info:     raise rhnFault(40, ("could not find any data on channel '%s'") % (channel))		if not c_info:     raise rhnFault(40, ("could not find any data on channel '%s'") % (channel))
cache_entry = ('blacklist_obsoletes-%s') % (channel)		cache_entry = ('list_obsoletes-%s') % (channel)
ret = rhnCache.get(cache_entry, c_info['last_modified'])		ret = rhnCache.get(cache_entry, c_info['last_modified'])
if ret:     log_debug(4, 'Scored cache hit', channel)     return ret		if ret:     log_debug(4, 'Scored cache hit', channel)     return ret
h = rhnSQL.prepare('\n select unique \n pnsrc.name src_name, \n bo.src_epoch,\n bo.src_version,\n bo.src_release,\n cdst.label dst_channel,\n pndst.name dst_name,\n bo.dst_epoch,\n bo.dst_version,\n bo.dst_release\n from \n rhnChannel csrc, rhnChannel cdst, \n rhnPackageName pnsrc, rhnPackageName pndst,\n rhnBlacklistObsoletes bo\n where bo.src_channel_id = csrc.id\n and csrc.label = :channel\n and bo.dst_channel_id = cdst.id (+)\n and bo.src_name_id = pnsrc.id\n and bo.dst_name_id = pndst.id\n order by pnsrc.name, pndst.name\n ')		h = rhnSQL.prepare('\n select distinct\n pn.name,\n pe.version, pe.release, pe.epoch,\n pa.label arch,\n pc.name obsolete_name,\n pc.version obsolete_version,\n p_info.sense\n from rhnPackageCapability pc,\n rhnPackageArch pa,\n rhnPackageEVR pe,\n rhnPackageName pn,\n rhnPackage p,\n ( select cp.channel_id,\n po.package_id, po.capability_id, po.sense\n from rhnPackageObsoletes po,\n rhnChannelPackage cp,\n rhnChannel c\n where 1=1\n and c.label = :channel\n and c.id = cp.channel_id\n and cp.package_id = po.package_id\n minus\n -- obsoletes that are blacklisted follow\n select cp.channel_id,\n po.package_id, po.capability_id, po.sense\n from rhnPackageName pni,\n rhnPackageCapability pc,\n rhnBlacklistObsoletes bo,\n rhnPackage p,\n rhnPackageObsoletes po,\n rhnChannelPackage cp,\n rhnChannel c\n where 1=1\n and c.label = :channel\n and c.id = cp.channel_id\n -- find all the packages we have obsoletes for\n and cp.package_id = po.package_id\n -- now find the name, and get the blacklists that apply\n and po.package_id = p.id\n and p.name_id = bo.name_id\n and p.evr_id = bo.evr_id\n and p.package_arch_id = bo.package_arch_id\n -- now match the blacklisted names to the caps\n and po.capability_id = pc.id\n and pc.name = pni.name\n and bo.ignore_name_id = pni.id\n ) p_info\n where 1=1\n and p_info.package_id = p.id\n and p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p_info.capability_id = pc.id\n ')
h.execute(channel=str(channel))		h.execute(channel=str(channel))
result = []		hash = {}

Clone # 51
Distance between two fragments = 0
Clone size = 13

Source file "./spacewalk/common/rhn_mpm.py" The first line is 280		Source file "./server/handlers/app/rhn_mpm.py" The first line is 257
def _replace_null(obj):     if obj is None:         return ''     if isinstance(obj, ListType):         return map(_replace_null, obj)     if isinstance(obj, TupleType):         return tuple(_replace_null(list(obj)))     if hasattr(obj, 'items'):         dict = {}         for k, v in obj.items():             dict[_replace_null(k)] = _replace_null(v)         return dict     return obj		def _replace_null(obj):     if obj is None:         return ''     if isinstance(obj, ListType):         return map(_replace_null, obj)     if isinstance(obj, TupleType):         return tuple(_replace_null(list(obj)))     if hasattr(obj, 'items'):         dict = {}         for k, v in obj.items():             dict[_replace_null(k)] = _replace_null(v)         return dict     return obj

Clone # 52
Distance between two fragments = 0
Clone size = 12

Source file "./server/importlib/userAuth.py" The first line is 205		Source file "./server/importlib/userAuth.py" The first line is 167
org_id = user.contact['org_id']		org_id = user.contact['org_id']
user_id = user.getid()		user_id = user.getid()
h = rhnSQL.prepare('\n select ugt.label\n from rhnUserGroupType ugt,\n rhnUserGroup ug,\n rhnUserGroupMembers ugm\n where ugm.user_id = :user_id\n and ugm.user_group_id = ug.id\n and ug.group_type = ugt.id\n ')		h = rhnSQL.prepare('\n select ugt.label\n from rhnUserGroupType ugt,\n rhnUserGroup ug,\n rhnUserGroupMembers ugm\n where ugm.user_id = :user_id\n and ugm.user_group_id = ug.id\n and ug.group_type = ugt.id\n ')
h.execute(user_id=user_id)		h.execute(user_id=user_id)
groups = []		groups = []
while 1:     row = h.fetchone_dict()     if not row:         break     groups.append(row['label'])		while 1:     row = h.fetchone_dict()     if not row:         break     groups.append(row['label'])
return (groups, org_id, user_id)		return (groups, org_id, user_id)

Clone # 53
Distance between two fragments = 2
Clone size = 12

Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 750		Source file "./satellite_tools/exporter/exportLib.py" The first line is 208
channel_id = self._row['id']		channel_id = self._row['id']
arr = []		arr = []
mappings = [('rhn-channel-parent-channel', 'parent_channel'), ('rhn-channel-basedir', 'basedir'), ('rhn-channel-name', 'name'), ('rhn-channel-summary', 'summary'), ('rhn-channel-description', 'description'), ('rhn-channel-gpg-key-url', 'gpg_key_url'), ('rhn-channel-checksum-type', 'checksum_type')]		mappings = [('rhn-channel-parent-channel', 'parent_channel'), ('rhn-channel-basedir', 'basedir'), ('rhn-channel-name', 'name'), ('rhn-channel-summary', 'summary'), ('rhn-channel-description', 'description'), ('rhn-channel-gpg-key-url', 'gpg_key_url'), ('rhn-channel-checksum-type', 'checksum_type')]
for k, v in mappings:     arr.append(exportLib.SimpleDumper(self._writer, k, self._row[v]))		for k, v in mappings:     arr.append(SimpleDumper(self._writer, k, self._row[v]))

Clone # 54
Distance between two fragments = 4
Clone size = 12

Source file "./server/importlib/test/test_blob_update.py" The first line is 168		Source file "./server/importlib/test/test_blob_update.py" The first line is 143
v1 = v[2]		i1 = v[0]
v2 = v[3]		i2 = v[1]
hval = {'id1': i1}		hval = {'id1': i1}
if i2 is None:     s = 'id2 is null' else:     s = 'id2 = :id2'     hval['id2'] = i2		if i2 is None:     s = 'id2 is null' else:     s = 'id2 = :id2'     hval['id2'] = i2
h = rhnSQL.prepare((q) % (s))		h = rhnSQL.prepare((q) % (s))
apply(h.execute, (), hval)		apply(h.execute, (), hval)
row = h.fetchone_dict()		row = h.fetchone_dict()
val1 = row['val1']		val1 = row['val1']
val2 = row['val2']		val2 = row['val2']

Clone # 55
Distance between two fragments = 4
Clone size = 12

Source file "./satellite_tools/xmlSource.py" The first line is 601		Source file "./satellite_tools/xmlSource.py" The first line is 593
class RequiresItem(BaseItem):     item_name = 'rhn-package-requires-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}		class ProvidesItem(BaseItem):     item_name = 'rhn-package-provides-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}
addItem(RequiresItem)		addItem(ProvidesItem)
class ConflictsItem(BaseItem):     item_name = 'rhn-package-conflicts-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}		class RequiresItem(BaseItem):     item_name = 'rhn-package-requires-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}
addItem(ConflictsItem)		addItem(RequiresItem)

Clone # 56
Distance between two fragments = 4
Clone size = 12

Source file "./satellite_tools/xmlSource.py" The first line is 609		Source file "./satellite_tools/xmlSource.py" The first line is 593
class ConflictsItem(BaseItem):     item_name = 'rhn-package-conflicts-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}		class ProvidesItem(BaseItem):     item_name = 'rhn-package-provides-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}
addItem(ConflictsItem)		addItem(ProvidesItem)
class ObsoletesItem(BaseItem):     item_name = 'rhn-package-obsoletes-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}		class RequiresItem(BaseItem):     item_name = 'rhn-package-requires-entry'     item_class = importLib.Dependency     tagMap = {'sense': 'flags'}
addItem(ObsoletesItem)		addItem(RequiresItem)

Clone # 57
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 953		Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 918
class PackagesDumper(CachedDumper, exportLib.PackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n p.id, \n p.org_id,\n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n pg.name package_group, \n p.rpm_version, \n p.description,\n p.summary,\n p.package_size,\n p.payload_size,\n p.build_host, \n TO_CHAR(p.build_time, 'YYYYMMDDHH24MISS') build_time,\n sr.name source_rpm, \n c.checksum_type,\n c.checksum,\n p.vendor,\n p.payload_format, \n p.compat, \n p.header_sig,\n p.header_start,\n p.header_end,\n p.copyright,\n p.cookie,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnPackageGroup pg, rhnSourceRPM sr,\n rhnChecksumView c\n where p.id = :package_id \n and p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.package_group = pg.id\n and p.source_rpm_id = sr.id\n and p.checksum_id = c.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-packages/%s/rhn-package-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.PackagesDumper.dump_subelement(self, data)		class ShortPackagesDumper(CachedDumper, exportLib.ShortPackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n p.id,\n p.org_id,\n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n c.checksum_type,\n c.checksum,\n p.package_size,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnChecksumView c\n where p.id = :package_id \n and p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.checksum_id = c.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-short-packages/%s/rhn-package-short-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.ShortPackagesDumper.dump_subelement(self, data)

Clone # 58
Distance between two fragments = 3
Clone size = 12

Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 1006		Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 953
class SourcePackagesDumper(CachedDumper, exportLib.SourcePackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n ps.id, \n sr.name source_rpm, \n pg.name package_group, \n ps.rpm_version, \n ps.payload_size,\n ps.build_host, \n TO_CHAR(ps.build_time, 'YYYYMMDDHH24MISS') build_time,\n sig.checksum sigchecksum,\n sig.checksum_type sigchecksum_type,\n ps.vendor,\n ps.cookie,\n ps.package_size,\n c.checksum_type,\n c.checksum,\n TO_CHAR(ps.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackageSource ps, rhnPackageGroup pg, rhnSourceRPM sr,\n rhnChecksumView c, rhnChecksumView sig\n where ps.id = :package_id\n and ps.package_group = pg.id\n and ps.source_rpm_id = sr.id\n and ps.checksum_id = c.id\n and ps.sigchecksum_id = sig.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-packages/%s/rhn-source-package-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.SourcePackagesDumper.dump_subelement(self, data)		class PackagesDumper(CachedDumper, exportLib.PackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n p.id, \n p.org_id,\n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n pg.name package_group, \n p.rpm_version, \n p.description,\n p.summary,\n p.package_size,\n p.payload_size,\n p.build_host, \n TO_CHAR(p.build_time, 'YYYYMMDDHH24MISS') build_time,\n sr.name source_rpm, \n c.checksum_type,\n c.checksum,\n p.vendor,\n p.payload_format, \n p.compat, \n p.header_sig,\n p.header_start,\n p.header_end,\n p.copyright,\n p.cookie,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnPackageGroup pg, rhnSourceRPM sr,\n rhnChecksumView c\n where p.id = :package_id \n and p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.package_group = pg.id\n and p.source_rpm_id = sr.id\n and p.checksum_id = c.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-packages/%s/rhn-package-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.PackagesDumper.dump_subelement(self, data)

Clone # 59
Distance between two fragments = 3
Clone size = 13

Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 1006		Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 918
class SourcePackagesDumper(CachedDumper, exportLib.SourcePackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n ps.id, \n sr.name source_rpm, \n pg.name package_group, \n ps.rpm_version, \n ps.payload_size,\n ps.build_host, \n TO_CHAR(ps.build_time, 'YYYYMMDDHH24MISS') build_time,\n sig.checksum sigchecksum,\n sig.checksum_type sigchecksum_type,\n ps.vendor,\n ps.cookie,\n ps.package_size,\n c.checksum_type,\n c.checksum,\n TO_CHAR(ps.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackageSource ps, rhnPackageGroup pg, rhnSourceRPM sr,\n rhnChecksumView c, rhnChecksumView sig\n where ps.id = :package_id\n and ps.package_group = pg.id\n and ps.source_rpm_id = sr.id\n and ps.checksum_id = c.id\n and ps.sigchecksum_id = sig.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-packages/%s/rhn-source-package-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.SourcePackagesDumper.dump_subelement(self, data)		class ShortPackagesDumper(CachedDumper, exportLib.ShortPackagesDumper):     def __init__(self, writer, packages):         h = rhnSQL.prepare("\n select \n p.id,\n p.org_id,\n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n c.checksum_type,\n c.checksum,\n p.package_size,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnChecksumView c\n where p.id = :package_id \n and p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.checksum_id = c.id\n ")         CachedDumper.__init__(self, writer, statement=h, params=packages)     def _get_key(self, params):         package_id = str(params['package_id'])         hash_val = rhnLib.hash_object_id(package_id, 2)         return ('xml-short-packages/%s/rhn-package-short-%s.xml') % ((hash_val, package_id))     def _dump_subelement(self, data):         log_debug(6, data)         return exportLib.ShortPackagesDumper.dump_subelement(self, data)

Clone # 60
Distance between two fragments = 2
Clone size = 12

Source file "./server/rhnChannel.py" The first line is 1246		Source file "./server/rhnChannel.py" The first line is 1173
def list_all_packages_sql(channel_id):     log_debug(3, channel_id)     h = rhnSQL.prepare('\n select\n pn.name, \n pevr.version, \n pevr.release, \n pevr.epoch, \n pa.label arch, \n p.package_size \n from \n rhnChannelPackage cp,\n rhnPackage p,\n rhnPackageName pn,\n rhnPackageEVR pevr,\n rhnPackageArch pa\n where\n cp.channel_id = :channel_id\n and cp.package_id = p.id\n and p.name_id = pn.id\n and p.evr_id = pevr.id\n and p.package_arch_id = pa.id\n order by pn.name, pevr.evr desc, pa.label\n ')     h.execute(channel_id=str(channel_id))     ret = h.fetchall_dict()     if not ret:         return []     ret = map(lambda a: (a['name'], a['version'], a['release'], a['epoch'], a['arch'], a['package_size']), __stringify(ret))     return ret		def list_packages_sql(channel_id):     log_debug(3, channel_id)     h = rhnSQL.prepare("\n select\n pn.name, \n pevr.version, \n pevr.release, \n pevr.epoch, \n pa.label arch, \n full_channel.package_size \n from \n rhnPackageArch pa,\n ( select \n p.name_id,\n max(pe.evr) evr\n from\n rhnChannelPackage cp,\n rhnPackage p,\n rhnPackageEVR pe\n where\n cp.channel_id = :channel_id\n and cp.package_id = p.id\n and p.evr_id = pe.id\n group by p.name_id\n ) listall,\n ( select distinct\n p.package_size,\n p.name_id,\n p.evr_id,\n p.package_arch_id\n from\n rhnChannelPackage cp,\n rhnPackage p\n where\n cp.channel_id = :channel_id\n and cp.package_id = p.id\n ) full_channel,\n -- Rank the package's arch\n ( select\n package_arch_id, \n count(*) rank\n from\n rhnServerPackageArchCompat\n group by package_arch_id\n ) arch_rank,\n rhnPackageName pn,\n rhnPackageEVR pevr\n where\n pn.id = listall.name_id\n -- link back to the specific package\n and full_channel.name_id = listall.name_id\n and full_channel.evr_id = pevr.id\n and pevr.evr = listall.evr\n and pa.id = full_channel.package_arch_id\n and pa.id = arch_rank.package_arch_id\n order by pn.name, arch_rank.rank desc\n ")     h.execute(channel_id=str(channel_id))     ret = h.fetchall_dict()     if not ret:         return []     ret = map(lambda a: (a['name'], a['version'], a['release'], a['epoch'], a['arch'], a['package_size']), __stringify(ret))     return ret

Clone # 61
Distance between two fragments = 1
Clone size = 12

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 112		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 72
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
c.load_from_dict(vdict)		c.load_from_dict(vdict)
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c

Clone # 62
Distance between two fragments = 0
Clone size = 12

Source file "./satellite_tools/test/test-iconv.py" The first line is 41		Source file "./common/rhn_memusage.py" The first line is 18
def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])		def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])

Clone # 63
Distance between two fragments = 0
Clone size = 12

Source file "./satellite_tools/test/test-iconv.py" The first line is 41		Source file "./server/test/test-cx_Oracle-memleak.py" The first line is 24
def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])		def mem_usage():     f = open('/proc/self/status')     dict = {}     while 1:         line = f.readline()         if not line:             break         arr = map(string.strip, string.split(line, ':', 1))         if len(arr) == 1:             continue         dict[arr[0]] = arr[1]     return (dict['Name'], dict['VmSize'], dict['VmRSS'], dict['VmData'])

Clone # 64
Distance between two fragments = 4
Clone size = 12

Source file "./satellite_tools/diskImportLib.py" The first line is 189		Source file "./satellite_tools/diskImportLib.py" The first line is 182
class ServerChannelArchCompatContainer(xmlSource.ServerChannelArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerChannelArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []		class ServerPackageArchCompatContainer(xmlSource.ServerPackageArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerPackageArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []
class ChannelPackageArchCompatContainer(xmlSource.ChannelPackageArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ChannelPackageArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []		class ServerChannelArchCompatContainer(xmlSource.ServerChannelArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerChannelArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []

Clone # 65
Distance between two fragments = 4
Clone size = 12

Source file "./satellite_tools/diskImportLib.py" The first line is 196		Source file "./satellite_tools/diskImportLib.py" The first line is 182
class ChannelPackageArchCompatContainer(xmlSource.ChannelPackageArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ChannelPackageArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []		class ServerPackageArchCompatContainer(xmlSource.ServerPackageArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerPackageArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []
class ServerGroupServerArchCompatContainer(xmlSource.ServerGroupServerArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerGroupServerArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []		class ServerChannelArchCompatContainer(xmlSource.ServerChannelArchCompatContainer):     def endContainerCallback(self):         importer = archImport.ServerChannelArchCompatImport(self.batch, get_backend())         importer.run()         self.batch = []

Clone # 66
Distance between two fragments = 2
Clone size = 12

Source file "./test/non-unit/server/rhnSQL/dbtests.py" The first line is 237		Source file "./test/non-unit/server/rhnSQL/dbtests.py" The first line is 199
QUERY_CREATE_TABLE = '\n CREATE TABLE %s(id NUMBER, name VARCHAR2(256), num NUMBER(5,2))\n '		QUERY_CREATE_TABLE = '\n CREATE TABLE %s(id INT, name TEXT, num NUMERIC(5,2))\n '
SIMPLE_PROCEDURE = '\nCREATE OR REPLACE FUNCTION \n return_int(returnme in integer) \nRETURN INTEGER AS\nBEGIN\n RETURN returnme;\nEND;\n '		SIMPLE_PROCEDURE = "\nCREATE OR REPLACE FUNCTION return_int(returnme INTEGER) RETURNS int AS $$\nDECLARE\n myInt int;\nBEGIN\n myInt := returnme;\n RETURN myInt;\nEND\n$$ LANGUAGE 'plpgsql';\n "
def setUp(self):     self.temp_table = ('testtable%s') % (randint(1, 10000000))     create_table_query = (self.QUERY_CREATE_TABLE) % (self.temp_table)     cursor = rhnSQL.prepare(create_table_query)     cursor.execute()     RhnSQLDatabaseTests.setUp(self)     cursor = rhnSQL.prepare(self.SIMPLE_PROCEDURE)     cursor.execute()		def setUp(self):     self.temp_table = ('testtable%s') % (randint(1, 10000000))     create_table_query = (self.QUERY_CREATE_TABLE) % (self.temp_table)     cursor = rhnSQL.prepare(create_table_query)     cursor.execute()     RhnSQLDatabaseTests.setUp(self)     cursor = rhnSQL.prepare(self.SIMPLE_PROCEDURE)     cursor.execute()

Clone # 67
Distance between two fragments = 1
Clone size = 12

Source file "./server/handlers/app/packages.py" The first line is 216		Source file "./server/handlers/xp/packages.py" The first line is 74
authobj.authzChannels(channelList)		authobj.authzChannels(channelList)
h = rhnSQL.prepare('\n select sr.name source_rpm\n from rhnChannel c,\n rhnChannelNewestPackage cnp, \n rhnPackage p,\n rhnSourceRPM sr\n where cnp.channel_id = c.id\n and c.label = :channel_label\n and cnp.package_id = p.id\n and p.source_rpm_id = sr.id\n minus\n select sr.name source_rpm\n from rhnChannel c,\n rhnChannelNewestPackage cnp,\n rhnPackage p,\n rhnSourceRPM sr,\n rhnPackageSource ps\n where cnp.channel_id = c.id\n and c.label = :channel_label\n and cnp.package_id = p.id\n and p.source_rpm_id = sr.id\n and p.source_rpm_id = ps.source_rpm_id\n and (p.org_id = ps.org_id or\n (p.org_id is null and ps.org_id is null)\n )\n ')		h = rhnSQL.prepare('\n select sr.name source_rpm\n from rhnChannel c,\n rhnChannelNewestPackage cnp,\n rhnPackage p,\n rhnSourceRPM sr\n where cnp.channel_id = c.id\n and c.label = :channel_label\n and cnp.package_id = p.id\n and p.source_rpm_id = sr.id\n minus\n select sr.name source_rpm\n from rhnChannel c,\n rhnChannelNewestPackage cnp,\n rhnPackage p,\n rhnSourceRPM sr,\n rhnPackageSource ps\n where cnp.channel_id = c.id\n and c.label = :channel_label\n and cnp.package_id = p.id\n and p.source_rpm_id = sr.id\n and p.source_rpm_id = ps.source_rpm_id\n and (p.org_id = ps.org_id or\n (p.org_id is null and ps.org_id is null)\n )\n ')
missing_packages = []		missing_packages = []
for c in channelList:     h.execute(channel_label=c)     while 1:         row = h.fetchone_dict()         if not row:             break         missing_packages.append([row['source_rpm'], c])		for c in channelList:     h.execute(channel_label=c)     while 1:         row = h.fetchone_dict()         if not row:             break         missing_packages.append([row['source_rpm'], c])
return missing_packages		return missing_packages

Clone # 68
Distance between two fragments = 3
Clone size = 12

Source file "./satellite_tools/satsync.py" The first line is 1702		Source file "./satellite_tools/satsync.py" The first line is 1104
package_count = len(packages)		package_count = len(pids)
log(1, (messages.package_importing) % ((channel, (package_count) or ('NONE RELEVANT'))))		log(1, (messages.package_parsing) % ((channel, (package_count) or ('NONE RELEVANT'))))
if not package_count:     continue		if not package_count:     continue
log(1, messages.warning_slow)		log(1, messages.warning_slow)
pb = ProgressBar(prompt='Importing: ', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)		pb = ProgressBar(prompt='Downloading:', endTag=' - complete', finalSize=package_count, finalBarLength=40, stream=sys.stdout)
if CFG.DEBUG > 2:     pb.redrawYN = 0		if CFG.DEBUG > 2:     pb.redrawYN = 0
pb.printAll(1)		pb.printAll(1)
ss = SequenceServer(packages[:], nevermorethan=self._batch_size)		ss = SequenceServer(pids[:], nevermorethan=self._batch_size)

Clone # 69
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 29		Source file "./server/test/byterangetests.py" The first line is 21
def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testEmptyRange(self):     try:         server.byterange.parse_byteranges('')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testNegativeStart(self):     try:         server.byterange.parse_byteranges('bytes=-1-30')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 70
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 44		Source file "./server/test/byterangetests.py" The first line is 37
def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNegativeStart(self):     try:         server.byterange.parse_byteranges('bytes=-1-30')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testNoStartOrEnd(self):     try:         server.byterange.parse_byteranges('bytes=-')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 71
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 58		Source file "./server/test/byterangetests.py" The first line is 51
def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoStartOrEnd(self):     try:         server.byterange.parse_byteranges('bytes=-')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testBadCharactersInRange(self):     try:         server.byterange.parse_byteranges('bytes=2-CB')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 72
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 37		Source file "./server/test/byterangetests.py" The first line is 21
def testNegativeStart(self):     try:         server.byterange.parse_byteranges('bytes=-1-30')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testEmptyRange(self):     try:         server.byterange.parse_byteranges('')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 73
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 51		Source file "./server/test/byterangetests.py" The first line is 37
def testNoStartOrEnd(self):     try:         server.byterange.parse_byteranges('bytes=-')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNegativeStart(self):     try:         server.byterange.parse_byteranges('bytes=-1-30')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 74
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 44		Source file "./server/test/byterangetests.py" The first line is 21
def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testEmptyRange(self):     try:         server.byterange.parse_byteranges('')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testNoStartOrEnd(self):     try:         server.byterange.parse_byteranges('bytes=-')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 75
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 58		Source file "./server/test/byterangetests.py" The first line is 37
def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNegativeStart(self):     try:         server.byterange.parse_byteranges('bytes=-1-30')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testBadCharactersInRange(self):     try:         server.byterange.parse_byteranges('bytes=2-CB')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testStartAfterEnd(self):     try:         server.byterange.parse_byteranges('bytes=12-3')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 76
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 51		Source file "./server/test/byterangetests.py" The first line is 21
def testNoStartOrEnd(self):     try:         server.byterange.parse_byteranges('bytes=-')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testEmptyRange(self):     try:         server.byterange.parse_byteranges('')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 77
Distance between two fragments = 4
Clone size = 12

Source file "./server/test/byterangetests.py" The first line is 58		Source file "./server/test/byterangetests.py" The first line is 21
def testNoStartInvalidEnd(self):     try:         server.byterange.parse_byteranges('bytes=-0')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testEmptyRange(self):     try:         server.byterange.parse_byteranges('')         self.fail()     except server.byterange.InvalidByteRangeException:         pass
def testBadCharactersInRange(self):     try:         server.byterange.parse_byteranges('bytes=2-CB')         self.fail()     except server.byterange.InvalidByteRangeException:         pass		def testNoRangeGroups(self):     try:         server.byterange.parse_byteranges('bytes=')         self.fail()     except server.byterange.InvalidByteRangeException:         pass

Clone # 78
Distance between two fragments = 3
Clone size = 12

Source file "./server/handlers/app/test/test_channel.py" The first line is 255		Source file "./server/handlers/app/test/test_channel.py" The first line is 232
def testrevokesubscribeChannelPermission(self):     ret = channel.revokeChannelPermission(options['label'], 'subscribe', commit, username, password)     h = rhnSQL.prepare('select id from rhnchannel where label = :label')     h.execute(label=options['label'])     ret = (h.fetchone_dict()) or ([])     h2 = rhnSQL.prepare('\n select cpr.label\n from rhnchannelpermission cp,\n rhnchannelpermissionrole cpr\n where cpr.id = cp.role_id\n and cp.channel_id = :cid\n ')     h2.execute(cid=ret['id'])     ret2 = (h2.fetchone_dict()) or ([])     if ret2:         assert ret2['label'] != 'subscribe'		def testrevokemanageChannelPermission(self):     ret = channel.revokeChannelPermission(options['label'], 'manage', commit, username, password)     h = rhnSQL.prepare('select id from rhnchannel where label = :label')     h.execute(label=options['label'])     ret = (h.fetchone_dict()) or ([])     h2 = rhnSQL.prepare('\n select cpr.label\n from rhnchannelpermission cp,\n rhnchannelpermissionrole cpr\n where cp.channel_id = :cid\n and cpr.id = cp.role_id\n ')     h2.execute(cid=ret['id'])     ret2 = (h2.fetchone_dict()) or ([])     if ret2:         assert ret2['label'] != 'manage'

Clone # 79
Distance between two fragments = 1
Clone size = 11

Source file "./server/test/test_leak.py" The first line is 29		Source file "./server/test/test_leak4.py" The first line is 30
while i < 10000:     h.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)		while i < 10000:     c.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)

Clone # 80
Distance between two fragments = 0
Clone size = 11

Source file "./server/test/test_leak.py" The first line is 29		Source file "./server/test/test_leak2.py" The first line is 29
while i < 10000:     h.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)		while i < 10000:     h.execute()     if (i) % (100) == 0:         f = open('/proc/self/status')         l = f.readlines()         vmsize = l[10][10:-1]         vmrss = l[12][10:-1]         f.close()         write(('%d %.3f vsz: %s rss: %s \n') % ((i, (time.time()) - (start), vmsize, vmrss)))     i = (i) + (1)

Clone # 81
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 305		Source file "./server/test/test_solve_dependencies.py" The first line is 292
def testUp2dateFilterGT(self):     nlimitstr = '35:mozilla-0-0'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1		def testUp2dateFilterEq(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 82
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 366		Source file "./server/test/test_solve_dependencies.py" The first line is 353
def testUp2dateFilterGT1(self):     nlimitstr = 'mozilla-0-0:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1		def testUp2dateFilterEq1(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 83
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 329		Source file "./server/test/test_solve_dependencies.py" The first line is 305
def testUp2dateFilterLT(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterGT(self):     nlimitstr = '35:mozilla-0-0'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1

Clone # 84
Distance between two fragments = 3
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 341		Source file "./server/test/test_solve_dependencies.py" The first line is 317
def testUp2dateFilterLTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)		def testUp2dateFilterGTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)

Clone # 85
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 353		Source file "./server/test/test_solve_dependencies.py" The first line is 329
def testUp2dateFilterEq1(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0		def testUp2dateFilterLT(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1

Clone # 86
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 390		Source file "./server/test/test_solve_dependencies.py" The first line is 366
def testUp2dateFilterLT1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterGT1(self):     nlimitstr = 'mozilla-0-0:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1

Clone # 87
Distance between two fragments = 3
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 402		Source file "./server/test/test_solve_dependencies.py" The first line is 378
def testUp2dateFilterLTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)		def testUp2dateFilterGTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)

Clone # 88
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 329		Source file "./server/test/test_solve_dependencies.py" The first line is 292
def testUp2dateFilterLT(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterEq(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 89
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 366		Source file "./server/test/test_solve_dependencies.py" The first line is 329
def testUp2dateFilterGT1(self):     nlimitstr = 'mozilla-0-0:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1		def testUp2dateFilterLT(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1

Clone # 90
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 378		Source file "./server/test/test_solve_dependencies.py" The first line is 341
def testUp2dateFilterGTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)		def testUp2dateFilterLTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)

Clone # 91
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 390		Source file "./server/test/test_solve_dependencies.py" The first line is 353
def testUp2dateFilterLT1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterEq1(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 92
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 353		Source file "./server/test/test_solve_dependencies.py" The first line is 305
def testUp2dateFilterEq1(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0		def testUp2dateFilterGT(self):     nlimitstr = '35:mozilla-0-0'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1

Clone # 93
Distance between two fragments = 1
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 353		Source file "./server/test/test_solve_dependencies.py" The first line is 292
def testUp2dateFilterEq1(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0		def testUp2dateFilterEq(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 94
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 366		Source file "./server/test/test_solve_dependencies.py" The first line is 292
def testUp2dateFilterGT1(self):     nlimitstr = 'mozilla-0-0:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1		def testUp2dateFilterEq(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 95
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 390		Source file "./server/test/test_solve_dependencies.py" The first line is 305
def testUp2dateFilterLT1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterGT(self):     nlimitstr = '35:mozilla-0-0'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 1

Clone # 96
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 402		Source file "./server/test/test_solve_dependencies.py" The first line is 317
def testUp2dateFilterLTE1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)		def testUp2dateFilterGTE(self):     nlimitstr = '35:mozilla-1-1'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='>', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)

Clone # 97
Distance between two fragments = 4
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 390		Source file "./server/test/test_solve_dependencies.py" The first line is 292
def testUp2dateFilterLT1(self):     nlimitstr = 'mozilla-1-1:35'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='<', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == -1		def testUp2dateFilterEq(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.up2date.solveDependencies_with_limits(self.myserver.getSystemId(), [self.filename], 2, limit_operator='==', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert ret == 0

Clone # 98
Distance between two fragments = 3
Clone size = 11

Source file "./server/test/test_solve_dependencies.py" The first line is 265		Source file "./server/test/test_solve_dependencies.py" The first line is 241
def testEvrFilterLTE(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.solve_deps_with_limits(self.serv_id, [self.filename], 2, limit_operator='<=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == -1) or (ret == 0)		def testEvrFilterGTE(self):     nlimitstr = '38:mozilla-1.5-2.rhfc1.dag'     nlimit = rhnDependency.make_evr(nlimitstr)     pack = self.solve_deps_with_limits(self.serv_id, [self.filename], 2, limit_operator='>=', limit=nlimitstr)     ret = rpm.labelCompare((pack[self.filename][0][3], pack[self.filename][0][1], pack[self.filename][0][2]), (nlimit['epoch'], nlimit['version'], nlimit['release']))     assert (ret == 1) or (ret == 0)

Clone # 99
Distance between two fragments = 2
Clone size = 11

Source file "./server/handlers/xmlrpc/registration.py" The first line is 909		Source file "./server/handlers/xmlrpc/registration.py" The first line is 894
def delete_packages(self, system_id, packages):     log_debug(5, system_id, packages)     if CFG.DISABLE_PACKAGES:         return 0     packages = self._normalize_packages(system_id, packages)     server = self.auth_system(system_id)     log_debug(1, server.getid(), ('packages: %d') % (len(packages)))     for package in packages:         server.delete_package(package)     server.save_packages()     return 0		def add_packages(self, system_id, packages):     log_debug(5, system_id, packages)     if CFG.DISABLE_PACKAGES:         return 0     packages = self._normalize_packages(system_id, packages)     server = self.auth_system(system_id)     log_debug(1, server.getid(), ('packages: %d') % (len(packages)))     for package in packages:         server.add_package(package)     server.save_packages()     return 0

Clone # 100
Distance between two fragments = 1
Clone size = 11

Source file "./server/rhnPackage.py" The first line is 348		Source file "./server/rhnPackage.py" The first line is 282
rs = h.fetchone_dict()		rs = h.fetchone_dict()
if not rs:     log_debug(4, 'Error', 'Non-existant package requested', server_id, pkg)     raise rhnFault(17, (_('Invalid RPM package %s requested')) % (pkg))		if not rs:     log_debug(4, 'Error', 'Non-existant package requested', server_id, packageName)     raise rhnFault(17, (_('Invalid RPM package %s requested')) % (packageName))
filePath = ('%s/%s') % ((CFG.MOUNT_POINT, rs['path']))		filePath = ('%s/%s') % ((CFG.MOUNT_POINT, rs['path']))
if not os.access(filePath, os.R_OK):     log_error('Package not found', filePath)     raise rhnFault(17, _('Package not found'))		if not os.access(filePath, os.R_OK):     log_error('Package not found', filePath)     raise rhnFault(17, _('Package not found'))
rhnFlags.set('Download-Accelerator-Path', rs['path'])		rhnFlags.set('Download-Accelerator-Path', rs['path'])
return filePath		return filePath

Clone # 101
Distance between two fragments = 4
Clone size = 11

Source file "./test/non-unit/server/rhnSQL/dbtests.py" The first line is 173		Source file "./test/non-unit/server/rhnSQL/dbtests.py" The first line is 160
def test_fetchall_dict(self):     query = rhnSQL.prepare(('SELECT * FROM %s ORDER BY id') % (self.temp_table))     query.execute()     rows = query.fetchall_dict()     self.assertEquals(len(TEST_IDS), len(rows))     i = 0     while i < len(TEST_IDS):         self.assertEquals(TEST_IDS[i], rows[i]['id'])         self.assertEquals(TEST_NAMES[i], rows[i]['name'])         i = (i) + (1)		def test_fetchall(self):     query = rhnSQL.prepare(('SELECT * FROM %s ORDER BY id') % (self.temp_table))     query.execute()     rows = query.fetchall()     self.assertEquals(len(TEST_IDS), len(rows))     i = 0     while i < len(TEST_IDS):         self.assertEquals(TEST_IDS[i], rows[i][0])         self.assertEquals(TEST_NAMES[i], rows[i][1])         i = (i) + (1)

Clone # 102
Distance between two fragments = 3
Clone size = 11

Source file "./server/action_extra_data/kickstart_guest.py" The first line is 55		Source file "./server/action_extra_data/kickstart_guest.py" The first line is 38
def initiate(server_id, action_id, data={}):     log_debug(3, action_id)     action_status = rhnFlags.get('action_status')     if action_status == 3:         ks_state = 'failed'         next_action_type = None     else:         ks_state = 'in_progress'         next_action_type = 'kickstart_guest.add_tools_channel'     server_kickstart.update_kickstart_session(server_id, action_id, action_status, kickstart_state=ks_state, next_action_type=next_action_type)		def add_tools_channel(server_id, action_id, data={}):     log_debug(3, action_id)     action_status = rhnFlags.get('action_status')     if action_status == 3:         ks_state = 'failed'         next_action_type = None     else:         ks_state = 'complete'         next_action_type = 'kickstart_guest.schedule_virt_guest_pkg_install'     server_kickstart.update_kickstart_session(server_id, action_id, action_status, kickstart_state=ks_state, next_action_type=next_action_type)

Clone # 103
Distance between two fragments = 4
Clone size = 11

Source file "./satellite_tools/exporter/exportLib.py" The first line is 718		Source file "./satellite_tools/exporter/exportLib.py" The first line is 567
tag_name = 'rhn-packages-short'		tag_name = 'rhn-packages'
def set_iterator(self):     if self._iterator:         return self._iterator     h = rhnSQL.prepare("\n select \n p.id, \n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n c.checksum_type,\n c.checksum,\n p.org_id,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnChecksumView c\n where p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.path is not null\n and p.checksum_id = c.id\n and rownum < 3\n ")     h.execute()     return h		def set_iterator(self):     if self._iterator:         return self._iterator     h = rhnSQL.prepare("\n select \n p.id,\n p.org_id, \n pn.name, \n pe.evr.version version, \n pe.evr.release release, \n pe.evr.epoch epoch, \n pa.label package_arch,\n pg.name package_group, \n p.rpm_version, \n p.description,\n p.summary,\n p.package_size,\n p.payload_size,\n p.build_host, \n TO_CHAR(p.build_time, 'YYYYMMDDHH24MISS') build_time,\n sr.name source_rpm, \n c.checksum_type,\n c.checksum,\n p.vendor,\n p.payload_format, \n p.compat, \n p.header_sig,\n p.copyright,\n p.cookie,\n p.header_start,\n p.header_end,\n TO_CHAR(p.last_modified, 'YYYYMMDDHH24MISS') last_modified\n from rhnPackage p, rhnPackageName pn, rhnPackageEVR pe, \n rhnPackageArch pa, rhnPackageGroup pg, rhnSourceRPM sr,\n rhnChecksumView c\n where p.name_id = pn.id\n and p.evr_id = pe.id\n and p.package_arch_id = pa.id\n and p.package_group = pg.id\n and p.source_rpm_id = sr.id\n and p.path is not null\n and p.checksum_id = c.id\n and rownum < 3\n ")     h.execute()     return h
def dump_subelement(self, data):     d = ShortPackageEntryDumper(self._writer, data)     d.dump()		def dump_subelement(self, data):     p = _PackageDumper(self._writer, data)     p.dump()

Clone # 104
Distance between two fragments = 3
Clone size = 11

Source file "./server/rhnChannel.py" The first line is 478		Source file "./server/rhnChannel.py" The first line is 463
_query_update_dists = rhnSQL.Statement('\n update rhnDistChannelMap\n set channel_arch_id = :channel_arch_id,\n os = :os\n where channel_id = :channel_id\n and release = :release\n ')		_query_add_dists = rhnSQL.Statement('\n insert into rhnDistChannelMap \n (channel_id, channel_arch_id, release, os)\n values (:channel_id, :channel_arch_id, :release, :os)\n ')
def _update_dists(self, releases, oses):     if not releases:         return None     count = len(releases)     channel_ids = ([self._row['id']]) * (count)     channel_arch_ids = ([self._row['channel_arch_id']]) * (count)     h = rhnSQL.prepare(self._query_update_dists)     h.executemany(channel_id=channel_ids, channel_arch_id=channel_arch_ids, release=releases, os=oses)		def _add_dists(self, releases, oses):     if not releases:         return None     count = len(releases)     channel_ids = ([self._row['id']]) * (count)     channel_arch_ids = ([self._row['channel_arch_id']]) * (count)     h = rhnSQL.prepare(self._query_add_dists)     h.executemany(channel_id=channel_ids, channel_arch_id=channel_arch_ids, release=releases, os=oses)

Clone # 105
Distance between two fragments = 4
Clone size = 10

Source file "./server/importlib/backend.py" The first line is 529		Source file "./server/importlib/backend.py" The first line is 436
def lookupChannelFamilies(self, hash):     if not hash:         return None     sql = 'select id from rhnChannelFamily where label = :label'     h = self.dbmodule.prepare(sql)     for k in hash.keys():         h.execute(label=k)         row = h.fetchone_dict()         if row:             hash[k] = row['id']		def lookupChecksumTypes(self, checksumTypeHash):     if not checksumTypeHash:         return None     sql = 'select id from rhnChecksumType where label = :label'     h = self.dbmodule.prepare(sql)     for l in checksumTypeHash.keys():         h.execute(label=l)         row = h.fetchone_dict()         if row:             checksumTypeHash[l] = row['id']

Clone # 106
Distance between two fragments = 4
Clone size = 10

Source file "./satellite_tools/sync_handlers.py" The first line is 378		Source file "./satellite_tools/sync_handlers.py" The first line is 263
class ErrataContainer(xmlSource.ErrataContainer):     def endItemCallback(self):         xmlSource.ErrataContainer.endItemCallback(self)         if not self.batch:             return None         c = ErrataCollection()         c.add_erratum(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ShortPackageContainer(xmlSource.IncompletePackageContainer):     def endItemCallback(self):         xmlSource.IncompletePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = ShortPackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass

Clone # 107
Distance between two fragments = 4
Clone size = 10

Source file "./satellite_tools/sync_handlers.py" The first line is 263		Source file "./satellite_tools/sync_handlers.py" The first line is 410
class ShortPackageContainer(xmlSource.IncompletePackageContainer):     def endItemCallback(self):         xmlSource.IncompletePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = ShortPackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class KickstartableTreesContainer(xmlSource.KickstartableTreesContainer):     def endItemCallback(self):         xmlSource.KickstartableTreesContainer.endItemCallback(self)         if not self.batch:             return None         c = KickstartableTreesCollection()         c.add_item(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass

Clone # 108
Distance between two fragments = 4
Clone size = 10

Source file "./satellite_tools/sync_handlers.py" The first line is 263		Source file "./satellite_tools/sync_handlers.py" The first line is 163
class ShortPackageContainer(xmlSource.IncompletePackageContainer):     def endItemCallback(self):         xmlSource.IncompletePackageContainer.endItemCallback(self)         if not self.batch:             return None         c = ShortPackageCollection()         c.add_package(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass		class ChannelContainer(xmlSource.ChannelContainer):     def endItemCallback(self):         xmlSource.ChannelContainer.endItemCallback(self)         if not self.batch:             return None         c = ChannelCollection()         c.add_channel(self.batch[-1])         self.batch[:]     def endContainerCallback(self):         pass

Clone # 109
Distance between two fragments = 4
Clone size = 10

Source file "./server/config_common/templated_document.py" The first line is 125		Source file "./server/config_common/templated_document.py" The first line is 117
def net_intf_netmask(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['netmask']		def net_intf_ipaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['ip_addr']
def net_intf_broadcast(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['broadcast']		def net_intf_netmask(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['netmask']

Clone # 110
Distance between two fragments = 4
Clone size = 10

Source file "./server/config_common/templated_document.py" The first line is 142		Source file "./server/config_common/templated_document.py" The first line is 134
def net_intf_hwaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['hw_addr']		def net_intf_broadcast(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['broadcast']
def net_intf_module(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['module']		def net_intf_hwaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['hw_addr']

Clone # 111
Distance between two fragments = 4
Clone size = 10

Source file "./server/config_common/templated_document.py" The first line is 134		Source file "./server/config_common/templated_document.py" The first line is 117
def net_intf_broadcast(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['broadcast']		def net_intf_ipaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['ip_addr']
def net_intf_hwaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['hw_addr']		def net_intf_netmask(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['netmask']

Clone # 112
Distance between two fragments = 4
Clone size = 10

Source file "./server/config_common/templated_document.py" The first line is 142		Source file "./server/config_common/templated_document.py" The first line is 117
def net_intf_hwaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['hw_addr']		def net_intf_ipaddr(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['ip_addr']
def net_intf_module(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['module']		def net_intf_netmask(self, interface_name):     iface = self._interface_info(interface_name)     if not iface:         return None     return iface['netmask']

Clone # 113
Distance between two fragments = 4
Clone size = 10

Source file "./server/action_extra_data/rollback.py" The first line is 22		Source file "./server/action_extra_data/packages.py" The first line is 408
def config(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.config: Should do something useful with this data', server_id, action_id, data)		def refresh_list(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.refresh_list: Should do something useful with this data', server_id, action_id, data)
def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)		def delta(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.delta: Should do something useful with this data', server_id, action_id, data)

Clone # 114
Distance between two fragments = 4
Clone size = 10

Source file "./server/action_extra_data/up2date_config.py" The first line is 23		Source file "./server/action_extra_data/rollback.py" The first line is 28
def get(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.get: Should do something useful with this data', server_id, action_id, data)		def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)
def update(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.update: Should do something useful with this data', server_id, action_id, data)		def rollback(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)

Clone # 115
Distance between two fragments = 4
Clone size = 10

Source file "./server/action_extra_data/up2date_config.py" The first line is 23		Source file "./server/action_extra_data/rollback.py" The first line is 22
def get(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.get: Should do something useful with this data', server_id, action_id, data)		def config(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.config: Should do something useful with this data', server_id, action_id, data)
def update(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.update: Should do something useful with this data', server_id, action_id, data)		def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)

Clone # 116
Distance between two fragments = 4
Clone size = 10

Source file "./server/action_extra_data/up2date_config.py" The first line is 23		Source file "./server/action_extra_data/packages.py" The first line is 408
def get(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.get: Should do something useful with this data', server_id, action_id, data)		def refresh_list(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.refresh_list: Should do something useful with this data', server_id, action_id, data)
def update(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.up2date_config.update: Should do something useful with this data', server_id, action_id, data)		def delta(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.delta: Should do something useful with this data', server_id, action_id, data)

Clone # 117
Distance between two fragments = 3
Clone size = 10

Source file "./server/action_extra_data/rollback.py" The first line is 28		Source file "./server/action_extra_data/rollback.py" The first line is 22
def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)		def config(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.config: Should do something useful with this data', server_id, action_id, data)
def rollback(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)		def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)

Clone # 118
Distance between two fragments = 4
Clone size = 10

Source file "./server/action_extra_data/rollback.py" The first line is 28		Source file "./server/action_extra_data/packages.py" The first line is 408
def listTransactions(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)		def refresh_list(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.refresh_list: Should do something useful with this data', server_id, action_id, data)
def rollback(server_id, action_id, data={}):     if not data:         return None     log_error('action_error.rollback.listTransactions: Should do something useful with this data', server_id, action_id, data)		def delta(server_id, action_id, data={}):     if not data:         return None     log_error('action_extra_data.packages.delta: Should do something useful with this data', server_id, action_id, data)

Clone # 119
Distance between two fragments = 0
Clone size = 10

Source file "./server/rhnDependency.py" The first line is 734		Source file "./server/rhnDependency.py" The first line is 652
if version > 1:     return packages		if version > 1:     return packages
result = []		result = []
for dep in deplist:     if not packages[dep]:         continue     r = packages[dep][0]     if r not in result:         result.append(r)		for dep in deplist:     if not packages[dep]:         continue     r = packages[dep][0]     if r not in result:         result.append(r)
return result		return result

Clone # 120
Distance between two fragments = 4
Clone size = 10

Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 439		Source file "./satellite_tools/disk_dumper/dumper.py" The first line is 232
def dump_kickstartable_trees(self, kickstart_labels=None):     log_debug(2)     writer = self._get_xml_writer()     dumper = SatelliteDumper(writer, KickstartableTreesDumper(writer, kickstarts=kickstart_labels))     dumper.dump()     writer.flush()     log_debug(4, 'OK')     self.close()     return 0		def dump_channels(self, channel_labels=None):     log_debug(2)     writer = self._get_xml_writer()     dumper = SatelliteDumper(writer, ChannelsDumper(writer, channels=channel_labels))     dumper.dump()     writer.flush()     log_debug(4, 'OK')     self.close()     return 0

Clone # 121
Distance between two fragments = 0
Clone size = 10

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 114		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 95
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.ChannelFamily()		c = rhnChannel.ChannelFamily()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c

Clone # 122
Distance between two fragments = 1
Clone size = 10

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 114		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 51
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c

Clone # 123
Distance between two fragments = 1
Clone size = 10

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 95		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 74
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.ChannelFamily()		c = rhnChannel.Channel()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c

Clone # 124
Distance between two fragments = 0
Clone size = 10

Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 74		Source file "./server/test/unit-test/test_rhnChannel.py" The first line is 51
c.save()		c.save()
channel_id = c.get_id()		channel_id = c.get_id()
c = rhnChannel.Channel()		c = rhnChannel.Channel()
c.load_by_label(label)		c.load_by_label(label)
for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)		for k, v in vdict.items():     method = getattr(c, ('get_') + (k))     dbv = method()     self.assertEqual(v, dbv)
rhnSQL.commit()		rhnSQL.commit()
return c		return c