slimproto.c 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977
  1. /*
  2. * Squeezelite - lightweight headless squeezebox emulator
  3. *
  4. * (c) Adrian Smith 2012-2015, triode1@btinternet.com
  5. * Ralph Irving 2015-2017, ralph_irving@hotmail.com
  6. *
  7. * This program is free software: you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation, either version 3 of the License, or
  10. * (at your option) any later version.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  19. *
  20. * Additions (c) Paul Hermann, 2015-2017 under the same license terms
  21. * -Control of Raspberry pi GPIO for amplifier power
  22. * -Launch script on power status change from LMS
  23. */
  24. #include "squeezelite.h"
  25. #include "slimproto.h"
  26. static log_level loglevel;
  27. #define SQUEEZENETWORK "mysqueezebox.com:3483"
  28. #define PORT 3483
  29. #define MAXBUF 4096
  30. #if SL_LITTLE_ENDIAN
  31. #define LOCAL_PLAYER_IP 0x0100007f // 127.0.0.1
  32. #define LOCAL_PLAYER_PORT 0x9b0d // 3483
  33. #else
  34. #define LOCAL_PLAYER_IP 0x7f000001 // 127.0.0.1
  35. #define LOCAL_PLAYER_PORT 0x0d9b // 3483
  36. #endif
  37. static sockfd sock = -1;
  38. static in_addr_t slimproto_ip = 0;
  39. extern struct buffer *streambuf;
  40. extern struct buffer *outputbuf;
  41. extern struct streamstate stream;
  42. extern struct outputstate output;
  43. extern struct decodestate decode;
  44. extern struct codec *codecs[];
  45. #if IR
  46. extern struct irstate ir;
  47. #endif
  48. event_event wake_e;
  49. #define LOCK_S mutex_lock(streambuf->mutex)
  50. #define UNLOCK_S mutex_unlock(streambuf->mutex)
  51. #define LOCK_O mutex_lock(outputbuf->mutex)
  52. #define UNLOCK_O mutex_unlock(outputbuf->mutex)
  53. #define LOCK_D mutex_lock(decode.mutex)
  54. #define UNLOCK_D mutex_unlock(decode.mutex)
  55. #if IR
  56. #define LOCK_I mutex_lock(ir.mutex)
  57. #define UNLOCK_I mutex_unlock(ir.mutex)
  58. #endif
  59. static struct {
  60. u32_t updated;
  61. u32_t stream_start;
  62. u32_t stream_full;
  63. u32_t stream_size;
  64. u64_t stream_bytes;
  65. u32_t output_full;
  66. u32_t output_size;
  67. u32_t frames_played;
  68. u32_t device_frames;
  69. u32_t current_sample_rate;
  70. u32_t last;
  71. stream_state stream_state;
  72. } status;
  73. int autostart;
  74. bool sentSTMu, sentSTMo, sentSTMl;
  75. u32_t new_server;
  76. char *new_server_cap;
  77. #define PLAYER_NAME_LEN 64
  78. char player_name[PLAYER_NAME_LEN + 1] = "";
  79. const char *name_file = NULL;
  80. void send_packet(u8_t *packet, size_t len) {
  81. u8_t *ptr = packet;
  82. unsigned try = 0;
  83. ssize_t n;
  84. while (len) {
  85. n = send(sock, ptr, len, MSG_NOSIGNAL);
  86. if (n <= 0) {
  87. if (n < 0 && last_error() == ERROR_WOULDBLOCK && try < 10) {
  88. LOG_DEBUG("retrying (%d) writing to socket", ++try);
  89. usleep(1000);
  90. continue;
  91. }
  92. LOG_INFO("failed writing to socket: %s", strerror(last_error()));
  93. return;
  94. }
  95. ptr += n;
  96. len -= n;
  97. }
  98. }
  99. static void sendHELO(bool reconnect, const char *fixed_cap, const char *var_cap, u8_t mac[6]) {
  100. #ifndef BASE_CAP
  101. #define BASE_CAP "Model=squeezelite,AccuratePlayPoints=1,HasDigitalOut=1,HasPolarityInversion=1,Firmware=" VERSION
  102. #endif
  103. #define SSL_CAP "CanHTTPS=1"
  104. const char *base_cap;
  105. struct HELO_packet pkt;
  106. #if USE_SSL
  107. #if !LINKALL && !NO_SSLSYM
  108. if (ssl_loaded) base_cap = SSL_CAP "," BASE_CAP;
  109. else base_cap = BASE_CAP;
  110. #endif
  111. base_cap = SSL_CAP "," BASE_CAP;
  112. #else
  113. base_cap = BASE_CAP;
  114. #endif
  115. memset(&pkt, 0, sizeof(pkt));
  116. memcpy(&pkt.opcode, "HELO", 4);
  117. pkt.length = htonl(sizeof(struct HELO_packet) - 8 + strlen(base_cap) + strlen(fixed_cap) + strlen(var_cap));
  118. pkt.deviceid = 12; // squeezeplay
  119. pkt.revision = 0;
  120. packn(&pkt.wlan_channellist, reconnect ? 0x4000 : 0x0000);
  121. packN(&pkt.bytes_received_H, (u64_t)status.stream_bytes >> 32);
  122. packN(&pkt.bytes_received_L, (u64_t)status.stream_bytes & 0xffffffff);
  123. memcpy(pkt.mac, mac, 6);
  124. LOG_INFO("mac: %02x:%02x:%02x:%02x:%02x:%02x", pkt.mac[0], pkt.mac[1], pkt.mac[2], pkt.mac[3], pkt.mac[4], pkt.mac[5]);
  125. LOG_INFO("cap: %s%s%s", base_cap, fixed_cap, var_cap);
  126. send_packet((u8_t *)&pkt, sizeof(pkt));
  127. send_packet((u8_t *)base_cap, strlen(base_cap));
  128. send_packet((u8_t *)fixed_cap, strlen(fixed_cap));
  129. send_packet((u8_t *)var_cap, strlen(var_cap));
  130. }
  131. static void sendSTAT(const char *event, u32_t server_timestamp) {
  132. struct STAT_packet pkt;
  133. u32_t now = gettime_ms();
  134. u32_t ms_played;
  135. if (status.current_sample_rate && status.frames_played && status.frames_played > status.device_frames) {
  136. ms_played = (u32_t)(((u64_t)(status.frames_played - status.device_frames) * (u64_t)1000) / (u64_t)status.current_sample_rate);
  137. if (now > status.updated) ms_played += (now - status.updated);
  138. LOG_SDEBUG("ms_played: %u (frames_played: %u device_frames: %u)", ms_played, status.frames_played, status.device_frames);
  139. } else if (status.frames_played && now > status.stream_start) {
  140. ms_played = now - status.stream_start;
  141. LOG_SDEBUG("ms_played: %u using elapsed time (frames_played: %u device_frames: %u)", ms_played, status.frames_played, status.device_frames);
  142. } else {
  143. LOG_SDEBUG("ms_played: 0");
  144. ms_played = 0;
  145. }
  146. memset(&pkt, 0, sizeof(struct STAT_packet));
  147. memcpy(&pkt.opcode, "STAT", 4);
  148. pkt.length = htonl(sizeof(struct STAT_packet) - 8);
  149. memcpy(&pkt.event, event, 4);
  150. // num_crlf
  151. // mas_initialized; mas_mode;
  152. packN(&pkt.stream_buffer_fullness, status.stream_full);
  153. packN(&pkt.stream_buffer_size, status.stream_size);
  154. packN(&pkt.bytes_received_H, (u64_t)status.stream_bytes >> 32);
  155. packN(&pkt.bytes_received_L, (u64_t)status.stream_bytes & 0xffffffff);
  156. pkt.signal_strength = 0xffff;
  157. packN(&pkt.jiffies, now);
  158. packN(&pkt.output_buffer_size, status.output_size);
  159. packN(&pkt.output_buffer_fullness, status.output_full);
  160. packN(&pkt.elapsed_seconds, ms_played / 1000);
  161. // voltage;
  162. packN(&pkt.elapsed_milliseconds, ms_played);
  163. pkt.server_timestamp = server_timestamp; // keep this is server format - don't unpack/pack
  164. // error_code;
  165. LOG_DEBUG("STAT: %s", event);
  166. if (loglevel == lSDEBUG) {
  167. LOG_SDEBUG("received bytesL: %u streambuf: %u outputbuf: %u calc elapsed: %u real elapsed: %u (diff: %d) device: %u delay: %d",
  168. (u32_t)status.stream_bytes, status.stream_full, status.output_full, ms_played, now - status.stream_start,
  169. ms_played - now + status.stream_start, status.device_frames * 1000 / status.current_sample_rate, now - status.updated);
  170. }
  171. send_packet((u8_t *)&pkt, sizeof(pkt));
  172. }
  173. static void sendDSCO(disconnect_code disconnect) {
  174. struct DSCO_packet pkt;
  175. memset(&pkt, 0, sizeof(pkt));
  176. memcpy(&pkt.opcode, "DSCO", 4);
  177. pkt.length = htonl(sizeof(pkt) - 8);
  178. pkt.reason = disconnect & 0xFF;
  179. LOG_DEBUG("DSCO: %d", disconnect);
  180. send_packet((u8_t *)&pkt, sizeof(pkt));
  181. }
  182. static void sendRESP(const char *header, size_t len) {
  183. struct RESP_header pkt_header;
  184. memset(&pkt_header, 0, sizeof(pkt_header));
  185. memcpy(&pkt_header.opcode, "RESP", 4);
  186. pkt_header.length = htonl(sizeof(pkt_header) + len - 8);
  187. LOG_DEBUG("RESP");
  188. send_packet((u8_t *)&pkt_header, sizeof(pkt_header));
  189. send_packet((u8_t *)header, len);
  190. }
  191. static void sendMETA(const char *meta, size_t len) {
  192. struct META_header pkt_header;
  193. memset(&pkt_header, 0, sizeof(pkt_header));
  194. memcpy(&pkt_header.opcode, "META", 4);
  195. pkt_header.length = htonl(sizeof(pkt_header) + len - 8);
  196. LOG_DEBUG("META");
  197. send_packet((u8_t *)&pkt_header, sizeof(pkt_header));
  198. send_packet((u8_t *)meta, len);
  199. }
  200. static void sendSETDName(const char *name) {
  201. struct SETD_header pkt_header;
  202. memset(&pkt_header, 0, sizeof(pkt_header));
  203. memcpy(&pkt_header.opcode, "SETD", 4);
  204. pkt_header.id = 0; // id 0 is playername S:P:Squeezebox2
  205. pkt_header.length = htonl(sizeof(pkt_header) + strlen(name) + 1 - 8);
  206. LOG_DEBUG("set playername: %s", name);
  207. send_packet((u8_t *)&pkt_header, sizeof(pkt_header));
  208. send_packet((u8_t *)name, strlen(name) + 1);
  209. }
  210. #if IR
  211. void sendIR(u32_t code, u32_t ts) {
  212. struct IR_packet pkt;
  213. memset(&pkt, 0, sizeof(pkt));
  214. memcpy(&pkt.opcode, "IR ", 4);
  215. pkt.length = htonl(sizeof(pkt) - 8);
  216. packN(&pkt.jiffies, ts);
  217. pkt.ir_code = htonl(code);
  218. LOG_DEBUG("IR: ir code: 0x%x ts: %u", code, ts);
  219. send_packet((u8_t *)&pkt, sizeof(pkt));
  220. }
  221. #endif
  222. static void process_strm(u8_t *pkt, int len) {
  223. struct strm_packet *strm = (struct strm_packet *)pkt;
  224. LOG_DEBUG("strm command %c", strm->command);
  225. switch(strm->command) {
  226. case 't':
  227. sendSTAT("STMt", strm->replay_gain); // STMt replay_gain is no longer used to track latency, but support it
  228. break;
  229. case 'q':
  230. decode_flush();
  231. output_flush();
  232. status.frames_played = 0;
  233. stream_disconnect();
  234. sendSTAT("STMf", 0);
  235. buf_flush(streambuf);
  236. break;
  237. case 'f':
  238. decode_flush();
  239. output_flush();
  240. status.frames_played = 0;
  241. if (stream_disconnect()) {
  242. sendSTAT("STMf", 0);
  243. }
  244. buf_flush(streambuf);
  245. break;
  246. case 'p':
  247. {
  248. unsigned interval = unpackN(&strm->replay_gain);
  249. LOCK_O;
  250. output.pause_frames = interval * status.current_sample_rate / 1000;
  251. if (interval) {
  252. output.state = OUTPUT_PAUSE_FRAMES;
  253. } else {
  254. output.state = OUTPUT_STOPPED;
  255. output.stop_time = gettime_ms();
  256. }
  257. UNLOCK_O;
  258. if (!interval) sendSTAT("STMp", 0);
  259. LOG_DEBUG("pause interval: %u", interval);
  260. }
  261. break;
  262. case 'a':
  263. {
  264. unsigned interval = unpackN(&strm->replay_gain);
  265. LOCK_O;
  266. output.skip_frames = interval * status.current_sample_rate / 1000;
  267. output.state = OUTPUT_SKIP_FRAMES;
  268. UNLOCK_O;
  269. LOG_DEBUG("skip ahead interval: %u", interval);
  270. }
  271. break;
  272. case 'u':
  273. {
  274. unsigned jiffies = unpackN(&strm->replay_gain);
  275. LOCK_O;
  276. output.state = jiffies ? OUTPUT_START_AT : OUTPUT_RUNNING;
  277. output.start_at = jiffies;
  278. UNLOCK_O;
  279. LOG_DEBUG("unpause at: %u now: %u", jiffies, gettime_ms());
  280. sendSTAT("STMr", 0);
  281. }
  282. break;
  283. case 's':
  284. {
  285. unsigned header_len = len - sizeof(struct strm_packet);
  286. char *header = (char *)(pkt + sizeof(struct strm_packet));
  287. in_addr_t ip = (in_addr_t)strm->server_ip; // keep in network byte order
  288. u16_t port = strm->server_port; // keep in network byte order
  289. if (ip == 0) ip = slimproto_ip;
  290. LOG_DEBUG("strm s autostart: %c transition period: %u transition type: %u codec: %c",
  291. strm->autostart, strm->transition_period, strm->transition_type - '0', strm->format);
  292. autostart = strm->autostart - '0';
  293. sendSTAT("STMf", 0);
  294. if (header_len > MAX_HEADER -1) {
  295. LOG_WARN("header too long: %u", header_len);
  296. break;
  297. }
  298. if (strm->format != '?') {
  299. codec_open(strm->format, strm->pcm_sample_size, strm->pcm_sample_rate, strm->pcm_channels, strm->pcm_endianness);
  300. } else if (autostart >= 2) {
  301. // extension to slimproto to allow server to detect codec from response header and send back in codc message
  302. LOG_DEBUG("streaming unknown codec");
  303. } else {
  304. LOG_WARN("unknown codec requires autostart >= 2");
  305. break;
  306. }
  307. if (ip == LOCAL_PLAYER_IP && port == LOCAL_PLAYER_PORT) {
  308. // extension to slimproto for LocalPlayer - header is filename not http header, don't expect cont
  309. stream_file(header, header_len, strm->threshold * 1024);
  310. autostart -= 2;
  311. } else {
  312. stream_sock(ip, port, header, header_len, strm->threshold * 1024, autostart >= 2);
  313. }
  314. sendSTAT("STMc", 0);
  315. sentSTMu = sentSTMo = sentSTMl = false;
  316. LOCK_O;
  317. output.external = false;
  318. _buf_resize(outputbuf, output.init_size);
  319. output.threshold = strm->output_threshold;
  320. output.next_replay_gain = unpackN(&strm->replay_gain);
  321. output.fade_mode = strm->transition_type - '0';
  322. output.fade_secs = strm->transition_period;
  323. output.invert = (strm->flags & 0x03) == 0x03;
  324. LOG_DEBUG("set fade mode: %u", output.fade_mode);
  325. UNLOCK_O;
  326. }
  327. break;
  328. default:
  329. LOG_WARN("unhandled strm %c", strm->command);
  330. break;
  331. }
  332. }
  333. static void process_cont(u8_t *pkt, int len) {
  334. struct cont_packet *cont = (struct cont_packet *)pkt;
  335. cont->metaint = unpackN(&cont->metaint);
  336. LOG_DEBUG("cont metaint: %u loop: %u", cont->metaint, cont->loop);
  337. if (autostart > 1) {
  338. autostart -= 2;
  339. LOCK_S;
  340. if (stream.state == STREAMING_WAIT) {
  341. stream.state = STREAMING_BUFFERING;
  342. stream.meta_interval = stream.meta_next = cont->metaint;
  343. }
  344. UNLOCK_S;
  345. wake_controller();
  346. }
  347. }
  348. static void process_codc(u8_t *pkt, int len) {
  349. struct codc_packet *codc = (struct codc_packet *)pkt;
  350. LOG_DEBUG("codc: %c", codc->format);
  351. codec_open(codc->format, codc->pcm_sample_size, codc->pcm_sample_rate, codc->pcm_channels, codc->pcm_endianness);
  352. }
  353. static void process_aude(u8_t *pkt, int len) {
  354. struct aude_packet *aude = (struct aude_packet *)pkt;
  355. LOG_DEBUG("enable spdif: %d dac: %d", aude->enable_spdif, aude->enable_dac);
  356. LOCK_O;
  357. if (!aude->enable_spdif && output.state != OUTPUT_OFF) {
  358. output.state = OUTPUT_OFF;
  359. }
  360. if (aude->enable_spdif && output.state == OUTPUT_OFF && !output.idle_to) {
  361. output.state = OUTPUT_STOPPED;
  362. output.stop_time = gettime_ms();
  363. }
  364. UNLOCK_O;
  365. }
  366. static void process_audg(u8_t *pkt, int len) {
  367. struct audg_packet *audg = (struct audg_packet *)pkt;
  368. audg->gainL = unpackN(&audg->gainL);
  369. audg->gainR = unpackN(&audg->gainR);
  370. LOG_DEBUG("audg gainL: %u gainR: %u adjust: %u", audg->gainL, audg->gainR, audg->adjust);
  371. set_volume(audg->adjust ? audg->gainL : FIXED_ONE, audg->adjust ? audg->gainR : FIXED_ONE);
  372. }
  373. static void process_setd(u8_t *pkt, int len) {
  374. struct setd_packet *setd = (struct setd_packet *)pkt;
  375. // handle player name query and change
  376. if (setd->id == 0) {
  377. if (len == 5) {
  378. if (strlen(player_name)) {
  379. sendSETDName(player_name);
  380. }
  381. } else if (len > 5) {
  382. strncpy(player_name, setd->data, PLAYER_NAME_LEN);
  383. player_name[PLAYER_NAME_LEN] = '\0';
  384. LOG_INFO("set name: %s", setd->data);
  385. // confirm change to server
  386. sendSETDName(setd->data);
  387. // write name to name_file if -N option set
  388. if (name_file) {
  389. FILE *fp = fopen(name_file, "w");
  390. if (fp) {
  391. LOG_INFO("storing name in %s", name_file);
  392. fputs(player_name, fp);
  393. fclose(fp);
  394. } else {
  395. LOG_WARN("unable to store new name in %s", name_file);
  396. }
  397. }
  398. }
  399. }
  400. }
  401. #define SYNC_CAP ",SyncgroupID="
  402. #define SYNC_CAP_LEN 13
  403. static void process_serv(u8_t *pkt, int len) {
  404. struct serv_packet *serv = (struct serv_packet *)pkt;
  405. unsigned slimproto_port = 0;
  406. char squeezeserver[] = SQUEEZENETWORK;
  407. if(pkt[4] == 0 && pkt[5] == 0 && pkt[6] == 0 && pkt[7] == 1) {
  408. server_addr(squeezeserver, &new_server, &slimproto_port);
  409. } else {
  410. new_server = serv->server_ip;
  411. }
  412. LOG_INFO("switch server");
  413. if (len - sizeof(struct serv_packet) == 10) {
  414. if (!new_server_cap) {
  415. new_server_cap = malloc(SYNC_CAP_LEN + 10 + 1);
  416. }
  417. new_server_cap[0] = '\0';
  418. strcat(new_server_cap, SYNC_CAP);
  419. strncat(new_server_cap, (const char *)(pkt + sizeof(struct serv_packet)), 10);
  420. } else {
  421. if (new_server_cap) {
  422. free(new_server_cap);
  423. new_server_cap = NULL;
  424. }
  425. }
  426. }
  427. struct handler {
  428. char opcode[5];
  429. void (*handler)(u8_t *, int);
  430. };
  431. static struct handler handlers[] = {
  432. { "strm", process_strm },
  433. { "cont", process_cont },
  434. { "codc", process_codc },
  435. { "aude", process_aude },
  436. { "audg", process_audg },
  437. { "setd", process_setd },
  438. { "serv", process_serv },
  439. { "", NULL },
  440. };
  441. static void process(u8_t *pack, int len) {
  442. struct handler *h = handlers;
  443. while (h->handler && strncmp((char *)pack, h->opcode, 4)) { h++; }
  444. if (h->handler) {
  445. LOG_DEBUG("%s", h->opcode);
  446. h->handler(pack, len);
  447. } else {
  448. pack[4] = '\0';
  449. LOG_WARN("unhandled %s", (char *)pack);
  450. }
  451. }
  452. static bool running;
  453. static void slimproto_run() {
  454. static u8_t *buffer = NULL;
  455. int expect = 0;
  456. int got = 0;
  457. u32_t now;
  458. static u32_t last = 0;
  459. event_handle ehandles[2];
  460. int timeouts = 0;
  461. // just to avoid having to free that up at multiple places
  462. if (!buffer) buffer = malloc(MAXBUF);
  463. set_readwake_handles(ehandles, sock, wake_e);
  464. while (running && !new_server) {
  465. bool wake = false;
  466. event_type ev;
  467. if ((ev = wait_readwake(ehandles, 1000)) != EVENT_TIMEOUT) {
  468. if (ev == EVENT_READ) {
  469. if (expect > 0) {
  470. int n = recv(sock, buffer + got, expect, 0);
  471. if (n <= 0) {
  472. if (n < 0 && last_error() == ERROR_WOULDBLOCK) {
  473. continue;
  474. }
  475. LOG_INFO("error reading from socket: %s", n ? strerror(last_error()) : "closed");
  476. return;
  477. }
  478. expect -= n;
  479. got += n;
  480. if (expect == 0) {
  481. process(buffer, got);
  482. got = 0;
  483. }
  484. } else if (expect == 0) {
  485. int n = recv(sock, buffer + got, 2 - got, 0);
  486. if (n <= 0) {
  487. if (n < 0 && last_error() == ERROR_WOULDBLOCK) {
  488. continue;
  489. }
  490. LOG_INFO("error reading from socket: %s", n ? strerror(last_error()) : "closed");
  491. return;
  492. }
  493. got += n;
  494. if (got == 2) {
  495. expect = buffer[0] << 8 | buffer[1]; // length pack 'n'
  496. got = 0;
  497. if (expect > MAXBUF) {
  498. LOG_ERROR("FATAL: slimproto packet too big: %d > %d", expect, MAXBUF);
  499. return;
  500. }
  501. }
  502. } else {
  503. LOG_ERROR("FATAL: negative expect");
  504. return;
  505. }
  506. }
  507. if (ev == EVENT_WAKE) {
  508. wake = true;
  509. }
  510. timeouts = 0;
  511. } else if (++timeouts > 35) {
  512. // expect message from server every 5 seconds, but 30 seconds on mysb.com so timeout after 35 seconds
  513. LOG_INFO("No messages from server - connection dead");
  514. return;
  515. }
  516. // update playback state when woken or every 100ms
  517. now = gettime_ms();
  518. if (wake || now - last > 100 || last > now) {
  519. bool _sendSTMs = false;
  520. bool _sendDSCO = false;
  521. bool _sendRESP = false;
  522. bool _sendMETA = false;
  523. bool _sendSTMd = false;
  524. bool _sendSTMt = false;
  525. bool _sendSTMl = false;
  526. bool _sendSTMu = false;
  527. bool _sendSTMo = false;
  528. bool _sendSTMn = false;
  529. bool _stream_disconnect = false;
  530. bool _start_output = false;
  531. decode_state _decode_state;
  532. disconnect_code disconnect_code;
  533. static char *header = NULL;
  534. size_t header_len = 0;
  535. #if IR
  536. bool _sendIR = false;
  537. u32_t ir_code, ir_ts;
  538. #endif
  539. // just to avoid allocating it at every pass
  540. if (!header) header = malloc(MAX_HEADER);
  541. last = now;
  542. LOCK_S;
  543. status.stream_full = _buf_used(streambuf);
  544. status.stream_size = streambuf->size;
  545. status.stream_bytes = stream.bytes;
  546. status.stream_state = stream.state;
  547. if (stream.state == DISCONNECT) {
  548. disconnect_code = stream.disconnect;
  549. stream.state = STOPPED;
  550. _sendDSCO = true;
  551. }
  552. if (!stream.sent_headers &&
  553. (stream.state == STREAMING_HTTP || stream.state == STREAMING_WAIT || stream.state == STREAMING_BUFFERING)) {
  554. header_len = stream.header_len;
  555. memcpy(header, stream.header, header_len);
  556. _sendRESP = true;
  557. stream.sent_headers = true;
  558. }
  559. if (stream.meta_send) {
  560. header_len = stream.header_len;
  561. memcpy(header, stream.header, header_len);
  562. _sendMETA = true;
  563. stream.meta_send = false;
  564. }
  565. UNLOCK_S;
  566. LOCK_D;
  567. if ((status.stream_state == STREAMING_HTTP || status.stream_state == STREAMING_FILE ||
  568. (status.stream_state == DISCONNECT && stream.disconnect == DISCONNECT_OK)) &&
  569. !sentSTMl && decode.state == DECODE_READY) {
  570. if (autostart == 0) {
  571. decode.state = DECODE_RUNNING;
  572. _sendSTMl = true;
  573. sentSTMl = true;
  574. } else if (autostart == 1) {
  575. decode.state = DECODE_RUNNING;
  576. _start_output = true;
  577. }
  578. // autostart 2 and 3 require cont to be received first
  579. }
  580. if (decode.state == DECODE_COMPLETE || decode.state == DECODE_ERROR) {
  581. if (decode.state == DECODE_COMPLETE) _sendSTMd = true;
  582. if (decode.state == DECODE_ERROR) _sendSTMn = true;
  583. decode.state = DECODE_STOPPED;
  584. if (status.stream_state == STREAMING_HTTP || status.stream_state == STREAMING_FILE) {
  585. _stream_disconnect = true;
  586. }
  587. }
  588. _decode_state = decode.state;
  589. UNLOCK_D;
  590. LOCK_O;
  591. status.output_full = _buf_used(outputbuf);
  592. status.output_size = outputbuf->size;
  593. status.frames_played = output.frames_played_dmp;
  594. status.current_sample_rate = output.current_sample_rate;
  595. status.updated = output.updated;
  596. status.device_frames = output.device_frames;
  597. if (output.track_started) {
  598. _sendSTMs = true;
  599. output.track_started = false;
  600. status.stream_start = output.track_start_time;
  601. }
  602. #if PORTAUDIO
  603. if (output.pa_reopen) {
  604. _pa_open();
  605. output.pa_reopen = false;
  606. }
  607. #endif
  608. if (_start_output && (output.state == OUTPUT_STOPPED || output.state == OUTPUT_OFF)) {
  609. output.state = OUTPUT_BUFFER;
  610. }
  611. if (!output.external && output.state == OUTPUT_RUNNING && !sentSTMu && status.output_full == 0 && status.stream_state <= DISCONNECT &&
  612. _decode_state == DECODE_STOPPED) {
  613. _sendSTMu = true;
  614. sentSTMu = true;
  615. LOG_DEBUG("output underrun");
  616. output.state = OUTPUT_STOPPED;
  617. output.stop_time = now;
  618. }
  619. if (output.state == OUTPUT_RUNNING && !sentSTMo && status.output_full == 0 && status.stream_state == STREAMING_HTTP) {
  620. _sendSTMo = true;
  621. sentSTMo = true;
  622. }
  623. if (output.state == OUTPUT_STOPPED && output.idle_to && (now - output.stop_time > output.idle_to)) {
  624. output.state = OUTPUT_OFF;
  625. LOG_DEBUG("output timeout");
  626. }
  627. if (!output.external && output.state == OUTPUT_RUNNING && now - status.last > 1000) {
  628. _sendSTMt = true;
  629. status.last = now;
  630. }
  631. UNLOCK_O;
  632. #if IR
  633. LOCK_I;
  634. if (ir.code) {
  635. _sendIR = true;
  636. ir_code = ir.code;
  637. ir_ts = ir.ts;
  638. ir.code = 0;
  639. }
  640. UNLOCK_I;
  641. #endif
  642. if (_stream_disconnect) stream_disconnect();
  643. // send packets once locks released as packet sending can block
  644. if (_sendDSCO) sendDSCO(disconnect_code);
  645. if (_sendSTMs) sendSTAT("STMs", 0);
  646. if (_sendSTMd) sendSTAT("STMd", 0);
  647. if (_sendSTMt) sendSTAT("STMt", 0);
  648. if (_sendSTMl) sendSTAT("STMl", 0);
  649. if (_sendSTMu) sendSTAT("STMu", 0);
  650. if (_sendSTMo) sendSTAT("STMo", 0);
  651. if (_sendSTMn) sendSTAT("STMn", 0);
  652. if (_sendRESP) sendRESP(header, header_len);
  653. if (_sendMETA) sendMETA(header, header_len);
  654. #if IR
  655. if (_sendIR) sendIR(ir_code, ir_ts);
  656. #endif
  657. }
  658. }
  659. }
  660. // called from other threads to wake state machine above
  661. void wake_controller(void) {
  662. wake_signal(wake_e);
  663. }
  664. in_addr_t discover_server(char *default_server) {
  665. struct sockaddr_in d;
  666. struct sockaddr_in s;
  667. char *buf;
  668. struct pollfd pollinfo;
  669. unsigned port;
  670. int disc_sock = socket(AF_INET, SOCK_DGRAM, 0);
  671. socklen_t enable = 1;
  672. setsockopt(disc_sock, SOL_SOCKET, SO_BROADCAST, (const void *)&enable, sizeof(enable));
  673. buf = "e";
  674. memset(&d, 0, sizeof(d));
  675. d.sin_family = AF_INET;
  676. d.sin_port = htons(PORT);
  677. d.sin_addr.s_addr = htonl(INADDR_BROADCAST);
  678. pollinfo.fd = disc_sock;
  679. pollinfo.events = POLLIN;
  680. do {
  681. LOG_INFO("sending discovery");
  682. memset(&s, 0, sizeof(s));
  683. if (sendto(disc_sock, buf, 1, 0, (struct sockaddr *)&d, sizeof(d)) < 0) {
  684. LOG_INFO("error sending disovery");
  685. }
  686. if (poll(&pollinfo, 1, 5000) == 1) {
  687. char readbuf[10];
  688. socklen_t slen = sizeof(s);
  689. recvfrom(disc_sock, readbuf, 10, 0, (struct sockaddr *)&s, &slen);
  690. LOG_INFO("got response from: %s:%d", inet_ntoa(s.sin_addr), ntohs(s.sin_port));
  691. }
  692. if (default_server) {
  693. server_addr(default_server, &s.sin_addr.s_addr, &port);
  694. }
  695. } while (s.sin_addr.s_addr == 0 && running);
  696. closesocket(disc_sock);
  697. return s.sin_addr.s_addr;
  698. }
  699. #define FIXED_CAP_LEN 256
  700. #define VAR_CAP_LEN 128
  701. void slimproto(log_level level, char *server, u8_t mac[6], const char *name, const char *namefile, const char *modelname, int maxSampleRate) {
  702. struct sockaddr_in serv_addr;
  703. static char fixed_cap[FIXED_CAP_LEN], var_cap[VAR_CAP_LEN] = "";
  704. bool reconnect = false;
  705. unsigned failed_connect = 0;
  706. unsigned slimproto_port = 0;
  707. in_addr_t previous_server = 0;
  708. int i;
  709. memset(&status, 0, sizeof(status));
  710. wake_create(wake_e);
  711. loglevel = level;
  712. running = true;
  713. if (server) {
  714. server_addr(server, &slimproto_ip, &slimproto_port);
  715. }
  716. if (!slimproto_ip) {
  717. slimproto_ip = discover_server(server);
  718. }
  719. if (!slimproto_port) {
  720. slimproto_port = PORT;
  721. }
  722. if (name) {
  723. strncpy(player_name, name, PLAYER_NAME_LEN);
  724. player_name[PLAYER_NAME_LEN] = '\0';
  725. }
  726. if (namefile) {
  727. FILE *fp;
  728. name_file = namefile;
  729. fp = fopen(namefile, "r");
  730. if (fp) {
  731. if (!fgets(player_name, PLAYER_NAME_LEN, fp)) {
  732. player_name[PLAYER_NAME_LEN] = '\0';
  733. } else {
  734. // strip any \n from fgets response
  735. int len = strlen(player_name);
  736. if (len > 0 && player_name[len - 1] == '\n') {
  737. player_name[len - 1] = '\0';
  738. }
  739. LOG_INFO("retrieved name %s from %s", player_name, name_file);
  740. }
  741. fclose(fp);
  742. }
  743. }
  744. if (!running) return;
  745. LOCK_O;
  746. snprintf(fixed_cap, FIXED_CAP_LEN, ",ModelName=%s,MaxSampleRate=%u", modelname ? modelname : MODEL_NAME_STRING,
  747. ((maxSampleRate > 0) ? maxSampleRate : output.supported_rates[0]));
  748. for (i = 0; i < MAX_CODECS; i++) {
  749. if (codecs[i] && codecs[i]->id && strlen(fixed_cap) < FIXED_CAP_LEN - 10) {
  750. strcat(fixed_cap, ",");
  751. strcat(fixed_cap, codecs[i]->types);
  752. }
  753. }
  754. UNLOCK_O;
  755. memset(&serv_addr, 0, sizeof(serv_addr));
  756. serv_addr.sin_family = AF_INET;
  757. serv_addr.sin_addr.s_addr = slimproto_ip;
  758. serv_addr.sin_port = htons(slimproto_port);
  759. LOG_INFO("connecting to %s:%d", inet_ntoa(serv_addr.sin_addr), ntohs(serv_addr.sin_port));
  760. new_server = 0;
  761. while (running) {
  762. if (new_server) {
  763. previous_server = slimproto_ip;
  764. slimproto_ip = serv_addr.sin_addr.s_addr = new_server;
  765. LOG_INFO("switching server to %s:%d", inet_ntoa(serv_addr.sin_addr), ntohs(serv_addr.sin_port));
  766. new_server = 0;
  767. reconnect = false;
  768. }
  769. sock = socket(AF_INET, SOCK_STREAM, 0);
  770. set_nonblock(sock);
  771. set_nosigpipe(sock);
  772. if (connect_timeout(sock, (struct sockaddr *) &serv_addr, sizeof(serv_addr), 5) != 0) {
  773. if (previous_server) {
  774. slimproto_ip = serv_addr.sin_addr.s_addr = previous_server;
  775. LOG_INFO("new server not reachable, reverting to previous server %s:%d", inet_ntoa(serv_addr.sin_addr), ntohs(serv_addr.sin_port));
  776. } else {
  777. LOG_INFO("unable to connect to server %u", failed_connect);
  778. sleep(5);
  779. }
  780. // rediscover server if it was not set at startup
  781. if (!server && ++failed_connect > 5) {
  782. slimproto_ip = serv_addr.sin_addr.s_addr = discover_server(NULL);
  783. }
  784. } else {
  785. struct sockaddr_in our_addr;
  786. socklen_t len;
  787. LOG_INFO("connected");
  788. var_cap[0] = '\0';
  789. failed_connect = 0;
  790. // check if this is a local player now we are connected & signal to server via 'loc' format
  791. // this requires LocalPlayer server plugin to enable direct file access
  792. len = sizeof(our_addr);
  793. getsockname(sock, (struct sockaddr *) &our_addr, &len);
  794. if (our_addr.sin_addr.s_addr == serv_addr.sin_addr.s_addr) {
  795. LOG_INFO("local player");
  796. strcat(var_cap, ",loc");
  797. }
  798. // add on any capablity to be sent to the new server
  799. if (new_server_cap) {
  800. strcat(var_cap, new_server_cap);
  801. free(new_server_cap);
  802. new_server_cap = NULL;
  803. }
  804. sendHELO(reconnect, fixed_cap, var_cap, mac);
  805. slimproto_run();
  806. if (!reconnect) {
  807. reconnect = true;
  808. }
  809. usleep(100000);
  810. }
  811. previous_server = 0;
  812. closesocket(sock);
  813. }
  814. }
  815. void slimproto_stop(void) {
  816. LOG_INFO("slimproto stop");
  817. running = false;
  818. }