#error "too old libcurl, cannot do HTTP/2 server push!"
#endif
+static FILE *out_download;
+
static void dump(const char *text, unsigned char *ptr, size_t size, char nohex)
{
size_t i;
static int setup(CURL *hnd, const char *url)
{
- FILE *out = fopen(OUTPUTFILE, "wb");
- if(!out)
- /* failed */
- return 1;
-
- /* write to this file */
- curl_easy_setopt(hnd, CURLOPT_WRITEDATA, out);
+ out_download = fopen(OUTPUTFILE, "wb");
+ if(!out_download)
+ return 1; /* failed */
/* set the same URL */
curl_easy_setopt(hnd, CURLOPT_URL, url);
- /* please be verbose */
- curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
- curl_easy_setopt(hnd, CURLOPT_DEBUGFUNCTION, my_trace);
-
/* HTTP/2 please */
curl_easy_setopt(hnd, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2_0);
curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYPEER, 0L);
curl_easy_setopt(hnd, CURLOPT_SSL_VERIFYHOST, 0L);
-#if (CURLPIPE_MULTIPLEX > 0)
+ /* write to this file */
+ curl_easy_setopt(hnd, CURLOPT_WRITEDATA, out_download);
+
+ /* please be verbose */
+ curl_easy_setopt(hnd, CURLOPT_VERBOSE, 1L);
+ curl_easy_setopt(hnd, CURLOPT_DEBUGFUNCTION, my_trace);
+
+#if CURLPIPE_MULTIPLEX > 0
/* wait for pipe connection to confirm */
curl_easy_setopt(hnd, CURLOPT_PIPEWAIT, 1L);
#endif
return 0; /* all is good */
}
+static FILE *out_push;
+
/* called when there is an incoming push */
static int server_push_callback(CURL *parent,
CURL *easy,
size_t i;
int *transfers = (int *)userp;
char filename[128];
- FILE *out;
static unsigned int count = 0;
(void)parent;
snprintf(filename, sizeof(filename), "push%u", count++);
/* here's a new stream, save it in a new file for each new push */
- out = fopen(filename, "wb");
- if(!out) {
+ out_push = fopen(filename, "wb");
+ if(!out_push) {
/* if we cannot save it, deny it */
fprintf(stderr, "Failed to create output file for push\n");
return CURL_PUSH_DENY;
}
/* write to this file */
- curl_easy_setopt(easy, CURLOPT_WRITEDATA, out);
+ curl_easy_setopt(easy, CURLOPT_WRITEDATA, out_push);
fprintf(stderr, "**** push callback approves stream %u, got %lu headers!\n",
count, (unsigned long)num_headers);
}
(*transfers)++; /* one more */
+
return CURL_PUSH_OK;
}
-
/*
* Download a file over HTTP/2, take care of server push.
*/
return 1;
}
- /* add the easy transfer */
- curl_multi_add_handle(multi_handle, easy);
-
curl_multi_setopt(multi_handle, CURLMOPT_PIPELINING, CURLPIPE_MULTIPLEX);
curl_multi_setopt(multi_handle, CURLMOPT_PUSHFUNCTION, server_push_callback);
curl_multi_setopt(multi_handle, CURLMOPT_PUSHDATA, &transfers);
+ /* add the easy transfer */
+ curl_multi_add_handle(multi_handle, easy);
+
do {
struct CURLMsg *m;
int still_running; /* keep number of running handles */
* created and added one or more easy handles but we need to clean them up
* when we are done.
*/
-
do {
int msgq = 0;
m = curl_multi_info_read(multi_handle, &msgq);
curl_multi_cleanup(multi_handle);
curl_global_cleanup();
+ fclose(out_download);
+ if(out_push)
+ fclose(out_push);
+
return 0;
}
static FILE *out_push;
-/* called when there's an incoming push */
+/* called when there is an incoming push */
static int server_push_callback(CURL *parent,
CURL *easy,
size_t num_headers,
int *transfers = (int *)userp;
char filename[128];
static unsigned int count = 0;
- int rv;
(void)parent;
+
curl_msnprintf(filename, sizeof(filename) - 1, "push%u", count++);
/* here's a new stream, save it in a new file for each new push */
if(!out_push) {
/* if we cannot save it, deny it */
curl_mfprintf(stderr, "Failed to create output file for push\n");
- rv = CURL_PUSH_DENY;
- goto out;
+ return CURL_PUSH_DENY;
}
/* write to this file */
}
(*transfers)++; /* one more */
- rv = CURL_PUSH_OK;
-out:
- return rv;
+ return CURL_PUSH_OK;
}
/*
CURL *easy;
CURLM *multi_handle;
int transfers = 1; /* we start with one */
- struct CURLMsg *m;
debug_config.nohex = TRUE;
debug_config.tracetime = FALSE;
}
multi_handle = curl_multi_init();
- curl_multi_setopt(multi_handle, CURLMOPT_PIPELINING, CURLPIPE_MULTIPLEX);
- curl_multi_setopt(multi_handle, CURLMOPT_PUSHFUNCTION, server_push_callback);
- curl_multi_setopt(multi_handle, CURLMOPT_PUSHDATA, &transfers);
easy = curl_easy_init();
if(setup_h2_serverpush(easy, URL)) {
return (CURLcode)1;
}
+ curl_multi_setopt(multi_handle, CURLMOPT_PIPELINING, CURLPIPE_MULTIPLEX);
+ curl_multi_setopt(multi_handle, CURLMOPT_PUSHFUNCTION, server_push_callback);
+ curl_multi_setopt(multi_handle, CURLMOPT_PUSHDATA, &transfers);
+
curl_multi_add_handle(multi_handle, easy);
+
do {
+ struct CURLMsg *m;
int still_running; /* keep number of running handles */
CURLMcode mc = curl_multi_perform(multi_handle, &still_running);