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
|
/*
* lftp - file transfer program
*
* Copyright (c) 1999-2005 by Alexander V. Lukyanov (lav@yars.free.net)
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/
/* $Id: FileCopyOutputJob.cc,v 1.5 2008/11/27 05:56:13 lav Exp $ */
#include <config.h>
#include "FileCopy.h"
#include "FileCopyOutputJob.h"
FileCopyPeerOutputJob::FileCopyPeerOutputJob(const JobRef<OutputJob>& new_o)
: FileCopyPeer(PUT), o(new_o)
{
DontCopyDate();
}
int FileCopyPeerOutputJob::Put_LL(const char *buf,int len)
{
off_t io_at=pos;
if(GetRealPos()!=io_at) // GetRealPos can alter pos.
return 0;
if(len==0 && eof)
return 0;
if(o->Full())
return 0;
o->Put(buf,len);
seek_pos+=len; // mainly to indicate that there was some output.
return len;
}
int FileCopyPeerOutputJob::Do()
{
int m=STALL;
if(broken || done)
return m;
if(o->Error())
{
broken=true;
return MOVED;
}
if(eof && Size()==0)
{
done=true;
return MOVED;
}
if(!write_allowed)
return m;
while(Size()>0)
{
int res=Put_LL(buffer+buffer_ptr,Size());
if(res>0)
{
buffer_ptr+=res;
m=MOVED;
}
if(res<0)
return MOVED;
if(res==0)
break;
}
return m;
}
void FileCopyPeerOutputJob::Fg()
{
o->Fg();
FileCopyPeer::Fg();
}
void FileCopyPeerOutputJob::Bg()
{
o->Bg();
FileCopyPeer::Bg();
}
|