jack1 codebase
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

680 lines
21KB

  1. /* -*- mode: c; c-file-style: "linux"; -*- */
  2. /*
  3. NetJack Driver
  4. Copyright (C) 2008 Pieter Palmers <pieterpalmers@users.sourceforge.net>
  5. Copyright (C) 2006 Torben Hohn <torbenh@gmx.de>
  6. Copyright (C) 2003 Robert Ham <rah@bash.sh>
  7. Copyright (C) 2001 Paul Davis
  8. This program is free software; you can redistribute it and/or modify
  9. it under the terms of the GNU General Public License as published by
  10. the Free Software Foundation; either version 2 of the License, or
  11. (at your option) any later version.
  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. You should have received a copy of the GNU General Public License
  17. along with this program; if not, write to the Free Software
  18. Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  19. $Id: net_driver.c,v 1.17 2006/04/16 20:16:10 torbenh Exp $
  20. */
  21. #include <math.h>
  22. #include <stdio.h>
  23. #include <memory.h>
  24. #include <unistd.h>
  25. #include <stdlib.h>
  26. #include <errno.h>
  27. #include <stdarg.h>
  28. #include <sys/mman.h>
  29. #include <jack/types.h>
  30. #include <jack/engine.h>
  31. #include <sysdeps/time.h>
  32. #include <sys/types.h>
  33. #include "config.h"
  34. #include "netjack.h"
  35. #include "netjack_packet.h"
  36. #include "net_driver.h"
  37. #undef DEBUG_WAKEUP
  38. #define MIN(x,y) ((x)<(y) ? (x) : (y))
  39. static jack_transport_state_t last_transport_state;
  40. static int sync_state = TRUE;
  41. static jack_nframes_t
  42. net_driver_wait (net_driver_t *driver, int extra_fd, int *status, float *delayed_usecs)
  43. {
  44. netjack_driver_state_t *netj = &( driver->netj );
  45. int delay;
  46. delay = netjack_wait( netj );
  47. if( delay ) {
  48. //driver->engine->delay( driver->engine, (float)delay );
  49. jack_error( "netxruns amount: %dms", delay/1000 );
  50. }
  51. driver->last_wait_ust = jack_get_microseconds ();
  52. driver->engine->transport_cycle_start (driver->engine, driver->last_wait_ust);
  53. /* this driver doesn't work so well if we report a delay */
  54. /* XXX: this might not be the case anymore */
  55. /* the delayed _usecs is a resync or something. */
  56. *delayed_usecs = 0; /* lie about it */
  57. *status = 0;
  58. return netj->period_size;
  59. }
  60. static int
  61. net_driver_run_cycle (net_driver_t *driver)
  62. {
  63. jack_engine_t *engine = driver->engine;
  64. //netjack_driver_state_t *netj = &(driver->netj);
  65. int wait_status = -1;
  66. float delayed_usecs;
  67. jack_nframes_t nframes = net_driver_wait (driver, -1, &wait_status,
  68. &delayed_usecs);
  69. // XXX: xrun code removed.
  70. // especially with celt there are no real xruns anymore.
  71. // things are different on the net.
  72. if (wait_status == 0)
  73. return engine->run_cycle (engine, nframes, delayed_usecs);
  74. if (wait_status < 0)
  75. return -1;
  76. else
  77. return 0;
  78. }
  79. static int
  80. net_driver_null_cycle (net_driver_t* driver, jack_nframes_t nframes)
  81. {
  82. // TODO: talk to paul about this.
  83. // do i wait here ?
  84. // just sending out a packet marked with junk ?
  85. netjack_driver_state_t *netj = &(driver->netj);
  86. int sync_state = (driver->engine->control->sync_remain <= 1);
  87. netjack_send_silence( netj, sync_state );
  88. return 0;
  89. }
  90. static int
  91. net_driver_bufsize (net_driver_t* driver, jack_nframes_t nframes)
  92. {
  93. netjack_driver_state_t *netj = &(driver->netj);
  94. if (nframes != netj->period_size)
  95. return EINVAL;
  96. return 0;
  97. }
  98. static int
  99. net_driver_read (net_driver_t* driver, jack_nframes_t nframes)
  100. {
  101. netjack_driver_state_t *netj = &(driver->netj);
  102. jack_position_t local_trans_pos;
  103. jack_transport_state_t local_trans_state;
  104. unsigned int *packet_buf, *packet_bufX;
  105. if( ! netj->packet_data_valid ) {
  106. render_payload_to_jack_ports (netj->bitdepth, NULL, netj->net_period_down, netj->capture_ports, netj->capture_srcs, nframes, netj->dont_htonl_floats );
  107. return 0;
  108. }
  109. packet_buf = netj->rx_buf;
  110. jacknet_packet_header *pkthdr = (jacknet_packet_header *)packet_buf;
  111. packet_bufX = packet_buf + sizeof(jacknet_packet_header) / sizeof(jack_default_audio_sample_t);
  112. netj->reply_port = pkthdr->reply_port;
  113. netj->latency = pkthdr->latency;
  114. // Special handling for latency=0
  115. if( netj->latency == 0 )
  116. netj->resync_threshold = 0;
  117. else
  118. netj->resync_threshold = MIN( 15, pkthdr->latency-1 );
  119. // check whether, we should handle the transport sync stuff, or leave trnasports untouched.
  120. if (netj->handle_transport_sync) {
  121. int compensated_tranport_pos = (pkthdr->transport_frame + (pkthdr->latency * nframes) + netj->codec_latency);
  122. // read local transport info....
  123. local_trans_state = jack_transport_query(netj->client, &local_trans_pos);
  124. // Now check if we have to start or stop local transport to sync to remote...
  125. switch (pkthdr->transport_state) {
  126. case JackTransportStarting:
  127. // the master transport is starting... so we set our reply to the sync_callback;
  128. if (local_trans_state == JackTransportStopped) {
  129. jack_transport_start(netj->client);
  130. last_transport_state = JackTransportStopped;
  131. sync_state = FALSE;
  132. jack_info("locally stopped... starting...");
  133. }
  134. if (local_trans_pos.frame != compensated_tranport_pos)
  135. {
  136. jack_transport_locate(netj->client, compensated_tranport_pos);
  137. last_transport_state = JackTransportRolling;
  138. sync_state = FALSE;
  139. jack_info("starting locate to %d", compensated_tranport_pos );
  140. }
  141. break;
  142. case JackTransportStopped:
  143. sync_state = TRUE;
  144. if (local_trans_pos.frame != (pkthdr->transport_frame)) {
  145. jack_transport_locate(netj->client, (pkthdr->transport_frame));
  146. jack_info("transport is stopped locate to %d", pkthdr->transport_frame);
  147. }
  148. if (local_trans_state != JackTransportStopped)
  149. jack_transport_stop(netj->client);
  150. break;
  151. case JackTransportRolling:
  152. sync_state = TRUE;
  153. // if(local_trans_pos.frame != (pkthdr->transport_frame + (pkthdr->latency) * nframes)) {
  154. // jack_transport_locate(netj->client, (pkthdr->transport_frame + (pkthdr->latency + 2) * nframes));
  155. // jack_info("running locate to %d", pkthdr->transport_frame + (pkthdr->latency)*nframes);
  156. // }
  157. if (local_trans_state != JackTransportRolling)
  158. jack_transport_start (netj->client);
  159. break;
  160. case JackTransportLooping:
  161. break;
  162. }
  163. }
  164. render_payload_to_jack_ports (netj->bitdepth, packet_bufX, netj->net_period_down, netj->capture_ports, netj->capture_srcs, nframes, netj->dont_htonl_floats );
  165. packet_cache_release_packet(global_packcache, netj->expected_framecnt );
  166. return 0;
  167. }
  168. static int
  169. net_driver_write (net_driver_t* driver, jack_nframes_t nframes)
  170. {
  171. netjack_driver_state_t *netj = &(driver->netj);
  172. int sync_state = (driver->engine->control->sync_remain <= 1);;
  173. uint32_t *packet_buf, *packet_bufX;
  174. int packet_size = get_sample_size(netj->bitdepth) * netj->playback_channels * netj->net_period_up + sizeof(jacknet_packet_header);
  175. jacknet_packet_header *pkthdr;
  176. packet_buf = alloca(packet_size);
  177. pkthdr = (jacknet_packet_header *)packet_buf;
  178. if( netj->running_free ) {
  179. return 0;
  180. }
  181. // offset packet_bufX by the packetheader.
  182. packet_bufX = packet_buf + sizeof(jacknet_packet_header) / sizeof(jack_default_audio_sample_t);
  183. pkthdr->sync_state = sync_state;
  184. pkthdr->latency = netj->time_to_deadline;
  185. //printf( "time to deadline = %d goodness=%d\n", (int)netj->time_to_deadline, netj->deadline_goodness );
  186. pkthdr->framecnt = netj->expected_framecnt;
  187. render_jack_ports_to_payload(netj->bitdepth, netj->playback_ports, netj->playback_srcs, nframes, packet_bufX, netj->net_period_up, netj->dont_htonl_floats );
  188. packet_header_hton(pkthdr);
  189. if (netj->srcaddress_valid)
  190. {
  191. int r;
  192. #ifndef MSG_CONFIRM
  193. static const int flag = 0;
  194. #else
  195. static const int flag = MSG_CONFIRM;
  196. #endif
  197. if (netj->reply_port)
  198. netj->syncsource_address.sin_port = htons(netj->reply_port);
  199. for( r=0; r<netj->redundancy; r++ )
  200. netjack_sendto(netj->sockfd, (char *)packet_buf, packet_size,
  201. flag, (struct sockaddr*)&(netj->syncsource_address), sizeof(struct sockaddr_in), netj->mtu);
  202. }
  203. return 0;
  204. }
  205. static int
  206. net_driver_attach (net_driver_t *driver)
  207. {
  208. netjack_driver_state_t *netj = &( driver->netj );
  209. driver->engine->set_buffer_size (driver->engine, netj->period_size);
  210. driver->engine->set_sample_rate (driver->engine, netj->sample_rate);
  211. netjack_attach( netj );
  212. return 0;
  213. }
  214. static int
  215. net_driver_detach (net_driver_t *driver)
  216. {
  217. netjack_driver_state_t *netj = &( driver->netj );
  218. if (driver->engine == 0)
  219. return 0;
  220. netjack_detach( netj );
  221. return 0;
  222. }
  223. static void
  224. net_driver_delete (net_driver_t *driver)
  225. {
  226. jack_driver_nt_finish ((jack_driver_nt_t *) driver);
  227. free (driver);
  228. }
  229. static jack_driver_t *
  230. net_driver_new (jack_client_t * client,
  231. char *name,
  232. unsigned int capture_ports,
  233. unsigned int playback_ports,
  234. unsigned int capture_ports_midi,
  235. unsigned int playback_ports_midi,
  236. jack_nframes_t sample_rate,
  237. jack_nframes_t period_size,
  238. unsigned int listen_port,
  239. unsigned int transport_sync,
  240. unsigned int resample_factor,
  241. unsigned int resample_factor_up,
  242. unsigned int bitdepth,
  243. unsigned int use_autoconfig,
  244. unsigned int latency,
  245. unsigned int redundancy,
  246. int dont_htonl_floats,
  247. int always_deadline,
  248. int jitter_val)
  249. {
  250. net_driver_t * driver;
  251. jack_info ("creating net driver ... %s|%" PRIu32 "|%" PRIu32
  252. "|%u|%u|%u|transport_sync:%u", name, sample_rate, period_size, listen_port,
  253. capture_ports, playback_ports, transport_sync);
  254. driver = (net_driver_t *) calloc (1, sizeof (net_driver_t));
  255. jack_driver_nt_init ((jack_driver_nt_t *) driver);
  256. driver->write = (JackDriverWriteFunction) net_driver_write;
  257. driver->read = (JackDriverReadFunction) net_driver_read;
  258. driver->null_cycle = (JackDriverNullCycleFunction) net_driver_null_cycle;
  259. driver->nt_attach = (JackDriverNTAttachFunction) net_driver_attach;
  260. driver->nt_detach = (JackDriverNTDetachFunction) net_driver_detach;
  261. driver->nt_bufsize = (JackDriverNTBufSizeFunction) net_driver_bufsize;
  262. driver->nt_run_cycle = (JackDriverNTRunCycleFunction) net_driver_run_cycle;
  263. driver->last_wait_ust = 0;
  264. driver->engine = NULL;
  265. netjack_driver_state_t *netj = &(driver->netj);
  266. netjack_init ( netj,
  267. client,
  268. name,
  269. capture_ports,
  270. playback_ports,
  271. capture_ports_midi,
  272. playback_ports_midi,
  273. sample_rate,
  274. period_size,
  275. listen_port,
  276. transport_sync,
  277. resample_factor,
  278. resample_factor_up,
  279. bitdepth,
  280. use_autoconfig,
  281. latency,
  282. redundancy,
  283. dont_htonl_floats,
  284. always_deadline,
  285. jitter_val );
  286. netjack_startup( netj );
  287. jack_info ("netjack: period : up: %d / dn: %d", netj->net_period_up, netj->net_period_down);
  288. jack_info ("netjack: framerate: %d", netj->sample_rate);
  289. jack_info ("netjack: audio : cap: %d / pbk: %d)", netj->capture_channels_audio, netj->playback_channels_audio);
  290. jack_info ("netjack: midi : cap: %d / pbk: %d)", netj->capture_channels_midi, netj->playback_channels_midi);
  291. jack_info ("netjack: buffsize : rx: %d)", netj->rx_bufsize);
  292. driver->period_usecs = netj->period_usecs;
  293. return (jack_driver_t *) driver;
  294. }
  295. /* DRIVER "PLUGIN" INTERFACE */
  296. jack_driver_desc_t *
  297. driver_get_descriptor ()
  298. {
  299. jack_driver_desc_t * desc;
  300. jack_driver_param_desc_t * params;
  301. unsigned int i;
  302. desc = calloc (1, sizeof (jack_driver_desc_t));
  303. strcpy (desc->name, "net");
  304. desc->nparams = 18;
  305. params = calloc (desc->nparams, sizeof (jack_driver_param_desc_t));
  306. i = 0;
  307. strcpy (params[i].name, "audio-ins");
  308. params[i].character = 'i';
  309. params[i].type = JackDriverParamUInt;
  310. params[i].value.ui = 2U;
  311. strcpy (params[i].short_desc, "Number of capture channels (defaults to 2)");
  312. strcpy (params[i].long_desc, params[i].short_desc);
  313. i++;
  314. strcpy (params[i].name, "audio-outs");
  315. params[i].character = 'o';
  316. params[i].type = JackDriverParamUInt;
  317. params[i].value.ui = 2U;
  318. strcpy (params[i].short_desc, "Number of playback channels (defaults to 2)");
  319. strcpy (params[i].long_desc, params[i].short_desc);
  320. i++;
  321. strcpy (params[i].name, "midi-ins");
  322. params[i].character = 'I';
  323. params[i].type = JackDriverParamUInt;
  324. params[i].value.ui = 1U;
  325. strcpy (params[i].short_desc, "Number of midi capture channels (defaults to 1)");
  326. strcpy (params[i].long_desc, params[i].short_desc);
  327. i++;
  328. strcpy (params[i].name, "midi-outs");
  329. params[i].character = 'O';
  330. params[i].type = JackDriverParamUInt;
  331. params[i].value.ui = 1U;
  332. strcpy (params[i].short_desc, "Number of midi playback channels (defaults to 1)");
  333. strcpy (params[i].long_desc, params[i].short_desc);
  334. i++;
  335. strcpy (params[i].name, "rate");
  336. params[i].character = 'r';
  337. params[i].type = JackDriverParamUInt;
  338. params[i].value.ui = 48000U;
  339. strcpy (params[i].short_desc, "Sample rate");
  340. strcpy (params[i].long_desc, params[i].short_desc);
  341. i++;
  342. strcpy (params[i].name, "period");
  343. params[i].character = 'p';
  344. params[i].type = JackDriverParamUInt;
  345. params[i].value.ui = 1024U;
  346. strcpy (params[i].short_desc, "Frames per period");
  347. strcpy (params[i].long_desc, params[i].short_desc);
  348. i++;
  349. strcpy (params[i].name, "num-periods");
  350. params[i].character = 'n';
  351. params[i].type = JackDriverParamUInt;
  352. params[i].value.ui = 5U;
  353. strcpy (params[i].short_desc,
  354. "Network latency setting in no. of periods");
  355. strcpy (params[i].long_desc, params[i].short_desc);
  356. i++;
  357. strcpy (params[i].name, "listen-port");
  358. params[i].character = 'l';
  359. params[i].type = JackDriverParamUInt;
  360. params[i].value.ui = 3000U;
  361. strcpy (params[i].short_desc,
  362. "The socket port we are listening on for sync packets");
  363. strcpy (params[i].long_desc, params[i].short_desc);
  364. i++;
  365. strcpy (params[i].name, "factor");
  366. params[i].character = 'f';
  367. params[i].type = JackDriverParamUInt;
  368. params[i].value.ui = 1U;
  369. strcpy (params[i].short_desc,
  370. "Factor for sample rate reduction (deprecated)");
  371. strcpy (params[i].long_desc, params[i].short_desc);
  372. i++;
  373. strcpy (params[i].name, "upstream-factor");
  374. params[i].character = 'u';
  375. params[i].type = JackDriverParamUInt;
  376. params[i].value.ui = 0U;
  377. strcpy (params[i].short_desc,
  378. "Factor for sample rate reduction on the upstream (deprecated)");
  379. strcpy (params[i].long_desc, params[i].short_desc);
  380. i++;
  381. strcpy (params[i].name, "celt");
  382. params[i].character = 'c';
  383. params[i].type = JackDriverParamUInt;
  384. params[i].value.ui = 0U;
  385. strcpy (params[i].short_desc,
  386. "sets celt encoding and number of bytes per period per channel");
  387. strcpy (params[i].long_desc, params[i].short_desc);
  388. i++;
  389. strcpy (params[i].name, "bit-depth");
  390. params[i].character = 'b';
  391. params[i].type = JackDriverParamUInt;
  392. params[i].value.ui = 0U;
  393. strcpy (params[i].short_desc,
  394. "Sample bit-depth (0 for float, 8 for 8bit and 16 for 16bit)");
  395. strcpy (params[i].long_desc, params[i].short_desc);
  396. i++;
  397. strcpy (params[i].name, "transport-sync");
  398. params[i].character = 't';
  399. params[i].type = JackDriverParamUInt;
  400. params[i].value.ui = 1U;
  401. strcpy (params[i].short_desc,
  402. "Whether to slave the transport to the master transport");
  403. strcpy (params[i].long_desc, params[i].short_desc);
  404. i++;
  405. strcpy (params[i].name, "autoconf");
  406. params[i].character = 'a';
  407. params[i].type = JackDriverParamUInt;
  408. params[i].value.ui = 1U;
  409. strcpy (params[i].short_desc,
  410. "Whether to use Autoconfig, or just start.");
  411. strcpy (params[i].long_desc, params[i].short_desc);
  412. i++;
  413. strcpy (params[i].name, "redundancy");
  414. params[i].character = 'R';
  415. params[i].type = JackDriverParamUInt;
  416. params[i].value.ui = 1U;
  417. strcpy (params[i].short_desc,
  418. "Send packets N times");
  419. strcpy (params[i].long_desc, params[i].short_desc);
  420. i++;
  421. strcpy (params[i].name, "native-endian");
  422. params[i].character = 'e';
  423. params[i].type = JackDriverParamUInt;
  424. params[i].value.ui = 0U;
  425. strcpy (params[i].short_desc,
  426. "Don't convert samples to network byte order.");
  427. strcpy (params[i].long_desc, params[i].short_desc);
  428. i++;
  429. strcpy (params[i].name, "jitterval");
  430. params[i].character = 'J';
  431. params[i].type = JackDriverParamInt;
  432. params[i].value.i = 0;
  433. strcpy (params[i].short_desc,
  434. "attempted jitterbuffer microseconds on master");
  435. strcpy (params[i].long_desc, params[i].short_desc);
  436. i++;
  437. strcpy (params[i].name, "always-deadline");
  438. params[i].character = 'D';
  439. params[i].type = JackDriverParamUInt;
  440. params[i].value.ui = 0U;
  441. strcpy (params[i].short_desc,
  442. "Always wait until deadline");
  443. strcpy (params[i].long_desc, params[i].short_desc);
  444. desc->params = params;
  445. return desc;
  446. }
  447. const char driver_client_name[] = "net_pcm";
  448. jack_driver_t *
  449. driver_initialize (jack_client_t *client, const JSList * params)
  450. {
  451. jack_nframes_t sample_rate = 48000;
  452. jack_nframes_t resample_factor = 1;
  453. jack_nframes_t period_size = 1024;
  454. unsigned int capture_ports = 2;
  455. unsigned int playback_ports = 2;
  456. unsigned int capture_ports_midi = 1;
  457. unsigned int playback_ports_midi = 1;
  458. unsigned int listen_port = 3000;
  459. unsigned int resample_factor_up = 0;
  460. unsigned int bitdepth = 0;
  461. unsigned int handle_transport_sync = 1;
  462. unsigned int use_autoconfig = 1;
  463. unsigned int latency = 5;
  464. unsigned int redundancy = 1;
  465. int dont_htonl_floats = 0;
  466. int always_deadline = 0;
  467. int jitter_val = 0;
  468. const JSList * node;
  469. const jack_driver_param_t * param;
  470. for (node = params; node; node = jack_slist_next (node)) {
  471. param = (const jack_driver_param_t *) node->data;
  472. switch (param->character) {
  473. case 'i':
  474. capture_ports = param->value.ui;
  475. break;
  476. case 'o':
  477. playback_ports = param->value.ui;
  478. break;
  479. case 'I':
  480. capture_ports_midi = param->value.ui;
  481. break;
  482. case 'O':
  483. playback_ports_midi = param->value.ui;
  484. break;
  485. case 'r':
  486. sample_rate = param->value.ui;
  487. break;
  488. case 'p':
  489. period_size = param->value.ui;
  490. break;
  491. case 'l':
  492. listen_port = param->value.ui;
  493. break;
  494. case 'f':
  495. #if HAVE_SAMPLERATE
  496. resample_factor = param->value.ui;
  497. #else
  498. printf( "not built with libsamplerate support\n" );
  499. exit(10);
  500. #endif
  501. break;
  502. case 'u':
  503. #if HAVE_SAMPLERATE
  504. resample_factor_up = param->value.ui;
  505. #else
  506. printf( "not built with libsamplerate support\n" );
  507. exit(10);
  508. #endif
  509. break;
  510. case 'b':
  511. bitdepth = param->value.ui;
  512. break;
  513. case 'c':
  514. #if HAVE_CELT
  515. bitdepth = 1000;
  516. resample_factor = param->value.ui;
  517. #else
  518. printf( "not built with celt support\n" );
  519. exit(10);
  520. #endif
  521. break;
  522. case 't':
  523. handle_transport_sync = param->value.ui;
  524. break;
  525. case 'a':
  526. use_autoconfig = param->value.ui;
  527. break;
  528. case 'n':
  529. latency = param->value.ui;
  530. break;
  531. case 'R':
  532. redundancy = param->value.ui;
  533. break;
  534. case 'e':
  535. dont_htonl_floats = param->value.ui;
  536. break;
  537. case 'J':
  538. jitter_val = param->value.ui;
  539. break;
  540. case 'D':
  541. always_deadline = param->value.ui;
  542. break;
  543. }
  544. }
  545. return net_driver_new (client, "net_pcm", capture_ports, playback_ports,
  546. capture_ports_midi, playback_ports_midi,
  547. sample_rate, period_size,
  548. listen_port, handle_transport_sync,
  549. resample_factor, resample_factor_up, bitdepth,
  550. use_autoconfig, latency, redundancy,
  551. dont_htonl_floats, always_deadline, jitter_val);
  552. }
  553. void
  554. driver_finish (jack_driver_t *driver)
  555. {
  556. net_driver_delete ((net_driver_t *) driver);
  557. }