1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
/**********
This library is free software; you can redistribute it and/or modify it under
the terms of the GNU Lesser General Public License as published by the
Free Software Foundation; either version 2.1 of the License, or (at your
option) any later version. (See <http://www.gnu.org/copyleft/lesser.html>.)
This library 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 Lesser General Public License for
more details.
You should have received a copy of the GNU Lesser General Public License
along with this library; if not, write to the Free Software Foundation, Inc.,
59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
**********/
// "liveMedia"
// Copyright (c) 1996-2004 Live Networks, Inc. All rights reserved.
// MP3 HTTP Sources
// Implementation
#include "MP3HTTPSource.hh"
#include "GroupsockHelper.hh"
#include "MP3StreamState.hh"
MP3HTTPSource* MP3HTTPSource::createNew(UsageEnvironment& env,
NetAddress const& remoteAddress,
Port remotePort,
char const* remoteHostName,
char const* fileName) {
int ourSocket = -1;
MP3HTTPSource* newSource = NULL;
do {
// Create a stream socket for this source.
// Note: We don't make the socket non-blocking, because we want
// to read from it synchronously (as we do with real file sources)
ourSocket = setupStreamSocket(env, 0, False);
if (ourSocket < 0) break;
// Connect to the remote endpoint:
struct sockaddr_in remoteName;
remoteName.sin_family = AF_INET;
remoteName.sin_port = remotePort.num();
remoteName.sin_addr.s_addr = *(unsigned*)(remoteAddress.data());
if (connect(ourSocket, (struct sockaddr*)&remoteName, sizeof remoteName)
!= 0) {
env.setResultErrMsg("connect() failed: ");
break;
}
// Make sure we have a big receive buffer:
if (!increaseReceiveBufferTo(env, ourSocket, 100*1024)) break;
// Try to make the new socket into a FILE*:
unsigned streamLength = 0; //#####
FILE* fid = NULL;
#if !defined(IMN_PIM) && !defined(CRIS) && !defined(_WIN32_WCE)
fid = fdopen(ourSocket, "r+b");
#endif
if (fid == NULL) {
// HACK HACK HACK #####
// We couldn't convert the socket to a FILE*; perhaps this is Windoze?
// Instead, tell the low-level to read it directly as a socket:
long ourSocket_long = (long)ourSocket;
fid = (FILE*)ourSocket_long;
streamLength = (unsigned)(-1);
}
newSource = new MP3HTTPSource(env, fid);
if (newSource == NULL) break;
newSource->assignStream(fid, streamLength);
// Write the HTTP 'GET' command:
newSource->writeGetCmd(remoteHostName, ntohs(remotePort.num()),
fileName);
// Now read the first frame header, to finish initializing the stream:
if (!newSource->initializeStream()) break;
return newSource;
} while (0);
if (ourSocket != -1) ::_close(ourSocket);
delete newSource;
return NULL;
}
MP3HTTPSource::MP3HTTPSource(UsageEnvironment& env, FILE* fid)
: MP3FileSource(env, fid) {
}
MP3HTTPSource::~MP3HTTPSource() {
}
void MP3HTTPSource::writeGetCmd(char const* hostName, unsigned portNum,
char const* fileName) {
streamState()->writeGetCmd(hostName, portNum, fileName);
}
|
