and not msgtype.lower() in mysettings["PORTAGE_ELOG_CLASSES"].split():

				and not msgtype.lower() in mysettings["PORTAGE_ELOG_CLASSES"].split():

			continue

			continue

		if msgfunction not in portage_const.EBUILD_PHASES:

		if msgfunction not in portage_const.EBUILD_PHASES:

			continue

			continue

		if not msgfunction in mylogentries:

		if not msgfunction in mylogentries:

			mylogentries[msgfunction] = []

			mylogentries[msgfunction] = []

			m = getattr(logmodule, "mod_"+s)

			m = getattr(logmodule, "mod_"+s)

			m.process(mysettings, cpv, mylogentries, fulllog)

			m.process(mysettings, cpv, mylogentries, fulllog)

		except (ImportError, AttributeError), e:

		except (ImportError, AttributeError), e:

		except portage_exception.PortageException, e:

		except portage_exception.PortageException, e:

#parse /etc/env.d and generate /etc/profile.env

#parse /etc/env.d and generate /etc/profile.env

	if droppriv and not uid and portage_gid and portage_uid:

	if droppriv and not uid and portage_gid and portage_uid:

		keywords.update({"uid":portage_uid,"gid":portage_gid,"groups":[portage_gid],"umask":002})

		keywords.update({"uid":portage_uid,"gid":portage_gid,"groups":[portage_gid],"umask":002})

	if not free:

	if not free:

		free=((droppriv and "usersandbox" not in features) or \

		free=((droppriv and "usersandbox" not in features) or \

			(not droppriv and "sandbox" not in features and "usersandbox" not in features))

			(not droppriv and "sandbox" not in features and "usersandbox" not in features))

		if ("mirror" in features) and ("lmirror" not in features):

		if ("mirror" in features) and ("lmirror" not in features):

			# lmirror should allow you to bypass mirror restrictions.

			# lmirror should allow you to bypass mirror restrictions.

			# XXX: This is not a good thing, and is temporary at best.

			# XXX: This is not a good thing, and is temporary at best.

			return 1

			return 1

	thirdpartymirrors = mysettings.thirdpartymirrors()

	thirdpartymirrors = mysettings.thirdpartymirrors()

					noiselevel=-1)

					noiselevel=-1)

				gotit=0

				gotit=0

		if not gotit:

		if not gotit:

			spawn(EBUILD_SH_BINARY+" nofetch",mysettings)

			spawn(EBUILD_SH_BINARY+" nofetch",mysettings)

			return 0

			return 0

		return 1

		return 1

	if not os.access(mysettings["DISTDIR"]+"/",os.W_OK):

	if not os.access(mysettings["DISTDIR"]+"/",os.W_OK):

		if not fetch_to_ro:

		if not fetch_to_ro:

			can_fetch=False

			can_fetch=False

	else:

	else:

		if use_locks and locks_in_subdir:

		if use_locks and locks_in_subdir:

								# Verify checksums at each fetch for fetchonly.

								# Verify checksums at each fetch for fetchonly.

								verified_ok,reason = portage_checksum.verify_all(mysettings["DISTDIR"]+"/"+myfile, mydigests[myfile])

								verified_ok,reason = portage_checksum.verify_all(mysettings["DISTDIR"]+"/"+myfile, mydigests[myfile])

								if not verified_ok:

								if not verified_ok:

									writemsg("!!! Previously fetched file: "+str(myfile)+"\n", noiselevel=-1)

									writemsg("!!! Previously fetched file: "+str(myfile)+"\n", noiselevel=-1)

									writemsg("!!! Reason: "+reason[0]+"\n", noiselevel=-1)

									writemsg("!!! Reason: "+reason[0]+"\n", noiselevel=-1)

									writemsg("!!! Got:      %s\n!!! Expected: %s\n" % \

									writemsg("!!! Got:      %s\n!!! Expected: %s\n" % \

								# from another mirror...

								# from another mirror...

								verified_ok,reason = portage_checksum.verify_all(mysettings["DISTDIR"]+"/"+myfile, mydigests[myfile])

								verified_ok,reason = portage_checksum.verify_all(mysettings["DISTDIR"]+"/"+myfile, mydigests[myfile])

								if not verified_ok:

								if not verified_ok:

									writemsg("!!! Fetched file: "+str(myfile)+" VERIFY FAILED!\n",

									writemsg("!!! Fetched file: "+str(myfile)+" VERIFY FAILED!\n",

										noiselevel=-1)

										noiselevel=-1)

									writemsg("!!! Reason: "+reason[0]+"\n",

									writemsg("!!! Reason: "+reason[0]+"\n",

				else:

				else:

					os.unlink(edpath)

					os.unlink(edpath)

			except OSError:

			except OSError:

				raise

				raise

		os.mkdir(edpath)

		os.mkdir(edpath)

		apply_secpass_permissions(edpath, gid=portage_gid, mode=0775)

		apply_secpass_permissions(edpath, gid=portage_gid, mode=0775)

			for file in aalist:

			for file in aalist:

				os.symlink(os.path.join(orig_distdir, file), os.path.join(edpath, file))

				os.symlink(os.path.join(orig_distdir, file), os.path.join(edpath, file))

		except OSError:

		except OSError:

			raise

			raise

	#initial dep checks complete; time to process main commands

	#initial dep checks complete; time to process main commands

	elif mydo=="qmerge":

	elif mydo=="qmerge":

		#check to ensure install was run.  this *only* pops up when users forget it and are using ebuild

		#check to ensure install was run.  this *only* pops up when users forget it and are using ebuild

		if not os.path.exists(mysettings["PORTAGE_BUILDDIR"]+"/.installed"):

		if not os.path.exists(mysettings["PORTAGE_BUILDDIR"]+"/.installed"):

			sys.exit(1)

			sys.exit(1)

		# qmerge is a special phase that implies noclean.

		# qmerge is a special phase that implies noclean.

		if "noclean" not in mysettings.features:

		if "noclean" not in mysettings.features:

				myebuild=mysettings["EBUILD"], mytree=tree, mydbapi=mydbapi,

				myebuild=mysettings["EBUILD"], mytree=tree, mydbapi=mydbapi,

				vartree=vartree, prev_mtimes=prev_mtimes)

				vartree=vartree, prev_mtimes=prev_mtimes)

	else:

	else:

		sys.exit(1)

		sys.exit(1)

	# Make sure that DISTDIR is restored to it's normal value before we return!

	# Make sure that DISTDIR is restored to it's normal value before we return!

	except SystemExit, e:

	except SystemExit, e:

		raise

		raise

	except Exception, e:

	except Exception, e:

		return None

		return None

	destexists=1

	destexists=1

		except SystemExit, e:

		except SystemExit, e:

			raise

			raise

		except Exception, e:

		except Exception, e:

			return None

			return None

	renamefailed=1

	renamefailed=1

		except Exception, e:

		except Exception, e:

			if e[0]!=errno.EXDEV:

			if e[0]!=errno.EXDEV:

				# Some random error.

				# Some random error.

				return None

				return None

			# Invalid cross-device-link 'bind' mounted or actually Cross-Device

			# Invalid cross-device-link 'bind' mounted or actually Cross-Device

	if renamefailed:

	if renamefailed:

			except SystemExit, e:

			except SystemExit, e:

				raise

				raise

			except Exception, e:

			except Exception, e:

				return None

				return None

		else:

		else:

			#we don't yet handle special, so we need to fall back to /bin/mv

			#we don't yet handle special, so we need to fall back to /bin/mv

			else:

			else:

				a=commands.getstatusoutput(MOVE_BINARY+" -f "+"'"+src+"' '"+dest+"'")

				a=commands.getstatusoutput(MOVE_BINARY+" -f "+"'"+src+"' '"+dest+"'")

				if a[0]!=0:

				if a[0]!=0:

					return None # failure

					return None # failure

		try:

		try:

			if didcopy:

			if didcopy:

		except SystemExit, e:

		except SystemExit, e:

			raise

			raise

		except Exception, e:

		except Exception, e:

			return None

			return None

	if newmtime:

	if newmtime:

			try:

			try:

				counter=long(cfile.readline())

				counter=long(cfile.readline())

			except ValueError:

			except ValueError:

				counter=long(0)

				counter=long(0)

				corrupted=1

				corrupted=1

			cfile.close()

			cfile.close()

		elif os.path.exists(cdir):

		elif os.path.exists(cdir):

			mys = pkgsplit(mycpv)

			mys = pkgsplit(mycpv)

			myl = self.match(mys[0],use_cache=0)

			myl = self.match(mys[0],use_cache=0)

			if len(myl) == 1:

			if len(myl) == 1:

				try:

				try:

					# Only one package... Counter doesn't matter.

					# Only one package... Counter doesn't matter.

		except SystemExit, e:

		except SystemExit, e:

			raise

			raise

		except Exception, e:

		except Exception, e:

			return []

			return []

	def get_all_provides(self):

	def get_all_provides(self):

		try:

		try:

			myuris = self.aux_get(mypkg, ["SRC_URI"], mytree=mytree)[0]

			myuris = self.aux_get(mypkg, ["SRC_URI"], mytree=mytree)[0]

		except (IOError,KeyError):

		except (IOError,KeyError):

			sys.exit(1)

			sys.exit(1)

		if useflags is None:

		if useflags is None:

		mf = Manifest(pkgdir, self.mysettings["DISTDIR"])

		mf = Manifest(pkgdir, self.mysettings["DISTDIR"])

		checksums = mf.getDigests()

		checksums = mf.getDigests()

		if not checksums:

		if not checksums:

			return None

			return None

		filesdict={}

		filesdict={}

		if useflags is None:

		if useflags is None:

			#match *all* visible *and* masked packages

			#match *all* visible *and* masked packages

			myval=match_from_list(mydep,self.cp_list(mykey))

			myval=match_from_list(mydep,self.cp_list(mykey))

		else:

		else:

			raise KeyError

			raise KeyError

		if self.frozen and (level not in ["match-list","bestmatch-list"]):

		if self.frozen and (level not in ["match-list","bestmatch-list"]):

			self.xcache[level][mydep]=myval

			self.xcache[level][mydep]=myval

		cpv=catpkgsplit(mykey)

		cpv=catpkgsplit(mykey)

		if not cpv:

		if not cpv:

			#invalid cat/pkg-v

			#invalid cat/pkg-v

			return []

			return []

		mycp=cpv[0]+"/"+cpv[1]

		mycp=cpv[0]+"/"+cpv[1]

		maskdict=self.mysettings.pmaskdict

		maskdict=self.mysettings.pmaskdict

				mymatches=self.xmatch("match-all",x)

				mymatches=self.xmatch("match-all",x)

				if mymatches is None:

				if mymatches is None:

					#error in package.mask file; print warning and continue:

					#error in package.mask file; print warning and continue:

					continue

					continue

				for y in mymatches:

				for y in mymatches:

					unmask=0

					unmask=0

				mymatches=self.xmatch("match-list",x,mylist=newlist)

				mymatches=self.xmatch("match-list",x,mylist=newlist)

				if mymatches is None:

				if mymatches is None:

					#error in packages file; print warning and continue:

					#error in packages file; print warning and continue:

					continue

					continue

				pos=0

				pos=0

				while pos<len(newlist):

				while pos<len(newlist):

	def gettbz2(self,pkgname):

	def gettbz2(self,pkgname):

		"fetches the package from a remote site, if necessary."

		"fetches the package from a remote site, if necessary."

		global settings

		global settings

		mysplit  = string.split(pkgname,"/")

		mysplit  = string.split(pkgname,"/")

		tbz2name = mysplit[1]+".tbz2"

		tbz2name = mysplit[1]+".tbz2"

		if not self.isremote(pkgname):

		if not self.isremote(pkgname):

				os.unlink(self.dbdir+"/"+x)

				os.unlink(self.dbdir+"/"+x)

			os.rmdir(self.dbdir)

			os.rmdir(self.dbdir)

		except OSError, e:

		except OSError, e:

			sys.exit(1)

			sys.exit(1)

	def clearcontents(self):

	def clearcontents(self):

				else:

				else:

					return None

					return None

			except (KeyError,IndexError):

			except (KeyError,IndexError):

			pos += 1

			pos += 1

		self.contentscache=pkgfiles

		self.contentscache=pkgfiles

		return pkgfiles

		return pkgfiles

		self.settings.load_infodir(self.dbdir)

		self.settings.load_infodir(self.dbdir)

		if not pkgfiles:

		if not pkgfiles:

			pkgfiles=self.getcontents()

			pkgfiles=self.getcontents()

		# Now, don't assume that the name of the ebuild is the same as the

		# Now, don't assume that the name of the ebuild is the same as the

				if myslot == self.vartree.dbapi.aux_get("/".join((self.cat, v)), ["SLOT"])[0]:

				if myslot == self.vartree.dbapi.aux_get("/".join((self.cat, v)), ["SLOT"])[0]:

					mypkglist.append(dblink(self.cat,v,destroot,self.settings))

					mypkglist.append(dblink(self.cat,v,destroot,self.settings))

			for f in myfilelist:

			for f in myfilelist:

				nocheck = False

				nocheck = False

				# listdir isn't intelligent enough to exclude symlinked dirs,

				# listdir isn't intelligent enough to exclude symlinked dirs,

					continue

					continue

				i=i+1

				i=i+1

				if i % 1000 == 0:

				if i % 1000 == 0:

				if f[0] != "/":

				if f[0] != "/":

					f="/"+f

					f="/"+f

				isowned = False

				isowned = False

						isowned = True

						isowned = True

						break

						break

				if not isowned:

				if not isowned:

					stopmerge=True

					stopmerge=True

			if stopmerge:

			if stopmerge:

				# Why is the package already merged here db-wise? Shouldn't be the case

				# Why is the package already merged here db-wise? Shouldn't be the case

				# only unmerge if it ia new package and has no contents

				# only unmerge if it ia new package and has no contents

				if not self.getcontents():

				if not self.getcontents():

				# unlinking no longer necessary; "movefile" will overwrite symlinks atomically and correctly

				# unlinking no longer necessary; "movefile" will overwrite symlinks atomically and correctly

				mymtime=movefile(mysrc,mydest,newmtime=thismtime,sstat=mystat, mysettings=self.settings)

				mymtime=movefile(mysrc,mydest,newmtime=thismtime,sstat=mystat, mysettings=self.settings)

				if mymtime!=None:

				if mymtime!=None:

					outfile.write("sym "+myrealdest+" -> "+myto+" "+str(mymtime)+"\n")

					outfile.write("sym "+myrealdest+" -> "+myto+" "+str(mymtime)+"\n")

				else:

				else:

					sys.exit(1)

					sys.exit(1)

			elif stat.S_ISDIR(mymode):

			elif stat.S_ISDIR(mymode):

				# we are merging a directory

				# we are merging a directory

						# a non-directory and non-symlink-to-directory.  Won't work for us.  Move out of the way.

						# a non-directory and non-symlink-to-directory.  Won't work for us.  Move out of the way.

						if movefile(mydest,mydest+".backup", mysettings=self.settings) is None:

						if movefile(mydest,mydest+".backup", mysettings=self.settings) is None:

							sys.exit(1)

							sys.exit(1)

						#now create our directory

						#now create our directory

						if self.settings.selinux_enabled():

						if self.settings.selinux_enabled():

							sid = selinux.get_sid(mysrc)

							sid = selinux.get_sid(mysrc)

							if cfgfiledict.has_key(myrealdest):

							if cfgfiledict.has_key(myrealdest):

								if destmd5 in cfgfiledict[myrealdest]:

								if destmd5 in cfgfiledict[myrealdest]:

									#cycle

									#cycle

									del cfgfiledict[myrealdest]

									del cfgfiledict[myrealdest]

									cycled=1

									cycled=1

							if mymd5==destmd5:

							if mymd5==destmd5:

	if vartree is None:

	if vartree is None:

		vartree = db[myroot]["vartree"]

		vartree = db[myroot]["vartree"]

	if mytbz2[-5:]!=".tbz2":

	if mytbz2[-5:]!=".tbz2":

		return None

		return None

	mypkg=os.path.basename(mytbz2)[:-5]

	mypkg=os.path.basename(mytbz2)[:-5]

	xptbz2=xpak.tbz2(mytbz2)

	xptbz2=xpak.tbz2(mytbz2)

	pkginfo={}

	pkginfo={}

	mycat=xptbz2.getfile("CATEGORY")

	mycat=xptbz2.getfile("CATEGORY")

	if not mycat:

	if not mycat:

		return None

		return None

	mycat=mycat.strip()

	mycat=mycat.strip()

	mycatpkg=mycat+"/"+mypkg

	mycatpkg=mycat+"/"+mypkg

	writemsg_stdout(">>> Extracting %s\n" % mypkg)

	writemsg_stdout(">>> Extracting %s\n" % mypkg)

	notok=spawn("bzip2 -dqc -- '"+mytbz2+"' | tar xpf -",mysettings,free=1)

	notok=spawn("bzip2 -dqc -- '"+mytbz2+"' | tar xpf -",mysettings,free=1)

	if notok:

	if notok:

		cleanup_pkgmerge(mypkg,origdir)

		cleanup_pkgmerge(mypkg,origdir)

		return None

		return None

		# Update progress above is indicated by characters written to stdout so

		# Update progress above is indicated by characters written to stdout so

		# we print a couple new lines here to separate the progress output from

		# we print a couple new lines here to separate the progress output from

		# what follows.

		# what follows.

		#make sure our internal databases are consistent; recreate our virts and vartree

		#make sure our internal databases are consistent; recreate our virts and vartree

		do_vartree(mysettings, trees=trees)

		do_vartree(mysettings, trees=trees)