Merge remote-tracking branch 'pocoproject/develop' into MySQLOnTravisAndAppVeyor

This commit is contained in:
FrancisANDRE 2016-03-10 17:36:47 +01:00
commit 41bbe9a7ea
7 changed files with 15 additions and 14 deletions

View File

@ -44,8 +44,6 @@ private:
#if defined(sun) || defined(__APPLE__) || defined(__osf__) || defined(__QNX__) || defined(_AIX)
sem_t* _sem;
#else
int _lockfd; // lock file descriptor
int _semfd; // file used to identify semaphore
int _semid; // semaphore id
#endif
};

View File

@ -47,8 +47,6 @@ private:
#if defined(sun) || defined(__APPLE__) || defined(__osf__) || defined(__QNX__) || defined(_AIX)
sem_t* _sem;
#else
int _lockfd; // lock file descriptor
int _semfd; // file used to identify semaphore
int _semid; // semaphore id
#endif
};

View File

@ -86,7 +86,7 @@ public:
TaskList taskList() const;
/// Returns a copy of the internal task list.
int count() const;
std::size_t count() const;
/// Returns the number of tasks in the internal task list.
void addObserver(const AbstractObserver& observer);
@ -125,11 +125,11 @@ private:
//
// inlines
//
inline int TaskManager::count() const
inline std::size_t TaskManager::count() const
{
FastMutex::ScopedLock lock(_mutex);
return (int) _taskList.size();
return _taskList.size();
}

View File

@ -115,11 +115,12 @@ void TaskManager::taskStarted(Task* pTask)
void TaskManager::taskProgress(Task* pTask, float progress)
{
FastMutex::ScopedLock lock(_mutex);
ScopedLockWithUnlock<FastMutex> lock(_mutex);
if (_lastProgressNotification.isElapsed(MIN_PROGRESS_NOTIFICATION_INTERVAL))
{
_lastProgressNotification.update();
lock.unlock();
_nc.postNotification(new TaskProgressNotification(pTask, progress));
}
}

View File

@ -58,7 +58,6 @@ protected:
void buildRequest(BinaryWriter& writer);
private:
Int32 _flags;
std::string _fullCollectionName;
Int32 _numberToReturn;
Int64 _cursorID;

View File

@ -376,8 +376,15 @@ long SecureSocketImpl::verifyPeerCertificateImpl(const std::string& hostName)
bool SecureSocketImpl::isLocalHost(const std::string& hostName)
{
SocketAddress addr(hostName, 0);
return addr.host().isLoopback();
try
{
SocketAddress addr(hostName, 0);
return addr.host().isLoopback();
}
catch (Poco::Exception&)
{
return false;
}
}

View File

@ -67,10 +67,8 @@ private:
AsyncReader(const AsyncReader&);
AsyncReader& operator = (const AsyncReader&);
Activity<AsyncReader> _activity;
Client& _client;
Activity<AsyncReader> _activity;
};