annotate libmpdemux/pnm.c @ 15246:849a6f39964f

use the documented default video device /dev/video0 instead of /dev/video that is missing on most systems
author iive
date Sat, 23 Apr 2005 21:23:58 +0000
parents a893e0bfa9d6
children 281d155fb37f
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
1 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
2 * Copyright (C) 2000-2002 the xine project
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
3 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
4 * This file is part of xine, a free video player.
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
5 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
6 * xine is free software; you can redistribute it and/or modify
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
7 * it under the terms of the GNU General Public License as published by
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
8 * the Free Software Foundation; either version 2 of the License, or
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
9 * (at your option) any later version.
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
10 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
11 * xine is distributed in the hope that it will be useful,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
14 * GNU General Public License for more details.
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
15 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
16 * You should have received a copy of the GNU General Public License
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
17 * along with this program; if not, write to the Free Software
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
18 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
19 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
20 * $Id$
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
21 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
22 * pnm protocol implementation
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
23 * based upon code from joschka
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
24 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
25
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
26 #include <unistd.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
27 #include <stdio.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
28 #include <assert.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
29 #include <string.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
30 #include <sys/stat.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
31 #include <fcntl.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
32 #include <errno.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
33 #include <stdlib.h>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
34 #include <sys/time.h>
8584
2d4328af7ea9 prefer inttypes.h (probably fix cygwin compile)
arpi
parents: 8570
diff changeset
35 #include <inttypes.h>
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
36
10281
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
37 #include "config.h"
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
38 #ifndef HAVE_WINSOCK2
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
39 #define closesocket close
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
40 #include <sys/socket.h>
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
41 //#include <netinet/in.h>
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
42 //#include <netdb.h>
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
43 #else
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
44 #include <winsock2.h>
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
45 #endif
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
46
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
47 #include "pnm.h"
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
48 //#include "libreal/rmff.h"
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
49
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
50 #define FOURCC_TAG( ch0, ch1, ch2, ch3 ) \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
51 (((long)(unsigned char)(ch3) ) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
52 ( (long)(unsigned char)(ch2) << 8 ) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
53 ( (long)(unsigned char)(ch1) << 16 ) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
54 ( (long)(unsigned char)(ch0) << 24 ) )
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
55
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
56
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
57 #define RMF_TAG FOURCC_TAG('.', 'R', 'M', 'F')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
58 #define PROP_TAG FOURCC_TAG('P', 'R', 'O', 'P')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
59 #define MDPR_TAG FOURCC_TAG('M', 'D', 'P', 'R')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
60 #define CONT_TAG FOURCC_TAG('C', 'O', 'N', 'T')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
61 #define DATA_TAG FOURCC_TAG('D', 'A', 'T', 'A')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
62 #define INDX_TAG FOURCC_TAG('I', 'N', 'D', 'X')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
63 #define PNA_TAG FOURCC_TAG('P', 'N', 'A', 0 )
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
64
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
65 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
66 #define LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
67 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
68
8880
e44d2ac094e8 buffer overflow fix :)
arpi
parents: 8852
diff changeset
69 #define BUF_SIZE 4096
e44d2ac094e8 buffer overflow fix :)
arpi
parents: 8852
diff changeset
70 #define HEADER_SIZE 4096
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
71
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
72 struct pnm_s {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
73
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
74 int s;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
75
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
76 // char *host;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
77 // int port;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
78 char *path;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
79 // char *url;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
80
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
81 char buffer[BUF_SIZE]; /* scratch buffer */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
82
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
83 /* receive buffer */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
84 uint8_t recv[BUF_SIZE];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
85 int recv_size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
86 int recv_read;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
87
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
88 uint8_t header[HEADER_SIZE];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
89 int header_len;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
90 int header_read;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
91 unsigned int seq_num[4]; /* two streams with two indices */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
92 unsigned int seq_current[2]; /* seqs of last stream chunk read */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
93 uint32_t ts_current; /* timestamp of current chunk */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
94 uint32_t ts_last[2]; /* timestamps of last chunks */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
95 unsigned int packet; /* number of last recieved packet */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
96 };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
97
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
98 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
99 * utility macros
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
100 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
101
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
102 #define BE_16(x) ((((uint8_t*)(x))[0] << 8) | ((uint8_t*)(x))[1])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
103 #define BE_32(x) ((((uint8_t*)(x))[0] << 24) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
104 (((uint8_t*)(x))[1] << 16) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
105 (((uint8_t*)(x))[2] << 8) | \
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
106 ((uint8_t*)(x))[3])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
107
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
108 /* D means direct (no pointer) */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
109 #define BE_16D(x) ((x & 0xff00) >> 8)|((x & 0x00ff) << 8)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
110
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
111 /* sizes */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
112 #define PREAMBLE_SIZE 8
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
113 #define CHECKSUM_SIZE 3
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
114
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
115
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
116 /* header of rm files */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
117 #define RM_HEADER_SIZE 0x12
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
118 const unsigned char rm_header[]={
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
119 0x2e, 0x52, 0x4d, 0x46, /* object_id ".RMF" */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
120 0x00, 0x00, 0x00, 0x12, /* header_size 0x12 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
121 0x00, 0x00, /* object_version 0x00 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
122 0x00, 0x00, 0x00, 0x00, /* file_version 0x00 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
123 0x00, 0x00, 0x00, 0x06 /* num_headers 0x06 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
124 };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
125
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
126 /* data chunk header */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
127 #define PNM_DATA_HEADER_SIZE 18
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
128 const unsigned char pnm_data_header[]={
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
129 'D','A','T','A',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
130 0,0,0,0, /* data chunk size */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
131 0,0, /* object version */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
132 0,0,0,0, /* num packets */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
133 0,0,0,0}; /* next data header */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
134
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
135 /* pnm request chunk ids */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
136
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
137 #define PNA_CLIENT_CAPS 0x03
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
138 #define PNA_CLIENT_CHALLANGE 0x04
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
139 #define PNA_BANDWIDTH 0x05
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
140 #define PNA_GUID 0x13
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
141 #define PNA_TIMESTAMP 0x17
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
142 #define PNA_TWENTYFOUR 0x18
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
143
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
144 #define PNA_CLIENT_STRING 0x63
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
145 #define PNA_PATH_REQUEST 0x52
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
146
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
147 const unsigned char pnm_challenge[] = "0990f6b4508b51e801bd6da011ad7b56";
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
148 const unsigned char pnm_timestamp[] = "[15/06/1999:22:22:49 00:00]";
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
149 const unsigned char pnm_guid[] = "3eac2411-83d5-11d2-f3ea-d7c3a51aa8b0";
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
150 const unsigned char pnm_response[] = "97715a899cbe41cee00dd434851535bf";
10350
a4cba6e2dfde fake newer realplayer version
faust3
parents: 10281
diff changeset
151 const unsigned char client_string[] = "WinNT_9.0_6.0.6.45_plus32_MP60_en-US_686l";
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
152
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
153 #define PNM_HEADER_SIZE 11
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
154 const unsigned char pnm_header[] = {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
155 'P','N','A',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
156 0x00, 0x0a,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
157 0x00, 0x14,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
158 0x00, 0x02,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
159 0x00, 0x01 };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
160
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
161 #define PNM_CLIENT_CAPS_SIZE 126
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
162 const unsigned char pnm_client_caps[] = {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
163 0x07, 0x8a, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
164 0, 0x90, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
165 0, 0x64, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
166 0, 0x46, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
167 0, 0x32, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
168 0, 0x2b, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
169 0, 0x28, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
170 0, 0x24, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
171 0, 0x19, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
172 0, 0x18, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
173 0, 0x14, 's','i','p','r',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
174 0, 0x14, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
175 0, 0x24, '2','8','_','8',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
176 0, 0x12, 'p','n','r','v',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
177 0, 0x0f, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
178 0, 0x0a, 's','i','p','r',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
179 0, 0x0a, 'd','n','e','t',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
180 0, 0x08, 's','i','p','r',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
181 0, 0x06, 's','i','p','r',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
182 0, 0x12, 'l','p','c','J',
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
183 0, 0x07, '0','5','_','6' };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
184
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
185 const uint32_t pnm_default_bandwidth=10485800;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
186 const uint32_t pnm_available_bandwidths[]={14400,19200,28800,33600,34430,57600,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
187 115200,262200,393216,524300,1544000,10485800};
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
188
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
189 #define PNM_TWENTYFOUR_SIZE 16
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
190 unsigned char pnm_twentyfour[]={
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
191 0xd5, 0x42, 0xa3, 0x1b, 0xef, 0x1f, 0x70, 0x24,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
192 0x85, 0x29, 0xb3, 0x8d, 0xba, 0x11, 0xf3, 0xd6 };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
193
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
194 /* now other data follows. marked with 0x0000 at the beginning */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
195 int after_chunks_length=6;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
196 unsigned char after_chunks[]={
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
197 0x00, 0x00, /* mark */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
198
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
199 0x50, 0x84, /* seems to be fixated */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
200 0x1f, 0x3a /* varies on each request (checksum ?)*/
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
201 };
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
202
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
203 static void hexdump (char *buf, int length);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
204
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
205 static int rm_write(int s, const char *buf, int len) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
206 int total, timeout;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
207
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
208 total = 0; timeout = 30;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
209 while (total < len){
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
210 int n;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
211
10206
35e306346e59 Using recv/send instead read/write for proper MinGW support (it's a 4.2BSD standard). Patch by FloDt <flodt8@yahoo.de>
alex
parents: 8880
diff changeset
212 n = send (s, &buf[total], len - total, 0);
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
213
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
214 if (n > 0)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
215 total += n;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
216 else if (n < 0) {
10281
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
217 #ifndef HAVE_WINSOCK2
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
218 if ((timeout>0) && ((errno == EAGAIN) || (errno == EINPROGRESS))) {
10281
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
219 #else
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
220 if ((timeout>0) && ((errno == EAGAIN) || (WSAGetLastError() == WSAEINPROGRESS))) {
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
221 #endif
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
222 sleep (1); timeout--;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
223 } else
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
224 return -1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
225 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
226 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
227
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
228 return total;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
229 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
230
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
231 static ssize_t rm_read(int fd, void *buf, size_t count) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
232
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
233 ssize_t ret, total;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
234
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
235 total = 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
236
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
237 while (total < count) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
238
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
239 fd_set rset;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
240 struct timeval timeout;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
241
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
242 FD_ZERO (&rset);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
243 FD_SET (fd, &rset);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
244
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
245 timeout.tv_sec = 3;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
246 timeout.tv_usec = 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
247
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
248 if (select (fd+1, &rset, NULL, NULL, &timeout) <= 0) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
249 return -1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
250 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
251
10206
35e306346e59 Using recv/send instead read/write for proper MinGW support (it's a 4.2BSD standard). Patch by FloDt <flodt8@yahoo.de>
alex
parents: 8880
diff changeset
252 ret=recv (fd, ((uint8_t*)buf)+total, count-total, 0);
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
253
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
254 if (ret<=0) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
255 printf ("input_pnm: read error.\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
256 return ret;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
257 } else
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
258 total += ret;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
259 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
260
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
261 return total;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
262 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
263
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
264 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
265 * debugging utilities
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
266 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
267
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
268 static void hexdump (char *buf, int length) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
269
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
270 int i;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
271
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
272 printf ("input_pnm: ascii>");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
273 for (i = 0; i < length; i++) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
274 unsigned char c = buf[i];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
275
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
276 if ((c >= 32) && (c <= 128))
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
277 printf ("%c", c);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
278 else
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
279 printf (".");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
280 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
281 printf ("\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
282
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
283 printf ("input_pnm: hexdump> ");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
284 for (i = 0; i < length; i++) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
285 unsigned char c = buf[i];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
286
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
287 printf ("%02x", c);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
288
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
289 if ((i % 16) == 15)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
290 printf ("\npnm: ");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
291
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
292 if ((i % 2) == 1)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
293 printf (" ");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
294
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
295 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
296 printf ("\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
297 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
298
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
299 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
300 * pnm_get_chunk gets a chunk from stream
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
301 * and returns number of bytes read
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
302 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
303
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
304 static int pnm_get_chunk(pnm_t *p,
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
305 unsigned int max,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
306 unsigned int *chunk_type,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
307 char *data, int *need_response) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
308
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
309 unsigned int chunk_size;
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
310 unsigned int n;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
311 char *ptr;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
312
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
313 if (max < PREAMBLE_SIZE)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
314 return -1;
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
315
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
316 /* get first PREAMBLE_SIZE bytes and ignore checksum */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
317 rm_read (p->s, data, CHECKSUM_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
318 if (data[0] == 0x72)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
319 rm_read (p->s, data, PREAMBLE_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
320 else
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
321 rm_read (p->s, data+CHECKSUM_SIZE, PREAMBLE_SIZE-CHECKSUM_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
322
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
323 max -= PREAMBLE_SIZE;
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
324
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
325 *chunk_type = BE_32(data);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
326 chunk_size = BE_32(data+4);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
327
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
328 switch (*chunk_type) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
329 case PNA_TAG:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
330 *need_response=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
331 ptr=data+PREAMBLE_SIZE;
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
332 if (max < 1)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
333 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
334 rm_read (p->s, ptr++, 1);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
335 max -= 1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
336
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
337 while(1) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
338 /* expecting following chunk format: 0x4f <chunk size> <data...> */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
339
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
340 if (max < 2)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
341 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
342 rm_read (p->s, ptr, 2);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
343 max -= 2;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
344 if (*ptr == 'X') /* checking for server message */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
345 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
346 printf("input_pnm: got a message from server:\n");
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
347 if (max < 1)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
348 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
349 rm_read (p->s, ptr+2, 1);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
350 max = -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
351 n=BE_16(ptr+1);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
352 if (max < n)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
353 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
354 rm_read (p->s, ptr+3, n);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
355 max -= n;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
356 ptr[3+n]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
357 printf("%s\n",ptr+3);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
358 return -1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
359 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
360
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
361 if (*ptr == 'F') /* checking for server error */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
362 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
363 printf("input_pnm: server error.\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
364 return -1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
365 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
366 if (*ptr == 'i')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
367 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
368 ptr+=2;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
369 *need_response=1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
370 continue;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
371 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
372 if (*ptr != 0x4f) break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
373 n=ptr[1];
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
374 if (max < n)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
375 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
376 rm_read (p->s, ptr+2, n);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
377 max -= n;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
378 ptr+=(n+2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
379 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
380 /* the checksum of the next chunk is ignored here */
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
381 if (max < 1)
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
382 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
383 rm_read (p->s, ptr+2, 1);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
384 ptr+=3;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
385 chunk_size=ptr-data;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
386 break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
387 case RMF_TAG:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
388 case DATA_TAG:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
389 case PROP_TAG:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
390 case MDPR_TAG:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
391 case CONT_TAG:
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
392 if (chunk_size > max || chunk_size < PREAMBLE_SIZE) {
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
393 printf("error: max chunk size exeeded (max was 0x%04x)\n", max);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
394 #ifdef LOG
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
395 n=rm_read (p->s, &data[PREAMBLE_SIZE], 0x100 - PREAMBLE_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
396 hexdump(data,n+PREAMBLE_SIZE);
14164
5901a6392db3 Security fixes ported from upstream (xine)
rtognimp
parents: 11000
diff changeset
397 #endif
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
398 return -1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
399 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
400 rm_read (p->s, &data[PREAMBLE_SIZE], chunk_size-PREAMBLE_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
401 break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
402 default:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
403 *chunk_type = 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
404 chunk_size = PREAMBLE_SIZE;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
405 break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
406 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
407
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
408 return chunk_size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
409 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
410
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
411 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
412 * writes a chunk to a buffer, returns number of bytes written
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
413 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
414
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
415 static int pnm_write_chunk(uint16_t chunk_id, uint16_t length,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
416 const char *chunk, char *data) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
417
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
418 data[0]=(chunk_id>>8)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
419 data[1]=chunk_id%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
420 data[2]=(length>>8)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
421 data[3]=length%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
422 memcpy(&data[4],chunk,length);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
423
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
424 return length+4;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
425 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
426
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
427 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
428 * constructs a request and sends it
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
429 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
430
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
431 static void pnm_send_request(pnm_t *p, uint32_t bandwidth) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
432
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
433 uint16_t i16;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
434 int c=PNM_HEADER_SIZE;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
435 char fixme[]={0,1};
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
436
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
437 memcpy(p->buffer,pnm_header,PNM_HEADER_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
438 c+=pnm_write_chunk(PNA_CLIENT_CHALLANGE,strlen(pnm_challenge),
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
439 pnm_challenge,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
440 c+=pnm_write_chunk(PNA_CLIENT_CAPS,PNM_CLIENT_CAPS_SIZE,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
441 pnm_client_caps,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
442 c+=pnm_write_chunk(0x0a,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
443 c+=pnm_write_chunk(0x0c,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
444 c+=pnm_write_chunk(0x0d,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
445 c+=pnm_write_chunk(0x16,2,fixme,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
446 c+=pnm_write_chunk(PNA_TIMESTAMP,strlen(pnm_timestamp),
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
447 pnm_timestamp,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
448 c+=pnm_write_chunk(PNA_BANDWIDTH,4,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
449 (const char *)&pnm_default_bandwidth,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
450 c+=pnm_write_chunk(0x08,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
451 c+=pnm_write_chunk(0x0e,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
452 c+=pnm_write_chunk(0x0f,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
453 c+=pnm_write_chunk(0x11,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
454 c+=pnm_write_chunk(0x10,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
455 c+=pnm_write_chunk(0x15,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
456 c+=pnm_write_chunk(0x12,0,NULL,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
457 c+=pnm_write_chunk(PNA_GUID,strlen(pnm_guid),
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
458 pnm_guid,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
459 c+=pnm_write_chunk(PNA_TWENTYFOUR,PNM_TWENTYFOUR_SIZE,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
460 pnm_twentyfour,&p->buffer[c]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
461
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
462 /* data after chunks */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
463 memcpy(&p->buffer[c],after_chunks,after_chunks_length);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
464 c+=after_chunks_length;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
465
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
466 /* client id string */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
467 p->buffer[c]=PNA_CLIENT_STRING;
11000
6e35326c742f many small typo and grammar fixes
gabucino
parents: 10350
diff changeset
468 i16=BE_16D((strlen(client_string)-1)); /* don't know why do we have -1 here */
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
469 memcpy(&p->buffer[c+1],&i16,2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
470 memcpy(&p->buffer[c+3],client_string,strlen(client_string)+1);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
471 c=c+3+strlen(client_string)+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
472
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
473 /* file path */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
474 p->buffer[c]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
475 p->buffer[c+1]=PNA_PATH_REQUEST;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
476 i16=BE_16D(strlen(p->path));
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
477 memcpy(&p->buffer[c+2],&i16,2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
478 memcpy(&p->buffer[c+4],p->path,strlen(p->path));
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
479 c=c+4+strlen(p->path);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
480
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
481 /* some trailing bytes */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
482 p->buffer[c]='y';
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
483 p->buffer[c+1]='B';
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
484
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
485 rm_write(p->s,p->buffer,c+2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
486 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
487
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
488 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
489 * pnm_send_response sends a response of a challenge
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
490 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
491
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
492 static void pnm_send_response(pnm_t *p, const char *response) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
493
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
494 int size=strlen(response);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
495
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
496 p->buffer[0]=0x23;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
497 p->buffer[1]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
498 p->buffer[2]=(unsigned char) size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
499
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
500 memcpy(&p->buffer[3], response, size);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
501
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
502 rm_write (p->s, p->buffer, size+3);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
503
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
504 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
505
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
506 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
507 * get headers and challenge and fix headers
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
508 * write headers to p->header
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
509 * write challenge to p->buffer
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
510 *
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
511 * return 0 on error. != 0 on success
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
512 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
513
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
514 static int pnm_get_headers(pnm_t *p, int *need_response) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
515
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
516 uint32_t chunk_type;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
517 uint8_t *ptr=p->header;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
518 uint8_t *prop_hdr=NULL;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
519 int chunk_size,size=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
520 int nr;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
521 /* rmff_header_t *h; */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
522
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
523 *need_response=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
524
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
525 while(1) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
526 if (HEADER_SIZE-size<=0)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
527 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
528 printf("input_pnm: header buffer overflow. exiting\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
529 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
530 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
531 chunk_size=pnm_get_chunk(p,HEADER_SIZE-size,&chunk_type,ptr,&nr);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
532 if (chunk_size < 0) return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
533 if (chunk_type == 0) break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
534 if (chunk_type == PNA_TAG)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
535 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
536 memcpy(ptr, rm_header, RM_HEADER_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
537 chunk_size=RM_HEADER_SIZE;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
538 *need_response=nr;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
539 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
540 if (chunk_type == DATA_TAG)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
541 chunk_size=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
542 if (chunk_type == RMF_TAG)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
543 chunk_size=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
544 if (chunk_type == PROP_TAG)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
545 prop_hdr=ptr;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
546 size+=chunk_size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
547 ptr+=chunk_size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
548 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
549
8852
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
550 if (!prop_hdr) {
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
551 printf("input_pnm: error while parsing headers.\n");
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
552 return 0;
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
553 }
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
554
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
555 /* set data offset */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
556 size--;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
557 prop_hdr[42]=(size>>24)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
558 prop_hdr[43]=(size>>16)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
559 prop_hdr[44]=(size>>8)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
560 prop_hdr[45]=(size)%0xff;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
561 size++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
562
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
563 /* read challenge */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
564 memcpy (p->buffer, ptr, PREAMBLE_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
565 rm_read (p->s, &p->buffer[PREAMBLE_SIZE], 64);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
566
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
567 /* now write a data header */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
568 memcpy(ptr, pnm_data_header, PNM_DATA_HEADER_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
569 size+=PNM_DATA_HEADER_SIZE;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
570 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
571 h=rmff_scan_header(p->header);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
572 rmff_fix_header(h);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
573 p->header_len=rmff_get_header_size(h);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
574 rmff_dump_header(h, p->header, HEADER_SIZE);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
575 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
576 p->header_len=size;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
577
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
578 return 1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
579 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
580
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
581 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
582 * determine correct stream number by looking at indices
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
583 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
584
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
585 static int pnm_calc_stream(pnm_t *p) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
586
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
587 char str0=0,str1=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
588
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
589 /* looking at the first index to
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
590 * find possible stream types
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
591 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
592 if (p->seq_current[0]==p->seq_num[0]) str0=1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
593 if (p->seq_current[0]==p->seq_num[2]) str1=1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
594
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
595 switch (str0+str1) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
596 case 1: /* one is possible, good. */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
597 if (str0)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
598 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
599 p->seq_num[0]++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
600 p->seq_num[1]=p->seq_current[1]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
601 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
602 } else
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
603 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
604 p->seq_num[2]++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
605 p->seq_num[3]=p->seq_current[1]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
606 return 1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
607 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
608 break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
609 case 0:
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
610 case 2: /* both types or none possible, not so good */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
611 /* try to figure out by second index */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
612 if ( (p->seq_current[1] == p->seq_num[1])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
613 &&(p->seq_current[1] != p->seq_num[3]))
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
614 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
615 /* ok, only stream0 matches */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
616 p->seq_num[0]=p->seq_current[0]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
617 p->seq_num[1]++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
618 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
619 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
620 if ( (p->seq_current[1] == p->seq_num[3])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
621 &&(p->seq_current[1] != p->seq_num[1]))
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
622 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
623 /* ok, only stream1 matches */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
624 p->seq_num[2]=p->seq_current[0]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
625 p->seq_num[3]++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
626 return 1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
627 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
628 /* wow, both streams match, or not. */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
629 /* now we try to decide by timestamps */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
630 if (p->ts_current < p->ts_last[1])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
631 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
632 if (p->ts_current < p->ts_last[0])
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
633 return 1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
634 /* does not help, we guess type 0 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
635 #ifdef LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
636 printf("guessing stream# 0\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
637 #endif
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
638 p->seq_num[0]=p->seq_current[0]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
639 p->seq_num[1]=p->seq_current[1]+1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
640 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
641 break;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
642 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
643 printf("input_pnm: wow, something very nasty happened in pnm_calc_stream\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
644 return 2;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
645 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
646
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
647 /*
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
648 * gets a stream chunk and writes it to a recieve buffer
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
649 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
650
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
651 static int pnm_get_stream_chunk(pnm_t *p) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
652
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
653 int n;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
654 char keepalive='!';
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
655 unsigned int fof1, fof2, stream;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
656
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
657 /* send a keepalive */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
658 /* realplayer seems to do that every 43th package */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
659 if ((p->packet%43) == 42)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
660 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
661 rm_write(p->s,&keepalive,1);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
662 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
663
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
664 /* data chunks begin with: 'Z' <o> <o> <i1> 'Z' <i2>
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
665 * where <o> is the offset to next stream chunk,
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
666 * <i1> is a 16 bit index
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
667 * <i2> is a 8 bit index which counts from 0x10 to somewhere
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
668 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
669
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
670 n = rm_read (p->s, p->buffer, 8);
15077
a893e0bfa9d6 "Fix" for pnm EOF detection (stop on read errors)
rtognimp
parents: 15076
diff changeset
671 if (n<0) return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
672 if (n<8) return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
673
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
674 /* skip 8 bytes if 0x62 is read */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
675 if (p->buffer[0] == 0x62)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
676 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
677 n = rm_read (p->s, p->buffer, 8);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
678 if (n<8) return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
679 #ifdef LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
680 printf("input_pnm: had to seek 8 bytes on 0x62\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
681 #endif
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
682 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
683
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
684 /* a server message */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
685 if (p->buffer[0] == 'X')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
686 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
687 int size=BE_16(&p->buffer[1]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
688
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
689 rm_read (p->s, &p->buffer[8], size-5);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
690 p->buffer[size+3]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
691 printf("input_pnm: got message from server while reading stream:\n%s\n", &p->buffer[3]);
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
692 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
693 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
694 if (p->buffer[0] == 'F')
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
695 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
696 printf("input_pnm: server error.\n");
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
697 return -1;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
698 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
699
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
700 /* skip bytewise to next chunk.
11000
6e35326c742f many small typo and grammar fixes
gabucino
parents: 10350
diff changeset
701 * seems, that we don't need that, if we send enough
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
702 * keepalives
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
703 */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
704 n=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
705 while (p->buffer[0] != 0x5a) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
706 int i;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
707 for (i=1; i<8; i++) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
708 p->buffer[i-1]=p->buffer[i];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
709 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
710 rm_read (p->s, &p->buffer[7], 1);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
711 n++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
712 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
713
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
714 #ifdef LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
715 if (n) printf("input_pnm: had to seek %i bytes to next chunk\n", n);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
716 #endif
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
717
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
718 /* check for 'Z's */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
719 if ((p->buffer[0] != 0x5a)||(p->buffer[7] != 0x5a))
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
720 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
721 printf("input_pnm: bad boundaries\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
722 hexdump(p->buffer, 8);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
723 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
724 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
725
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
726 /* check offsets */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
727 fof1=BE_16(&p->buffer[1]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
728 fof2=BE_16(&p->buffer[3]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
729 if (fof1 != fof2)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
730 {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
731 printf("input_pnm: frame offsets are different: 0x%04x 0x%04x\n",fof1,fof2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
732 return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
733 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
734
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
735 /* get first index */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
736 p->seq_current[0]=BE_16(&p->buffer[5]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
737
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
738 /* now read the rest of stream chunk */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
739 n = rm_read (p->s, &p->recv[5], fof1-5);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
740 if (n<(fof1-5)) return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
741
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
742 /* get second index */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
743 p->seq_current[1]=p->recv[5];
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
744
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
745 /* get timestamp */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
746 p->ts_current=BE_32(&p->recv[6]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
747
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
748 /* get stream number */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
749 stream=pnm_calc_stream(p);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
750
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
751 /* saving timestamp */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
752 p->ts_last[stream]=p->ts_current;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
753
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
754 /* constructing a data packet header */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
755
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
756 p->recv[0]=0; /* object version */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
757 p->recv[1]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
758
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
759 fof2=BE_16(&fof2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
760 memcpy(&p->recv[2], &fof2, 2);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
761 /*p->recv[2]=(fof2>>8)%0xff;*/ /* length */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
762 /*p->recv[3]=(fof2)%0xff;*/
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
763
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
764 p->recv[4]=0; /* stream number */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
765 p->recv[5]=stream;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
766
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
767 p->recv[10]=p->recv[10] & 0xfe; /* streambox seems to do that... */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
768
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
769 p->packet++;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
770
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
771 p->recv_size=fof1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
772
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
773 return fof1;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
774 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
775
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
776 // pnm_t *pnm_connect(const char *mrl) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
777 pnm_t *pnm_connect(int fd, char *path) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
778
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
779 pnm_t *p=malloc(sizeof(pnm_t));
8852
668cc9e77d2d check if prop_hdr==NULL insteda of sig11
arpi
parents: 8584
diff changeset
780 int need_response=0;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
781
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
782 p->path=strdup(path);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
783 p->s=fd;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
784
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
785 pnm_send_request(p,pnm_available_bandwidths[10]);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
786 if (!pnm_get_headers(p, &need_response)) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
787 printf ("input_pnm: failed to set up stream\n");
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
788 free(p->path);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
789 free(p);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
790 return NULL;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
791 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
792 if (need_response)
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
793 pnm_send_response(p, pnm_response);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
794 p->ts_last[0]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
795 p->ts_last[1]=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
796
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
797 /* copy header to recv */
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
798
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
799 memcpy(p->recv, p->header, p->header_len);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
800 p->recv_size = p->header_len;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
801 p->recv_read = 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
802
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
803 return p;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
804 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
805
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
806 int pnm_read (pnm_t *this, char *data, int len) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
807
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
808 int to_copy=len;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
809 char *dest=data;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
810 char *source=this->recv + this->recv_read;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
811 int fill=this->recv_size - this->recv_read;
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
812 int retval;
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
813
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
814 if (len < 0) return 0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
815 while (to_copy > fill) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
816
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
817 memcpy(dest, source, fill);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
818 to_copy -= fill;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
819 dest += fill;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
820 this->recv_read=0;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
821
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
822 if ((retval = pnm_get_stream_chunk (this)) <= 0) {
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
823 #ifdef LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
824 printf ("input_pnm: %d of %d bytes provided\n", len-to_copy, len);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
825 #endif
15076
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
826 if (retval < 0)
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
827 return retval;
1a02a23202c2 Stop streaming if we got a server error or message on pnm streaming.
rtognimp
parents: 14164
diff changeset
828 else
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
829 return len-to_copy;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
830 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
831 source = this->recv;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
832 fill = this->recv_size - this->recv_read;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
833 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
834
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
835 memcpy(dest, source, to_copy);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
836 this->recv_read += to_copy;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
837
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
838 #ifdef LOG
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
839 printf ("input_pnm: %d bytes provided\n", len);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
840 #endif
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
841
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
842 return len;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
843 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
844
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
845 int pnm_peek_header (pnm_t *this, char *data) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
846
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
847 memcpy (data, this->header, this->header_len);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
848 return this->header_len;
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
849 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
850
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
851 void pnm_close(pnm_t *p) {
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
852
10281
54bcbf28698a Networking support under MinGW.
diego
parents: 10232
diff changeset
853 if (p->s >= 0) closesocket(p->s);
8570
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
854 free(p->path);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
855 free(p);
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
856 }
16af93c01dbf pnm:// support (ported from xine)
arpi
parents:
diff changeset
857