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
|
/**
*
* Ulfius Framework example program
*
* This example program get a stream data from the server
*
* Copyright 2016 Nicolas Mora <mail@babelouest.org>
*
* License MIT
*
*/
#include <stdio.h>
#include <string.h>
#include <ulfius.h>
#include <u_example.h>
#define URL "http://localhost:7876/stream"
size_t my_write_body(void * contents, size_t size, size_t nmemb, 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) {
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);
request.http_verb = o_strdup("GET");
request.http_url = o_strdup(URL);
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);
o_free(request.http_url);
request.http_url = o_strdup(URL "/audio");
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);
o_free(request.http_url);
request.http_url = o_strdup("http://www.w3.org/");
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;
}
|
