19 #include "JackNetInterface.h" 20 #include "JackException.h" 21 #include "JackError.h" 37 JackNetInterface::JackNetInterface() : fSocket()
42 JackNetInterface::JackNetInterface(
const char* multicast_ip,
int port) : fSocket(multicast_ip, port)
44 strcpy(fMulticastIP, multicast_ip);
48 JackNetInterface::JackNetInterface(session_params_t& params, JackNetSocket& socket,
const char* multicast_ip) : fSocket(socket)
51 strcpy(fMulticastIP, multicast_ip);
55 void JackNetInterface::Initialize()
60 fNetAudioCaptureBuffer = NULL;
61 fNetAudioPlaybackBuffer = NULL;
62 fNetMidiCaptureBuffer = NULL;
63 fNetMidiPlaybackBuffer = NULL;
64 memset(&fSendTransportData, 0,
sizeof(net_transport_data_t));
65 memset(&fReturnTransportData, 0,
sizeof(net_transport_data_t));
66 fPacketTimeOut = PACKET_TIMEOUT * NETWORK_DEFAULT_LATENCY;
69 void JackNetInterface::FreeNetworkBuffers()
71 delete fNetMidiCaptureBuffer;
72 delete fNetMidiPlaybackBuffer;
73 delete fNetAudioCaptureBuffer;
74 delete fNetAudioPlaybackBuffer;
75 fNetMidiCaptureBuffer = NULL;
76 fNetMidiPlaybackBuffer = NULL;
77 fNetAudioCaptureBuffer = NULL;
78 fNetAudioPlaybackBuffer = NULL;
81 JackNetInterface::~JackNetInterface()
83 jack_log(
"JackNetInterface::~JackNetInterface");
88 delete fNetAudioCaptureBuffer;
89 delete fNetAudioPlaybackBuffer;
90 delete fNetMidiCaptureBuffer;
91 delete fNetMidiPlaybackBuffer;
94 int JackNetInterface::SetNetBufferSize()
97 float audio_size = (fNetAudioCaptureBuffer)
98 ? fNetAudioCaptureBuffer->GetCycleSize()
99 : (fNetAudioPlaybackBuffer) ? fNetAudioPlaybackBuffer->GetCycleSize() : 0;
100 jack_log(
"audio_size %f", audio_size);
103 float midi_size = (fNetMidiCaptureBuffer)
104 ? fNetMidiCaptureBuffer->GetCycleSize()
105 : (fNetMidiPlaybackBuffer) ? fNetMidiPlaybackBuffer->GetCycleSize() : 0;
106 jack_log(
"midi_size %f", midi_size);
109 int bufsize = NETWORK_MAX_LATENCY * (fParams.fMtu + (int)audio_size + (
int)midi_size);
110 jack_log(
"SetNetBufferSize bufsize = %d", bufsize);
113 if (fSocket.SetOption(SOL_SOCKET, SO_SNDBUF, &bufsize,
sizeof(bufsize)) == SOCKET_ERROR) {
118 if (fSocket.SetOption(SOL_SOCKET, SO_RCVBUF, &bufsize,
sizeof(bufsize)) == SOCKET_ERROR) {
125 bool JackNetInterface::SetParams()
128 strcpy(fTxHeader.fPacketType,
"header");
129 fTxHeader.fID = fParams.fID;
130 fTxHeader.fCycle = 0;
131 fTxHeader.fSubCycle = 0;
132 fTxHeader.fIsLastPckt = 0;
135 strcpy(fRxHeader.fPacketType,
"header");
136 fRxHeader.fID = fParams.fID;
137 fRxHeader.fCycle = 0;
138 fRxHeader.fSubCycle = 0;
139 fRxHeader.fIsLastPckt = 0;
142 fTxBuffer =
new char[fParams.fMtu];
143 fRxBuffer =
new char[fParams.fMtu];
148 fTxData = fTxBuffer + HEADER_SIZE;
149 fRxData = fRxBuffer + HEADER_SIZE;
154 int JackNetInterface::MidiSend(NetMidiBuffer* buffer,
int midi_channnels,
int audio_channels)
156 if (midi_channnels > 0) {
158 fTxHeader.fDataType =
'm';
159 uint data_size = buffer->RenderFromJackPorts();
160 fTxHeader.fNumPacket = buffer->GetNumPackets(data_size, PACKET_AVAILABLE_SIZE(&fParams));
162 for (uint subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
163 fTxHeader.fSubCycle = subproc;
164 fTxHeader.fIsLastPckt = ((subproc == (fTxHeader.fNumPacket - 1)) && audio_channels == 0) ? 1 : 0;
165 fTxHeader.fPacketSize = HEADER_SIZE + buffer->RenderToNetwork(subproc, data_size);
166 memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
167 if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR) {
175 int JackNetInterface::AudioSend(NetAudioBuffer* buffer,
int audio_channels)
178 if (audio_channels > 0) {
179 fTxHeader.fDataType =
'a';
180 fTxHeader.fActivePorts = buffer->RenderFromJackPorts(fTxHeader.fFrames);
181 fTxHeader.fNumPacket = buffer->GetNumPackets(fTxHeader.fActivePorts);
183 for (uint subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
184 fTxHeader.fSubCycle = subproc;
185 fTxHeader.fIsLastPckt = (subproc == (fTxHeader.fNumPacket - 1)) ? 1 : 0;
186 fTxHeader.fPacketSize = HEADER_SIZE + buffer->RenderToNetwork(subproc, fTxHeader.fActivePorts);
187 memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
189 if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR) {
197 int JackNetInterface::MidiRecv(packet_header_t* rx_head, NetMidiBuffer* buffer, uint& recvd_midi_pckt)
199 int rx_bytes = Recv(rx_head->fPacketSize, 0);
200 fRxHeader.fCycle = rx_head->fCycle;
201 fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
202 buffer->RenderFromNetwork(rx_head->fSubCycle, rx_bytes - HEADER_SIZE);
205 if (++recvd_midi_pckt == rx_head->fNumPacket) {
206 buffer->RenderToJackPorts();
211 int JackNetInterface::AudioRecv(packet_header_t* rx_head, NetAudioBuffer* buffer)
213 int rx_bytes = Recv(rx_head->fPacketSize, 0);
214 fRxHeader.fCycle = rx_head->fCycle;
215 fRxHeader.fSubCycle = rx_head->fSubCycle;
216 fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
217 fRxHeader.fActivePorts = rx_head->fActivePorts;
218 fRxHeader.fFrames = rx_head->fFrames;
219 rx_bytes = buffer->RenderFromNetwork(rx_head->fCycle, rx_head->fSubCycle, fRxHeader.fActivePorts);
222 if (fRxHeader.fIsLastPckt) {
223 buffer->RenderToJackPorts(fRxHeader.fFrames);
228 int JackNetInterface::FinishRecv(NetAudioBuffer* buffer)
231 buffer->RenderToJackPorts(fRxHeader.fFrames);
235 return DATA_PACKET_ERROR;
238 NetAudioBuffer* JackNetInterface::AudioBufferFactory(
int nports,
char* buffer)
240 switch (fParams.fSampleEncoder) {
242 case JackFloatEncoder:
243 return new NetFloatAudioBuffer(&fParams, nports, buffer);
246 return new NetIntAudioBuffer(&fParams, nports, buffer);
249 case JackCeltEncoder:
250 return new NetCeltAudioBuffer(&fParams, nports, buffer, fParams.fKBps);
253 case JackOpusEncoder:
254 return new NetOpusAudioBuffer(&fParams, nports, buffer, fParams.fKBps);
258 throw std::bad_alloc();
261 void JackNetInterface::SetRcvTimeOut()
264 if (fSocket.SetTimeOut(fPacketTimeOut) == SOCKET_ERROR) {
265 jack_error(
"Can't set rx timeout : %s", StrError(NET_ERROR_CODE));
274 bool JackNetMasterInterface::Init()
276 jack_log(
"JackNetMasterInterface::Init : ID %u", fParams.fID);
278 session_params_t host_params;
283 if (fSocket.NewSocket() == SOCKET_ERROR) {
284 jack_error(
"Can't create socket : %s", StrError(NET_ERROR_CODE));
289 if (fSocket.SetTimeOut(MASTER_INIT_TIMEOUT) < 0) {
290 jack_error(
"Can't set init timeout : %s", StrError(NET_ERROR_CODE));
294 if (fSocket.Connect() == SOCKET_ERROR) {
295 jack_error(
"Can't connect : %s", StrError(NET_ERROR_CODE));
300 jack_info(
"Sending parameters to %s...", fParams.fSlaveNetName);
303 session_params_t net_params;
304 memset(&net_params, 0,
sizeof(session_params_t));
305 SetPacketType(&fParams, SLAVE_SETUP);
306 SessionParamsHToN(&fParams, &net_params);
308 if (fSocket.Send(&net_params,
sizeof(session_params_t), 0) == SOCKET_ERROR) {
309 jack_error(
"Error in send : %s", StrError(NET_ERROR_CODE));
312 memset(&net_params, 0,
sizeof(session_params_t));
313 if (((rx_bytes = fSocket.Recv(&net_params,
sizeof(session_params_t), 0)) == SOCKET_ERROR) && (fSocket.GetError() != NET_NO_DATA)) {
318 SessionParamsNToH(&net_params, &host_params);
320 while ((GetPacketType(&host_params) != START_MASTER) && (++attempt < SLAVE_SETUP_RETRY));
322 if (attempt == SLAVE_SETUP_RETRY) {
330 bool JackNetMasterInterface::SetParams()
332 jack_log(
"JackNetMasterInterface::SetParams audio in = %d audio out = %d MIDI in = %d MIDI out = %d",
333 fParams.fSendAudioChannels, fParams.fReturnAudioChannels,
334 fParams.fSendMidiChannels, fParams.fReturnMidiChannels);
336 JackNetInterface::SetParams();
338 fTxHeader.fDataStream =
's';
339 fRxHeader.fDataStream =
'r';
341 fMaxCycleOffset = fParams.fNetworkLatency;
344 if (fParams.fSendMidiChannels > 0) {
345 fNetMidiCaptureBuffer =
new NetMidiBuffer(&fParams, fParams.fSendMidiChannels, fTxData);
348 if (fParams.fReturnMidiChannels > 0) {
349 fNetMidiPlaybackBuffer =
new NetMidiBuffer(&fParams, fParams.fReturnMidiChannels, fRxData);
355 if (fParams.fSendAudioChannels > 0) {
356 fNetAudioCaptureBuffer = AudioBufferFactory(fParams.fSendAudioChannels, fTxData);
357 assert(fNetAudioCaptureBuffer);
360 if (fParams.fReturnAudioChannels > 0) {
361 fNetAudioPlaybackBuffer = AudioBufferFactory(fParams.fReturnAudioChannels, fRxData);
362 assert(fNetAudioPlaybackBuffer);
365 }
catch (exception&) {
366 jack_error(
"NetAudioBuffer on master allocation error...");
371 if (SetNetBufferSize() == SOCKET_ERROR) {
372 jack_error(
"Can't set net buffer sizes : %s", StrError(NET_ERROR_CODE));
379 FreeNetworkBuffers();
383 void JackNetMasterInterface::Exit()
385 jack_log(
"JackNetMasterInterface::Exit, ID %u", fParams.fID);
391 jack_info(
"Exiting '%s' %s", fParams.fName, fMulticastIP);
392 SetPacketType(&fParams, KILL_MASTER);
393 JackNetSocket mcast_socket(fMulticastIP, fSocket.GetPort());
395 session_params_t net_params;
396 memset(&net_params, 0,
sizeof(session_params_t));
397 SessionParamsHToN(&fParams, &net_params);
399 if (mcast_socket.NewSocket() == SOCKET_ERROR) {
400 jack_error(
"Can't create socket : %s", StrError(NET_ERROR_CODE));
402 if (mcast_socket.SendTo(&net_params,
sizeof(session_params_t), 0, fMulticastIP) == SOCKET_ERROR) {
403 jack_error(
"Can't send suicide request : %s", StrError(NET_ERROR_CODE));
406 mcast_socket.Close();
409 void JackNetMasterInterface::FatalRecvError()
412 jack_error(
"Recv connection lost error = %s, '%s' exiting", StrError(NET_ERROR_CODE), fParams.fName);
419 void JackNetMasterInterface::FatalSendError()
422 jack_error(
"Send connection lost error = %s, '%s' exiting", StrError(NET_ERROR_CODE), fParams.fName);
429 int JackNetMasterInterface::Recv(
size_t size,
int flags)
433 if (((rx_bytes = fSocket.Recv(fRxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
437 packet_header_t* header =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
438 PacketHeaderNToH(header, header);
442 int JackNetMasterInterface::Send(
size_t size,
int flags)
445 packet_header_t* header =
reinterpret_cast<packet_header_t*
>(fTxBuffer);
446 PacketHeaderHToN(header, header);
448 if (((tx_bytes = fSocket.Send(fTxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
454 int JackNetMasterInterface::SyncSend()
459 fTxHeader.fSubCycle = 0;
460 fTxHeader.fDataType =
's';
461 fTxHeader.fIsLastPckt = (fParams.fSendMidiChannels == 0 && fParams.fSendAudioChannels == 0) ? 1 : 0;
462 fTxHeader.fPacketSize = fParams.fMtu;
464 memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
466 return Send(fTxHeader.fPacketSize, 0);
469 int JackNetMasterInterface::DataSend()
471 if (MidiSend(fNetMidiCaptureBuffer, fParams.fSendMidiChannels, fParams.fSendAudioChannels) == SOCKET_ERROR) {
474 return AudioSend(fNetAudioCaptureBuffer, fParams.fSendAudioChannels);
477 int JackNetMasterInterface::SyncRecv()
480 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
484 rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
486 if (rx_bytes == SOCKET_ERROR) {
490 while (strcmp(rx_head->fPacketType,
"header") != 0);
492 if (rx_head->fDataType !=
's') {
493 jack_error(
"Wrong packet type : %c", rx_head->fDataType);
495 fRxHeader.fIsLastPckt = 0;
496 return SYNC_PACKET_ERROR;
499 fCurrentCycleOffset = fTxHeader.fCycle - rx_head->fCycle;
501 if (fCurrentCycleOffset < fMaxCycleOffset && !fSynched) {
502 jack_info(
"Synching with latency = %d", fCurrentCycleOffset);
505 if (fCurrentCycleOffset == fMaxCycleOffset) {
509 rx_bytes = Recv(rx_head->fPacketSize, 0);
510 fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
515 int JackNetMasterInterface::DataRecv()
518 uint recvd_midi_pckt = 0;
519 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
521 while (!fRxHeader.fIsLastPckt) {
523 rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
526 if (rx_bytes == SOCKET_ERROR) {
530 if (rx_bytes && (rx_head->fDataStream ==
'r') && (rx_head->fID == fParams.fID)) {
532 switch (rx_head->fDataType) {
535 rx_bytes = MidiRecv(rx_head, fNetMidiPlaybackBuffer, recvd_midi_pckt);
539 rx_bytes = AudioRecv(rx_head, fNetAudioPlaybackBuffer);
543 jack_info(
"NetMaster : missing last data packet from '%s'", fParams.fName);
544 return FinishRecv(fNetAudioPlaybackBuffer);
552 void JackNetMasterInterface::EncodeSyncPacket(
int frames)
556 memset(fTxData, 0, PACKET_AVAILABLE_SIZE(&fParams));
572 fTxHeader.fActivePorts = (fNetAudioPlaybackBuffer) ? fNetAudioPlaybackBuffer->ActivePortsToNetwork(fTxData) : 0;
573 fTxHeader.fFrames = frames;
576 void JackNetMasterInterface::DecodeSyncPacket(
int& frames)
593 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
596 if (fNetAudioCaptureBuffer) {
597 fNetAudioCaptureBuffer->ActivePortsFromNetwork(fRxData, rx_head->fActivePorts);
599 frames = rx_head->fFrames;
604 uint JackNetSlaveInterface::fSlaveCounter = 0;
606 void JackNetSlaveInterface::InitAPI()
609 if (fSlaveCounter++ == 0) {
610 if (SocketAPIInit() < 0) {
611 jack_error(
"Can't init Socket API, exiting...");
612 throw std::bad_alloc();
617 bool JackNetSlaveInterface::Init()
619 jack_log(
"JackNetSlaveInterface::Init()");
622 strcpy(fParams.fPacketType,
"params");
623 fParams.fProtocolVersion = NETWORK_PROTOCOL;
624 SetPacketType(&fParams, SLAVE_AVAILABLE);
631 status = SendAvailableToMaster();
632 if (status == NET_SOCKET_ERROR) {
636 while (status != NET_CONNECTED);
639 jack_info(
"Initializing connection with %s...", fParams.fMasterNetName);
640 status = SendStartToMaster();
641 if (status == NET_ERROR) {
645 while (status != NET_ROLLING);
651 bool JackNetSlaveInterface::InitConnection(
int time_out_sec)
653 jack_log(
"JackNetSlaveInterface::InitConnection time_out_sec = %d", time_out_sec);
654 int try_count = (time_out_sec > 0) ?
int((1000000.f *
float(time_out_sec)) / float(SLAVE_INIT_TIMEOUT)) : INT_MAX;
657 strcpy(fParams.fPacketType,
"params");
658 fParams.fProtocolVersion = NETWORK_PROTOCOL;
659 SetPacketType(&fParams, SLAVE_AVAILABLE);
661 return (SendAvailableToMaster(try_count) == NET_CONNECTED);
664 bool JackNetSlaveInterface::InitRendering()
666 jack_log(
"JackNetSlaveInterface::InitRendering()");
671 jack_info(
"Initializing connection with %s...", fParams.fMasterNetName);
672 status = SendStartToMaster();
673 if (status == NET_ERROR) {
677 while (status != NET_ROLLING);
682 net_status_t JackNetSlaveInterface::SendAvailableToMaster(
int try_count)
684 jack_log(
"JackNetSlaveInterface::SendAvailableToMaster try_count = %d", try_count);
686 session_params_t host_params;
690 if (fSocket.NewSocket() == SOCKET_ERROR) {
691 jack_error(
"Fatal error : network unreachable - %s", StrError(NET_ERROR_CODE));
692 return NET_SOCKET_ERROR;
695 if (fSocket.IsLocal(fMulticastIP)) {
699 if (fSocket.Bind() == SOCKET_ERROR) {
700 jack_error(
"Can't bind the socket : %s", StrError(NET_ERROR_CODE));
701 return NET_SOCKET_ERROR;
706 if (fSocket.SetTimeOut(SLAVE_INIT_TIMEOUT) == SOCKET_ERROR) {
707 jack_error(
"Can't set init timeout : %s", StrError(NET_ERROR_CODE));
711 if (fSocket.SetLocalLoop() == SOCKET_ERROR) {
712 jack_error(
"Can't disable multicast loop : %s", StrError(NET_ERROR_CODE));
720 session_params_t net_params;
721 memset(&net_params, 0,
sizeof(session_params_t));
722 SessionParamsHToN(&fParams, &net_params);
723 if (fSocket.SendTo(&net_params,
sizeof(session_params_t), 0, fMulticastIP) == SOCKET_ERROR) {
724 jack_error(
"Error in data send : %s", StrError(NET_ERROR_CODE));
728 memset(&net_params, 0,
sizeof(session_params_t));
729 rx_bytes = fSocket.CatchHost(&net_params,
sizeof(session_params_t), 0);
730 SessionParamsNToH(&net_params, &host_params);
731 if ((rx_bytes == SOCKET_ERROR) && (fSocket.GetError() != NET_NO_DATA)) {
732 jack_error(
"Can't receive : %s", StrError(NET_ERROR_CODE));
733 return NET_RECV_ERROR;
736 while (strcmp(host_params.fPacketType, fParams.fPacketType) && (GetPacketType(&host_params) != SLAVE_SETUP) && (--try_count > 0));
739 if (try_count == 0) {
741 return NET_CONNECT_ERROR;
745 fParams = host_params;
748 if (fSocket.Connect() == SOCKET_ERROR) {
749 jack_error(
"Error in connect : %s", StrError(NET_ERROR_CODE));
750 return NET_CONNECT_ERROR;
753 return NET_CONNECTED;
756 net_status_t JackNetSlaveInterface::SendStartToMaster()
758 jack_log(
"JackNetSlaveInterface::SendStartToMaster");
761 session_params_t net_params;
762 memset(&net_params, 0,
sizeof(session_params_t));
763 SetPacketType(&fParams, START_MASTER);
764 SessionParamsHToN(&fParams, &net_params);
765 if (fSocket.Send(&net_params,
sizeof(session_params_t), 0) == SOCKET_ERROR) {
766 jack_error(
"Error in send : %s", StrError(NET_ERROR_CODE));
767 return (fSocket.GetError() == NET_CONN_ERROR) ? NET_ERROR : NET_SEND_ERROR;
772 bool JackNetSlaveInterface::SetParams()
774 jack_log(
"JackNetSlaveInterface::SetParams audio in = %d audio out = %d MIDI in = %d MIDI out = %d",
775 fParams.fSendAudioChannels, fParams.fReturnAudioChannels,
776 fParams.fSendMidiChannels, fParams.fReturnMidiChannels);
778 JackNetInterface::SetParams();
780 fTxHeader.fDataStream =
'r';
781 fRxHeader.fDataStream =
's';
784 if (fParams.fSendMidiChannels > 0) {
785 fNetMidiCaptureBuffer =
new NetMidiBuffer(&fParams, fParams.fSendMidiChannels, fRxData);
788 if (fParams.fReturnMidiChannels > 0) {
789 fNetMidiPlaybackBuffer =
new NetMidiBuffer(&fParams, fParams.fReturnMidiChannels, fTxData);
795 if (fParams.fSendAudioChannels > 0) {
796 fNetAudioCaptureBuffer = AudioBufferFactory(fParams.fSendAudioChannels, fRxData);
797 assert(fNetAudioCaptureBuffer);
800 if (fParams.fReturnAudioChannels > 0) {
801 fNetAudioPlaybackBuffer = AudioBufferFactory(fParams.fReturnAudioChannels, fTxData);
802 assert(fNetAudioPlaybackBuffer);
805 }
catch (exception&) {
806 jack_error(
"NetAudioBuffer on slave allocation error...");
811 if (SetNetBufferSize() == SOCKET_ERROR) {
812 jack_error(
"Can't set net buffer sizes : %s", StrError(NET_ERROR_CODE));
819 FreeNetworkBuffers();
823 void JackNetSlaveInterface::FatalRecvError()
825 throw JackNetException(
"Recv connection lost error");
828 void JackNetSlaveInterface::FatalSendError()
830 throw JackNetException(
"Send connection lost error");
833 int JackNetSlaveInterface::Recv(
size_t size,
int flags)
835 int rx_bytes = fSocket.Recv(fRxBuffer, size, flags);
838 if (rx_bytes == SOCKET_ERROR) {
842 packet_header_t* header =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
843 PacketHeaderNToH(header, header);
847 int JackNetSlaveInterface::Send(
size_t size,
int flags)
849 packet_header_t* header =
reinterpret_cast<packet_header_t*
>(fTxBuffer);
850 PacketHeaderHToN(header, header);
851 int tx_bytes = fSocket.Send(fTxBuffer, size, flags);
854 if (tx_bytes == SOCKET_ERROR) {
861 int JackNetSlaveInterface::SyncRecv()
866 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
870 rx_bytes = Recv(fParams.fMtu, 0);
872 if (rx_bytes == SOCKET_ERROR) {
876 while (strcmp(rx_head->fPacketType,
"header") != 0);
878 if (rx_head->fDataType !=
's') {
879 jack_error(
"Wrong packet type : %c", rx_head->fDataType);
881 fRxHeader.fIsLastPckt = 0;
882 return SYNC_PACKET_ERROR;
885 fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
889 int JackNetSlaveInterface::DataRecv()
892 uint recvd_midi_pckt = 0;
893 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
895 while (!fRxHeader.fIsLastPckt) {
897 rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
900 if (rx_bytes == SOCKET_ERROR) {
904 if (rx_bytes && (rx_head->fDataStream ==
's') && (rx_head->fID == fParams.fID)) {
906 switch (rx_head->fDataType) {
909 rx_bytes = MidiRecv(rx_head, fNetMidiCaptureBuffer, recvd_midi_pckt);
913 rx_bytes = AudioRecv(rx_head, fNetAudioCaptureBuffer);
917 jack_info(
"NetSlave : missing last data packet");
918 return FinishRecv(fNetAudioCaptureBuffer);
923 fRxHeader.fCycle = rx_head->fCycle;
927 int JackNetSlaveInterface::SyncSend()
930 if (fParams.fSlaveSyncMode) {
931 fTxHeader.fCycle = fRxHeader.fCycle;
935 fTxHeader.fSubCycle = 0;
936 fTxHeader.fDataType =
's';
937 fTxHeader.fIsLastPckt = (fParams.fReturnMidiChannels == 0 && fParams.fReturnAudioChannels == 0) ? 1 : 0;
938 fTxHeader.fPacketSize = fParams.fMtu;
940 memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
942 return Send(fTxHeader.fPacketSize, 0);
945 int JackNetSlaveInterface::DataSend()
947 if (MidiSend(fNetMidiPlaybackBuffer, fParams.fReturnMidiChannels, fParams.fReturnAudioChannels) == SOCKET_ERROR) {
950 return AudioSend(fNetAudioPlaybackBuffer, fParams.fReturnAudioChannels);
954 void JackNetSlaveInterface::EncodeSyncPacket(
int frames)
958 memset(fTxData, 0, PACKET_AVAILABLE_SIZE(&fParams));
974 fTxHeader.fActivePorts = (fNetAudioCaptureBuffer) ? fNetAudioCaptureBuffer->ActivePortsToNetwork(fTxData) : 0;
975 fTxHeader.fFrames = frames;
978 void JackNetSlaveInterface::DecodeSyncPacket(
int& frames)
995 packet_header_t* rx_head =
reinterpret_cast<packet_header_t*
>(fRxBuffer);
998 if (fNetAudioPlaybackBuffer) {
999 fNetAudioPlaybackBuffer->ActivePortsFromNetwork(fRxData, rx_head->fActivePorts);
1002 frames = rx_head->fFrames;
SERVER_EXPORT void jack_error(const char *fmt,...)
SERVER_EXPORT void jack_info(const char *fmt,...)
SERVER_EXPORT void jack_log(const char *fmt,...)