Mercurial > hg > beaglert

annotate include/NetworkSend.h @ 151:e9c9404e3d1f ClockSync

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Pff partially working. No PID. When setting the audio clock on the bbb to 44098 the master and slave clock keep diverging instead of converging ...
author Giulio Moro <giuliomoro@yahoo.it>
date Tue, 22 Sep 2015 04:10:07 +0100
parents e24c531220ee
children
rev   line source
andrewm@71 1 //scope.cpp
giuliomoro@109 2 #ifndef SCOPE_H_
giuliomoro@109 3 #define SCOPE_H_
giuliomoro@109 4
giuliomoro@129 5 #ifdef USE_JUCE
giuliomoro@131 6 #include <JuceHeader.h>
giuliomoro@129 7 #else
andrewm@71 8 #include <BeagleRT.h>
andrewm@71 9 #include <rtdk.h>
andrewm@71 10 #include <cmath>
andrewm@71 11 #include <UdpClient.h>
giuliomoro@111 12 #include <vector>
giuliomoro@131 13 #include <string>
giuliomoro@131 14 extern bool gShouldStop;
giuliomoro@129 15 #endif /* USE_JUCE */
andrewm@71 16
giuliomoro@107 17 #define NETWORK_AUDIO_BUFFER_SIZE 302
giuliomoro@131 18 #define UDP_BUFFER_HEADER_CHANNEL_INDEX 0
giuliomoro@131 19 #define UDP_BUFFER_HEADER_TIMESTAMP_INDEX 1
giuliomoro@131 20 #define UDP_BUFFER_HEADER_LENGTH 2
giuliomoro@109 21
giuliomoro@109 22 struct NetworkBuffer{
giuliomoro@109 23 int channelNumber;
giuliomoro@131 24 int numBuffers;
giuliomoro@131 25 int writeBuffer;
giuliomoro@131 26 int readBuffer;
giuliomoro@131 27 int writePointer;
giuliomoro@131 28 float** buffers;
giuliomoro@131 29 bool* doneOnTime;
giuliomoro@131 30 bool* readyToBeSent;
giuliomoro@131 31 bool enabled;
giuliomoro@131 32 int sampleCount;
giuliomoro@131 33 static const int bufferLength=NETWORK_AUDIO_BUFFER_SIZE;
giuliomoro@131 34 static const int headerLength=UDP_BUFFER_HEADER_LENGTH;
giuliomoro@131 35 static const int headerChannelIndex=UDP_BUFFER_HEADER_CHANNEL_INDEX;
giuliomoro@131 36 static const int headerTimestampIndex=UDP_BUFFER_HEADER_TIMESTAMP_INDEX;
andrewm@71 37 };
andrewm@71 38
giuliomoro@129 39 #ifdef USE_JUCE
giuliomoro@129 40 class NetworkSend: public Thread {
giuliomoro@129 41 #else
giuliomoro@111 42 class NetworkSend {
giuliomoro@129 43 #endif /* USE_JUCE */
giuliomoro@129 44 float sampleRate;
giuliomoro@129 45 #ifdef USE_JUCE
giuliomoro@129 46 DatagramSocket udpClient;
giuliomoro@131 47 int sleepTimeMs;
giuliomoro@131 48 String remoteHostname;
giuliomoro@131 49 int remotePortNumber;
giuliomoro@129 50 #else
giuliomoro@111 51 UdpClient udpClient;
giuliomoro@131 52 bool isThreadRunning();
giuliomoro@131 53 static int sleepTimeMs;
giuliomoro@131 54 static bool threadShouldExit();
giuliomoro@131 55 static bool threadIsExiting;
giuliomoro@131 56 static bool threadRunning;
giuliomoro@111 57 static bool staticConstructed;
giuliomoro@129 58 static void staticConstructor();
giuliomoro@129 59 static AuxiliaryTask sendDataTask; //TODO: allow different AuxiliaryTasks for different priorities (e.g.: audio vs scope)
giuliomoro@129 60 static std::vector<NetworkSend *> objAddrs;
giuliomoro@129 61 #endif /* USE_JUCE */
giuliomoro@131 62 void dealloc();
giuliomoro@131 63 public:
giuliomoro@129 64 NetworkBuffer channel;
giuliomoro@131 65 #ifdef USE_JUCE
giuliomoro@131 66 NetworkSend(const String &threadName);
giuliomoro@131 67 #else
giuliomoro@129 68 NetworkSend();
giuliomoro@131 69 #endif
giuliomoro@129 70 ~NetworkSend();
giuliomoro@131 71 void setup(float aSampleRate, int blockSize, int aChannelNumber, int aPort, const char *aServer);
giuliomoro@131 72 void cleanup();
giuliomoro@129 73 void sendData();
giuliomoro@129 74 void log(float value);
giuliomoro@129 75 void setPort(int aPort);
giuliomoro@129 76 void setServer(const char* aServer);
giuliomoro@129 77 void setChannelNumber(int aChannelNumber);
giuliomoro@129 78 int getChannelNumber();
giuliomoro@132 79 int getTimestamp();
giuliomoro@129 80 #ifdef USE_JUCE
giuliomoro@129 81 void run();
giuliomoro@129 82 #else
giuliomoro@129 83 static int getNumInstances();
giuliomoro@129 84 static void sendAllData();
giuliomoro@131 85 static void startThread();
giuliomoro@131 86 static void stopThread();
giuliomoro@129 87 static void run();
giuliomoro@129 88 #endif /* USE_JUCE */
andrewm@71 89 };
andrewm@71 90
giuliomoro@129 91 #ifdef USE_JUCE
giuliomoro@129 92 #else
giuliomoro@111 93 /**
giuliomoro@111 94 * An array of NetworkSend objects with some default parameters
giuliomoro@111 95 *
giuliomoro@111 96 * All sending on the same port (defaults to 9999)
giuliomoro@111 97 * All sending to the same server (defaults to 127.0.0.1)
giuliomoro@111 98 */
giuliomoro@109 99 class Scope {
giuliomoro@111 100 std::vector<NetworkSend> channels;
giuliomoro@109 101 void deallocate();
giuliomoro@109 102 public:
giuliomoro@109 103 Scope(int aNumChannels);
giuliomoro@109 104 ~Scope();
giuliomoro@109 105 void log(int channel, float value);
giuliomoro@111 106 void setup();
giuliomoro@111 107 void setup(float sampleRate, int aPort, const char* aServer);
giuliomoro@109 108 void sendData();
giuliomoro@119 109 void setPort(int port);
giuliomoro@119 110 void setPort(int channel, int port);
giuliomoro@111 111 int getNumChannels();
giuliomoro@109 112 };
giuliomoro@129 113 #endif /* USE_JUCE */
giuliomoro@129 114
giuliomoro@109 115 #endif /* SCOPE_H */