1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
/**
*
* Ulfius Framework example program
*
* This example program get a stream data from the server
*
* Copyright 2016-2022 Nicolas Mora <mail@babelouest.org>
*
* License MIT
*
*/
#include <stdio.h>
#include <string.h>
#include <ulfius.h>
#include "u_example.h"
#if defined(U_DISABLE_CURL)
#error You must build ulfius with libcurl support enabled to compile this example, check the install documentation
#else
#define URL "http://localhost:7876/stream"
size_t my_write_body(void * contents, size_t size, size_t nmemb, void * user_data) {
(void)(user_data);
printf("got %s", (char *)contents);
return size * nmemb;
}
size_t my_write_meta_body(void * contents, size_t size, size_t nmemb, void * user_data) {
(void)(contents);
(void)(user_data);
printf("got %zu %zu\n", size, nmemb);
return size * nmemb;
}
int main(void) {
struct _u_request request;
struct _u_response response;
int res;
y_init_logs("stream_example client", Y_LOG_MODE_CONSOLE, Y_LOG_LEVEL_DEBUG, NULL, "Starting stream_example");
ulfius_init_response(&response);
ulfius_init_request(&request);
ulfius_set_request_properties(&request,
U_OPT_HTTP_VERB, "GET",
U_OPT_HTTP_URL, URL,
U_OPT_NONE); // Required to close the parameters list
y_log_message(Y_LOG_LEVEL_DEBUG, "Press <enter> to run stream test");
getchar();
res = ulfius_send_http_streaming_request(&request, &response, my_write_body, NULL);
if (res == U_OK) {
y_log_message(Y_LOG_LEVEL_DEBUG, "ulfius_send_http_streaming_request OK");
} else {
y_log_message(Y_LOG_LEVEL_DEBUG, "Error in http request: %d", res);
}
ulfius_clean_response(&response);
y_log_message(Y_LOG_LEVEL_DEBUG, "Press <enter> to run stream audio test");
ulfius_init_response(&response);
ulfius_set_request_properties(&request, U_OPT_HTTP_VERB, "GET", U_OPT_HTTP_URL, URL, U_OPT_HTTP_URL_APPEND, "/audio", U_OPT_NONE);
getchar();
res = ulfius_send_http_streaming_request(&request, &response, my_write_meta_body, NULL);
if (res == U_OK) {
y_log_message(Y_LOG_LEVEL_DEBUG, "ulfius_send_http_streaming_request OK");
} else {
y_log_message(Y_LOG_LEVEL_DEBUG, "Error in http request: %d", res);
}
ulfius_clean_response(&response);
y_log_message(Y_LOG_LEVEL_DEBUG, "Press <enter> to run no stream test");
ulfius_init_response(&response);
ulfius_set_request_properties(&request, U_OPT_HTTP_VERB, "GET", U_OPT_HTTP_URL, "http://www.w3.org/", U_OPT_NONE);
getchar();
res = ulfius_send_http_request(&request, &response);
if (res == U_OK) {
y_log_message(Y_LOG_LEVEL_DEBUG, "ulfius_send_http_request OK");
} else {
y_log_message(Y_LOG_LEVEL_DEBUG, "Error in http request: %d", res);
}
ulfius_clean_response(&response);
ulfius_clean_request(&request);
y_close_logs();
return 0;
}
#endif
|
