【发布时间】:2016-06-07 01:52:55
【问题描述】:
所以我在我的 RPI 上编写了这个 python 代码来创建一个与我的快思聪控制处理器对话的数字海报。由于某种原因,我的代码在一段时间后停止响应。我不知道为什么。 我不知道我的 Pi 是否会睡觉,但如果有人能指出我的代码中可能导致这种情况的任何内容,请告诉我。
编辑:我自己想出来的。非常感谢所有评论的人。
每次我通过循环时,我都在创建一个新的 FBI 进程,我最终用尽了 Pi 的所有 RAM,直到它停止,因为它没有任何剩余。我现在在加载修复该问题的图像后终止 FBI 进程。感谢大家的帮助。
我的功能和设置资料:
import socket
import os
import thread
import sys
import urllib
from time import ctime
from PIL import Image
import time
import random
import logging
frameBufferCommand = "sudo fbi -a -T 1 -d /dev/fb0 -noverbose "
moviePosterLocation = "/home/pi/movieposters/"
openBlackImage = "/home/pi/movieposters/special/black.jpg"
killFrameBuffer = "sudo killall fbi"
turnOffScreen = "sudo /opt/vc/bin/tvservice -o"
turnOnScreen = "sudo /opt/vc/bin/tvservice -p"
def splitString(input):
stringList = input.split("/x00/")
return stringList
def displayRandomPoster():
displayingPoster = False
fileCount = next(os.walk(moviePosterLocation))[2] #get the number of available posters
print('Current # Of Posters in Directory: ' + str(len(fileCount)))
attemptNumber = 0
while not displayingPoster:
posterToDisplay = random.randint(0, len(fileCount))
print('Trying To Display A Random Poster')
attemptNumber += 1
try:
image = Image.open(moviePosterLocation + fileCount[posterToDisplay]) #open the current image
width, height = image.size
except IndexError as msg:
print("encountered an IndexError while opening an image")
width = 0
height = 0
except IOError as msg:
print(msg)
try:
conn.send(msg)
except socket.error as msg:
print("Socket Error")
if width > height:
if attemptNumber > 5:
print("Too Many Attempts, Stopping")
break
else:
print("We Think This Isnt A Poster, Trying Again")
continue
else:
try:
conn.send(" Displaying Poster: " + str(fileCount[posterToDisplay]))
except socket.error as msg:
print msg
os.system(frameBufferCommand + moviePosterLocation + fileCount[posterToDisplay])
displayingPoster = True
return
正在监听的线程和主循环:
#-- CLIENT THREAD --
def client(conn):
try:
conn.send("Connected With Raspberry Pi")
os.system(frameBufferCommand + openBlackImage)
except socket.Error as msg:
print(msg)
print(str(bindSuccess))
while 1:
dataReceived = conn.recv(1024)
reply = "OK.. "
conn.send(reply + dataReceived)
dataList = splitString(dataReceived)
print(dataList)
if dataList[6] == "":
print("dataList[6] is empty, displaying a random poster")
displayRandomPoster()
else:
try:
moviePosterURL = dataList[6]
splitPosterURL = moviePosterURL.split("%")
moviePosterFilename = splitPosterURL[7]
urllib.urlretrieve(moviePosterURL, moviePosterLocation + moviePosterFilename)
conn.send("XBMC Movie Poster Downloading")
conn.send("Movie Poster saved as: " + moviePosterLocation + moviePosterFilename)
print("Movie Poster saved as: " + moviePosterLocation + moviePosterFilename)
except socket.error:
print("Encountered Socket Error While Downloading Poster - Line 80")
try:
os.system(frameBufferCommand + moviePosterLocation + moviePosterFilename)
print('Opening Downloaded Poster')
except OSError as msg:
print(str(msg[0]) + str(msg[1]))
if not dataReceived:
break
time.sleep(1)
#-- MAIN FUNCTION --
host = ''
communicationPort = 5005
bindSuccess = False
crestronSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
print("Socket Created Successfully")
try:
crestronSocket.bind((host, communicationPort))
bindSuccess = True
except socket.Error as msg:
bindSuccess = False
print("Socket Bind Error" + msg)
sys.exit()
crestronSocket.listen(1)
print("Crestron Socket Listening")
while bindSuccess == True:
#wait to accept a connection - blocking call
conn, addr = crestronSocket.accept()
print('Connected with Client: ' + addr[0] + ':' + str(addr[1]))
thread.start_new_thread(client , (conn,))
crestronSocket.close()
【问题讨论】:
-
代码太多了。尝试将其修剪为MVCE。
-
@LexScarisbrick 你的意思是为了调试目的吗?
-
请阅读我其他评论中的链接。要点是人们必须筛选的代码越多,您得到答案的可能性就越小。
-
“代码停止响应” - 您的意思是您的服务器不接受新连接,还是现有连接停止工作?在 ConnectionThread 函数中,您应该在它退出并关闭连接的地方放置一些打印语句,也许您的代码正在那里?否则,是的,代码太多了,任何人都无法轻松地深入了解。也太特定于应用程序 - 如果有人可以自己运行它,那么检查你的代码是最容易的,所以把自己放在一个潜在的回答者的位置,一个没有你可用的图像/位的人。
-
@barny 现有连接停止响应。但是我想我可能已经想通了。我只是在看电视时运行脚本,我想我可能已经发现了问题。在 displayRandomPoster() 函数中,我遇到了 IOError,因为它试图打开一个没有正确保存的文件。我认为这就是问题所在。但我不确定。
标签: python raspberry-pi tcpsocket