Changeset 86 for trunk/pbs_drmaa

Timestamp:

02/06/13 10:34:55 (12 years ago)

Author:

mmamonski

Message:

DRMAA pbs connection

File:

• trunk/pbs_drmaa/pbs_conn.c (modified) (3 diffs)

trunk/pbs_drmaa/pbs_conn.c

@@ -58 +58 @@
 static void check_reconnect( pbsdrmaa_pbs_conn_t *self, bool reconnect);
 
+/*
 static void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self );
 
 static void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self );
+
+static void autoclose_thread_loop( void *data ); */
 
 
@@ -109 +112 @@
                         if (self->connection_fd != -1)
                                 pbs_disconnect(self->connection_fd);
-                        stop_autoclose_thread(self);
                   }
                         
@@ -514 +516 @@
 
 
-static void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self )
-{
-
-
-}
-
-static void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self )
-{
-
-
-}
-
+/*
+void start_autoclose_thread( pbsdrmaa_pbs_conn_t *self )
+{
+
+
+}
+
+void stop_autoclose_thread( pbsdrmaa_pbs_conn_t *self )
+{
+
+
+}
+
+void autoclose_thread_loop( void *data )
+{
+        pbsdrmaa_pbs_conn_t *self = (pbsdrmaa_pbs_conn_t *)data;
+        struct timespec wait_time;
+
+        fsd_mutex_lock(&self->session->drm_connection_mutex);
+
+        if (fsd_cond_timedwait(&self->autoclose_cond, &self->session->drm_connection_mutex, wait_time);
+         {
+                fsd_log_debug("autoclose thread signaled, waiting again");
+         }
+        else
+         {
+                fsd_log_info("autoclosing PBS connection: fd=%d, time_diff=%d", self->connection_fd, (int)(time(NULL) - self->last_connect_time));
+                pbs_disconnect(self->connection_fd);
+                self->connection_fd = -1;
+         }
+
+        fsd_mutex_unlock(&self->session->drm_connection_mutex);
+}
+*/