Merge pull request #819 from tylerjereddy/treddy_issue_811_part3_cffi_only

BUG: memleak part 3 (CFFI only)

Author: shanedsnyder

darshan-util/pydarshan/darshan/backend/cffi_backend.py

@@ -350,8 +350,9 @@ def log_get_generic_record(log, mod_name, dtype='numpy'):
     if mod_name == 'H5D':
         rec['file_rec_id'] = rbuf[0].file_rec_id
 
-    clst = np.frombuffer(ffi.buffer(rbuf[0].counters), dtype=np.int64)
-    flst = np.frombuffer(ffi.buffer(rbuf[0].fcounters), dtype=np.float64)
+    clst = np.copy(np.frombuffer(ffi.buffer(rbuf[0].counters), dtype=np.int64))
+    flst = np.copy(np.frombuffer(ffi.buffer(rbuf[0].fcounters), dtype=np.float64))
+    libdutil.darshan_free(buf[0])
 
     c_cols = counter_names(mod_name)
     fc_cols = fcounter_names(mod_name)
@@ -471,7 +472,8 @@ def _log_get_lustre_record(log, dtype='numpy'):
     clst = []
     for i in range(0, len(rbuf[0].counters)):
         clst.append(rbuf[0].counters[i])
-    rec['counters'] = np.array(clst, dtype=np.int64)
+    rec['counters'] = np.array(clst, dtype=np.int64, copy=True)
+    libdutil.darshan_free(buf[0])
 
     # counters
     cdict = dict(zip(counter_names('LUSTRE'), rec['counters']))
@@ -594,6 +596,7 @@ def log_get_dxt_record(log, mod_name, reads=True, writes=True, dtype='dict'):
         rec['read_segments'] = pd.DataFrame(rec['read_segments'])
         rec['write_segments'] = pd.DataFrame(rec['write_segments'])
 
+    libdutil.darshan_free(buf[0])
     return rec
 
 
@@ -636,10 +639,11 @@ def _log_get_heatmap_record(log):
     # write/read bins
     sizeof_64 = ffi.sizeof("int64_t")
 
-    write_bins = np.frombuffer(ffi.buffer(filerec[0].write_bins, sizeof_64*nbins), dtype = np.int64)
+    write_bins = np.copy(np.frombuffer(ffi.buffer(filerec[0].write_bins, sizeof_64*nbins), dtype = np.int64))
     rec['write_bins'] = write_bins
 
-    read_bins = np.frombuffer(ffi.buffer(filerec[0].read_bins, sizeof_64*nbins), dtype = np.int64)
+    read_bins = np.copy(np.frombuffer(ffi.buffer(filerec[0].read_bins, sizeof_64*nbins), dtype = np.int64))
     rec['read_bins'] = read_bins
+    libdutil.darshan_free(buf[0])
 
     return rec