moparisthebest/curl
1
0
Fork 0
mirror of https://github.com/moparisthebest/curl synced 2024-12-21 07:38:49 -05:00
Code Issues Releases Wiki Activity

adjusted to use curl_multi_setopt() to set the callback

Browse Source
This commit is contained in:
Daniel Stenberg 2006-01-15 23:17:46 +00:00
parent 0e79a8944b
commit 802b2aaf6a
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
hiper/shiper.c
View File

@ -104,7 +104,8 @@ static struct fdinfo *findsock(curl_socket_t s)
static void remsock(curl_socket_t s) static void remsock(curl_socket_t s)
{ {
struct fdinfo *fdp; struct fdinfo *fdp = allsocks;
while(fdp) { while(fdp) {
if(fdp->sockfd == s) if(fdp->sockfd == s)
break; break;
@ -437,7 +438,7 @@ int main(int argc, char **argv)
curl_easy_setopt(e, CURLOPT_URL, conns[i].url); curl_easy_setopt(e, CURLOPT_URL, conns[i].url);
curl_easy_setopt(e, CURLOPT_WRITEFUNCTION, writecallback); curl_easy_setopt(e, CURLOPT_WRITEFUNCTION, writecallback);
curl_easy_setopt(e, CURLOPT_WRITEDATA, &conns[i]); curl_easy_setopt(e, CURLOPT_WRITEDATA, &conns[i]);
curl_easy_setopt(e, CURLOPT_VERBOSE, 1); curl_easy_setopt(e, CURLOPT_VERBOSE, 0);
curl_easy_setopt(e, CURLOPT_ERRORBUFFER, conns[i].error); curl_easy_setopt(e, CURLOPT_ERRORBUFFER, conns[i].error);
curl_easy_setopt(e, CURLOPT_PRIVATE, &conns[i]); curl_easy_setopt(e, CURLOPT_PRIVATE, &conns[i]);
@ -448,9 +449,11 @@ int main(int argc, char **argv)
} }
} }
curl_multi_setopt(multi_handle, CURLMOPT_SOCKETFUNCTION, socket_callback);
curl_multi_setopt(multi_handle, CURLMOPT_SOCKETDATA, NULL);
/* we start the action by calling *socket() right away */ /* we start the action by calling *socket() right away */
while(CURLM_CALL_MULTI_PERFORM == while(CURLM_CALL_MULTI_PERFORM == curl_multi_socket_all(multi_handle));
curl_multi_socket_all(multi_handle, socket_callback, NULL));
printf("Starting timer, expects to run for %ldus\n", RUN_FOR_THIS_LONG); printf("Starting timer, expects to run for %ldus\n", RUN_FOR_THIS_LONG);
timer_start(); timer_start();
@ -485,8 +488,7 @@ int main(int argc, char **argv)
break; break;
case 0: case 0:
timeouts++; timeouts++;
curl_multi_socket(multi_handle, CURL_SOCKET_TIMEOUT, socket_callback, curl_multi_socket(multi_handle, CURL_SOCKET_TIMEOUT);
NULL);
break; break;
default: default:
@ -510,7 +512,7 @@ int main(int argc, char **argv)
timer_continue(); timer_continue();
if(act & CURL_POLL_OUT) if(act & CURL_POLL_OUT)
act--; act--;
curl_multi_socket(multi_handle, fdp->sockfd, socket_callback, NULL); curl_multi_socket(multi_handle, fdp->sockfd);
timer_pause(); timer_pause();
} }
} }