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

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"
22
#include "JackPlatformPlug.h"
23
#include <assert.h>
24
25
26

using namespace std;

sletz's avatar
sletz committed
27
#define PACKET_AVAILABLE_SIZE (fParams.fMtu - sizeof(packet_header_t))
sletz's avatar
sletz committed
28
#define HEADER_SIZE (sizeof(packet_header_t))
sletz's avatar
sletz committed
29

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

36
37
38
39
namespace Jack
{
    // JackNetInterface*******************************************

40
41
    JackNetInterface::JackNetInterface() : fSocket()
    {
sletz's avatar
sletz committed
42
        Initialize();
43
44
    }

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

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

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

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

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

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

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

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

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

        //tx buffer
sletz's avatar
sletz committed
114
        if (fSocket.SetOption(SOL_SOCKET, SO_SNDBUF, &bufsize, sizeof(bufsize)) == SOCKET_ERROR)
115
            return SOCKET_ERROR;
moret's avatar
moret committed
116
117

        //rx buffer
sletz's avatar
sletz committed
118
        if (fSocket.SetOption(SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize)) == SOCKET_ERROR)
119
            return SOCKET_ERROR;
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
    {
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
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
140
141
142

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

moret's avatar
moret 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
    }

153
    // JackNetMasterInterface ************************************************************************************
154

155
    bool JackNetMasterInterface::Init()
156
    {
sletz's avatar
sletz committed
157
        jack_log("JackNetMasterInterface::Init, ID %u", fParams.fID);
158

159
        session_params_t host_params;
160
        uint attempt = 0;
161
162
163
        int rx_bytes = 0;

        //socket
sletz's avatar
sletz committed
164
165
        if (fSocket.NewSocket() == SOCKET_ERROR) {
            jack_error("Can't create socket : %s", StrError(NET_ERROR_CODE));
166
            return false;
167
168
        }

169
        //timeout on receive (for init)
sletz's avatar
sletz committed
170
171
        if (fSocket.SetTimeOut(MASTER_INIT_TIMEOUT) < 0)
            jack_error("Can't set timeout : %s", StrError(NET_ERROR_CODE));
172

173
        //connect
sletz's avatar
sletz committed
174
175
        if (fSocket.Connect() == SOCKET_ERROR) {
            jack_error("Can't connect : %s", StrError(NET_ERROR_CODE));
176
177
            return false;
        }
178

179
        //send 'SLAVE_SETUP' until 'START_MASTER' received
sletz's avatar
sletz committed
180
        jack_info("Sending parameters to %s...", fParams.fSlaveNetName);
181
182
        do
        {
183
            session_params_t net_params;
sletz's avatar
sletz committed
184
185
            memset(&net_params, 0, sizeof(session_params_t));
            SetPacketType(&fParams, SLAVE_SETUP);
186
            SessionParamsHToN(&fParams, &net_params);
187

sletz's avatar
sletz committed
188
            if (fSocket.Send(&net_params, sizeof(session_params_t), 0) == SOCKET_ERROR)
sletz's avatar
sletz committed
189
                jack_error("Error in send : %s", StrError(NET_ERROR_CODE));
190

sletz's avatar
sletz committed
191
            memset(&net_params, 0, sizeof(session_params_t));
sletz's avatar
sletz committed
192
            if (((rx_bytes = fSocket.Recv(&net_params, sizeof(session_params_t), 0)) == SOCKET_ERROR) && (fSocket.GetError() != NET_NO_DATA))
193
            {
sletz's avatar
sletz committed
194
                jack_error("Problem with network");
195
                return false;
196
            }
197

198
            SessionParamsNToH(&net_params, &host_params);
199
        }
sletz's avatar
sletz committed
200
201
202
        while ((GetPacketType(&host_params) != START_MASTER) && (++attempt < SLAVE_SETUP_RETRY));
        if (attempt == SLAVE_SETUP_RETRY) {
            jack_error("Slave doesn't respond, exiting");
203
            return false;
204
205
        }

206
        return true;
207
208
    }

sletz's avatar
sletz committed
209
    /*
moret's avatar
moret committed
210
211
    int JackNetMasterInterface::SetRxTimeout()
    {
sletz's avatar
sletz committed
212
        jack_log("JackNetMasterInterface::SetRxTimeout");
moret's avatar
moret committed
213

moret's avatar
moret committed
214
        float time = 0;
sletz's avatar
sletz committed
215

moret's avatar
moret committed
216
        //slow or normal mode, short timeout on recv (2 audio subcycles)
sletz's avatar
sletz committed
217
        if ((fParams.fNetworkMode == 's') || (fParams.fNetworkMode == 'n')) {
sletz's avatar
sletz committed
218
219
            time = 2000000.f * ((fNetAudioCaptureBuffer)
                                ? fNetAudioCaptureBuffer->GetCycleDuration()
sletz's avatar
sletz committed
220
221
                                : (fNetAudioPlaybackBuffer) ? fNetAudioPlaybackBuffer->GetCycleDuration() : 0);
        }
moret's avatar
moret committed
222
        //fast mode, wait for 75% of the entire cycle duration
sletz's avatar
sletz committed
223
224
225
        else if (fParams.fNetworkMode == 'f') {
            time = 750000.f * (static_cast<float>(fParams.fPeriodSize) / static_cast<float>(fParams.fSampleRate));
        }
sletz's avatar
sletz committed
226

sletz's avatar
sletz committed
227
        return fSocket.SetTimeOut(static_cast<int>(time));
moret's avatar
moret committed
228
    }
sletz's avatar
sletz committed
229
230
    */

sletz's avatar
sletz committed
231
232
233
234
235
236
    int JackNetMasterInterface::SetRxTimeout()
    {
        jack_log("JackNetMasterInterface::SetRxTimeout");
        float time = 3 * 1000000.f * (static_cast<float>(fParams.fPeriodSize) / static_cast<float>(fParams.fSampleRate));
        return fSocket.SetTimeOut(static_cast<int>(time));
    }
moret's avatar
moret committed
237

sletz's avatar
sletz committed
238
    bool JackNetMasterInterface::SetParams()
moret's avatar
moret committed
239
    {
sletz's avatar
sletz committed
240
241
        jack_log("JackNetMasterInterface::SetParams audio in = %d audio out = %d MIDI in = %d MIDI out = %d",
            fParams.fSendAudioChannels, fParams.fReturnAudioChannels, fParams.fSendMidiChannels, fParams.fReturnMidiChannels);
moret's avatar
moret committed
242
243
244

        JackNetInterface::SetParams();

245
246
        fTxHeader.fDataStream = 's';
        fRxHeader.fDataStream = 'r';
moret's avatar
moret committed
247
248

        //midi net buffers
sletz's avatar
sletz committed
249
        if (fParams.fSendMidiChannels > 0)
sletz's avatar
sletz committed
250
            fNetMidiCaptureBuffer = new NetMidiBuffer(&fParams, fParams.fSendMidiChannels, fTxData);
sletz's avatar
sletz committed
251

sletz's avatar
sletz committed
252
        if (fParams.fReturnMidiChannels > 0)
sletz's avatar
sletz committed
253
            fNetMidiPlaybackBuffer = new NetMidiBuffer(&fParams, fParams.fReturnMidiChannels, fRxData);
sletz's avatar
sletz committed
254

sletz's avatar
sletz committed
255
        try {
sletz's avatar
sletz committed
256

257
            //audio net buffers
sletz's avatar
sletz committed
258
            if (fParams.fSendAudioChannels > 0) {
sletz's avatar
sletz committed
259

260
                switch (fParams.fSampleEncoder) {
sletz's avatar
sletz committed
261

262
                    case JackFloatEncoder:
sletz's avatar
sletz committed
263
                        fNetAudioCaptureBuffer = new NetFloatAudioBuffer(&fParams, fParams.fSendAudioChannels, fTxData);
264
                        break;
sletz's avatar
sletz committed
265

266
                    case JackIntEncoder:
sletz's avatar
sletz committed
267
                        fNetAudioCaptureBuffer = new NetIntAudioBuffer(&fParams, fParams.fSendAudioChannels, fTxData);
268
                        break;
sletz's avatar
sletz committed
269

270
                    case JackCeltEncoder:
nedko's avatar
nedko committed
271
                    #if HAVE_CELT
sletz's avatar
sletz committed
272
                        fNetAudioCaptureBuffer = new NetCeltAudioBuffer(&fParams, fParams.fSendAudioChannels, fTxData, fParams.fKBps);
273
274
275
                    #endif
                        break;
                }
sletz's avatar
sletz committed
276

sletz's avatar
sletz committed
277
278
                assert(fNetAudioCaptureBuffer);
            }
sletz's avatar
sletz committed
279

sletz's avatar
sletz committed
280
            if (fParams.fReturnAudioChannels > 0) {
sletz's avatar
sletz committed
281

282
                switch (fParams.fSampleEncoder) {
sletz's avatar
sletz committed
283

284
                    case JackFloatEncoder:
sletz's avatar
sletz committed
285
                        fNetAudioPlaybackBuffer = new NetFloatAudioBuffer(&fParams, fParams.fReturnAudioChannels, fRxData);
286
                        break;
sletz's avatar
sletz committed
287

288
                    case JackIntEncoder:
sletz's avatar
sletz committed
289
                        fNetAudioPlaybackBuffer = new NetIntAudioBuffer(&fParams, fParams.fReturnAudioChannels, fRxData);
290
                        break;
sletz's avatar
sletz committed
291

292
                    case JackCeltEncoder:
nedko's avatar
nedko committed
293
                    #if HAVE_CELT
sletz's avatar
sletz committed
294
                        fNetAudioPlaybackBuffer = new NetCeltAudioBuffer(&fParams, fParams.fReturnAudioChannels, fRxData, fParams.fKBps);
295
296
297
                    #endif
                        break;
                }
sletz's avatar
sletz committed
298

sletz's avatar
sletz committed
299
300
                assert(fNetAudioPlaybackBuffer);
            }
sletz's avatar
sletz committed
301

sletz's avatar
sletz committed
302
303
304
305
        } catch (exception&) {
            jack_error("NetAudioBuffer allocation error...");
            return false;
        }
moret's avatar
moret committed
306

sletz's avatar
sletz committed
307
        //set the new timeout for the socket
sletz's avatar
sletz committed
308
309
        if (SetRxTimeout() == SOCKET_ERROR) {
            jack_error("Can't set rx timeout : %s", StrError(NET_ERROR_CODE));
sletz's avatar
sletz committed
310
            goto error;
sletz's avatar
sletz committed
311
        }
moret's avatar
moret committed
312

sletz's avatar
sletz committed
313
        //set the new rx buffer size
sletz's avatar
sletz committed
314
315
        if (SetNetBufferSize() == SOCKET_ERROR) {
            jack_error("Can't set net buffer sizes : %s", StrError(NET_ERROR_CODE));
sletz's avatar
sletz committed
316
317
            goto error;
        }
sletz's avatar
sletz committed
318

sletz's avatar
sletz committed
319
        return true;
sletz's avatar
sletz committed
320

sletz's avatar
sletz committed
321
    error:
sletz's avatar
sletz committed
322
        FreeNetworkBuffers();
sletz's avatar
sletz committed
323
        return false;
moret's avatar
moret committed
324
325
    }

326
    void JackNetMasterInterface::Exit()
327
    {
sletz's avatar
sletz committed
328
        jack_log("JackNetMasterInterface::Exit, ID %u", fParams.fID);
329
330
331

        //stop process
        fRunning = false;
332

333
        //send a 'multicast euthanasia request' - new socket is required on macosx
sletz's avatar
sletz committed
334
335
336
        jack_info("Exiting '%s'", fParams.fName);
        SetPacketType(&fParams, KILL_MASTER);
        JackNetSocket mcast_socket(fMulticastIP, fSocket.GetPort());
337

338
        session_params_t net_params;
sletz's avatar
sletz committed
339
        memset(&net_params, 0, sizeof(session_params_t));
340
341
        SessionParamsHToN(&fParams, &net_params);

sletz's avatar
sletz committed
342
343
344
345
        if (mcast_socket.NewSocket() == SOCKET_ERROR)
            jack_error("Can't create socket : %s", StrError(NET_ERROR_CODE));
        if (mcast_socket.SendTo(&net_params, sizeof(session_params_t), 0, fMulticastIP) == SOCKET_ERROR)
            jack_error("Can't send suicide request : %s", StrError(NET_ERROR_CODE));
346

347
348
349
        mcast_socket.Close();
    }

sletz's avatar
sletz committed
350
351
352
353
354
355
356
357
358
359
    void JackNetMasterInterface::FatalError()
    {
        //fatal connection issue, exit
        jack_error("'%s' : %s, exiting", fParams.fName, StrError(NET_ERROR_CODE));
        //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();
    }

sletz's avatar
sletz committed
360
    int JackNetMasterInterface::Recv(size_t size, int flags)
361
    {
362
        int rx_bytes;
sletz's avatar
sletz committed
363

sletz's avatar
sletz committed
364
        if (((rx_bytes = fSocket.Recv(fRxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
365
366

            /*
367
            net_error_t error = fSocket.GetError();
sletz's avatar
sletz committed
368
            //no data isn't really a network error, so just return 0 available read bytes
sletz's avatar
sletz committed
369
            if (error == NET_NO_DATA) {
370
                return 0;
sletz's avatar
sletz committed
371
            } else if (error == NET_CONN_ERROR) {
sletz's avatar
sletz committed
372
                FatalError();
sletz's avatar
sletz committed
373
            } else {
sletz's avatar
sletz committed
374
                jack_error("Error in master receive : %s", StrError(NET_ERROR_CODE));
375
            }
376
377
            */

sletz's avatar
sletz committed
378
            FatalError();
379
        }
380

381
382
383
        packet_header_t* header = reinterpret_cast<packet_header_t*>(fRxBuffer);
        PacketHeaderNToH(header, header);
        return rx_bytes;
384
    }
385

sletz's avatar
sletz committed
386
    int JackNetMasterInterface::Send(size_t size, int flags)
387
    {
388
389
390
        int tx_bytes;
        packet_header_t* header = reinterpret_cast<packet_header_t*>(fTxBuffer);
        PacketHeaderHToN(header, header);
391

sletz's avatar
sletz committed
392
        if (((tx_bytes = fSocket.Send(fTxBuffer, size, flags)) == SOCKET_ERROR) && fRunning) {
sletz's avatar
sletz committed
393
            /*
394
            net_error_t error = fSocket.GetError();
sletz's avatar
sletz committed
395
            if (error == NET_CONN_ERROR) {
sletz's avatar
sletz committed
396
                FatalError();
sletz's avatar
sletz committed
397
398
            } else {
                jack_error("Error in master send : %s", StrError(NET_ERROR_CODE));
399
            }
sletz's avatar
sletz committed
400
401
            */
            FatalError();
402
        }
403
        return tx_bytes;
404
    }
405

406
407
    bool JackNetMasterInterface::IsSynched()
    {
sletz's avatar
sletz committed
408
        if (fParams.fNetworkMode == 's') {
409
            return (fCycleOffset < (CYCLE_OFFSET_SLOW + 1));
sletz's avatar
sletz committed
410
        } else {
411
            return true;
sletz's avatar
sletz committed
412
        }
413
    }
414

415
    int JackNetMasterInterface::SyncSend()
416
    {
417
418
419
        fTxHeader.fCycle++;
        fTxHeader.fSubCycle = 0;
        fTxHeader.fDataType = 's';
420
        fTxHeader.fIsLastPckt = (fParams.fSendMidiChannels == 0 && fParams.fSendAudioChannels == 0) ? 1 : 0;
sletz's avatar
sletz committed
421
        fTxHeader.fPacketSize = fParams.fMtu;
sletz's avatar
sletz committed
422

423
424
425
426
        // Write active ports list
        if (fNetAudioPlaybackBuffer)
            fNetAudioPlaybackBuffer->ActivePortsToNetwork(fTxData, fTxHeader.fActivePorts);

sletz's avatar
sletz committed
427
        memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
428
        //PacketHeaderDisplay(&fTxHeader);
sletz's avatar
sletz committed
429
        return Send(fTxHeader.fPacketSize, 0);
430
431
432
433
434
    }

    int JackNetMasterInterface::DataSend()
    {
        uint subproc;
sletz's avatar
sletz committed
435
436
        uint data_size;

437
        //midi
sletz's avatar
sletz committed
438
        if (fParams.fSendMidiChannels > 0) {
439
440
            //set global header fields and get the number of midi packets
            fTxHeader.fDataType = 'm';
sletz's avatar
sletz committed
441
            data_size = fNetMidiCaptureBuffer->RenderFromJackPorts();
sletz's avatar
sletz committed
442
            fTxHeader.fNumPacket = fNetMidiCaptureBuffer->GetNumPackets(data_size, PACKET_AVAILABLE_SIZE);
sletz's avatar
sletz committed
443

sletz's avatar
sletz committed
444
            for (subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
445
                fTxHeader.fSubCycle = subproc;
sletz's avatar
sletz committed
446
447
                fTxHeader.fIsLastPckt = ((subproc == (fTxHeader.fNumPacket - 1)) && (fParams.fSendAudioChannels == 0)) ? 1 : 0;
                fTxHeader.fPacketSize = HEADER_SIZE + fNetMidiCaptureBuffer->RenderToNetwork(subproc, data_size);
sletz's avatar
sletz committed
448
449
                memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
                if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR)
450
                    return SOCKET_ERROR;
451
452
            }
        }
453
454

        //audio
sletz's avatar
sletz committed
455
        if (fParams.fSendAudioChannels > 0) {
456
            fTxHeader.fDataType = 'a';
sletz's avatar
sletz committed
457
            fNetAudioCaptureBuffer->RenderFromJackPorts();
sletz's avatar
sletz committed
458
            fTxHeader.fNumPacket = fNetAudioCaptureBuffer->GetNumPackets();
sletz's avatar
sletz committed
459

sletz's avatar
sletz committed
460
            for (subproc = 0; subproc < fTxHeader.fNumPacket; subproc++) {
461
                fTxHeader.fSubCycle = subproc;
sletz's avatar
sletz committed
462
                fTxHeader.fIsLastPckt = (subproc == (fTxHeader.fNumPacket - 1)) ? 1 : 0;
463
                fTxHeader.fPacketSize = HEADER_SIZE + fNetAudioCaptureBuffer->RenderToNetwork(subproc, fTxHeader.fActivePorts);
sletz's avatar
sletz committed
464
                memcpy(fTxBuffer, &fTxHeader, HEADER_SIZE);
465
                //PacketHeaderDisplay(&fTxHeader);
sletz's avatar
sletz committed
466
                if (Send(fTxHeader.fPacketSize, 0) == SOCKET_ERROR)
467
468
469
470
471
                    return SOCKET_ERROR;
            }
        }

        return 0;
472
473
    }

474
    int JackNetMasterInterface::SyncRecv()
475
    {
sletz's avatar
sletz committed
476
        packet_header_t* rx_head = reinterpret_cast<packet_header_t*>(fRxBuffer);
sletz's avatar
sletz committed
477
        int rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
478

sletz's avatar
sletz committed
479
        if ((rx_bytes == 0) || (rx_bytes == SOCKET_ERROR)) {
sletz's avatar
sletz committed
480
            // 0 bytes considered an error (lost connection)
sletz's avatar
sletz committed
481
482
            return SOCKET_ERROR;
        }
483

484
        fCycleOffset = fTxHeader.fCycle - rx_head->fCycle;
485

486
487
488
489
        // Read active ports list
        if (fNetAudioCaptureBuffer)
            fNetAudioCaptureBuffer->ActivePortsFromNetwork(fRxData, rx_head->fActivePorts);

sletz's avatar
sletz committed
490
        switch (fParams.fNetworkMode)
491
        {
492
            case 's' :
moret's avatar
moret committed
493
494
495
496
497
                //slow mode : allow to use full bandwidth and heavy process on the slave
                //  - extra latency is set to two cycles, one cycle for send/receive operations + one cycle for heavy process on the slave
                //  - if the network is two fast, just wait the next cycle, this mode allows a shorter cycle duration for the master
                //  - this mode will skip the two first cycles, thus it lets time for data to be processed and queued on the socket rx buffer
                //the slow mode is the safest mode because it wait twice the bandwidth relative time (send/return + process)
498

sletz's avatar
sletz committed
499
500
501
                if (fCycleOffset < CYCLE_OFFSET_SLOW) {
                    return 0;
                } else {
sletz's avatar
sletz committed
502
                    rx_bytes = Recv(rx_head->fPacketSize, 0);
sletz's avatar
sletz committed
503
504
505
                }

                /*
sletz's avatar
sletz committed
506
                rx_bytes = Recv(rx_head->fPacketSize, 0);
sletz's avatar
sletz committed
507

sletz's avatar
sletz committed
508
                if (fCycleOffset != fLastfCycleOffset)
509
                    jack_info("Warning : '%s' runs in slow network mode, but data received too late (%d cycle(s) offset)", fParams.fName, fCycleOffset);
sletz's avatar
sletz committed
510
                fLastfCycleOffset = fCycleOffset;
sletz's avatar
sletz committed
511
512
                */

513
                break;
514

515
516
517
518
519
            case 'n' :
                //normal use of the network :
                //  - extra latency is set to one cycle, what is the time needed to receive streams using full network bandwidth
                //  - if the network is too fast, just wait the next cycle, the benefit here is the master's cycle is shorter
                //  - indeed, data is supposed to be on the network rx buffer, so we don't have to wait for it
sletz's avatar
sletz committed
520
                if (fCycleOffset < CYCLE_OFFSET_NORMAL) {
521
                    return 0;
sletz's avatar
sletz committed
522
                } else {
sletz's avatar
sletz committed
523
                    rx_bytes = Recv(rx_head->fPacketSize, 0);
sletz's avatar
sletz committed
524
                }
525

sletz's avatar
sletz committed
526
                if (fCycleOffset > CYCLE_OFFSET_NORMAL)  {
527
                    jack_info("'%s' can't run in normal network mode, data received too late (%d cycle(s) offset)", fParams.fName, fCycleOffset);
sletz's avatar
sletz committed
528
                }
529
                break;
530

531
532
533
534
535
            case 'f' :
                //fast mode suppose the network bandwith is larger than required for the transmission (only a few channels for example)
                //    - packets can be quickly received, quickly is here relative to the cycle duration
                //    - here, receive data, we can't keep it queued on the rx buffer,
                //    - but if there is a cycle offset, tell the user, that means we're not in fast mode anymore, network is too slow
sletz's avatar
sletz committed
536
                rx_bytes = Recv(rx_head->fPacketSize, 0);
537

sletz's avatar
sletz committed
538
                if (fCycleOffset > CYCLE_OFFSET_FAST) {
539
                    jack_info("'%s' can't run in fast network mode, data received too late (%d cycle(s) offset)", fParams.fName, fCycleOffset);
sletz's avatar
sletz committed
540
                }
541
                break;
542
        }
543

moret's avatar
moret committed
544
        fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
545
546
        return rx_bytes;
    }
547

548
    int JackNetMasterInterface::DataRecv()
549
550
    {
        int rx_bytes = 0;
551
        uint recvd_midi_pckt = 0;
sletz's avatar
sletz committed
552
        packet_header_t* rx_head = reinterpret_cast<packet_header_t*>(fRxBuffer);
553

sletz's avatar
sletz committed
554
        while (!fRxHeader.fIsLastPckt)
555
        {
moret's avatar
moret committed
556
            //how much data is queued on the rx buffer ?
sletz's avatar
sletz committed
557
            rx_bytes = Recv(fParams.fMtu, MSG_PEEK);
558

sletz's avatar
sletz committed
559
            //error here, problem with recv, just skip the cycle (return -1)
sletz's avatar
sletz committed
560
            if (rx_bytes == SOCKET_ERROR)
moret's avatar
moret committed
561
                return rx_bytes;
sletz's avatar
sletz committed
562

sletz's avatar
sletz committed
563
            if (rx_bytes && (rx_head->fDataStream == 'r') && (rx_head->fID == fParams.fID))
moret's avatar
moret committed
564
565
            {
                //read data
sletz's avatar
sletz committed
566
                switch (rx_head->fDataType)
567
                {
moret's avatar
moret committed
568
                    case 'm':   //midi
sletz's avatar
sletz committed
569
                        rx_bytes = Recv(rx_head->fPacketSize, 0);
moret's avatar
moret committed
570
                        fRxHeader.fCycle = rx_head->fCycle;
moret's avatar
moret committed
571
                        fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
sletz's avatar
sletz committed
572
                        fNetMidiPlaybackBuffer->RenderFromNetwork(rx_head->fSubCycle, rx_bytes - HEADER_SIZE);
sletz's avatar
sletz committed
573
574
                        // Last midi packet is received, so finish rendering...
                        if (++recvd_midi_pckt == rx_head->fNumPacket)
moret's avatar
moret committed
575
576
                            fNetMidiPlaybackBuffer->RenderToJackPorts();
                        break;
577

moret's avatar
moret committed
578
                    case 'a':   //audio
sletz's avatar
sletz committed
579
                        rx_bytes = Recv(rx_head->fPacketSize, 0);
moret's avatar
moret committed
580
581
                        fRxHeader.fCycle = rx_head->fCycle;
                        fRxHeader.fSubCycle = rx_head->fSubCycle;
moret's avatar
moret committed
582
                        fRxHeader.fIsLastPckt = rx_head->fIsLastPckt;
583
                        fRxHeader.fActivePorts = rx_head->fActivePorts;
sletz's avatar
sletz committed
584
                        rx_bytes = fNetAudioPlaybackBuffer->RenderFromNetwork(rx_head->fCycle, rx_head->fSubCycle, rx_bytes - HEADER_SIZE, fRxHeader.fActivePorts);
sletz's avatar
sletz committed
585
586
                        // Last audio packet is received, so finish rendering...
                        if (fRxHeader.fIsLastPckt)
sletz's avatar
sletz committed
587
                            fNetAudioPlaybackBuffer->RenderToJackPorts();
moret's avatar
moret committed
588
                        break;
589

moret's avatar
moret committed
590
                    case 's':   //sync
591
                        jack_info("NetMaster : overloaded, skipping receive from '%s'", fParams.fName);
sletz's avatar
sletz committed
592
                        // TODO : finish midi and audio rendering ?
sletz's avatar
sletz committed
593
                        fNetAudioPlaybackBuffer->RenderToJackPorts();
sletz's avatar
sletz committed
594
                        return NET_PACKET_ERROR;
595
596
597
                }
            }
        }
sletz's avatar
sletz committed
598

599
        return rx_bytes;
600
    }
601

602
    void JackNetMasterInterface::EncodeSyncPacket()
603
604
605
    {
        //this method contains every step of sync packet informations coding
        //first of all, reset sync packet
sletz's avatar
sletz committed
606
        memset(fTxData, 0, PACKET_AVAILABLE_SIZE);
607
608

        //then, first step : transport
609
        if (fParams.fTransportSync) {
sletz's avatar
sletz committed
610
611
612
            // desactivated...
            //EncodeTransportData();
            TransportDataHToN(&fSendTransportData,  &fSendTransportData);
613
            //copy to TxBuffer
sletz's avatar
sletz committed
614
            memcpy(fTxData, &fSendTransportData, sizeof(net_transport_data_t));
615
616
617
618
619
        }
        //then others (freewheel etc.)
        //...
    }

620
    void JackNetMasterInterface::DecodeSyncPacket()
621
622
623
    {
        //this method contains every step of sync packet informations decoding process
        //first : transport
624
        if (fParams.fTransportSync) {
625
            //copy received transport data to transport data structure
sletz's avatar
sletz committed
626
627
628
629
            memcpy(&fReturnTransportData, fRxData, sizeof(net_transport_data_t));
            TransportDataNToH(&fReturnTransportData,  &fReturnTransportData);
            // desactivated...
            //DecodeTransportData();
630
631
632
633
        }
        //then others
        //...
    }
634

635
636
// JackNetSlaveInterface ************************************************************************************************

moret's avatar
moret committed
637
638
    uint JackNetSlaveInterface::fSlaveCounter = 0;

639
    bool JackNetSlaveInterface::Init()
640
    {
sletz's avatar
sletz committed
641
        jack_log("JackNetSlaveInterface::Init()");
642

643
        //set the parameters to send
sletz's avatar
sletz committed
644
        strcpy(fParams.fPacketType, "params");
645
        fParams.fProtocolVersion = SLAVE_PROTOCOL;
sletz's avatar
sletz committed
646
        SetPacketType(&fParams, SLAVE_AVAILABLE);
647

648
649
        //init loop : get a master and start, do it until connection is ok
        net_status_t status;
650
        do {
651
            //first, get a master, do it until a valid connection is running
652
            do {
653
                status = SendAvailableToMaster();
sletz's avatar
sletz committed
654
                if (status == NET_SOCKET_ERROR)
655
                    return false;
656
            }
sletz's avatar
sletz committed
657
            while (status != NET_CONNECTED);
658

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

667
668
        return true;
    }
669

670
    // Separate the connection protocol into two separated step
sletz's avatar
sletz committed
671
    bool JackNetSlaveInterface::InitConnection(int time_out)
672
    {
sletz's avatar
sletz committed
673
        jack_log("JackNetSlaveInterface::InitConnection()");
sletz's avatar
sletz committed
674
        unsigned int try_count = (time_out > 0) ? ((1000000 * time_out) / SLAVE_INIT_TIMEOUT) : LONG_MAX;
675
676

        //set the parameters to send
sletz's avatar
sletz committed
677
        strcpy(fParams.fPacketType, "params");
678
        fParams.fProtocolVersion = SLAVE_PROTOCOL;
sletz's avatar
sletz committed
679
        SetPacketType(&fParams, SLAVE_AVAILABLE);
680
681

        net_status_t status;
682
        do {
683
            //get a master
sletz's avatar
sletz committed
684
            status = SendAvailableToMaster(try_count);
685
686
687
            if (status == NET_SOCKET_ERROR)
                return false;
        }
sletz's avatar
sletz committed
688
        while (status != NET_CONNECTED && --try_count > 0);
689

sletz's avatar
sletz committed
690
        return (try_count != 0);
691
    }
692

693
694
695
696
697
    bool JackNetSlaveInterface::InitRendering()
    {
        jack_log("JackNetSlaveInterface::InitRendering()");

        net_status_t status;
698
        do {
699
700
701
702
703
704
            //then tell the master we are ready
            jack_info("Initializing connection with %s...", fParams.fMasterNetName);
            status = SendStartToMaster();
            if (status == NET_ERROR)
                return false;
        }
705
706
        while (status != NET_ROLLING);

707
708
        return true;
    }
709

sletz's avatar
sletz committed
710
    net_status_t JackNetSlaveInterface::SendAvailableToMaster(long try_count)
711
    {
sletz's avatar
sletz committed
712
        jack_log("JackNetSlaveInterface::SendAvailableToMaster()");
713
        //utility
714
        session_params_t host_params;
715
716
717
        int rx_bytes = 0;

        //socket
sletz's avatar
sletz committed
718
719
        if (fSocket.NewSocket() == SOCKET_ERROR) {
            jack_error("Fatal error : network unreachable - %s", StrError(NET_ERROR_CODE));
720
            return NET_SOCKET_ERROR;
721
722
        }

723
        //bind the socket
sletz's avatar
sletz committed
724
725
        if (fSocket.Bind() == SOCKET_ERROR) {
            jack_error("Can't bind the socket : %s", StrError(NET_ERROR_CODE));
726
727
            return NET_SOCKET_ERROR;
        }
728
729

        //timeout on receive
sletz's avatar
sletz committed
730
731
        if (fSocket.SetTimeOut(SLAVE_INIT_TIMEOUT) == SOCKET_ERROR)
            jack_error("Can't set timeout : %s", StrError(NET_ERROR_CODE));
732

733
        //disable local loop
sletz's avatar
sletz committed
734
735
        if (fSocket.SetLocalLoop() == SOCKET_ERROR)
            jack_error("Can't disable multicast loop : %s", StrError(NET_ERROR_CODE));
736

737
        //send 'AVAILABLE' until 'SLAVE_SETUP' received
sletz's avatar
sletz committed
738
        jack_info("Waiting for a master...");