ó uÈÔec@sSddlmZmZddlmZddlmZdeefd„ƒYZdS(iÿÿÿÿ(tPlugint RedHatPlugin(tquote(tmatchtPulpcBs>eZdZdZd Zd gZd„Zd „Zd „ZRS( s Pulp platformtpulps pulp-servers pulp-katellottaskss*number of tasks to collect from DB queriestfastiÈc Csyd|_d|_d|_d|_d|_t}yx tdƒjƒjƒD]ó}t d|ƒr§|j ƒdj dƒdj d ƒ}|d|_|d|_nt d |ƒrÐd |j ƒd|_nt d |ƒrùd |j ƒd|_n|j dƒrt }n|rO|j dƒrO|j ƒd|_t}qOqOWWnt k rZnX|jdddddddddg ƒ|jdƒ}|jd|ƒ}|jd|ƒ}|jd|ƒ}|jdƒ}|jdƒ} |j|dd ƒ|j|dd!ƒ|j|dd"ƒ|j|dd#ƒ|j| dd$ƒ|jgd%D]} d&| |jf^qUƒdS('Nt localhostt27017ts/etc/pulp/server.confs^\s*seeds:\s+\S+:\S+it,it:s\s*username:\s+\S+s-u %ss\s*password:\s+\S+s-p %ss [messaging]s certfile:s/etc/pulp/*.confs /etc/pulp/server/plugins.conf.d/s/etc/default/pulp*s/var/log/httpd/pulp-http.log*s/var/log/httpd/pulp-https.log*s(/var/log/httpd/pulp-http_access_ssl.log*s)/var/log/httpd/pulp-https_access_ssl.log*s'/var/log/httpd/pulp-http_error_ssl.log*s(/var/log/httpd/pulp-https_error_ssl.log*Rsa"DBQuery.shellBatchSize=%s;; db.task_status.find().sort({finish_time: -1}).pretty().shellPrint()"sP"DBQuery.shellBatchSize=%s;; db.reserved_resources.find().pretty().shellPrint()"se"DBQuery.shellBatchSize=%s;; db.task_status.find({state:{\$ne: \"finished\"}}).pretty().shellPrint()"s­"function humanReadable(bytes) { var i = -1; var byteUnits = ['kB', 'MB', 'GB', 'TB', 'PB', 'EB', 'ZB', 'YB']; do { bytes = bytes / 1024; i++; } while (bytes > 1024); return Math.max(bytes, 0.1).toFixed(1) + ' ' + byteUnits[i];};var collectionNames = db.getCollectionNames(), stats = [];collectionNames.forEach(function (n) { stats.push(db[n].stats()); });stats = stats.sort(function(a, b) { return b['size'] - a['size']; });for (var c in stats) { print(stats[c]['ns'] + ': ' + humanReadable(stats[c]['size']) + ' (' + humanReadable(stats[c]['storageSize']) + ')'); }"s "db.stats()"tsuggest_filenamesmongo-task_statussmongo-reserved_resourcesspulp-running_taskssmongo-collection_sizessmongo-db_statstqucs<qpid-stat -%s --ssl-certificate=%s -b amqps://localhost:5671(tdbhosttdbporttdbusert dbpasswordtmessaging_cert_filetFalsetopentreadt splitlinesRtsplitt startswithtTruetIOErrort add_copy_spect get_optiontbuild_mongo_cmdtadd_cmd_output( tselftin_messaging_sectiontlineturit num_taskstmtaskstmrestpruntcsizestdbstatstopt((s4/usr/lib/python2.7/site-packages/sos/plugins/pulp.pytsetupsl     &        cCsFd}d|j|j|j|jf}d}|t|||fƒS(Ns bash -c %ss--host %s --port %s %s %ss mongo pulp_database %s --eval %s(RRRRR(R tqueryt_cmdt_mondbt_moncmd((s4/usr/lib/python2.7/site-packages/sos/plugins/pulp.pyRƒs cCsBd}d}|jd||ƒd}d}|jd||ƒdS(Ns0(([a-z].*(passw|token|cred|secret).*)\:(\s))(.*)s \1 ********s/etc/pulp/(.*)\.conf$s7(\s*\".*(passw|cred|token|secret).*\"\s*:\s*\")(.*)(\")s \1********\4s/etc/pulp(.*)(.json$)(tdo_path_regex_sub(R tetcregtrepltjreg((s4/usr/lib/python2.7/site-packages/sos/plugins/pulp.pytpostprocŠs (s pulp-servers pulp-katello(staskss*number of tasks to collect from DB queriesRiÈ( t__name__t __module__t__doc__t plugin_nametpackagest option_listR+RR4(((s4/usr/lib/python2.7/site-packages/sos/plugins/pulp.pyRs  j N(t sos.pluginsRRtpipesRtreRR(((s4/usr/lib/python2.7/site-packages/sos/plugins/pulp.pyt s