Mercurial > hg > beaglert

comparison core/OSCServer.cpp @ 474:efc9a9f8e63d prerelease

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Libpd added scope support and example
author Giulio Moro <giuliomoro@yahoo.it>
date Mon, 20 Jun 2016 20:38:46 +0100
parents 421a69d42943
children
comparison
equal deleted inserted replaced
473:2a0b468ce1dd 474:efc9a9f8e63d
18 createAuxTasks(); 18 createAuxTasks();
19 } 19 }
20 20
21 void OSCServer::createAuxTasks(){ 21 void OSCServer::createAuxTasks(){
22 char name [30]; 22 char name [30];
23 sprintf (name, "OSCRecieveTask %i", port); 23 sprintf (name, "OSCReceiveTask %i", port);
24 OSCRecieveTask = Bela_createAuxiliaryTask(OSCServer::checkMessages, BELA_AUDIO_PRIORITY-5, name, this, true); 24 OSCReceiveTask = Bela_createAuxiliaryTask(OSCServer::checkMessages, BELA_AUDIO_PRIORITY-5, name, this, true);
25 } 25 }
26 26
27 void OSCServer::messageCheck(){ 27 void OSCServer::messageCheck(){
28 if (socket.waitUntilReady(true, UDP_RECIEVE_TIMEOUT_MS)){ 28 if (socket.waitUntilReady(true, UDP_RECEIVE_TIMEOUT_MS)){
29 int msgLength = socket.read(&inBuffer, UDP_RECIEVE_MAX_LENGTH, false); 29 int msgLength = socket.read(&inBuffer, UDP_RECEIVE_MAX_LENGTH, false);
30 pr.init(inBuffer, msgLength); 30 pr.init(inBuffer, msgLength);
31 oscpkt::Message *inmsg; 31 oscpkt::Message *inmsg;
32 while (pr.isOk() && (inmsg = pr.popMessage()) != 0) { 32 while (pr.isOk() && (inmsg = pr.popMessage()) != 0) {
33 inQueue.push(*inmsg); 33 inQueue.push(*inmsg);
34 } 34 }
47 poppedMessage.init("/error"); 47 poppedMessage.init("/error");
48 } 48 }
49 return poppedMessage; 49 return poppedMessage;
50 } 50 }
51 51
52 void OSCServer::recieveMessageNow(int timeout){ 52 void OSCServer::receiveMessageNow(int timeout){
53 if (socket.waitUntilReady(true, timeout)){ 53 if (socket.waitUntilReady(true, timeout)){
54 int msgLength = socket.read(&inBuffer, UDP_RECIEVE_MAX_LENGTH, false); 54 int msgLength = socket.read(&inBuffer, UDP_RECEIVE_MAX_LENGTH, false);
55 pr.init(inBuffer, msgLength); 55 pr.init(inBuffer, msgLength);
56 oscpkt::Message *inmsg; 56 oscpkt::Message *inmsg;
57 while (pr.isOk() && (inmsg = pr.popMessage()) != 0) { 57 while (pr.isOk() && (inmsg = pr.popMessage()) != 0) {
58 inQueue.push(*inmsg); 58 inQueue.push(*inmsg);
59 } 59 }