TuioServer.cpp 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641
  1. /*
  2. TUIO Server Component - part of the reacTIVision project
  3. http://reactivision.sourceforge.net/
  4. Copyright (c) 2005-2009 Martin Kaltenbrunner <[email protected]>
  5. This program is free software; you can redistribute it and/or modify
  6. it under the terms of the GNU General Public License as published by
  7. the Free Software Foundation; either version 2 of the License, or
  8. (at your option) any later version.
  9. This program is distributed in the hope that it will be useful,
  10. but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. GNU General Public License for more details.
  13. You should have received a copy of the GNU General Public License
  14. along with this program; if not, write to the Free Software
  15. Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  16. */
  17. #include "TuioServer.h"
  18. #ifndef WIN32
  19. #include <unistd.h>
  20. #else
  21. #endif
  22. using namespace TUIO;
  23. using namespace osc;
  24. #ifndef WIN32
  25. static void* ThreadFunc( void* obj )
  26. #else
  27. static DWORD WINAPI ThreadFunc( LPVOID obj )
  28. #endif
  29. {
  30. TuioServer *tuioServer = static_cast<TuioServer*>(obj);
  31. while ((tuioServer->isConnected()) && (tuioServer->periodicMessagesEnabled())) {
  32. tuioServer->sendFullMessages();
  33. #ifndef WIN32
  34. usleep(USEC_SECOND*tuioServer->getUpdateInterval());
  35. #else
  36. Sleep(MSEC_SECOND*tuioServer->getUpdateInterval());
  37. #endif
  38. }
  39. return 0;
  40. };
  41. void TuioServer::enablePeriodicMessages(int interval) {
  42. if (periodic_update) return;
  43. update_interval = interval;
  44. periodic_update = true;
  45. #ifndef WIN32
  46. pthread_create(&thread , NULL, ThreadFunc, this);
  47. #else
  48. DWORD threadId;
  49. thread = CreateThread( 0, 0, ThreadFunc, this, 0, &threadId );
  50. #endif
  51. }
  52. void TuioServer::disablePeriodicMessages() {
  53. if (!periodic_update) return;
  54. periodic_update = false;
  55. #ifdef WIN32
  56. if( thread ) CloseHandle( thread );
  57. #endif
  58. thread = NULL;
  59. }
  60. void TuioServer::sendFullMessages() {
  61. // prepare the cursor packet
  62. fullPacket->Clear();
  63. (*fullPacket) << osc::BeginBundleImmediate;
  64. // add the cursor alive message
  65. (*fullPacket) << osc::BeginMessage( "/tuio/2Dcur") << "alive";
  66. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++)
  67. (*fullPacket) << (int32)((*tuioCursor)->getSessionID());
  68. (*fullPacket) << osc::EndMessage;
  69. // add all current cursor set messages
  70. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++) {
  71. // start a new packet if we exceed the packet capacity
  72. if ((fullPacket->Capacity()-fullPacket->Size())<CUR_MESSAGE_SIZE) {
  73. // add the immediate fseq message and send the cursor packet
  74. (*fullPacket) << osc::BeginMessage( "/tuio/2Dcur") << "fseq" << -1 << osc::EndMessage;
  75. (*fullPacket) << osc::EndBundle;
  76. socket->Send( fullPacket->Data(), fullPacket->Size() );
  77. // prepare the new cursor packet
  78. fullPacket->Clear();
  79. (*fullPacket) << osc::BeginBundleImmediate;
  80. // add the cursor alive message
  81. (*fullPacket) << osc::BeginMessage( "/tuio/2Dcur") << "alive";
  82. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++)
  83. (*fullPacket) << (int32)((*tuioCursor)->getSessionID());
  84. (*fullPacket) << osc::EndMessage;
  85. }
  86. // add the actual cursor set message
  87. (*fullPacket) << osc::BeginMessage( "/tuio/2Dcur") << "set";
  88. (*fullPacket) << (int32)((*tuioCursor)->getSessionID()) << (*tuioCursor)->getX() << (*tuioCursor)->getY();
  89. (*fullPacket) << (*tuioCursor)->getXSpeed() << (*tuioCursor)->getYSpeed() <<(*tuioCursor)->getMotionAccel();
  90. (*fullPacket) << osc::EndMessage;
  91. }
  92. // add the immediate fseq message and send the cursor packet
  93. (*fullPacket) << osc::BeginMessage( "/tuio/2Dcur") << "fseq" << -1 << osc::EndMessage;
  94. (*fullPacket) << osc::EndBundle;
  95. socket->Send( fullPacket->Data(), fullPacket->Size() );
  96. // prepare the object packet
  97. fullPacket->Clear();
  98. (*fullPacket) << osc::BeginBundleImmediate;
  99. // add the object alive message
  100. (*fullPacket) << osc::BeginMessage( "/tuio/2Dobj") << "alive";
  101. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++)
  102. (*fullPacket) << (int32)((*tuioObject)->getSessionID());
  103. (*fullPacket) << osc::EndMessage;
  104. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++) {
  105. // start a new packet if we exceed the packet capacity
  106. if ((fullPacket->Capacity()-fullPacket->Size())<OBJ_MESSAGE_SIZE) {
  107. // add the immediate fseq message and send the object packet
  108. (*fullPacket) << osc::BeginMessage( "/tuio/2Dobj") << "fseq" << -1 << osc::EndMessage;
  109. (*fullPacket) << osc::EndBundle;
  110. socket->Send( fullPacket->Data(), fullPacket->Size() );
  111. // prepare the new object packet
  112. fullPacket->Clear();
  113. (*fullPacket) << osc::BeginBundleImmediate;
  114. // add the object alive message
  115. (*fullPacket) << osc::BeginMessage( "/tuio/2Dobj") << "alive";
  116. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++)
  117. (*fullPacket) << (int32)((*tuioObject)->getSessionID());
  118. (*fullPacket) << osc::EndMessage;
  119. }
  120. // add the actual object set message
  121. (*fullPacket) << osc::BeginMessage( "/tuio/2Dobj") << "set";
  122. (*fullPacket) << (int32)((*tuioObject)->getSessionID()) << (*tuioObject)->getSymbolID() << (*tuioObject)->getX() << (*tuioObject)->getY() << (*tuioObject)->getAngle();
  123. (*fullPacket) << (*tuioObject)->getXSpeed() << (*tuioObject)->getYSpeed() << (*tuioObject)->getRotationSpeed() << (*tuioObject)->getMotionAccel() << (*tuioObject)->getRotationAccel();
  124. (*fullPacket) << osc::EndMessage;
  125. }
  126. // add the immediate fseq message and send the object packet
  127. (*fullPacket) << osc::BeginMessage( "/tuio/2Dobj") << "fseq" << -1 << osc::EndMessage;
  128. (*fullPacket) << osc::EndBundle;
  129. socket->Send( fullPacket->Data(), fullPacket->Size() );
  130. }
  131. TuioServer::TuioServer() {
  132. initialize("127.0.0.1",3333,MAX_UDP_SIZE);
  133. }
  134. TuioServer::TuioServer(const char *host, int port) {
  135. initialize(host,port,IP_MTU_SIZE);
  136. }
  137. TuioServer::TuioServer(const char *host, int port, int size) {
  138. initialize(host,port,size);
  139. }
  140. void TuioServer::initialize(const char *host, int port, int size) {
  141. if (size>MAX_UDP_SIZE) size = MAX_UDP_SIZE;
  142. else if (size<MIN_UDP_SIZE) size = MIN_UDP_SIZE;
  143. try {
  144. long unsigned int ip = GetHostByName(host);
  145. socket = new UdpTransmitSocket(IpEndpointName(ip, port));
  146. oscBuffer = new char[size];
  147. oscPacket = new osc::OutboundPacketStream(oscBuffer,size);
  148. fullBuffer = new char[size];
  149. fullPacket = new osc::OutboundPacketStream(fullBuffer,size);
  150. } catch (std::exception&) {
  151. std::cout << "could not create socket" << std::endl;
  152. socket = NULL;
  153. }
  154. currentFrameTime = TuioTime::getSessionTime().getSeconds();
  155. currentFrame = sessionID = maxCursorID = -1;
  156. verbose = updateObject = updateCursor = false;
  157. lastObjectUpdate = lastCursorUpdate = currentFrameTime.getSeconds();
  158. sendEmptyCursorBundle();
  159. sendEmptyObjectBundle();
  160. periodic_update = false;
  161. full_update = false;
  162. connected = true;
  163. }
  164. TuioServer::~TuioServer() {
  165. connected = false;
  166. sendEmptyCursorBundle();
  167. sendEmptyObjectBundle();
  168. delete oscPacket;
  169. delete []oscBuffer;
  170. delete fullPacket;
  171. delete []fullBuffer;
  172. delete socket;
  173. }
  174. TuioObject* TuioServer::addTuioObject(int f_id, float x, float y, float a) {
  175. sessionID++;
  176. TuioObject *tobj = new TuioObject(currentFrameTime, sessionID, f_id, x, y, a);
  177. objectList.push_back(tobj);
  178. updateObject = true;
  179. if (verbose)
  180. std::cout << "add obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ") "<< tobj->getX() << " " << tobj->getY() << " " << tobj->getAngle() << std::endl;
  181. return tobj;
  182. }
  183. void TuioServer::addExternalTuioObject(TuioObject *tobj) {
  184. if (tobj==NULL) return;
  185. objectList.push_back(tobj);
  186. updateObject = true;
  187. if (verbose)
  188. std::cout << "add obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ") "<< tobj->getX() << " " << tobj->getY() << " " << tobj->getAngle() << std::endl;
  189. }
  190. void TuioServer::updateTuioObject(TuioObject *tobj, float x, float y, float a) {
  191. if (tobj==NULL) return;
  192. if (tobj->getTuioTime()==currentFrameTime) return;
  193. tobj->update(currentFrameTime,x,y,a);
  194. updateObject = true;
  195. if (verbose && tobj->isMoving())
  196. std::cout << "set obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ") "<< tobj->getX() << " " << tobj->getY() << " " << tobj->getAngle()
  197. << " " << tobj->getXSpeed() << " " << tobj->getYSpeed() << " " << tobj->getRotationSpeed() << " " << tobj->getMotionAccel() << " " << tobj->getRotationAccel() << std::endl;
  198. }
  199. void TuioServer::updateExternalTuioObject(TuioObject *tobj) {
  200. if (tobj==NULL) return;
  201. updateObject = true;
  202. if (verbose && tobj->isMoving())
  203. std::cout << "set obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ") "<< tobj->getX() << " " << tobj->getY() << " " << tobj->getAngle()
  204. << " " << tobj->getXSpeed() << " " << tobj->getYSpeed() << " " << tobj->getRotationSpeed() << " " << tobj->getMotionAccel() << " " << tobj->getRotationAccel() << std::endl;
  205. }
  206. void TuioServer::removeTuioObject(TuioObject *tobj) {
  207. if (tobj==NULL) return;
  208. objectList.remove(tobj);
  209. delete tobj;
  210. updateObject = true;
  211. if (verbose)
  212. std::cout << "del obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ")" << std::endl;
  213. }
  214. void TuioServer::removeExternalTuioObject(TuioObject *tobj) {
  215. if (tobj==NULL) return;
  216. objectList.remove(tobj);
  217. updateObject = true;
  218. if (verbose)
  219. std::cout << "del obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ")" << std::endl;
  220. }
  221. TuioCursor* TuioServer::addTuioCursor(float x, float y) {
  222. sessionID++;
  223. int cursorID = (int)cursorList.size();
  224. if (((int)(cursorList.size())<=maxCursorID) && ((int)(freeCursorList.size())>0)) {
  225. std::list<TuioCursor*>::iterator closestCursor = freeCursorList.begin();
  226. for(std::list<TuioCursor*>::iterator iter = freeCursorList.begin();iter!= freeCursorList.end(); iter++) {
  227. if((*iter)->getDistance(x,y)<(*closestCursor)->getDistance(x,y)) closestCursor = iter;
  228. }
  229. TuioCursor *freeCursor = (*closestCursor);
  230. cursorID = (*closestCursor)->getCursorID();
  231. freeCursorList.erase(closestCursor);
  232. delete freeCursor;
  233. } else maxCursorID = cursorID;
  234. TuioCursor *tcur = new TuioCursor(currentFrameTime, sessionID, cursorID, x, y);
  235. cursorList.push_back(tcur);
  236. updateCursor = true;
  237. if (verbose)
  238. std::cout << "add cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ") " << tcur->getX() << " " << tcur->getY() << std::endl;
  239. return tcur;
  240. }
  241. void TuioServer::addExternalTuioCursor(TuioCursor *tcur) {
  242. if (tcur==NULL) return;
  243. cursorList.push_back(tcur);
  244. updateCursor = true;
  245. if (verbose)
  246. std::cout << "add cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ") " << tcur->getX() << " " << tcur->getY() << std::endl;
  247. }
  248. void TuioServer::updateTuioCursor(TuioCursor *tcur,float x, float y) {
  249. if (tcur==NULL) return;
  250. if (tcur->getTuioTime()==currentFrameTime) return;
  251. tcur->update(currentFrameTime,x,y);
  252. updateCursor = true;
  253. if (verbose && tcur->isMoving())
  254. std::cout << "set cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ") " << tcur->getX() << " " << tcur->getY()
  255. << " " << tcur->getXSpeed() << " " << tcur->getYSpeed() << " " << tcur->getMotionAccel() << " " << std::endl;
  256. }
  257. void TuioServer::updateExternalTuioCursor(TuioCursor *tcur) {
  258. if (tcur==NULL) return;
  259. updateCursor = true;
  260. if (verbose && tcur->isMoving())
  261. std::cout << "set cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ") " << tcur->getX() << " " << tcur->getY()
  262. << " " << tcur->getXSpeed() << " " << tcur->getYSpeed() << " " << tcur->getMotionAccel() << " " << std::endl;
  263. }
  264. void TuioServer::removeTuioCursor(TuioCursor *tcur) {
  265. if (tcur==NULL) return;
  266. cursorList.remove(tcur);
  267. tcur->remove(currentFrameTime);
  268. updateCursor = true;
  269. if (verbose)
  270. std::cout << "del cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ")" << std::endl;
  271. if (tcur->getCursorID()==maxCursorID) {
  272. maxCursorID = -1;
  273. delete tcur;
  274. if (cursorList.size()>0) {
  275. std::list<TuioCursor*>::iterator clist;
  276. for (clist=cursorList.begin(); clist != cursorList.end(); clist++) {
  277. int cursorID = (*clist)->getCursorID();
  278. if (cursorID>maxCursorID) maxCursorID=cursorID;
  279. }
  280. freeCursorBuffer.clear();
  281. for (std::list<TuioCursor*>::iterator flist=freeCursorList.begin(); flist != freeCursorList.end(); flist++) {
  282. TuioCursor *freeCursor = (*flist);
  283. if (freeCursor->getCursorID()>maxCursorID) delete freeCursor;
  284. else freeCursorBuffer.push_back(freeCursor);
  285. }
  286. freeCursorList = freeCursorBuffer;
  287. } else {
  288. for (std::list<TuioCursor*>::iterator flist=freeCursorList.begin(); flist != freeCursorList.end(); flist++) {
  289. TuioCursor *freeCursor = (*flist);
  290. delete freeCursor;
  291. }
  292. freeCursorList.clear();
  293. }
  294. } else if (tcur->getCursorID()<maxCursorID) {
  295. freeCursorList.push_back(tcur);
  296. }
  297. }
  298. void TuioServer::removeExternalTuioCursor(TuioCursor *tcur) {
  299. if (tcur==NULL) return;
  300. cursorList.remove(tcur);
  301. updateCursor = true;
  302. if (verbose)
  303. std::cout << "del cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ")" << std::endl;
  304. }
  305. long TuioServer::getSessionID() {
  306. sessionID++;
  307. return sessionID;
  308. }
  309. long TuioServer::getFrameID() {
  310. return currentFrame;
  311. }
  312. TuioTime TuioServer::getFrameTime() {
  313. return currentFrameTime;
  314. }
  315. void TuioServer::initFrame(TuioTime ttime) {
  316. currentFrameTime = ttime;
  317. currentFrame++;
  318. }
  319. void TuioServer::commitFrame() {
  320. if(updateCursor) {
  321. startCursorBundle();
  322. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++) {
  323. // start a new packet if we exceed the packet capacity
  324. if ((oscPacket->Capacity()-oscPacket->Size())<CUR_MESSAGE_SIZE) {
  325. sendCursorBundle(currentFrame);
  326. startCursorBundle();
  327. }
  328. TuioCursor *tcur = (*tuioCursor);
  329. if ((full_update) || (tcur->getTuioTime()==currentFrameTime)) addCursorMessage(tcur);
  330. }
  331. sendCursorBundle(currentFrame);
  332. } else if ((!periodic_update) && (lastCursorUpdate<currentFrameTime.getSeconds())) {
  333. lastCursorUpdate = currentFrameTime.getSeconds();
  334. startCursorBundle();
  335. sendCursorBundle(currentFrame);
  336. }
  337. updateCursor = false;
  338. if(updateObject) {
  339. startObjectBundle();
  340. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++) {
  341. // start a new packet if we exceed the packet capacity
  342. if ((oscPacket->Capacity()-oscPacket->Size())<OBJ_MESSAGE_SIZE) {
  343. sendObjectBundle(currentFrame);
  344. startObjectBundle();
  345. }
  346. TuioObject *tobj = (*tuioObject);
  347. if ((full_update) || (tobj->getTuioTime()==currentFrameTime)) addObjectMessage(tobj);
  348. }
  349. sendObjectBundle(currentFrame);
  350. } else if ((!periodic_update) && (lastObjectUpdate<currentFrameTime.getSeconds())) {
  351. lastObjectUpdate = currentFrameTime.getSeconds();
  352. startObjectBundle();
  353. sendObjectBundle(currentFrame);
  354. }
  355. updateObject = false;
  356. }
  357. void TuioServer::sendEmptyCursorBundle() {
  358. oscPacket->Clear();
  359. (*oscPacket) << osc::BeginBundleImmediate;
  360. (*oscPacket) << osc::BeginMessage( "/tuio/2Dcur") << "alive" << osc::EndMessage;
  361. (*oscPacket) << osc::BeginMessage( "/tuio/2Dcur") << "fseq" << -1 << osc::EndMessage;
  362. (*oscPacket) << osc::EndBundle;
  363. socket->Send( oscPacket->Data(), oscPacket->Size() );
  364. }
  365. void TuioServer::startCursorBundle() {
  366. oscPacket->Clear();
  367. (*oscPacket) << osc::BeginBundleImmediate;
  368. (*oscPacket) << osc::BeginMessage( "/tuio/2Dcur") << "alive";
  369. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++) {
  370. (*oscPacket) << (int32)((*tuioCursor)->getSessionID());
  371. }
  372. (*oscPacket) << osc::EndMessage;
  373. }
  374. void TuioServer::addCursorMessage(TuioCursor *tcur) {
  375. (*oscPacket) << osc::BeginMessage( "/tuio/2Dcur") << "set";
  376. (*oscPacket) << (int32)(tcur->getSessionID()) << tcur->getX() << tcur->getY();
  377. (*oscPacket) << tcur->getXSpeed() << tcur->getYSpeed() << tcur->getMotionAccel();
  378. (*oscPacket) << osc::EndMessage;
  379. }
  380. void TuioServer::sendCursorBundle(long fseq) {
  381. (*oscPacket) << osc::BeginMessage( "/tuio/2Dcur") << "fseq" << (int32)fseq << osc::EndMessage;
  382. (*oscPacket) << osc::EndBundle;
  383. socket->Send( oscPacket->Data(), oscPacket->Size() );
  384. }
  385. void TuioServer::sendEmptyObjectBundle() {
  386. oscPacket->Clear();
  387. (*oscPacket) << osc::BeginBundleImmediate;
  388. (*oscPacket) << osc::BeginMessage( "/tuio/2Dobj") << "alive" << osc::EndMessage;
  389. (*oscPacket) << osc::BeginMessage( "/tuio/2Dobj") << "fseq" << -1 << osc::EndMessage;
  390. (*oscPacket) << osc::EndBundle;
  391. socket->Send( oscPacket->Data(), oscPacket->Size() );
  392. }
  393. void TuioServer::startObjectBundle() {
  394. oscPacket->Clear();
  395. (*oscPacket) << osc::BeginBundleImmediate;
  396. (*oscPacket) << osc::BeginMessage( "/tuio/2Dobj") << "alive";
  397. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++) {
  398. (*oscPacket) << (int32)((*tuioObject)->getSessionID());
  399. }
  400. (*oscPacket) << osc::EndMessage;
  401. }
  402. void TuioServer::addObjectMessage(TuioObject *tobj) {
  403. (*oscPacket) << osc::BeginMessage( "/tuio/2Dobj") << "set";
  404. (*oscPacket) << (int32)(tobj->getSessionID()) << tobj->getSymbolID() << tobj->getX() << tobj->getY() << tobj->getAngle();
  405. (*oscPacket) << tobj->getXSpeed() << tobj->getYSpeed() << tobj->getRotationSpeed() << tobj->getMotionAccel() << tobj->getRotationAccel();
  406. (*oscPacket) << osc::EndMessage;
  407. }
  408. void TuioServer::sendObjectBundle(long fseq) {
  409. (*oscPacket) << osc::BeginMessage( "/tuio/2Dobj") << "fseq" << (int32)fseq << osc::EndMessage;
  410. (*oscPacket) << osc::EndBundle;
  411. socket->Send( oscPacket->Data(), oscPacket->Size() );
  412. }
  413. TuioObject* TuioServer::getTuioObject(long s_id) {
  414. for (std::list<TuioObject*>::iterator iter=objectList.begin(); iter != objectList.end(); iter++)
  415. if((*iter)->getSessionID()==s_id) return (*iter);
  416. return NULL;
  417. }
  418. TuioCursor* TuioServer::getTuioCursor(long s_id) {
  419. for (std::list<TuioCursor*>::iterator iter=cursorList.begin(); iter != cursorList.end(); iter++)
  420. if((*iter)->getSessionID()==s_id) return (*iter);
  421. return NULL;
  422. }
  423. TuioObject* TuioServer::getClosestTuioObject(float xp, float yp) {
  424. TuioObject *closestObject = NULL;
  425. float closestDistance = 1.0f;
  426. for (std::list<TuioObject*>::iterator iter=objectList.begin(); iter != objectList.end(); iter++) {
  427. float distance = (*iter)->getDistance(xp,yp);
  428. if(distance<closestDistance) {
  429. closestObject = (*iter);
  430. closestDistance = distance;
  431. }
  432. }
  433. return closestObject;
  434. }
  435. TuioCursor* TuioServer::getClosestTuioCursor(float xp, float yp) {
  436. TuioCursor *closestCursor = NULL;
  437. float closestDistance = 1.0f;
  438. for (std::list<TuioCursor*>::iterator iter=cursorList.begin(); iter != cursorList.end(); iter++) {
  439. float distance = (*iter)->getDistance(xp,yp);
  440. if(distance<closestDistance) {
  441. closestCursor = (*iter);
  442. closestDistance = distance;
  443. }
  444. }
  445. return closestCursor;
  446. }
  447. std::list<TuioObject*> TuioServer::getTuioObjects() {
  448. return objectList;
  449. }
  450. std::list<TuioCursor*> TuioServer::getTuioCursors() {
  451. return cursorList;
  452. }
  453. std::list<TuioObject*> TuioServer::getUntouchedObjects() {
  454. std::list<TuioObject*> untouched;
  455. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++) {
  456. TuioObject *tobj = (*tuioObject);
  457. if (tobj->getTuioTime()!=currentFrameTime) untouched.push_back(tobj);
  458. }
  459. return untouched;
  460. }
  461. void TuioServer::stopUntouchedMovingObjects() {
  462. std::list<TuioObject*> untouched;
  463. for (std::list<TuioObject*>::iterator tuioObject = objectList.begin(); tuioObject!=objectList.end(); tuioObject++) {
  464. TuioObject *tobj = (*tuioObject);
  465. if ((tobj->getTuioTime()!=currentFrameTime) && (tobj->isMoving())) {
  466. tobj->stop(currentFrameTime);
  467. updateObject = true;
  468. if (verbose)
  469. std::cout << "set obj " << tobj->getSymbolID() << " (" << tobj->getSessionID() << ") "<< tobj->getX() << " " << tobj->getY() << " " << tobj->getAngle()
  470. << " " << tobj->getXSpeed() << " " << tobj->getYSpeed() << " " << tobj->getRotationSpeed() << " " << tobj->getMotionAccel() << " " << tobj->getRotationAccel() << std::endl;
  471. }
  472. }
  473. }
  474. void TuioServer::removeUntouchedStoppedObjects() {
  475. std::list<TuioObject*>::iterator tuioObject = objectList.begin();
  476. while (tuioObject!=objectList.end()) {
  477. TuioObject *tobj = (*tuioObject);
  478. if ((tobj->getTuioTime()!=currentFrameTime) && (!tobj->isMoving())) {
  479. removeTuioObject(tobj);
  480. tuioObject = objectList.begin();
  481. } else tuioObject++;
  482. }
  483. }
  484. std::list<TuioCursor*> TuioServer::getUntouchedCursors() {
  485. std::list<TuioCursor*> untouched;
  486. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++) {
  487. TuioCursor *tcur = (*tuioCursor);
  488. if (tcur->getTuioTime()!=currentFrameTime) untouched.push_back(tcur);
  489. }
  490. return untouched;
  491. }
  492. void TuioServer::stopUntouchedMovingCursors() {
  493. std::list<TuioCursor*> untouched;
  494. for (std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin(); tuioCursor!=cursorList.end(); tuioCursor++) {
  495. TuioCursor *tcur = (*tuioCursor);
  496. if ((tcur->getTuioTime()!=currentFrameTime) && (tcur->isMoving())) {
  497. tcur->stop(currentFrameTime);
  498. updateCursor = true;
  499. if (verbose)
  500. std::cout << "set cur " << tcur->getCursorID() << " (" << tcur->getSessionID() << ") " << tcur->getX() << " " << tcur->getY()
  501. << " " << tcur->getXSpeed() << " " << tcur->getYSpeed()<< " " << tcur->getMotionAccel() << " " << std::endl;
  502. }
  503. }
  504. }
  505. void TuioServer::removeUntouchedStoppedCursors() {
  506. if (cursorList.size()==0) return;
  507. std::list<TuioCursor*>::iterator tuioCursor = cursorList.begin();
  508. while (tuioCursor!=cursorList.end()) {
  509. TuioCursor *tcur = (*tuioCursor);
  510. if ((tcur->getTuioTime()!=currentFrameTime) && (!tcur->isMoving())) {
  511. removeTuioCursor(tcur);
  512. tuioCursor = cursorList.begin();
  513. } else tuioCursor++;
  514. }
  515. }