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.

664 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. {
  249. net_driver_t * driver;
  250. jack_info ("creating net driver ... %s|%" PRIu32 "|%" PRIu32
  251. "|%u|%u|%u|transport_sync:%u", name, sample_rate, period_size, listen_port,
  252. capture_ports, playback_ports, transport_sync);
  253. driver = (net_driver_t *) calloc (1, sizeof (net_driver_t));
  254. jack_driver_nt_init ((jack_driver_nt_t *) driver);
  255. driver->write = (JackDriverWriteFunction) net_driver_write;
  256. driver->read = (JackDriverReadFunction) net_driver_read;
  257. driver->null_cycle = (JackDriverNullCycleFunction) net_driver_null_cycle;
  258. driver->nt_attach = (JackDriverNTAttachFunction) net_driver_attach;
  259. driver->nt_detach = (JackDriverNTDetachFunction) net_driver_detach;
  260. driver->nt_bufsize = (JackDriverNTBufSizeFunction) net_driver_bufsize;
  261. driver->nt_run_cycle = (JackDriverNTRunCycleFunction) net_driver_run_cycle;
  262. driver->last_wait_ust = 0;
  263. driver->engine = NULL;
  264. netjack_driver_state_t *netj = &(driver->netj);
  265. netjack_init ( netj,
  266. client,
  267. name,
  268. capture_ports,
  269. playback_ports,
  270. capture_ports_midi,
  271. playback_ports_midi,
  272. sample_rate,
  273. period_size,
  274. listen_port,
  275. transport_sync,
  276. resample_factor,
  277. resample_factor_up,
  278. bitdepth,
  279. use_autoconfig,
  280. latency,
  281. redundancy,
  282. dont_htonl_floats,
  283. always_deadline );
  284. netjack_startup( netj );
  285. jack_info ("netjack: period : up: %d / dn: %d", netj->net_period_up, netj->net_period_down);
  286. jack_info ("netjack: framerate: %d", netj->sample_rate);
  287. jack_info ("netjack: audio : cap: %d / pbk: %d)", netj->capture_channels_audio, netj->playback_channels_audio);
  288. jack_info ("netjack: midi : cap: %d / pbk: %d)", netj->capture_channels_midi, netj->playback_channels_midi);
  289. jack_info ("netjack: buffsize : rx: %d)", netj->rx_bufsize);
  290. return (jack_driver_t *) driver;
  291. }
  292. /* DRIVER "PLUGIN" INTERFACE */
  293. jack_driver_desc_t *
  294. driver_get_descriptor ()
  295. {
  296. jack_driver_desc_t * desc;
  297. jack_driver_param_desc_t * params;
  298. unsigned int i;
  299. desc = calloc (1, sizeof (jack_driver_desc_t));
  300. strcpy (desc->name, "net");
  301. desc->nparams = 17;
  302. params = calloc (desc->nparams, sizeof (jack_driver_param_desc_t));
  303. i = 0;
  304. strcpy (params[i].name, "inchannels");
  305. params[i].character = 'i';
  306. params[i].type = JackDriverParamUInt;
  307. params[i].value.ui = 2U;
  308. strcpy (params[i].short_desc, "Number of capture channels (defaults to 2)");
  309. strcpy (params[i].long_desc, params[i].short_desc);
  310. i++;
  311. strcpy (params[i].name, "outchannels");
  312. params[i].character = 'o';
  313. params[i].type = JackDriverParamUInt;
  314. params[i].value.ui = 2U;
  315. strcpy (params[i].short_desc, "Number of playback channels (defaults to 2)");
  316. strcpy (params[i].long_desc, params[i].short_desc);
  317. i++;
  318. strcpy (params[i].name, "midi inchannels");
  319. params[i].character = 'I';
  320. params[i].type = JackDriverParamUInt;
  321. params[i].value.ui = 1U;
  322. strcpy (params[i].short_desc, "Number of midi capture channels (defaults to 1)");
  323. strcpy (params[i].long_desc, params[i].short_desc);
  324. i++;
  325. strcpy (params[i].name, "midi outchannels");
  326. params[i].character = 'O';
  327. params[i].type = JackDriverParamUInt;
  328. params[i].value.ui = 1U;
  329. strcpy (params[i].short_desc, "Number of midi playback channels (defaults to 1)");
  330. strcpy (params[i].long_desc, params[i].short_desc);
  331. i++;
  332. strcpy (params[i].name, "rate");
  333. params[i].character = 'r';
  334. params[i].type = JackDriverParamUInt;
  335. params[i].value.ui = 48000U;
  336. strcpy (params[i].short_desc, "Sample rate");
  337. strcpy (params[i].long_desc, params[i].short_desc);
  338. i++;
  339. strcpy (params[i].name, "period");
  340. params[i].character = 'p';
  341. params[i].type = JackDriverParamUInt;
  342. params[i].value.ui = 1024U;
  343. strcpy (params[i].short_desc, "Frames per period");
  344. strcpy (params[i].long_desc, params[i].short_desc);
  345. i++;
  346. strcpy (params[i].name, "listen-port");
  347. params[i].character = 'l';
  348. params[i].type = JackDriverParamUInt;
  349. params[i].value.ui = 3000U;
  350. strcpy (params[i].short_desc,
  351. "The socket port we are listening on for sync packets");
  352. strcpy (params[i].long_desc, params[i].short_desc);
  353. i++;
  354. strcpy (params[i].name, "factor");
  355. params[i].character = 'f';
  356. params[i].type = JackDriverParamUInt;
  357. params[i].value.ui = 1U;
  358. strcpy (params[i].short_desc,
  359. "Factor for sample rate reduction");
  360. strcpy (params[i].long_desc, params[i].short_desc);
  361. i++;
  362. strcpy (params[i].name, "upstream-factor");
  363. params[i].character = 'u';
  364. params[i].type = JackDriverParamUInt;
  365. params[i].value.ui = 0U;
  366. strcpy (params[i].short_desc,
  367. "Factor for sample rate reduction on the upstream");
  368. strcpy (params[i].long_desc, params[i].short_desc);
  369. i++;
  370. strcpy (params[i].name, "celt");
  371. params[i].character = 'c';
  372. params[i].type = JackDriverParamUInt;
  373. params[i].value.ui = 0U;
  374. strcpy (params[i].short_desc,
  375. "sets celt encoding and number of bytes per channel");
  376. strcpy (params[i].long_desc, params[i].short_desc);
  377. i++;
  378. strcpy (params[i].name, "bit-depth");
  379. params[i].character = 'b';
  380. params[i].type = JackDriverParamUInt;
  381. params[i].value.ui = 0U;
  382. strcpy (params[i].short_desc,
  383. "Sample bit-depth (0 for float, 8 for 8bit and 16 for 16bit)");
  384. strcpy (params[i].long_desc, params[i].short_desc);
  385. i++;
  386. strcpy (params[i].name, "transport-sync");
  387. params[i].character = 't';
  388. params[i].type = JackDriverParamUInt;
  389. params[i].value.ui = 1U;
  390. strcpy (params[i].short_desc,
  391. "Whether to slave the transport to the master transport");
  392. strcpy (params[i].long_desc, params[i].short_desc);
  393. i++;
  394. strcpy (params[i].name, "autoconf");
  395. params[i].character = 'a';
  396. params[i].type = JackDriverParamUInt;
  397. params[i].value.ui = 1U;
  398. strcpy (params[i].short_desc,
  399. "Whether to use Autoconfig, or just start.");
  400. strcpy (params[i].long_desc, params[i].short_desc);
  401. i++;
  402. strcpy (params[i].name, "latency");
  403. params[i].character = 'L';
  404. params[i].type = JackDriverParamUInt;
  405. params[i].value.ui = 5U;
  406. strcpy (params[i].short_desc,
  407. "Latency setting");
  408. strcpy (params[i].long_desc, params[i].short_desc);
  409. i++;
  410. strcpy (params[i].name, "redundancy");
  411. params[i].character = 'R';
  412. params[i].type = JackDriverParamUInt;
  413. params[i].value.ui = 1U;
  414. strcpy (params[i].short_desc,
  415. "Send packets N times");
  416. strcpy (params[i].long_desc, params[i].short_desc);
  417. i++;
  418. strcpy (params[i].name, "no-htonl");
  419. params[i].character = 'H';
  420. params[i].type = JackDriverParamUInt;
  421. params[i].value.ui = 0U;
  422. strcpy (params[i].short_desc,
  423. "Dont convert samples to network byte order.");
  424. strcpy (params[i].long_desc, params[i].short_desc);
  425. i++;
  426. strcpy (params[i].name, "always-deadline");
  427. params[i].character = 'D';
  428. params[i].type = JackDriverParamUInt;
  429. params[i].value.ui = 0U;
  430. strcpy (params[i].short_desc,
  431. "Always wait until deadline");
  432. strcpy (params[i].long_desc, params[i].short_desc);
  433. desc->params = params;
  434. return desc;
  435. }
  436. const char driver_client_name[] = "net_pcm";
  437. jack_driver_t *
  438. driver_initialize (jack_client_t *client, const JSList * params)
  439. {
  440. jack_nframes_t sample_rate = 48000;
  441. jack_nframes_t resample_factor = 1;
  442. jack_nframes_t period_size = 1024;
  443. unsigned int capture_ports = 2;
  444. unsigned int playback_ports = 2;
  445. unsigned int capture_ports_midi = 1;
  446. unsigned int playback_ports_midi = 1;
  447. unsigned int listen_port = 3000;
  448. unsigned int resample_factor_up = 0;
  449. unsigned int bitdepth = 0;
  450. unsigned int handle_transport_sync = 1;
  451. unsigned int use_autoconfig = 1;
  452. unsigned int latency = 5;
  453. unsigned int redundancy = 1;
  454. int dont_htonl_floats = 0;
  455. int always_deadline = 0;
  456. const JSList * node;
  457. const jack_driver_param_t * param;
  458. for (node = params; node; node = jack_slist_next (node)) {
  459. param = (const jack_driver_param_t *) node->data;
  460. switch (param->character) {
  461. case 'i':
  462. capture_ports = param->value.ui;
  463. break;
  464. case 'o':
  465. playback_ports = param->value.ui;
  466. break;
  467. case 'I':
  468. capture_ports_midi = param->value.ui;
  469. break;
  470. case 'O':
  471. playback_ports_midi = param->value.ui;
  472. break;
  473. case 'r':
  474. sample_rate = param->value.ui;
  475. break;
  476. case 'p':
  477. period_size = param->value.ui;
  478. break;
  479. case 'l':
  480. listen_port = param->value.ui;
  481. break;
  482. case 'f':
  483. #if HAVE_SAMPLERATE
  484. resample_factor = param->value.ui;
  485. #else
  486. printf( "not built with libsamplerate support\n" );
  487. exit(10);
  488. #endif
  489. break;
  490. case 'u':
  491. #if HAVE_SAMPLERATE
  492. resample_factor_up = param->value.ui;
  493. #else
  494. printf( "not built with libsamplerate support\n" );
  495. exit(10);
  496. #endif
  497. break;
  498. case 'b':
  499. bitdepth = param->value.ui;
  500. break;
  501. case 'c':
  502. #if HAVE_CELT
  503. bitdepth = 1000;
  504. resample_factor = param->value.ui;
  505. #else
  506. printf( "not built with celt support\n" );
  507. exit(10);
  508. #endif
  509. break;
  510. case 't':
  511. handle_transport_sync = param->value.ui;
  512. break;
  513. case 'a':
  514. use_autoconfig = param->value.ui;
  515. break;
  516. case 'L':
  517. latency = param->value.ui;
  518. break;
  519. case 'R':
  520. redundancy = param->value.ui;
  521. break;
  522. case 'H':
  523. dont_htonl_floats = param->value.ui;
  524. break;
  525. case 'D':
  526. always_deadline = param->value.ui;
  527. break;
  528. }
  529. }
  530. return net_driver_new (client, "net_pcm", capture_ports, playback_ports,
  531. capture_ports_midi, playback_ports_midi,
  532. sample_rate, period_size,
  533. listen_port, handle_transport_sync,
  534. resample_factor, resample_factor_up, bitdepth,
  535. use_autoconfig, latency, redundancy,
  536. dont_htonl_floats, always_deadline);
  537. }
  538. void
  539. driver_finish (jack_driver_t *driver)
  540. {
  541. net_driver_delete ((net_driver_t *) driver);
  542. }