Path: csiph.com!v102.xanadu-bbs.net!xanadu-bbs.net!goblin1!goblin2!goblin.stu.neva.ru!newsfeed.xs4all.nl!newsfeed1a.news.xs4all.nl!xs4all!post.news.xs4all.nl!not-for-mail Return-Path: X-Original-To: python-list@python.org Delivered-To: python-list@mail.python.org X-Spam-Status: OK 0.003 X-Spam-Evidence: '*H*': 0.99; '*S*': 0.00; 'url:pipermail': 0.05; 'filename:fname piece:py': 0.07; 'problem?': 0.07; 'socket': 0.07; '"__main__":': 0.09; '__name__': 0.09; 'data):': 0.09; 'main()': 0.09; 'try:': 0.09; 'python': 0.11; 'def': 0.12; 'wrote': 0.14; 'posted': 0.15; 'addr': 0.16; 'addr):': 0.16; 'client:': 0.16; 'main():': 0.16; 'size):': 0.16; 'sources,': 0.16; 'subject:usage': 0.16; 'true:': 0.16; 'url:tutor': 0.16; 'exception': 0.16; 'trying': 0.19; 'skip:f 30': 0.19; 'code,': 0.22; 'import': 0.22; 'helper': 0.24; 'skip:l 30': 0.24; 'question': 0.24; '(see': 0.26; 'header:In-Reply-To:1': 0.27; 'message-id:@mail.gmail.com': 0.30; "i'm": 0.30; 'class': 0.32; 'url:python': 0.33; 'skip:_ 10': 0.34; 'could': 0.34; 'except': 0.35; 'skip:s 30': 0.35; 'but': 0.35; 'received:google.com': 0.35; 'library.': 0.36; 'skip:f 40': 0.36; 'yield': 0.36; 'method': 0.36; 'charset:us-ascii': 0.36; 'hi,': 0.36; 'url:org': 0.36; 'list': 0.37; 'server': 0.38; 'solving': 0.38; 'to:addr:python- list': 0.38; 'to:addr:python.org': 0.39; 'called': 0.40; 'url:mail': 0.40; 'remove': 0.60; 'future': 0.60; 'manually': 0.60; 'skip:a 30': 0.61; 'tips': 0.61; 'subject:Fwd': 0.61; 'from:charset:utf-8': 0.61; 'simple': 0.61; 'more': 0.64; 'here': 0.66; 'bare': 0.84; 'basics.': 0.84; 'connected:': 0.84; 'mehtod': 0.84; 'luck': 0.93 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=EDfree4nXFn5QXAPuIfQBO49AHeR+ZkcAc9Wy+/zZmU=; b=H3h4+jWvSXhzIbd3UFeoKoI90aW4rZZNgkMSxiWm/ar7sPi90CfQygpmpSRYmHSGAN sBcJRrPqqZaEKyVZU4Wmh5F4hWp9scK/ASnOLOsC/OLOK0RmYl+7QdMco3SwDOnMEJcl KbgMjv5Ysi0aD/pmnbHg5ONWzkCQoPo1J+gBa1MOwt6+GmBWvLbz0GYAsfoT+elsrB4w o6SJZktk84dEVKQXXSEIMxfhjH6Pbu4vAB1bHCTH6V4NLTXxe0QFTT85Skz59ds0jAz/ kXC33x5zyJT2C9ODZNCUmC8DF7p3VReU/IllIP/SyLg+AJ3/lh/K9rahwNd/MaJu8rHh DZ9w== MIME-Version: 1.0 X-Received: by 10.229.214.74 with SMTP id gz10mr16660011qcb.19.1395833731873; Wed, 26 Mar 2014 04:35:31 -0700 (PDT) In-Reply-To: References: Date: Wed, 26 Mar 2014 12:35:31 +0100 Subject: Fwd: Basic asyncio usage From: =?UTF-8?Q?Piotr_Husiaty=C5=84ski?= To: python-list@python.org Content-Type: multipart/mixed; boundary=001a11339b4cc1886804f580dd10 X-BeenThere: python-list@python.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: General discussion list for the Python programming language List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Newsgroups: comp.lang.python Message-ID: Lines: 63 NNTP-Posting-Host: 2001:888:2000:d::a6 X-Trace: 1395833733 news.xs4all.nl 2975 [2001:888:2000:d::a6]:33727 X-Complaints-To: abuse@xs4all.nl Xref: csiph.com comp.lang.python:69114 --001a11339b4cc1886804f580dd10 Content-Type: text/plain; charset=UTF-8 Hi, I have posted the same question to python-tutor list *, but I'm trying my luck here as advised. I'm trying to get more familiar with asyncio library. Using python 3.4, I wrote simple echo server (see attachement for the code). I know that instead of using bare bone send/recv I could use some of the helper functions, but I want to start with the basics. Using attached code, I can connect from multiple sources, but echo won't work for all clients. Also, please look at the `sendall` mehtod - I have to manually remove write callback, otherwise it will be called all the time. Any tips on solving this problem? * https://mail.python.org/pipermail/tutor/2014-March/100679.html --001a11339b4cc1886804f580dd10 Content-Type: text/x-python; charset=US-ASCII; name="asynciotest.py" Content-Disposition: attachment; filename="asynciotest.py" Content-Transfer-Encoding: base64 X-Attachment-Id: f_ht7fkzvs0 aW1wb3J0IGFzeW5jaW8KaW1wb3J0IHNvY2tldAppbXBvcnQgdGltZQoKCmxvb3AgPSBhc3luY2lv LmdldF9ldmVudF9sb29wKCkKCgpjbGFzcyBDbGllbnQ6CiAgICBkZWYgX19pbml0X18oc2VsZiwg Y29ubik6CiAgICAgICAgc2VsZi5jb25uID0gY29ubgogICAgICAgIHNlbGYuY29ubi5zZXRibG9j a2luZyhGYWxzZSkKCiAgICBkZWYgcmVjdihzZWxmLCBzaXplKToKICAgICAgICAid3JhcCBgcmVj dmAgbWV0aG9kIHdpdGggZnV0dXJlIgogICAgICAgIGZ1dHVyZSA9IGFzeW5jaW8uRnV0dXJlKCkK CiAgICAgICAgZGVmIF9yZWN2KCk6CiAgICAgICAgICAgIHRyeToKICAgICAgICAgICAgICAgIGZ1 dHVyZS5zZXRfcmVzdWx0KHNlbGYuY29ubi5yZWN2KHNpemUpKQogICAgICAgICAgICBleGNlcHQg RXhjZXB0aW9uIGFzIGV4YzoKICAgICAgICAgICAgICAgIGZ1dHVyZS5zZXRfZXhjZXB0aW9uKGV4 YykKCiAgICAgICAgbG9vcC5hZGRfcmVhZGVyKHNlbGYuY29ubiwgX3JlY3YpCiAgICAgICAgcmV0 dXJuIGZ1dHVyZQoKICAgIGRlZiBzZW5kYWxsKHNlbGYsIGRhdGEpOgogICAgICAgICJ3cmFwIGBz ZW5kYWxsYCBtZXRob2Qgd2l0aCBmdXR1cmUiCiAgICAgICAgZnV0dXJlID0gYXN5bmNpby5GdXR1 cmUoKQoKICAgICAgICBkZWYgX3NlbmRhbGwoKToKICAgICAgICAgICAgdHJ5OgogICAgICAgICAg ICAgICAgIyBYWFggbWFudWFsbHkgcmVtb3ZlLCBiZWNhdXNlIG90aGVyd2lzZSBpdCB3aWxsIGJl IGNhbGxlZAogICAgICAgICAgICAgICAgIyBmb3JldmVyCiAgICAgICAgICAgICAgICBsb29wLnJl bW92ZV93cml0ZXIoc2VsZi5jb25uKQogICAgICAgICAgICAgICAgZnV0dXJlLnNldF9yZXN1bHQo c2VsZi5jb25uLnNlbmRhbGwoZGF0YSkpCiAgICAgICAgICAgIGV4Y2VwdCBFeGNlcHRpb24gYXMg ZXhjOgogICAgICAgICAgICAgICAgZnV0dXJlLnNldF9leGNlcHRpb24oZXhjKQoKICAgICAgICBs b29wLmFkZF93cml0ZXIoc2VsZi5jb25uLCBfc2VuZGFsbCkKICAgICAgICByZXR1cm4gZnV0dXJl CgogICAgZGVmIGNsb3NlKHNlbGYpOgogICAgICAgIHNlbGYuY29ubi5jbG9zZSgpCgoKZGVmIGFj Y2VwdChzb2NrKToKICAgIGZ1dHVyZSA9IGFzeW5jaW8uRnV0dXJlKCkKCiAgICBkZWYgX2FjY2Vw dF9jbGllbnQoKToKICAgICAgICBjb25uLCBhZGRyID0gc29jay5hY2NlcHQoKQogICAgICAgIGZ1 dHVyZS5zZXRfcmVzdWx0KChDbGllbnQoY29ubiksIGFkZHIpKQoKICAgIGxvb3AuYWRkX3JlYWRl cihzb2NrLCBfYWNjZXB0X2NsaWVudCkKICAgIHJldHVybiBmdXR1cmUKCgpkZWYgaGFuZGxlX2Ns aWVudChjb25uLCBhZGRyKToKICAgIHByaW50KCJDbGllbnQgY29ubmVjdGVkOiB7fSIuZm9ybWF0 KGFkZHIpKQogICAgd2hpbGUgVHJ1ZToKICAgICAgICBkYXRhID0geWllbGQgZnJvbSBjb25uLnJl Y3YoMTAyNCkKICAgICAgICBpZiBkYXRhLnN0cmlwKCkgPT0gYidxdWl0JzoKICAgICAgICAgICAg Y29ubi5jbG9zZSgpCiAgICAgICAgICAgIHByaW50KCJDbGllbnQgZGlzY29ubmVjdGVkOiB7fSIu Zm9ybWF0KGFkZHIpKQogICAgICAgICAgICByZXR1cm4KICAgICAgICB5aWVsZCBmcm9tIGNvbm4u c2VuZGFsbChkYXRhKQoKCkBhc3luY2lvLmNvcm91dGluZQpkZWYgdGVzdCgpOgogICAgc29jayA9 IHNvY2tldC5zb2NrZXQoc29ja2V0LkFGX0lORVQsIHNvY2tldC5TT0NLX1NUUkVBTSkKICAgIHNv Y2suc2V0c29ja29wdChzb2NrZXQuU09MX1NPQ0tFVCwgc29ja2V0LlNPX1JFVVNFQUREUiwgMSkK ICAgIHNvY2suc2V0YmxvY2tpbmcoRmFsc2UpCiAgICBzb2NrLmJpbmQoKCdsb2NhbGhvc3QnLCAx MjM0NSkpCiAgICBzb2NrLmxpc3RlbigxKQogICAgd2hpbGUgVHJ1ZToKICAgICAgICBjb25uLCBh ZGRyID0geWllbGQgZnJvbSBhY2NlcHQoc29jaykKICAgICAgICBhc3luY2lvLlRhc2soaGFuZGxl X2NsaWVudChjb25uLCBhZGRyKSkKCgpkZWYgbWFpbigpOgogICAgbG9vcC5ydW5fdW50aWxfY29t cGxldGUodGVzdCgpKQogICAgbG9vcC5jbG9zZSgpCgppZiBfX25hbWVfXyA9PSAiX19tYWluX18i OgogICAgbWFpbigpCg== --001a11339b4cc1886804f580dd10--