4

当我运行它时，我得到了泄漏。我不确定发生了什么。我猜管道没有关闭或者可能发生了其他事情。 

def deactivateMetadataDevice(input_dmd_lun_wwn):
    #print('pvremove /dev/mapper/' + input_dmd_lun_wwn)
    status_cmd = False
    ps = subprocess.Popen('/sbin/pvremove /dev/mapper/' + input_dmd_lun_wwn, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
    for line in iter(ps.stdout.readline, ''):
        print line
        if re.search('wiped', line):
           status_cmd = True
        else:
           # Cleaning metadata and removing from LVM if ok then return true
           status_cmd = False
           raise Warning('\t\t PV /dev/mapper/'+ input_dmd_lun_wwn +' belongs to Volume Group')

    return status_cmd

当我运行上面的代码时遇到这个问题：

File descriptor 4 (pipe:[323948]) leaked on pvremove invocation. Parent PID 15380: python
4

3 回答 3

4

问题是您在读取管道中的所有数据之前返回，并且您没有发出等待以获取返回码并从操作系统 pid 表中删除该进程。我认为一些调整会做到这一点（我还删除了一些我认为多余的东西）。

def deactivateMetadataDevice(input_dmd_lun_wwn):
    #print('pvremove /dev/mapper/' + input_dmd_lun_wwn)
    status_cmd = False
    ps = subprocess.Popen('/sbin/pvremove /dev/mapper/' + input_dmd_lun_wwn, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
    for line in ps.stdout:
        print line
        if 'wiped' in line:
           status_cmd = True
    ps.wait()
    # need to handle ps.returncode != 0
    if status_cmd is False:
       # Cleaning metadata and removing from LVM if ok then return true
       raise Warning('\t\t PV /dev/mapper/'+ input_dmd_lun_wwn +' belongs to Volume Group')
    return status_cmd # likely not needed because you are using exceptions for errors
于 2013-08-23T18:26:00.547 回答
3

我知道这已经很老了，但是我遇到了类似的问题，并认为我的答案可能会帮助其他人在寻求帮助时遇到这个问题。

subprocess.Popen 的默认值为 close_fds=False（ETA：在 Python 3.2 中的 POSIX 上，默认值已更改为 True）。但是 lvm(8) 手册页指出：

在调用时，lvm 要求只有标准文件描述符 stdin、stdout 和 stderr 可用。如果找到其他人，他们将被关闭，并发出有关泄漏的警告消息。

因此，对于像 pvremove 这样的 lvm 命令，您可以通过在 subprocess.Popen 调用中设置 close_fds=True 来避免泄漏。

于 2015-10-01T00:15:52.003 回答
0

我最终这样做了。不幸的是，env 中的大多数服务器都有 python 2.6。Check_output 带有 python 2.7 版本。

# check_output in subprocess unfortunately comes by default in 2.7 version
def check_output(*popenargs, **kwargs):
    # Passing all arguments to process
    process = subprocess.Popen(stdout=subprocess.PIPE, *popenargs, **kwargs)
    output, unused_err = process.communicate()
    retcode = process.poll()

    if retcode:
       cmd = kwargs.get("args")
       if cmd is None:
          cmd = popenargs[0]
       error = subprocess.CalledProcessError(retcode, cmd)
       error.output = output
       raise error

    return output

# Function to remove metadata from phisical device
def deactivateMetadataDevice(input_dmd_lun_wwn):
    #print('pvremove /dev/mapper/' + input_dmd_lun_wwn)
    status_cmd = False
    if 'wiped' in check_output(["/sbin/pvremove", "/dev/mapper/" + input_dmd_lun_wwn]):
       status_cmd = True

    return status_cmd
于 2013-08-30T06:06:23.427 回答