C#

<br />
#include "stdafx.h"<br />
#include <stdio.h><br />
#include <windows.h><br />
<br />
// G3 API function type declarations<br />
typedef int (__stdcall *FNCOpenRadioDevice)(int iDeviceNum);<br />
typedef BOOL (__stdcall *FNCCloseRadioDevice)(int hRadio);<br />
typedef BOOL (__stdcall *FNCSetAtten)(int hRadio, BOOL fAtten);<br />
typedef BOOL (__stdcall *FNCSetPower)(int hRadio, BOOL fPower);<br />
typedef BOOL (__stdcall *FNCSetAGC)(int hRadio, int iAGC);<br />
typedef BOOL (__stdcall *FNCCodecStart)(int hRadio,void (__stdcall *CallbackFunc)(void *),<br />
void *CallbackTarget);<br />
typedef BOOL (__stdcall *FNCCodecStop)(int hRadio);<br />
typedef unsigned int (__stdcall *FNCCodecRead)(int hRadio,void *Buf,unsigned int Size);<br />
<br />
typedef struct {<br />
int hRadio;<br />
FILE *IFFile;<br />
FNCCodecRead CodecRead;<br />
} CallbackContext;<br />
<br />
void __stdcall CodecCallback(void *Target)<br />
{<br />
unsigned int i;<br />
char Buf[4096];<br />
CallbackContext *Ctx=(CallbackContext *)Target;<br />
<br />
while ((i=Ctx->CodecRead(Ctx->hRadio,Buf,sizeof(Buf)))!=0) <br />
	fwrite(Buf,i,1,Ctx->IFFile);<br />
}<br />
//int _tmain(int argc, _TCHAR* argv[])<br />
int main(int argc, char* argv[])<br />
{<br />
// load the G3 API library<br />
HMODULE dll=LoadLibraryA("wrg303api.dll");<br />
if (!dll) {puts("WRG303API.DLL not found !"); return 0;}<br />
<br />
// link G3 API functions<br />
FNCOpenRadioDevice OpenRadioDevice=(FNCOpenRadioDevice)GetProcAddress(dll,"OpenRadioDevice");<br />
FNCCloseRadioDevice CloseRadioDevice=(FNCCloseRadioDevice)GetProcAddress(dll,"CloseRadioDevice");<br />
FNCSetAtten SetAtten=(FNCSetAtten)GetProcAddress(dll,"SetAtten");<br />
FNCSetPower SetPower=(FNCSetPower)GetProcAddress(dll,"SetPower");<br />
FNCSetAGC SetAGC=(FNCSetAGC)GetProcAddress(dll,"SetAGC");<br />
FNCCodecStart CodecStart=(FNCCodecStart)GetProcAddress(dll,"CodecStart");<br />
FNCCodecStop CodecStop=(FNCCodecStop)GetProcAddress(dll,"CodecStop");<br />
FNCCodecRead CodecRead=(FNCCodecRead)GetProcAddress(dll,"CodecRead");<br />
<br />
// open the first available radio<br />
int hRadio=OpenRadioDevice(0);<br />
if (!hRadio) {puts("No WR-G303 device could be opened !");FreeLibrary(dll); return 0;}<br />
<br />
// set Power, AGC and Attenuator<br />
if (SetPower(hRadio,TRUE)) puts("The device is turned ON"); else puts("The device failed to turn ON");<br />
if (SetAtten(hRadio,FALSE)) puts("The attenuator is OFF"); else puts("The attenuator failed to turn OFF");<br />
if (SetAGC(hRadio,3)) puts("The AGC is FAST"); else puts("The AGC failed to switch");<br />
<br />
// open the IF samples destination file<br />
FILE *f=fopen("IF2.pcm","wb");<br />
<br />
// start the IF stream from the codec<br />
CallbackContext Ctx;<br />
<br />
Ctx.hRadio=hRadio;<br />
Ctx.IFFile=f;<br />
Ctx.CodecRead=CodecRead;<br />
if (!CodecStart(hRadio,CodecCallback,&Ctx)) puts("Codec streaming couldn't be started!");<br />
else {<br />
puts("Codec streaming properly started!");<br />
while (!ftell(f) ) <br />
{<br />
}<br />
CodecStop(hRadio);<br />
fclose(f);<br />
}<br />
<br />
// close the device handle<br />
if (CloseRadioDevice(hRadio)) puts("The device is closed properly"); else puts("The device failed to close");<br />
<br />
// free the G3 API library<br />
FreeLibrary(dll);<br />
<br />
return 0;<br />
}<br />

  public void Go()//lovely method name!
        {
            //now we want some asynchronous reading here....
            socket.BeginReceive(cs.RcvBuffer , 0 , cs.RcvBuffer.Length , SocketFlags.None , new AsyncCallback(ReadCallback), cs);
        }

        protected void ReadCallback(IAsyncResult ar)
        {
            clientState cs = (clientState)ar.AsyncState;

            try
            {
                int recvMsgSize = cs.ClntSock.EndReceive(ar);

                if (recvMsgSize > 0)
                {
                    cs.TotalBytes += recvMsgSize;

                    Console.WriteLine("Thread {0} - ReadCallback(): total received {1} bytes",
                        ID,
                        cs.TotalBytes);
                    //next line is good if array only has one object in but fails,
                    //which you'd expect if it has more...
                    SocketTest.MyTestClass m = Decode(cs.RcvBuffer);
                    DoSomethingWithMyTestClass( m );

                    Go();//read from stream again...is this the best way?
                }
            }
            catch(SocketException se)
            {
                Console.WriteLine(se.ErrorCode + ":" + se.Message);
            }
        }
    

        public SocketTest.MyTestClass Decode(byte[] theByteArray)
        {
            Console.WriteLine("Decoding {0} bytes", theByteArray.Length);
            MemoryStream ms = new MemoryStream(theByteArray);
            BinaryFormatter bf1 = new BinaryFormatter();
            ms.Position = 0;

            return (SocketTest.MyTestClass)bf1.Deserialize(ms);
        }