1 | /********** |
2 | This library is free software; you can redistribute it and/or modify it under |
3 | the terms of the GNU Lesser General Public License as published by the |
4 | Free Software Foundation; either version 3 of the License, or (at your |
5 | option) any later version. (See <http://www.gnu.org/copyleft/lesser.html>.) |
6 | |
7 | This library is distributed in the hope that it will be useful, but WITHOUT |
8 | ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS |
9 | FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for |
10 | more details. |
11 | |
12 | You should have received a copy of the GNU Lesser General Public License |
13 | along with this library; if not, write to the Free Software Foundation, Inc., |
14 | 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
15 | **********/ |
16 | // "mTunnel" multicast access service |
17 | // Copyright (c) 1996-2020 Live Networks, Inc. All rights reserved. |
18 | // IO event handlers |
19 | // Implementation |
20 | |
21 | #include "IOHandlers.hh" |
22 | #include "TunnelEncaps.hh" |
23 | |
24 | //##### TEMP: Use a single buffer, sized for UDP tunnels: |
25 | //##### This assumes that the I/O handlers are non-reentrant |
26 | static unsigned const maxPacketLength = 50*1024; // bytes |
27 | // This is usually overkill, because UDP packets are usually no larger |
28 | // than the typical Ethernet MTU (1500 bytes). However, I've seen |
29 | // reports of Windows Media Servers sending UDP packets as large as |
30 | // 27 kBytes. These will probably undego lots of IP-level |
31 | // fragmentation, but that occurs below us. We just have to hope that |
32 | // fragments don't get lost. |
33 | static unsigned const ioBufferSize |
34 | = maxPacketLength + TunnelEncapsulationTrailerMaxSize; |
35 | static unsigned char ioBuffer[ioBufferSize]; |
36 | |
37 | |
38 | void socketReadHandler(Socket* sock, int /*mask*/) { |
39 | unsigned bytesRead; |
40 | struct sockaddr_in fromAddress; |
41 | UsageEnvironment& saveEnv = sock->env(); |
42 | // because handleRead(), if it fails, may delete "sock" |
43 | if (!sock->handleRead(ioBuffer, ioBufferSize, bytesRead, fromAddress)) { |
44 | saveEnv.reportBackgroundError(); |
45 | } |
46 | } |
47 | |