102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
/* TBD */
}else if( g.urlIsFile ){
if( transport.pFile ){
fclose(transport.pFile);
transport.pFile = 0;
}
unlink(transport.zInFile);
free(transport.zInFile);
unlink(transport.zOutFile);
free(transport.zOutFile);
}else{
socket_close();
}
transport.isOpen = 0;
}
}
|
<
>
|
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
/* TBD */
}else if( g.urlIsFile ){
if( transport.pFile ){
fclose(transport.pFile);
transport.pFile = 0;
}
unlink(transport.zInFile);
unlink(transport.zOutFile);
free(transport.zInFile);
free(transport.zOutFile);
}else{
socket_close();
}
transport.isOpen = 0;
}
}
|
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
** it is time to being recieving a reply.
*/
void transport_flip(void){
if( g.urlIsFile ){
char *zCmd;
fclose(transport.pFile);
zCmd = mprintf("\"%s\" http \"%s\" \"%s\" \"%s\" 127.0.0.1",
g.argv[0], g.zRepositoryName, transport.zOutFile, transport.zInFile
);
system(zCmd);
free(zCmd);
transport.pFile = fopen(transport.zInFile, "rb");
}
}
|
|
|
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
** it is time to being recieving a reply.
*/
void transport_flip(void){
if( g.urlIsFile ){
char *zCmd;
fclose(transport.pFile);
zCmd = mprintf("\"%s\" http \"%s\" \"%s\" \"%s\" 127.0.0.1",
g.argv[0], g.urlName, transport.zOutFile, transport.zInFile
);
system(zCmd);
free(zCmd);
transport.pFile = fopen(transport.zInFile, "rb");
}
}
|
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
|
}
if( N>0 ){
int got;
if( g.urlIsHttps ){
/* TBD */
got = 0;
}else if( g.urlIsFile ){
got = fread(zBuf, 0, N, transport.pFile);
}else{
got = socket_receive(0, zBuf, N);
}
if( got>0 ){
nByte += got;
}
}
|
|
|
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
|
}
if( N>0 ){
int got;
if( g.urlIsHttps ){
/* TBD */
got = 0;
}else if( g.urlIsFile ){
got = fread(zBuf, 1, N, transport.pFile);
}else{
got = socket_receive(0, zBuf, N);
}
if( got>0 ){
nByte += got;
}
}
|