From: John Melton - G0ORX/N6LYT Date: Sun, 27 Nov 2016 17:45:15 +0000 (+0000) Subject: Added rigctl code supplied by Steve Wilson KA6S X-Git-Url: https://git.rkrishnan.org/uri/%3C?a=commitdiff_plain;h=e68de9c0028fa341288ebf262e77ba577cb1aa29;p=pihpsdr.git Added rigctl code supplied by Steve Wilson KA6S --- diff --git a/Makefile b/Makefile index 70c7c5f..5bc635d 100644 --- a/Makefile +++ b/Makefile @@ -133,6 +133,7 @@ pa_menu.c \ cw_menu.c \ oc_menu.c \ xvtr_menu.c \ +equalizer_menu.c \ rit.c \ meter.c \ mode.c \ @@ -144,6 +145,7 @@ new_protocol_programmer.c \ panadapter.c \ property.c \ radio.c \ +rigctl.c \ signal.c \ splash.c \ toolbar.c \ @@ -176,6 +178,7 @@ pa_menu.h \ cw_menu.h \ oc_menu.h \ xvtr_menu.h \ +equalizer_menu.h \ rit.h \ meter.h \ mode.h \ @@ -186,6 +189,7 @@ new_protocol.h \ panadapter.h \ property.h \ radio.h \ +rigctl.h \ signal.h \ splash.h \ toolbar.h \ @@ -216,6 +220,7 @@ pa_menu.o \ cw_menu.o \ oc_menu.o \ xvtr_menu.o \ +equalizer_menu.o \ rit.o \ meter.o \ mode.o \ @@ -227,6 +232,7 @@ new_protocol_programmer.o \ panadapter.o \ property.o \ radio.o \ +rigctl.o \ signal.o \ splash.o \ toolbar.o \ diff --git a/main.c b/main.c index 0909509..204055d 100644 --- a/main.c +++ b/main.c @@ -56,6 +56,7 @@ #include "toolbar.h" #include "sliders.h" #include "radio.h" +#include "rigctl.h" #include "wdsp_init.h" #include "version.h" #include "mode.h" @@ -703,6 +704,8 @@ fprintf(stderr,"toolbar_height=%d\n",TOOLBAR_HEIGHT); } #endif + launch_rigctl(); + g_idle_add(vfo_update,(gpointer)NULL); } diff --git a/new_menu.c b/new_menu.c index 7198265..98408ac 100644 --- a/new_menu.c +++ b/new_menu.c @@ -35,6 +35,7 @@ #include "freedv_menu.h" #endif #include "xvtr_menu.h" +#include "equalizer_menu.h" #include "radio.h" static GtkWidget *parent_window=NULL; @@ -132,6 +133,13 @@ static gboolean xvtr_cb (GtkWidget *widget, GdkEventButton *event, gpointer data return TRUE; } +static gboolean equalizer_cb (GtkWidget *widget, GdkEventButton *event, gpointer data) { + gtk_widget_destroy(dialog); + dialog=NULL; + equalizer_menu(parent_window); + return TRUE; +} + static gboolean new_menu_pressed_event_cb (GtkWidget *widget, GdkEventButton *event, gpointer data) @@ -215,6 +223,10 @@ static gboolean new_menu_pressed_event_cb (GtkWidget *widget, g_signal_connect (xvtr_b, "button-press-event", G_CALLBACK(xvtr_cb), NULL); gtk_grid_attach(GTK_GRID(grid),xvtr_b,4,2,1,1); + GtkWidget *equalizer_b=gtk_button_new_with_label("Equalizer"); + g_signal_connect (equalizer_b, "button-press-event", G_CALLBACK(equalizer_cb), NULL); + gtk_grid_attach(GTK_GRID(grid),equalizer_b,0,3,1,1); + gtk_container_add(GTK_CONTAINER(content),grid); gtk_widget_show_all(dialog); diff --git a/radio.c b/radio.c index bbb6050..252af23 100644 --- a/radio.c +++ b/radio.c @@ -210,6 +210,9 @@ static int pre_tune_mode; int ctun=0; +int enable_rx_equalizer=0; +double rx_equalizer[4]={0.0,0.0,0.0,0.0}; + void init_radio() { int rc; rc=sem_init(&property_sem, 0, 0); diff --git a/radio.h b/radio.h index a0c55d9..73c79ba 100644 --- a/radio.h +++ b/radio.h @@ -220,6 +220,9 @@ extern int tx_filter_high; extern int ctun; +extern int enable_rx_equalizer; +extern double rx_equalizer[4]; + extern void init_radio(); extern void setSampleRate(int rate); extern int getSampleRate(); diff --git a/rigctl.c b/rigctl.c new file mode 100644 index 0000000..b10556b --- /dev/null +++ b/rigctl.c @@ -0,0 +1,1111 @@ + +/* + * Server for hamlib's TCP rigctl protocol. + * Copyright (C) 2010 Adam Sampson + * 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 2 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, see . + */ + +/* + * PiHPSDR RigCtl by Steve KA6S Oct 16 2016 + * + */ +#include +#include +#include +#include +#include +#include +#include "toolbar.h" +#include "sliders.h" +#include "rigctl.h" +#include "radio.h" +#include "channel.h" +#include "filter.h" +#include +#include "mode.h" +#include "filter.h" +#include "wdsp_init.h" +#include "bandstack.h" +#include "vfo.h" +#include + +// IP stuff below +#include +#include //inet_addr + +#define RIGCTL_DEBUG + +// the port client will be connecting to +#define PORT 19090 // This is the HAMLIB port +// max number of bytes we can get at once +#define MAXDATASIZE 300 + +int init_server (); + +int rigctlGetFilterLow(); +int rigctlGetFilterHigh(); +int rigctlSetFilterLow(int val); +int rigctlSetFilterHigh(int val); +int new_level; + +typedef struct com_list { + char cmd_string[80]; + struct com_list * next_ent; + } com_list_t; +com_list_t cmd_list; +char cmd_save[80]; + +char cmd_input[MAXDATASIZE] ; +char * wptr; +com_list_t * work_input; +com_list_t * work_list; +com_list_t * follow_list; +com_list_t * com_head = NULL; +com_list_t * cur_ent; +int cmdlistcnt; +int retcode = 1; +char workvar[100]; + +char command[80]; +char msg[80]; +char msg2[80]; +char * newf; + +FILE * TTYFILE; +FILE * out; +int output; +FILTER * band_filter; + +static pthread_t rigctl_thread_id; +static void * rigctl (void * arg); + +// This stuff from the telnet server +int sockfd, numbytes; +char buf[MAXDATASIZE]; +struct hostent *he; + +// connector’s address information +struct sockaddr_in their_addr; + +int socket_desc , client_sock , c , read_size; +struct sockaddr_in server , client; +char client_message[MAXDATASIZE]; + +int freq_flag; // Determines if we are in the middle of receiving frequency info + +int digl_offset = 0; +int digl_pol = 0; +int digu_offset = 0; +int digu_pol = 0; +double new_vol = 0; + +// Now my stuff +// +// Looks up entry INDEX_NUM in the command structure and +// returns the command string +// + +void send_resp (char * msg) { + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL: RESP=%s\n",msg); + #endif + write(client_sock, msg, strlen(msg)); +} + +char * cmd_lookup (int index_num) { + com_list_t * lcl_p; + lcl_p = com_head; + if(index_num == 0) { + return(lcl_p->cmd_string); + } else { + while((lcl_p->next_ent != (com_list_t * ) NULL) && (index_num != 0)) { + lcl_p = lcl_p->next_ent; + index_num--; + } + } + if(index_num == 0) { + return(lcl_p->cmd_string); + } else { + return ((char *) NULL); + } +} + +static void * rigctl (void * arg) { + + int len; + init_server(); + double meter; + int save_flag = 0; // Used to concatenate two cmd lines together + + for(;;) { + fprintf(stderr,"RIGCTL - New run\n"); + while((numbytes=recv(client_sock , cmd_input , 1000 , 0)) > 0 ) { + + if(cmd_input[numbytes-1] != ';') { // Got here because the command line is short + cmd_input[numbytes] = '\0'; // Turn it into a C string + strcpy(cmd_save,cmd_input); // And save a copy of it till next time through + save_flag = 1; + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL: *** CMD_SAVE=%s\n",cmd_save); + #endif + } else if(save_flag == 1) { + save_flag = 0; + cmd_input[numbytes] = '\0'; // Turn it into a C string + strcat(cmd_save,cmd_input); + strcpy(cmd_input,cmd_save); // Cat them together and replace cmd_input + numbytes = strlen(cmd_input); + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL: *** CMD_INPUT=%s LEN=%d\n",cmd_input,numbytes); + #endif + } + + cmd_input[numbytes-1] = '\0'; // Turn it into a C string. + len = strlen(cmd_input); + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL: RCVD=%s LENGTH=%d\n",cmd_input,len); + #endif + // Parse the cmd_input + //int space = command.indexOf(' '); + //char cmd_char = com_head->cmd_string[0]; // Assume the command is first thing! + char cmd_str[3]; + cmd_str[0] = cmd_input[0]; + cmd_str[1] = cmd_input[1]; + cmd_str[2] = '\0'; + if(strcmp(cmd_str,"AC")==0) { // Sets or reads the internal antenna tuner status + // P1 0:RX-AT Thru, 1: RX-AT IN + // P2 0: TX-AT Thru 1: TX-AT In + // + if(len <= 2) { + send_resp("AC000;"); + } + } + else if(strcmp(cmd_str,"AG")==0) { // Set Audio Gain - + // AG123; Value of 0- + // AG1 = Sub receiver - what is the value set + // Response - AG<0/1>123; Where 123 is 0-260 + if(len>4) { // Set Audio Gain + volume = (double) atoi(&cmd_input[3])/260; +/* KA6S - This crashes the system + BUG + set_af_gain(volume); +*/ + g_idle_add(update_af_gain,NULL); + } else { // Read Audio Gain + sprintf(msg,"AG0%03d;",2.6 * volume); + send_resp(msg); + #ifdef RIGCTL_DEBUG + fprintf(stderr,":%s\n",msg); + #endif + } + } + else if(strcmp(cmd_str,"AI")==0) { // Allow rebroadcast of set frequency after set - not supported + if(len <=2) { + send_resp("AI0;"); + } + } + else if(strcmp(cmd_str,"AL")==0) { // Set/Reads the auto Notch level + if(len <=2) { + send_resp("AL000;"); + } + } + else if(strcmp(cmd_str,"AM")==0) { // Sets or reads the Auto Mode + if(len <=2) { + send_resp("AM0;"); + } + } + else if(strcmp(cmd_str,"AN")==0) { // Selects the antenna connector (ANT1/2) + if(len <=2) { + send_resp("AN0;"); + } + } + else if(strcmp(cmd_str,"AR")==0) { // Sets or reads the ASC function on/off + if(len <=2) { + send_resp("AR0;"); + } + } + else if(strcmp(cmd_str,"AS")==0) { // Sets/reads automode function parameters + // AS<2xP2><11P3>; + // AS<2xP2><11P3>; + if(len < 6) { + sprintf(msg,"AS%1d%02d%011d%01d;", + 0, // P1 + 0, // Automode + getFrequency(), + rigctlGetMode()); + send_resp(msg); + + } + } + else if(strcmp(cmd_str,"BC")==0) { // Beat Cancellor OFF + if(len <=2) { + send_resp("BC0;"); + } + } + else if(strcmp(cmd_str,"BD")==0) { // Moves down the frequency band + // No response + } + else if(strcmp(cmd_str,"BP")==0) { // Reads the manual beat canceller frequency setting + if(len <=2) { + send_resp("BP000;"); + } + } + else if(strcmp(cmd_str,"BS")==0) { // Sets or reads Beat Canceller status + if(len <=2) { + send_resp("BS0;"); + } + } + else if(strcmp(cmd_str,"BU")==0) { // Moves Up the frequency band + // No response + } + else if(strcmp(cmd_str,"BY")==0) { // Read the busy signal status + if(len <=2) { + send_resp("BY00;"); + } + } + else if(strcmp(cmd_str,"CA")==0) { // Sets/reads cw auto tune function status + if(len <=2) { + send_resp("CA0;"); + } + } + else if(strcmp(cmd_str,"CG")==0) { // Sets/reads the carrier gain status + // 0-100 legal values + if(len <=2) { + send_resp("CG000;"); + } + } + else if(strcmp(cmd_str,"CH")==0) { // Sets the current frequency to call Channel + // No response + } + else if(strcmp(cmd_str,"CI")==0) { // While in VFO mode or memory recall mode, sets freq to the call channel + // No response + } + else if(strcmp(cmd_str,"CM")==0) { // Sets or reads the packet cluster tune f(x) on/off + // 0-100 legal values + if(len <=2) { + send_resp("CM0;"); + } + } + else if(strcmp(cmd_str,"CN")==0) { // Sets and reads CTSS function - 01-38 legal values + if(len <=2) { + send_resp("CN00;"); + } + } + else if(strcmp(cmd_str,"CT")==0) { // Sets and reads CTSS function status + if(len <=2) { + send_resp("CT0;"); + } + } + else if(strcmp(cmd_str,"DC")==0) { // Sets/Reads TX band status + if(len <=2) { + send_resp("DC00;"); + } + } + else if(strcmp(cmd_str,"DN")==0) { // Emulate Mic down key + } + else if(strcmp(cmd_str,"DQ")==0) { // ETs/and reads the DCS function status + if(len <=2) { + send_resp("DQ0;"); + } + } + else if(strcmp(cmd_str,"EX")==0) { // Set/reads the extension menu + if(len <=12) { + send_resp("EX00000000000000000000000;"); + } + } + else if(strcmp(cmd_str,"FA")==0) { // VFO A frequency + // LEN=7 - set frequency + // Next data will be rest of freq + if(len == 13) { //We are receiving freq info + long long new_freqA = atoll(&cmd_input[2]); + setFrequency(new_freqA); + // KA6S - this kills the system pretty quickly - it freezes + // vfo_update(NULL); + // BUG + g_idle_add(vfo_update,NULL); + } else { + if(len==2) { + sprintf(msg,"FA%011d;",getFrequency()); + send_resp(msg); + } + } + } + else if(strcmp(cmd_str,"FB")==0) { // VFO B frequency + if(len==13) { //We are receiving freq info + long long new_freqA = atoll(&cmd_input[2]); + setFrequency(new_freqA); + } else if(len == 2) { + sprintf(msg,"FB%011d;",getFrequency()); + send_resp(msg); + } + } + else if(strcmp(cmd_str,"FC")==0) { // Set Sub receiver freq + // LEN=7 - set frequency + // Next data will be rest of freq + // Len<7 - frequency? + if(len>4) { //We are receiving freq info + long long new_freqA = atoll(&cmd_input[2]); + //setFrequency(new_freqA); + } else { + sprintf(msg,"FC%011d;",getFrequency()); +/* + send_resp(msg); +*/ + } + } + else if(strcmp(cmd_str,"FD")==0) { // Read the filter display dot pattern + send_resp("FD00000000;"); + } + else if(strcmp(cmd_str,"FR")==0) { // Set/reads the extension menu + if(len <2) { + send_resp("FR0;"); + } + } + else if(strcmp(cmd_str,"FS")==0) { // Set/reads fine funct status + if(len <2) { + send_resp("FS0;"); + } + } + else if(strcmp(cmd_str,"FT")==0) { // Sel or reads the transmitters VFO, M, ch or Call comm + if(len <2) { + send_resp("FT0;"); + } + } + else if(strcmp(cmd_str,"FW")==0) { // Sets/Reas DSP receive filter width in hz 0-9999hz + if(len <2) { + send_resp("FW0000;"); + } + } + else if(strcmp(cmd_str,"GT")==0) { // Sets/Reas AGC constant status + if(len <2) { + send_resp("GT000;"); + } + } + else if(strcmp(cmd_str,"ID")==0) { // Read ID - Default to TS-2000 which is type 019. + sprintf(msg,"ID019;"); + send_resp(msg); + } + else if(strcmp(cmd_str,"IF")==0) { // Reads Transceiver status + // IFFFFFFFFFFFF - Frequency + // OFFS - 4 chars Offset in powers of 10 + // RITRIT - 6 chars RIT/XIT Frequency - Not supported =0 + // R - 1 char RIT Status = 0 is off + // X - 1 char XIT Status = 0 is off + // 0 - 1 char Channel Bank number - not used + // 00 - 2 char Channel Bank number - not used + // C - 1 char Mox Status 0=off, 1=on + // M - 1 char Operating mode - align with MD commands + // V - 1 char VFO Split status - not supported + // 0 - 1 char Scan status - not supported + // A - 1 char - same as FT command + // 0 - 1 char - CTCSS tone - not used + // 00 - 2 char - More tone control + // 0 - 1 char - Shift status + sprintf(msg,"IF%011d%04d%06d%1d%1d%1d%02d%01d%01d%01d%01d%01d%01d%02d%01d;", + getFrequency(), + 0, // Shift Offset + 0, // Rit Freq + 0, // Rit Status + 0, // XIT Status + 0, // Channel Bank num + 0, // Channel Bank num + 0, // Mox Status + rigctlGetMode(), // Mode Status - same as MD Command + 0, // VFO Status + 0, // Scan status + 0, // FT command + 0, // CTSS Tone + 0, // More tone control + 0); // Shift status + send_resp(msg); + } + else if(strcmp(cmd_str,"IS")==0) { // Sets/Reas IF shift funct status + if(len <2) { + send_resp("IS00000;"); + } + } + else if(strcmp(cmd_str,"KS")==0) { // Sets/Reads keying freq - 0-060 max + if(len <2) { + send_resp("KS000;"); + } + } + else if(strcmp(cmd_str,"KY")==0) { // Convert char to morse code + if(len <2) { + send_resp("KY0;"); + } + } + else if(strcmp(cmd_str,"LK")==0) { // Set/read key lock function status + if(len <2) { + send_resp("LK00;"); + } + } + else if(strcmp(cmd_str,"LM")==0) { // Set/read DRU 3A unit or elect keyer recording status + if(len <2) { + send_resp("LM0;"); + } + } + else if(strcmp(cmd_str,"LT")==0) { // Set/read Alt function + if(len <2) { + send_resp("LT0;"); + } + } + else if(strcmp(cmd_str,"MC")==0) { // Recalls or reads memory channel + if(len <2) { + send_resp("MC000;"); // Link this to band stack at some point + } + } + else if(strcmp(cmd_str,"MD")==0) { // Mode - digit selects mode + // 1 = LSB + // 2 = USB + // 3 = CWU + // 4 = FM + // 5 = AM + // 6 = DIGL + // 7 = CWL + // 9 = DIGU + int new_mode; + if(len > 2) { // Set Mode + switch(atoi(&cmd_input[2])) { + case 1: + new_mode = modeLSB; + break; + case 2: + new_mode = modeUSB; + break; + case 3: + new_mode = modeCWU; + break; + case 4: + new_mode = modeFMN; + break; + case 5: + new_mode = modeAM; + break; + case 6: + new_mode = modeDIGL; + break; + case 7: + new_mode = modeCWL; + break; + case 9: + new_mode = modeDIGU; + break; + default: + break; + #ifdef RIGCTL_DEBUG + fprintf(stderr,"MD command Unknown"); + #endif + } + // Other stuff to switch modes goes here.. + // since new_mode has the interpreted command in + // in it now. + BANDSTACK_ENTRY *entry; + entry= (BANDSTACK_ENTRY *) + bandstack_entry_get_current(); + entry->mode=new_mode; + setMode(entry->mode); + + FILTER* band_filters=filters[entry->mode]; + FILTER* band_filter=&band_filters[entry->filter]; + setFilter(band_filter->low,band_filter->high); + /* Need a way to update VFO info here..*/ + } else { // Read Mode + int curr_mode; + switch (mode) { + case modeLSB: curr_mode = 1; + break; + case modeUSB: curr_mode = 2; + break; + case modeCWL: curr_mode = 7; // CWL + break; + case modeCWU: curr_mode = 3; // CWU + break; + case modeFMN: curr_mode = 4; // FMN + break; + case modeAM: curr_mode = 5; // AM + break; + case modeDIGU: curr_mode = 9; // DIGU + break; + case modeDIGL: curr_mode = 6; // DIGL + break; + default: + #ifdef RIGCTL_DEBUG + fprintf(stderr, + "RIGCTL: MD command doesn't support %d\n", + mode); + #endif + break; + } + sprintf(msg,"MD%1d;",curr_mode); + send_resp(msg); + } + } + else if(strcmp(cmd_str,"MF")==0) { // Set/read menu A/B + if(len <2) { + send_resp("MF0;"); + } + } + else if(strcmp(cmd_str,"MG")==0) { // Mike Gain - 3 digit value + if(len <2) { + sprintf(msg,"MG%03d",mic_gain * 100); + send_resp(msg); + } else { + int tval = atoi(&cmd_input[2]); + new_vol = (double) tval/100; + set_mic_gain(new_vol); + } + } + else if(strcmp(cmd_str,"ML")==0) { // Set/read the monitor function level + if(len <2) { + send_resp("ML000;"); + } + } + else if(strcmp(cmd_str,"MO")==0) { // Set Monitor on/off + if(len <2) { + send_resp("MO0;"); + } + } + else if(strcmp(cmd_str,"MR")==0) { // Read Memory Channel data + sprintf("MR%1d%02d%02d%011d%1d%1d%1d%02d%02d%03d%1d%1d%09d%02d%1d%08d;", + 0, // P1 - Rx Freq - 1 Tx Freq + 0, // P2 Bankd and channel number -- see MC comment + 0, // P3 - see MC comment + getFrequency(), // P4 - frequency + rigctlGetMode(), // P5 - Mode + 0, // P6 - Locked status + 0, // P7 - O-off, 1-tone, 2-CTCSS, 3 =DCS + 0, // P8 - Tone Numbe3r - see page 35 + 0, // P9 - CTCSS tone number - see CN command + 0, // P10 - DCS code - see QC command + 0, // P11 - Reverse status + 0, // P12 - Shift status - see OS command + 0, // P13 - Offset freq - see OS command + 0, // P14 - Step Size - see ST command + 0, // P15 - Memory Group Number (0-9) + 0); // P16 - Memory Name - 8 char max + send_resp(msg); + } + else if(strcmp(cmd_str,"MU")==0) { // Set/Read Memory Group Data + if(len <2) { + send_resp("MU0000000000;"); + } + } + else if(strcmp(cmd_str,"MW")==0) { // Store Data to Memory Channel + } + else if(strcmp(cmd_str,"NB")==0) { // Set/Read Noise Blanker func status (on/off) + if(len <2) { + send_resp("NB0;"); + } + } + else if(strcmp(cmd_str,"NL")==0) { // Set/Read Noise Reduction Level + if(len <2) { + send_resp("NL000;"); + } + } + else if(strcmp(cmd_str,"NR")==0) { // Set/Read Noise Reduction function status + if(len <2) { + send_resp("NR0;"); + } + } + else if(strcmp(cmd_str,"NT")==0) { // Set/Read autonotch function + if(len <2) { + send_resp("NT0;"); + } + } + else if(strcmp(cmd_str,"OF")==0) { // Set/Read Offset freq (9 digits - hz) + if(len <2) { + send_resp("OF000000000;"); + } + } + else if(strcmp(cmd_str,"OI")==0) { // Read Memory Channel Data + if(len <2) { + sprintf(msg,"OI%011d%04d%06d%1d%1d%1d%02d%1d%1d%1d%1d%1d%1d%02d%1d;", + getFrequency(), + 0, // P2 - Freq Step size + 0, // P3 - Rit/Xit Freq + 0, // P4 - RIT off/Rit On + 0, // P5 - XIT off/on + 0, // P6 - Channel + 0, // P7 - Bank + 0, // P8 - 0RX, 1TX + rigctlGetMode(), // P10 - MD + 0, // P11 - SC command + 0, // P12 Split op - SP command + 0, // P13 Off, 1, 2, + 0, // P14 Tone freq - See TN command + 0); + send_resp(msg); + } + } + else if(strcmp(cmd_str,"OS")==0) { // Set/Read Offset freq (9 digits - hz) + if(len <2) { + send_resp("OS0;"); + } + } + else if(strcmp(cmd_str,"PA")==0) { // Set/Read Preamp function status + if(len <2) { + send_resp("PA00;"); + } + } + else if(strcmp(cmd_str,"PB")==0) { // Set/Read DRU-3A Playback status + if(len <2) { + send_resp("PB0;"); + } + } + else if(strcmp(cmd_str,"PC")==0) { // Set/Read Drive Power output + if(len==2) { + sprintf(msg,"PC%03d;",drive*100); + send_resp(msg); + } else { + // Power Control - 3 digit number- 0 to 100 + //Scales to 0.00-1.00 + + double drive_val = + (double)(atoi(&cmd_input[2]))/10; + // setDrive(drive_val); + set_drive(drive_val); + } + } + else if(strcmp(cmd_str,"PI")==0) { // STore the programmable memory channel + } + else if(strcmp(cmd_str,"PK")==0) { // Reads the packet cluster data + send_resp("PK000000000000000000000000000000000000000000000000;"); + } + else if(strcmp(cmd_str,"PL")==0) { // Set/Read Speech processor level + // P1 000 - min-100 max + // P2 000 - min - 100 max + if(len <2) { + send_resp("PL000000;"); + } + } + else if(strcmp(cmd_str,"PM")==0) { // Recalls the Programmable memory + if(len <2) { + send_resp("PM0;"); + } + } + else if(strcmp(cmd_str,"PR")==0) { // Sets/reads the speech processor function on/off + // 0 - off, 1=on + if(len <2) { + send_resp("PR0;"); + } + } + else if(strcmp(cmd_str,"PS")==0) { // Sets/reads Power on/off state + // 0 - off, 1=on + if(len <2) { + send_resp("PS1;"); // Lets pretend we're powered up ;-) + } + } + else if(strcmp(cmd_str,"PS")==0) { // Sets/reads DCS code + // Codes numbered from 000 to 103. + if(len <2) { + send_resp("QC000;"); // Lets pretend we're powered up ;-) + } + } + else if(strcmp(cmd_str,"QI")==0) { // Store the settings in quick memory + } + else if(strcmp(cmd_str,"QR")==0) { // Send the Quick memory channel data + // P1 - Quick mem off, 1 quick mem on + // P2 - Quick mem channel number + if(len <2) { + send_resp("QR00;"); // Lets pretend we're powered up ;-) + } + } + else if(strcmp(cmd_str,"RA")==0) { // Sets/reads Attenuator function status + // 00-off, 1-99 -on - Main and sub receivers reported + if(len <2) { + send_resp("RA0000;"); + } + } + else if(strcmp(cmd_str,"RC")==0) { // Clears the RIT offset freq + } + else if(strcmp(cmd_str,"RD")==0) { // Move the RIT offset freq down, slow down the scan speed in scan mode + if(len <2) { + send_resp("RD0;"); + } + } + else if(strcmp(cmd_str,"RG")==0) { // RF Gain - 3 digit number + // RG123; 0-255 value + // Scale from -20 - 120 + if(len>4) { // Set Audio Gain + int base_value = atoi(&cmd_input[2]); + float new_gain = ((((float) base_value)/255) * 140) - 20; + set_agc_gain(new_gain); + } else { // Read Audio Gain + sprintf(msg,"RG%03d;",(255/140)*(agc_gain+20)); + send_resp(msg); + } + } + else if(strcmp(cmd_str,"RL")==0) { // Set/read Noise reduction level + if(len <2) { + send_resp("RL00;"); + } + } + else if(strcmp(cmd_str,"RM")==0) { // Set/read Meter function + // P1- 0, unsel, 1 SWR, 2 Comp, 3 ALC + // P2 - 4 dig - Meter value in dots - 000-0030 + if(len <2) { + send_resp("RM00000;"); + } + } + else if(strcmp(cmd_str,"RT")==0) { // Set/read the RIT function status + if(len <2) { + send_resp("RT0;"); + } + } + else if(strcmp(cmd_str,"RU")==0) { // Set/move RIT frequency up + if(len <2) { + send_resp("RU0;"); + } + } + else if(strcmp(cmd_str,"RX")==0) { // Unkey Xmitter + setMox(0); + // 0-main, 1=sub + if(len <2) { + send_resp("RX0;"); + } + } + else if(strcmp(cmd_str,"SA")==0) { // Set/reads satellite mode status + // 0-main, 1=sub + if(len <2) { + send_resp("SA000000000000000;"); + } + } + else if(strcmp(cmd_str,"SB")==0) { // Set/read the SUB TF-W status + if(len <2) { + send_resp("SB0;"); + } + } + else if(strcmp(cmd_str,"SC")==0) { // Set/read the Scan function status + if(len <2) { + send_resp("SC0;"); + } + } + else if(strcmp(cmd_str,"SD")==0) { // Set/read CW break-in time delay + // 0000-1000 ms (in steps of 50 ms) 0000 is full break in + if(len <2) { + send_resp("SD0000;"); + } + } + else if(strcmp(cmd_str,"SH")==0) { // Set/read the DSP filter settings + if(len <2) { + send_resp("SH00;"); + } + } + else if(strcmp(cmd_str,"SI")==0) { // Enters the satellite memory name + } + else if(strcmp(cmd_str,"SL")==0) { // Set/read the DSP filter settings - this appears twice? See SH + if(len <2) { + send_resp("SL00;"); + } + } + else if(strcmp(cmd_str,"SM")==0) { // Read SMETER + // SMx; x=0 RX1, x=1 RX2 + // meter is in dbm - value will be 0<260 + // Translate to 00-30 for main, 0-15 fo sub + // Resp= SMxAABB; + // + double level; + level = GetRXAMeter(CHANNEL_RX0, smeter); + level = level + (double) get_attenuation(); + new_level = (int) level; + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL: SM level=%.21f new_level=%d\n", + level,new_level); + #endif + sprintf(msg,"SM%1c%04d;", + cmd_input[2],new_level); + send_resp(msg); + } + else if(strcmp(cmd_str,"SQ")==0) { // Set/read the squelch level + // P1 - 0- main, 1=sub + // P2 - 0-255 + if(len <2) { + send_resp("SQ0000;"); + } + } + else if(strcmp(cmd_str,"SR")==0) { // Resets the transceiver + } + else if(strcmp(cmd_str,"SS")==0) { // Set/read Scan pause freq + if(len <2) { + send_resp("SS0;"); + } + } + else if(strcmp(cmd_str,"ST")==0) { // Set/read the multi/ch control freq steps + if(len <2) { + send_resp("ST00;"); + } + } + else if(strcmp(cmd_str,"SU")==0) { // Set/read the scan pause freq + if(len <2) { + send_resp("SU00000000000;"); + } + } + else if(strcmp(cmd_str,"SV")==0) { // Execute the memory transfer function + } + else if(strcmp(cmd_str,"TC")==0) { // Set/read the internal TNC mode + if(len <2) { + send_resp("TC00;"); + } + } + else if(strcmp(cmd_str,"TD")==0) { // Sends the DTMF memory channel + } + else if(strcmp(cmd_str,"TI")==0) { // Reads the TNC LED status + if(len <2) { + send_resp("TI00;"); + } + } + else if(strcmp(cmd_str,"TN")==0) { // Set/Read sub tone freq + if(len <2) { + send_resp("TN00;"); + } + } + else if(strcmp(cmd_str,"TO")==0) { // Set/Read tone function + if(len <2) { + send_resp("TO0;"); + } + } + else if(strcmp(cmd_str,"TS")==0) { // Set/Read TF Set function status + if(len <2) { + send_resp("TS0;"); + } + } + else if(strcmp(cmd_str,"TX")==0) { // Key Xmitter - P1 - transmit on main/sub freq + setMox(1); + if(len <2) { + send_resp("TS0;"); + } + } + else if(strcmp(cmd_str,"TY")==0) { // Set/Read uP firmware type + if(len <2) { + send_resp("TY000;"); + } + } + else if(strcmp(cmd_str,"UL")==0) { // Detects the PLL unlock status - this should never occur - xmit only + if(len <2) { + send_resp("UL0;"); + } + } + else if(strcmp(cmd_str,"UP")==0) { // Emulates the mic up key + } + else if(strcmp(cmd_str,"VD")==0) { // Sets/Reads VOX dleay time - 0000-3000ms in steps of 150 + if(len <2) { + send_resp("VD0000;"); + } + } + else if(strcmp(cmd_str,"VG")==0) { // Sets/Reads VOX gain 000-009 + if(len <2) { + send_resp("VG000;"); + } + } + else if(strcmp(cmd_str,"VG")==0) { // Emulates the voide 1/2 key + } + else if(strcmp(cmd_str,"VX")==0) { // Sets/reads vox f(x) state + if(len <2) { + send_resp("VX0;"); + } + } + else if(strcmp(cmd_str,"XT")==0) { // Sets/reads the XIT f(x) state + if(len <2) { + send_resp("XT0;"); + } + } + else if(strcmp(cmd_str,"XX")==0) { // + // Format RL01234: First dig 0=neg, 1=pos number + // 1-4- digital offset in hertz. + if(len > 4) { // It is set instead of a read + digl_pol = (cmd_input[2]=='0') ? -1 : 1; + digl_offset = atoi(&cmd_input[3]); + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL:RL set %d %d",digl_pol,digl_offset); + #endif + } else { + if(digl_pol==1) { // Nah - its a read + sprintf(msg,"RL1%04d;"); + } else { + sprintf(msg,"RL0%04d;"); + } + send_resp(msg); + #ifdef RIGCTL_DEBUG + fprintf(stderr,":%s\n",msg); + #endif + } + } + else if(strcmp(cmd_str,"XY")==0) { // set/read RTTY DIGL offset frequency - Not available - just store values + // Format RL01234: First dig 0=neg, 1=pos number + // 1-4- digital offset in hertz. + if(len > 4) { // It is set instead of a read + digl_pol = (cmd_input[2]=='0') ? -1 : 1; + digl_offset = atoi(&cmd_input[3]); + #ifdef RIGCTL_DEBUG + fprintf(stderr,"RIGCTL:RL set %d %d",digl_pol,digl_offset); + #endif + } else { + if(digl_pol==1) { // Nah - its a read + sprintf(msg,"RL1%04d;"); + } else { + sprintf(msg,"RL0%04d;"); + } + send_resp(msg); + #ifdef RIGCTL_DEBUG + fprintf(stderr,":%s\n",msg); + #endif + } + } + else { + fprintf(stderr,"RIGCTL: UNKNOWN\n"); + } + } + // Got here because pipe closed + if(numbytes == 0) { + fprintf(stderr,"RIGCTL: Client disconnected\n"); + close(client_sock); + sleep(1); + client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c); + } + } +} + +char * rigctlGetFilter() +{ + + char * m = mode_string[mode]; + + if (strcmp(m,"CWU") == 0){ + return (char *) (getFilterHigh() + getFilterLow()); + } + else + if (strcmp(m,"CWL") == 0){ + return (char *) (getFilterHigh() + getFilterLow()); + } + else + return (char *) (getFilterHigh() - getFilterLow()); +} + + +void launch_rigctl () { + int err; + fprintf(stderr, "LAUNCHING RIGCTL!!\n"); + // This routine encapsulates the pthread call + err = pthread_create (&rigctl_thread_id,NULL,rigctl,NULL); + if(err != 0) { + fprintf(stderr, "pthread_create failed on rigctl launch\n"); + } +} + +// +// Telnet Server Code below: +// + // the port client will be connecting to + #define PORT 19090 // This is the HAMLIB port + // max number of bytes we can get at once + #define MAXDATASIZE 300 + +int init_server () { + + //Create socket + socket_desc = socket(AF_INET , SOCK_STREAM , 0); + if (socket_desc == -1) + { + fprintf(stderr,"RIGCTL: Could not create socket"); + } + fprintf(stderr, "RIGCTL: Socket created"); + + //Prepare the sockaddr_in structure + server.sin_family = AF_INET; + server.sin_addr.s_addr = INADDR_ANY; + server.sin_port = htons( PORT ); + + //Bind + if( bind(socket_desc,(struct sockaddr *)&server , sizeof(server)) < 0) + { + //print the error message + fprintf(stderr,"RIGCLT: bind failed. Error"); + return 1; + } + fprintf(stderr,"RIGCTL: bind done"); + + //Listen + listen(socket_desc , 3); + + //Accept and incoming connection + fprintf(stderr,"RIGCTL: Waiting for incoming connections..."); + c = sizeof(struct sockaddr_in); + + //accept connection from an incoming client + client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c); + if (client_sock < 0) + { + fprintf(stderr,"RIGCTL: Accept failed"); + return 1; + } + fprintf(stderr,"RIGCTL: Connection accepted\n"); +} + +int rigctlGetFilterLow() { + int lookup; + int rval; + + BANDSTACK_ENTRY *entry; + entry = (BANDSTACK_ENTRY *) bandstack_entry_get_current(); + + FILTER* band_filters=filters[entry->mode]; + FILTER* band_filter=&band_filters[entry->filter]; + rval = 0; + for(lookup = 0; lookup<=9; lookup++) { + if(band_filter[lookup].low == -150) { + rval = lookup; + break; + } + } + return rval; +} + +int rigctlGetFilterHigh() { + int lookup; + int rval; + + BANDSTACK_ENTRY *entry; + entry = (BANDSTACK_ENTRY *) bandstack_entry_get_current(); + + FILTER* band_filters=filters[entry->mode]; + FILTER* band_filter=&band_filters[entry->filter]; + rval = 0; + for(lookup = 0; lookup<=9; lookup++) { + if(band_filter[lookup].high == -150) { + rval = lookup; + break; + } + } + return rval; +} +int rigctlGetMode() { + BANDSTACK_ENTRY *entry; + entry= (BANDSTACK_ENTRY *) + bandstack_entry_get_current(); + switch(entry->mode) { + case modeLSB: return(1); // LSB + case modeUSB: return(2); // USB + case modeCWL: return(7); // CWL + case modeCWU: return(3); // CWU + case modeFMN: return(4); // FMN + case modeAM: return(5); // AM + case modeDIGU: return(9); // DIGU + case modeDIGL: return(6); // DIGL + default: return(0); + } +} + +int rigctlSetFilterLow(int val){ +}; +int rigctlSetFilterHigh(int val){ +}; diff --git a/rigctl.h b/rigctl.h new file mode 100644 index 0000000..39d3584 --- /dev/null +++ b/rigctl.h @@ -0,0 +1,9 @@ +#ifndef RIGCTL_H +#define RIGCTL_H + +void launch_rigctl (); + +int rigctlGetMode(); +char * rigctlGetFilter(); + +#endif // RIGCTL_H diff --git a/sliders.c b/sliders.c index 1a6b4da..52bbc49 100644 --- a/sliders.c +++ b/sliders.c @@ -161,6 +161,11 @@ static void afgain_value_changed_cb(GtkWidget *widget, gpointer data) { SetRXAPanelGain1 (CHANNEL_RX0, volume); } +int update_af_gain(void *data) { + set_af_gain(volume); + return 0; +} + void set_af_gain(double value) { volume=value; SetRXAPanelGain1 (CHANNEL_RX0, volume); diff --git a/sliders.h b/sliders.h index a469077..2326c7f 100644 --- a/sliders.h +++ b/sliders.h @@ -20,6 +20,8 @@ #ifndef _SLIDERS_H #define _SLIDERS_H +int update_af_gain(void *data); + void set_agc_gain(double value); void set_af_gain(double value); void set_mic_gain(double value);