-/* 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 / commitdiff