python - IMAP and Gevent: ConcurrentObjectUseError -

-

i'm trying create asynchronous download of messages e-mail gevent , imap. use python 2.7.8 , gevent 1.1.1.

self.connection = imaplib.imap4_ssl(self.hostname, self.port, **ssl_files)  ...  rv, data = self.connection.search(none, "all") numbers = [number number in data[0].split()]  threads = [gevent.spawn(self._get_message, message) message in numbers] gevent.joinall(threads)

function _get_message have code:

def _get_message(self, message_number):     logging.info("message {0} called!".format(message_number))     rv, data = self.connection.fetch(message_number, '(rfc822)')     if not self.is_ok(rv): return     message = email.message_from_string(data[0][1])

but every time have error:

traceback (most recent call last):   file "c:\python27\lib\site-packages\gevent\greenlet.py", line 534, in run     result = self._run(*self.args, **self.kwargs)   file "c:/users/eugene/pycharmprojects/extract email criteria/imap_email.py", line 108, in _get_message     rv, data = self.connection.fetch(message_number, '(rfc822)')   file "c:\python27\lib\imaplib.py", line 456, in fetch     typ, dat = self._simple_command(name, message_set, message_parts)   file "c:\python27\lib\imaplib.py", line 1088, in _simple_command     return self._command_complete(name, self._command(name, *args))   file "c:\python27\lib\imaplib.py", line 910, in _command_complete     typ, data = self._get_tagged_response(tag)   file "c:\python27\lib\imaplib.py", line 1017, in _get_tagged_response     self._get_response()   file "c:\python27\lib\imaplib.py", line 929, in _get_response     resp = self._get_line()   file "c:\python27\lib\imaplib.py", line 1027, in _get_line     line = self.readline()   file "c:\python27\lib\imaplib.py", line 1189, in readline     return self.file.readline()   file "c:\python27\lib\socket.py", line 451, in readline     data = self._sock.recv(self._rbufsize)   file "c:\python27\lib\site-packages\gevent\_sslgte279.py", line 455, in recv     return self.read(buflen)   file "c:\python27\lib\site-packages\gevent\_sslgte279.py", line 314, in read     self._wait(self._read_event, timeout_exc=_sslerrorreadtimeout)   file "c:\python27\lib\site-packages\gevent\_socket2.py", line 173, in _wait     raise _socketcommon.concurrentobjectuseerror('this socket used greenlet: %r' % (watcher.callback, )) concurrentobjectuseerror: socket used greenlet: <bound method waiter.switch of <gevent.hub.waiter object @ 0x02b1c558>> <greenlet @ 0x2afe710: <bound method emailimapconnection._get_message of <__main__.emailimapconnection object @ 0x02a63c50>>(4)> failed concurrentobjectuseerror

code on github gist: https://gist.github.com/gitex/0d9385fa3ab1d98f30713f6eeeab454f

i have monkey.patch_all() in beginning. works first socket, rest locked. assume socket blocked inside imap. how can solve problem?


Comments

Post a Comment

Popular posts from this blog

javascript - How to get current YouTube IDs via iMacros? -

-
i want viewed youtube video id , save csv via imacros, gets nothing. here js code: var videoid; videoid ="code:"; videoid +="url goto=https://www.youtube.com/watch?v=dbnywxdz_pa"+"\n"; videoid +="add !extract {{!urlcurrent}}"+"\n"; videoid +="set !var1 eval(\"var s=\"{{!urlcurrent}}\"; s.match((?<=watch\\?v=|/videos/|embed\\/)[^#\\&\\?]*);s[0]; \")"+"\n"; videoid +="add !extract {{!var1}}"+"\n"; videoid +="saveas type=extract folder=* file=url.csv"+"\n"; try this: var videoid = "url goto=https://www.youtube.com/watch?v=dbnywxdz_pa" + "\n"; videoid += "set !extract {{!urlcurrent}}" + "\n"; videoid += 'set !extract eval("\'{{!extract}}\'.match(/v=(.{11})/)[1];")' + "\n"; videoid += "saveas type=extract folder=* file=url.csv" + "\n"; iimplay
Read more

c# - Maintaining a program folder in program files out of date? -

-
for program i'm writing in vs c# wpf need store user related information on user's computer. far knew has been done creating folder in c:\program files , adding whatever program related info folder in subfolders or whatever. after doing browsing came across lot of people saying method out of date because access may denied create folder there, works administrative accounts, etc.. 1 site suggested saving c:\users\username\appdata\roaming or c:\users\username\appdata\local. question best , date method saving program data users computer? also take @ msdn article . it uwp apps have general idea put if developing wpf app. you may need these folders: environment.specialfolder.applicationdata environment.specialfolder.localapplicationdata environment.specialfolder.commonapplicationdata
Read more

emulation - Android map show my location didn't work -

-
i have been struggle current location in google map, tried official map demo, not working also. shows getmylocation button on upper right, didn't show blue dot on map current location. here code , i'm using emulator target api 23, guess may emulator's problem since code download directly github. advice appreciated. [screenshot][1] package com.example.mapdemo; import com.google.android.gms.maps.googlemap; import com.google.android.gms.maps.googlemap.onmylocationbuttonclicklistener; import com.google.android.gms.maps.onmapreadycallback; import com.google.android.gms.maps.supportmapfragment; import android.manifest; import android.content.pm.packagemanager; import android.os.bundle; import android.support.annotation.nonnull; import android.support.v4.app.activitycompat; import android.support.v4.content.contextcompat; import android.support.v7.app.appcompatactivity; import android.widget.toast; /** * demo
Read more