diff options
Diffstat (limited to 'miranda-wine/protocols/MSN/msn_p2ps.cpp')
| -rw-r--r-- | miranda-wine/protocols/MSN/msn_p2ps.cpp | 248 |
1 files changed, 248 insertions, 0 deletions
diff --git a/miranda-wine/protocols/MSN/msn_p2ps.cpp b/miranda-wine/protocols/MSN/msn_p2ps.cpp new file mode 100644 index 0000000..55fd57e --- /dev/null +++ b/miranda-wine/protocols/MSN/msn_p2ps.cpp @@ -0,0 +1,248 @@ +/*
+Plugin of Miranda IM for communicating with users of the MSN Messenger protocol.
+Copyright (c) 2003-5 George Hazan.
+Copyright (c) 2002-3 Richard Hughes (original version).
+
+Miranda IM: the free icq client for MS Windows
+Copyright (C) 2000-2002 Richard Hughes, Roland Rabien & Tristan Van de Vreede
+
+This program is free software; you can redistribute it and/or
+modify it under the terms of the GNU General Public License
+as published by the Free Software Foundation; either version 2
+of the License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program; if not, write to the Free Software
+Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+*/
+
+#include "msn_global.h"
+
+static int sessionCount = 0;
+static filetransfer** sessionList = NULL;
+static CRITICAL_SECTION sessionLock;
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// add file session to a list
+
+void __stdcall p2p_registerSession( filetransfer* ft )
+{
+ EnterCriticalSection( &sessionLock );
+
+ bool bIsFirst = true;
+ for ( int i=0; i < sessionCount; i++ ) {
+ if ( sessionList[i]->std.hContact == ft->std.hContact ) {
+ bIsFirst = false;
+ break;
+ } }
+
+ sessionList = ( filetransfer** )realloc( sessionList, sizeof( void* ) * ( sessionCount+1 ));
+ sessionList[ sessionCount++ ] = ft;
+ ft->mIsFirst = bIsFirst;
+
+ LeaveCriticalSection( &sessionLock );
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// remove file session from a list
+
+void __stdcall p2p_unregisterSession( filetransfer* ft )
+{
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ if ( sessionList[i] == ft ) {
+ delete sessionList[i];
+ while( i < sessionCount-1 ) {
+ sessionList[ i ] = sessionList[ i+1 ];
+ i++;
+ }
+ sessionCount--;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// remove file sessions for a thread
+
+void __stdcall p2p_unregisterThreadSession( LONG threadID )
+{
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ if ( sessionList[i]->mThreadId == threadID ) {
+ delete sessionList[i];
+ while( i < sessionCount-1 ) {
+ sessionList[ i ] = sessionList[ i+1 ];
+ i++;
+ }
+ sessionCount--;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// get session by some parameter
+
+filetransfer* __stdcall p2p_getSessionByID( unsigned ID )
+{
+ if ( ID == 0 )
+ return NULL;
+
+ filetransfer* ft = NULL;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->p2p_sessionid == ID ) {
+ ft = FT;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ if ( ft == NULL )
+ MSN_DebugLog( "Ignoring unknown session id %lu", ID );
+
+ return ft;
+}
+
+filetransfer* __stdcall p2p_getSessionByMsgID( unsigned ID )
+{
+ if ( ID == 0 )
+ return NULL;
+
+ filetransfer* ft = NULL;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->p2p_msgid == ID || FT->p2p_msgid == (ID + 1) ) {
+ ft = FT;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ if ( ft == NULL )
+ MSN_DebugLog( "Ignoring unknown message id %lu", ID );
+
+ return ft;
+}
+
+filetransfer* __stdcall p2p_getAnotherContactSession( filetransfer* ft )
+{
+ filetransfer* result = NULL;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->std.hContact == ft->std.hContact && FT != ft ) {
+ result = FT;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ return result;
+}
+
+BOOL __stdcall p2p_sessionRegistered( filetransfer* ft )
+{
+ BOOL result = FALSE;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( sessionList[i] == ft ) {
+ result = TRUE;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ return result;
+}
+
+filetransfer* __stdcall p2p_getFirstSession( HANDLE hContact )
+{
+ filetransfer* result = NULL;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->std.hContact == hContact && FT->mIsFirst ) {
+ result = FT;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ return result;
+}
+
+filetransfer* __stdcall p2p_getSessionByCallID( const char* CallID )
+{
+ if ( CallID == NULL )
+ return NULL;
+
+ filetransfer* ft = NULL;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->p2p_callID == NULL )
+ continue;
+
+ if ( !strcmp( FT->p2p_callID, CallID )) {
+ ft = FT;
+ break;
+ } }
+
+ LeaveCriticalSection( &sessionLock );
+ if ( ft == NULL )
+ MSN_DebugLog( "Ignoring unknown session call id %s", CallID );
+
+ return ft;
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// push another file transfers
+
+void __stdcall p2p_ackOtherFiles( ThreadData* info )
+{
+ filetransfer* ft = info->mP2pSession;
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ ) {
+ filetransfer* FT = sessionList[i];
+ if ( FT->std.hContact == ft->std.hContact && FT != ft )
+ p2p_sendStatus( FT, info->mParentThread, 200 );
+ }
+
+ LeaveCriticalSection( &sessionLock );
+}
+
+/////////////////////////////////////////////////////////////////////////////////////////
+// external functions
+
+void P2pSessions_Init()
+{
+ InitializeCriticalSection( &sessionLock );
+}
+
+void P2pSessions_Uninit()
+{
+ EnterCriticalSection( &sessionLock );
+
+ for ( int i=0; i < sessionCount; i++ )
+ delete sessionList[i];
+ if ( sessionList != NULL )
+ free( sessionList );
+
+ LeaveCriticalSection( &sessionLock );
+ DeleteCriticalSection( &sessionLock );
+}
|