summaryrefslogtreecommitdiffstats
path: root/servers/gpib_server_lin/src
diff options
context:
space:
mode:
authorTimothy Pearson <kb9vqf@pearsoncomputing.net>2012-07-09 19:23:03 -0500
committerTimothy Pearson <kb9vqf@pearsoncomputing.net>2012-07-09 19:23:03 -0500
commitd8ef27cb450ae607fd3f26c3078b27b155b91caf (patch)
tree866cd160bf32e1ceba650d8e88d7edf2274c534f /servers/gpib_server_lin/src
parent786b46a05369912c5883a5bc549b02287b91086e (diff)
downloadulab-d8ef27cb450ae607fd3f26c3078b27b155b91caf.tar.gz
ulab-d8ef27cb450ae607fd3f26c3078b27b155b91caf.zip
Added common directories
Diffstat (limited to 'servers/gpib_server_lin/src')
-rw-r--r--servers/gpib_server_lin/src/Makefile.am11
-rw-r--r--servers/gpib_server_lin/src/commanalyzer_functions.c962
-rw-r--r--servers/gpib_server_lin/src/commanalyzer_functions.h56
-rw-r--r--servers/gpib_server_lin/src/gpib_functions.c40
-rw-r--r--servers/gpib_server_lin/src/gpib_functions.h23
-rw-r--r--servers/gpib_server_lin/src/main_server_lin.c1340
-rw-r--r--servers/gpib_server_lin/src/parameters.h28
-rw-r--r--servers/gpib_server_lin/src/scope_functions.c516
-rw-r--r--servers/gpib_server_lin/src/scope_functions.h37
-rw-r--r--servers/gpib_server_lin/src/signal_functions.c284
-rw-r--r--servers/gpib_server_lin/src/signal_functions.h28
11 files changed, 3325 insertions, 0 deletions
diff --git a/servers/gpib_server_lin/src/Makefile.am b/servers/gpib_server_lin/src/Makefile.am
new file mode 100644
index 0000000..bd6b9ee
--- /dev/null
+++ b/servers/gpib_server_lin/src/Makefile.am
@@ -0,0 +1,11 @@
+INCLUDES= $(all_includes) $(KDE_INCLUDES)/tde -I/usr/include/sasl
+KDE_CXXFLAGS = $(USE_EXCEPTIONS)
+
+bin_PROGRAMS = remotefpga_fpgaprogserver
+
+remotefpga_fpgaprogserver_SOURCES = main.cpp fpga_conn.cpp
+
+remotefpga_fpgaprogserver_METASOURCES = AUTO
+remotefpga_fpgaprogserver_LDFLAGS = $(all_libraries) $(KDE_RPATH) $(LIB_QT) -lDCOP $(LIB_TDECORE) $(LIB_TDEUI) -ltdefx $(LIB_KIO) -lktexteditor -ltdekrbsocket -ltqtrla
+
+KDE_OPTIONS = nofinal
diff --git a/servers/gpib_server_lin/src/commanalyzer_functions.c b/servers/gpib_server_lin/src/commanalyzer_functions.c
new file mode 100644
index 0000000..207a4d5
--- /dev/null
+++ b/servers/gpib_server_lin/src/commanalyzer_functions.c
@@ -0,0 +1,962 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include <ctype.h>
+#include <errno.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <string.h>
+#include <getopt.h>
+#include <allegro.h>
+#include "parameters.h"
+#include "gpib_functions.h"
+#include "gpib/ib.h"
+
+char falpha[1024];
+double commanalyzer_raw_trace_data[1024];
+
+unsigned long commanalyzerTraceLength (char * commanalyzerType) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ return 417;
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_date(struct tm * datetime, char * commanalyzerType, int gpibDevice) {
+ char datebuffer [80];
+ strftime(datebuffer,80,"CONF:DATE %m%d%y",datetime);
+
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting date on communications analyzer\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", datebuffer);
+ #endif
+ if (gpib_write(gpibDevice, datebuffer) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_time(struct tm * datetime, char * commanalyzerType, int gpibDevice) {
+ char timebuffer [80];
+ strftime(timebuffer,80,"CONF:TIME +%H.%M",datetime); // FIXME wrong format
+
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting time on communications analyzer\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", timebuffer);
+ #endif
+ if (gpib_write(gpibDevice, timebuffer) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_switch_to_spectrum_analyzer_mode(char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting communications analyzer to spectrum anayzer mode\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"DISP SAN");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_lock_screen (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Locking communications analyzer screen\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SPEC:DISP 'LOCKED'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_mode_tracking (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator to tracking mode\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:RFG 'TRACK'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_mode_fixed (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator to fixed mode\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:RFG 'FIXED'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_rf_input_dedicated (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer RF input to dedicated connector\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:INP 'ANT'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_rf_input_muxed (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer RF input to multiplexed connector\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:INP 'RF IN'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_output_dedicated (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator output to dedicated connector\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:DEST 'DUPL'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_output_muxed (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator output to multiplexed connector\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:DEST 'RF OUT'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_get_spectrum_analyzer_trace(char * commanalyzerType, int gpibDevice) {
+ int max_num_bytes = 0;
+
+ unsigned char segarray[4194304];
+ unsigned char floatstring[1024];
+ long array_pointer;
+ long ai;
+ long left_char;
+ long right_char;
+
+ int x;
+ int y;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ // Send request
+ printf("[INFO] Getting spectrum analyzer trace [Stage 1]\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"MEAS:SAN:TRACE?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ max_num_bytes = (commanalyzerTraceLength(commanalyzerType)*24); // Request more bytes than are possible to ensure no bytes are left behind
+ }
+ else {
+ return 2;
+ }
+ }
+
+ // Read response
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(gpibDevice, T30s);
+ ibeos(gpibDevice, 0x0);
+
+ ai = gpib_read_array(gpibDevice, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ left_char = 0;
+ right_char = 0;
+ array_pointer = 0;
+ while (left_char < ai) {
+ for (right_char=left_char;right_char<ai;right_char++) {
+ if (segarray[right_char] == ',') {
+ break;
+ }
+ }
+ strncpy(floatstring, segarray+left_char, right_char-left_char);
+ floatstring[right_char-left_char] = 0;
+ commanalyzer_raw_trace_data[array_pointer] = atof(floatstring);
+ array_pointer++;
+ left_char = right_char+1;
+ }
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(gpibDevice, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", array_pointer);
+ #endif
+
+ return 0;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_center_frequency(float desired_frequency, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer center frequency to %f\n\r", desired_frequency);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:CFR %E", desired_frequency);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_frequency_span(float desired_frequency, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer span frequency to %f\n\r", desired_frequency);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:SPAN %E", desired_frequency);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_input_attenuation(float desired_attenuation, char * commanalyzerType, int gpibDevice) {
+ int instrument_att;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ // Only three attenuation values are valid
+ if (desired_attenuation < 10) {
+ instrument_att = 0;
+ }
+ else if (desired_attenuation < 30) {
+ instrument_att = 20;
+ }
+ else {
+ instrument_att = 40;
+ }
+ }
+ printf("[INFO] Setting spectrum analyzer attenuation to %d dB\n\r", instrument_att);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:ATT '%d DB'", instrument_att);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_scale(float desired_scale, char * commanalyzerType, int gpibDevice) {
+ int instrument_scale;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ // Only three scale values are valid
+ if (desired_scale < 1.5) {
+ instrument_scale = 1;
+ }
+ else if (desired_scale < 6) {
+ instrument_scale = 2;
+ }
+ else {
+ instrument_scale = 10;
+ }
+ }
+ printf("[INFO] Setting spectrum analyzer scale to %d dB/div\n\r", instrument_scale);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:DISP:SCAL '%d DB/DIV'", instrument_scale);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_input_attenuator_mode_auto( char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer attenuation mode to automatic\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:ATT:MODE 'AUTO'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_input_attenuator_mode_fixed( char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer attenuation mode to fixed\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:ATT:MODE 'HOLD'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_generator_power(float desired_power, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer generator power to %f\n\r", desired_power);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:AMPL %E", desired_power);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_generator_frequency(float desired_frequency, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer generator frequency to %f\n\r", desired_frequency);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:OFR %E", desired_frequency);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_sweep_ascending (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator output sweep to ascending\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:SWE 'NORM'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_spectrum_analyzer_set_generator_sweep_descending (char * commanalyzerType, int gpibDevice) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ printf("[INFO] Setting spectrum analyzer generator output sweep to descending\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:TGEN:SWE 'INVERT'");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_trace_averaging(float desired_avg_samples, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ int instrument_samples;
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ // Only certain values are valid, and I am interpreting 0 as no pk/avg and -1 as peak hold
+ instrument_samples = desired_avg_samples;
+ if (desired_avg_samples > 5) {
+ if (desired_avg_samples < 5) {
+ instrument_samples = desired_avg_samples;
+ }
+ else if (desired_avg_samples < 7) {
+ instrument_samples = 5;
+ }
+ else if (desired_avg_samples < 15) {
+ instrument_samples = 10;
+ }
+ else if (desired_avg_samples < 35) {
+ instrument_samples = 20;
+ }
+ else if (desired_avg_samples < 75) {
+ instrument_samples = 50;
+ }
+ else {
+ instrument_samples = 100;
+ }
+ }
+ }
+ printf("[INFO] Setting spectrum analyzer generator trace averaging to %d\n\r", instrument_samples);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ if (instrument_samples > 0) {
+ sprintf(falpha,"SAN:TRAC:MHOL 'AVG %d'", instrument_samples);
+ }
+ else if (instrument_samples == -1) {
+ sprintf(falpha,"SAN:TRAC:MHOL 'PK HOLD'");
+ }
+ else {
+ sprintf(falpha,"SAN:TRAC:MHOL 'NO PK/AVG'");
+ }
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_set_spectrum_analyzer_reference_power_level(float desired_reflevel, char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ printf("[INFO] Setting spectrum analyzer generator reference level to %f dBm\n\r", desired_reflevel);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:RLEV %E", desired_reflevel);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int commanalyzer_get_spectrum_analyzer_number_of_vertical_divisions( char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ return 8;
+ }
+ else {
+ return -1;
+ }
+}
+
+int commanalyzer_get_spectrum_analyzer_number_of_horizontal_divisions( char * commanalyzerType, int gpibDevice) {
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ return 10;
+ }
+ else {
+ return -1;
+ }
+}
+
+double commanalyzer_get_spectrum_analyzer_reference_power_level(double * retval, char * commanalyzerType, int gpibDevice) {
+ unsigned char segarray[4194304];
+ unsigned char floatstring[1024];
+ long array_pointer;
+ long ai;
+ long left_char;
+ long right_char;
+
+ int max_num_bytes = 0;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ // Send request
+ printf("[INFO] Getting spectrum analyzer reference power level\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:RLEV?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ max_num_bytes = 24; // Request more bytes than are possible to ensure no bytes are left behind
+ }
+ else {
+ return 2;
+ }
+ }
+
+ // Read response
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(gpibDevice, T10s);
+ ibeos(gpibDevice, 0x0);
+
+ ai = gpib_read_array(gpibDevice, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ segarray[ai] = 0;
+ *retval = atof(segarray);
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(gpibDevice, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", ai);
+ #endif
+
+ return 0;
+ }
+ else {
+ return -1;
+ }
+}
+
+double commanalyzer_get_spectrum_analyzer_scale(double * retval, char * commanalyzerType, int gpibDevice) {
+ unsigned char segarray[4194304];
+ unsigned char floatstring[1024];
+ long array_pointer;
+ long ai;
+ long left_char;
+ long right_char;
+
+ int max_num_bytes = 0;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ // Send request
+ printf("[INFO] Getting spectrum analyzer scale\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:DISP:SCAL?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ max_num_bytes = 24; // Request more bytes than are possible to ensure no bytes are left behind
+ }
+ else {
+ return 2;
+ }
+ }
+
+ // Read response
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(gpibDevice, T10s);
+ ibeos(gpibDevice, 0x0);
+
+ ai = gpib_read_array(gpibDevice, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ left_char = 1;
+ right_char = 0;
+ array_pointer = 0;
+ for (right_char=left_char;right_char<ai;right_char++) {
+ if (segarray[right_char] == ' ') {
+ break;
+ }
+ }
+ strncpy(floatstring, segarray+left_char, right_char-left_char);
+ floatstring[right_char-left_char] = 0;
+ *retval = atof(floatstring);
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(gpibDevice, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", ai);
+ #endif
+
+ return 0;
+ }
+ else {
+ return -1;
+ }
+}
+
+int commanalyzer_set_display_brightness(float percent, char * commanalyzerType, int gpibDevice) {
+ int instrument_scale;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ instrument_scale = ((percent/100.0)*7.0)+1;
+ }
+ printf("[INFO] Setting display brightness to %d\n\r", instrument_scale);
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"CONF:INT %d", instrument_scale);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+double commanalyzer_get_spectrum_analyzer_center_frequency(double * retval, char * commanalyzerType, int gpibDevice) {
+ unsigned char segarray[4194304];
+ unsigned char floatstring[1024];
+ long array_pointer;
+ long ai;
+ long left_char;
+ long right_char;
+
+ int max_num_bytes = 0;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ // Send request
+ printf("[INFO] Getting spectrum analyzer center frequency\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:CFR?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ max_num_bytes = 24; // Request more bytes than are possible to ensure no bytes are left behind
+ }
+ else {
+ return 2;
+ }
+ }
+
+ // Read response
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(gpibDevice, T10s);
+ ibeos(gpibDevice, 0x0);
+
+ ai = gpib_read_array(gpibDevice, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ left_char = 1;
+ right_char = 0;
+ array_pointer = 0;
+ for (right_char=left_char;right_char<ai;right_char++) {
+ if (segarray[right_char] == ' ') {
+ break;
+ }
+ }
+ strncpy(floatstring, segarray+left_char, right_char-left_char);
+ floatstring[right_char-left_char] = 0;
+ *retval = atof(floatstring);
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(gpibDevice, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", ai);
+ #endif
+
+ return 0;
+ }
+ else {
+ return -1;
+ }
+}
+
+double commanalyzer_get_spectrum_analyzer_span(double * retval, char * commanalyzerType, int gpibDevice) {
+ unsigned char segarray[4194304];
+ unsigned char floatstring[1024];
+ long array_pointer;
+ long ai;
+ long left_char;
+ long right_char;
+
+ int max_num_bytes = 0;
+
+ if ((strcmp("HP8924C", commanalyzerType) == 0)) {
+ // Send request
+ printf("[INFO] Getting spectrum analyzer frequency span\n\r");
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ sprintf(falpha,"SAN:SPAN?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ max_num_bytes = 24; // Request more bytes than are possible to ensure no bytes are left behind
+ }
+ else {
+ return 2;
+ }
+ }
+
+ // Read response
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(gpibDevice, T10s);
+ ibeos(gpibDevice, 0x0);
+
+ ai = gpib_read_array(gpibDevice, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ left_char = 1;
+ right_char = 0;
+ array_pointer = 0;
+ for (right_char=left_char;right_char<ai;right_char++) {
+ if (segarray[right_char] == ' ') {
+ break;
+ }
+ }
+ strncpy(floatstring, segarray+left_char, right_char-left_char);
+ floatstring[right_char-left_char] = 0;
+ *retval = atof(floatstring);
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(gpibDevice, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", ai);
+ #endif
+
+ return 0;
+ }
+ else {
+ return -1;
+ }
+} \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/commanalyzer_functions.h b/servers/gpib_server_lin/src/commanalyzer_functions.h
new file mode 100644
index 0000000..50f1474
--- /dev/null
+++ b/servers/gpib_server_lin/src/commanalyzer_functions.h
@@ -0,0 +1,56 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+extern double commanalyzer_raw_trace_data[1024];
+
+unsigned long commanalyzerTraceLength (char * commanalyzerType);
+int commanalyzer_set_date(struct tm * datetime, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_time(struct tm * datetime, char * commanalyzerType, int gpibDevice);
+int commanalyzer_switch_to_spectrum_analyzer_mode (char * commanalyzerType, int gpibDevice);
+int commanalyzer_lock_screen (char * commanalyzerType, int gpibDevice);
+
+int commanalyzer_get_spectrum_analyzer_trace (char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_center_frequency(float desired_frequency, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_frequency_span(float desired_frequency, char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_mode_tracking (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_mode_fixed (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_rf_input_dedicated (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_rf_input_muxed (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_output_dedicated (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_output_muxed (char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_input_attenuation(float desired_attenuation, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_scale(float desired_scale, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_input_attenuator_mode_auto( char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_input_attenuator_mode_fixed( char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_generator_power(float desired_power, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_generator_frequency(float desired_frequency, char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_sweep_ascending (char * commanalyzerType, int gpibDevice);
+int commanalyzer_spectrum_analyzer_set_generator_sweep_descending (char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_trace_averaging(float desired_avg_samples, char * commanalyzerType, int gpibDevice);
+int commanalyzer_set_spectrum_analyzer_reference_power_level(float desired_reflevel, char * commanalyzerType, int gpibDevice);
+int commanalyzer_get_spectrum_analyzer_number_of_vertical_divisions( char * commanalyzerType, int gpibDevice);
+int commanalyzer_get_spectrum_analyzer_number_of_horizontal_divisions( char * commanalyzerType, int gpibDevice);
+
+double commanalyzer_get_spectrum_analyzer_reference_power_level (double * retval, char * commanalyzerType, int gpibDevice);
+double commanalyzer_get_spectrum_analyzer_scale (double * retval, char * commanalyzerType, int gpibDevice);
+double commanalyzer_get_spectrum_analyzer_center_frequency (double * retval, char * commanalyzerType, int gpibDevice);
+double commanalyzer_get_spectrum_analyzer_span (double * retval, char * commanalyzerType, int gpibDevice); \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/gpib_functions.c b/servers/gpib_server_lin/src/gpib_functions.c
new file mode 100644
index 0000000..57b20f0
--- /dev/null
+++ b/servers/gpib_server_lin/src/gpib_functions.c
@@ -0,0 +1,40 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include <ctype.h>
+#include <errno.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <string.h>
+#include <getopt.h>
+#include <allegro.h>
+#include "gpib/ib.h"
+
+int gpib_write(int ud, char * buffer){
+ if( ibwrt(ud, buffer, strlen(buffer)) & ERR )
+ {
+ return -1;
+ }
+ return 0;
+} \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/gpib_functions.h b/servers/gpib_server_lin/src/gpib_functions.h
new file mode 100644
index 0000000..d2d6dc6
--- /dev/null
+++ b/servers/gpib_server_lin/src/gpib_functions.h
@@ -0,0 +1,23 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+int gpib_write(int ud, char * buffer);
diff --git a/servers/gpib_server_lin/src/main_server_lin.c b/servers/gpib_server_lin/src/main_server_lin.c
new file mode 100644
index 0000000..9788566
--- /dev/null
+++ b/servers/gpib_server_lin/src/main_server_lin.c
@@ -0,0 +1,1340 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include <stdio.h> /* perror() */
+#include <stdlib.h> /* atoi() */
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <unistd.h> /* read() */
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <netdb.h>
+#include <fcntl.h>
+#include <glib.h>
+#include <gtk/gtk.h>
+#include <termios.h>
+#include <unistd.h>
+#include <sys/signal.h>
+#include <sys/types.h>
+#include <gpib/ib.h>
+#include <time.h>
+#include "parameters.h"
+#include "scope_functions.h"
+#include "signal_functions.h"
+#include "commanalyzer_functions.h"
+
+// Server variables
+char *serverAddress;
+unsigned short serverPort = 4000;
+char *serialportDescription;
+char *gpibServerString;
+
+// Scope parameters
+char *scopeBoard;
+char *scopeDevice;
+char *scopeType;
+char scopeFound = 0;
+int scope_board_device;
+
+// Function generator parameters
+char *funcgenBoard;
+char *funcgenDevice;
+char *funcgenType;
+char funcgenFound = 0;
+int funcgen_board_device;
+
+// Communications analyzer parameters
+char *commanalyzerBoard;
+char *commanalyzerDevice;
+char *commanalyzerType;
+char commanalyzerFound = 0;
+int commanalyzer_board_device;
+
+// Serial port parameters
+char *serialDevice;
+long serialBaud = 0;
+
+// Serial stuff
+int tty;
+struct termios oldtio, newtio; //place for old and new port settings for serial port
+struct termios oldkey, newkey; //place tor old and new port settings for keyboard teletype
+struct sigaction saio; //definition of signal action
+char buf[256]; //buffer for where data is put
+int fd_tty;
+int wait_flag=TRUE; //TRUE while no signal received
+int server_fd_with_serial = -1;
+
+// Network variables
+int clientSocket;
+int status = 0;
+int last_command_acked = 0;
+struct hostent *hostPtr = NULL;
+struct sockaddr_in serverName = { 0 };
+int authentication_timer_check(void);
+long optval;
+int return_status;
+
+// Timing variables
+unsigned int authentication_timer;
+unsigned char enable_authentication_timer;
+
+unsigned char buffer[100000];
+
+// Generic server stuff
+#define QLEN 100000
+u_short portbase = 0;
+struct timeval server_multiplexer;
+
+// Query server stuff
+char *queryservice_port = "4003";
+struct sockaddr_in fsin_query;
+int msock_query;
+fd_set rfds_query;
+fd_set afds_query;
+int alen_query;
+int fd_query;
+int nfds_query;
+
+// Main server stuff
+char *mainservice_port = "4002";
+struct sockaddr_in fsin_mainserver;
+int msock_mainserver;
+fd_set rfds_mainserver;
+fd_set afds_mainserver;
+int alen_mainserver;
+int fd_mainserver;
+int nfds_mainserver;
+int ssock_mainserver;
+//char main_server_in_use;
+//char main_server_fd;
+char main_server_state[65535];
+char auth_char_pos;
+char auth_string[40];
+int k;
+int m;
+
+// Configuration stuff
+static const char filename[] = "remotefpga_gpib.conf";
+char linedata [256];
+
+// Shut up GCC
+void quiet_write(int fd, const void *buf, size_t count) {
+ int retcode = write(fd, buf, count);
+ if (retcode < 0) {
+ printf("[WARN] Network error\n\r");
+ }
+}
+
+void getMyIP (void)
+{
+ char Buf [256];
+ struct hostent* Host;
+ gethostname (Buf, 256);
+ Host=(struct hostent *) gethostbyname (Buf);
+ serverAddress=strdup(inet_ntoa(*((struct in_addr *)Host->h_addr)));
+ //serverAddress=strdup(Buf);
+}
+
+int msleep(unsigned long milisec) {
+ struct timespec req={0};
+ time_t sec=(int)(milisec/1000);
+ milisec=milisec-(sec*1000);
+ req.tv_sec=sec;
+ req.tv_nsec=milisec*1000000L;
+ while(nanosleep(&req,&req)==-1)
+ continue;
+ return 1;
+}
+
+int musleep(unsigned long milisec) {
+ struct timespec req={0};
+ time_t sec=(int)(milisec/1000);
+ milisec=milisec-(sec*1000);
+ req.tv_sec=sec;
+ req.tv_nsec=milisec*1000L;
+ while(nanosleep(&req,&req)==-1)
+ continue;
+ return 1;
+}
+
+void signal_handler_IO (int status) {
+ wait_flag = FALSE;
+}
+
+int setupSerial(void) {
+ struct termios oldtio,newtio;
+
+ fd_tty = open(serialDevice, O_RDWR | O_NOCTTY | O_NONBLOCK | O_APPEND);
+ if (fd_tty < 0) {
+ printf("[FAIL] Unable to open serial device %s\n\r", serialDevice);
+ return 1;
+ }
+
+ tcgetattr(fd_tty,&oldtio); // Save current port settings
+
+ bzero(&newtio, sizeof(newtio));
+ newtio.c_cflag = serialBaud | CS8 | CLOCAL | CREAD;
+ newtio.c_iflag = IGNPAR;
+ newtio.c_oflag = 0;
+
+ // Set input mode (non-canonical, no echo,...)
+ newtio.c_lflag = 0;
+
+ newtio.c_cc[VTIME] = 0; // Inter-character timer unused
+ newtio.c_cc[VMIN] = 0; // Blocking read unused
+
+ tcflush(fd_tty, TCIFLUSH);
+ tcsetattr(fd_tty,TCSANOW,&newtio);
+
+ return 0;
+}
+
+int getConfig(char *parameter, char *line) {
+ int i;
+
+ if (strstr(line, parameter) != NULL) {
+ for (i=0; i<(strlen(line)-strlen(parameter));i++) {
+ linedata[i] = line[i+strlen(parameter)];
+ }
+ linedata[i-1]=0;
+
+ return 0;
+ }
+ else {
+ return 1;
+ }
+}
+
+void concatenateStrings(char * str1, char * str2) {
+ char *str3;
+
+ str3 = (char *)calloc(strlen(str1) + strlen(str2) + 1, sizeof(char));
+ strcpy(str3, str1);
+ strcat(str3, str2);
+
+ str1 = (char *)calloc(strlen(str3) + 1, sizeof(char));
+
+ strcpy(str1, str3);
+
+ free(str1);
+ free(str3);
+}
+
+/* returns a device descriptor after prompting user for primary address */
+int open_gpib_device(int minor, int pad)
+{
+ int ud;
+ const int sad = 0;
+ const int send_eoi = 1;
+ const int eos_mode = 0;
+ const int timeout = T1s;
+
+ printf("[INFO] Trying to open GPIB device %i on board /dev/gpib%i...\n\r", pad, minor);
+ ud = ibdev(minor, pad, sad, timeout, send_eoi, eos_mode);
+ if(ud < 0)
+ {
+ printf("[WARN] GPIB interface error\n\r");
+ return -1;
+ }
+
+ return ud;
+}
+
+char * scopeLongDescription (char * scopeType) {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ return "Hewlett Packard 54600 series";
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ return "Tektronix 744A series";
+ }
+ else {
+ return "UNKNOWN";
+ }
+}
+
+char * commanalyzerLongDescription (char * scopeType) {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ return "Hewlett Packard 8924 series";
+ }
+ else {
+ return "UNKNOWN";
+ }
+}
+
+char * funcgenLongDescription (char * funcgenType) {
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ return "Agilent AG33250A";
+ }
+ else {
+ return "UNKNOWN";
+ }
+}
+
+int readConfig(void) {
+ int i;
+
+ FILE *file = fopen ( filename, "r" );
+ if ( file != NULL ) {
+ char line [256]; // or other suitable maximum line size
+ // read a line
+ while ( fgets ( line, sizeof line, file ) != NULL ) {
+ // Parse the line and update global variables (current line in variable "line")
+ if (getConfig("SERVER_DESCRIPTION:", line) == 0) {
+ gpibServerString = strdup(linedata);
+ printf("[INFO] Server Description: %s\n\r", gpibServerString);
+ }
+ if (getConfig("SERIAL_PORT:", line) == 0) {
+ serialDevice = strdup(linedata);
+ printf("[INFO] Serial Port: %s\n\r", serialDevice);
+ }
+ if (getConfig("BAUD_RATE:", line) == 0) {
+ if (strcmp(linedata, "9600") == 0) serialBaud = B9600;
+ if (strcmp(linedata, "115200") == 0) serialBaud = B115200;
+ //serialBaud = B9600;
+ printf("[INFO] Baud Rate: %s [%ld]\n\r", linedata, serialBaud);
+ serialportDescription = strdup(linedata);
+ }
+ if (getConfig("SCOPE_BOARD:", line) == 0) {
+ scopeBoard = strdup(linedata);
+ scopeFound++;
+ }
+ if (getConfig("SCOPE_DEVICE:", line) == 0) {
+ scopeDevice = strdup(linedata);
+ scopeFound++;
+ }
+ if (getConfig("SCOPE_TYPE:", line) == 0) {
+ scopeType = strdup(linedata);
+ scopeFound++;
+ }
+ if (getConfig("FUNCTION_GENERATOR_BOARD:", line) == 0) {
+ funcgenBoard = strdup(linedata);
+ funcgenFound++;
+ }
+ if (getConfig("FUNCTION_GENERATOR_DEVICE:", line) == 0) {
+ funcgenDevice = strdup(linedata);
+ funcgenFound++;
+ }
+ if (getConfig("FUNCTION_GENERATOR_TYPE:", line) == 0) {
+ funcgenType = strdup(linedata);
+ funcgenFound++;
+ }
+ if (getConfig("COMMANALYZER_BOARD:", line) == 0) {
+ commanalyzerBoard = strdup(linedata);
+ commanalyzerFound++;
+ }
+ if (getConfig("COMMANALYZER_DEVICE:", line) == 0) {
+ commanalyzerDevice = strdup(linedata);
+ commanalyzerFound++;
+ }
+ if (getConfig("COMMANALYZER_TYPE:", line) == 0) {
+ commanalyzerType = strdup(linedata);
+ commanalyzerFound++;
+ }
+ }
+ fclose ( file );
+ if (scopeFound == 3) {
+ printf("[INFO] Oscilloscope conjectured to be on GPIB address %s:%s\n\r", scopeBoard, scopeDevice);
+ scope_board_device = open_gpib_device(atoi(scopeBoard), atoi(scopeDevice));
+ if (scope_board_device < 0) {
+ //return 1;
+ }
+ else {
+ time_t rawtime;
+ struct tm * timeinfo;
+ char datebuffer [80];
+ char timebuffer [80];
+ time ( &rawtime );
+ timeinfo = localtime ( &rawtime );
+ strftime(timebuffer,80,"TIME \"%H:%M:%S\"",timeinfo);
+ strftime(datebuffer,80,"DATE \"%Y-%m-%d\"",timeinfo);
+ printf("[INFO] Configuring %s oscilloscope\n\r", scopeLongDescription(scopeType));
+ printf("[INFO] %s\n\r", datebuffer);
+ printf("[INFO] %s\n\r", timebuffer);
+ if (gpib_write(scope_board_device, timebuffer) == 0) {
+ gpib_write(scope_board_device, datebuffer);
+ printf("[INFO] Communication verified\n\r");
+ }
+ else {
+ printf("[WARN] Communication failed!\n\r");
+ }
+ }
+ }
+ if (funcgenFound == 3) {
+ printf("[INFO] Function generator conjectured to be on GPIB address %s:%s\n\r", funcgenBoard, funcgenDevice);
+ funcgen_board_device = open_gpib_device(atoi(funcgenBoard), atoi(funcgenDevice));
+ if (funcgen_board_device < 0) {
+ //return 1;
+ }
+ else {
+ printf("[INFO] Configuring %s function generator\n\r", funcgenLongDescription(funcgenType));
+ if (gpib_write(funcgen_board_device, "RESET") == 0) {
+ printf("[INFO] Communication verified\n\r");
+ }
+ else {
+ printf("[WARN] Communication failed!\n\r");
+ }
+ }
+ }
+ if (commanalyzerFound == 3) {
+ printf("[INFO] Communications analyzer conjectured to be on GPIB address %s:%s\n\r", commanalyzerBoard, commanalyzerDevice);
+ commanalyzer_board_device = open_gpib_device(atoi(commanalyzerBoard), atoi(commanalyzerDevice));
+ if (commanalyzer_board_device < 0) {
+ //return 1;
+ }
+ else {
+ time_t rawtime;
+ struct tm * timeinfo;
+ time ( &rawtime );
+ timeinfo = localtime ( &rawtime );
+ printf("[INFO] Configuring %s communications analyzer\n\r", commanalyzerLongDescription(commanalyzerType));
+ if (commanalyzer_set_time(timeinfo, commanalyzerType, commanalyzer_board_device) == 0) {
+ commanalyzer_set_date(timeinfo, commanalyzerType, commanalyzer_board_device);
+ printf("[INFO] Communication verified\n\r");
+ }
+ else {
+ printf("[WARN] Communication failed!\n\r");
+ }
+ }
+ }
+ }
+ else
+ {
+ printf("[WARN] Unable to open configuration file %s\n\r", filename);
+ return 1;
+ }
+
+ return 0;
+}
+
+int authentication_timer_check(void) {
+ authentication_timer++;
+
+ return enable_authentication_timer;
+}
+
+int passivesock(const char *service, const char *transport, int qlen) {
+ struct servent *pse;
+ struct protoent *ppe;
+ struct sockaddr_in sin;
+ int s;
+ int type;
+
+ memset(&sin, 0, sizeof(sin));
+ sin.sin_family = AF_INET;
+ sin.sin_addr.s_addr = INADDR_ANY;
+
+ // Map service name to port number
+ if(pse = getservbyname(service, transport)) {
+ sin.sin_port = htons(ntohs((u_short)pse->s_port) + portbase);
+ }
+ else if((sin.sin_port = htons((u_short)atoi(service))) == 0) {
+ printf("[FAIL] Query Server Service Entry %s\n\r", service);
+ return -1;
+ }
+
+ // Map protocol name to protocol number
+ if((ppe = getprotobyname(transport)) == 0) {
+ printf("[FAIL] Query Server Protocol Entry %s\n\r", transport);
+ return -1;
+ }
+
+ // Use protocol to choose a socket type
+ if(strcmp(transport, "udp") == 0) {
+ type = SOCK_DGRAM;
+ }
+ else {
+ type = SOCK_STREAM;
+ }
+
+ // Allocate a socket
+ s = socket(PF_INET, type, ppe->p_proto);
+
+ if(s < 0) {
+ printf("[FAIL] Socket Error\n\r");
+ return -1;
+ }
+
+ // Bind the socket
+ if(bind(s, (struct sockaddr *)&sin, sizeof(sin)) < 0) {
+ printf("[FAIL] Cannot bind to port %s\n\r", service);
+ return -1;
+ }
+
+ if(type == SOCK_STREAM && listen(s, qlen) < 0) {
+ printf("[FAIL] Cannot bind to port %s\n\r", service);
+ return -1;
+ }
+ return s;
+}
+
+int passiveTCP(const char *service, int qlen) {
+ return passivesock(service, "tcp", qlen);
+}
+
+int queryserver(int fd) {
+ return 0;
+}
+
+void buffer_lookfor_two_termdegree (unsigned char * array, unsigned char * array2, int termination_count) {
+ int i;
+ int k;
+ char degree_found;
+
+ degree_found = 0;
+ k=0;
+ for (i=0;i<termination_count;i++) {
+ if (array[i+1] == 176) {
+ if (degree_found == 0) {
+ degree_found = 1;
+ }
+ else {
+ degree_found = 3;
+ }
+ }
+ if (degree_found == 2) {
+ array2[k] = array[i+1];
+ k++;
+ }
+ if (degree_found == 1) {
+ array[i] = 0;
+ degree_found = 2;
+ k=0;
+ }
+ else {
+ array[i] = array[i+1];
+ }
+ }
+ array[i] = 0;
+ array2[k] = 0;
+}
+
+void buffer_lookfor_termdegree (unsigned char * array, int termination_count) {
+ int i;
+ char degree_found;
+
+ degree_found = 0;
+ for (i=0;i<termination_count;i++) {
+ if (array[i+1] == 176) {
+ degree_found = 1;
+ }
+ if (degree_found == 1) {
+ array[i] = 0;
+ }
+ else {
+ array[i] = array[i+1];
+ }
+ }
+ array[i] = 0;
+}
+
+int mainserver(int fd) {
+ char readbuf[100000];
+ char readbuf2[100000];
+ char writebuf[100000];
+ int cc;
+ int z;
+ long bytestosend;
+ char errorbuf[1000];
+
+ cc = 1;
+ switch (main_server_state[fd]) {
+ case 1: // Check the command code
+ cc = read(fd, readbuf, 1);
+ if (cc > 0) {
+ // Got one!
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got command %d on server fd %d\n\r", readbuf[0], fd);
+ #endif
+
+ // What is it?
+ if (readbuf[0] == 31) {
+ // Serial channel open request
+ // Open the serial port
+ printf("[INFO] Opening serial port for fd %d...\n\r", fd);
+ if (serialBaud != 0) {
+ if (setupSerial() != 0) {
+ printf("[FAIL] Cannot open serial port\n\r");
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ else {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ main_server_state[fd] = 4;
+ server_fd_with_serial = fd;
+ printf("[INFO] Entering state 4 on server fd %d\n\r", fd);
+ }
+ }
+ else {
+ printf("[FAIL] Serial port not set up!\n\r");
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 21) {
+ // Scope request
+ if (scope_board_device < 0) {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ else {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ quiet_write(fd, "546\r", strlen("546\r"));
+ main_server_state[fd] = 5;
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ quiet_write(fd, "744\r", strlen("744\r"));
+ main_server_state[fd] = 5;
+ }
+ else {
+ // Scope not recognized, apparently
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ printf("[INFO] Entering state %d on server fd %d\n\r", main_server_state[fd], fd);
+ }
+ }
+ else if (readbuf[0] == 40) {
+ // Function generator request
+ if (funcgen_board_device < 0) {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ else {
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ //if (signal_reset(funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ main_server_state[fd] = 6;
+ //}
+ // Function generator seems to have failed
+ //write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ else {
+ // Function generator not recognized, apparently
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ printf("[INFO] Entering state %d on server fd %d\n\r", main_server_state[fd], fd);
+ }
+ }
+ else if (readbuf[0] == 41) {
+ // Communications analyzer request
+ if (commanalyzer_board_device < 0) {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ else {
+ if (strcmp("HP8924C", commanalyzerType) == 0) {
+ quiet_write(fd, "892\r", strlen("892\r"));
+ main_server_state[fd] = 7;
+ }
+ else {
+ // Communications analyzer not recognized, apparently
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ printf("[INFO] Entering state %d on server fd %d\n\r", main_server_state[fd], fd);
+ }
+ }
+ }
+ break;
+
+ case 4: // Process serial port transfers
+ cc = read(fd_tty, readbuf, 100000);
+ if (cc > 0) {
+ quiet_write(fd, readbuf, cc);
+ fsync(fd_tty);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got %d bytes from the serial port\n\r", cc);
+ #endif
+ }
+ cc = read(fd, writebuf, 100000);
+ if (cc > 0) {
+ quiet_write(fd_tty, writebuf, cc);
+ fsync(fd);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got %d bytes from the network interface\n\r", cc);
+ #endif
+ }
+ break;
+
+ case 5: // Process scope interface commands
+ cc = read(fd, readbuf, 25);
+ if (cc > 0) {
+ // Got one!
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got command %d on server fd %d\n\r", readbuf[0], fd);
+ #endif
+ if ((readbuf[0] == 20) || (readbuf[0] == 29)) { // Want scope screenshot!
+ quiet_write(fd, "ACK", strlen("ACK"));
+ fsync(fd);
+ if (scope_get_screenshot(scopeType, scope_board_device) == 0) {
+ sleep (5);
+ scope_board_device = open_gpib_device(atoi(scopeBoard), atoi(scopeDevice));
+ if (scope_get_screenshot_stage2(scopeType, scope_board_device) == 0) {
+ // Send the data, all of it!
+ quiet_write(fd, "ACK", strlen("ACK"));
+
+ bytestosend = scopeScreenSize(scopeType);
+ k=0;
+ while (bytestosend > 0) {
+ return_status = write(fd, scope_raw_screenshot_data+k, 1);
+ if (return_status > 0) {
+ bytestosend = bytestosend - return_status;
+ k++;
+ }
+ else {
+ bytestosend = 0;
+ }
+ }
+ }
+ else {
+ quiet_write(fd, "NCK", strlen("NCK"));
+ }
+ }
+ else {
+ quiet_write(fd, "NCK", strlen("NCK"));
+ }
+ }
+ else if (readbuf[0] == 22) { // Want to change horizontal timebase
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (scope_set_timebase(atof(readbuf), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 23) { // Want to change volts per division
+ buffer_lookfor_two_termdegree(readbuf, readbuf2, 25);
+ if (scope_set_volts_div(atoi(readbuf), atof(readbuf2), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 24) { // Want to change run status
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (scope_set_acquisition(atoi(readbuf), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 25) { // Want to change channel enable
+ buffer_lookfor_two_termdegree(readbuf, readbuf2, 25);
+ if (scope_set_channel_state(atoi(readbuf), atoi(readbuf2), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 26) { // Want to change trigger channel
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (scope_set_trigger_channel(atoi(readbuf), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 27) { // Want to change trigger level
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (scope_set_trigger_level(atof(readbuf), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 28) { // Want to change channel vertical position
+ buffer_lookfor_two_termdegree(readbuf, readbuf2, 25);
+ if (scope_set_channel_position(atoi(readbuf), atof(readbuf2), scopeType, scope_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ }
+ break;
+ case 6: // Process function generator interface commands
+ cc = read(fd, readbuf, 25);
+ if (cc > 0) {
+ // Got one!
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got command %d on server fd %d\n\r", readbuf[0], fd);
+ #endif
+ if (readbuf[0] == 40) { // Want to reset function generator
+ if (signal_reset(funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 41) { // Is function generator configured?
+ // If I'm in state 6 it had *better* be available!!!
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else if (readbuf[0] == 42) { // Want to change frequency
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (signal_set_frequency(atof(readbuf), funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 43) { // Want to change duty cycle
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (signal_set_duty_cycle(atof(readbuf), funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 44) { // Want to set square wave
+ if (signal_set_waveform("SQUARE", funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 45) { // Want to set sine wave
+ if (signal_set_waveform("SINUSOID", funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 46) { // Want to set triangle wave
+ if (signal_set_waveform("RAMP", funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 47) { // Want to set noise wave
+ if (signal_set_waveform("NOISE", funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 48) { // Want to change P-P voltage
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (signal_set_peak_peak_voltage(atof(readbuf), funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ else if (readbuf[0] == 49) { // Want to change offset voltage
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (signal_set_offset_voltage(atof(readbuf), funcgenType, funcgen_board_device, errorbuf) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, errorbuf, strlen(errorbuf));
+ }
+ }
+ }
+ break;
+ case 7: // Process communications analyzer interface commands
+ cc = read(fd, readbuf, 25);
+ if (cc > 0) {
+ // Got one!
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Got command %d on server fd %d\n\r", readbuf[0], fd);
+ #endif
+ if (readbuf[0] == 40) { // Want to set SA mode
+ if (commanalyzer_switch_to_spectrum_analyzer_mode(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 41) { // Is communications analyzer configured?
+ // If I'm in state 7 it had *better* be available!!!
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else if ((readbuf[0] == 42)) { // Want SA trace
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ fsync(fd);
+ if (commanalyzer_get_spectrum_analyzer_trace(commanalyzerType, commanalyzer_board_device) == 0) {
+ bytestosend = commanalyzerTraceLength(commanalyzerType)*sizeof(double);
+ int16_t numbytes = bytestosend;
+ quiet_write(fd, &numbytes, 2);
+ quiet_write(fd, "\r", 1);
+ fsync(fd);
+ k=0;
+ while (bytestosend > 0) {
+ return_status = write(fd, ((uint8_t*)commanalyzer_raw_trace_data)+k, 1);
+ if (return_status > 0) {
+ bytestosend = bytestosend - return_status;
+ k++;
+ }
+ else {
+ bytestosend = 0;
+ }
+ }
+ fsync(fd);
+ }
+ else {
+ quiet_write(fd, "NCK", strlen("NCK"));
+ }
+ }
+ else if (readbuf[0] == 43) { // Want to lock screen
+ if (commanalyzer_lock_screen(commanalyzerType, commanalyzer_board_device) == 0) {
+ commanalyzer_set_display_brightness(0, commanalyzerType, commanalyzer_board_device); // Don't burn in the screen
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 44) { // Want to set generator to tracking mode
+ if (commanalyzer_spectrum_analyzer_set_generator_mode_tracking(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 45) { // Want to set generator to fixed mode
+ if (commanalyzer_spectrum_analyzer_set_generator_mode_fixed(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 46) { // Want to change center frequency
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_center_frequency(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 47) { // Want to change frequency span
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_frequency_span(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 48) { // Want to set RF input to dedicated connector
+ if (commanalyzer_spectrum_analyzer_set_rf_input_dedicated(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 49) { // Want to set RF input to multiplexed connector
+ if (commanalyzer_spectrum_analyzer_set_rf_input_muxed(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 50) { // Want to set generator output to dedicated connector
+ if (commanalyzer_spectrum_analyzer_set_generator_output_dedicated(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 51) { // Want to set generator output to multiplexed connector
+ if (commanalyzer_spectrum_analyzer_set_generator_output_muxed(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 52) { // Want to change input attenuation
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_input_attenuation(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 53) { // Want to change scale
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_scale(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 54) { // Want to set RF input attenuator mode to automatic
+ if (commanalyzer_set_spectrum_analyzer_input_attenuator_mode_auto(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 55) { // Want to set RF input attenuator mode to fixed
+ if (commanalyzer_set_spectrum_analyzer_input_attenuator_mode_fixed(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 56) { // Want to change generator output power
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_generator_power(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 57) { // Want to change generator output frequency
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_generator_frequency(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 58) { // Want to set generator sweep to ascending
+ if (commanalyzer_spectrum_analyzer_set_generator_sweep_ascending(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 59) { // Want to set generator sweep to descending
+ if (commanalyzer_spectrum_analyzer_set_generator_sweep_descending(commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 60) { // Want to set trace averaging
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_trace_averaging(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 61) { // Want to set reference power level
+ buffer_lookfor_termdegree(readbuf, 25);
+ if (commanalyzer_set_spectrum_analyzer_reference_power_level(atof(readbuf), commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 62) { // Want the number of vertical divisions available
+ int16_t divisions = commanalyzer_get_spectrum_analyzer_number_of_vertical_divisions(commanalyzerType, commanalyzer_board_device);
+ if (divisions >= 0) {
+ quiet_write(fd, &divisions, 2);
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 63) { // Want the number of samples in a trace
+ int16_t divisions = commanalyzerTraceLength(commanalyzerType);
+ if (divisions >= 0) {
+ quiet_write(fd, &divisions, 2);
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &divisions, 2);
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 64) { // Want the number of horizontal divisions available
+ int16_t divisions = commanalyzer_get_spectrum_analyzer_number_of_horizontal_divisions(commanalyzerType, commanalyzer_board_device);
+ if (divisions >= 0) {
+ quiet_write(fd, &divisions, 2);
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &divisions, 2);
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 65) { // Want the reference power level
+ double rpower;
+ if (commanalyzer_get_spectrum_analyzer_reference_power_level(&rpower, commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, &rpower, sizeof(double));
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &rpower, sizeof(double));
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 66) { // Want the vertical division scale
+ double scale;
+ if (commanalyzer_get_spectrum_analyzer_scale(&scale, commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, &scale, sizeof(double));
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &scale, sizeof(double));
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 67) { // Want to get the center frequency
+ double freq;
+ if (commanalyzer_get_spectrum_analyzer_center_frequency(&freq, commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, &freq, sizeof(double));
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &freq, sizeof(double));
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ else if (readbuf[0] == 68) { // Want to get the frequency span
+ double freq;
+ if (commanalyzer_get_spectrum_analyzer_span(&freq, commanalyzerType, commanalyzer_board_device) == 0) {
+ quiet_write(fd, &freq, sizeof(double));
+ quiet_write(fd, "ACK\r", strlen("ACK\r"));
+ }
+ else {
+ quiet_write(fd, &freq, sizeof(double));
+ quiet_write(fd, "NCK\r", strlen("NCK\r"));
+ }
+ }
+ }
+ break;
+ case 2: // Open the serial port
+ printf("[INFO] Opening serial port...\n\r");
+ if (setupSerial() != 0) {
+ printf("[FAIL] Cannot open serial port\n\r");
+ cc = 0;
+ }
+ main_server_state[fd] = 1;
+ break;
+ case 127: sleep(1);
+ cc = 0;
+ break;
+ }
+
+ return cc;
+}
+
+int RunQueryServer() {
+ msock_query = passiveTCP(queryservice_port, QLEN);
+ if (msock_query == -1) {
+ return -1;
+ }
+ nfds_query = getdtablesize();
+ FD_ZERO(&afds_query);
+ FD_SET(msock_query, &afds_query);
+}
+
+int RunMainServer() {
+ //main_server_in_use = 0;
+ //main_server_fd = -1;
+ msock_mainserver = passiveTCP(mainservice_port, QLEN);
+ if (msock_mainserver == -1) {
+ return -1;
+ }
+ nfds_mainserver = getdtablesize();;
+ FD_ZERO(&afds_mainserver);
+ FD_SET(msock_mainserver, &afds_mainserver);
+}
+
+int main(int argc, char *argv[])
+{
+ char successful = 1;
+
+ server_multiplexer.tv_sec = 0;
+ server_multiplexer.tv_usec = 10;
+
+ // Register signal handler
+ signal(SIGPIPE, signal_handler_IO);
+
+ printf("RemoteFPGA GPIB Server v%s.%s%s\n\r", SERVER_MAJOR, SERVER_MINOR, SERVER_REVISION);
+ printf("(c) %s Timothy Pearson\n\r", COPYRIGHT_DATE);
+ printf("(c) %s Remote Laboratory FOSS Contributors\n\r", FOSS_COPYRIGHT_DATE);
+
+ getMyIP();
+
+ printf("[INFO] Reading configuration from %s...\n\r", filename);
+ readConfig();
+
+ if (serialBaud != 0) {
+ printf("[INFO] Opening serial port...\n\r");
+ if (setupSerial() != 0) {
+ successful = 0;
+ }
+ printf("[INFO] Closing serial port...\n\r");
+ close(fd_tty);
+ }
+
+ if (successful == 1) {
+ // Open query port 4001
+ if (RunQueryServer() == -1) {
+ successful = 0;
+ }
+ else {
+ printf("[INFO] Query process started on %s:%s\n\r", serverAddress, queryservice_port);
+ }
+ }
+
+ if (successful == 1) {
+ // Open main port 4000
+ if (RunMainServer() == -1) {
+ successful = 0;
+ }
+ else {
+ printf("[INFO] Main port opened on %s:%s\n\r", serverAddress, mainservice_port);
+ }
+ }
+
+ if (successful == 1) {
+ while (1) {
+ //musleep(1);
+ musleep(10);
+ //musleep(50);
+ //musleep(100);
+ //musleep(250);
+ //musleep(1000);
+
+ // Execute Query Server
+ memcpy(&rfds_query, &afds_query, sizeof(rfds_query));
+ if (select(nfds_query, &rfds_query, (fd_set *)0, (fd_set *)0, &server_multiplexer) < 0) {
+ //errexit("select: %s\n\r", strerror(errno));
+ }
+ if (FD_ISSET(msock_query, &rfds_query)) {
+ int ssock_query;
+ alen_query = sizeof(fsin_query);
+ ssock_query = accept(msock_query, (struct sockaddr *)&fsin_query, &alen_query);
+ if (ssock_query >= 0) {
+ printf("[INFO] Query received from %s\n\r", inet_ntoa(fsin_query.sin_addr));
+
+ FD_SET(ssock_query, &afds_query);
+ if (strlen(gpibServerString) > 0) {
+ quiet_write(ssock_query, gpibServerString, strlen(gpibServerString));
+ quiet_write(ssock_query, "\r", strlen("\r"));
+ }
+ if (serialBaud != 0) {
+ quiet_write(ssock_query, "Auxiliary serial port: ", strlen("Auxiliary serial port: "));
+ quiet_write(ssock_query, serialportDescription, strlen(serialportDescription));
+ quiet_write(ssock_query, " baud\r", strlen(" baud\r"));
+ }
+ if (scopeFound == 3) {
+ quiet_write(ssock_query, scopeLongDescription(scopeType), strlen(scopeLongDescription(scopeType)));
+ quiet_write(ssock_query, " oscilloscope\r", strlen(" oscilloscope\r"));
+ }
+ if (funcgenFound == 3) {
+ quiet_write(ssock_query, funcgenLongDescription(funcgenType), strlen(funcgenLongDescription(funcgenType)));
+ quiet_write(ssock_query, " signal generator\r", strlen(" signal generator\r"));
+ }
+ if (commanalyzerFound == 3) {
+ quiet_write(ssock_query, commanalyzerLongDescription(commanalyzerType), strlen(commanalyzerLongDescription(commanalyzerType)));
+ quiet_write(ssock_query, " communications analyzer\r", strlen(" communications analyzer\r"));
+ }
+ }
+ else {
+ printf("[WARN] Unable to accept query connection\n\r");
+ }
+ }
+ for (fd_query=0; fd_query < nfds_query; fd_query++) {
+ if(fd_query != msock_query && FD_ISSET(fd_query, &rfds_query)) {
+ if(queryserver(fd_query) == 0) {
+ (void) close(fd_query);
+ FD_CLR(fd_query, &afds_query);
+ }
+ }
+ }
+
+ // Execute Main Server
+ memcpy(&rfds_mainserver, &afds_mainserver, sizeof(rfds_mainserver));
+ if (select(nfds_mainserver, &rfds_mainserver, (fd_set *)0, (fd_set *)0, &server_multiplexer) < 0) {
+ //errexit("select: %s\n\r", strerror(errno));
+ }
+ if (FD_ISSET(msock_mainserver, &rfds_mainserver)) {
+ int ssock_mainserver;
+ alen_mainserver = sizeof(fsin_mainserver);
+ ssock_mainserver = accept(msock_mainserver, (struct sockaddr *)&fsin_mainserver, &alen_mainserver);
+
+ optval = 4194304;
+ status = setsockopt(ssock_mainserver, SOL_SOCKET, SO_SNDBUF, &optval, sizeof(optval));
+ printf("[INFO] Socket send buffer size set to %ld bytes\n", optval, status);
+
+ if (ssock_mainserver >= 0) {
+ //printf("[INFO] Connection established with %s\n\r", &fsin_mainserver.sin_addr);
+ }
+ FD_SET(ssock_mainserver, &afds_mainserver);
+
+ fcntl(ssock_mainserver, F_SETFL, (fcntl(ssock_mainserver, F_GETFL) | O_NONBLOCK));
+ //int sockbufsize = 0;
+ //int size = sizeof(int);
+ //getsockopt(ssock_mainserver, SOL_SOCKET, SO_RCVBUF, (char *)&sockbufsize, &size);
+ //printf("[DEBG] SO_RCVBUF: %d\n\r", sockbufsize);
+ main_server_state[ssock_mainserver] = 1;
+ //write(ssock_mainserver, "OPENA", strlen("OPENA"));
+
+ printf("[INFO] Connection established with client %s\n\r", inet_ntoa(fsin_mainserver.sin_addr));
+ }
+ for (fd_mainserver=0; fd_mainserver < nfds_mainserver; ++fd_mainserver) {
+ if (fd_mainserver != msock_mainserver && FD_ISSET(fd_mainserver, &rfds_mainserver)) {
+ if (mainserver(fd_mainserver) == 0) {
+ (void) close(fd_mainserver);
+ FD_CLR(fd_mainserver, &afds_mainserver);
+ if (server_fd_with_serial != -1) {
+ printf("[INFO] Closing serial port...\n\r");
+ close(fd_tty);
+ }
+ printf("[INFO] Connection with client terminated\n\r");
+ }
+ }
+ }
+ if (server_fd_with_serial != -1) {
+ mainserver(server_fd_with_serial);
+ }
+ }
+ }
+
+ return EXIT_SUCCESS;
+} \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/parameters.h b/servers/gpib_server_lin/src/parameters.h
new file mode 100644
index 0000000..0c1776d
--- /dev/null
+++ b/servers/gpib_server_lin/src/parameters.h
@@ -0,0 +1,28 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#define SERVER_MAJOR "1"
+#define SERVER_MINOR "01"
+#define SERVER_REVISION "a"
+#define COPYRIGHT_DATE "2009-2012"
+#define FOSS_COPYRIGHT_DATE "2009-2012"
+#define ENABLE_EXTRA_DEBUGGING \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/scope_functions.c b/servers/gpib_server_lin/src/scope_functions.c
new file mode 100644
index 0000000..8d35552
--- /dev/null
+++ b/servers/gpib_server_lin/src/scope_functions.c
@@ -0,0 +1,516 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include <ctype.h>
+#include <errno.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <string.h>
+#include <getopt.h>
+#include <allegro.h>
+#include "parameters.h"
+#include "gpib_functions.h"
+#include "gpib/ib.h"
+
+char falpha[1024];
+unsigned char scope_raw_screenshot_data[4194304];
+
+unsigned long scopeScreenWidth (char * scopeType) {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ return 512;
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ return 640;
+ }
+ else {
+ return 1;
+ }
+}
+
+unsigned long scopeScreenHeight (char * scopeType) {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ return 280;
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ return 480;
+ }
+ else {
+ return 1;
+ }
+}
+
+unsigned long scopeScreenSize (char * scopeType) {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ return scopeScreenWidth(scopeType)*scopeScreenHeight(scopeType)*3;
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ return scopeScreenWidth(scopeType)*scopeScreenHeight(scopeType)*3;
+ }
+ else {
+ return 1;
+ }
+}
+
+int gpib_read_binblock(int ud, int max_num_bytes, char * scopeType)
+{
+ unsigned char segarray[4194304];
+ long array_pointer;
+ long ai;
+
+ int x;
+ int y;
+
+ array_pointer = 0;
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ ibtmo(ud, T30s);
+ ibeos(ud, 0x0);
+
+ ai = gpib_read_array(ud, max_num_bytes, segarray);
+ if (ai == -1) {
+ return 1;
+ }
+ else {
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ ai = 0;
+ for (x=0;x<scopeScreenWidth(scopeType);x++) {
+ for (y=0;y<scopeScreenHeight(scopeType);y++) {
+ if ((x & 0x7) == 0) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x80) << 0;
+ if ((x & 0x7) == 1) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x40) << 1;
+ if ((x & 0x7) == 2) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x20) << 2;
+ if ((x & 0x7) == 3) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x10) << 3;
+ if ((x & 0x7) == 4) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x08) << 4;
+ if ((x & 0x7) == 5) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x04) << 5;
+ if ((x & 0x7) == 6) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x02) << 6;
+ if ((x & 0x7) == 7) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = (segarray[((x >> 3)+(y*(560/8)))+17] & 0x01) << 7;
+ if (scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] == 0x0) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = 255;
+ if (scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] == 0x80) scope_raw_screenshot_data[y+(x*scopeScreenHeight(scopeType))] = 0;
+ }
+ }
+ }
+ else {
+ return 2;
+ }
+ }
+
+ ibtmo(ud, T10s);
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Read %li bytes from GPIB device\n", array_pointer);
+ #endif
+
+ return 0;
+}
+
+int gpib_read_array(int ud, int max_num_bytes, unsigned char * segarray)
+{
+ int br;
+
+ ibrd(ud, segarray, max_num_bytes-1);
+ br = ThreadIbcntl();
+
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Number of bytes read from GPIB device: %li\n", br);
+ #endif
+ if ((ThreadIbsta() & ERR) && (br == 0)) {
+ return -1;
+ }
+ return br;
+}
+
+int gpib_read_binary(int ud, int max_num_bytes)
+{
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Trying to read %i bytes from GPIB device...\n", max_num_bytes);
+ #endif
+
+ //ibrd(ud, scope_raw_screenshot_data, max_num_bytes-1);
+ system("rm -f /tmp/current_scope_screenshot.bmp");
+ ibrdf(ud, "/tmp/current_scope_screenshot.bmp");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Number of bytes read from GPIB device: %li\n", ThreadIbcntl());
+ #endif
+ if (ThreadIbsta() & ERR) {
+ return -1;
+ }
+ return 0;
+}
+
+int scope_get_screenshot_stage2(char * scopeType, int gpibDevice) {
+ long bytestosend;
+ int k;
+ int m;
+
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Getting scope screenshot [Stage 2]\n\r");
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ if (gpib_read_binblock(gpibDevice, 19768, scopeType) == 0) {
+ return 0;
+ }
+ else {
+ return 1;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ gpib_read_binary(gpibDevice, scopeScreenSize(scopeType));
+
+ BITMAP *bmp;
+ PALETTE palette;
+ int bpp;
+ install_allegro(SYSTEM_AUTODETECT, &errno, atexit);
+ bmp = load_bmp("/tmp/current_scope_screenshot.bmp", palette);
+ if (!bmp) {
+ printf("[WARN] Unable to load screenshot bitmap\n\r");
+ return 1;
+ }
+ set_palette(palette);
+ bpp = bitmap_color_depth(bmp);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Found BPP of %d\n\r", bpp);
+ #endif
+ bytestosend = 0;
+ for (m=0;m<scopeScreenWidth(scopeType);m++) {
+ for (k=0;k<scopeScreenHeight(scopeType);k++) {
+ scope_raw_screenshot_data[bytestosend] = getr_depth(bpp, getpixel(bmp, m, k));
+ bytestosend = bytestosend + 1;
+ scope_raw_screenshot_data[bytestosend] = getg_depth(bpp, getpixel(bmp, m, k));
+ bytestosend = bytestosend + 1;
+ scope_raw_screenshot_data[bytestosend] = getb_depth(bpp, getpixel(bmp, m, k));
+ bytestosend = bytestosend + 1;
+ }
+ }
+ destroy_bitmap(bmp);
+ return 0;
+ }
+ }
+ return 1;
+}
+
+
+int scope_get_screenshot(char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Getting scope screenshot [Stage 1]\n\r");
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"PRINT?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"HARDCOPY:FORMAT BMPCOLOR");
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Wrote: %s\n\r", falpha);
+ #endif
+ sprintf(falpha,"HARDCOPY:LAYOUT PORTRAIT");
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Wrote: %s\n\r", falpha);
+ #endif
+ sprintf(falpha,"HARDCOPY:PALETTE HARDCOPY");
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Wrote: %s\n\r", falpha);
+ #endif
+ sprintf(falpha,"HARDCOPY:PORT GPIB");
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Wrote: %s\n\r", falpha);
+ #endif
+ sprintf(falpha,"HARDCOPY START");
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Wrote: %s\n\r", falpha);
+ #endif
+ return 0;
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ return 1;
+}
+
+int scope_set_timebase(float desired_timebase, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope timebase to %E\n\r", desired_timebase);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"TIM:RANG %E", desired_timebase);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"HORIZONTAL:MAIN:SCALE %E", desired_timebase/10);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_volts_div(int desired_channel, float desired_volts, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope volts/div on channel %d to %f\n\r", desired_channel, desired_volts/8);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"CHAN%d:RANG %E", desired_channel, desired_volts);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"CH%d:SCALE %f", desired_channel, desired_volts/8);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_acquisition(int status, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope run status to %d\n\r", status);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ if (status == 0) {
+ sprintf(falpha,"STOP");
+ }
+ else {
+ sprintf(falpha,"RUN");
+ }
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"ACQUIRE:STATE %d", status);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_channel_state(int desired_channel, int status, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting channel %d state to %i\n\r", desired_channel, status);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ if (status == 0) {
+ sprintf(falpha,"BLAN CHAN%d", desired_channel);
+ }
+ else if (status == 1) {
+ sprintf(falpha,"VIEW CHAN%d", desired_channel);
+ }
+ else {
+ return 2;
+ }
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ if (status == 0) {
+ sprintf(falpha,"SELECT:CH%d OFF", desired_channel);
+ }
+ else if (status == 1) {
+ sprintf(falpha,"SELECT:CH%d ON", desired_channel);
+ }
+ else {
+ return 2;
+ }
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_trigger_channel(int desired_channel, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope trigger channel to %d\n\r", desired_channel);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"TRIG:SOUR CHAN%d", desired_channel);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"TRIGGER:MAIN:EDGE:SOURCE CH%d", desired_channel);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_trigger_level(float desired_level, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope trigger level to %f\n\r", desired_level);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"TRIG:LEV %E", desired_level);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"TRIGGER:MAIN:LEVEL %f", desired_level);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
+
+int scope_set_channel_position(int desired_channel, float desired_level, char * scopeType, int gpibDevice) {
+ if ((strcmp("HP54600OS", scopeType) == 0) || (strcmp("TDS744AOS", scopeType) == 0)) {
+ printf("[INFO] Setting scope channel %d level to %f\n\r", desired_channel, desired_level);
+ if (strcmp("HP54600OS", scopeType) == 0) {
+ sprintf(falpha,"CHAN%d:OFFS %E", desired_channel, desired_level);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ else if (strcmp("TDS744AOS", scopeType) == 0) {
+ sprintf(falpha,"CH%d:POSITION %f", desired_channel, desired_level);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return 0;
+ }
+ else {
+ return 2;
+ }
+ }
+ }
+ else {
+ return 1;
+ }
+}
diff --git a/servers/gpib_server_lin/src/scope_functions.h b/servers/gpib_server_lin/src/scope_functions.h
new file mode 100644
index 0000000..2e7eaa3
--- /dev/null
+++ b/servers/gpib_server_lin/src/scope_functions.h
@@ -0,0 +1,37 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+extern unsigned char scope_raw_screenshot_data[4194304];
+
+unsigned long scopeScreenSize (char * scopeType);
+unsigned long scopeScreenWidth (char * scopeType);
+unsigned long scopeScreenHeight (char * scopeType);
+int gpib_read_binary(int ud, int max_num_bytes);
+int scope_get_screenshot(char * scopeType, int gpibDevice);
+int scope_get_screenshot_stage2(char * scopeType, int gpibDevice);
+int scope_set_timebase(float desired_timebase, char * scopeType, int gpibDevice);
+int scope_set_volts_div(int desired_channel, float desired_volts, char * scopeType, int gpibDevice);
+int scope_set_acquisition(int status, char * scopeType, int gpibDevice);
+int scope_set_channel_state(int desired_channel, int status, char * scopeType, int gpibDevice);
+int scope_set_trigger_channel(int desired_channel, char * scopeType, int gpibDevice);
+int scope_set_trigger_level(float desired_level, char * scopeType, int gpibDevice);
+int scope_set_channel_position(int desired_channel, float desired_level, char * scopeType, int gpibDevice); \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/signal_functions.c b/servers/gpib_server_lin/src/signal_functions.c
new file mode 100644
index 0000000..63562cb
--- /dev/null
+++ b/servers/gpib_server_lin/src/signal_functions.c
@@ -0,0 +1,284 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include <ctype.h>
+#include <errno.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <string.h>
+#include <getopt.h>
+#include "gpib_functions.h"
+#include "parameters.h"
+#include "gpib/ib.h"
+
+char falpha[1024];
+
+int signal_get_last_error(char * funcgenType, int gpibDevice, char * extendedError) {
+ char error_array[1024];
+ int ei;
+ char * ep;
+
+ // Zero the error array
+ for (ei=0;ei<1024;ei++) {
+ error_array[ei] = 0;
+ }
+
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ sleep (1);
+ sprintf(falpha,"SYSTEM:ERROR?");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ ibrd(gpibDevice, error_array, 1024-1);
+ ep = strstr(error_array, "+0,");
+ if (ep != 0) {
+ return 0;
+ }
+ else {
+ sprintf(extendedError, "EXT%s%c\n\r", error_array, 176);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Extended error: %s\n\r", extendedError);
+ #endif
+ return 3;
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!%c\n\r", 176);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Extended error: %s\n\r", extendedError);
+ #endif
+ return 2;
+ }
+ }
+ }
+ sprintf(extendedError, "EXTAn invalid device was selected!%c\n\r", 176);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Extended error: %s\n\r", extendedError);
+ #endif
+ return 1;
+}
+
+int signal_reset(char * funcgenType, int gpibDevice, char * extendedError)
+{
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Resetting function generator\n\r");
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ sprintf(falpha,"*RST");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"*CLS");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"DISP:TEXT 'Remote Control System v%s.%s%s'", SERVER_MAJOR, SERVER_MINOR, SERVER_REVISION);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"FUNCTION SQUARE");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"OUTPUT:LOAD INFINITY");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"VOLTAGE 3.3");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"FUNCTION SQUARE");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"FUNCTION:SQUARE:DCYCLE 50");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"SYSTEM:BEEPER:STATE ON");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"OUTPUT ON");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ sprintf(falpha,"SYSTEM:BEEPER");
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+}
+
+int signal_set_frequency(float desired_frequency, char * funcgenType, int gpibDevice, char * extendedError) {
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Setting function generator frequency to %f\n\r", desired_frequency);
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ // FIXME
+ sprintf(falpha,"FREQUENCY %E", desired_frequency);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+ }
+}
+
+int signal_set_duty_cycle(float desired_dcycle, char * funcgenType, int gpibDevice, char * extendedError) {
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Setting function generator period to %f\n\r", desired_dcycle);
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ // FIXME
+ sprintf(falpha,"FUNCTION:SQUARE:DCYCLE %E", desired_dcycle);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+ }
+}
+
+int signal_set_waveform(char * waveform, char * funcgenType, int gpibDevice, char * extendedError) {
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Setting function generator waveform to %s\n\r", waveform);
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ // FIXME
+ sprintf(falpha,"FUNCTION %s", waveform);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+ }
+}
+
+int signal_set_peak_peak_voltage(float desired_voltage, char * funcgenType, int gpibDevice, char * extendedError) {
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Setting function generator peak-peak voltage to %f\n\r", desired_voltage);
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ // FIXME
+ sprintf(falpha,"VOLTAGE %E", desired_voltage);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+ }
+}
+
+int signal_set_offset_voltage(float desired_voltage, char * funcgenType, int gpibDevice, char * extendedError) {
+ if ((strcmp("AG33250A", funcgenType) == 0)) {
+ printf("[INFO] Setting function generator peak-peak voltage to %f\n\r", desired_voltage);
+ if (strcmp("AG33250A", funcgenType) == 0) {
+ // FIXME
+ sprintf(falpha,"VOLTAGE:OFFSET %E", desired_voltage);
+ #ifdef ENABLE_EXTRA_DEBUGGING
+ printf("[DEBG] Writing: %s\n\r", falpha);
+ #endif
+ if (gpib_write(gpibDevice, falpha) == 0) {
+ return signal_get_last_error(funcgenType, gpibDevice, extendedError);
+ }
+ else {
+ sprintf(extendedError, "EXTAn unknown communications error has occured!�");
+ return 2;
+ }
+ }
+ }
+ else {
+ sprintf(extendedError, "EXTAn invalid device was selected!�");
+ return 1;
+ }
+} \ No newline at end of file
diff --git a/servers/gpib_server_lin/src/signal_functions.h b/servers/gpib_server_lin/src/signal_functions.h
new file mode 100644
index 0000000..e1e05bd
--- /dev/null
+++ b/servers/gpib_server_lin/src/signal_functions.h
@@ -0,0 +1,28 @@
+/*
+ * Remote Laboratory Instrumentation Server
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License along
+ * with this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2009 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+int signal_reset(char * funcgenType, int gpibDevice, char * extendedError);
+int signal_set_frequency(float desired_frequency, char * funcgenType, int gpibDevice, char * extendedError);
+int signal_set_duty_cycle(float desired_dcycle, char * funcgenType, int gpibDevice, char * extendedError);
+int signal_set_waveform(char * waveform, char * funcgenType, int gpibDevice, char * extendedError);
+int signal_set_peak_peak_voltage(float desired_voltage, char * funcgenType, int gpibDevice, char * extendedError);
+int signal_set_offset_voltage(float desired_voltage, char * funcgenType, int gpibDevice, char * extendedError);