Mercurial > pygar

annotate modules/bluespec/Pygar/core/AudioCoreSystem.cpp @ 64:bf08daea854e pygar svn.65

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[svn r65] compiles but doesn't run
author punk
date Mon, 10 May 2010 23:16:14 -0400
parents b5be746a0d74
children cf8bb3038cbd
rev   line source
punk@13 1 #include <stdio.h>
punk@13 2 #include <pthread.h>
punk@13 3 #include <semaphore.h>
punk@13 4
punk@13 5 #include "asim/provides/connected_application.h"
punk@13 6 #include "asim/provides/stats_device.h"
punk@13 7 //#include "asim/provides/SndfileWavUtil.h"
punk@13 8
punk@13 9 #include "asim/rrr/client_stub_AUDIOCORERRR.h"
punk@13 10
punk@13 11 using namespace std;
punk@13 12
punk@13 13 pthread_mutex_t CONNECTED_APPLICATION_CLASS::lock;
punk@13 14 pthread_cond_t CONNECTED_APPLICATION_CLASS::cond;
punk@13 15 sem_t CONNECTED_APPLICATION_CLASS::throttle;
punk@13 16
punk@13 17 // constructor
punk@13 18 CONNECTED_APPLICATION_CLASS::CONNECTED_APPLICATION_CLASS(VIRTUAL_PLATFORM vp) :
rlm@23 19
rlm@23 20 clientStub(new AUDIOCORERRR_CLIENT_STUB_CLASS(this))
punk@13 21 {
punk@64 22 printf("SendSide Created\n");
punk@13 23 }
punk@13 24
punk@13 25 // destructor
punk@13 26 CONNECTED_APPLICATION_CLASS::~CONNECTED_APPLICATION_CLASS()
punk@13 27 {
punk@13 28 }
punk@13 29
punk@13 30 // init
punk@13 31 void
punk@13 32 CONNECTED_APPLICATION_CLASS::Init()
punk@13 33 {
punk@13 34
punk@64 35 printf("InitSend Side\n");
punk@13 36 pthread_mutex_init(&lock, NULL);
punk@13 37 pthread_cond_init(&cond, NULL);
punk@13 38 sem_init(&throttle, 0, 64);
punk@13 39
punk@13 40 // enable stats
punk@64 41 //STATS_DEVICE_SERVER_CLASS::GetInstance()->SetupStats();
punk@13 42 }
punk@13 43
punk@57 44 //This isn't called.
punk@13 45 void
punk@13 46 CONNECTED_APPLICATION_CLASS::UpdateSemaphore()
punk@13 47 {
punk@64 48 printf("UpdateSemaphore\n");
punk@13 49 sem_post(&throttle);
punk@13 50 }
punk@13 51
punk@13 52 void
punk@13 53 CONNECTED_APPLICATION_CLASS::EndSimulation()
punk@13 54 {
punk@13 55 printf("EndSimulation Called\n");
punk@13 56 fflush(stdout);
punk@13 57 pthread_mutex_lock(&lock);
punk@13 58 // Do something about the race occuring here
punk@13 59 pthread_cond_signal(&cond);
punk@13 60 pthread_mutex_unlock(&lock);
punk@13 61 printf("EndSimulation done\n");
punk@13 62 fflush(stdout);
punk@13 63 }
punk@13 64
punk@13 65 // main
punk@13 66 void
punk@13 67 CONNECTED_APPLICATION_CLASS::Main()
punk@13 68 {
rlm@34 69 //rlm: two files
punk@13 70 FILE *inputFile;
punk@52 71 FILE *inputFile1;
punk@13 72 UINT16 sample;
punk@52 73 UINT16 sample1;
rlm@34 74
rlm@34 75 //rlm: not sure if normal ints are ok here; using UINT16 because I know it works
punk@52 76 UINT16 channel0 = 0;
punk@52 77 UINT16 channel1 = 1;
punk@31 78
punk@31 79 //init processor
punk@31 80 int sleepCount = 0;
punk@31 81 int result = 0;
punk@31 82
punk@31 83 bool coreFin = false;
punk@31 84
punk@64 85 printf("SendSide Main\n");
punk@31 86 fflush(stdout);
punk@31 87
punk@13 88 // Convert input wav to pcm
rlm@34 89
rlm@34 90 //rlm: for now we are going to going to just have 2 files with "common names"
rlm@34 91
punk@13 92 generate_pcm("input.wav","input.pcm");
punk@52 93 generate_pcm("input1.wav", "input1.pcm");
rlm@34 94
punk@13 95
punk@13 96 //Send data to the machine here.
rlm@34 97 //rlm: two files
punk@13 98 inputFile = fopen("input.pcm","r");
punk@53 99 inputFile1 = fopen("input1.pcm", "r");
rlm@34 100
punk@52 101 assert(inputFile1);
punk@13 102 assert(inputFile);
punk@13 103
punk@13 104 int count = 0;
punk@13 105
punk@57 106 printf("main:samples about to start sending %d\n", count);
punk@13 107
rlm@34 108 //rlm: here we read both files. later refactor into a function.
rlm@34 109 // also, this will terminate when the FIRST file reaches its end.
punk@52 110 while( (fread(&sample, 2, 1, inputFile)) || (fread(&sample1, 2 , 1, inputFile1)))
punk@39 111 { /*
punk@37 112 printf("hi\n");
punk@37 113 if (!coreFin && (result = clientStub->ReadCPUToHost(0)) != 1)
punk@37 114 {
punk@37 115 sleepCount++;
punk@37 116 }
punk@37 117 else if (!coreFin && result == 1)
punk@37 118 {
punk@37 119 printf("\n***SOFT_CORE PASSED***\n");
punk@37 120 coreFin = true;
punk@37 121 }
punk@39 122 */
punk@31 123
punk@37 124 if(count%1000 == 0)
punk@37 125 printf("main: %d\n", count);
punk@37 126 count++;
punk@37 127
rlm@34 128 //rlm: two files.
rlm@41 129 // clientStub->SendUnprocessedStream( Data,(UINT32)sample);
punk@52 130 clientStub->SendUnprocessedStream((UINT32)channel0 , Data,(UINT32)sample);
punk@52 131 clientStub->SendUnprocessedStream((UINT32)channel1 , Data,(UINT32)sample1);
punk@13 132 }
punk@13 133
punk@13 134 printf("main: out of loop\n");
punk@13 135
punk@13 136 // Need to put lock here to prevent potential race condition
punk@13 137 pthread_mutex_lock(&lock);
rlm@34 138
rlm@34 139 //rlm: have to send end-files to both voices.
rlm@34 140 // all of these operations wil eventually be moved into functions.
rlm@41 141 //clientStub->SendUnprocessedStream(EndOfFile,0);
rlm@41 142 clientStub->SendUnprocessedStream((UINT32)channel0, EndOfFile,0);
punk@52 143 clientStub->SendUnprocessedStream((UINT32)channel1, EndOfFile,0);
punk@13 144
punk@13 145 printf("main: wait for end of file\n");
punk@13 146
punk@13 147 pthread_cond_wait(&cond, &lock);
punk@13 148 pthread_mutex_unlock(&lock);
punk@13 149
rlm@23 150 printf("main: last data out\n");
punk@13 151
punk@13 152 // Convert input wav to pcm
rlm@34 153 // this part is ok because there is always only one input file.
punk@13 154 generate_wav("out_hw.pcm","input.wav","out_hw.wav");
punk@13 155
punk@13 156 printf("generate wav done\n");
punk@13 157
punk@50 158 // printf("If you missed it, core %s", coreFin ? "PASSED\n" : "FAILED\n");
punk@13 159 // Dump the stats file
punk@13 160
punk@13 161 STATS_DEVICE_SERVER_CLASS::GetInstance()->DumpStats();
punk@13 162 STATS_DEVICE_SERVER_CLASS::GetInstance()->EmitFile();
punk@13 163
punk@31 164 fflush(stdout);
punk@53 165 // exit(0);
punk@31 166 }