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.

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