JackNetInterface.cpp 33.1 KB
Newer Older
1
/*
sletz's avatar
sletz committed
2
Copyright (C) 2008-2011 Romain Moret at Grame
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#include "JackNetInterface.h"
#include "JackException.h"
sletz's avatar
sletz committed
21
22
#include "JackError.h"

23
#include <assert.h>
24
25
26

using namespace std;

27
28
29
/*
 TODO : since midi buffers now uses up to BUFFER_SIZE_MAX frames,
 probably also use BUFFER_SIZE_MAX in everything related to MIDI events
30
31
32
 handling (see MidiBufferInit in JackMidiPort.cpp)
*/

33
34
35
36
namespace Jack
{
    // JackNetInterface*******************************************

37
38
    JackNetInterface::JackNetInterface() : fSocket()
    {
sletz's avatar
sletz committed
39
        Initialize();
40
41
    }

sletz's avatar
sletz committed
42
    JackNetInterface::JackNetInterface(const char* multicast_ip, int port) : fSocket(multicast_ip, port)
43
    {
44
        strcpy(fMulticastIP, multicast_ip);
sletz's avatar
sletz committed
45
        Initialize();
46
47
    }

sletz's avatar
sletz committed
48
    JackNetInterface::JackNetInterface(session_params_t& params, JackNetSocket& socket, const char* multicast_ip) : fSocket(socket)
49
    {
moret's avatar
moret committed
50
        fParams = params;
51
        strcpy(fMulticastIP, multicast_ip);
sletz's avatar
sletz committed
52
53
        Initialize();
    }
sletz's avatar
sletz committed
54

sletz's avatar
sletz committed
55
56
    void JackNetInterface::Initialize()
    {
57
        fSetTimeOut = false;
58
59
60
61
62
63
        fTxBuffer = NULL;
        fRxBuffer = NULL;
        fNetAudioCaptureBuffer = NULL;
        fNetAudioPlaybackBuffer = NULL;
        fNetMidiCaptureBuffer = NULL;
        fNetMidiPlaybackBuffer = NULL;
64
65
        memset(&fSendTransportData, 0, sizeof(net_transport_data_t));
        memset(&fReturnTransportData, 0, sizeof(net_transport_data_t));
66
67
    }

sletz's avatar
sletz committed
68
69
70
71
72
73
74
75
76
77
78
    void JackNetInterface::FreeNetworkBuffers()
    {
        delete fNetMidiCaptureBuffer;
        delete fNetMidiPlaybackBuffer;
        delete fNetAudioCaptureBuffer;
        delete fNetAudioPlaybackBuffer;
        fNetMidiCaptureBuffer = NULL;
        fNetMidiPlaybackBuffer = NULL;
        fNetAudioCaptureBuffer = NULL;
        fNetAudioPlaybackBuffer = NULL;
    }
sletz's avatar
sletz committed
79

80
81
    JackNetInterface::~JackNetInterface()
    {
sletz's avatar
sletz committed
82
        jack_log("JackNetInterface::~JackNetInterface");
moret's avatar
moret committed
83

84
85
86
87
88
89
90
91
92
        fSocket.Close();
        delete[] fTxBuffer;
        delete[] fRxBuffer;
        delete fNetAudioCaptureBuffer;
        delete fNetAudioPlaybackBuffer;
        delete fNetMidiCaptureBuffer;
        delete fNetMidiPlaybackBuffer;
    }

moret's avatar
moret committed
93
94
    int JackNetInterface::SetNetBufferSize()
    {
sletz's avatar
sletz committed
95
        // audio
sletz's avatar
sletz committed
96
        float audio_size = (fNetAudioCaptureBuffer)
sletz's avatar
sletz committed
97
98
                        ? fNetAudioCaptureBuffer->GetCycleSize()
                        : (fNetAudioPlaybackBuffer) ? fNetAudioPlaybackBuffer->GetCycleSize() : 0;
sletz's avatar
sletz committed
99
        jack_log("audio_size %f", audio_size);
sletz's avatar
sletz committed
100

sletz's avatar
sletz committed
101
        // midi
sletz's avatar
sletz committed
102
        float midi_size = (fNetMidiCaptureBuffer)
sletz's avatar
sletz committed
103
104
                        ? fNetMidiCaptureBuffer->GetCycleSize()
                        : (fNetMidiPlaybackBuffer) ? fNetMidiPlaybackBuffer->GetCycleSize() : 0;
sletz's avatar
sletz committed
105
        jack_log("midi_size %f", midi_size);
sletz's avatar
sletz committed
106

sletz's avatar
sletz committed
107
108
        // bufsize = sync + audio + midi
        int bufsize = NETWORK_MAX_LATENCY * (fParams.fMtu + (int)audio_size + (int)midi_size);
sletz's avatar
sletz committed
109
        jack_log("SetNetBufferSize bufsize = %d", bufsize);
moret's avatar
moret committed
110

sletz's avatar
sletz committed
111
        // tx buffer
112
        if (fSocket.SetOption(SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize)) == SOCKET_ERROR) {
113
            return SOCKET_ERROR;
114
        }
moret's avatar
moret committed
115

sletz's avatar
sletz committed
116
        // rx buffer
117
        if (fSocket.SetOption(SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize)) == SOCKET_ERROR) {
118
            return SOCKET_ERROR;
119
        }
moret's avatar
moret committed
120

121
        return 0;
moret's avatar
moret committed
122
123
    }

sletz's avatar
sletz committed
124
    bool JackNetInterface::SetParams()
moret's avatar
moret committed
125
    {
sletz's avatar
sletz committed
126
        // TX header init
sletz's avatar
sletz committed
127
        strcpy(fTxHeader.fPacketType, "header");
128
129
130
        fTxHeader.fID = fParams.fID;
        fTxHeader.fCycle = 0;
        fTxHeader.fSubCycle = 0;
moret's avatar
moret committed
131
        fTxHeader.fIsLastPckt = 0;
132

sletz's avatar
sletz committed
133
        // RX header init
sletz's avatar
sletz committed
134
        strcpy(fRxHeader.fPacketType, "header");
135
136
137
        fRxHeader.fID = fParams.fID;
        fRxHeader.fCycle = 0;
        fRxHeader.fSubCycle = 0;
moret's avatar
moret committed
138
        fRxHeader.fIsLastPckt = 0;
139

sletz's avatar
sletz committed
140
        // network buffers
141
142
        fTxBuffer = new char[fParams.fMtu];
        fRxBuffer = new char[fParams.fMtu];
sletz's avatar
sletz committed
143
144
        assert(fTxBuffer);
        assert(fRxBuffer);
145

sletz's avatar
sletz committed
146
        // net audio/midi buffers'addresses
sletz's avatar
sletz committed
147
148
        fTxData = fTxBuffer + HEADER_SIZE;
        fRxData = fRxBuffer + HEADER_SIZE;
sletz's avatar
sletz committed
149

sletz's avatar
sletz committed
150
        return true;
151
152
    }

sletz's avatar
sletz committed
153
154
155
156
157
158
    int JackNetInterface::MidiSend(NetMidiBuffer* buffer, int midi_channnels, int audio_channels)
    {
        if (midi_channnels > 0) {
            // set global header fields and get the number of midi packets
            fTxHeader.fDataType = 'm';
            uint data_size = buffer->RenderFromJackPorts();
159
            fTxHeader.fNumPacket = buffer->GetNumPackets(data_size, PACKET_AVAILABLE_SIZE(&fParams));
sletz's avatar
sletz committed
160
161
162
163
164
165

            for (uint subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
                fTxHeader.fSubCycle = subproc;
                fTxHeader.fIsLastPckt = ((subproc == (fTxHeader.fNumPacket - 1)) && audio_channels == 0) ? 1 : 0;
                fTxHeader.fPacketSize = HEADER_SIZE + buffer->RenderToNetwork(subproc, data_size);
                memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
166
                if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR) {
sletz's avatar
sletz committed
167
                    return SOCKET_ERROR;
168
                }
sletz's avatar
sletz committed
169
170
171
172
173
174
175
176
177
178
            }
        }
        return 0;
    }

    int JackNetInterface::AudioSend(NetAudioBuffer* buffer, int audio_channels)
    {
        // audio
        if (audio_channels > 0) {
            fTxHeader.fDataType = 'a';
sletz's avatar
sletz committed
179
180
            fTxHeader.fActivePorts = buffer->RenderFromJackPorts();
            fTxHeader.fNumPacket = buffer->GetNumPackets(fTxHeader.fActivePorts);
sletz's avatar
sletz committed
181
182
183
184
185
186
187

            for (uint subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
                fTxHeader.fSubCycle = subproc;
                fTxHeader.fIsLastPckt = (subproc == (fTxHeader.fNumPacket - 1)) ? 1 : 0;
                fTxHeader.fPacketSize = HEADER_SIZE + buffer->RenderToNetwork(subproc, fTxHeader.fActivePorts);
                memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
                // PacketHeaderDisplay(&fTxHeader);
188
                if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR) {
sletz's avatar
sletz committed
189
                    return SOCKET_ERROR;
190
                }
sletz's avatar
sletz committed
191
192
193
194
195
196
197
198
199
200
201
            }
        }
        return 0;
    }

    int JackNetInterface::MidiRecv(packet_header_t* rx_head, NetMidiBuffer* buffer, uint& recvd_midi_pckt)
    {
        int rx_bytes = Recv(rx_head->fPacketSize, 0);
        fRxHeader.fCycle = rx_head->fCycle;
        fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
        buffer->RenderFromNetwork(rx_head->fSubCycle, rx_bytes - HEADER_SIZE);
sletz's avatar
sletz committed
202
        
sletz's avatar
sletz committed
203
        // Last midi packet is received, so finish rendering...
204
        if (++recvd_midi_pckt == rx_head->fNumPacket) {
sletz's avatar
sletz committed
205
            buffer->RenderToJackPorts();
206
        }
sletz's avatar
sletz committed
207
208
209
210
211
212
213
214
215
216
        return rx_bytes;
    }

    int JackNetInterface::AudioRecv(packet_header_t* rx_head, NetAudioBuffer* buffer)
    {
        int rx_bytes = Recv(rx_head->fPacketSize, 0);
        fRxHeader.fCycle = rx_head->fCycle;
        fRxHeader.fSubCycle = rx_head->fSubCycle;
        fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
        fRxHeader.fActivePorts = rx_head->fActivePorts;
sletz's avatar
sletz committed
217
        rx_bytes = buffer->RenderFromNetwork(rx_head->fCycle, rx_head->fSubCycle, fRxHeader.fActivePorts);
sletz's avatar
sletz committed
218
        
sletz's avatar
sletz committed
219
        // Last audio packet is received, so finish rendering...
220
        if (fRxHeader.fIsLastPckt) {
sletz's avatar
sletz committed
221
            buffer->RenderToJackPorts();
222
        }
sletz's avatar
sletz committed
223
224
225
226
227
228
229
230
231
        return rx_bytes;
    }

    int JackNetInterface::FinishRecv(NetAudioBuffer* buffer)
    {
        buffer->RenderToJackPorts();
        return NET_PACKET_ERROR;
    }

232
233
234
235
236
237
238
239
240
241
242
    NetAudioBuffer* JackNetInterface::AudioBufferFactory(int nports, char* buffer)
    {
         switch (fParams.fSampleEncoder) {

            case JackFloatEncoder:
                return new NetFloatAudioBuffer(&fParams, nports, buffer);

            case JackIntEncoder:
                return new NetIntAudioBuffer(&fParams, nports, buffer);

            #if HAVE_CELT
sletz's avatar
sletz committed
243
            case JackCeltEncoder:
244
245
                return new NetCeltAudioBuffer(&fParams, nports, buffer, fParams.fKBps);
            #endif
Robin Gareus's avatar
Robin Gareus committed
246
247
248
249
            #if HAVE_OPUS
            case JackOpusEncoder:
                return new NetOpusAudioBuffer(&fParams, nports, buffer, fParams.fKBps);
            #endif
250
251
252
        }
        return NULL;
    }
253
254
255
256
257
258
259
260
261
262
263
    
    void JackNetInterface::SetRcvTimeOut()
    {
        if (!fSetTimeOut) {
            if (fSocket.SetTimeOut(PACKET_TIMEOUT) == SOCKET_ERROR) {
                jack_error("Can't set rx timeout : %s", StrError(NET_ERROR_CODE));
                return;
            }
            fSetTimeOut = true;
        }
    }
264

265
    // JackNetMasterInterface ************************************************************************************
266

267
    bool JackNetMasterInterface::Init()
268
    {
sletz's avatar
sletz committed
269
        jack_log("JackNetMasterInterface::Init : ID %u", fParams.fID);
270

271
        session_params_t host_params;
272
        uint attempt = 0;
273
274
        int rx_bytes = 0;

sletz's avatar
sletz committed
275
        // socket
sletz's avatar
sletz committed
276
277
        if (fSocket.NewSocket() == SOCKET_ERROR) {
            jack_error("Can't create socket : %s", StrError(NET_ERROR_CODE));
278
            return false;
279
280
        }

sletz's avatar
sletz committed
281
        // timeout on receive (for init)
282
283
284
        if (fSocket.SetTimeOut(MASTER_INIT_TIMEOUT) < 0) {
            jack_error("Can't set init timeout : %s", StrError(NET_ERROR_CODE));
        }
285

sletz's avatar
sletz committed
286
        // connect
sletz's avatar
sletz committed
287
288
        if (fSocket.Connect() == SOCKET_ERROR) {
            jack_error("Can't connect : %s", StrError(NET_ERROR_CODE));
289
290
            return false;
        }
291

sletz's avatar
sletz committed
292
        // send 'SLAVE_SETUP' until 'START_MASTER' received
sletz's avatar
sletz committed
293
        jack_info("Sending parameters to %s...", fParams.fSlaveNetName);
294
295
        do
        {
296
            session_params_t net_params;
sletz's avatar
sletz committed
297
298
            memset(&net_params, 0, sizeof(session_params_t));
            SetPacketType(&fParams, SLAVE_SETUP);
299
            SessionParamsHToN(&fParams, &net_params);
300

301
            if (fSocket.Send(&net_params, sizeof(session_params_t), 0) == SOCKET_ERROR) {
sletz's avatar
sletz committed
302
                jack_error("Error in send : %s", StrError(NET_ERROR_CODE));
303
            }
304

sletz's avatar
sletz committed
305
            memset(&net_params, 0, sizeof(session_params_t));
306
            if (((rx_bytes = fSocket.Recv(&net_params, sizeof(session_params_t), 0)) == SOCKET_ERROR) && (fSocket.GetError() != NET_NO_DATA)) {
sletz's avatar
sletz committed
307
                jack_error("Problem with network");
308
                return false;
309
            }
310

311
            SessionParamsNToH(&net_params, &host_params);
312
        }
sletz's avatar
sletz committed
313
        while ((GetPacketType(&host_params) != START_MASTER) && (++attempt < SLAVE_SETUP_RETRY));
sletz's avatar
sletz committed
314
        
sletz's avatar
sletz committed
315
316
        if (attempt == SLAVE_SETUP_RETRY) {
            jack_error("Slave doesn't respond, exiting");
317
            return false;
318
319
        }

320
        return true;
321
322
    }

sletz's avatar
sletz committed
323
    bool JackNetMasterInterface::SetParams()
moret's avatar
moret committed
324
    {
sletz's avatar
sletz committed
325
        jack_log("JackNetMasterInterface::SetParams audio in = %d audio out = %d MIDI in = %d MIDI out = %d",
326
327
            fParams.fSendAudioChannels, fParams.fReturnAudioChannels,
            fParams.fSendMidiChannels, fParams.fReturnMidiChannels);
moret's avatar
moret committed
328
329
330

        JackNetInterface::SetParams();

331
332
        fTxHeader.fDataStream = 's';
        fRxHeader.fDataStream = 'r';
moret's avatar
moret committed
333

sletz's avatar
sletz committed
334
335
336
        fMaxCycleOffset = fParams.fNetworkLatency;

        // midi net buffers
337
        if (fParams.fSendMidiChannels > 0) {
sletz's avatar
sletz committed
338
            fNetMidiCaptureBuffer = new NetMidiBuffer(&fParams, fParams.fSendMidiChannels, fTxData);
339
        }
sletz's avatar
sletz committed
340

341
        if (fParams.fReturnMidiChannels > 0) {
sletz's avatar
sletz committed
342
            fNetMidiPlaybackBuffer = new NetMidiBuffer(&fParams, fParams.fReturnMidiChannels, fRxData);
343
        }
sletz's avatar
sletz committed
344

sletz's avatar
sletz committed
345
        try {
sletz's avatar
sletz committed
346

sletz's avatar
sletz committed
347
            // audio net buffers
sletz's avatar
sletz committed
348
            if (fParams.fSendAudioChannels > 0) {
349
                fNetAudioCaptureBuffer = AudioBufferFactory(fParams.fSendAudioChannels, fTxData);
sletz's avatar
sletz committed
350
351
                assert(fNetAudioCaptureBuffer);
            }
sletz's avatar
sletz committed
352

sletz's avatar
sletz committed
353
            if (fParams.fReturnAudioChannels > 0) {
354
                fNetAudioPlaybackBuffer = AudioBufferFactory(fParams.fReturnAudioChannels, fRxData);
sletz's avatar
sletz committed
355
356
                assert(fNetAudioPlaybackBuffer);
            }
sletz's avatar
sletz committed
357

sletz's avatar
sletz committed
358
359
360
361
        } catch (exception&) {
            jack_error("NetAudioBuffer allocation error...");
            return false;
        }
moret's avatar
moret committed
362

sletz's avatar
sletz committed
363
        // set the new rx buffer size
sletz's avatar
sletz committed
364
365
        if (SetNetBufferSize() == SOCKET_ERROR) {
            jack_error("Can't set net buffer sizes : %s", StrError(NET_ERROR_CODE));
sletz's avatar
sletz committed
366
367
            goto error;
        }
sletz's avatar
sletz committed
368

sletz's avatar
sletz committed
369
        return true;
sletz's avatar
sletz committed
370

sletz's avatar
sletz committed
371
    error:
sletz's avatar
sletz committed
372
        FreeNetworkBuffers();
sletz's avatar
sletz committed
373
        return false;
moret's avatar
moret committed
374
375
    }

376
    void JackNetMasterInterface::Exit()
377
    {
sletz's avatar
sletz committed
378
        jack_log("JackNetMasterInterface::Exit, ID %u", fParams.fID);
379

sletz's avatar
sletz committed
380
        // stop process
381
        fRunning = false;
382

sletz's avatar
sletz committed
383
        // send a 'multicast euthanasia request' - new socket is required on macosx
sletz's avatar
sletz committed
384
385
386
        jack_info("Exiting '%s'", fParams.fName);
        SetPacketType(&fParams, KILL_MASTER);
        JackNetSocket mcast_socket(fMulticastIP, fSocket.GetPort());
387

388
        session_params_t net_params;
sletz's avatar
sletz committed
389
        memset(&net_params, 0, sizeof(session_params_t));
390
391
        SessionParamsHToN(&fParams, &net_params);

392
        if (mcast_socket.NewSocket() == SOCKET_ERROR) {
sletz's avatar
sletz committed
393
            jack_error("Can't create socket : %s", StrError(NET_ERROR_CODE));
394
395
        }
        if (mcast_socket.SendTo(&net_params, sizeof(session_params_t), 0, fMulticastIP) == SOCKET_ERROR) {
sletz's avatar
sletz committed
396
            jack_error("Can't send suicide request : %s", StrError(NET_ERROR_CODE));
397
        }
398

399
400
401
        mcast_socket.Close();
    }

402
    void JackNetMasterInterface::FatalRecvError()
sletz's avatar
sletz committed
403
    {
sletz's avatar
sletz committed
404
        // fatal connection issue, exit
405
406
407
408
409
410
411
412
413
414
415
        jack_error("Recv connection lost error = %s, '%s' exiting", StrError(NET_ERROR_CODE), fParams.fName);
        // ask to the manager to properly remove the master
        Exit();
        // UGLY temporary way to be sure the thread does not call code possibly causing a deadlock in JackEngine.
        ThreadExit();
    }

     void JackNetMasterInterface::FatalSendError()
    {
        // fatal connection issue, exit
        jack_error("Send connection lost error = %s, '%s' exiting", StrError(NET_ERROR_CODE), fParams.fName);
sletz's avatar
sletz committed
416
        // ask to the manager to properly remove the master
sletz's avatar
sletz committed
417
418
419
420
421
        Exit();
        // UGLY temporary way to be sure the thread does not call code possibly causing a deadlock in JackEngine.
        ThreadExit();
    }

sletz's avatar
sletz committed
422
    int JackNetMasterInterface::Recv(size_t size, int flags)
423
    {
424
        int rx_bytes;
sletz's avatar
sletz committed
425

sletz's avatar
sletz committed
426
        if (((rx_bytes = fSocket.Recv(fRxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
427
            FatalRecvError();
428
        }
429

430
431
432
        packet_header_t* header = reinterpret_cast<packet_header_t*>(fRxBuffer);
        PacketHeaderNToH(header, header);
        return rx_bytes;
433
    }
434

sletz's avatar
sletz committed
435
    int JackNetMasterInterface::Send(size_t size, int flags)
436
    {
437
438
439
        int tx_bytes;
        packet_header_t* header = reinterpret_cast<packet_header_t*>(fTxBuffer);
        PacketHeaderHToN(header, header);
440

sletz's avatar
sletz committed
441
        if (((tx_bytes = fSocket.Send(fTxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
442
            FatalSendError();
443
        }
444
        return tx_bytes;
445
    }
446

447
448
    bool JackNetMasterInterface::IsSynched()
    {
sletz's avatar
sletz committed
449
        return (fCurrentCycleOffset <= fMaxCycleOffset);
450
    }
451

452
    int JackNetMasterInterface::SyncSend()
453
    {
454
455
        SetRcvTimeOut();
        
456
457
458
        fTxHeader.fCycle++;
        fTxHeader.fSubCycle = 0;
        fTxHeader.fDataType = 's';
459
        fTxHeader.fIsLastPckt = (fParams.fSendMidiChannels == 0 && fParams.fSendAudioChannels == 0) ? 1 : 0;
sletz's avatar
sletz committed
460
        fTxHeader.fPacketSize = fParams.fMtu;
sletz's avatar
sletz committed
461

sletz's avatar
sletz committed
462
        memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
sletz's avatar
sletz committed
463
        // PacketHeaderDisplay(&fTxHeader);
sletz's avatar
sletz committed
464
        return Send(fTxHeader.fPacketSize, 0);
465
466
467
468
    }

    int JackNetMasterInterface::DataSend()
    {
469
        if (MidiSend(fNetMidiCaptureBuffer, fParams.fSendMidiChannels, fParams.fSendAudioChannels) == SOCKET_ERROR) {
sletz's avatar
sletz committed
470
            return SOCKET_ERROR;
471
        }
sletz's avatar
sletz committed
472
        return AudioSend(fNetAudioCaptureBuffer, fParams.fSendAudioChannels);
473
474
    }

475
    int JackNetMasterInterface::SyncRecv()
476
    {
sletz's avatar
sletz committed
477
        int rx_bytes = 0;
sletz's avatar
sletz committed
478
        packet_header_t* rx_head = reinterpret_cast<packet_header_t*>(fRxBuffer);
sletz's avatar
sletz committed
479
480
481
482
483
484
485
486
487
488
489

        // receive sync (launch the cycle)
        do {
            rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
            // connection issue, send will detect it, so don't skip the cycle (return 0)
            if (rx_bytes == SOCKET_ERROR) {
                return SOCKET_ERROR;
            }
        }
        while ((strcmp(rx_head->fPacketType, "header") != 0) && (rx_head->fDataType != 's'));

sletz's avatar
sletz committed
490
        fCurrentCycleOffset = fTxHeader.fCycle - rx_head->fCycle;
491

sletz's avatar
sletz committed
492
493
        if (fCurrentCycleOffset < fMaxCycleOffset) {
            jack_info("Synching with latency = %d", fCurrentCycleOffset);
494
495
496
            return 0;
        } else {
            rx_bytes = Recv(rx_head->fPacketSize, 0);
497
498
            fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
            return rx_bytes;
499
        }
500
    }
501

502
    int JackNetMasterInterface::DataRecv()
503
504
    {
        int rx_bytes = 0;
505
        uint recvd_midi_pckt = 0;
sletz's avatar
sletz committed
506
        packet_header_t* rx_head = reinterpret_cast<packet_header_t*>(fRxBuffer);
507

sletz's avatar
sletz committed
508
509
        while (!fRxHeader.fIsLastPckt) {
            // how much data is queued on the rx buffer ?
sletz's avatar
sletz committed
510
            rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
sletz's avatar
sletz committed
511
         
sletz's avatar
sletz committed
512
            // error here, problem with recv, just skip the cycle (return -1)
513
            if (rx_bytes == SOCKET_ERROR) {
moret's avatar
moret committed
514
                return rx_bytes;
515
            }
sletz's avatar
sletz committed
516

sletz's avatar
sletz committed
517
518
519
520
521
522
            if (rx_bytes && (rx_head->fDataStream == 'r') && (rx_head->fID == fParams.fID)) {
                // read data
                switch (rx_head->fDataType) {

                    case 'm':   // midi
                        rx_bytes = MidiRecv(rx_head, fNetMidiPlaybackBuffer, recvd_midi_pckt);
moret's avatar
moret committed
523
                        break;
524

sletz's avatar
sletz committed
525
526
                    case 'a':   // audio
                        rx_bytes = AudioRecv(rx_head, fNetAudioPlaybackBuffer);
moret's avatar
moret committed
527
                        break;
528

sletz's avatar
sletz committed
529
                    case 's':   // sync
530
                        jack_info("NetMaster : overloaded, skipping receive from '%s'", fParams.fName);
sletz's avatar
sletz committed
531
                        return FinishRecv(fNetAudioPlaybackBuffer);
532
533
534
                }
            }
        }
sletz's avatar
sletz committed
535
   
536
        return rx_bytes;
537
    }
538

539
    void JackNetMasterInterface::EncodeSyncPacket()
540
    {
sletz's avatar
sletz committed
541
        // This method contains every step of sync packet informations coding
sletz's avatar
sletz committed
542
        // first of all, clear sync packet
543
        memset(fTxData, 0, PACKET_AVAILABLE_SIZE(&fParams));
544

sletz's avatar
sletz committed
545
        // then, first step : transport
546
        if (fParams.fTransportSync) {
sletz's avatar
sletz committed
547
            EncodeTransportData();
sletz's avatar
sletz committed
548
            TransportDataHToN(&fSendTransportData, &fSendTransportData);
sletz's avatar
sletz committed
549
            // copy to TxBuffer
sletz's avatar
sletz committed
550
            memcpy(fTxData, &fSendTransportData, sizeof(net_transport_data_t));
551
        }
sletz's avatar
sletz committed
552
553
        // then others (freewheel etc.)
        // ...
sletz's avatar
sletz committed
554
555
556
557

        // Transport not used for now...

        // Write active ports list
sletz's avatar
sletz committed
558
        fTxHeader.fActivePorts = (fNetAudioPlaybackBuffer) ? fNetAudioPlaybackBuffer->ActivePortsToNetwork(fTxData) : 0;
559
560
    }

561
    void JackNetMasterInterface::DecodeSyncPacket()
562
    {
sletz's avatar
sletz committed
563
564
        // This method contains every step of sync packet informations decoding process
        // first : transport
565
        if (fParams.fTransportSync) {
sletz's avatar
sletz committed
566
            // copy received transport data to transport data structure
sletz's avatar
sletz committed
567
568
            memcpy(&fReturnTransportData, fRxData, sizeof(net_transport_data_t));
            TransportDataNToH(&fReturnTransportData,  &fReturnTransportData);
sletz's avatar
sletz committed
569
            DecodeTransportData();
570
        }
sletz's avatar
sletz committed
571
572
        // then others
        // ...
sletz's avatar
sletz committed
573
574
575
576
577
578
579
580

        // Transport not used for now...
        packet_header_t* rx_head = reinterpret_cast<packet_header_t*>(fRxBuffer);

        // Read active ports list
        if (fNetAudioCaptureBuffer) {
            fNetAudioCaptureBuffer->ActivePortsFromNetwork(fRxData, rx_head->fActivePorts);
        }
581
    }
582

583
584
// JackNetSlaveInterface ************************************************************************************************

moret's avatar
moret committed
585
586
    uint JackNetSlaveInterface::fSlaveCounter = 0;

sletz's avatar
sletz committed
587
588
589
590
591
592
593
594
595
596
597
    void JackNetSlaveInterface::InitAPI()
    {
        // open Socket API with the first slave
        if (fSlaveCounter++ == 0) {
            if (SocketAPIInit() < 0) {
                jack_error("Can't init Socket API, exiting...");
                throw std::bad_alloc();
            }
        }
    }

598
    bool JackNetSlaveInterface::Init()
599
    {
sletz's avatar
sletz committed
600
        jack_log("JackNetSlaveInterface::Init()");
601

sletz's avatar
sletz committed
602
        // set the parameters to send
sletz's avatar
sletz committed
603
        strcpy(fParams.fPacketType, "params");
604
        fParams.fProtocolVersion = SLAVE_PROTOCOL;
sletz's avatar
sletz committed
605
        SetPacketType(&fParams, SLAVE_AVAILABLE);
606

sletz's avatar
sletz committed
607
        // init loop : get a master and start, do it until connection is ok
608
        net_status_t status;
609
        do {
sletz's avatar
sletz committed
610
            // first, get a master, do it until a valid connection is running
611
            do {
612
                status = SendAvailableToMaster();
613
                if (status == NET_SOCKET_ERROR) {
614
                    return false;
615
                }
616
            }
sletz's avatar
sletz committed
617
            while (status != NET_CONNECTED);
618

sletz's avatar
sletz committed
619
            // then tell the master we are ready
sletz's avatar
sletz committed
620
            jack_info("Initializing connection with %s...", fParams.fMasterNetName);
moret's avatar
moret committed
621
            status = SendStartToMaster();
622
            if (status == NET_ERROR) {
623
                return false;
624
            }
625
        }
sletz's avatar
sletz committed
626
        while (status != NET_ROLLING);
627

628
629
        return true;
    }
630

631
    // Separate the connection protocol into two separated step
sletz's avatar
sletz committed
632
    bool JackNetSlaveInterface::InitConnection(int time_out_sec)
633
    {
sletz's avatar
sletz committed
634
        jack_log("JackNetSlaveInterface::InitConnection()");
635
        uint try_count = (time_out_sec > 0) ? ((1000000 * time_out_sec) / SLAVE_INIT_TIMEOUT) : UINT_MAX;
636

sletz's avatar
sletz committed
637
        // set the parameters to send
sletz's avatar
sletz committed
638
        strcpy(fParams.fPacketType, "params");
639
        fParams.fProtocolVersion = SLAVE_PROTOCOL;
sletz's avatar
sletz committed
640
        SetPacketType(&fParams, SLAVE_AVAILABLE);
641
642

        net_status_t status;
643
        do {
sletz's avatar
sletz committed
644
            // get a master
sletz's avatar
sletz committed
645
            status = SendAvailableToMaster(try_count);
646
            if (status == NET_SOCKET_ERROR) {
647
                return false;
648
            }
649
        }
sletz's avatar
sletz committed
650
        while (status != NET_CONNECTED && --try_count > 0);
651

sletz's avatar
sletz committed
652
        return (try_count != 0);
653
    }
654

655
656
657
658
659
    bool JackNetSlaveInterface::InitRendering()
    {
        jack_log("JackNetSlaveInterface::InitRendering()");

        net_status_t status;
660
        do {
sletz's avatar
sletz committed
661
            // then tell the master we are ready
662
663
            jack_info("Initializing connection with %s...", fParams.fMasterNetName);
            status = SendStartToMaster();
sletz's avatar
sletz committed
664
            if (status == NET_ERROR) {
665
                return false;
sletz's avatar
sletz committed
666
            }
667
        }
668
669
        while (status != NET_ROLLING);

670
671
        return true;
    }
672

sletz's avatar
sletz committed
673
    net_status_t JackNetSlaveInterface::SendAvailableToMaster(long try_count)
674
    {
sletz's avatar
sletz committed
675
        jack_log("JackNetSlaveInterface::SendAvailableToMaster()");
sletz's avatar
sletz committed
676
        // utility
677
        session_params_t host_params;
678
679
        int rx_bytes = 0;

sletz's avatar
sletz committed
680
        // socket
sletz's avatar
sletz committed
681
682
        if (fSocket.NewSocket() == SOCKET_ERROR) {
            jack_error("Fatal error : network unreachable - %s", StrError(NET_ERROR_CODE));
683
            return NET_SOCKET_ERROR;
684
685
        }

sletz's avatar
sletz committed
686
687
688
689
690
691
692
693
        if (fSocket.IsLocal(fMulticastIP)) {
            jack_info("Local IP is used...");
        } else {
            // bind the socket
            if (fSocket.Bind() == SOCKET_ERROR) {
                jack_error("Can't bind the socket : %s", StrError(NET_ERROR_CODE));
                return NET_SOCKET_ERROR;
            }
694
        }
695

696
697
698
699
        // timeout on receive (for init)
        if (fSocket.SetTimeOut(SLAVE_INIT_TIMEOUT) == SOCKET_ERROR) {
            jack_error("Can't set init timeout : %s", StrError(NET_ERROR_CODE));
        }
700

sletz's avatar
sletz committed
701
        // disable local loop
702
        if (fSocket.SetLocalLoop() == SOCKET_ERROR) {
sletz's avatar
sletz committed
703
            jack_error("Can't disable multicast loop : %s", StrError(NET_ERROR_CODE));
704
        }
705

sletz's avatar
sletz committed
706
        // send 'AVAILABLE' until 'SLAVE_SETUP' received
sletz's avatar
sletz committed
707
        jack_info("Waiting for a master...");
708
        do {
sletz's avatar
sletz committed
709
            // send 'available'
710
            session_params_t net_params;
sletz's avatar
sletz committed
711
            memset(&net_params, 0, sizeof(session_params_t));
712
            SessionParamsHToN(&fParams, &net_params);
sletz's avatar
sletz committed
713
            if (fSocket.SendTo(&net_params, sizeof(session_params_t), 0, fMulticastIP) == SOCKET_ERROR) {
sletz's avatar
sletz committed
714
                jack_error("Error in data send : %s", StrError(NET_ERROR_CODE));
sletz's avatar
sletz committed
715
            }
716

sletz's avatar
sletz committed
717
            // filter incoming packets : don't exit while no error is detected
sletz's avatar
sletz committed
718
719
            memset(&net_params, 0, sizeof(session_params_t));
            rx_bytes = fSocket.CatchHost(&net_params, sizeof(session_params_t), 0);
720
            SessionParamsNToH(&net_params, &host_params);
721
            if ((rx_bytes == SOCKET_ERROR) && (fSocket.GetError() != NET_NO_DATA)) {
sletz's avatar
sletz committed
722
                jack_error("Can't receive : %s", StrError(NET_ERROR_CODE));
723
                return NET_RECV_ERROR;
724
725
            }
        }
sletz's avatar
sletz committed
726
        while (strcmp(host_params.fPacketType, fParams.fPacketType)  && (GetPacketType(&host_params) != SLAVE_SETUP)  && (--try_count > 0));
sletz's avatar
sletz committed
727

sletz's avatar
sletz committed
728
        // Time out failure..
sletz's avatar
sletz committed
729
730
        if (try_count == 0) {
            jack_error("Time out error in connect");
sletz's avatar
sletz committed
731
732
            return NET_CONNECT_ERROR;
        }
733

sletz's avatar
sletz committed
734
        // everything is OK, copy parameters
735
        fParams = host_params;
moret's avatar
moret committed
736

sletz's avatar
sletz committed
737
        // connect the socket
sletz's avatar
sletz committed
738
739
        if (fSocket.Connect() == SOCKET_ERROR) {
            jack_error("Error in connect : %s", StrError(NET_ERROR_CODE));
740
            return NET_CONNECT_ERROR;
741
        }
moret's avatar
moret committed
742
        return NET_CONNECTED;
743
744
    }

moret's avatar
moret committed
745
    net_status_t JackNetSlaveInterface::SendStartToMaster()
746
    {
sletz's avatar
sletz committed
747
        jack_log("JackNetSlaveInterface::SendStartToMaster");
moret's avatar
moret committed
748

sletz's avatar
sletz committed
749
        // tell the master to start
750
        session_params_t net_params;
sletz's avatar
sletz committed
751
752
        memset(&net_params, 0, sizeof(session_params_t));
        SetPacketType(&fParams, START_MASTER);
753
        SessionParamsHToN(&fParams, &net_params);
754
        if (fSocket.Send(&net_params, sizeof(session_params_t), 0) == SOCKET_ERROR) {
sletz's avatar
sletz committed
755
756
            jack_error("Error in send : %s", StrError(NET_ERROR_CODE));
            return (fSocket.GetError() == NET_CONN_ERROR) ? NET_ERROR : NET_SEND_ERROR;
757
        }
758
        return NET_ROLLING;
759
760
    }

sletz's avatar
sletz committed
761
    bool JackNetSlaveInterface::SetParams()
moret's avatar
moret committed
762
    {
sletz's avatar
sletz committed
763
        jack_log("JackNetSlaveInterface::SetParams audio in = %d audio out = %d MIDI in = %d MIDI out = %d",
sletz's avatar
sletz committed
764
765
                fParams.fSendAudioChannels, fParams.fReturnAudioChannels,
                fParams.fSendMidiChannels, fParams.fReturnMidiChannels);
moret's avatar
moret committed
766
767
768

        JackNetInterface::SetParams();

769
770
        fTxHeader.fDataStream = 'r';
        fRxHeader.fDataStream = 's';
moret's avatar
moret committed
771

sletz's avatar
sletz committed
772
        // midi net buffers
773
        if (fParams.fSendMidiChannels > 0) {
sletz's avatar
sletz committed
774
            fNetMidiCaptureBuffer = new NetMidiBuffer(&fParams, fParams.fSendMidiChannels, fRxData);
775
        }
sletz's avatar
sletz committed
776

777
        if (fParams.fReturnMidiChannels > 0) {
sletz's avatar
sletz committed
778
            fNetMidiPlaybackBuffer = new NetMidiBuffer(&fParams, fParams.fReturnMidiChannels, fTxData);