external/miraclecast
1
0
Fork 0
mirror of https://github.com/albfan/miraclecast.git synced 2025-03-09 23:38:56 +00:00
Code Issues Releases Wiki Activity

init source side implementation

Browse source
This commit is contained in:
Derek Dai 2016-10-11 13:45:46 +08:00
parent c76667cf71
commit 5c501c0594
No known key found for this signature in database
GPG key ID: E109CC97553EF009
3 changed files with 725 additions and 459 deletions
Download patch file Download diff file Expand all files Collapse all files

960
src/ctl/ctl-src.c
View file

File diff suppressed because it is too large Load diff

118
src/ctl/ctl-src.h
View file

@ -1,4 +1,6 @@
/* /*
* vim: set tabstop=4:softtabstop=4:shiftwidth=4:noexpandtab
*
* MiracleCast - Wifi-Display/Miracast Implementation * MiracleCast - Wifi-Display/Miracast Implementation
* *
* MiracleCast is free software; you can redistribute it and/or modify it * MiracleCast is free software; you can redistribute it and/or modify it
@ -39,60 +41,70 @@
#include "shl_util.h" #include "shl_util.h"
#include "wfd.h" #include "wfd.h"
struct ctl_src { enum audio_format {
sd_event *event; AUDIO_FORMAT_UNKNOWN,
AUDIO_FORMAT_LPCM,
char *local; AUDIO_FORMAT_AAC,
char *session; AUDIO_FORMAT_AC3,
// char *url;
// char *uibc_config;
// char *uibc_setting;
struct sockaddr_storage addr;
size_t addr_size;
int fd;
sd_event_source *fd_source;
struct rtsp *rtsp;
bool connected : 1;
bool hup : 1;
//
// uint32_t resolutions_cea;
// uint32_t resolutions_vesa;
// uint32_t resolutions_hh;
//
// int hres;
// int vres;
}; };
//extern int rstp_port; struct video_formats {
//extern bool uibc; uint8_t native_disp_mode;
//extern int uibc_port; uint8_t pref_disp_mode;
// uint8_t codec_profile;
//struct ctl_sink { uint8_t codec_level;
// sd_event *event; unsigned int resolutions_cea;
// unsigned int resolutions_vesa;
// char *target; unsigned int resolutions_hh;
// char *session; uint8_t latency;
// char *url; unsigned short min_slice_size;
// char *uibc_config; unsigned short slice_enc_params;
// char *uibc_setting; uint8_t frame_rate_control;
// struct sockaddr_storage addr; int hres;
// size_t addr_size; int vres;
// int fd; };
// sd_event_source *fd_source;
// struct audio_codecs {
// struct rtsp *rtsp; enum audio_format format;
// unsigned int modes;
// bool connected : 1; uint8_t latency;
// bool hup : 1; };
//
// uint32_t resolutions_cea; struct client_rtp_ports {
// uint32_t resolutions_vesa; char *profile;
// uint32_t resolutions_hh; unsigned short port0;
// unsigned short port1;
// int hres; };
// int vres;
//}; struct ctl_src {
sd_event *event;
char *local;
char *session;
char url[256];
// char *uibc_config;
// char *uibc_setting;
struct sockaddr_storage addr;
size_t addr_size;
int fd;
sd_event_source *fd_source;
sd_event_source *req_source;
struct rtsp *rtsp;
struct {
struct video_formats video_formats;
struct audio_codecs audio_codecs;
struct client_rtp_ports rtp_ports;
bool has_video_formats : 1;
bool has_audio_codecs : 1;
bool has_rtp_ports : 1;
} sink;
bool connected : 1;
bool hup : 1;
};
#endif /* CTL_SRC_H */ #endif /* CTL_SRC_H */

106
src/ctl/srcctl.c
View file

@ -54,8 +54,6 @@ static struct ctl_link *running_link;
static struct ctl_peer *running_peer; static struct ctl_peer *running_peer;
static struct ctl_peer *pending_peer; static struct ctl_peer *pending_peer;
// //
//void launch_player(struct ctl_sink *s);
//
//char *gst_scale_res; //char *gst_scale_res;
int gst_audio_en = 1; int gst_audio_en = 1;
static const int DEFAULT_RSTP_PORT = 1991; static const int DEFAULT_RSTP_PORT = 1991;
@ -120,9 +118,9 @@ static int cmd_list(char **args, unsigned int n)
cli_printf("%6s %-24s %-30s\n", cli_printf("%6s %-24s %-30s\n",
l->label, l->label,
shl_isempty(l->ifname) ? shl_isempty(l->ifname) ?
"<unknown>" : l->ifname, "<unknown>" : l->ifname,
shl_isempty(l->friendly_name) ? shl_isempty(l->friendly_name) ?
"<unknown>" : l->friendly_name); "<unknown>" : l->friendly_name);
} }
cli_printf("\n"); cli_printf("\n");
@ -143,7 +141,7 @@ static int cmd_list(char **args, unsigned int n)
p->l->label, p->l->label,
p->label, p->label,
shl_isempty(p->friendly_name) ? shl_isempty(p->friendly_name) ?
"<unknown>" : p->friendly_name, "<unknown>" : p->friendly_name,
p->connected ? "yes" : "no"); p->connected ? "yes" : "no");
} }
} }
@ -164,9 +162,9 @@ static int cmd_show(char **args, unsigned int n)
if (n > 0) { if (n > 0) {
if (!(l = ctl_wifi_find_link(wifi, args[0])) && if (!(l = ctl_wifi_find_link(wifi, args[0])) &&
!(p = ctl_wifi_find_peer(wifi, args[0])) && !(p = ctl_wifi_find_peer(wifi, args[0])) &&
!(l = ctl_wifi_search_link(wifi, args[0])) && !(l = ctl_wifi_search_link(wifi, args[0])) &&
!(p = ctl_wifi_search_peer(wifi, args[0]))) { !(p = ctl_wifi_search_peer(wifi, args[0]))) {
cli_error("unknown link or peer %s", args[0]); cli_error("unknown link or peer %s", args[0]);
return 0; return 0;
} }
@ -250,7 +248,7 @@ static int cmd_p2p_scan(char **args, unsigned int n)
struct ctl_link *l = NULL; struct ctl_link *l = NULL;
unsigned int i; unsigned int i;
bool stop = false; bool stop = false;
int r; int r;
for (i = 0; i < n; ++i) { for (i = 0; i < n; ++i) {
if (!strcmp(args[i], "stop")) { if (!strcmp(args[i], "stop")) {
@ -270,13 +268,13 @@ static int cmd_p2p_scan(char **args, unsigned int n)
return 0; return 0;
} }
ctl_link_set_wfd_subelements(l, "00000600101c440032"); ctl_link_set_wfd_subelements(l, "000600101c4400c8");
r = ctl_link_set_p2p_scanning(l, !stop); r = ctl_link_set_p2p_scanning(l, !stop);
if(!r && !running_link) { if(!r && !running_link) {
running_link = l; running_link = l;
} }
return r; return r;
} }
/* /*
@ -363,9 +361,9 @@ static int cmd_quit(char **args, unsigned int n)
*/ */
static void schedule_timeout(sd_event_source **out, static void schedule_timeout(sd_event_source **out,
uint64_t rel_usec, uint64_t rel_usec,
sd_event_time_handler_t timeout_fn, sd_event_time_handler_t timeout_fn,
void *data) void *data)
{ {
int r; int r;
@ -377,12 +375,12 @@ static void schedule_timeout(sd_event_source **out,
cli_vERR(r); cli_vERR(r);
} else { } else {
r = sd_event_add_time(cli_event, r = sd_event_add_time(cli_event,
out, out,
CLOCK_MONOTONIC, CLOCK_MONOTONIC,
rel_usec, rel_usec,
0, 0,
timeout_fn, timeout_fn,
data); data);
if (r < 0) if (r < 0)
cli_vERR(r); cli_vERR(r);
} }
@ -421,14 +419,9 @@ static int src_timeout_fn(sd_event_source *s, uint64_t usec, void *data)
stop_timeout(&src_timeout); stop_timeout(&src_timeout);
cli_printf("src_timeout_fn(): %p, %d, %d\n",
running_peer,
running_peer ? running_peer->connected : 0,
ctl_src_is_closed(src));
if (running_peer && if (running_peer &&
running_peer->connected && running_peer->connected &&
ctl_src_is_closed(src)) { ctl_src_is_closed(src)) {
r = ctl_src_listen(src, running_peer->local_address); r = ctl_src_listen(src, running_peer->local_address);
if (r < 0) { if (r < 0) {
if (src_timeout_time++ >= 3) if (src_timeout_time++ >= 3)
@ -440,7 +433,7 @@ static int src_timeout_fn(sd_event_source *s, uint64_t usec, void *data)
NULL); NULL);
} }
log_info("listening on %s", running_peer->local_address); log_info("listening on %s", running_peer->local_address);
} }
return 0; return 0;
@ -535,23 +528,23 @@ static const struct cli_cmd cli_cmds[] = {
// argv[i++] = resolution; // argv[i++] = resolution;
// } // }
// //
// argv[i] = NULL; // argv[i] = NULL;
// //
// i = 0; // i = 0;
// int size = 0; // int size = 0;
// while (argv[i]) { // while (argv[i]) {
// size += strlen(argv[i++] + 1); // size += strlen(argv[i++] + 1);
// } // }
// //
// char* player_command = malloc(size); // char* player_command = malloc(size);
// i = 0; // i = 0;
// strcpy(player_command, argv[i++]); // strcpy(player_command, argv[i++]);
// while (argv[i]) { // while (argv[i]) {
// strcat(player_command, " "); // strcat(player_command, " ");
// strcat(player_command, argv[i++]); // strcat(player_command, argv[i++]);
// } // }
// log_debug("player command: %s", player_command); // log_debug("player command: %s", player_command);
// //free(player_command); // //free(player_command);
// if (execvpe(argv[0], argv, environ) < 0) { // if (execvpe(argv[0], argv, environ) < 0) {
// cli_debug("stream player failed (%d): %m", errno); // cli_debug("stream player failed (%d): %m", errno);
// int i = 0; // int i = 0;
@ -649,8 +642,8 @@ void ctl_fn_peer_free(struct ctl_peer *p)
} }
// //
void ctl_fn_peer_provision_discovery(struct ctl_peer *p, void ctl_fn_peer_provision_discovery(struct ctl_peer *p,
const char *prov, const char *prov,
const char *pin) const char *pin)
{ {
if (p->l != running_link || shl_isempty(p->wfd_subelements)) if (p->l != running_link || shl_isempty(p->wfd_subelements))
return; return;
@ -661,8 +654,8 @@ void ctl_fn_peer_provision_discovery(struct ctl_peer *p,
} }
void ctl_fn_peer_go_neg_request(struct ctl_peer *p, void ctl_fn_peer_go_neg_request(struct ctl_peer *p,
const char *prov, const char *prov,
const char *pin) const char *pin)
{ {
if (p->l != running_link || shl_isempty(p->wfd_subelements)) if (p->l != running_link || shl_isempty(p->wfd_subelements))
return; return;
@ -720,7 +713,6 @@ void ctl_fn_peer_connected(struct ctl_peer *p)
src_connected = false; src_connected = false;
src_timeout_time = 1; src_timeout_time = 1;
cli_printf("src_timeout_time=%llu\n", src_timeout_time);
schedule_timeout(&src_timeout, schedule_timeout(&src_timeout,
src_timeout_time * 1000ULL * 1000ULL, src_timeout_time * 1000ULL * 1000ULL,
src_timeout_fn, src_timeout_fn,
@ -774,21 +766,21 @@ void cli_fn_help()
{ {
/* /*
* 80-char barrier: * 80-char barrier:
* 01234567890123456789012345678901234567890123456789012345678901234567890123456789 * 01234567890123456789012345678901234567890123456789012345678901234567890123456789
*/ */
printf("%s [OPTIONS...] ...\n\n" printf("%s [OPTIONS...] ...\n\n"
"Control a dedicated local sink via MiracleCast.\n" "Control a dedicated local sink via MiracleCast.\n"
" -h --help Show this help\n" " -h --help Show this help\n"
" --version Show package version\n" " --version Show package version\n"
" --log-level <lvl> Maximum level for log messages\n" " --log-level <lvl> Maximum level for log messages\n"
" --log-journal-level <lvl> Maximum level for journal log messages\n" " --log-journal-level <lvl> Maximum level for journal log messages\n"
" --audio <0/1> Enable audio support (default %d)\n" " --audio <0/1> Enable audio support (default %d)\n"
"\n" "\n"
, program_invocation_short_name, gst_audio_en , program_invocation_short_name, gst_audio_en
); );
/* /*
* 80-char barrier: * 80-char barrier:
* 01234567890123456789012345678901234567890123456789012345678901234567890123456789 * 01234567890123456789012345678901234567890123456789012345678901234567890123456789
*/ */
} }
@ -913,3 +905,5 @@ int main(int argc, char **argv)
return r < 0 ? EXIT_FAILURE : EXIT_SUCCESS; return r < 0 ? EXIT_FAILURE : EXIT_SUCCESS;
} }
/* vim: set tabstop=4 softtabstop=4 shiftwidth=4 noexpandtab : */