Changeset 5766


Ignore:
Timestamp:
May 7, 2008, 11:57:23 AM (14 years ago)
Author:
charles
Message:

use sendpkmsg()

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/daemon/server.c

    r5579 r5766  
    3939#include <libtransmission/bencode.h>
    4040#include <libtransmission/ipcparse.h>
     41#include <libtransmission/utils.h> /* tr_free */
    4142
    4243#include "bsdtree.h"
     
    388389}
    389390
    390 int
     391static int
    391392queuemsg( struct client * client, uint8_t * buf, size_t buflen )
    392393{
     
    417418}
    418419
     420static int
     421queuepkmsg( struct client * client, tr_benc * pk )
     422{
     423    size_t buflen;
     424    uint8_t * buf = ipc_serialize( pk, &buflen );
     425    int ret = queuemsg( client, buf, buflen );
     426    tr_free( buf );
     427    return ret;
     428}
     429
    419430int
    420431msgresp( struct client * client, int64_t tag, enum ipc_msg id )
     
    460471    benc_val_t      pk, * added;
    461472    int             ii, tor;
    462     size_t          buflen;
    463     uint8_t       * buf;
    464473
    465474    if( !tr_bencIsList( val ) )
     
    497506    }
    498507
    499     buf = ipc_serialize( &pk, &buflen );
     508    queuepkmsg( client, &pk );
    500509    tr_bencFree( &pk );
    501     queuemsg( client, buf, buflen );
    502     free( buf );
    503510}
    504511
     
    509516    benc_val_t    * val, pk;
    510517    int             tor, start;
    511     size_t          buflen;
    512     uint8_t       * buf;
    513518    const char    * dir;
    514519
     
    558563            return;
    559564        }
    560         buf = ipc_serialize( &pk, &buflen );
     565
     566        queuepkmsg( client, &pk );
    561567        tr_bencFree( &pk );
    562         queuemsg( client, buf, buflen );
    563         free( buf );
    564568    }
    565569    else
     
    658662{
    659663    struct client * client = arg;
    660     uint8_t       * buf;
    661     size_t          buflen;
    662664    benc_val_t      pk, * pkinf, * typelist, * idlist, * idval;
    663665    int             all, types, ii, tor;
     
    755757    }
    756758
    757     /* generate packet data and send it */
    758     buf = ipc_serialize( &pk, &buflen );
     759    queuepkmsg( client, &pk );
    759760    tr_bencFree( &pk );
    760     queuemsg( client, buf, buflen );
    761     free( buf );
    762761}
    763762
     
    854853{
    855854    struct client * client = arg;
    856     uint8_t       * buf;
    857     size_t          buflen;
    858855    int             ii;
    859856    benc_val_t    * hash, pk, * pkinf;
     
    897894    }
    898895
    899     buf = ipc_serialize( &pk, &buflen );
     896    queuepkmsg( client, &pk );
    900897    tr_bencFree( &pk );
    901     queuemsg( client, buf, buflen );
    902     free( buf );
    903898}
    904899
     
    963958{
    964959    struct client  * client = arg;
    965     uint8_t        * buf;
    966     size_t           buflen;
    967960    int              ii;
    968961    benc_val_t       pk, *pkval;
     
    10091002    }
    10101003
    1011     buf = ipc_serialize( &pk, &buflen );
     1004    queuepkmsg( client, &pk );
    10121005    tr_bencFree( &pk );
    1013     queuemsg( client, buf, buflen );
    1014     free( buf );
    1015 }
     1006}
Note: See TracChangeset for help on using the changeset viewer.