Skip to main content

Some notes on Promise / async guzzle

 Some notes on Promise / async

It works this way because calling tick when starting a promise could have the side effect of resolving other promises and resolving them. This could have pretty bad unforeseen consequences-- most of which revolve around unwanted recursion. Take the following example:


You are building a rate-limited pool of concurrent promises that yields promises from a generator. When a promise completes, the abstraction calls next on the generator, sends the request, and adds a promise to the pool. If initiating a promise in cURL caused other promises to complete, then it would cause the abstraction to attempt to call next on the generator while it's still yielding the previous value. This causes a strange sort of recursion in PHP generators and will trigger a fatal error.


You should either use the tick approach I mentioned in the comment linked by @Briareos or use a different adapter that hooks into an event loop in which your whole application is run asynchronously.

https://github.com/guzzle/guzzle/issues/1127


Unfortunately, calling tick() turned out to be not that simple.

In my case I have to execute tick() about 2-3 times until the request is actually sent.

As far as I understood, every while (curl_multi_exec() === CURLM_CALL_MULTI_PERFORM) loop performs some piece of work on registered handles.
My conjecture is that you can't say what exactly this piece of work will be. It's up to cURL and, probaly, is subject to changes.
Maybe first time it will establish connection, next time it will send data, and so on...

So, you can't be sure that your request will be fired on the very first curl_multi_exec() loop.


@drscre That's strange; I'm not a cURL expert, but when I look into the ext/curl source code, I see that curl_multi_exec is calling curl_multi_perform in libcurl, which says:

This function handles transfers on all the added handles that need attention in an non-blocking fashion.
When an application has found out there's data available for the multi_handle or a timeout has elapsed, the application should call this function to read/write whatever there is to read or write right now etc.

My interpretation is that all requests are sent at that point. Are you sure you are calling tick() only after all Client::xxxAsync() calls?



curl /kərl/

guzzle /ˈɡəzəl/


https://github.com/php-http/message/issues/96


https://stackoverflow.com/questions/45182654/upload-file-in-chunks-to-url-endpoint-using-guzzle-php


 $pathname = FCPATH . '../upload/Indus_at_Skardu.jpg';

        $api = env('DFC.URL') . '/api/uploadMedia';

        my_log($api);


        $resource = fopen($pathname, 'r');

        $stream = \GuzzleHttp\Psr7\Utils::tryFopen($pathname, 'r');

        $streamData =

        [

            'name' => 'file_upload',

            'contents' => $stream,

        ];

        $requestData = array_push($requestData, $streamData);


        $request = new \GuzzleHttp\Psr7\Request(

            'POST',

            $api,

            [],

            new \GuzzleHttp\Psr7\MultipartStream(

                [

                    [

                        'name' => 'file_upload',

                        'contents' => $stream,

                    ],

                    [

                        'name' => 'folderId',

                        'contents' => 2

                    ]

                ]

            )

        );

        $response = $this->guzzleHttpClient->send($request);

        my_log($response);

Comments

Popular posts from this blog

AWS Elasticache Memcached connection

https://docs.aws.amazon.com/AmazonElastiCache/latest/mem-ug/accessing-elasticache.html#access-from-outside-aws http://hourlyapps.blogspot.com/2010/06/examples-of-memcached-commands.html Access memcached https://docs.aws.amazon.com/AmazonElastiCache/latest/mem-ug/GettingStarted.AuthorizeAccess.html Zip include hidden file https://stackoverflow.com/questions/12493206/zip-including-hidden-files phpmemcachedadmin ~ phpMyAdmin or phpPgAdmin ... telnet mycachecluster.eaogs8.0001.usw2.cache.amazonaws.com 11211 stats items stats cachedump 27 100 https://docs.aws.amazon.com/AmazonElastiCache/latest/mem-ug/VPCs.EC.html https://lzone.de/cheat-sheet/memcached VPC ID Security Group ID (sg-...) Cluster: The identifier for the cluster memcached1 Creation Time: The time (UTC) when the cluster was created January 9, 2019 at 11:47:16 AM UTC+7 Configuration Endpoint: The configuration endpoint of the cluster memcached1.ahgofe.cfg.usw1.cache.amazonaws.com:11211 St...

Simulate Fail2ban on Apache request spam with mod_evasive limitipconn ...

https://en.wikipedia.org/wiki/Manchu_alphabet https://en.wikipedia.org/wiki/Sweet_potato https://en.wikipedia.org/wiki/New_World_crops https://www.mdpi.com/journal/energies http://www.cired.net/publications/cired2007/pdfs/CIRED2007_0342_paper.pdf https://www.davidpashley.com/articles/writing-robust-shell-scripts/ trap command https://en.wikipedia.org/wiki/Race_condition https://unix.stackexchange.com/questions/172541/why-does-exit-1-not-exit-the-script exit 1 not work it seem { } brace bound fixed it. cat access_log | cut -d ' ' -f 1 > ip1 sort -n -t. -k1,1 -k2,2 -k3,3 -k4,4 | uniq -c | sort -n -r -s https://unix.stackexchange.com/questions/246104/unix-count-unique-ip-addresses-sort-them-by-most-frequent-and-also-sort-them https://stackoverflow.com/questions/20164696/how-to-block-spam-and-spam-bots-for-good-with-htaccess  Code: ------------------------------------------------------------------- #Block Spam Bots and Spam on your website #Block proxies...

Notes Windows 10 Virtualbox config, PHP Storm Japanese, custom PHP, Apache build, Postgresql

 cmd => Ctrl + Shift + Enter mklink "C:\Users\HauNT\Videos\host3" "C:\Windows\System32\drivers\etc\hosts" https://www.quora.com/How-to-create-a-router-in-php https://serverfault.com/questions/225155/virtualbox-how-to-set-up-networking-so-both-host-and-guest-can-access-internet 1 NAT + 1 host only config https://unix.stackexchange.com/questions/115464/how-to-properly-set-up-2-network-interfaces-in-centos-running-in-virtualbox DEVICE=eth0 TYPE=Ethernet #BOOTPROTO=dhcp BOOTPROTO=none #IPADDR=10.9.11.246 #PREFIX=24 #GATEWAY=10.9.11.1 #IPV4_FAILURE_FATAL=yes #HWADDR=08:00:27:CC:AC:AC ONBOOT=yes NAME="System eth0" [root@localhost www]# cat /etc/sysconfig/network-scripts/ifcfg-eth1 # Advanced Micro Devices, Inc. [AMD] 79c970 [PCnet32 LANCE] DEVICE=eth1 IPADDR=192.168.56.28 <= no eff => auto like DHCP #GATEWAY=192.168.56.1 #BOOTPROTO=dhcp BOOTPROTO=static <= no eff ONBOOT=yes HWADDR=08:00:27:b4:20:10 [root@localhost www]# ...