--- /dev/null
+/* main.c
+
+This file is part of a program that implements a Software-Defined Radio.
+
+Copyright (C) 2004-5 by Frank Brickle, AB2KT and Bob McGwier, N4HY
+
+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, write to the Free Software
+Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+
+The authors can be reached by email at
+
+ab2kt@arrl.net
+or
+rwmcgwier@comcast.net
+
+or by paper mail at
+
+The DTTS Microwave Society
+6 Kathleen Place
+Bridgewater, NJ 08807
+*/
+
+#include <common.h>
+
+/////////////////////////////////////////////////////////////////////////
+
+// Windows SHTUFF
+
+PRIVATE CRITICAL_SECTION csobj;
+PRIVATE CRITICAL_SECTION cs_updobj;
+PRIVATE LPCRITICAL_SECTION cs;
+PRIVATE LPCRITICAL_SECTION cs_upd;
+PRIVATE BOOLEAN IC = FALSE;
+
+// elementary defaults
+struct _loc loc;
+
+/////////////////////////////////////////////////////////////////////////
+// most of what little we know here about the inner loop,
+// functionally speaking
+
+extern void reset_meters(void);
+extern void reset_spectrum(void);
+extern void reset_counters(void);
+extern void process_samples(float *, float *, float *, float *, int);
+extern void setup_workspace(void);
+extern void destroy_workspace(void);
+
+//========================================================================
+
+PRIVATE void
+spectrum_thread(void)
+{
+ DWORD NumBytesWritten;
+ while (top.running) {
+ sem_wait(&top.sync.pws.sem);
+ compute_spectrum(&uni.spec);
+ WriteFile(top.meas.spec.fd, (LPVOID) & uni.spec.label,
+ sizeof(int), &NumBytesWritten, NULL);
+ WriteFile(top.meas.spec.fd, (LPVOID) uni.spec.output,
+ sizeof(float) * uni.spec.size, &NumBytesWritten, NULL);
+ }
+ pthread_exit(0);
+}
+
+/*PRIVATE void
+scope_thread(void) {
+ DWORD NumBytesWritten;
+ while (top.running) {
+ sem_wait(&top.sync.scope.sem);
+ compute_spectrum(&uni.spec);
+ WriteFile(top.meas.scope.fd,(LPVOID)&uni.spec.label,
+ sizeof(int),&NumBytesWritten,NULL);
+ WriteFile(top.meas.scope.fd,(LPVOID)uni.spec.accum,
+ sizeof(float)*uni.spec.size,&NumBytesWritten,NULL);
+ }
+ pthread_exit(0);
+} */
+
+PRIVATE void
+meter_thread(void)
+{
+ DWORD NumBytesWritten;
+ while (top.running) {
+ sem_wait(&top.sync.mtr.sem);
+ WriteFile(top.meas.mtr.fd, (LPVOID) & uni.meter.label, sizeof(int),
+ &NumBytesWritten, NULL);
+ WriteFile(top.meas.mtr.fd, (LPVOID) & uni.meter.snap.rx,
+ sizeof(REAL) * MAXRX * RXMETERPTS, &NumBytesWritten, NULL);
+ WriteFile(top.meas.mtr.fd, (LPVOID) & uni.meter.snap.tx,
+ sizeof(REAL) * TXMETERPTS, &NumBytesWritten, NULL);
+ }
+ pthread_exit(0);
+}
+
+//========================================================================
+
+PRIVATE void
+monitor_thread(void)
+{
+ while (top.running) {
+ sem_wait(&top.sync.mon.sem);
+ /* If there is anything that needs monitoring, do it here */
+ fprintf(stderr,
+ "@@@ mon [%d]: cb = %d rbi = %d rbo = %d xr = %d\n",
+ uni.tick,
+ top.jack.blow.cb,
+ top.jack.blow.rb.i, top.jack.blow.rb.o, top.jack.blow.xr);
+ memset((char *) &top.jack.blow, 0, sizeof(top.jack.blow));
+ }
+ pthread_exit(0);
+
+}
+
+//========================================================================
+
+PRIVATE void
+process_updates_thread(void)
+{
+
+ while (top.running) {
+ DWORD NumBytesRead;
+ pthread_testcancel();
+ while (ReadFile(top.parm.fd, top.parm.buff, 256, &NumBytesRead, NULL)) {
+ fprintf(stderr, "Update Bytes:%lu Msg:%s\n", NumBytesRead,
+ top.parm.buff), fflush(stderr);
+ if (NumBytesRead != 0)
+ do_update(top.parm.buff, top.verbose ? stderr : 0);
+ }
+ }
+ pthread_exit(0);
+}
+
+//========================================================================
+
+
+PRIVATE void
+gethold(void)
+{
+ EnterCriticalSection(cs);
+ if (ringb_write_space(top.jack.ring.o.l)
+ < top.hold.size.bytes) {
+ // pathology
+ ringb_reset(top.jack.ring.o.l);
+ ringb_reset(top.jack.ring.o.r);
+ top.jack.blow.rb.o++;
+ }
+ ringb_write(top.jack.ring.o.l,
+ (char *) top.hold.buf.l, top.hold.size.bytes);
+ ringb_write(top.jack.ring.o.r,
+ (char *) top.hold.buf.r, top.hold.size.bytes);
+ if (ringb_read_space(top.jack.ring.i.l)
+ < top.hold.size.bytes) {
+ // pathology
+ ringb_reset(top.jack.ring.i.l);
+ ringb_reset(top.jack.ring.i.r);
+ memset((char *) top.hold.buf.l, 0, top.hold.size.bytes);
+ memset((char *) top.hold.buf.r, 0, top.hold.size.bytes);
+ ringb_reset(top.jack.auxr.i.l);
+ ringb_reset(top.jack.auxr.i.r);
+ memset((char *) top.hold.aux.l, 0, top.hold.size.bytes);
+ memset((char *) top.hold.aux.r, 0, top.hold.size.bytes);
+ top.jack.blow.rb.i++;
+ } else {
+ ringb_read(top.jack.ring.i.l,
+ (char *) top.hold.buf.l, top.hold.size.bytes);
+ ringb_read(top.jack.ring.i.r,
+ (char *) top.hold.buf.r, top.hold.size.bytes);
+ ringb_read(top.jack.auxr.i.l,
+ (char *) top.hold.aux.l, top.hold.size.bytes);
+ ringb_read(top.jack.auxr.i.r,
+ (char *) top.hold.aux.r, top.hold.size.bytes);
+ }
+ LeaveCriticalSection(cs);
+}
+
+PRIVATE BOOLEAN
+canhold(void)
+{
+ BOOLEAN answer;
+ EnterCriticalSection(cs);
+ answer = (ringb_read_space(top.jack.ring.i.l) >= top.hold.size.bytes);
+ LeaveCriticalSection(cs);
+ return answer;
+}
+
+
+//------------------------------------------------------------------------
+
+PRIVATE void
+run_mute(void)
+{
+ memset((char *) top.hold.buf.l, 0, top.hold.size.bytes);
+ memset((char *) top.hold.buf.r, 0, top.hold.size.bytes);
+ memset((char *) top.hold.aux.l, 0, top.hold.size.bytes);
+ memset((char *) top.hold.aux.r, 0, top.hold.size.bytes);
+ uni.tick++;
+}
+
+PRIVATE void
+run_pass(void)
+{
+ uni.tick++;
+}
+
+PRIVATE void
+run_play(void)
+{
+ process_samples(top.hold.buf.l, top.hold.buf.r,
+ top.hold.aux.l, top.hold.aux.r, top.hold.size.frames);
+}
+
+// NB do not set RUN_SWCH directly via setRunState;
+// use setSWCH instead
+
+PRIVATE void
+run_swch(void)
+{
+ if (top.swch.bfct.have == 0) {
+ // first time
+ // apply ramp down
+ int i, m = top.swch.fade, n = top.swch.tail;
+ for (i = 0; i < m; i++) {
+ float w = (float) 1.0 - (float) i / m;
+ top.hold.buf.l[i] *= w, top.hold.buf.r[i] *= w;
+ }
+ memset((char *) (top.hold.buf.l + m), 0, n);
+ memset((char *) (top.hold.buf.r + m), 0, n);
+ top.swch.bfct.have++;
+ } else if (top.swch.bfct.have < top.swch.bfct.want) {
+ // in medias res
+ memset((char *) top.hold.buf.l, 0, top.hold.size.bytes);
+ memset((char *) top.hold.buf.r, 0, top.hold.size.bytes);
+ top.swch.bfct.have++;
+ } else {
+ // last time
+ // apply ramp up
+ int i, m = top.swch.fade, n = top.swch.tail;
+ for (i = 0; i < m; i++) {
+ float w = (float) i / m;
+ top.hold.buf.l[i] *= w, top.hold.buf.r[i] *= w;
+ }
+ uni.mode.trx = top.swch.trx.next;
+ switch (uni.mode.trx) {
+ int i;
+ case TX:
+ tx.agc.gen->over = tx.tick + 3;
+ break;
+ case RX:
+ for (i = 0; i < uni.multirx.nrx; i++)
+ rx[i].agc.gen->over = rx[i].tick + 3;
+ break;
+ }
+
+ top.state = top.swch.run.last;
+ top.swch.bfct.want = top.swch.bfct.have = 0;
+
+ ringb_reset(top.jack.ring.o.l);
+ ringb_reset(top.jack.ring.o.r);
+ ringb_clear(top.jack.ring.o.l, top.hold.size.bytes);
+ ringb_clear(top.jack.ring.o.r, top.hold.size.bytes);
+
+ reset_meters();
+ reset_spectrum();
+ reset_counters();
+ }
+
+ process_samples(top.hold.buf.l, top.hold.buf.r,
+ top.hold.aux.l, top.hold.aux.r, top.hold.size.frames);
+}
+
+//========================================================================
+
+
+
+DttSP_EXP void
+audio_callback(float *input_l, float *input_r, float *output_l,
+ float *output_r, int nframes)
+{
+ size_t nbytes = sizeof(float) * nframes;
+
+
+ EnterCriticalSection(cs);
+
+
+ if (ringb_read_space(top.jack.ring.o.l) >= nbytes) {
+ ringb_read(top.jack.ring.o.l, (char *) output_l, nbytes);
+ ringb_read(top.jack.ring.o.r, (char *) output_r, nbytes);
+ } else { // rb pathology
+ memset((char *) output_l, 0, nbytes);
+ memset((char *) output_r, 0, nbytes);
+ ringb_restart(top.jack.ring.o.l, nbytes);
+ ringb_restart(top.jack.ring.o.r, nbytes);
+ top.jack.blow.rb.o++;
+ }
+
+ // input: copy from port to ring
+ if (ringb_write_space(top.jack.ring.i.l) >= nbytes) {
+ ringb_write(top.jack.ring.i.l, (char *) input_l, nbytes);
+ ringb_write(top.jack.ring.i.r, (char *) input_r, nbytes);
+ ringb_write(top.jack.auxr.i.l, (char *) input_l, nbytes);
+ ringb_write(top.jack.auxr.i.r, (char *) input_r, nbytes);
+ } else { // rb pathology
+ ringb_restart(top.jack.ring.i.l, nbytes);
+ ringb_restart(top.jack.ring.i.r, nbytes);
+ ringb_restart(top.jack.auxr.i.l, nbytes);
+ ringb_restart(top.jack.auxr.i.r, nbytes);
+ top.jack.blow.rb.i++;
+ }
+ LeaveCriticalSection(cs);
+ // if enough accumulated in ring, fire dsp
+ if (ringb_read_space(top.jack.ring.i.l) >= top.hold.size.bytes)
+ sem_post(&top.sync.buf.sem);
+
+ // check for blowups
+ if ((top.jack.blow.cb > 0) ||
+ (top.jack.blow.rb.i > 0) || (top.jack.blow.rb.o > 0))
+ sem_post(&top.sync.mon.sem);
+}
+
+//========================================================================
+
+DttSP_EXP void
+process_samples_thread(void)
+{
+ while (top.running) {
+ sem_wait(&top.sync.buf.sem);
+ do {
+ gethold();
+ sem_wait(&top.sync.upd.sem);
+ switch (top.state) {
+ case RUN_MUTE:
+ run_mute();
+ break;
+ case RUN_PASS:
+ run_pass();
+ break;
+ case RUN_PLAY:
+ run_play();
+ break;
+ case RUN_SWCH:
+ run_swch();
+ break;
+ }
+ sem_post(&top.sync.upd.sem);
+ } while (canhold());
+ }
+}
+
+
+void
+closeup(void)
+{
+ top.running = FALSE;
+ Sleep(50);
+ safefree((char *) top.jack.ring.o.r);
+ safefree((char *) top.jack.ring.o.l);
+ safefree((char *) top.jack.ring.i.r);
+ safefree((char *) top.jack.ring.i.l);
+ safefree((char *) top.jack.auxr.i.l);
+ safefree((char *) top.jack.auxr.i.r);
+ safefree((char *) top.jack.auxr.o.l);
+ safefree((char *) top.jack.auxr.o.r);
+
+ CloseHandle(top.parm.fp);
+ DisconnectNamedPipe(top.parm.fd);
+ CloseHandle(top.parm.fd);
+
+
+ if (uni.meter.flag) {
+ CloseHandle(top.meas.mtr.fp);
+ DisconnectNamedPipe(top.meas.mtr.fd);
+ CloseHandle(top.meas.mtr.fd);
+ };
+
+ if (uni.spec.flag) {
+ CloseHandle(top.meas.spec.fp);
+ DisconnectNamedPipe(top.meas.spec.fd);
+ CloseHandle(top.meas.spec.fd);
+ };
+ destroy_workspace();
+}
+
+//........................................................................
+
+PRIVATE void
+setup_switching(void)
+{
+ top.swch.fade = (int) (0.1 * uni.buflen + 0.5);
+ top.swch.tail = (top.hold.size.frames - top.swch.fade) * sizeof(float);
+}
+
+PRIVATE void
+setup_local_audio(void)
+{
+ top.hold.size.frames = uni.buflen;
+ top.hold.size.bytes = top.hold.size.frames * sizeof(float);
+ top.hold.buf.l = (float *) safealloc(top.hold.size.frames, sizeof(float),
+ "main hold buffer left");
+ top.hold.buf.r = (float *) safealloc(top.hold.size.frames, sizeof(float),
+ "main hold buffer right");
+ top.hold.aux.l = (float *) safealloc(top.hold.size.frames, sizeof(float),
+ "aux hold buffer left");
+ top.hold.aux.r = (float *) safealloc(top.hold.size.frames, sizeof(float),
+ "aux hold buffer right");
+}
+
+#include <lmerr.h>
+
+PRIVATE void
+DisplayErrorText(DWORD dwLastError)
+{
+ HMODULE hModule = NULL; // default to system source
+ LPSTR MessageBuffer;
+ DWORD dwBufferLength;
+
+ DWORD dwFormatFlags = FORMAT_MESSAGE_ALLOCATE_BUFFER |
+ FORMAT_MESSAGE_IGNORE_INSERTS | FORMAT_MESSAGE_FROM_SYSTEM;
+
+ //
+ // If dwLastError is in the network range,
+ // load the message source.
+ //
+
+ if (dwLastError >= NERR_BASE && dwLastError <= MAX_NERR) {
+ hModule = LoadLibraryEx(TEXT("netmsg.dll"),
+ NULL, LOAD_LIBRARY_AS_DATAFILE);
+
+ if (hModule != NULL)
+ dwFormatFlags |= FORMAT_MESSAGE_FROM_HMODULE;
+ }
+ //
+ // Call FormatMessage() to allow for message
+ // text to be acquired from the system
+ // or from the supplied module handle.
+ //
+
+ if (dwBufferLength = FormatMessageA(dwFormatFlags, hModule, // module to get message from (NULL == system)
+ dwLastError, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), // default language
+ (LPSTR) & MessageBuffer, 0, NULL)) {
+ DWORD dwBytesWritten;
+
+ //
+ // Output message string on stderr.
+ //
+ WriteFile(GetStdHandle(STD_ERROR_HANDLE),
+ MessageBuffer, dwBufferLength, &dwBytesWritten, NULL);
+
+ //
+ // Free the buffer allocated by the system.
+ //
+ LocalFree(MessageBuffer);
+ }
+ //
+ // If we loaded a message source, unload it.
+ //
+ if (hModule != NULL)
+ FreeLibrary(hModule);
+}
+
+
+
+PRIVATE sem_t setup_update_sem;
+
+PRIVATE void
+setup_update_server()
+{
+
+ if (INVALID_HANDLE_VALUE == (top.parm.fd = CreateNamedPipe(top.parm.path,
+ PIPE_ACCESS_INBOUND,
+ PIPE_WAIT |
+ PIPE_TYPE_MESSAGE
+ |
+ PIPE_READMODE_MESSAGE,
+ PIPE_UNLIMITED_INSTANCES,
+ 512, 512,
+ INFINITE,
+ NULL))) {
+ fprintf(stderr, "Update server pipe setup failed:\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+// fprintf(stderr,"Update NamedPipe made\n"),fflush(stderr);
+ sem_post(&setup_update_sem);
+ if (ConnectNamedPipe(top.parm.fd, NULL)) {
+// fprintf(stderr,"Connected the server to the Update pipe\n"),fflush(stderr);
+ } else {
+ fprintf(stderr, "Connected the server to the Update pipe failed\n"),
+ fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ pthread_exit(0);
+}
+
+
+PRIVATE void
+setup_update_client()
+{
+// fprintf(stderr,"Looking for the Update server\n"),fflush(stderr);
+ WaitNamedPipe(top.parm.path, INFINITE);
+// fprintf(stderr,"Found the Update server\n"),fflush(stderr);
+ if (INVALID_HANDLE_VALUE == (top.parm.fp = CreateFile(top.parm.path,
+ GENERIC_WRITE, 0,
+ NULL, OPEN_EXISTING,
+ FILE_ATTRIBUTE_NORMAL,
+ NULL))) {
+ fprintf(stderr, "The Update Client Open Failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ sem_post(&setup_update_sem);
+/* {
+ DWORD numwritten;
+ WriteFile(top.parm.fp,"test",5,&numwritten,NULL);
+ fprintf(stderr,"Number written to server: %lu\n",numwritten),fflush(stderr);
+ }*/
+ pthread_exit(0);
+}
+
+PRIVATE void
+setup_meter_server()
+{
+ top.meas.mtr.fd = CreateNamedPipe(top.meas.mtr.path,
+ PIPE_ACCESS_OUTBOUND,
+ PIPE_WAIT | PIPE_TYPE_MESSAGE |
+ PIPE_READMODE_MESSAGE,
+ PIPE_UNLIMITED_INSTANCES, 512, 512,
+ INFINITE, NULL);
+// fprintf(stderr,"meter handle = %08X\n",(DWORD)top.meas.mtr.fd),fflush(stderr);
+ if (top.meas.mtr.fd == INVALID_HANDLE_VALUE) {
+ fprintf(stderr, "Meter server pipe setup failed:\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ } else {
+// fprintf(stderr,"Meter Pipe Connect succeeded\n"),fflush(stderr);
+ sem_post(&setup_update_sem);
+ if (ConnectNamedPipe(top.meas.mtr.fd, NULL)) {
+// fprintf(stderr,"Connected the Meter Pooch\n"),fflush(stderr);
+ } else {
+ fprintf(stderr, "Meter Pipe Connect failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ }
+ pthread_exit(0);
+}
+
+PRIVATE void
+setup_meter_client()
+{
+// fprintf(stderr,"Looking for the meter server\n"),fflush(stderr);
+ if (WaitNamedPipe(top.meas.mtr.path, INFINITE)) {
+// fprintf(stderr,"Found the Meter server\n"),fflush(stderr);
+ if (INVALID_HANDLE_VALUE ==
+ (top.meas.mtr.fp =
+ CreateFile(top.meas.mtr.path, GENERIC_READ, 0, NULL, OPEN_EXISTING,
+ FILE_ATTRIBUTE_NORMAL, NULL))) {
+ fprintf(stderr, "The Meter Client Open Failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ } else {
+// fprintf(stderr,"The Meter Client Open Succeeded\n"),fflush(stderr);
+ }
+ } else {
+ fprintf(stderr, "Wait for meter pipe failed: Error message %d\n",
+ GetLastError()), fflush(stderr);
+ }
+ sem_post(&setup_update_sem);
+ pthread_exit(0);
+}
+
+PRIVATE void
+setup_spec_server()
+{
+
+ if (INVALID_HANDLE_VALUE ==
+ (top.meas.spec.fd =
+ CreateNamedPipe(top.meas.spec.path, PIPE_ACCESS_OUTBOUND,
+ PIPE_WAIT | PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE,
+ PIPE_UNLIMITED_INSTANCES, 32768, 32768, INFINITE,
+ NULL))) {
+ fprintf(stderr, "Spectrum pipe create failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ } else {
+// fprintf(stderr,"Spectrum Pipe %s Create succeeded\n",top.meas.spec.path),fflush(stderr);
+ sem_post(&setup_update_sem);
+ if (ConnectNamedPipe(top.meas.spec.fd, NULL)) {
+// fprintf(stderr,"Connected to the Spectrum Pipe\n"),fflush(stderr);
+ } else {
+ fprintf(stderr, "Spectrum pipe connect failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ }
+ pthread_exit(0);
+}
+
+PRIVATE void
+setup_spec_client()
+{
+// fprintf(stderr,"Looking for the spectrum server\n"),fflush(stderr);
+ if (WaitNamedPipe(top.meas.spec.path, INFINITE)) {
+// fprintf(stderr,"Found the server\n"),fflush(stderr);
+ if (INVALID_HANDLE_VALUE ==
+ (top.meas.spec.fp =
+ CreateFile(top.meas.spec.path, GENERIC_READ, 0, NULL, OPEN_EXISTING,
+ FILE_ATTRIBUTE_NORMAL, NULL))) {
+ fprintf(stderr, "The Spectrum Client Open Failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ } else {
+// fprintf(stderr,"The Spectrum Client Open Succeeded\n");
+// fprintf(stderr,"Spec Read handle = %08X\n",(DWORD)top.meas.spec.fp),fflush(stderr);
+ }
+ } else {
+ fprintf(stderr, "Wait for spec pipe failed\n"), fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ sem_post(&setup_update_sem);
+ pthread_exit(0);
+}
+PRIVATE pthread_t id1, id2, id3, id4, id5, id6;
+PRIVATE void
+setup_updates(void)
+{
+
+ char mesg[16384] = "TEST TEST METER\n";
+// DWORD NumBytes;
+ top.parm.path = loc.path.parm;
+ sem_init(&setup_update_sem, 0, 0);
+
+
+ if (uni.meter.flag) {
+ top.meas.mtr.path = loc.path.meter;
+ }
+ if (uni.spec.flag) {
+ top.meas.spec.path = loc.path.spec;
+ }
+
+ // Do this STUPID stuff to make use of the Named Pipe Mechanism in Windows
+ // For the update server
+
+
+ pthread_create(&id1, NULL, (void *) setup_update_server, NULL);
+ sem_wait(&setup_update_sem);
+ pthread_create(&id2, NULL, (void *) setup_update_client, NULL);
+ sem_wait(&setup_update_sem);
+ if (uni.meter.flag) {
+ pthread_create(&id3, NULL, (void *) setup_meter_server, NULL);
+ sem_wait(&setup_update_sem);
+ pthread_create(&id4, NULL, (void *) setup_meter_client, NULL);
+ sem_wait(&setup_update_sem);
+/* if (WriteFile(top.meas.mtr.fd,mesg,strlen(mesg)+1,&NumBytes,NULL))
+ {
+ fprintf(stderr,"Meter Pipe write succeeded and wrote %lu bytes\n",NumBytes),fflush(stderr);
+ } else {
+ fprintf(stderr,"Meter Pipe write failed\n"),fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ if (ReadFile(top.meas.mtr.fp,mesg,256,&NumBytes,NULL))
+ {
+ fprintf(stderr,"Meter Pipe read succeeded and %lu bytes read\n",NumBytes),fflush(stderr);
+ fprintf(stderr,"Meter message %s",mesg),fflush(stderr);
+ } else {
+ fprintf(stderr,"Meter Pipe read failed\n"),fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }*/
+
+ }
+
+ if (uni.spec.flag) {
+ memset(mesg, 0, 16384);
+ pthread_create(&id5, NULL, (void *) setup_spec_server, NULL);
+ sem_wait(&setup_update_sem);
+ pthread_create(&id6, NULL, (void *) setup_spec_client, NULL);
+ sem_wait(&setup_update_sem);
+ Sleep(0);
+/* if (WriteFile(top.meas.spec.fd,mesg,16384,&NumBytes,NULL))
+ {
+ fprintf(stderr,"Spec Pipe write succeeded and wrote %lu bytes\n",NumBytes),fflush(stderr);
+ } else {
+ fprintf(stderr,"Spec Pipe write failed\n"),fflush(stderr);
+ DisplayErrorText(GetLastError());
+ }
+ fprintf(stderr,"Spec Read handle(2) = %08X\n",(DWORD)top.meas.spec.fp),fflush(stderr);
+ if (ReadFile(top.meas.spec.fp,mesg,16384,&NumBytes,NULL))
+ {
+ fprintf(stderr,"Spec Pipe read succeeded and %lu bytes read\n",NumBytes),fflush(stderr);
+ } else {
+ fprintf(stderr,"Spec Pipe read failed\n"),fflush(stderr);
+ DisplayErrorText(GetLastError());
+ } */
+ }
+ sem_destroy(&setup_update_sem);
+}
+PRIVATE void
+setup_system_audio(void)
+{
+ size_t ringsize;
+ void *usemem;
+ sprintf(top.jack.name, "sdr-%d", top.pid);
+ top.jack.size = uni.buflen;
+ ringsize = top.hold.size.bytes * loc.mult.ring + sizeof(ringb_t);
+ usemem = safealloc(ringsize, 1, "Ring Input Left");
+ top.jack.ring.i.l =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Input Right");
+ top.jack.ring.i.r =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Output Left");
+ top.jack.ring.o.l =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Output Right");
+ top.jack.ring.o.r =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Input Left Auxiliary");
+ top.jack.auxr.i.l =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Input Right Auxiliary");
+ top.jack.auxr.i.r =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Output Left Auxiliary");
+ top.jack.auxr.o.l =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ usemem = safealloc(ringsize, 1, "Ring Output Right Auxiliary");
+ top.jack.auxr.o.r =
+ ringb_create(usemem, top.hold.size.bytes * loc.mult.ring);
+
+ ringb_clear(top.jack.ring.o.l, top.jack.size * sizeof(float));
+ ringb_clear(top.jack.ring.o.r, top.jack.size * sizeof(float));
+ ringb_clear(top.jack.auxr.o.l, top.jack.size * sizeof(float));
+ ringb_clear(top.jack.auxr.o.r, top.jack.size * sizeof(float));
+}
+
+PRIVATE void
+setup_threading(void)
+{
+ sem_init(&top.sync.upd.sem, 0, 0);
+ pthread_create(&top.thrd.upd.id, NULL, (void *) process_updates_thread,
+ NULL);
+ sem_init(&top.sync.buf.sem, 0, 0);
+ pthread_create(&top.thrd.trx.id, NULL, (void *) process_samples_thread,
+ NULL);
+ sem_init(&top.sync.mon.sem, 0, 0);
+ pthread_create(&top.thrd.mon.id, NULL, (void *) monitor_thread, NULL);
+ if (uni.meter.flag) {
+ sem_init(&top.sync.mtr.sem, 0, 0);
+ pthread_create(&top.thrd.mtr.id, NULL, (void *) meter_thread, NULL);
+ }
+ if (uni.spec.flag) {
+ sem_init(&top.sync.pws.sem, 0, 0);
+ pthread_create(&top.thrd.pws.id, NULL, (void *) spectrum_thread, NULL);
+ }
+ cs = &csobj;
+ InitializeCriticalSection(cs);
+}
+
+//========================================================================
+// hard defaults, then environment
+
+PRIVATE void
+setup_defaults(void)
+{
+ loc.name[0] = 0; // no default name for jack client
+ strcpy(loc.path.rcfile, RCBASE);
+ strcpy(loc.path.parm, PARMPATH);
+ strcpy(loc.path.meter, METERPATH);
+ strcpy(loc.path.spec, SPECPATH);
+ strcpy(loc.path.wisdom, WISDOMPATH);
+ loc.def.rate = DEFRATE;
+ loc.def.size = DEFSIZE;
+ loc.def.nrx = MAXRX;
+ loc.def.mode = DEFMODE;
+ loc.def.spec = DEFSPEC;
+ loc.mult.ring = RINGMULT;
+}
+
+//========================================================================
+void
+setup()
+{
+
+
+ top.pid = GetCurrentThreadId();
+ top.uid = 0L;
+ top.start_tv = now_tv();
+ top.running = TRUE;
+ top.verbose = FALSE;
+ top.state = RUN_PLAY;
+
+ setup_defaults();
+ top.verbose = FALSE;
+ uni.meter.flag = TRUE;
+ uni.spec.flag = TRUE;
+
+ setup_workspace();
+ setup_updates();
+
+ setup_local_audio();
+ setup_system_audio();
+
+ setup_threading();
+ setup_switching();
+ uni.spec.flag = TRUE;
+ uni.spec.type = SPEC_POST_FILT;
+ uni.spec.scale = SPEC_PWR;
+ uni.spec.rxk = 0;
+
+}
projects / dttsp.git / blobdiff