/usr/lib/python2.7/dist-packages/pymucous/MucousMuscan.py is in mucous 1:0.2+svn20100315.r1208-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 | # This is part of the Mucous Museek Client, and distributed under the GPLv2
# Copyright (c) 2006 daelstorm.
import threading
import os
## Muscan commands, threads
#
class Muscan:
## Constructor
# Launch a local muscan process with special options from the setup buttons,
# Or from /commands
## @author daelstorm
# @param self Muscan (Class)
# @param mucous Mucous (Class)
def __init__(self, mucous):
## @var mucous
# Mucous (Class)
self.mucous = mucous
## @var timer
# threading timer that calls ThreadMuscan
self.timer = threading.Timer(1.0, self.ThreadMuscan)
## @var command
# once set, a list of command options for subprocess
self.command = []
## Clear timer and restart it in one second
# @param self Muscan (Class)
def RestartTimer(self):
self.timer.cancel()
self.timer = threading.Timer(1.0, self.ThreadMuscan)
self.timer.start()
## Set command and call RestartTimer
# @param self Muscan (Class)
# @param command List of command options for subprocess
def Command(self, command):
self.command = command
self.RestartTimer()
## Spawn Subprocess and accept stdout and stderr
# @param self Muscan (Class)
def ThreadMuscan(self):
try:
self.timer.cancel()
if self.mucous.subprocess_fail:
self.mucous.Help.Log("status", "This feature requires Python 2.4")
return
if self.mucous.Config["connection"]["interface"][:9] in ("localhost", "/tmp/muse") and self.command != [] :
p = "/usr/bin/muscan"
if os.path.exists(p):
z = self.mucous.subprocess.Popen( self.command, stdout=self.mucous.subprocess.PIPE, stderr=self.mucous.subprocess.PIPE)
stdout_text, stderr_text = z.communicate()
z.wait()
stdout_text = stdout_text.split('\n')
stderr_text = stderr_text.split('\n')
for line in stdout_text:
if line.isspace() or line == '':
pass
else:
self.mucous.Help.Log("status", line)
for line in stderr_text:
if line.isspace() or line == '':
pass
else:
self.mucous.Help.Log("status", line)
self.mucous.Help.Log("status", "Finished with shares.")
else:
self.mucous.Help.Log("status", "Your Museekd is either running remotely or already running a command, cancelling.")
self.command = []
except Exception,e:
self.mucous.Help.Log("debug", "ThreadMuscan: " + str(e))
## Change setup input mode, so directory paths can be inputted
# @param self Muscan (Class)
# @param inputmode string that is set as Spl["setup_input"] variable
def ChangeInput(self, inputmode):
self.mucous.Setup.input = inputmode
self.mucous.Setup.Mode()
## Output list of Normal shared directories to debug log
# @param self Muscan (Class)
def ListNormal(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-l"]
self.RestartTimer()
self.mucous.Help.Log("status", "Listing normal shares with muscan:")
## Output list of Buddy-only shared directories to debug log
# @param self Muscan (Class)
def ListBuddy(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-b", "-l"]
self.RestartTimer()
self.mucous.Help.Log("status", "Listing buddy shares with muscan: %s" % self.mucous.Spl["museekconfigfile"])
## Rescan Buddy-only Shares (rebuilds shares from scratch)
# @param self Muscan (Class)
def RescanBuddy(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-v", "-b", "-r"]
self.RestartTimer()
self.mucous.Help.Log("status", "Rescanning buddy shares with muscan, don't forget to Reload them. Please wait for muscan to complete.")
## Update Buddy-only Shares (checks mtimes and updates only newer dirs/files)
# @param self Muscan (Class)
def UpdateBuddy(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-v", "-b"]
self.RestartTimer()
self.mucous.Help.Log("status", "Updating buddy shares with muscan, don't forget to Reload them. Please wait for muscan to complete.")
## Update Normal Shares (checks mtimes and updates only new dirs)
# @param self Muscan (Class)
def UpdateNormal(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-v"]
self.RestartTimer()
self.mucous.Help.Log("status", "Updating shares with muscan, don't forget to Reload them. Please wait for muscan to complete.")
## Rescan Normal Shares (rebuilds shares from scratch)
# @param self Muscan (Class)
def RescanNormal(self):
self.command = ["muscan", "-c", self.mucous.Spl["museekconfigfile"], "-v", "-r"]
self.RestartTimer()
self.mucous.Help.Log("status", "Rescanning shares with muscan, don't forget to Reload them. Please wait for muscan to complete.")
|