Changeset 289


Ignore:
Timestamp:
09/19/11 18:10:03 (10 years ago)
Author:
sc
Message:

Interface.py:

  • Final fixes to scrubData for 0.9.2 release
File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/Puzzlebox/Synapse/Interface.py

    r288 r289  
    8787 
    8888INTERFACE_RAW_EEG_UPDATE_FREQUENCY = 512 
     89 
     90PACKET_MINIMUM_TIME_DIFFERENCE_THRESHOLD = 0.75 
    8991 
    9092### CLASSES ### 
     
    10361038                for key in csv_keys: 
    10371039                         
    1038                         localtime = key 
     1040                        timestamp = key 
    10391041 
    10401042                        if csv[key]['Attention'] == '': 
     
    10421044                         
    10431045                        if last_time == None: 
    1044                                 last_time = localtime 
    1045                                 last_recorded_time = localtime 
     1046                                # First entry in log 
     1047                                last_time = timestamp 
     1048                                last_recorded_time = timestamp 
    10461049                                output[key] = csv[key] 
    10471050                                continue 
     
    10491052                        else: 
    10501053                                 
    1051                                 time_difference = localtime - last_time 
     1054                                #time_difference = timestamp - last_time 
     1055                                time_difference = timestamp - last_recorded_time 
    10521056                                 
    1053                                 if self.DEBUG: 
    1054                                         print "localtime:", 
    1055                                         print localtime 
    1056                                         print "last_time:", 
    1057                                         print last_time 
    1058                                         print "last_recorded_time:", 
    1059                                         print last_recorded_time 
    1060                                         print "time_difference:", 
    1061                                         print time_difference 
    1062                                  
    1063                                 if time_difference <= 1: 
    1064                                         last_time = localtime 
    1065                                         last_recorded_time = localtime 
     1057                                if (time_difference <= 1) and \ 
     1058                                   (time_difference >= PACKET_MINIMUM_TIME_DIFFERENCE_THRESHOLD): 
     1059                                        # Skip packets within the correct time threshold 
     1060                                        last_time = timestamp 
     1061                                        last_recorded_time = timestamp 
    10661062                                        output[key] = csv[key] 
    10671063                                        continue 
    10681064                                 
    10691065                                else: 
     1066 
     1067                                        if self.DEBUG: 
     1068                                                print "time_difference:", 
     1069                                                print time_difference 
     1070                                                print "timestamp:", 
     1071                                                print self.parseTimeStamp(timestamp)[-1].split(' ')[0] 
     1072                                                print "last_time:", 
     1073                                                print self.parseTimeStamp(last_time)[-1].split(' ')[0] 
     1074                                                print "last_recorded_time:", 
     1075                                                print self.parseTimeStamp(last_recorded_time)[-1].split(' ')[0] 
     1076 
    10701077                                         
    10711078                                        new_packet = csv[key].copy() 
     
    10731080                                        if time_difference >= 2: 
    10741081                                                 
    1075                                                 new_time = last_time + 1 
     1082                                                ##new_time = last_time + 1 
     1083                                                #new_time = last_recorded_time + 1 
     1084 
     1085                                                count = int(time_difference) 
     1086                                                while count >= 1: 
     1087                                                        new_packet = csv[key].copy() 
     1088                                                        new_time = last_recorded_time + 1 
     1089                                                        (date, formatted_new_time) = self.parseTimeStamp(new_time, \ 
     1090                                                         truncate_time_zone=truncate_csv_timezone) 
     1091                                                        new_packet['Time'] = formatted_new_time 
     1092                                                        last_recorded_time = new_time 
     1093                                                        last_time = timestamp 
     1094                                                        output[new_time] = new_packet 
     1095                                                        count = count - 1 
     1096                                                continue 
     1097                                                 
     1098                                        elif time_difference < PACKET_MINIMUM_TIME_DIFFERENCE_THRESHOLD: 
     1099                                                # Spread out "bunched up" packets 
     1100                                                #new_time = last_time + 1 
     1101                                                new_time = last_recorded_time + 1 
    10761102                                         
    10771103                                         
    10781104                                        elif (time_difference < 2) and (time_difference > 1): 
    10791105                                                 
    1080                                                 new_time = last_time + ((last_time - localtime) / 2) 
     1106                                                #new_time = last_time + ((last_time - timestamp) / 2) 
     1107                                                #new_time = last_recorded_time + ((last_recorded_time - timestamp) / 2) 
     1108                                                #new_time = last_time + 1 
     1109                                                new_time = last_recorded_time + 1 
    10811110                                         
    10821111                                         
     
    10881117                                        #last_time = new_time 
    10891118                                        last_recorded_time = new_time 
    1090                                         last_time = localtime 
     1119                                        last_time = timestamp 
    10911120                                        output[new_time] = new_packet 
    10921121                                         
     
    10941123                                                print "WARN: Scrubbing new packet:", 
    10951124                                                print new_packet 
     1125                                                print 
    10961126                 
    10971127                 
     
    10991129         
    11001130         
     1131        ################################################################## 
     1132 
     1133        #def processTimeDifference(self,  
     1134 
    11011135        ################################################################## 
    11021136         
Note: See TracChangeset for help on using the changeset viewer.