Synnefo » Pithos MS Client

                throw new ArgumentException("The action.AccountInfo is empty","action");

            Contract.EndContractBlock();

            var accountInfo = action.AccountInfo;

            using (log4net.ThreadContext.Stacks["NETWORK"].Push("PROCESS"))

                var downloadPath = action.GetDownloadPath();

                try

                    if (action.Action == CloudActionType.DeleteCloud)

                        //Redirect deletes to the delete agent 

                        _deleteAgent.Post((CloudDeleteAction)action);

                    }

                }

                finally

                {

                }

            }

        }

        /// <summary>

        /// Processes cloud delete actions

        /// </summary>

            Contract.EndContractBlock();

            StatusKeeper.SetFileOverlayStatus(downloadPath, FileOverlayStatus.Conflict);

            var message = String.Format("Conflict detected for file {0}", downloadPath);

            Log.Warn(message);

            StatusNotification.NotifyChange(message, TraceLevel.Warning);

        public void SynchNow()

        {             

            if (_tcs!=null)

            else

            {

                //TODO: This may be OK for testing purposes, but we have no guarantee that it will

        //Remote files are polled periodically. Any changes are processed

        public async Task PollRemoteFiles(DateTime? since = null,bool repeat=true)

        {

            using (log4net.ThreadContext.Stacks["Retrieve Remote"].Push("All accounts"))

            {

                    Log.ErrorFormat("Error while processing accounts\r\n{0}",ex);

                    //In case of failure retry with the same "since" value

                }

                //Wait for the polling interval to pass or the Manual flat to be toggled

                nextSince = await WaitForScheduledOrManualPoll(nextSince);

                throw new ArgumentException("The AccountInfo.AccountPath is empty","accountInfo");

            Contract.EndContractBlock();

            using (log4net.ThreadContext.Stacks["Retrieve Remote"].Push(accountInfo.UserName))

            {

                            .Except(_agent.GetEnumerable(), new PithosMonitor.LocalFileComparer())

                            .ToList();

                        //Queue all the actions

                        foreach (var message in distinctActions)

                        {

                {

                    StatusKeeper.SetFileState(item.FullName, FileStatus.Conflict, FileOverlayStatus.Deleted);

                }

                StatusNotification.NotifyConflicts(filesToDelete, String.Format("{0} local files are missing from Pithos, possibly because they were deleted",filesToDelete.Count));

            }

            else

            if (!Path.IsPathRooted(filePath))

                throw new ArgumentException("The filePath must be rooted", "filePath");

            Contract.EndContractBlock();

            var localPath = Interfaces.FileInfoExtensions.GetProperFilePathCapitalization(filePath);

            var relativeUrl = new Uri(cloudFile.Name, UriKind.Relative);

                        Directory.CreateDirectory(localPath);

                }

                else

                    //Retrieve the hashmap from the server

                    var serverHash = await client.GetHashMap(account, container, url);

                    //If it's a small file

                if (localHash==cloudHash)

                    return;

            }

            var fileAgent = GetFileAgent(accountInfo);

            //Calculate the relative file path for the new file

                var upHash = upHashes[i];

                if (!localHashes.ContainsKey(upHash))

                {

                    if (blockUpdater.UseOrphan(i, upHash))

                    {

                        Log.InfoFormat("[BLOCK GET] ORPHAN FOUND for {0} of {1} for {2}", i, upHashes.Length, localPath);

            Contract.EndContractBlock();

            try

                var accountInfo = action.AccountInfo;

                var fileInfo = action.LocalFile;