Changeset 4397

Show
Ignore:
Timestamp:
10/01/06 17:10:05 (2 years ago)
Author:
morris
Message:

Cleanups

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trackerd/trunk/trackerd/commands.c

    r4396 r4397  
    408408 
    409409        /* is there an existing server from this host? */ 
    410         server = wt_server_with_ip(client->ip); 
     410        server = wt_servers_server_with_ip(client->ip); 
    411411 
    412412        if(server) { 

  • trackerd/trunk/trackerd/servers.c

    r4395 r4397  
    284284#pragma mark - 
    285285 
     286wt_server_t * wt_servers_server_with_ip(wi_string_t *ip) { 
     287        wi_enumerator_t *enumerator; 
     288        wt_server_t             *server, *value = NULL; 
     289 
     290        wi_array_rdlock(wt_servers); 
     291         
     292        enumerator = wi_array_data_enumerator(wt_servers); 
     293         
     294        while((server = wi_enumerator_next_data(enumerator))) { 
     295                if(wi_is_equal(server->ip, ip)) { 
     296                        value = server; 
     297 
     298                        break; 
     299                } 
     300        } 
     301 
     302        wi_array_unlock(wt_servers); 
     303 
     304        return value; 
     305} 
     306 
     307 
     308 
     309wt_server_t * wt_servers_server_with_key(wi_string_t *key) { 
     310        wi_enumerator_t *enumerator; 
     311        wt_server_t             *server, *value = NULL; 
     312 
     313        wi_array_rdlock(wt_servers); 
     314 
     315        enumerator = wi_array_data_enumerator(wt_servers); 
     316         
     317        while((server = wi_enumerator_next_data(enumerator))) { 
     318                if(wi_is_equal(server->key, key)) { 
     319                        value = server; 
     320 
     321                        break; 
     322                } 
     323        } 
     324         
     325        wi_array_unlock(wt_servers); 
     326 
     327        return value; 
     328} 
     329 
     330 
     331 
    286332void wt_servers_add_stats_for_server(wt_server_t *server) { 
    287333        wi_lock_lock(wt_status_lock); 
    …… 
    430476        return server_packed; 
    431477} 
    432  
    433  
    434  
    435 #pragma mark - 
    436  
    437 wt_server_t * wt_server_with_ip(wi_string_t *ip) { 
    438         wi_enumerator_t *enumerator; 
    439         wt_server_t             *server, *value = NULL; 
    440  
    441         wi_array_rdlock(wt_servers); 
    442          
    443         enumerator = wi_array_data_enumerator(wt_servers); 
    444          
    445         while((server = wi_enumerator_next_data(enumerator))) { 
    446                 if(wi_is_equal(server->ip, ip)) { 
    447                         value = server; 
    448  
    449                         break; 
    450                 } 
    451         } 
    452  
    453         wi_array_unlock(wt_servers); 
    454  
    455         return value; 
    456 } 
    457  
    458  
    459  
    460 wt_server_t * wt_server_with_key(wi_string_t *key) { 
    461         wi_enumerator_t *enumerator; 
    462         wt_server_t             *server, *value = NULL; 
    463  
    464         wi_array_rdlock(wt_servers); 
    465  
    466         enumerator = wi_array_data_enumerator(wt_servers); 
    467          
    468         while((server = wi_enumerator_next_data(enumerator))) { 
    469                 if(wi_is_equal(server->key, key)) { 
    470                         value = server; 
    471  
    472                         break; 
    473                 } 
    474         } 
    475          
    476         wi_array_unlock(wt_servers); 
    477  
    478         return value; 
    479 } 

  • trackerd/trunk/trackerd/servers.h

    r4395 r4397  
    3030#define WT_SERVERS_H 1 
    3131 
    32 #include <sys/time.h> 
    3332#include <wired/wired.h> 
    3433 
    …… 
    6362void                                                            wt_write_servers(void); 
    6463 
     64wt_server_t *                                           wt_servers_server_with_ip(wi_string_t *); 
     65wt_server_t *                                           wt_servers_server_with_key(wi_string_t *); 
    6566void                                                            wt_servers_add_stats_for_server(wt_server_t *); 
    6667void                                                            wt_servers_remove_stats_for_server(wt_server_t *); 
    …… 
    7273void                                                            wt_server_clear(wt_server_t *); 
    7374 
    74 wt_server_t *                                           wt_server_with_ip(wi_string_t *); 
    75 wt_server_t *                                           wt_server_with_key(wi_string_t *); 
    76  
    7775 
    7876extern wi_array_t                                       *wt_servers; 

  • trackerd/trunk/trackerd/tracker.c

    r4395 r4397  
    300300 
    301301                if(wi_is_equal(command, WI_STR("UPDATE")) && wi_array_count(arguments) >= 6) { 
    302                         server = wt_server_with_key(WI_ARRAY(arguments, 0)); 
     302                        server = wt_servers_server_with_key(WI_ARRAY(arguments, 0)); 
    303303 
    304304                        if(!server)