Changeset 4ac647d for protocols

Timestamp:

2008-08-04T14:21:49Z (16 years ago)

Author:

ulim <a.sporto+bee@…>

Branches:

master

Children:

8661caa

Parents:

8a90001

Message:

moved some stuff around in preperation for MSN merge.

• both ends (proto&dcc) need to finish a transfer now for it to be finished
• moved throughput calc. and some messages to dcc (no need to implement in protocols)

Location:

protocols

Files:

• ft.h (modified) (1 diff)
• jabber/jabber.c (modified) (1 diff)
• jabber/s5bytestream.c (modified) (3 diffs)
• jabber/si.c (modified) (4 diffs)

protocols/ft.h

@@ -171 +171 @@
 
 gboolean imcb_file_recv_start( file_transfer_t *ft );
+
+void imcb_file_finished( file_transfer_t *file );
 #endif

protocols/jabber/jabber.c

@@ -245 +245 @@
         struct jabber_data *jd = ic->proto_data;
         
+        while( jd->filetransfers )
+                imcb_file_canceled( ( ( struct jabber_transfer *) jd->filetransfers->data )->ft, "Logging out" );
+
+        while( jd->streamhosts )
+        {
+                jabber_streamhost_t *sh = jd->streamhosts->data;
+                jd->streamhosts = g_slist_remove( jd->streamhosts, sh );
+                g_free( sh->jid );
+                g_free( sh->host );
+                g_free( sh );
+        }
+
         if( jd->fd >= 0 )
                 jabber_end_stream( ic );

protocols/jabber/s5bytestream.c

@@ -643 +643 @@
                 return jabber_bs_abort( bt, "Remote end closed connection" );
         
-        if( tf->bytesread == 0 )
-                tf->ft->started = time( NULL );
-
         tf->bytesread += ret;
+
+        if( tf->bytesread >= tf->ft->file_size )
+                imcb_file_finished( tf->ft );
 
         tf->ft->write( tf->ft, tf->ft->buffer, ret );   
@@ -701 +701 @@
         ASSERTSOCKOP( ret = send( tf->fd, buffer, len, 0 ), "Sending" );
 
-        if( tf->byteswritten == 0 )
-                tf->ft->started = time( NULL );
-
         tf->byteswritten += ret;
         
@@ -710 +707 @@
                 return jabber_bs_abort( bt, "send() sent %d instead of %d (send buffer too big!)", ret, len );
 
-        bt->tf->watch_out = b_input_add( tf->fd, GAIM_INPUT_WRITE, jabber_bs_send_can_write, bt );
+        if( tf->byteswritten >= ft->file_size )
+                imcb_file_finished( ft );
+        else
+                bt->tf->watch_out = b_input_add( tf->fd, GAIM_INPUT_WRITE, jabber_bs_send_can_write, bt );
                 
         return TRUE;

protocols/jabber/si.c

@@ -54 +54 @@
 }
 
-/* file_transfer finished() callback */
-void jabber_si_finished( file_transfer_t *ft )
-{
-        struct jabber_transfer *tf = ft->data;
-        time_t diff = time( NULL ) - ft->started ? : 1;
-
-        imcb_log( tf->ic, "File %s transferred successfully at %d kb/s!" , ft->file_name, (int) ( ft->bytes_transferred / 1024 / diff ) );
-}
-
 /* file_transfer canceled() callback */
 void jabber_si_canceled( file_transfer_t *ft, char *reason )
@@ -177 +168 @@
         tf->ft->data = tf;
         tf->ft->free = jabber_si_free_transfer;
-        tf->ft->finished = jabber_si_finished;
         tf->bud = bud;
         ft->write = jabber_bs_send_write;
@@ -302 +292 @@
         /* Request is fine. */
 
-        imcb_log( ic, "File transfer request from %s for %s (%zd kb). ", xt_find_attr( node, "from" ), name, size/1024 );
-
-        imcb_log( ic, "Accept the file transfer if you'd like the file. If you don't, issue the 'transfers reject' command.");
-
         tf = g_new0( struct jabber_transfer, 1 );
 
@@ -318 +304 @@
         tf->ft->accept = jabber_si_answer_request;
         tf->ft->free = jabber_si_free_transfer;
-        tf->ft->finished = jabber_si_finished;
         tf->ft->canceled = jabber_si_canceled;