Mercurial > pygar

     1 // The MIT License

     2 

     3 // Copyright (c) 2009 Massachusetts Institute of Technology

     4 

     5 // Permission is hereby granted, free of charge, to any person obtaining a copy

     6 // of this software and associated documentation files (the "Software"), to deal

     7 // in the Software without restriction, including without limitation the rights

     8 // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell

     9 // copies of the Software, and to permit persons to whom the Software is

    10 // furnished to do so, subject to the following conditions:

    11 

    12 // The above copyright notice and this permission notice shall be included in

    13 // all copies or substantial portions of the Software.

    14 

    15 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

    16 // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

    17 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

    18 // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

    19 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

    20 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN

    21 // THE SOFTWARE.

    22 

    23 import Connectable::*;

    24 import GetPut::*;

    25 import ClientServer::*;

    26 

    27 //AWB includes

    28 `include "asim/provides/low_level_platform_interface.bsh"

    29 `include "asim/provides/soft_connections.bsh"

    30 `include "asim/provides/common_services.bsh"

    31 

    32 // Local includes

    33 `include "asim/provides/audio_processor_types.bsh"

    34 `include "asim/provides/audio_pipeline.bsh"

    35 

    36 `include "asim/rrr/remote_client_stub_AUDIOPROCESSORRRR.bsh"

    37 `include "asim/rrr/remote_server_stub_AUDIOPROCESSORRRR.bsh"

    38 

    39 

    40 module [CONNECTED_MODULE] mkConnectedApplication ();

    41 

    42    // Instantiate the rrr stubs

    43    ClientStub_AUDIOPROCESSORRRR client_stub <- mkClientStub_AUDIOPROCESSORRRR();

    44    ServerStub_AUDIOPROCESSORRRR server_stub <- mkServerStub_AUDIOPROCESSORRRR();

    45 

    46    // Instantiate the audio pipeline

    47    AudioPipeline pipeline <- mkAudioPipeline();

    48 

    49    rule feedInput;

    50      let command <- server_stub.acceptRequest_SendUnprocessedStream();

    51      AudioProcessorControl ctrl = unpack(truncate(command.ctrl));

    52 

    53      if(ctrl == EndOfFile)

    54        begin

    55          pipeline.sampleInput.put(tagged EndOfFile);

    56        end

    57      else 

    58        begin

    59          pipeline.sampleInput.put(tagged Sample unpack(truncate(command.sample)));

    60        end

    61    endrule

    62 

    63    rule feedOutput;

    64      let pipelineData <- pipeline.sampleOutput.get();

    65      AudioProcessorControl endOfFileTag = EndOfFile;

    66      AudioProcessorControl sampleTag = Data;

    67 

    68      case (pipelineData) matches

    69        tagged EndOfFile: client_stub.makeRequest_SendProcessedStream(zeroExtend(pack(endOfFileTag)),?);

    70        tagged Sample .sample:client_stub.makeRequest_SendProcessedStream(zeroExtend(pack(sampleTag)),

    71                                                                          zeroExtend(pack(sample)));

    72      endcase

    73    endrule

    74 

    75 endmodule

    76 

    77
author	rlm
date	Tue, 27 Apr 2010 22:55:55 -0400
parents	7e1510b47336
children