def pcl_put(options, source, target):
"""
?????????? ?????????? ??????? ???????? ????? ? ????????? (pcl_put_retry)
"""
pcl_verbose("Transfer: {0} ({1}) -> {2}".format(source, pcl_human(os.path.getsize(source)), target), options.verbose)
retry = 0
while True:
try:
pcl_put_retry(options, source, target)
break
except (pclURLError, pclBadStatusLine, pclCannotSendRequest, ssl.SSLError, socket.error, pclError) as e:
pcl_can_query_retry(e)
retry += 1
pcl_debug("Retry {0}/{1}: {2}".format(retry, options.retries, e), options.debug)
if retry >= options.retries:
raise pclError(1, e)
time.sleep(options.delay)
python类CannotSendRequest()的实例源码
def pcl_get(options, source, target):
"""
?????????? ?????????? ??????? ????????? ????? ?? ????????? (pcl_get_retry)
"""
pcl_verbose("Transfer: {0} -> {1}".format(source, target), options.verbose)
retry = 0
while True:
try:
pcl_get_retry(options, source, target)
break
except (pclURLError, pclBadStatusLine, pclCannotSendRequest, ssl.SSLError, socket.error, pclError) as e:
pcl_can_query_retry(e)
retry += 1
pcl_debug("Retry {0}/{1}: {2}".format(retry, options.retries, e), options.debug)
if retry >= options.retries:
raise pclError(1, e)
time.sleep(options.delay)
def deposit():
printMsg("Loading bitcoin address...")
# connect to node and get new wallet address
try:
addr = rpc_connection.getnewaddress()
except (socket.error, httplib.CannotSendRequest):
printMsg("getnewaddress http error", COLOR_RED)
time.sleep(2)
return False
# show off the new address!
printMsg(addr, COLOR_GREEN, 1)
showQR(addr, 'M')
# called by withdraw() to display segment of a list as a menu
def poli_request(self, endpoint, data, method="POST"):
"""
@arg : endpoint The API target endpoint
@arg : data dictionary
@return : dict issued from JSON
"""
if not self.is_online:
g_logger.error("Cannot send requests while not connected")
raise IOError
headers = {"Accept-encoding": "gzip, deflate",
"Content-type": "application/json",
"Accept": "*/*;q=0.8",
"Accept-Language": "en-US,en;q=0.5",
"Connection": "Keep-Alive",
"X-API-Key": self.api_key}
json_data = json.dumps(data)
try:
self.h_conn.request(method, endpoint, json_data, headers)
except httplib.CannotSendRequest as e:
g_logger.error("Error during request, retrying")
self.close_connection()
self.get_online()
self.h_conn.request(method, endpoint, json_data, headers)
res = self.h_conn.getresponse()
if res.status != 200:
g_logger.error("The %s request didn't go as expected", method)
g_logger.debug("Status code was %d and content was %s",
res.status, res.read())
return None
content_type = res.getheader("Content-Encoding")
if content_type == "gzip":
buf = StringIO(res.read())
res = gzip.GzipFile(fileobj=buf)
data = res.read()
try:
result = json.loads(data)
except BaseException:
raise IOError
return result
def pcl_query(options, method, url, args, headers = None, filename = None):
"""
?????????? ?????????? ??????? ??????? ? API (pcl_query_retry)
"""
retry = 0
while True:
try:
return pcl_query_retry(options, method, url, args, headers, filename)
except (pclURLError, pclBadStatusLine, pclCannotSendRequest, ssl.SSLError, socket.error, pclError) as e:
pcl_can_query_retry(e)
retry += 1
pcl_debug("Retry {0}/{1}: {2}".format(retry, options.retries, e), options.debug)
if retry >= options.retries:
raise pclError(1, e)
time.sleep(options.delay)
def showQR():
global rpc_connection
print "Loading 2nd bitcoin address..."
# connect to node and get new wallet address
try:
addr = rpc_connection.getnewaddress()
except (socket.error, httplib.CannotSendRequest):
print "showQR Timeout"
initRPC()
return False
# bypass rpc for testing
#addr = '1CepbXDXPeJTsk9PUUKkXwfqcyDgmo1qoE'
# generate QR code and display on LED grid
code = pyqrcode.create(addr, error='M', version=3)
t = code.text(1)
print addr
# print the actual QR code to terminal with 1's and 0's
print t
row = 31
col = 0
matrix.Clear()
for i in t:
if i != '\n':
matrix.SetPixel(row, col, 255-int(i)*255, 255-int(i)*255, 255-int(i)*255)
col += 1
else:
row -= 1
col = 0
time.sleep(0.001)
# give us a chance to scan it
time.sleep(5)
return True
def withdraw():
printMsg("Loading unspent coins...")
# connect to node and get all unspent outputs
try:
list = rpc_connection.listunspent(0)
except (socket.error, httplib.CannotSendRequest):
printMsg("listunspent http error", COLOR_RED)
time.sleep(2)
return False
# no coins
if len(list) == 0:
printMsg("No unspent outputs!", COLOR_RED)
time.sleep(2)
return False
# calculate balances of each spendable key in wallet
coins = {}
for addr in list:
if addr['address'] in coins:
coins[addr['address']] += addr['amount']
else:
coins[addr['address']] = addr['amount']
# send unspent coins list to the recursive paging menu function
withdrawMenu(coins)
# display bitcoin address QR code for tipping
def quit(self):
"""
Overrides the base class method cleaning the timestamped profile.
"""
self.is_running = False
try:
wl_log.info("Quit: Removing profile dir")
shutil.rmtree(self.prof_dir_path)
super(TorBrowserDriver, self).quit()
except CannotSendRequest:
wl_log.error("CannotSendRequest while quitting TorBrowserDriver",
exc_info=False)
# following is copied from webdriver.firefox.webdriver.quit() which
# was interrupted due to an unhandled CannotSendRequest exception.
# kill the browser
self.binary.kill()
# remove the profile folder
try:
shutil.rmtree(self.profile.path)
if self.profile.tempfolder is not None:
shutil.rmtree(self.profile.tempfolder)
except Exception as e:
print(str(e))
except Exception:
wl_log.error("Exception while quitting TorBrowserDriver",
exc_info=True)
def quit(self):
"""
Overrides the base class method cleaning the timestamped profile.
"""
self.is_running = False
try:
wl_log.info("Quit: Removing profile dir")
shutil.rmtree(self.prof_dir_path)
super(TorBrowserDriver, self).quit()
except CannotSendRequest:
wl_log.error("CannotSendRequest while quitting TorBrowserDriver",
exc_info=False)
# following is copied from webdriver.firefox.webdriver.quit() which
# was interrupted due to an unhandled CannotSendRequest exception.
# kill the browser
self.binary.kill()
# remove the profile folder
try:
shutil.rmtree(self.profile.path)
if self.profile.tempfolder is not None:
shutil.rmtree(self.profile.tempfolder)
except Exception as e:
print(str(e))
except Exception:
wl_log.error("Exception while quitting TorBrowserDriver",
exc_info=True)
def getSuggestions(self, queryString):
self.prepareQuery()
if queryString is not "":
query = self.prepQuerry + quote(queryString)
self.conn = HTTPConnection("google.com")
try:
self.conn = HTTPConnection("google.com")
self.conn.request("GET", query, "", {"Accept-Encoding": "UTF-8"})
except (CannotSendRequest, gaierror, error):
self.conn.close()
print "[MyTube - GoogleSuggestions] Can not send request for suggestions"
return None
else:
try:
response = self.conn.getresponse()
except BadStatusLine:
self.conn.close()
print "[MyTube - GoogleSuggestions] Can not get a response from google"
return None
else:
if response.status == 200:
data = response.read()
header = response.getheader("Content-Type", "text/xml; charset=ISO-8859-1")
charset = "ISO-8859-1"
try:
charset = header.split(";")[1].split("=")[1]
print "[MyTube - GoogleSuggestions] Got charset %s" %charset
except:
print "[MyTube - GoogleSuggestions] No charset in Header, falling back to %s" %charset
data = data.decode(charset).encode("utf-8")
self.conn.close()
return data
else:
self.conn.close()
return None
else:
return None
def getnewaddr(self, _user = None):
"""
Generate a new address for _user
Returns (string) address
"""
user = self.verify_user(_user=_user)
addr = ""
counter = 0
while True:
try:
# Unlock wallet for keypoolrefill
if hasattr(self.conf, 'walletpassphrase'):
self.conn.walletpassphrase(self.conf.walletpassphrase, 1)
# Generate new address
addr = self.conn.getnewaddress(user)
# Lock wallet
if hasattr(self.conf, 'walletpassphrase'):
self.conn.walletlock()
if not addr:
raise Exception("CtbCoin::getnewaddr(%s): empty addr", user)
time.sleep(0.1)
return str(addr)
except BitcoindException as e:
lg.error("CtbCoin::getnewaddr(%s): BitcoindException: %s", user, e)
raise
except CannotSendRequest as e:
if counter < 3:
lg.warning("CtbCoin::getnewaddr(%s): CannotSendRequest, retrying")
counter += 1
time.sleep(10)
continue
else:
raise
except Exception as e:
if str(e) == "timed out" and counter < 3:
lg.warning("CtbCoin::getnewaddr(%s): timed out, retrying")
counter += 1
time.sleep(10)
continue
else:
lg.error("CtbCoin::getnewaddr(%s): Exception: %s", user, e)
raise
def getPath(self, path="/"):
self.body = None
self.__initConnections__( path )
try:
self.conn.request("GET", path, headers=self.headers)
except httplib.CannotSendRequest as e:
log.error("CannotSendRequest")
pass
except Exception as e:
log.error("{}".format(type(e).__name__))
exit(1)
#log.debug("GET:{} with {}".format(path, self.headers))
self.res = None
cnt = 0
while True:
try:
self.res = self.conn.getresponse()
if self.res is not None:
self.body = self.res.read()
break
except Exception, e:
if self.res is not None:
self.body = self.res.read()
break
sys.stdout.write("\tretry {}\r".format(cnt))
sys.stdout.flush()
self.conn = None
self.__initConnections__( path )
self.conn.request("GET", path, headers=self.headers)
time.sleep(cnt*0.5)
#if cnt > 10:
# log.error("Reaching Max Fail")
# exit(1)
continue
for header in self.res.getheaders():
if header[0] == 'set-cookie':
self.cookie_str = header[1]
break
return self.res.status
