Changeset 4393
- Timestamp:
- 09/30/06 11:44:22 (2 years ago)
- Files:
-
- wire/trunk/wire/client.c (modified) (2 diffs)
- wire/trunk/wire/main.c (modified) (7 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
wire/trunk/wire/client.c
r4385 r4393 183 183 void wr_connect(wi_string_t *hostname, unsigned int port, wi_string_t *login, wi_string_t *password) { 184 184 wi_enumerator_t *enumerator; 185 wi_ list_t *addresses;185 wi_array_t *addresses; 186 186 wi_address_t *address; 187 187 wi_socket_t *socket; … … 205 205 } 206 206 207 enumerator = wi_ list_data_enumerator(addresses);207 enumerator = wi_array_data_enumerator(addresses); 208 208 209 209 while((address = wi_enumerator_next_data(enumerator))) { wire/trunk/wire/main.c
r4384 r4393 59 59 static void wr_wi_log_callback(wi_string_t *); 60 60 61 static int wr_runloop(wi_ list_t *, wi_time_interval_t);61 static int wr_runloop(wi_array_t *, wi_time_interval_t); 62 62 static int wr_runloop_stdin_callback(wi_socket_t *); 63 63 64 64 65 static wi_ list_t *wr_runloop_sockets;65 static wi_array_t *wr_runloop_sockets; 66 66 67 67 volatile sig_atomic_t wr_running = 1; … … 301 301 302 302 void wr_init_runloop(void) { 303 wr_runloop_sockets = wi_ list_init(wi_list_alloc());303 wr_runloop_sockets = wi_array_init(wi_array_alloc()); 304 304 } 305 305 … … 308 308 void wr_runloop_add_socket(wi_socket_t *socket, wr_runloop_callback_func_t *callback) { 309 309 wi_socket_set_data(socket, callback); 310 wi_ list_append_data(wr_runloop_sockets, socket);310 wi_array_add_data(wr_runloop_sockets, socket); 311 311 } 312 312 … … 314 314 315 315 void wr_runloop_remove_socket(wi_socket_t *socket) { 316 wi_ list_remove_data(wr_runloop_sockets, socket);316 wi_array_remove_data(wr_runloop_sockets, socket); 317 317 } 318 318 … … 366 366 367 367 void wr_runloop_run_for_socket(wi_socket_t *socket, wi_time_interval_t timeout, unsigned int message) { 368 wi_ list_t *list;368 wi_array_t *array; 369 369 int result; 370 370 371 list = wi_list_init_with_data(wi_list_alloc(), socket, NULL);371 array = wi_array_init_with_data(wi_array_alloc(), socket, NULL); 372 372 373 373 while(wr_running) { 374 result = wr_runloop( list, timeout);374 result = wr_runloop(array, timeout); 375 375 376 376 if(result < 0 || (unsigned int) result == message || (result >= 500 && result < 600)) … … 378 378 } 379 379 380 wi_release( list);380 wi_release(array); 381 381 } 382 382 … … 385 385 #pragma mark - 386 386 387 static int wr_runloop(wi_ list_t *list, wi_time_interval_t timeout) {387 static int wr_runloop(wi_array_t *array, wi_time_interval_t timeout) { 388 388 wi_socket_t *socket; 389 389 wr_runloop_callback_func_t *callback; 390 390 391 socket = wi_socket_wait_multiple( list, timeout);391 socket = wi_socket_wait_multiple(array, timeout); 392 392 393 393 if(socket) {
