Hex Artifact Content
Not logged in

Artifact 556260da363ec2062fd498640198e756197cfb32:


0000: 2f 2a 20 6f 77 6e 43 6c 6f 75 64 20 41 6e 64 72  /* ownCloud Andr
0010: 6f 69 64 20 4c 69 62 72 61 72 79 20 69 73 20 61  oid Library is a
0020: 76 61 69 6c 61 62 6c 65 20 75 6e 64 65 72 20 4d  vailable under M
0030: 49 54 20 6c 69 63 65 6e 73 65 0a 20 2a 20 20 20  IT license. *   
0040: 43 6f 70 79 72 69 67 68 74 20 28 43 29 20 32 30  Copyright (C) 20
0050: 31 35 20 6f 77 6e 43 6c 6f 75 64 20 49 6e 63 2e  15 ownCloud Inc.
0060: 0a 20 2a 20 20 20 0a 20 2a 20 20 20 50 65 72 6d  . *   . *   Perm
0070: 69 73 73 69 6f 6e 20 69 73 20 68 65 72 65 62 79  ission is hereby
0080: 20 67 72 61 6e 74 65 64 2c 20 66 72 65 65 20 6f   granted, free o
0090: 66 20 63 68 61 72 67 65 2c 20 74 6f 20 61 6e 79  f charge, to any
00a0: 20 70 65 72 73 6f 6e 20 6f 62 74 61 69 6e 69 6e   person obtainin
00b0: 67 20 61 20 63 6f 70 79 0a 20 2a 20 20 20 6f 66  g a copy. *   of
00c0: 20 74 68 69 73 20 73 6f 66 74 77 61 72 65 20 61   this software a
00d0: 6e 64 20 61 73 73 6f 63 69 61 74 65 64 20 64 6f  nd associated do
00e0: 63 75 6d 65 6e 74 61 74 69 6f 6e 20 66 69 6c 65  cumentation file
00f0: 73 20 28 74 68 65 20 22 53 6f 66 74 77 61 72 65  s (the "Software
0100: 22 29 2c 20 74 6f 20 64 65 61 6c 0a 20 2a 20 20  "), to deal. *  
0110: 20 69 6e 20 74 68 65 20 53 6f 66 74 77 61 72 65   in the Software
0120: 20 77 69 74 68 6f 75 74 20 72 65 73 74 72 69 63   without restric
0130: 74 69 6f 6e 2c 20 69 6e 63 6c 75 64 69 6e 67 20  tion, including 
0140: 77 69 74 68 6f 75 74 20 6c 69 6d 69 74 61 74 69  without limitati
0150: 6f 6e 20 74 68 65 20 72 69 67 68 74 73 0a 20 2a  on the rights. *
0160: 20 20 20 74 6f 20 75 73 65 2c 20 63 6f 70 79 2c     to use, copy,
0170: 20 6d 6f 64 69 66 79 2c 20 6d 65 72 67 65 2c 20   modify, merge, 
0180: 70 75 62 6c 69 73 68 2c 20 64 69 73 74 72 69 62  publish, distrib
0190: 75 74 65 2c 20 73 75 62 6c 69 63 65 6e 73 65 2c  ute, sublicense,
01a0: 20 61 6e 64 2f 6f 72 20 73 65 6c 6c 0a 20 2a 20   and/or sell. * 
01b0: 20 20 63 6f 70 69 65 73 20 6f 66 20 74 68 65 20    copies of the 
01c0: 53 6f 66 74 77 61 72 65 2c 20 61 6e 64 20 74 6f  Software, and to
01d0: 20 70 65 72 6d 69 74 20 70 65 72 73 6f 6e 73 20   permit persons 
01e0: 74 6f 20 77 68 6f 6d 20 74 68 65 20 53 6f 66 74  to whom the Soft
01f0: 77 61 72 65 20 69 73 0a 20 2a 20 20 20 66 75 72  ware is. *   fur
0200: 6e 69 73 68 65 64 20 74 6f 20 64 6f 20 73 6f 2c  nished to do so,
0210: 20 73 75 62 6a 65 63 74 20 74 6f 20 74 68 65 20   subject to the 
0220: 66 6f 6c 6c 6f 77 69 6e 67 20 63 6f 6e 64 69 74  following condit
0230: 69 6f 6e 73 3a 0a 20 2a 20 20 20 0a 20 2a 20 20  ions:. *   . *  
0240: 20 54 68 65 20 61 62 6f 76 65 20 63 6f 70 79 72   The above copyr
0250: 69 67 68 74 20 6e 6f 74 69 63 65 20 61 6e 64 20  ight notice and 
0260: 74 68 69 73 20 70 65 72 6d 69 73 73 69 6f 6e 20  this permission 
0270: 6e 6f 74 69 63 65 20 73 68 61 6c 6c 20 62 65 20  notice shall be 
0280: 69 6e 63 6c 75 64 65 64 20 69 6e 0a 20 2a 20 20  included in. *  
0290: 20 61 6c 6c 20 63 6f 70 69 65 73 20 6f 72 20 73   all copies or s
02a0: 75 62 73 74 61 6e 74 69 61 6c 20 70 6f 72 74 69  ubstantial porti
02b0: 6f 6e 73 20 6f 66 20 74 68 65 20 53 6f 66 74 77  ons of the Softw
02c0: 61 72 65 2e 0a 20 2a 20 20 20 0a 20 2a 20 20 20  are.. *   . *   
02d0: 54 48 45 20 53 4f 46 54 57 41 52 45 20 49 53 20  THE SOFTWARE IS 
02e0: 50 52 4f 56 49 44 45 44 20 22 41 53 20 49 53 22  PROVIDED "AS IS"
02f0: 2c 20 57 49 54 48 4f 55 54 20 57 41 52 52 41 4e  , WITHOUT WARRAN
0300: 54 59 20 4f 46 20 41 4e 59 20 4b 49 4e 44 2c 20  TY OF ANY KIND, 
0310: 0a 20 2a 20 20 20 45 58 50 52 45 53 53 20 4f 52  . *   EXPRESS OR
0320: 20 49 4d 50 4c 49 45 44 2c 20 49 4e 43 4c 55 44   IMPLIED, INCLUD
0330: 49 4e 47 20 42 55 54 20 4e 4f 54 20 4c 49 4d 49  ING BUT NOT LIMI
0340: 54 45 44 20 54 4f 20 54 48 45 20 57 41 52 52 41  TED TO THE WARRA
0350: 4e 54 49 45 53 20 4f 46 0a 20 2a 20 20 20 4d 45  NTIES OF. *   ME
0360: 52 43 48 41 4e 54 41 42 49 4c 49 54 59 2c 20 46  RCHANTABILITY, F
0370: 49 54 4e 45 53 53 20 46 4f 52 20 41 20 50 41 52  ITNESS FOR A PAR
0380: 54 49 43 55 4c 41 52 20 50 55 52 50 4f 53 45 20  TICULAR PURPOSE 
0390: 41 4e 44 20 0a 20 2a 20 20 20 4e 4f 4e 49 4e 46  AND . *   NONINF
03a0: 52 49 4e 47 45 4d 45 4e 54 2e 20 49 4e 20 4e 4f  RINGEMENT. IN NO
03b0: 20 45 56 45 4e 54 20 53 48 41 4c 4c 20 54 48 45   EVENT SHALL THE
03c0: 20 41 55 54 48 4f 52 53 20 4f 52 20 43 4f 50 59   AUTHORS OR COPY
03d0: 52 49 47 48 54 20 48 4f 4c 44 45 52 53 20 0a 20  RIGHT HOLDERS . 
03e0: 2a 20 20 20 42 45 20 4c 49 41 42 4c 45 20 46 4f  *   BE LIABLE FO
03f0: 52 20 41 4e 59 20 43 4c 41 49 4d 2c 20 44 41 4d  R ANY CLAIM, DAM
0400: 41 47 45 53 20 4f 52 20 4f 54 48 45 52 20 4c 49  AGES OR OTHER LI
0410: 41 42 49 4c 49 54 59 2c 20 57 48 45 54 48 45 52  ABILITY, WHETHER
0420: 20 49 4e 20 41 4e 20 0a 20 2a 20 20 20 41 43 54   IN AN . *   ACT
0430: 49 4f 4e 20 4f 46 20 43 4f 4e 54 52 41 43 54 2c  ION OF CONTRACT,
0440: 20 54 4f 52 54 20 4f 52 20 4f 54 48 45 52 57 49   TORT OR OTHERWI
0450: 53 45 2c 20 41 52 49 53 49 4e 47 20 46 52 4f 4d  SE, ARISING FROM
0460: 2c 20 4f 55 54 20 4f 46 20 4f 52 20 49 4e 20 0a  , OUT OF OR IN .
0470: 20 2a 20 20 20 43 4f 4e 4e 45 43 54 49 4f 4e 20   *   CONNECTION 
0480: 57 49 54 48 20 54 48 45 20 53 4f 46 54 57 41 52  WITH THE SOFTWAR
0490: 45 20 4f 52 20 54 48 45 20 55 53 45 20 4f 52 20  E OR THE USE OR 
04a0: 4f 54 48 45 52 20 44 45 41 4c 49 4e 47 53 20 49  OTHER DEALINGS I
04b0: 4e 0a 20 2a 20 20 20 54 48 45 20 53 4f 46 54 57  N. *   THE SOFTW
04c0: 41 52 45 2e 0a 20 2a 0a 20 2a 2f 0a 0a 70 61 63  ARE.. *. */..pac
04d0: 6b 61 67 65 20 63 6f 6d 2e 6f 77 6e 63 6c 6f 75  kage com.ownclou
04e0: 64 2e 61 6e 64 72 6f 69 64 2e 6c 69 62 2e 72 65  d.android.lib.re
04f0: 73 6f 75 72 63 65 73 2e 66 69 6c 65 73 3b 0a 0a  sources.files;..
0500: 69 6d 70 6f 72 74 20 63 6f 6d 2e 6f 77 6e 63 6c  import com.owncl
0510: 6f 75 64 2e 61 6e 64 72 6f 69 64 2e 6c 69 62 2e  oud.android.lib.
0520: 63 6f 6d 6d 6f 6e 2e 4f 77 6e 43 6c 6f 75 64 43  common.OwnCloudC
0530: 6c 69 65 6e 74 3b 0a 69 6d 70 6f 72 74 20 63 6f  lient;.import co
0540: 6d 2e 6f 77 6e 63 6c 6f 75 64 2e 61 6e 64 72 6f  m.owncloud.andro
0550: 69 64 2e 6c 69 62 2e 63 6f 6d 6d 6f 6e 2e 6e 65  id.lib.common.ne
0560: 74 77 6f 72 6b 2e 46 69 6c 65 52 65 71 75 65 73  twork.FileReques
0570: 74 45 6e 74 69 74 79 3b 0a 69 6d 70 6f 72 74 20  tEntity;.import 
0580: 63 6f 6d 2e 6f 77 6e 63 6c 6f 75 64 2e 61 6e 64  com.owncloud.and
0590: 72 6f 69 64 2e 6c 69 62 2e 63 6f 6d 6d 6f 6e 2e  roid.lib.common.
05a0: 6e 65 74 77 6f 72 6b 2e 4f 6e 44 61 74 61 74 72  network.OnDatatr
05b0: 61 6e 73 66 65 72 50 72 6f 67 72 65 73 73 4c 69  ansferProgressLi
05c0: 73 74 65 6e 65 72 3b 0a 69 6d 70 6f 72 74 20 63  stener;.import c
05d0: 6f 6d 2e 6f 77 6e 63 6c 6f 75 64 2e 61 6e 64 72  om.owncloud.andr
05e0: 6f 69 64 2e 6c 69 62 2e 63 6f 6d 6d 6f 6e 2e 6e  oid.lib.common.n
05f0: 65 74 77 6f 72 6b 2e 50 72 6f 67 72 65 73 73 69  etwork.Progressi
0600: 76 65 44 61 74 61 54 72 61 6e 73 66 65 72 65 72  veDataTransferer
0610: 3b 0a 69 6d 70 6f 72 74 20 63 6f 6d 2e 6f 77 6e  ;.import com.own
0620: 63 6c 6f 75 64 2e 61 6e 64 72 6f 69 64 2e 6c 69  cloud.android.li
0630: 62 2e 63 6f 6d 6d 6f 6e 2e 6e 65 74 77 6f 72 6b  b.common.network
0640: 2e 57 65 62 64 61 76 55 74 69 6c 73 3b 0a 69 6d  .WebdavUtils;.im
0650: 70 6f 72 74 20 63 6f 6d 2e 6f 77 6e 63 6c 6f 75  port com.ownclou
0660: 64 2e 61 6e 64 72 6f 69 64 2e 6c 69 62 2e 63 6f  d.android.lib.co
0670: 6d 6d 6f 6e 2e 6f 70 65 72 61 74 69 6f 6e 73 2e  mmon.operations.
0680: 4f 70 65 72 61 74 69 6f 6e 43 61 6e 63 65 6c 6c  OperationCancell
0690: 65 64 45 78 63 65 70 74 69 6f 6e 3b 0a 69 6d 70  edException;.imp
06a0: 6f 72 74 20 63 6f 6d 2e 6f 77 6e 63 6c 6f 75 64  ort com.owncloud
06b0: 2e 61 6e 64 72 6f 69 64 2e 6c 69 62 2e 63 6f 6d  .android.lib.com
06c0: 6d 6f 6e 2e 6f 70 65 72 61 74 69 6f 6e 73 2e 52  mon.operations.R
06d0: 65 6d 6f 74 65 4f 70 65 72 61 74 69 6f 6e 3b 0a  emoteOperation;.
06e0: 69 6d 70 6f 72 74 20 63 6f 6d 2e 6f 77 6e 63 6c  import com.owncl
06f0: 6f 75 64 2e 61 6e 64 72 6f 69 64 2e 6c 69 62 2e  oud.android.lib.
0700: 63 6f 6d 6d 6f 6e 2e 6f 70 65 72 61 74 69 6f 6e  common.operation
0710: 73 2e 52 65 6d 6f 74 65 4f 70 65 72 61 74 69 6f  s.RemoteOperatio
0720: 6e 52 65 73 75 6c 74 3b 0a 0a 69 6d 70 6f 72 74  nResult;..import
0730: 20 6f 72 67 2e 61 70 61 63 68 65 2e 63 6f 6d 6d   org.apache.comm
0740: 6f 6e 73 2e 68 74 74 70 63 6c 69 65 6e 74 2e 44  ons.httpclient.D
0750: 65 66 61 75 6c 74 48 74 74 70 4d 65 74 68 6f 64  efaultHttpMethod
0760: 52 65 74 72 79 48 61 6e 64 6c 65 72 3b 0a 69 6d  RetryHandler;.im
0770: 70 6f 72 74 20 6f 72 67 2e 61 70 61 63 68 65 2e  port org.apache.
0780: 63 6f 6d 6d 6f 6e 73 2e 68 74 74 70 63 6c 69 65  commons.httpclie
0790: 6e 74 2e 48 74 74 70 53 74 61 74 75 73 3b 0a 69  nt.HttpStatus;.i
07a0: 6d 70 6f 72 74 20 6f 72 67 2e 61 70 61 63 68 65  mport org.apache
07b0: 2e 63 6f 6d 6d 6f 6e 73 2e 68 74 74 70 63 6c 69  .commons.httpcli
07c0: 65 6e 74 2e 6d 65 74 68 6f 64 73 2e 50 75 74 4d  ent.methods.PutM
07d0: 65 74 68 6f 64 3b 0a 69 6d 70 6f 72 74 20 6f 72  ethod;.import or
07e0: 67 2e 61 70 61 63 68 65 2e 63 6f 6d 6d 6f 6e 73  g.apache.commons
07f0: 2e 68 74 74 70 63 6c 69 65 6e 74 2e 6d 65 74 68  .httpclient.meth
0800: 6f 64 73 2e 52 65 71 75 65 73 74 45 6e 74 69 74  ods.RequestEntit
0810: 79 3b 0a 69 6d 70 6f 72 74 20 6f 72 67 2e 61 70  y;.import org.ap
0820: 61 63 68 65 2e 63 6f 6d 6d 6f 6e 73 2e 68 74 74  ache.commons.htt
0830: 70 63 6c 69 65 6e 74 2e 70 61 72 61 6d 73 2e 48  pclient.params.H
0840: 74 74 70 4d 65 74 68 6f 64 50 61 72 61 6d 73 3b  ttpMethodParams;
0850: 0a 0a 69 6d 70 6f 72 74 20 6a 61 76 61 2e 69 6f  ..import java.io
0860: 2e 46 69 6c 65 3b 0a 69 6d 70 6f 72 74 20 6a 61  .File;.import ja
0870: 76 61 2e 69 6f 2e 49 4f 45 78 63 65 70 74 69 6f  va.io.IOExceptio
0880: 6e 3b 0a 69 6d 70 6f 72 74 20 6a 61 76 61 2e 75  n;.import java.u
0890: 74 69 6c 2e 48 61 73 68 53 65 74 3b 0a 69 6d 70  til.HashSet;.imp
08a0: 6f 72 74 20 6a 61 76 61 2e 75 74 69 6c 2e 53 65  ort java.util.Se
08b0: 74 3b 0a 69 6d 70 6f 72 74 20 6a 61 76 61 2e 75  t;.import java.u
08c0: 74 69 6c 2e 63 6f 6e 63 75 72 72 65 6e 74 2e 61  til.concurrent.a
08d0: 74 6f 6d 69 63 2e 41 74 6f 6d 69 63 42 6f 6f 6c  tomic.AtomicBool
08e0: 65 61 6e 3b 0a 0a 2f 2a 2a 0a 20 2a 20 52 65 6d  ean;../**. * Rem
08f0: 6f 74 65 20 6f 70 65 72 61 74 69 6f 6e 20 70 65  ote operation pe
0900: 72 66 6f 72 6d 69 6e 67 20 74 68 65 20 75 70 6c  rforming the upl
0910: 6f 61 64 20 6f 66 20 61 20 72 65 6d 6f 74 65 20  oad of a remote 
0920: 66 69 6c 65 20 74 6f 20 74 68 65 20 6f 77 6e 43  file to the ownC
0930: 6c 6f 75 64 20 73 65 72 76 65 72 2e 0a 20 2a 20  loud server.. * 
0940: 0a 20 2a 20 40 61 75 74 68 6f 72 20 44 61 76 69  . * @author Davi
0950: 64 20 41 2e 20 56 65 6c 61 73 63 6f 0a 20 2a 20  d A. Velasco. * 
0960: 40 61 75 74 68 6f 72 20 6d 61 73 65 6e 73 69 6f  @author masensio
0970: 0a 20 2a 2f 0a 0a 70 75 62 6c 69 63 20 63 6c 61  . */..public cla
0980: 73 73 20 55 70 6c 6f 61 64 52 65 6d 6f 74 65 46  ss UploadRemoteF
0990: 69 6c 65 4f 70 65 72 61 74 69 6f 6e 20 65 78 74  ileOperation ext
09a0: 65 6e 64 73 20 52 65 6d 6f 74 65 4f 70 65 72 61  ends RemoteOpera
09b0: 74 69 6f 6e 20 7b 0a 0a 09 70 72 69 76 61 74 65  tion {...private
09c0: 20 73 74 61 74 69 63 20 66 69 6e 61 6c 20 53 74   static final St
09d0: 72 69 6e 67 20 54 41 47 20 3d 20 55 70 6c 6f 61  ring TAG = Uploa
09e0: 64 52 65 6d 6f 74 65 46 69 6c 65 4f 70 65 72 61  dRemoteFileOpera
09f0: 74 69 6f 6e 2e 63 6c 61 73 73 2e 67 65 74 53 69  tion.class.getSi
0a00: 6d 70 6c 65 4e 61 6d 65 28 29 3b 0a 0a 09 70 72  mpleName();...pr
0a10: 6f 74 65 63 74 65 64 20 73 74 61 74 69 63 20 66  otected static f
0a20: 69 6e 61 6c 20 53 74 72 69 6e 67 20 4f 43 5f 54  inal String OC_T
0a30: 4f 54 41 4c 5f 4c 45 4e 47 54 48 5f 48 45 41 44  OTAL_LENGTH_HEAD
0a40: 45 52 20 3d 20 22 4f 43 2d 54 6f 74 61 6c 2d 4c  ER = "OC-Total-L
0a50: 65 6e 67 74 68 22 3b 0a 09 70 72 6f 74 65 63 74  ength";..protect
0a60: 65 64 20 73 74 61 74 69 63 20 66 69 6e 61 6c 20  ed static final 
0a70: 53 74 72 69 6e 67 20 49 46 5f 4d 41 54 43 48 5f  String IF_MATCH_
0a80: 48 45 41 44 45 52 20 3d 20 22 49 66 2d 4d 61 74  HEADER = "If-Mat
0a90: 63 68 22 3b 0a 20 20 20 20 70 72 6f 74 65 63 74  ch";.    protect
0aa0: 65 64 20 73 74 61 74 69 63 20 66 69 6e 61 6c 20  ed static final 
0ab0: 53 74 72 69 6e 67 20 4f 43 5f 58 5f 4f 43 5f 4d  String OC_X_OC_M
0ac0: 54 49 4d 45 5f 48 45 41 44 45 52 20 3d 20 22 58  TIME_HEADER = "X
0ad0: 2d 4f 43 2d 4d 74 69 6d 65 22 3b 0a 0a 09 70 72  -OC-Mtime";...pr
0ae0: 6f 74 65 63 74 65 64 20 53 74 72 69 6e 67 20 6d  otected String m
0af0: 4c 6f 63 61 6c 50 61 74 68 3b 0a 09 70 72 6f 74  LocalPath;..prot
0b00: 65 63 74 65 64 20 53 74 72 69 6e 67 20 6d 52 65  ected String mRe
0b10: 6d 6f 74 65 50 61 74 68 3b 0a 09 70 72 6f 74 65  motePath;..prote
0b20: 63 74 65 64 20 53 74 72 69 6e 67 20 6d 4d 69 6d  cted String mMim
0b30: 65 54 79 70 65 3b 0a 09 70 72 6f 74 65 63 74 65  eType;..protecte
0b40: 64 20 53 74 72 69 6e 67 20 6d 46 69 6c 65 4c 61  d String mFileLa
0b50: 73 74 4d 6f 64 69 66 54 69 6d 65 73 74 61 6d 70  stModifTimestamp
0b60: 3b 0a 09 70 72 6f 74 65 63 74 65 64 20 50 75 74  ;..protected Put
0b70: 4d 65 74 68 6f 64 20 6d 50 75 74 4d 65 74 68 6f  Method mPutMetho
0b80: 64 20 3d 20 6e 75 6c 6c 3b 0a 09 70 72 6f 74 65  d = null;..prote
0b90: 63 74 65 64 20 53 74 72 69 6e 67 20 6d 52 65 71  cted String mReq
0ba0: 75 69 72 65 64 45 74 61 67 20 3d 20 6e 75 6c 6c  uiredEtag = null
0bb0: 3b 0a 0a 09 70 72 6f 74 65 63 74 65 64 20 66 69  ;...protected fi
0bc0: 6e 61 6c 20 41 74 6f 6d 69 63 42 6f 6f 6c 65 61  nal AtomicBoolea
0bd0: 6e 20 6d 43 61 6e 63 65 6c 6c 61 74 69 6f 6e 52  n mCancellationR
0be0: 65 71 75 65 73 74 65 64 20 3d 20 6e 65 77 20 41  equested = new A
0bf0: 74 6f 6d 69 63 42 6f 6f 6c 65 61 6e 28 66 61 6c  tomicBoolean(fal
0c00: 73 65 29 3b 0a 09 70 72 6f 74 65 63 74 65 64 20  se);..protected 
0c10: 53 65 74 3c 4f 6e 44 61 74 61 74 72 61 6e 73 66  Set<OnDatatransf
0c20: 65 72 50 72 6f 67 72 65 73 73 4c 69 73 74 65 6e  erProgressListen
0c30: 65 72 3e 20 6d 44 61 74 61 54 72 61 6e 73 66 65  er> mDataTransfe
0c40: 72 4c 69 73 74 65 6e 65 72 73 20 3d 20 6e 65 77  rListeners = new
0c50: 20 48 61 73 68 53 65 74 3c 4f 6e 44 61 74 61 74   HashSet<OnDatat
0c60: 72 61 6e 73 66 65 72 50 72 6f 67 72 65 73 73 4c  ransferProgressL
0c70: 69 73 74 65 6e 65 72 3e 28 29 3b 0a 0a 09 70 72  istener>();...pr
0c80: 6f 74 65 63 74 65 64 20 52 65 71 75 65 73 74 45  otected RequestE
0c90: 6e 74 69 74 79 20 6d 45 6e 74 69 74 79 20 3d 20  ntity mEntity = 
0ca0: 6e 75 6c 6c 3b 0a 0a 09 70 75 62 6c 69 63 20 55  null;...public U
0cb0: 70 6c 6f 61 64 52 65 6d 6f 74 65 46 69 6c 65 4f  ploadRemoteFileO
0cc0: 70 65 72 61 74 69 6f 6e 28 53 74 72 69 6e 67 20  peration(String 
0cd0: 6c 6f 63 61 6c 50 61 74 68 2c 20 53 74 72 69 6e  localPath, Strin
0ce0: 67 20 72 65 6d 6f 74 65 50 61 74 68 2c 20 53 74  g remotePath, St
0cf0: 72 69 6e 67 20 6d 69 6d 65 54 79 70 65 2c 0a 09  ring mimeType,..
0d00: 09 09 09 09 09 09 09 09 20 53 74 72 69 6e 67 20  ........ String 
0d10: 66 69 6c 65 4c 61 73 74 4d 6f 64 69 66 54 69 6d  fileLastModifTim
0d20: 65 73 74 61 6d 70 29 20 7b 0a 09 09 6d 4c 6f 63  estamp) {...mLoc
0d30: 61 6c 50 61 74 68 20 3d 20 6c 6f 63 61 6c 50 61  alPath = localPa
0d40: 74 68 3b 0a 09 09 6d 52 65 6d 6f 74 65 50 61 74  th;...mRemotePat
0d50: 68 20 3d 20 72 65 6d 6f 74 65 50 61 74 68 3b 0a  h = remotePath;.
0d60: 09 09 6d 4d 69 6d 65 54 79 70 65 20 3d 20 6d 69  ..mMimeType = mi
0d70: 6d 65 54 79 70 65 3b 0a 09 09 6d 46 69 6c 65 4c  meType;...mFileL
0d80: 61 73 74 4d 6f 64 69 66 54 69 6d 65 73 74 61 6d  astModifTimestam
0d90: 70 20 3d 20 66 69 6c 65 4c 61 73 74 4d 6f 64 69  p = fileLastModi
0da0: 66 54 69 6d 65 73 74 61 6d 70 3b 0a 09 7d 0a 0a  fTimestamp;..}..
0db0: 09 70 75 62 6c 69 63 20 55 70 6c 6f 61 64 52 65  .public UploadRe
0dc0: 6d 6f 74 65 46 69 6c 65 4f 70 65 72 61 74 69 6f  moteFileOperatio
0dd0: 6e 28 53 74 72 69 6e 67 20 6c 6f 63 61 6c 50 61  n(String localPa
0de0: 74 68 2c 20 53 74 72 69 6e 67 20 72 65 6d 6f 74  th, String remot
0df0: 65 50 61 74 68 2c 20 53 74 72 69 6e 67 20 6d 69  ePath, String mi
0e00: 6d 65 54 79 70 65 2c 20 53 74 72 69 6e 67 20 72  meType, String r
0e10: 65 71 75 69 72 65 64 45 74 61 67 2c 0a 09 09 09  equiredEtag,....
0e20: 09 09 09 09 09 09 20 53 74 72 69 6e 67 20 66 69  ...... String fi
0e30: 6c 65 4c 61 73 74 4d 6f 64 69 66 54 69 6d 65 73  leLastModifTimes
0e40: 74 61 6d 70 29 20 7b 0a 09 09 74 68 69 73 28 6c  tamp) {...this(l
0e50: 6f 63 61 6c 50 61 74 68 2c 20 72 65 6d 6f 74 65  ocalPath, remote
0e60: 50 61 74 68 2c 20 6d 69 6d 65 54 79 70 65 2c 20  Path, mimeType, 
0e70: 66 69 6c 65 4c 61 73 74 4d 6f 64 69 66 54 69 6d  fileLastModifTim
0e80: 65 73 74 61 6d 70 29 3b 0a 09 09 6d 52 65 71 75  estamp);...mRequ
0e90: 69 72 65 64 45 74 61 67 20 3d 20 72 65 71 75 69  iredEtag = requi
0ea0: 72 65 64 45 74 61 67 3b 0a 09 7d 0a 0a 09 40 4f  redEtag;..}...@O
0eb0: 76 65 72 72 69 64 65 0a 09 70 72 6f 74 65 63 74  verride..protect
0ec0: 65 64 20 52 65 6d 6f 74 65 4f 70 65 72 61 74 69  ed RemoteOperati
0ed0: 6f 6e 52 65 73 75 6c 74 20 72 75 6e 28 4f 77 6e  onResult run(Own
0ee0: 43 6c 6f 75 64 43 6c 69 65 6e 74 20 63 6c 69 65  CloudClient clie
0ef0: 6e 74 29 20 7b 0a 09 09 52 65 6d 6f 74 65 4f 70  nt) {...RemoteOp
0f00: 65 72 61 74 69 6f 6e 52 65 73 75 6c 74 20 72 65  erationResult re
0f10: 73 75 6c 74 20 3d 20 6e 75 6c 6c 3b 0a 09 09 44  sult = null;...D
0f20: 65 66 61 75 6c 74 48 74 74 70 4d 65 74 68 6f 64  efaultHttpMethod
0f30: 52 65 74 72 79 48 61 6e 64 6c 65 72 20 6f 6c 64  RetryHandler old
0f40: 52 65 74 72 79 48 61 6e 64 6c 65 72 20 3d 0a 09  RetryHandler =..
0f50: 09 09 28 44 65 66 61 75 6c 74 48 74 74 70 4d 65  ..(DefaultHttpMe
0f60: 74 68 6f 64 52 65 74 72 79 48 61 6e 64 6c 65 72  thodRetryHandler
0f70: 29 20 63 6c 69 65 6e 74 2e 67 65 74 50 61 72 61  ) client.getPara
0f80: 6d 73 28 29 2e 67 65 74 50 61 72 61 6d 65 74 65  ms().getParamete
0f90: 72 28 48 74 74 70 4d 65 74 68 6f 64 50 61 72 61  r(HttpMethodPara
0fa0: 6d 73 2e 52 45 54 52 59 5f 48 41 4e 44 4c 45 52  ms.RETRY_HANDLER
0fb0: 29 3b 0a 0a 09 09 74 72 79 20 7b 0a 09 09 09 2f  );....try {..../
0fc0: 2f 20 70 72 65 76 65 6e 74 20 74 68 61 74 20 75  / prevent that u
0fd0: 70 6c 6f 61 64 73 20 61 72 65 20 72 65 74 72 69  ploads are retri
0fe0: 65 64 20 61 75 74 6f 6d 61 74 69 63 61 6c 6c 79  ed automatically
0ff0: 20 62 79 20 6e 65 74 77 6f 72 6b 20 6c 69 62 72   by network libr
1000: 61 72 79 0a 09 09 09 63 6c 69 65 6e 74 2e 67 65  ary....client.ge
1010: 74 50 61 72 61 6d 73 28 29 2e 73 65 74 50 61 72  tParams().setPar
1020: 61 6d 65 74 65 72 28 0a 09 09 09 09 48 74 74 70  ameter(.....Http
1030: 4d 65 74 68 6f 64 50 61 72 61 6d 73 2e 52 45 54  MethodParams.RET
1040: 52 59 5f 48 41 4e 44 4c 45 52 2c 0a 09 09 09 09  RY_HANDLER,.....
1050: 6e 65 77 20 44 65 66 61 75 6c 74 48 74 74 70 4d  new DefaultHttpM
1060: 65 74 68 6f 64 52 65 74 72 79 48 61 6e 64 6c 65  ethodRetryHandle
1070: 72 28 30 2c 20 66 61 6c 73 65 29 0a 09 09 09 29  r(0, false)....)
1080: 3b 0a 0a 09 09 09 6d 50 75 74 4d 65 74 68 6f 64  ;.....mPutMethod
1090: 20 3d 20 6e 65 77 20 50 75 74 4d 65 74 68 6f 64   = new PutMethod
10a0: 28 63 6c 69 65 6e 74 2e 67 65 74 57 65 62 64 61  (client.getWebda
10b0: 76 55 72 69 28 29 20 2b 20 57 65 62 64 61 76 55  vUri() + WebdavU
10c0: 74 69 6c 73 2e 65 6e 63 6f 64 65 50 61 74 68 28  tils.encodePath(
10d0: 6d 52 65 6d 6f 74 65 50 61 74 68 29 29 3b 0a 0a  mRemotePath));..
10e0: 09 09 09 69 66 20 28 6d 43 61 6e 63 65 6c 6c 61  ...if (mCancella
10f0: 74 69 6f 6e 52 65 71 75 65 73 74 65 64 2e 67 65  tionRequested.ge
1100: 74 28 29 29 20 7b 0a 09 09 09 09 2f 2f 20 74 68  t()) {.....// th
1110: 65 20 6f 70 65 72 61 74 69 6f 6e 20 77 61 73 20  e operation was 
1120: 63 61 6e 63 65 6c 6c 65 64 20 62 65 66 6f 72 65  cancelled before
1130: 20 67 65 74 74 69 6e 67 20 69 74 27 73 20 74 75   getting it's tu
1140: 72 6e 20 74 6f 20 62 65 20 65 78 65 63 75 74 65  rn to be execute
1150: 64 20 69 6e 20 74 68 65 20 71 75 65 75 65 20 6f  d in the queue o
1160: 66 20 75 70 6c 6f 61 64 73 0a 09 09 09 09 72 65  f uploads.....re
1170: 73 75 6c 74 20 3d 20 6e 65 77 20 52 65 6d 6f 74  sult = new Remot
1180: 65 4f 70 65 72 61 74 69 6f 6e 52 65 73 75 6c 74  eOperationResult
1190: 28 6e 65 77 20 4f 70 65 72 61 74 69 6f 6e 43 61  (new OperationCa
11a0: 6e 63 65 6c 6c 65 64 45 78 63 65 70 74 69 6f 6e  ncelledException
11b0: 28 29 29 3b 0a 0a 09 09 09 7d 20 65 6c 73 65 20  ());.....} else 
11c0: 7b 0a 09 09 09 09 2f 2f 20 70 65 72 66 6f 72 6d  {.....// perform
11d0: 20 74 68 65 20 75 70 6c 6f 61 64 0a 09 09 09 09   the upload.....
11e0: 72 65 73 75 6c 74 20 3d 20 75 70 6c 6f 61 64 46  result = uploadF
11f0: 69 6c 65 28 63 6c 69 65 6e 74 29 3b 0a 09 09 09  ile(client);....
1200: 7d 0a 0a 09 09 7d 20 63 61 74 63 68 20 28 45 78  }....} catch (Ex
1210: 63 65 70 74 69 6f 6e 20 65 29 20 7b 0a 09 09 09  ception e) {....
1220: 69 66 20 28 6d 50 75 74 4d 65 74 68 6f 64 20 21  if (mPutMethod !
1230: 3d 20 6e 75 6c 6c 20 26 26 20 6d 50 75 74 4d 65  = null && mPutMe
1240: 74 68 6f 64 2e 69 73 41 62 6f 72 74 65 64 28 29  thod.isAborted()
1250: 29 20 7b 0a 09 09 09 09 72 65 73 75 6c 74 20 3d  ) {.....result =
1260: 20 6e 65 77 20 52 65 6d 6f 74 65 4f 70 65 72 61   new RemoteOpera
1270: 74 69 6f 6e 52 65 73 75 6c 74 28 6e 65 77 20 4f  tionResult(new O
1280: 70 65 72 61 74 69 6f 6e 43 61 6e 63 65 6c 6c 65  perationCancelle
1290: 64 45 78 63 65 70 74 69 6f 6e 28 29 29 3b 0a 0a  dException());..
12a0: 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09  ...} else {.....
12b0: 72 65 73 75 6c 74 20 3d 20 6e 65 77 20 52 65 6d  result = new Rem
12c0: 6f 74 65 4f 70 65 72 61 74 69 6f 6e 52 65 73 75  oteOperationResu
12d0: 6c 74 28 65 29 3b 0a 09 09 09 7d 0a 09 09 7d 20  lt(e);....}...} 
12e0: 66 69 6e 61 6c 6c 79 20 7b 0a 09 09 09 2f 2f 20  finally {....// 
12f0: 72 65 73 65 74 20 70 72 65 76 69 6f 75 73 20 72  reset previous r
1300: 65 74 72 79 20 68 61 6e 64 6c 65 72 0a 09 09 09  etry handler....
1310: 63 6c 69 65 6e 74 2e 67 65 74 50 61 72 61 6d 73  client.getParams
1320: 28 29 2e 73 65 74 50 61 72 61 6d 65 74 65 72 28  ().setParameter(
1330: 0a 09 09 09 09 48 74 74 70 4d 65 74 68 6f 64 50  .....HttpMethodP
1340: 61 72 61 6d 73 2e 52 45 54 52 59 5f 48 41 4e 44  arams.RETRY_HAND
1350: 4c 45 52 2c 0a 09 09 09 09 6f 6c 64 52 65 74 72  LER,.....oldRetr
1360: 79 48 61 6e 64 6c 65 72 0a 09 09 09 29 3b 0a 09  yHandler....);..
1370: 09 7d 0a 09 09 72 65 74 75 72 6e 20 72 65 73 75  .}...return resu
1380: 6c 74 3b 0a 09 7d 0a 0a 09 70 75 62 6c 69 63 20  lt;..}...public 
1390: 62 6f 6f 6c 65 61 6e 20 69 73 53 75 63 63 65 73  boolean isSucces
13a0: 73 28 69 6e 74 20 73 74 61 74 75 73 29 20 7b 0a  s(int status) {.
13b0: 09 09 72 65 74 75 72 6e 20 28 28 73 74 61 74 75  ..return ((statu
13c0: 73 20 3d 3d 20 48 74 74 70 53 74 61 74 75 73 2e  s == HttpStatus.
13d0: 53 43 5f 4f 4b 20 7c 7c 20 73 74 61 74 75 73 20  SC_OK || status 
13e0: 3d 3d 20 48 74 74 70 53 74 61 74 75 73 2e 53 43  == HttpStatus.SC
13f0: 5f 43 52 45 41 54 45 44 20 7c 7c 0a 20 20 20 20  _CREATED ||.    
1400: 20 20 20 20 20 20 20 20 20 20 20 20 73 74 61 74              stat
1410: 75 73 20 3d 3d 20 48 74 74 70 53 74 61 74 75 73  us == HttpStatus
1420: 2e 53 43 5f 4e 4f 5f 43 4f 4e 54 45 4e 54 29 29  .SC_NO_CONTENT))
1430: 3b 0a 09 7d 0a 0a 09 70 72 6f 74 65 63 74 65 64  ;..}...protected
1440: 20 52 65 6d 6f 74 65 4f 70 65 72 61 74 69 6f 6e   RemoteOperation
1450: 52 65 73 75 6c 74 20 75 70 6c 6f 61 64 46 69 6c  Result uploadFil
1460: 65 28 4f 77 6e 43 6c 6f 75 64 43 6c 69 65 6e 74  e(OwnCloudClient
1470: 20 63 6c 69 65 6e 74 29 20 74 68 72 6f 77 73 20   client) throws 
1480: 49 4f 45 78 63 65 70 74 69 6f 6e 20 7b 0a 09 09  IOException {...
1490: 69 6e 74 20 73 74 61 74 75 73 20 3d 20 2d 31 3b  int status = -1;
14a0: 0a 09 09 52 65 6d 6f 74 65 4f 70 65 72 61 74 69  ...RemoteOperati
14b0: 6f 6e 52 65 73 75 6c 74 20 72 65 73 75 6c 74 3b  onResult result;
14c0: 0a 0a 09 09 74 72 79 20 7b 0a 09 09 09 46 69 6c  ....try {....Fil
14d0: 65 20 66 20 3d 20 6e 65 77 20 46 69 6c 65 28 6d  e f = new File(m
14e0: 4c 6f 63 61 6c 50 61 74 68 29 3b 0a 09 09 09 6d  LocalPath);....m
14f0: 45 6e 74 69 74 79 20 20 3d 20 6e 65 77 20 46 69  Entity  = new Fi
1500: 6c 65 52 65 71 75 65 73 74 45 6e 74 69 74 79 28  leRequestEntity(
1510: 66 2c 20 6d 4d 69 6d 65 54 79 70 65 29 3b 0a 09  f, mMimeType);..
1520: 09 09 73 79 6e 63 68 72 6f 6e 69 7a 65 64 20 28  ..synchronized (
1530: 6d 44 61 74 61 54 72 61 6e 73 66 65 72 4c 69 73  mDataTransferLis
1540: 74 65 6e 65 72 73 29 20 7b 0a 09 09 09 09 28 28  teners) {.....((
1550: 50 72 6f 67 72 65 73 73 69 76 65 44 61 74 61 54  ProgressiveDataT
1560: 72 61 6e 73 66 65 72 65 72 29 6d 45 6e 74 69 74  ransferer)mEntit
1570: 79 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20  y).             
1580: 20 20 20 20 20 20 20 20 20 20 20 2e 61 64 64 44             .addD
1590: 61 74 61 74 72 61 6e 73 66 65 72 50 72 6f 67 72  atatransferProgr
15a0: 65 73 73 4c 69 73 74 65 6e 65 72 73 28 6d 44 61  essListeners(mDa
15b0: 74 61 54 72 61 6e 73 66 65 72 4c 69 73 74 65 6e  taTransferListen
15c0: 65 72 73 29 3b 0a 09 09 09 7d 0a 09 09 09 69 66  ers);....}....if
15d0: 20 28 6d 52 65 71 75 69 72 65 64 45 74 61 67 20   (mRequiredEtag 
15e0: 21 3d 20 6e 75 6c 6c 20 26 26 20 6d 52 65 71 75  != null && mRequ
15f0: 69 72 65 64 45 74 61 67 2e 6c 65 6e 67 74 68 28  iredEtag.length(
1600: 29 20 3e 20 30 29 20 7b 0a 09 09 09 09 6d 50 75  ) > 0) {.....mPu
1610: 74 4d 65 74 68 6f 64 2e 61 64 64 52 65 71 75 65  tMethod.addReque
1620: 73 74 48 65 61 64 65 72 28 49 46 5f 4d 41 54 43  stHeader(IF_MATC
1630: 48 5f 48 45 41 44 45 52 2c 20 22 5c 22 22 20 2b  H_HEADER, "\"" +
1640: 20 6d 52 65 71 75 69 72 65 64 45 74 61 67 20 2b   mRequiredEtag +
1650: 20 22 5c 22 22 29 3b 0a 09 09 09 7d 0a 09 09 09   "\"");....}....
1660: 6d 50 75 74 4d 65 74 68 6f 64 2e 61 64 64 52 65  mPutMethod.addRe
1670: 71 75 65 73 74 48 65 61 64 65 72 28 4f 43 5f 54  questHeader(OC_T
1680: 4f 54 41 4c 5f 4c 45 4e 47 54 48 5f 48 45 41 44  OTAL_LENGTH_HEAD
1690: 45 52 2c 20 53 74 72 69 6e 67 2e 76 61 6c 75 65  ER, String.value
16a0: 4f 66 28 66 2e 6c 65 6e 67 74 68 28 29 29 29 3b  Of(f.length()));
16b0: 0a 20 20 20 20 20 20 20 20 20 20 20 20 6d 50 75  .            mPu
16c0: 74 4d 65 74 68 6f 64 2e 61 64 64 52 65 71 75 65  tMethod.addReque
16d0: 73 74 48 65 61 64 65 72 28 4f 43 5f 58 5f 4f 43  stHeader(OC_X_OC
16e0: 5f 4d 54 49 4d 45 5f 48 45 41 44 45 52 2c 20 6d  _MTIME_HEADER, m
16f0: 46 69 6c 65 4c 61 73 74 4d 6f 64 69 66 54 69 6d  FileLastModifTim
1700: 65 73 74 61 6d 70 29 3b 0a 09 09 09 6d 50 75 74  estamp);....mPut
1710: 4d 65 74 68 6f 64 2e 73 65 74 52 65 71 75 65 73  Method.setReques
1720: 74 45 6e 74 69 74 79 28 6d 45 6e 74 69 74 79 29  tEntity(mEntity)
1730: 3b 0a 09 09 09 73 74 61 74 75 73 20 3d 20 63 6c  ;....status = cl
1740: 69 65 6e 74 2e 65 78 65 63 75 74 65 4d 65 74 68  ient.executeMeth
1750: 6f 64 28 6d 50 75 74 4d 65 74 68 6f 64 29 3b 0a  od(mPutMethod);.
1760: 0a 09 09 09 72 65 73 75 6c 74 20 3d 20 6e 65 77  ....result = new
1770: 20 52 65 6d 6f 74 65 4f 70 65 72 61 74 69 6f 6e   RemoteOperation
1780: 52 65 73 75 6c 74 28 69 73 53 75 63 63 65 73 73  Result(isSuccess
1790: 28 73 74 61 74 75 73 29 2c 20 6d 50 75 74 4d 65  (status), mPutMe
17a0: 74 68 6f 64 29 3b 0a 0a 09 09 09 63 6c 69 65 6e  thod);.....clien
17b0: 74 2e 65 78 68 61 75 73 74 52 65 73 70 6f 6e 73  t.exhaustRespons
17c0: 65 28 6d 50 75 74 4d 65 74 68 6f 64 2e 67 65 74  e(mPutMethod.get
17d0: 52 65 73 70 6f 6e 73 65 42 6f 64 79 41 73 53 74  ResponseBodyAsSt
17e0: 72 65 61 6d 28 29 29 3b 0a 0a 09 09 7d 20 66 69  ream());....} fi
17f0: 6e 61 6c 6c 79 20 7b 0a 09 09 09 6d 50 75 74 4d  nally {....mPutM
1800: 65 74 68 6f 64 2e 72 65 6c 65 61 73 65 43 6f 6e  ethod.releaseCon
1810: 6e 65 63 74 69 6f 6e 28 29 3b 20 2f 2f 20 6c 65  nection(); // le
1820: 74 20 74 68 65 20 63 6f 6e 6e 65 63 74 69 6f 6e  t the connection
1830: 20 61 76 61 69 6c 61 62 6c 65 20 66 6f 72 20 6f   available for o
1840: 74 68 65 72 20 6d 65 74 68 6f 64 73 0a 09 09 7d  ther methods...}
1850: 0a 09 09 72 65 74 75 72 6e 20 72 65 73 75 6c 74  ...return result
1860: 3b 0a 09 7d 0a 0a 20 20 20 20 70 75 62 6c 69 63  ;..}..    public
1870: 20 53 65 74 3c 4f 6e 44 61 74 61 74 72 61 6e 73   Set<OnDatatrans
1880: 66 65 72 50 72 6f 67 72 65 73 73 4c 69 73 74 65  ferProgressListe
1890: 6e 65 72 3e 20 67 65 74 44 61 74 61 54 72 61 6e  ner> getDataTran
18a0: 73 66 65 72 4c 69 73 74 65 6e 65 72 73 28 29 20  sferListeners() 
18b0: 7b 0a 20 20 20 20 20 20 20 20 72 65 74 75 72 6e  {.        return
18c0: 20 6d 44 61 74 61 54 72 61 6e 73 66 65 72 4c 69   mDataTransferLi
18d0: 73 74 65 6e 65 72 73 3b 0a 20 20 20 20 7d 0a 20  steners;.    }. 
18e0: 20 20 20 0a 20 20 20 20 70 75 62 6c 69 63 20 76     .    public v
18f0: 6f 69 64 20 61 64 64 44 61 74 61 74 72 61 6e 73  oid addDatatrans
1900: 66 65 72 50 72 6f 67 72 65 73 73 4c 69 73 74 65  ferProgressListe
1910: 6e 65 72 20 28 4f 6e 44 61 74 61 74 72 61 6e 73  ner (OnDatatrans
1920: 66 65 72 50 72 6f 67 72 65 73 73 4c 69 73 74 65  ferProgressListe
1930: 6e 65 72 20 6c 69 73 74 65 6e 65 72 29 20 7b 0a  ner listener) {.
1940: 20 20 20 20 20 20 20 20 73 79 6e 63 68 72 6f 6e          synchron
1950: 69 7a 65 64 20 28 6d 44 61 74 61 54 72 61 6e 73  ized (mDataTrans
1960: 66 65 72 4c 69 73 74 65 6e 65 72 73 29 20 7b 0a  ferListeners) {.
1970: 20 20 20 20 20 20 20 20 20 20 20 20 6d 44 61 74              mDat
1980: 61 54 72 61 6e 73 66 65 72 4c 69 73 74 65 6e 65  aTransferListene
1990: 72 73 2e 61 64 64 28 6c 69 73 74 65 6e 65 72 29  rs.add(listener)
19a0: 3b 0a 20 20 20 20 20 20 20 20 7d 0a 20 20 20 20  ;.        }.    
19b0: 20 20 20 20 69 66 20 28 6d 45 6e 74 69 74 79 20      if (mEntity 
19c0: 21 3d 20 6e 75 6c 6c 29 20 7b 0a 20 20 20 20 20  != null) {.     
19d0: 20 20 20 20 20 20 20 28 28 50 72 6f 67 72 65 73         ((Progres
19e0: 73 69 76 65 44 61 74 61 54 72 61 6e 73 66 65 72  siveDataTransfer
19f0: 65 72 29 6d 45 6e 74 69 74 79 29 2e 61 64 64 44  er)mEntity).addD
1a00: 61 74 61 74 72 61 6e 73 66 65 72 50 72 6f 67 72  atatransferProgr
1a10: 65 73 73 4c 69 73 74 65 6e 65 72 28 6c 69 73 74  essListener(list
1a20: 65 6e 65 72 29 3b 0a 20 20 20 20 20 20 20 20 7d  ener);.        }
1a30: 0a 20 20 20 20 7d 0a 20 20 20 20 0a 20 20 20 20  .    }.    .    
1a40: 70 75 62 6c 69 63 20 76 6f 69 64 20 72 65 6d 6f  public void remo
1a50: 76 65 44 61 74 61 74 72 61 6e 73 66 65 72 50 72  veDatatransferPr
1a60: 6f 67 72 65 73 73 4c 69 73 74 65 6e 65 72 28 4f  ogressListener(O
1a70: 6e 44 61 74 61 74 72 61 6e 73 66 65 72 50 72 6f  nDatatransferPro
1a80: 67 72 65 73 73 4c 69 73 74 65 6e 65 72 20 6c 69  gressListener li
1a90: 73 74 65 6e 65 72 29 20 7b 0a 20 20 20 20 20 20  stener) {.      
1aa0: 20 20 73 79 6e 63 68 72 6f 6e 69 7a 65 64 20 28    synchronized (
1ab0: 6d 44 61 74 61 54 72 61 6e 73 66 65 72 4c 69 73  mDataTransferLis
1ac0: 74 65 6e 65 72 73 29 20 7b 0a 20 20 20 20 20 20  teners) {.      
1ad0: 20 20 20 20 20 20 6d 44 61 74 61 54 72 61 6e 73        mDataTrans
1ae0: 66 65 72 4c 69 73 74 65 6e 65 72 73 2e 72 65 6d  ferListeners.rem
1af0: 6f 76 65 28 6c 69 73 74 65 6e 65 72 29 3b 0a 20  ove(listener);. 
1b00: 20 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20         }.       
1b10: 20 69 66 20 28 6d 45 6e 74 69 74 79 20 21 3d 20   if (mEntity != 
1b20: 6e 75 6c 6c 29 20 7b 0a 20 20 20 20 20 20 20 20  null) {.        
1b30: 20 20 20 20 28 28 50 72 6f 67 72 65 73 73 69 76      ((Progressiv
1b40: 65 44 61 74 61 54 72 61 6e 73 66 65 72 65 72 29  eDataTransferer)
1b50: 6d 45 6e 74 69 74 79 29 2e 72 65 6d 6f 76 65 44  mEntity).removeD
1b60: 61 74 61 74 72 61 6e 73 66 65 72 50 72 6f 67 72  atatransferProgr
1b70: 65 73 73 4c 69 73 74 65 6e 65 72 28 6c 69 73 74  essListener(list
1b80: 65 6e 65 72 29 3b 0a 20 20 20 20 20 20 20 20 7d  ener);.        }
1b90: 0a 20 20 20 20 7d 0a 20 20 20 20 0a 20 20 20 20  .    }.    .    
1ba0: 70 75 62 6c 69 63 20 76 6f 69 64 20 63 61 6e 63  public void canc
1bb0: 65 6c 28 29 20 7b 0a 20 20 20 20 20 20 20 20 73  el() {.        s
1bc0: 79 6e 63 68 72 6f 6e 69 7a 65 64 20 28 6d 43 61  ynchronized (mCa
1bd0: 6e 63 65 6c 6c 61 74 69 6f 6e 52 65 71 75 65 73  ncellationReques
1be0: 74 65 64 29 20 7b 0a 20 20 20 20 20 20 20 20 20  ted) {.         
1bf0: 20 20 20 6d 43 61 6e 63 65 6c 6c 61 74 69 6f 6e     mCancellation
1c00: 52 65 71 75 65 73 74 65 64 2e 73 65 74 28 74 72  Requested.set(tr
1c10: 75 65 29 3b 0a 20 20 20 20 20 20 20 20 20 20 20  ue);.           
1c20: 20 69 66 20 28 6d 50 75 74 4d 65 74 68 6f 64 20   if (mPutMethod 
1c30: 21 3d 20 6e 75 6c 6c 29 0a 20 20 20 20 20 20 20  != null).       
1c40: 20 20 20 20 20 20 20 20 20 6d 50 75 74 4d 65 74           mPutMet
1c50: 68 6f 64 2e 61 62 6f 72 74 28 29 3b 0a 20 20 20  hod.abort();.   
1c60: 20 20 20 20 20 7d 0a 20 20 20 20 7d 0a 0a 7d 0a       }.    }..}.