Changeset 86


Ignore:
Timestamp:
02/06/13 10:34:55 (7 years ago)
Author:
mmamonski
Message:

DRMAA pbs connection

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/pbs_drmaa/pbs_conn.c

    r85 r86  
    5858static void check_reconnect( pbsdrmaa_pbs_conn_t *self, bool reconnect); 
    5959 
     60/* 
    6061static void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self ); 
    6162 
    6263static void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self ); 
     64 
     65static void autoclose_thread_loop( void *data ); */ 
    6366 
    6467 
     
    109112                        if (self->connection_fd != -1) 
    110113                                pbs_disconnect(self->connection_fd); 
    111                         stop_autoclose_thread(self); 
    112114                  } 
    113115                         
     
    514516 
    515517 
    516 static void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self ) 
    517 { 
    518  
    519  
    520 } 
    521  
    522 static void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self ) 
    523 { 
    524  
    525  
    526 } 
    527  
     518/* 
     519void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self ) 
     520{ 
     521 
     522 
     523} 
     524 
     525void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self ) 
     526{ 
     527 
     528 
     529} 
     530 
     531void autoclose_thread_loop( void *data ) 
     532{ 
     533        pbsdrmaa_pbs_conn_t *self = (pbsdrmaa_pbs_conn_t *)data; 
     534        struct timespec wait_time; 
     535 
     536        fsd_mutex_lock(&self->session->drm_connection_mutex); 
     537 
     538        if (fsd_cond_timedwait(&self->autoclose_cond, &self->session->drm_connection_mutex, wait_time); 
     539         { 
     540                fsd_log_debug("autoclose thread signaled, waiting again"); 
     541         } 
     542        else 
     543         { 
     544                fsd_log_info("autoclosing PBS connection: fd=%d, time_diff=%d", self->connection_fd, (int)(time(NULL) - self->last_connect_time)); 
     545                pbs_disconnect(self->connection_fd); 
     546                self->connection_fd = -1; 
     547         } 
     548 
     549        fsd_mutex_unlock(&self->session->drm_connection_mutex); 
     550} 
     551*/ 
Note: See TracChangeset for help on using the changeset viewer.