@@ -102,15 +102,18 @@ def write_rtcm(file_rtcm, msg_t, intr, nep=1):
102102 return msg [:k ]
103103
104104
105- def decode_rtcm (msg , intr = None , nep = 1 , logfile = None , maxlen = 1024 ):
105+ def decode_rtcm (msg , intr = None , nep = 1 , logfile = None , maxlen = 1024 ,
106+ mt_skip = None ):
106107 cs = rtcm (foutname = logfile )
107108 cs .monlevel = 2
109+ if mt_skip is not None :
110+ cs .mt_skip = mt_skip
108111
109112 k = 0
110113 for ne in range (nep ):
111114
112115 # loop for RTCM
113- while k < maxlen :
116+ while k < maxlen - 1024 :
114117 stat = cs .sync (msg , k )
115118 if stat is False :
116119 k += 1
@@ -138,7 +141,7 @@ def decode_rtcm(msg, intr=None, nep=1, logfile=None, maxlen=1024):
138141 return cs
139142
140143
141- def read_rtcm (file_rtcm , intr , nep = 1 , logfile = None ):
144+ def read_rtcm (file_rtcm , intr , nep = 1 , logfile = None , mt_skip = None ):
142145 """ read test script for SC-134 messages """
143146
144147 fc = open (file_rtcm , 'rb' )
@@ -150,12 +153,15 @@ def read_rtcm(file_rtcm, intr, nep=1, logfile=None):
150153 maxlen = len (msg )- 5
151154 fc .close ()
152155
153- return decode_rtcm (msg , intr , nep , logfile , maxlen )
156+ return decode_rtcm (msg , intr , nep , logfile , maxlen , mt_skip )
154157
155158
156159if __name__ == "__main__" :
157160 bdir = '../data/sc134/msg/'
158161 flg_sim = False
162+
163+ mt_skip = []
164+ #mt_skip = [1267] # work-around for SC134 SSR interop-test
159165
160166 if flg_sim : # generate test data
161167 file_rtcm = bdir + 'test.rtcm'
@@ -198,9 +204,12 @@ def read_rtcm(file_rtcm, intr, nep=1, logfile=None):
198204 #file_rtcm = ['RTCM134test_21012026']
199205
200206 # file_rtcm = ['sampledataMT03-04-05-06-07']
207+ file_rtcm = ['ssr/SSRTEST_20260206_CORR' ,
208+ 'ssr/ROVRMSG' ,
209+ 'ssr/ROMAMSG' ]
201210
202211 # msg = read_asc(file_asc)
203212 for f in file_rtcm :
204213 file_log = bdir + f + '.dlg'
205214 msg = read_bin (bdir + f + '.bin' )
206- decode_rtcm (msg , logfile = file_log , maxlen = len (msg ))
215+ decode_rtcm (msg , logfile = file_log , maxlen = len (msg ), mt_skip = mt_skip )
0 commit comments