Synnefo » Pithos MS Client

                using (var client = await listener.AcceptTcpClientAsync()

                                        .WithTimeout(TimeSpan.FromMinutes(5)))

                {

                    using (var stream = client.GetStream())

                    using (var reader=new StreamReader(stream))

                    {

                        var request = await reader.ReadLineAsync();

                            throw new Exception("Nothing retrieved");

                        Log.InfoFormat("[RETRIEVE] Got Connection {0}", request);

        private bool _firstPoll = true;

        private TaskCompletionSource<bool> _tcs;

        public void Start()

        {

            //Consider for deleteion only files modified before the PREVIOUS poll

            //A user may perform a file creation or rename at roughly the same time as a poll. In such a case

            //the new file will appear as deleted

            var deleteCandidates = FileState.Queryable.Where(state => 

                state.Modified <= previousPollTime

            var filesToDelete = (from deleteCandidate in deleteCandidates 

                         let localFile = FileInfoExtensions.FromPath(deleteCandidate.FilePath) 

                         let relativeFilePath = localFile.AsRelativeTo(accountInfo.AccountPath) 

                         //Exclude files enqueued for uploading

                         //Large files will not appear on the server for multiple polls. They must not be marked as deleted

                         //Do NOT delete files modified since the previous poll

                                && localFile.LastAccessTime < previousPollTime

                         select localFile).ToList();

            //On the first run

            if (_firstPoll)

                    using (new SessionScope(FlushAction.Never))

                    {

                        var state =  StatusKeeper.GetStateByFilePath(localFile.FullName);

                        //FileState.FindByFilePath(localFile.FullName);

                        //Common files should be checked on a per-case basis to detect differences, which is newer