jack2 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.

1695 lines
45KB

  1. /*
  2. Copyright (C) 2001 Paul Davis
  3. Copyright (C) 2004-2008 Grame
  4. This program is free software; you can redistribute it and/or modify
  5. it under the terms of the GNU Lesser General Public License as published by
  6. the Free Software Foundation; either version 2.1 of the License, or
  7. (at your option) any later version.
  8. This program is distributed in the hope that it will be useful,
  9. but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11. GNU Lesser General Public License for more details.
  12. You should have received a copy of the GNU Lesser General Public License
  13. along with this program; if not, write to the Free Software
  14. Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  15. */
  16. #ifndef __JackRequest__
  17. #define __JackRequest__
  18. #include "JackConstants.h"
  19. #include "JackError.h"
  20. #include "JackPlatformPlug.h"
  21. #include "JackChannel.h"
  22. #include "JackTime.h"
  23. #include "types.h"
  24. #include <string.h>
  25. #include <stdio.h>
  26. #include <stdlib.h>
  27. #include <list>
  28. namespace Jack
  29. {
  30. #define CheckRes(exp) { if ((exp) < 0) { jack_error("CheckRes error"); return -1; } }
  31. #define CheckSize() { CheckRes(trans->Read(&fSize, sizeof(int))); if (fSize != Size()) { jack_error("CheckSize error size = %d Size() = %d", fSize, Size()); return -1; } }
  32. /*!
  33. \brief Session API constants.
  34. */
  35. enum JackSessionReply {
  36. kImmediateSessionReply = 1,
  37. kPendingSessionReply = 2
  38. };
  39. /*!
  40. \brief Request from client to server.
  41. */
  42. struct JackRequest
  43. {
  44. enum RequestType {
  45. kRegisterPort = 1,
  46. kUnRegisterPort = 2,
  47. kConnectPorts = 3,
  48. kDisconnectPorts = 4,
  49. kSetTimeBaseClient = 5,
  50. kActivateClient = 6,
  51. kDeactivateClient = 7,
  52. kDisconnectPort = 8,
  53. kSetClientCapabilities = 9,
  54. kGetPortConnections = 10,
  55. kGetPortNConnections = 11,
  56. kReleaseTimebase = 12,
  57. kSetTimebaseCallback = 13,
  58. kSetBufferSize = 20,
  59. kSetFreeWheel = 21,
  60. kClientCheck = 22,
  61. kClientOpen = 23,
  62. kClientClose = 24,
  63. kConnectNamePorts = 25,
  64. kDisconnectNamePorts = 26,
  65. kGetInternalClientName = 27,
  66. kInternalClientHandle = 28,
  67. kInternalClientLoad = 29,
  68. kInternalClientUnload = 30,
  69. kPortRename = 31,
  70. kNotification = 32,
  71. kSessionNotify = 33,
  72. kSessionReply = 34,
  73. kGetClientByUUID = 35,
  74. kReserveClientName = 36,
  75. kGetUUIDByClient = 37,
  76. kClientHasSessionCallback = 38,
  77. kComputeTotalLatencies = 39
  78. };
  79. RequestType fType;
  80. int fSize;
  81. JackRequest(): fType((RequestType)0), fSize(0)
  82. {}
  83. JackRequest(RequestType type): fType(type), fSize(0)
  84. {}
  85. virtual ~JackRequest()
  86. {}
  87. virtual int Read(detail::JackChannelTransactionInterface* trans)
  88. {
  89. return trans->Read(&fType, sizeof(RequestType));
  90. }
  91. virtual int Write(detail::JackChannelTransactionInterface* trans) { return -1; }
  92. virtual int Write(detail::JackChannelTransactionInterface* trans, int size)
  93. {
  94. fSize = size;
  95. CheckRes(trans->Write(&fType, sizeof(RequestType)));
  96. return trans->Write(&fSize, sizeof(int));
  97. }
  98. virtual int Size() { return 0; }
  99. };
  100. /*!
  101. \brief Result from the server.
  102. */
  103. struct JackResult
  104. {
  105. int fResult;
  106. JackResult(): fResult( -1)
  107. {}
  108. JackResult(int result): fResult(result)
  109. {}
  110. virtual ~JackResult()
  111. {}
  112. virtual int Read(detail::JackChannelTransactionInterface* trans)
  113. {
  114. return trans->Read(&fResult, sizeof(int));
  115. }
  116. virtual int Write(detail::JackChannelTransactionInterface* trans)
  117. {
  118. return trans->Write(&fResult, sizeof(int));
  119. }
  120. };
  121. /*!
  122. \brief CheckClient request.
  123. */
  124. struct JackClientCheckRequest : public JackRequest
  125. {
  126. char fName[JACK_CLIENT_NAME_SIZE+1];
  127. int fProtocol;
  128. int fOptions;
  129. int fUUID;
  130. int fOpen;
  131. JackClientCheckRequest() : fProtocol(0), fOptions(0), fUUID(0), fOpen(0)
  132. {
  133. memset(fName, 0, sizeof(fName));
  134. }
  135. JackClientCheckRequest(const char* name, int protocol, int options, int uuid, int open = false)
  136. : JackRequest(JackRequest::kClientCheck), fProtocol(protocol), fOptions(options), fUUID(uuid), fOpen(open)
  137. {
  138. memset(fName, 0, sizeof(fName));
  139. snprintf(fName, sizeof(fName), "%s", name);
  140. }
  141. int Read(detail::JackChannelTransactionInterface* trans)
  142. {
  143. CheckSize();
  144. CheckRes(trans->Read(&fName, sizeof(fName)));
  145. CheckRes(trans->Read(&fProtocol, sizeof(int)));
  146. CheckRes(trans->Read(&fOptions, sizeof(int)));
  147. CheckRes(trans->Read(&fUUID, sizeof(int)));
  148. return trans->Read(&fOpen, sizeof(int));
  149. }
  150. int Write(detail::JackChannelTransactionInterface* trans)
  151. {
  152. CheckRes(JackRequest::Write(trans, Size()));
  153. CheckRes(trans->Write(&fName, sizeof(fName)));
  154. CheckRes(trans->Write(&fProtocol, sizeof(int)));
  155. CheckRes(trans->Write(&fOptions, sizeof(int)));
  156. CheckRes(trans->Write(&fUUID, sizeof(int)));
  157. return trans->Write(&fOpen, sizeof(int));
  158. }
  159. int Size() { return sizeof(fName) + 4 * sizeof(int); }
  160. };
  161. /*!
  162. \brief CheckClient result.
  163. */
  164. struct JackClientCheckResult : public JackResult
  165. {
  166. char fName[JACK_CLIENT_NAME_SIZE+1];
  167. int fStatus;
  168. JackClientCheckResult(): JackResult(), fStatus(0)
  169. {
  170. memset(fName, 0, sizeof(fName));
  171. }
  172. JackClientCheckResult(int32_t result, const char* name, int status)
  173. : JackResult(result), fStatus(status)
  174. {
  175. memset(fName, 0, sizeof(fName));
  176. snprintf(fName, sizeof(fName), "%s", name);
  177. }
  178. int Read(detail::JackChannelTransactionInterface* trans)
  179. {
  180. CheckRes(JackResult::Read(trans));
  181. CheckRes(trans->Read(&fName, sizeof(fName)));
  182. CheckRes(trans->Read(&fStatus, sizeof(int)));
  183. return 0;
  184. }
  185. int Write(detail::JackChannelTransactionInterface* trans)
  186. {
  187. CheckRes(JackResult::Write(trans));
  188. CheckRes(trans->Write(&fName, sizeof(fName)));
  189. CheckRes(trans->Write(&fStatus, sizeof(int)));
  190. return 0;
  191. }
  192. };
  193. /*!
  194. \brief NewClient request.
  195. */
  196. struct JackClientOpenRequest : public JackRequest
  197. {
  198. int fPID;
  199. int fUUID;
  200. char fName[JACK_CLIENT_NAME_SIZE+1];
  201. JackClientOpenRequest() : fPID(0), fUUID(0)
  202. {
  203. memset(fName, 0, sizeof(fName));
  204. }
  205. JackClientOpenRequest(const char* name, int pid, int uuid): JackRequest(JackRequest::kClientOpen)
  206. {
  207. memset(fName, 0, sizeof(fName));
  208. snprintf(fName, sizeof(fName), "%s", name);
  209. fPID = pid;
  210. fUUID = uuid;
  211. }
  212. int Read(detail::JackChannelTransactionInterface* trans)
  213. {
  214. CheckSize();
  215. CheckRes(trans->Read(&fPID, sizeof(int)));
  216. CheckRes(trans->Read(&fUUID, sizeof(int)));
  217. return trans->Read(&fName, sizeof(fName));
  218. }
  219. int Write(detail::JackChannelTransactionInterface* trans)
  220. {
  221. CheckRes(JackRequest::Write(trans, Size()));
  222. CheckRes(trans->Write(&fPID, sizeof(int)));
  223. CheckRes(trans->Write(&fUUID, sizeof(int)));
  224. return trans->Write(&fName, sizeof(fName));
  225. }
  226. int Size() { return 2 * sizeof(int) + sizeof(fName); }
  227. };
  228. /*!
  229. \brief NewClient result.
  230. */
  231. struct JackClientOpenResult : public JackResult
  232. {
  233. int fSharedEngine;
  234. int fSharedClient;
  235. int fSharedGraph;
  236. JackClientOpenResult()
  237. : JackResult(), fSharedEngine(-1), fSharedClient(-1), fSharedGraph(-1)
  238. {}
  239. JackClientOpenResult(int32_t result, int index1, int index2, int index3)
  240. : JackResult(result), fSharedEngine(index1), fSharedClient(index2), fSharedGraph(index3)
  241. {}
  242. int Read(detail::JackChannelTransactionInterface* trans)
  243. {
  244. CheckRes(JackResult::Read(trans));
  245. CheckRes(trans->Read(&fSharedEngine, sizeof(int)));
  246. CheckRes(trans->Read(&fSharedClient, sizeof(int)));
  247. CheckRes(trans->Read(&fSharedGraph, sizeof(int)));
  248. return 0;
  249. }
  250. int Write(detail::JackChannelTransactionInterface* trans)
  251. {
  252. CheckRes(JackResult::Write(trans));
  253. CheckRes(trans->Write(&fSharedEngine, sizeof(int)));
  254. CheckRes(trans->Write(&fSharedClient, sizeof(int)));
  255. CheckRes(trans->Write(&fSharedGraph, sizeof(int)));
  256. return 0;
  257. }
  258. };
  259. /*!
  260. \brief CloseClient request.
  261. */
  262. struct JackClientCloseRequest : public JackRequest
  263. {
  264. int fRefNum;
  265. JackClientCloseRequest() : fRefNum(0)
  266. {}
  267. JackClientCloseRequest(int refnum): JackRequest(JackRequest::kClientClose), fRefNum(refnum)
  268. {}
  269. int Read(detail::JackChannelTransactionInterface* trans)
  270. {
  271. CheckSize();
  272. return trans->Read(&fRefNum, sizeof(int));
  273. }
  274. int Write(detail::JackChannelTransactionInterface* trans)
  275. {
  276. CheckRes(JackRequest::Write(trans, Size()));
  277. return trans->Write(&fRefNum, sizeof(int));
  278. }
  279. int Size() { return sizeof(int); }
  280. };
  281. /*!
  282. \brief Activate request.
  283. */
  284. struct JackActivateRequest : public JackRequest
  285. {
  286. int fRefNum;
  287. int fIsRealTime;
  288. JackActivateRequest() : fRefNum(0), fIsRealTime(0)
  289. {}
  290. JackActivateRequest(int refnum, int is_real_time)
  291. : JackRequest(JackRequest::kActivateClient), fRefNum(refnum), fIsRealTime(is_real_time)
  292. {}
  293. int Read(detail::JackChannelTransactionInterface* trans)
  294. {
  295. CheckSize();
  296. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  297. return trans->Read(&fIsRealTime, sizeof(int));
  298. }
  299. int Write(detail::JackChannelTransactionInterface* trans)
  300. {
  301. CheckRes(JackRequest::Write(trans, Size()));
  302. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  303. return trans->Write(&fIsRealTime, sizeof(int));
  304. }
  305. int Size() { return 2 * sizeof(int); }
  306. };
  307. /*!
  308. \brief Deactivate request.
  309. */
  310. struct JackDeactivateRequest : public JackRequest
  311. {
  312. int fRefNum;
  313. JackDeactivateRequest() : fRefNum(0)
  314. {}
  315. JackDeactivateRequest(int refnum): JackRequest(JackRequest::kDeactivateClient), fRefNum(refnum)
  316. {}
  317. int Read(detail::JackChannelTransactionInterface* trans)
  318. {
  319. CheckSize();
  320. return trans->Read(&fRefNum, sizeof(int));
  321. }
  322. int Write(detail::JackChannelTransactionInterface* trans)
  323. {
  324. CheckRes(JackRequest::Write(trans, Size()));
  325. return trans->Write(&fRefNum, sizeof(int));
  326. }
  327. int Size() { return sizeof(int); }
  328. };
  329. /*!
  330. \brief PortRegister request.
  331. */
  332. struct JackPortRegisterRequest : public JackRequest
  333. {
  334. int fRefNum;
  335. char fName[JACK_PORT_NAME_SIZE + 1]; // port short name
  336. char fPortType[JACK_PORT_TYPE_SIZE + 1];
  337. unsigned int fFlags;
  338. unsigned int fBufferSize;
  339. JackPortRegisterRequest() : fRefNum(0), fFlags(0), fBufferSize(0)
  340. {
  341. memset(fName, 0, sizeof(fName));
  342. memset(fPortType, 0, sizeof(fPortType));
  343. }
  344. JackPortRegisterRequest(int refnum, const char* name, const char* port_type, unsigned int flags, unsigned int buffer_size)
  345. : JackRequest(JackRequest::kRegisterPort), fRefNum(refnum), fFlags(flags), fBufferSize(buffer_size)
  346. {
  347. memset(fName, 0, sizeof(fName));
  348. memset(fPortType, 0, sizeof(fPortType));
  349. strncpy(fName, name, sizeof(fName)-1);
  350. strncpy(fPortType, port_type, sizeof(fPortType)-1);
  351. }
  352. int Read(detail::JackChannelTransactionInterface* trans)
  353. {
  354. CheckSize();
  355. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  356. CheckRes(trans->Read(&fName, sizeof(fName)));
  357. CheckRes(trans->Read(&fPortType, sizeof(fPortType)));
  358. CheckRes(trans->Read(&fFlags, sizeof(unsigned int)));
  359. CheckRes(trans->Read(&fBufferSize, sizeof(unsigned int)));
  360. return 0;
  361. }
  362. int Write(detail::JackChannelTransactionInterface* trans)
  363. {
  364. CheckRes(JackRequest::Write(trans, Size()));
  365. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  366. CheckRes(trans->Write(&fName, sizeof(fName)));
  367. CheckRes(trans->Write(&fPortType, sizeof(fPortType)));
  368. CheckRes(trans->Write(&fFlags, sizeof(unsigned int)));
  369. CheckRes(trans->Write(&fBufferSize, sizeof(unsigned int)));
  370. return 0;
  371. }
  372. int Size() { return sizeof(int) + sizeof(fName) + sizeof(fPortType) + 2 * sizeof(unsigned int); }
  373. };
  374. /*!
  375. \brief PortRegister result.
  376. */
  377. struct JackPortRegisterResult : public JackResult
  378. {
  379. jack_port_id_t fPortIndex;
  380. JackPortRegisterResult(): JackResult(), fPortIndex(NO_PORT)
  381. {}
  382. int Read(detail::JackChannelTransactionInterface* trans)
  383. {
  384. CheckRes(JackResult::Read(trans));
  385. return trans->Read(&fPortIndex, sizeof(jack_port_id_t));
  386. }
  387. int Write(detail::JackChannelTransactionInterface* trans)
  388. {
  389. CheckRes(JackResult::Write(trans));
  390. return trans->Write(&fPortIndex, sizeof(jack_port_id_t));
  391. }
  392. };
  393. /*!
  394. \brief PortUnregister request.
  395. */
  396. struct JackPortUnRegisterRequest : public JackRequest
  397. {
  398. int fRefNum;
  399. jack_port_id_t fPortIndex;
  400. JackPortUnRegisterRequest() : fRefNum(0), fPortIndex(0)
  401. {}
  402. JackPortUnRegisterRequest(int refnum, jack_port_id_t index)
  403. : JackRequest(JackRequest::kUnRegisterPort), fRefNum(refnum), fPortIndex(index)
  404. {}
  405. int Read(detail::JackChannelTransactionInterface* trans)
  406. {
  407. CheckSize();
  408. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  409. CheckRes(trans->Read(&fPortIndex, sizeof(jack_port_id_t)));
  410. return 0;
  411. }
  412. int Write(detail::JackChannelTransactionInterface* trans)
  413. {
  414. CheckRes(JackRequest::Write(trans, Size()));
  415. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  416. CheckRes(trans->Write(&fPortIndex, sizeof(jack_port_id_t)));
  417. return 0;
  418. }
  419. int Size() { return sizeof(int) + sizeof(jack_port_id_t); }
  420. };
  421. /*!
  422. \brief PortConnectName request.
  423. */
  424. struct JackPortConnectNameRequest : public JackRequest
  425. {
  426. int fRefNum;
  427. char fSrc[REAL_JACK_PORT_NAME_SIZE+1]; // port full name
  428. char fDst[REAL_JACK_PORT_NAME_SIZE+1]; // port full name
  429. JackPortConnectNameRequest() : fRefNum(0)
  430. {
  431. memset(fSrc, 0, sizeof(fSrc));
  432. memset(fDst, 0, sizeof(fDst));
  433. }
  434. JackPortConnectNameRequest(int refnum, const char* src_name, const char* dst_name)
  435. : JackRequest(JackRequest::kConnectNamePorts), fRefNum(refnum)
  436. {
  437. memset(fSrc, 0, sizeof(fSrc));
  438. memset(fDst, 0, sizeof(fDst));
  439. strncpy(fSrc, src_name, sizeof(fSrc)-1);
  440. strncpy(fDst, dst_name, sizeof(fDst)-1);
  441. }
  442. int Read(detail::JackChannelTransactionInterface* trans)
  443. {
  444. CheckSize();
  445. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  446. CheckRes(trans->Read(&fSrc, sizeof(fSrc)));
  447. CheckRes(trans->Read(&fDst, sizeof(fDst)));
  448. return 0;
  449. }
  450. int Write(detail::JackChannelTransactionInterface* trans)
  451. {
  452. CheckRes(JackRequest::Write(trans, Size()));
  453. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  454. CheckRes(trans->Write(&fSrc, sizeof(fSrc)));
  455. CheckRes(trans->Write(&fDst, sizeof(fDst)));
  456. return 0;
  457. }
  458. int Size() { return sizeof(int) + sizeof(fSrc) + sizeof(fDst); }
  459. };
  460. /*!
  461. \brief PortDisconnectName request.
  462. */
  463. struct JackPortDisconnectNameRequest : public JackRequest
  464. {
  465. int fRefNum;
  466. char fSrc[REAL_JACK_PORT_NAME_SIZE+1]; // port full name
  467. char fDst[REAL_JACK_PORT_NAME_SIZE+1]; // port full name
  468. JackPortDisconnectNameRequest() : fRefNum(0)
  469. {
  470. memset(fSrc, 0, sizeof(fSrc));
  471. memset(fDst, 0, sizeof(fDst));
  472. }
  473. JackPortDisconnectNameRequest(int refnum, const char* src_name, const char* dst_name)
  474. : JackRequest(JackRequest::kDisconnectNamePorts), fRefNum(refnum)
  475. {
  476. memset(fSrc, 0, sizeof(fSrc));
  477. memset(fDst, 0, sizeof(fDst));
  478. strncpy(fSrc, src_name, sizeof(fSrc)-1);
  479. strncpy(fDst, dst_name, sizeof(fDst)-1);
  480. }
  481. int Read(detail::JackChannelTransactionInterface* trans)
  482. {
  483. CheckSize();
  484. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  485. CheckRes(trans->Read(&fSrc, sizeof(fSrc)));
  486. CheckRes(trans->Read(&fDst, sizeof(fDst)));
  487. return 0;
  488. }
  489. int Write(detail::JackChannelTransactionInterface* trans)
  490. {
  491. CheckRes(JackRequest::Write(trans, Size()));
  492. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  493. CheckRes(trans->Write(&fSrc, sizeof(fSrc)));
  494. CheckRes(trans->Write(&fDst, sizeof(fDst)));
  495. return 0;
  496. }
  497. int Size() { return sizeof(int) + sizeof(fSrc) + sizeof(fDst); }
  498. };
  499. /*!
  500. \brief PortConnect request.
  501. */
  502. struct JackPortConnectRequest : public JackRequest
  503. {
  504. int fRefNum;
  505. jack_port_id_t fSrc;
  506. jack_port_id_t fDst;
  507. JackPortConnectRequest() : fRefNum(0), fSrc(0), fDst(0)
  508. {}
  509. JackPortConnectRequest(int refnum, jack_port_id_t src, jack_port_id_t dst)
  510. : JackRequest(JackRequest::kConnectPorts), fRefNum(refnum), fSrc(src), fDst(dst)
  511. {}
  512. int Read(detail::JackChannelTransactionInterface* trans)
  513. {
  514. CheckSize();
  515. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  516. CheckRes(trans->Read(&fSrc, sizeof(jack_port_id_t)));
  517. CheckRes(trans->Read(&fDst, sizeof(jack_port_id_t)));
  518. return 0;
  519. }
  520. int Write(detail::JackChannelTransactionInterface* trans)
  521. {
  522. CheckRes(JackRequest::Write(trans, Size()));
  523. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  524. CheckRes(trans->Write(&fSrc, sizeof(jack_port_id_t)));
  525. CheckRes(trans->Write(&fDst, sizeof(jack_port_id_t)));
  526. return 0;
  527. }
  528. int Size() { return sizeof(int) + sizeof(jack_port_id_t) + sizeof(jack_port_id_t); }
  529. };
  530. /*!
  531. \brief PortDisconnect request.
  532. */
  533. struct JackPortDisconnectRequest : public JackRequest
  534. {
  535. int fRefNum;
  536. jack_port_id_t fSrc;
  537. jack_port_id_t fDst;
  538. JackPortDisconnectRequest() : fRefNum(0), fSrc(0), fDst(0)
  539. {}
  540. JackPortDisconnectRequest(int refnum, jack_port_id_t src, jack_port_id_t dst)
  541. : JackRequest(JackRequest::kDisconnectPorts), fRefNum(refnum), fSrc(src), fDst(dst)
  542. {}
  543. int Read(detail::JackChannelTransactionInterface* trans)
  544. {
  545. CheckSize();
  546. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  547. CheckRes(trans->Read(&fSrc, sizeof(jack_port_id_t)));
  548. CheckRes(trans->Read(&fDst, sizeof(jack_port_id_t)));
  549. return 0;
  550. }
  551. int Write(detail::JackChannelTransactionInterface* trans)
  552. {
  553. CheckRes(JackRequest::Write(trans, Size()));
  554. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  555. CheckRes(trans->Write(&fSrc, sizeof(jack_port_id_t)));
  556. CheckRes(trans->Write(&fDst, sizeof(jack_port_id_t)));
  557. return 0;
  558. }
  559. int Size() { return sizeof(int) + sizeof(jack_port_id_t) + sizeof(jack_port_id_t); }
  560. };
  561. /*!
  562. \brief PortRename request.
  563. */
  564. struct JackPortRenameRequest : public JackRequest
  565. {
  566. int fRefNum;
  567. jack_port_id_t fPort;
  568. char fName[JACK_PORT_NAME_SIZE + 1]; // port short name
  569. JackPortRenameRequest() : fRefNum(0), fPort(0)
  570. {
  571. memset(fName, 0, sizeof(fName));
  572. }
  573. JackPortRenameRequest(int refnum, jack_port_id_t port, const char* name)
  574. : JackRequest(JackRequest::kPortRename), fRefNum(refnum), fPort(port)
  575. {
  576. memset(fName, 0, sizeof(fName));
  577. strncpy(fName, name, sizeof(fName)-1);
  578. }
  579. int Read(detail::JackChannelTransactionInterface* trans)
  580. {
  581. CheckSize();
  582. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  583. CheckRes(trans->Read(&fPort, sizeof(jack_port_id_t)));
  584. CheckRes(trans->Read(&fName, sizeof(fName)));
  585. return 0;
  586. }
  587. int Write(detail::JackChannelTransactionInterface* trans)
  588. {
  589. CheckRes(JackRequest::Write(trans, Size()));
  590. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  591. CheckRes(trans->Write(&fPort, sizeof(jack_port_id_t)));
  592. CheckRes(trans->Write(&fName, sizeof(fName)));
  593. return 0;
  594. }
  595. int Size() { return sizeof(int) + sizeof(jack_port_id_t) + sizeof(fName); }
  596. };
  597. /*!
  598. \brief SetBufferSize request.
  599. */
  600. struct JackSetBufferSizeRequest : public JackRequest
  601. {
  602. jack_nframes_t fBufferSize;
  603. JackSetBufferSizeRequest() : fBufferSize(0)
  604. {}
  605. JackSetBufferSizeRequest(jack_nframes_t buffer_size)
  606. : JackRequest(JackRequest::kSetBufferSize), fBufferSize(buffer_size)
  607. {}
  608. int Read(detail::JackChannelTransactionInterface* trans)
  609. {
  610. CheckSize();
  611. return trans->Read(&fBufferSize, sizeof(jack_nframes_t));
  612. }
  613. int Write(detail::JackChannelTransactionInterface* trans)
  614. {
  615. CheckRes(JackRequest::Write(trans, Size()));
  616. return trans->Write(&fBufferSize, sizeof(jack_nframes_t));
  617. }
  618. int Size() { return sizeof(jack_nframes_t); }
  619. };
  620. /*!
  621. \brief SetFreeWheel request.
  622. */
  623. struct JackSetFreeWheelRequest : public JackRequest
  624. {
  625. int fOnOff;
  626. JackSetFreeWheelRequest() : fOnOff(0)
  627. {}
  628. JackSetFreeWheelRequest(int onoff)
  629. : JackRequest(JackRequest::kSetFreeWheel), fOnOff(onoff)
  630. {}
  631. int Read(detail::JackChannelTransactionInterface* trans)
  632. {
  633. CheckSize();
  634. return trans->Read(&fOnOff, sizeof(int));
  635. }
  636. int Write(detail::JackChannelTransactionInterface* trans)
  637. {
  638. CheckRes(JackRequest::Write(trans, Size()));
  639. return trans->Write(&fOnOff, sizeof(int));
  640. }
  641. int Size() { return sizeof(int); }
  642. };
  643. /*!
  644. \brief ComputeTotalLatencies request.
  645. */
  646. struct JackComputeTotalLatenciesRequest : public JackRequest
  647. {
  648. JackComputeTotalLatenciesRequest()
  649. : JackRequest(JackRequest::kComputeTotalLatencies)
  650. {}
  651. int Read(detail::JackChannelTransactionInterface* trans)
  652. {
  653. CheckSize();
  654. return 0;
  655. }
  656. int Write(detail::JackChannelTransactionInterface* trans)
  657. {
  658. CheckRes(JackRequest::Write(trans, Size()));
  659. return 0;
  660. }
  661. int Size() { return 0; }
  662. };
  663. /*!
  664. \brief ReleaseTimebase request.
  665. */
  666. struct JackReleaseTimebaseRequest : public JackRequest
  667. {
  668. int fRefNum;
  669. JackReleaseTimebaseRequest() : fRefNum(0)
  670. {}
  671. JackReleaseTimebaseRequest(int refnum)
  672. : JackRequest(JackRequest::kReleaseTimebase), fRefNum(refnum)
  673. {}
  674. int Read(detail::JackChannelTransactionInterface* trans)
  675. {
  676. CheckSize();
  677. return trans->Read(&fRefNum, sizeof(int));
  678. }
  679. int Write(detail::JackChannelTransactionInterface* trans)
  680. {
  681. CheckRes(JackRequest::Write(trans, Size()));
  682. return trans->Write(&fRefNum, sizeof(int));
  683. }
  684. int Size() { return sizeof(int); }
  685. };
  686. /*!
  687. \brief SetTimebaseCallback request.
  688. */
  689. struct JackSetTimebaseCallbackRequest : public JackRequest
  690. {
  691. int fRefNum;
  692. int fConditionnal;
  693. JackSetTimebaseCallbackRequest() : fRefNum(0), fConditionnal(0)
  694. {}
  695. JackSetTimebaseCallbackRequest(int refnum, int conditional)
  696. : JackRequest(JackRequest::kSetTimebaseCallback), fRefNum(refnum), fConditionnal(conditional)
  697. {}
  698. int Read(detail::JackChannelTransactionInterface* trans)
  699. {
  700. CheckSize();
  701. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  702. return trans->Read(&fConditionnal, sizeof(int));
  703. }
  704. int Write(detail::JackChannelTransactionInterface* trans)
  705. {
  706. CheckRes(JackRequest::Write(trans, Size()));
  707. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  708. return trans->Write(&fConditionnal, sizeof(int));
  709. }
  710. int Size() { return sizeof(int) + sizeof(int); }
  711. };
  712. /*!
  713. \brief GetInternalClientName request.
  714. */
  715. struct JackGetInternalClientNameRequest : public JackRequest
  716. {
  717. int fRefNum;
  718. int fIntRefNum;
  719. JackGetInternalClientNameRequest() : fRefNum(0), fIntRefNum(0)
  720. {}
  721. JackGetInternalClientNameRequest(int refnum, int int_ref)
  722. : JackRequest(JackRequest::kGetInternalClientName), fRefNum(refnum), fIntRefNum(int_ref)
  723. {}
  724. int Read(detail::JackChannelTransactionInterface* trans)
  725. {
  726. CheckSize();
  727. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  728. return trans->Read(&fIntRefNum, sizeof(int));
  729. }
  730. int Write(detail::JackChannelTransactionInterface* trans)
  731. {
  732. CheckRes(JackRequest::Write(trans, Size()));
  733. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  734. return trans->Write(&fIntRefNum, sizeof(int));
  735. }
  736. int Size() { return sizeof(int) + sizeof(int); }
  737. };
  738. /*!
  739. \brief GetInternalClient result.
  740. */
  741. struct JackGetInternalClientNameResult : public JackResult
  742. {
  743. char fName[JACK_CLIENT_NAME_SIZE+1];
  744. JackGetInternalClientNameResult(): JackResult()
  745. {
  746. memset(fName, 0, sizeof(fName));
  747. }
  748. JackGetInternalClientNameResult(int32_t result, const char* name)
  749. : JackResult(result)
  750. {
  751. memset(fName, 0, sizeof(fName));
  752. snprintf(fName, sizeof(fName), "%s", name);
  753. }
  754. int Read(detail::JackChannelTransactionInterface* trans)
  755. {
  756. CheckRes(JackResult::Read(trans));
  757. CheckRes(trans->Read(&fName, sizeof(fName)));
  758. return 0;
  759. }
  760. int Write(detail::JackChannelTransactionInterface* trans)
  761. {
  762. CheckRes(JackResult::Write(trans));
  763. CheckRes(trans->Write(&fName, sizeof(fName)));
  764. return 0;
  765. }
  766. int Size() { return sizeof(fName); }
  767. };
  768. /*!
  769. \brief InternalClientHandle request.
  770. */
  771. struct JackInternalClientHandleRequest : public JackRequest
  772. {
  773. int fRefNum;
  774. char fName[JACK_CLIENT_NAME_SIZE+1];
  775. JackInternalClientHandleRequest() : fRefNum(0)
  776. {
  777. memset(fName, 0, sizeof(fName));
  778. }
  779. JackInternalClientHandleRequest(int refnum, const char* client_name)
  780. : JackRequest(JackRequest::kInternalClientHandle), fRefNum(refnum)
  781. {
  782. memset(fName, 0, sizeof(fName));
  783. snprintf(fName, sizeof(fName), "%s", client_name);
  784. }
  785. int Read(detail::JackChannelTransactionInterface* trans)
  786. {
  787. CheckSize();
  788. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  789. return trans->Read(&fName, sizeof(fName));
  790. }
  791. int Write(detail::JackChannelTransactionInterface* trans)
  792. {
  793. CheckRes(JackRequest::Write(trans, Size()));
  794. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  795. return trans->Write(&fName, sizeof(fName));
  796. }
  797. int Size() { return sizeof(int) + sizeof(fName); }
  798. };
  799. /*!
  800. \brief InternalClientHandle result.
  801. */
  802. struct JackInternalClientHandleResult : public JackResult
  803. {
  804. int fStatus;
  805. int fIntRefNum;
  806. JackInternalClientHandleResult(): JackResult(), fStatus(0), fIntRefNum(0)
  807. {}
  808. JackInternalClientHandleResult(int32_t result, int status, int int_ref)
  809. : JackResult(result), fStatus(status), fIntRefNum(int_ref)
  810. {}
  811. int Read(detail::JackChannelTransactionInterface* trans)
  812. {
  813. CheckRes(JackResult::Read(trans));
  814. CheckRes(trans->Read(&fStatus, sizeof(int)));
  815. CheckRes(trans->Read(&fIntRefNum, sizeof(int)));
  816. return 0;
  817. }
  818. int Write(detail::JackChannelTransactionInterface* trans)
  819. {
  820. CheckRes(JackResult::Write(trans));
  821. CheckRes(trans->Write(&fStatus, sizeof(int)));
  822. CheckRes(trans->Write(&fIntRefNum, sizeof(int)));
  823. return 0;
  824. }
  825. int Size() { return sizeof(int) + sizeof(int); }
  826. };
  827. /*!
  828. \brief InternalClientLoad request.
  829. */
  830. struct JackInternalClientLoadRequest : public JackRequest
  831. {
  832. #ifndef MAX_PATH
  833. #define MAX_PATH 256
  834. #endif
  835. int fRefNum;
  836. char fName[JACK_CLIENT_NAME_SIZE+1];
  837. char fDllName[MAX_PATH+1];
  838. char fLoadInitName[JACK_LOAD_INIT_LIMIT+1];
  839. int fOptions;
  840. int fUUID;
  841. JackInternalClientLoadRequest() : fRefNum(0), fOptions(0), fUUID(0)
  842. {
  843. memset(fName, 0, sizeof(fName));
  844. memset(fDllName, 0, sizeof(fDllName));
  845. memset(fLoadInitName, 0, sizeof(fLoadInitName));
  846. }
  847. JackInternalClientLoadRequest(int refnum, const char* client_name, const char* so_name, const char* objet_data, int options, int uuid )
  848. : JackRequest(JackRequest::kInternalClientLoad), fRefNum(refnum), fOptions(options), fUUID(uuid)
  849. {
  850. memset(fName, 0, sizeof(fName));
  851. memset(fDllName, 0, sizeof(fDllName));
  852. memset(fLoadInitName, 0, sizeof(fLoadInitName));
  853. snprintf(fName, sizeof(fName), "%s", client_name);
  854. snprintf(fDllName, sizeof(fDllName), "%s", so_name);
  855. snprintf(fLoadInitName, sizeof(fLoadInitName), "%s", objet_data);
  856. }
  857. int Read(detail::JackChannelTransactionInterface* trans)
  858. {
  859. CheckSize();
  860. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  861. CheckRes(trans->Read(&fName, sizeof(fName)));
  862. CheckRes(trans->Read(&fDllName, sizeof(fDllName)));
  863. CheckRes(trans->Read(&fLoadInitName, sizeof(fLoadInitName)));
  864. CheckRes(trans->Read(&fUUID, sizeof(int)));
  865. return trans->Read(&fOptions, sizeof(int));
  866. }
  867. int Write(detail::JackChannelTransactionInterface* trans)
  868. {
  869. CheckRes(JackRequest::Write(trans, Size()));
  870. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  871. CheckRes(trans->Write(&fName, sizeof(fName)));
  872. CheckRes(trans->Write(&fDllName, sizeof(fDllName)));
  873. CheckRes(trans->Write(&fLoadInitName, sizeof(fLoadInitName)));
  874. CheckRes(trans->Write(&fUUID, sizeof(int)));
  875. return trans->Write(&fOptions, sizeof(int));
  876. }
  877. int Size() { return sizeof(int) + sizeof(fName) + sizeof(fDllName) + sizeof(fLoadInitName) + 2 * sizeof(int); }
  878. };
  879. /*!
  880. \brief InternalClientLoad result.
  881. */
  882. struct JackInternalClientLoadResult : public JackResult
  883. {
  884. int fStatus;
  885. int fIntRefNum;
  886. JackInternalClientLoadResult(): JackResult(), fStatus(0), fIntRefNum(0)
  887. {}
  888. JackInternalClientLoadResult(int32_t result, int status, int int_ref)
  889. : JackResult(result), fStatus(status), fIntRefNum(int_ref)
  890. {}
  891. int Read(detail::JackChannelTransactionInterface* trans)
  892. {
  893. CheckRes(JackResult::Read(trans));
  894. CheckRes(trans->Read(&fStatus, sizeof(int)));
  895. CheckRes(trans->Read(&fIntRefNum, sizeof(int)));
  896. return 0;
  897. }
  898. int Write(detail::JackChannelTransactionInterface* trans)
  899. {
  900. CheckRes(JackResult::Write(trans));
  901. CheckRes(trans->Write(&fStatus, sizeof(int)));
  902. CheckRes(trans->Write(&fIntRefNum, sizeof(int)));
  903. return 0;
  904. }
  905. int Size() { return sizeof(int) + sizeof(int); }
  906. };
  907. /*!
  908. \brief InternalClientUnload request.
  909. */
  910. struct JackInternalClientUnloadRequest : public JackRequest
  911. {
  912. int fRefNum;
  913. int fIntRefNum;
  914. JackInternalClientUnloadRequest() : fRefNum(0), fIntRefNum(0)
  915. {}
  916. JackInternalClientUnloadRequest(int refnum, int int_ref)
  917. : JackRequest(JackRequest::kInternalClientUnload), fRefNum(refnum), fIntRefNum(int_ref)
  918. {}
  919. int Read(detail::JackChannelTransactionInterface* trans)
  920. {
  921. CheckSize();
  922. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  923. return trans->Read(&fIntRefNum, sizeof(int));
  924. }
  925. int Write(detail::JackChannelTransactionInterface* trans)
  926. {
  927. CheckRes(JackRequest::Write(trans, Size()));
  928. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  929. return trans->Write(&fIntRefNum, sizeof(int));
  930. }
  931. int Size() { return sizeof(int) + sizeof(int); }
  932. };
  933. /*!
  934. \brief InternalClientLoad result.
  935. */
  936. struct JackInternalClientUnloadResult : public JackResult
  937. {
  938. int fStatus;
  939. JackInternalClientUnloadResult(): JackResult(), fStatus(0)
  940. {}
  941. JackInternalClientUnloadResult(int32_t result, int status)
  942. : JackResult(result), fStatus(status)
  943. {}
  944. int Read(detail::JackChannelTransactionInterface* trans)
  945. {
  946. CheckRes(JackResult::Read(trans));
  947. CheckRes(trans->Read(&fStatus, sizeof(int)));
  948. return 0;
  949. }
  950. int Write(detail::JackChannelTransactionInterface* trans)
  951. {
  952. CheckRes(JackResult::Write(trans));
  953. CheckRes(trans->Write(&fStatus, sizeof(int)));
  954. return 0;
  955. }
  956. int Size() { return sizeof(int); }
  957. };
  958. /*!
  959. \brief ClientNotification request.
  960. */
  961. struct JackClientNotificationRequest : public JackRequest
  962. {
  963. int fRefNum;
  964. int fNotify;
  965. int fValue;
  966. JackClientNotificationRequest() : fRefNum(0), fNotify(0), fValue(0)
  967. {}
  968. JackClientNotificationRequest(int refnum, int notify, int value)
  969. : JackRequest(JackRequest::kNotification), fRefNum(refnum), fNotify(notify), fValue(value)
  970. {}
  971. int Read(detail::JackChannelTransactionInterface* trans)
  972. {
  973. CheckSize();
  974. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  975. CheckRes(trans->Read(&fNotify, sizeof(int)));
  976. CheckRes(trans->Read(&fValue, sizeof(int)));
  977. return 0;
  978. }
  979. int Write(detail::JackChannelTransactionInterface* trans)
  980. {
  981. CheckRes(JackRequest::Write(trans, Size()));
  982. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  983. CheckRes(trans->Write(&fNotify, sizeof(int)));
  984. CheckRes(trans->Write(&fValue, sizeof(int)));
  985. return 0;
  986. }
  987. int Size() { return 3 * sizeof(int); }
  988. };
  989. struct JackSessionCommand
  990. {
  991. char fUUID[JACK_UUID_SIZE];
  992. char fClientName[JACK_CLIENT_NAME_SIZE+1];
  993. char fCommand[JACK_SESSION_COMMAND_SIZE];
  994. jack_session_flags_t fFlags;
  995. JackSessionCommand() : fFlags(JackSessionSaveError)
  996. {
  997. memset(fUUID, 0, sizeof(fUUID));
  998. memset(fClientName, 0, sizeof(fClientName));
  999. memset(fCommand, 0, sizeof(fCommand));
  1000. }
  1001. JackSessionCommand(const char *uuid, const char *clientname, const char *command, jack_session_flags_t flags)
  1002. {
  1003. memset(fUUID, 0, sizeof(fUUID));
  1004. memset(fClientName, 0, sizeof(fClientName));
  1005. memset(fCommand, 0, sizeof(fCommand));
  1006. strncpy(fUUID, uuid, sizeof(fUUID)-1);
  1007. strncpy(fClientName, clientname, sizeof(fClientName)-1);
  1008. strncpy(fCommand, command, sizeof(fCommand)-1);
  1009. fFlags = flags;
  1010. }
  1011. };
  1012. struct JackSessionNotifyResult : public JackResult
  1013. {
  1014. std::list<JackSessionCommand> fCommandList;
  1015. bool fDone;
  1016. JackSessionNotifyResult(): JackResult(), fDone(false)
  1017. {}
  1018. JackSessionNotifyResult(int32_t result)
  1019. : JackResult(result), fDone(false)
  1020. {}
  1021. int Read(detail::JackChannelTransactionInterface* trans)
  1022. {
  1023. if (trans == NULL)
  1024. {
  1025. return 0;
  1026. }
  1027. CheckRes(JackResult::Read(trans));
  1028. while (true) {
  1029. JackSessionCommand buffer;
  1030. CheckRes(trans->Read(buffer.fUUID, sizeof(buffer.fUUID)));
  1031. if (buffer.fUUID[0] == '\0')
  1032. break;
  1033. CheckRes(trans->Read(buffer.fClientName, sizeof(buffer.fClientName)));
  1034. CheckRes(trans->Read(buffer.fCommand, sizeof(buffer.fCommand)));
  1035. CheckRes(trans->Read(&(buffer.fFlags), sizeof(buffer.fFlags)));
  1036. fCommandList.push_back(buffer);
  1037. }
  1038. fDone = true;
  1039. return 0;
  1040. }
  1041. int Write(detail::JackChannelTransactionInterface* trans)
  1042. {
  1043. if (trans == NULL)
  1044. {
  1045. fDone = true;
  1046. return 0;
  1047. }
  1048. char terminator[JACK_UUID_SIZE];
  1049. terminator[0] = '\0';
  1050. CheckRes(JackResult::Write(trans));
  1051. for (std::list<JackSessionCommand>::iterator i = fCommandList.begin(); i != fCommandList.end(); i++) {
  1052. CheckRes(trans->Write(i->fUUID, sizeof(i->fUUID)));
  1053. CheckRes(trans->Write(i->fClientName, sizeof(i->fClientName)));
  1054. CheckRes(trans->Write(i->fCommand, sizeof(i->fCommand)));
  1055. CheckRes(trans->Write(&(i->fFlags), sizeof(i->fFlags)));
  1056. }
  1057. CheckRes(trans->Write(terminator, sizeof(terminator)));
  1058. return 0;
  1059. }
  1060. jack_session_command_t* GetCommands()
  1061. {
  1062. /* TODO: some kind of signal should be used instead */
  1063. while (!fDone)
  1064. {
  1065. JackSleep(50000); /* 50 ms */
  1066. }
  1067. jack_session_command_t* session_command = (jack_session_command_t *)malloc(sizeof(jack_session_command_t) * (fCommandList.size() + 1));
  1068. int i = 0;
  1069. for (std::list<JackSessionCommand>::iterator ci = fCommandList.begin(); ci != fCommandList.end(); ci++) {
  1070. session_command[i].uuid = strdup(ci->fUUID);
  1071. session_command[i].client_name = strdup(ci->fClientName);
  1072. session_command[i].command = strdup(ci->fCommand);
  1073. session_command[i].flags = ci->fFlags;
  1074. i += 1;
  1075. }
  1076. session_command[i].uuid = NULL;
  1077. session_command[i].client_name = NULL;
  1078. session_command[i].command = NULL;
  1079. session_command[i].flags = (jack_session_flags_t)0;
  1080. return session_command;
  1081. }
  1082. };
  1083. /*!
  1084. \brief SessionNotify request.
  1085. */
  1086. struct JackSessionNotifyRequest : public JackRequest
  1087. {
  1088. char fPath[JACK_MESSAGE_SIZE+1];
  1089. char fDst[JACK_CLIENT_NAME_SIZE+1];
  1090. jack_session_event_type_t fEventType;
  1091. int fRefNum;
  1092. JackSessionNotifyRequest() : fEventType(JackSessionSave), fRefNum(0)
  1093. {}
  1094. JackSessionNotifyRequest(int refnum, const char* path, jack_session_event_type_t type, const char* dst)
  1095. : JackRequest(JackRequest::kSessionNotify), fEventType(type), fRefNum(refnum)
  1096. {
  1097. memset(fPath, 0, sizeof(fPath));
  1098. memset(fDst, 0, sizeof(fDst));
  1099. snprintf(fPath, sizeof(fPath), "%s", path);
  1100. fPath[JACK_MESSAGE_SIZE] = 0;
  1101. if (dst) {
  1102. snprintf(fDst, sizeof(fDst), "%s", dst);
  1103. fDst[JACK_CLIENT_NAME_SIZE] = 0;
  1104. }
  1105. }
  1106. int Read(detail::JackChannelTransactionInterface* trans)
  1107. {
  1108. CheckSize();
  1109. CheckRes(trans->Read(&fRefNum, sizeof(fRefNum)));
  1110. CheckRes(trans->Read(&fPath, sizeof(fPath)));
  1111. CheckRes(trans->Read(&fDst, sizeof(fDst)));
  1112. CheckRes(trans->Read(&fEventType, sizeof(fEventType)));
  1113. return 0;
  1114. }
  1115. int Write(detail::JackChannelTransactionInterface* trans)
  1116. {
  1117. CheckRes(JackRequest::Write(trans, Size()));
  1118. CheckRes(trans->Write(&fRefNum, sizeof(fRefNum)));
  1119. CheckRes(trans->Write(&fPath, sizeof(fPath)));
  1120. CheckRes(trans->Write(&fDst, sizeof(fDst)));
  1121. CheckRes(trans->Write(&fEventType, sizeof(fEventType)));
  1122. return 0;
  1123. }
  1124. int Size() { return sizeof(fRefNum) + sizeof(fPath) + sizeof(fDst) + sizeof(fEventType); }
  1125. };
  1126. struct JackSessionReplyRequest : public JackRequest
  1127. {
  1128. int fRefNum;
  1129. JackSessionReplyRequest() : fRefNum(0)
  1130. {}
  1131. JackSessionReplyRequest(int refnum)
  1132. : JackRequest(JackRequest::kSessionReply), fRefNum(refnum)
  1133. {}
  1134. int Read(detail::JackChannelTransactionInterface* trans)
  1135. {
  1136. CheckSize();
  1137. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  1138. return 0;
  1139. }
  1140. int Write(detail::JackChannelTransactionInterface* trans)
  1141. {
  1142. CheckRes(JackRequest::Write(trans, Size()));
  1143. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  1144. return 0;
  1145. }
  1146. int Size() { return sizeof(int); }
  1147. };
  1148. struct JackClientNameResult : public JackResult
  1149. {
  1150. char fName[JACK_CLIENT_NAME_SIZE+1];
  1151. JackClientNameResult(): JackResult()
  1152. {
  1153. memset(fName, 0, sizeof(fName));
  1154. }
  1155. JackClientNameResult(int32_t result, const char* name)
  1156. : JackResult(result)
  1157. {
  1158. memset(fName, 0, sizeof(fName));
  1159. snprintf(fName, sizeof(fName), "%s", name);
  1160. }
  1161. int Read(detail::JackChannelTransactionInterface* trans)
  1162. {
  1163. CheckRes(JackResult::Read(trans));
  1164. CheckRes(trans->Read(&fName, sizeof(fName)));
  1165. return 0;
  1166. }
  1167. int Write(detail::JackChannelTransactionInterface* trans)
  1168. {
  1169. CheckRes(JackResult::Write(trans));
  1170. CheckRes(trans->Write(&fName, sizeof(fName)));
  1171. return 0;
  1172. }
  1173. };
  1174. struct JackUUIDResult : public JackResult
  1175. {
  1176. char fUUID[JACK_UUID_SIZE];
  1177. JackUUIDResult(): JackResult()
  1178. {
  1179. memset(fUUID, 0, sizeof(fUUID));
  1180. }
  1181. JackUUIDResult(int32_t result, const char* uuid)
  1182. : JackResult(result)
  1183. {
  1184. memset(fUUID, 0, sizeof(fUUID));
  1185. snprintf(fUUID, sizeof(fUUID), "%s", uuid);
  1186. }
  1187. int Read(detail::JackChannelTransactionInterface* trans)
  1188. {
  1189. CheckRes(JackResult::Read(trans));
  1190. CheckRes(trans->Read(&fUUID, sizeof(fUUID)));
  1191. return 0;
  1192. }
  1193. int Write(detail::JackChannelTransactionInterface* trans)
  1194. {
  1195. CheckRes(JackResult::Write(trans));
  1196. CheckRes(trans->Write(&fUUID, sizeof(fUUID)));
  1197. return 0;
  1198. }
  1199. };
  1200. struct JackGetUUIDRequest : public JackRequest
  1201. {
  1202. char fName[JACK_CLIENT_NAME_SIZE+1];
  1203. JackGetUUIDRequest()
  1204. {
  1205. memset(fName, 0, sizeof(fName));
  1206. }
  1207. JackGetUUIDRequest(const char* client_name)
  1208. : JackRequest(JackRequest::kGetUUIDByClient)
  1209. {
  1210. memset(fName, 0, sizeof(fName));
  1211. strncpy(fName, client_name, sizeof(fName)-1);
  1212. }
  1213. int Read(detail::JackChannelTransactionInterface* trans)
  1214. {
  1215. CheckSize();
  1216. CheckRes(trans->Read(&fName, sizeof(fName)));
  1217. return 0;
  1218. }
  1219. int Write(detail::JackChannelTransactionInterface* trans)
  1220. {
  1221. CheckRes(JackRequest::Write(trans, Size()));
  1222. CheckRes(trans->Write(&fName, sizeof(fName)));
  1223. return 0;
  1224. }
  1225. int Size() { return sizeof(fName); }
  1226. };
  1227. struct JackGetClientNameRequest : public JackRequest
  1228. {
  1229. char fUUID[JACK_UUID_SIZE];
  1230. JackGetClientNameRequest()
  1231. {
  1232. memset(fUUID, 0, sizeof(fUUID));
  1233. }
  1234. JackGetClientNameRequest(const char* uuid)
  1235. : JackRequest(JackRequest::kGetClientByUUID)
  1236. {
  1237. memset(fUUID, 0, sizeof(fUUID));
  1238. strncpy(fUUID, uuid, sizeof(fUUID)-1);
  1239. }
  1240. int Read(detail::JackChannelTransactionInterface* trans)
  1241. {
  1242. CheckSize();
  1243. CheckRes(trans->Read(&fUUID, sizeof(fUUID)));
  1244. return 0;
  1245. }
  1246. int Write(detail::JackChannelTransactionInterface* trans)
  1247. {
  1248. CheckRes(JackRequest::Write(trans, Size()));
  1249. CheckRes(trans->Write(&fUUID, sizeof(fUUID)));
  1250. return 0;
  1251. }
  1252. int Size() { return sizeof(fUUID); }
  1253. };
  1254. struct JackReserveNameRequest : public JackRequest
  1255. {
  1256. int fRefNum;
  1257. char fName[JACK_CLIENT_NAME_SIZE+1];
  1258. char fUUID[JACK_UUID_SIZE];
  1259. JackReserveNameRequest() : fRefNum(0)
  1260. {
  1261. memset(fName, 0, sizeof(fName));
  1262. memset(fUUID, 0, sizeof(fUUID));
  1263. }
  1264. JackReserveNameRequest(int refnum, const char *name, const char* uuid)
  1265. : JackRequest(JackRequest::kReserveClientName), fRefNum(refnum)
  1266. {
  1267. memset(fName, 0, sizeof(fName));
  1268. memset(fUUID, 0, sizeof(fUUID));
  1269. strncpy(fName, name, sizeof(fName)-1);
  1270. strncpy(fUUID, uuid, sizeof(fUUID)-1);
  1271. }
  1272. int Read(detail::JackChannelTransactionInterface* trans)
  1273. {
  1274. CheckSize();
  1275. CheckRes(trans->Read(&fUUID, sizeof(fUUID)));
  1276. CheckRes(trans->Read(&fName, sizeof(fName)));
  1277. CheckRes(trans->Read(&fRefNum, sizeof(fRefNum)));
  1278. return 0;
  1279. }
  1280. int Write(detail::JackChannelTransactionInterface* trans)
  1281. {
  1282. CheckRes(JackRequest::Write(trans, Size()));
  1283. CheckRes(trans->Write(&fUUID, sizeof(fUUID)));
  1284. CheckRes(trans->Write(&fName, sizeof(fName)));
  1285. CheckRes(trans->Write(&fRefNum, sizeof(fRefNum)));
  1286. return 0;
  1287. }
  1288. int Size() { return sizeof(fUUID) + sizeof(fName) + sizeof(fRefNum); }
  1289. };
  1290. struct JackClientHasSessionCallbackRequest : public JackRequest
  1291. {
  1292. char fName[JACK_CLIENT_NAME_SIZE+1];
  1293. JackClientHasSessionCallbackRequest()
  1294. {
  1295. memset(fName, 0, sizeof(fName));
  1296. }
  1297. JackClientHasSessionCallbackRequest(const char *name)
  1298. : JackRequest(JackRequest::kClientHasSessionCallback)
  1299. {
  1300. memset(fName, 0, sizeof(fName));
  1301. strncpy(fName, name, sizeof(fName)-1);
  1302. }
  1303. int Read(detail::JackChannelTransactionInterface* trans)
  1304. {
  1305. CheckSize();
  1306. CheckRes(trans->Read(&fName, sizeof(fName)));
  1307. return 0;
  1308. }
  1309. int Write(detail::JackChannelTransactionInterface* trans)
  1310. {
  1311. CheckRes(JackRequest::Write(trans, Size()));
  1312. CheckRes(trans->Write(&fName, sizeof(fName)));
  1313. return 0;
  1314. }
  1315. int Size() { return sizeof(fName); }
  1316. };
  1317. /*!
  1318. \brief ClientNotification.
  1319. */
  1320. struct JackClientNotification
  1321. {
  1322. int fSize;
  1323. char fName[JACK_CLIENT_NAME_SIZE+1];
  1324. int fRefNum;
  1325. int fNotify;
  1326. int fValue1;
  1327. int fValue2;
  1328. int fSync;
  1329. char fMessage[JACK_MESSAGE_SIZE+1];
  1330. JackClientNotification(): fSize(0), fRefNum(0), fNotify(-1), fValue1(-1), fValue2(-1), fSync(0)
  1331. {
  1332. memset(fName, 0, sizeof(fName));
  1333. memset(fMessage, 0, sizeof(fMessage));
  1334. }
  1335. JackClientNotification(const char* name, int refnum, int notify, int sync, const char* message, int value1, int value2)
  1336. : fRefNum(refnum), fNotify(notify), fValue1(value1), fValue2(value2), fSync(sync)
  1337. {
  1338. memset(fName, 0, sizeof(fName));
  1339. memset(fMessage, 0, sizeof(fMessage));
  1340. snprintf(fName, sizeof(fName), "%s", name);
  1341. snprintf(fMessage, sizeof(fMessage), "%s", message);
  1342. fSize = Size();
  1343. }
  1344. int Read(detail::JackChannelTransactionInterface* trans)
  1345. {
  1346. CheckSize();
  1347. CheckRes(trans->Read(&fName, sizeof(fName)));
  1348. CheckRes(trans->Read(&fRefNum, sizeof(int)));
  1349. CheckRes(trans->Read(&fNotify, sizeof(int)));
  1350. CheckRes(trans->Read(&fValue1, sizeof(int)));
  1351. CheckRes(trans->Read(&fValue2, sizeof(int)));
  1352. CheckRes(trans->Read(&fSync, sizeof(int)));
  1353. CheckRes(trans->Read(&fMessage, sizeof(fMessage)));
  1354. return 0;
  1355. }
  1356. int Write(detail::JackChannelTransactionInterface* trans)
  1357. {
  1358. CheckRes(trans->Write(&fSize, sizeof(int)));
  1359. CheckRes(trans->Write(&fName, sizeof(fName)));
  1360. CheckRes(trans->Write(&fRefNum, sizeof(int)));
  1361. CheckRes(trans->Write(&fNotify, sizeof(int)));
  1362. CheckRes(trans->Write(&fValue1, sizeof(int)));
  1363. CheckRes(trans->Write(&fValue2, sizeof(int)));
  1364. CheckRes(trans->Write(&fSync, sizeof(int)));
  1365. CheckRes(trans->Write(&fMessage, sizeof(fMessage)));
  1366. return 0;
  1367. }
  1368. int Size() { return sizeof(int) + sizeof(fName) + 5 * sizeof(int) + sizeof(fMessage); }
  1369. };
  1370. } // end of namespace
  1371. #endif