/* try to consume the input buffer */
if( io->canRead )
{
- tr_globalLock( session );
+ tr_sessionLock( session );
while( !done && !err )
{
assert( tr_isPeerIo( io ) );
}
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
}
/* keep the iobuf's excess capacity from growing too large */
static inline void
managerLock( const struct tr_peerMgr * manager )
{
- tr_globalLock( manager->session );
+ tr_sessionLock( manager->session );
}
static inline void
managerUnlock( const struct tr_peerMgr * manager )
{
- tr_globalUnlock( manager->session );
+ tr_sessionUnlock( manager->session );
}
static inline void
static inline int
torrentIsLocked( const Torrent * t )
{
- return tr_globalIsLocked( t->manager->session );
+ return tr_sessionIsLocked( t->manager->session );
}
/**
***/
void
-tr_globalLock( tr_session * session )
+tr_sessionLock( tr_session * session )
{
assert( tr_isSession( session ) );
}
void
-tr_globalUnlock( tr_session * session )
+tr_sessionUnlock( tr_session * session )
{
assert( tr_isSession( session ) );
}
tr_bool
-tr_globalIsLocked( const tr_session * session )
+tr_sessionIsLocked( const tr_session * session )
{
return tr_isSession( session ) && tr_lockHave( session->lock );
}
{
assert( tr_isSession( session ) );
- tr_globalLock( session );
+ tr_sessionLock( session );
tr_sharedTraversalEnable( session->shared, enabled );
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
}
tr_bool
tr_bool tr_sessionIsAddressBlocked( const tr_session * session,
const struct tr_address * addr );
-void tr_globalLock( tr_session * );
+void tr_sessionLock( tr_session * );
-void tr_globalUnlock( tr_session * );
+void tr_sessionUnlock( tr_session * );
-tr_bool tr_globalIsLocked( const tr_session * );
+tr_bool tr_sessionIsLocked( const tr_session * );
const struct tr_address* tr_sessionGetPublicAddress( const tr_session *, int tr_af_type );
assert( session != NULL );
- tr_globalLock( session );
+ tr_sessionLock( session );
tor->session = session;
tor->uniqueId = nextUniqueId++;
if( doStart )
torrentStart( tor );
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
}
tr_parse_result
assert( tr_isTorrent( tor ) );
assert( !tor->isRunning );
- tr_globalLock( session );
+ tr_sessionLock( session );
tr_peerMgrRemoveTorrent( tor );
tr_metainfoFree( inf );
tr_free( tor );
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
}
/**
assert( tr_isTorrent( tor ) );
- tr_globalLock( tor->session );
+ tr_sessionLock( tor->session );
/** If we had local data before, but it's disappeared,
stop the torrent and log an error. */
tr_peerMgrStartTorrent( tor );
}
- tr_globalUnlock( tor->session );
+ tr_sessionUnlock( tor->session );
}
static void
{
assert( tr_isTorrent( tor ) );
- tr_globalLock( tor->session );
+ tr_sessionLock( tor->session );
if( !tor->isRunning )
{
tr_verifyAdd( tor, checkAndStartCB );
}
- tr_globalUnlock( tor->session );
+ tr_sessionUnlock( tor->session );
}
void
tr_torrent * tor = vtor;
assert( tr_isTorrent( tor ) );
- tr_globalLock( tor->session );
+ tr_sessionLock( tor->session );
/* if the torrent's already being verified, stop it */
tr_verifyRemove( tor );
tr_torrentUncheck( tor );
tr_verifyAdd( tor, torrentRecheckDoneCB );
- tr_globalUnlock( tor->session );
+ tr_sessionUnlock( tor->session );
}
void
if( tr_isTorrent( tor ) )
{
- tr_globalLock( tor->session );
+ tr_sessionLock( tor->session );
tor->isRunning = 0;
tr_torrentSetDirty( tor );
tr_runInEventThread( tor->session, stopTorrent, tor );
- tr_globalUnlock( tor->session );
+ tr_sessionUnlock( tor->session );
}
}
{
tr_session * session = tor->session;
assert( tr_isSession( session ) );
- tr_globalLock( session );
+ tr_sessionLock( session );
tr_torrentClearCompletenessCallback( tor );
tr_runInEventThread( session, closeTorrent, tor );
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
}
}
#define TR_TORRENT_H 1
#include "completion.h" /* tr_completion */
-#include "session.h" /* tr_globalLock(), tr_globalUnlock() */
+#include "session.h" /* tr_sessionLock(), tr_sessionUnlock() */
#include "utils.h" /* TR_GNUC_PRINTF */
struct tr_bandwidth;
static inline void tr_torrentLock( const tr_torrent * tor )
{
- tr_globalLock( tor->session );
+ tr_sessionLock( tor->session );
}
static inline void tr_torrentUnlock( const tr_torrent * tor )
{
- tr_globalUnlock( tor->session );
+ tr_sessionUnlock( tor->session );
}
static inline tr_bool
{
if( event == DHT_EVENT_VALUES || event == DHT_EVENT_VALUES6 ) {
tr_torrent *tor;
- tr_globalLock( session );
+ tr_sessionLock( session );
tor = tr_torrentFindFromHash( session, info_hash );
if( tor && tr_torrentAllowsDHT( tor ))
{
(int)n,
event == DHT_EVENT_VALUES6 ? " IPv6" : "");
}
- tr_globalUnlock( session );
+ tr_sessionUnlock( session );
} else if( event == DHT_EVENT_SEARCH_DONE ||
event == DHT_EVENT_SEARCH_DONE6) {
tr_torrent * tor = tr_torrentFindFromHash( session, info_hash );