radarsys_met Commit - r444:d8e453ba0459

Add 'reset pedestal' option

eynilupu -

r444:d8e453ba0459

parent child

Context file:

r444:d8e453ba0459

volumes/sirm/apps/main/management/commands/restart_pedestal.py +15 -5

                     exp.pedestal.start_device(name_experiment=name)
                     self.stdout.write(f'"{exp.name}" experiment: Pedestal acquisition was restarted')
+            def pedestal_reset(self, id_exp):
+                all_status = Experiment.objects.filter(status=2)
+                check_id = False
+                if len(all_status) > 0:
+                    check_id = all_status[0].pk
+                if check_id and check_id == id_exp:
+                    exp = get_object_or_404(Experiment, pk=id_exp)
+                    exp.pedestal.reset_device()
+                    self.stdout.write(f'"{exp.name}" experiment: Pedestal acquisition is resetting')
             def pedestal_stop(self, id_exp):
                 all_status = Experiment.objects.filter(status=2)
                 check_id = False
                 if check_id and check_id == id_exp:
                     exp = get_object_or_404(Experiment, pk=id_exp)
                     exp.pedestal.stop_device()
-                    self.stdout.write(f'"{exp.name}" experiment: Pedestal acquisition "{exp.name}" was stopped')
+                    self.stdout.write(f'"{exp.name}" experiment: Pedestal acquisition was stopped')
             def hdf5_list_content(get_file):
                 table_records = np.array(get_file).tolist()
                                 pedestal_stop(self, id_exp)
                                 time.sleep(14)
-                                #pedestal_reset(self, id_exp)
-                                #time.sleep(2)
                                 pedestal_start(self, id_exp)
                         else:
                             else:
                                 self.stdout.write(f'No file increment, retry')
+                            pedestal_reset(self, id_exp)
+                            time.sleep(14)
                             pedestal_stop(self, id_exp)
                             time.sleep(14)
-                            #pedestal_reset(self, id_exp)
-                            #time.sleep(2)
                             pedestal_start(self, id_exp)
                     else:

volumes/sirm/apps/main/management/commands/restart_reception.py +5 -1

                     name = '{}-R@{}'.format(exp.name, datetime.now().strftime('%Y-%m-%dT%H-%M-%S'))
                     exp.reception_rx.start_device(name_experiment = name, restart = True)
                     self.stdout.write(f'"{exp.name}" experiment: Data acquisition was restarted')
                     self.stdout.write(f'Restarting schain...')
+                    datadir_exp = exp.reception_rx.datadir
+                    datadir_exp = datadir_exp.replace(os.environ.get('EXPOSE_NAS', '/DATA_RM/DATA') + '/', '')
+                    datadir_exp = datadir_exp.replace('/rawdata', '')
                     r = requests.get('http://'+os.environ.get('SCHAIN_SITE', 'sophy-schain')+'/stop')
                     time.sleep(1)
-                    r = requests.post('http://'+os.environ.get('SCHAIN_SITE', 'sophy-schain')+'/start', json={'name': exp.name})
+                    r = requests.post('http://'+os.environ.get('SCHAIN_SITE', 'sophy-schain')+'/start', json={'name': datadir_exp})
             def acquisition_stop(self, id_exp):
                 all_status = Experiment.objects.filter(status=2)

volumes/sirm/apps/main/models.py +2 0

                         time.sleep(0.1)
                         self.reception_rx.stop_device()
                         time.sleep(0.1)
+                        self.pedestal.reset_device()
+                        time.sleep(14)
                         self.pedestal.stop_device()
                         time.sleep(0.1)
                         proc_url = 'http://'+os.environ['PROC_SITE']+'/stop'

volumes/sirm/apps/pedestal/models.py +26 -5

                     self.device.save()
                     return True
-                def reset_device(self, axi, angle):
+                def reset_device(self):
+                    try:
+                        r = requests.get(self.device.url() + 'reset')
+                        if r:
+                            #self.device.status = 3
+                            #self.device.save()
+                            self.message = 'Pedestal restarted'
+                        else:
+                            return False
+                    except Exception as e:
+                        self.message = "Pedestal can't restarted: {}".format(str(e))
+                        return False
+                    return True
+                def initial_device(self, axi, angle):
                     try:
                         url = self.device.url() + "position?params="
                         if r:
                             self.device.status = 3
                             self.device.save()
-                            self.message = 'Pedestal reset'
+                            self.message = 'Pedestal - initial position'
                         else:
                             return False
                     except Exception as e:
-                        self.message = 'Pedestal reset: {}'.format(str(e))
+                        self.message = 'Pedestal - initial position: {}'.format(str(e))
                         return False
                     return True
                             AX = {'az':'azimuth', 'el':'elevation'}
                             axis = [AX[x.lower().strip()] for x in self.axis.split(',')]
                             list_of_floats = [float(x.strip()) for x in self.angle.split(",")]
-                            self.reset_device(axis[0], list_of_floats[0])
+                            self.initial_device(axis[0], list_of_floats[0])
                         if r:
                             self.device.status = 4
                     return payload
                 def get_absolute_url_import(self):
-                    return reverse('url_import_pedestal_conf', args=[str(self.id)])
  No newline at end of file
+                    return reverse('url_import_pedestal_conf', args=[str(self.id)])
+                def get_absolute_url_reset(self):
+                    return reverse('url_reset_pedestal_conf', args=[str(self.id)])
  No newline at end of file

volumes/sirm/apps/pedestal/templates/pedestal_conf.html +4 0

             {% load bootstrap4 %}
             {% load main_tags %}
+            {% block extra-menu-actions %}
+            	<li><a href="{{ dev_conf.get_absolute_url_reset }}"><span class="fas fa-spinner" aria-hidden="true"></span> Reset </a></li>
+            {% endblock %}
             {% block content-detail %}
             <h2>Pedestal</h2>

volumes/sirm/apps/pedestal/urls.py +1 0

                 path('<int:conf_id>/', views.conf, name='url_pedestal_conf'),
                 path('<int:conf_id>/import/', views.import_file, name='url_import_pedestal_conf'),
                 path('<int:conf_id>/edit/', views.conf_edit, name='url_edit_pedestal_conf'),
+                path('<int:conf_id>/reset/', views.conf_reset, name='url_reset_pedestal_conf'),
                 #url(r'^(?P<id_conf>-?\d+)/write/$', 'apps.main.views.dev_conf_write', name='url_write_pedestal_conf'),
                 #url(r'^(?P<id_conf>-?\d+)/read/$', 'apps.main.views.dev_conf_read', name='url_read_pedestal_conf'),
             )

volumes/sirm/apps/pedestal/views.py +12 0

@@ -114,6 +114,18 def import_file(request, conf_id):
114		114
115	return render(request, 'pedestal_import.html', kwargs)	115	return render(request, 'pedestal_import.html', kwargs)
116		116
		117	@login_required
		118	def conf_reset(request, conf_id):
		119
		120	conf = get_object_or_404(PedestalConfiguration, pk=conf_id)
		121
		122	if conf.reset_device():
		123	messages.success(request, conf.message)
		124	else:
		125	messages.error(request, conf.message)
		126
		127	return redirect(conf.get_absolute_url())
		128
117	def conf_raw(request, conf_id):	129	def conf_raw(request, conf_id):
118	conf = get_object_or_404(PedestalConfiguration, pk=conf_id)	130	conf = get_object_or_404(PedestalConfiguration, pk=conf_id)
119	raw = conf.write_device(raw=True)	131	raw = conf.write_device(raw=True)

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages