mirror of
https://github.com/saitohirga/WSJT-X.git
synced 2025-05-24 02:12:37 -04:00
Forgot to include this routine.
git-svn-id: svn+ssh://svn.code.sf.net/p/wsjt/wsjt/branches/map65@398 ab8295b8-cf94-4d9e-aec4-7959e3be5d79
This commit is contained in:
parent
7df821cd1b
commit
f4bf9ef27c
75
recvpkt.F90
Normal file
75
recvpkt.F90
Normal file
@ -0,0 +1,75 @@
|
|||||||
|
!---------------------------------------------------- recvpkt
|
||||||
|
subroutine recvpkt(iarg)
|
||||||
|
|
||||||
|
! Receive timf2 packets from Linrad, stuff data into id().
|
||||||
|
! This routine runs in a background thread and will never return.
|
||||||
|
|
||||||
|
#ifdef Win32
|
||||||
|
use dflib
|
||||||
|
#endif
|
||||||
|
|
||||||
|
parameter (NSZ=60*96000)
|
||||||
|
real*8 d8(NSZ)
|
||||||
|
integer*1 userx_no,iusb
|
||||||
|
integer*2 nblock,nblock0
|
||||||
|
logical first
|
||||||
|
real*8 center_freq,buf8
|
||||||
|
common/plrscom/center_freq,msec,fqso,iptr,nblock,userx_no,iusb,buf8(174)
|
||||||
|
! 8 4 4 4 2 1 1 1392
|
||||||
|
include 'datcom.f90'
|
||||||
|
include 'gcom2.f90'
|
||||||
|
equivalence (id,d8)
|
||||||
|
data nblock0/0/,first/.true./,kb/1/
|
||||||
|
save
|
||||||
|
|
||||||
|
! Open a socket to receive multicast data from Linrad
|
||||||
|
call setup_rsocket
|
||||||
|
nreset=-1
|
||||||
|
k=0
|
||||||
|
npkt=0
|
||||||
|
nsec0=-999
|
||||||
|
|
||||||
|
10 call recv_pkt(center_freq)
|
||||||
|
if((nblock-nblock0).ne.1 .and. .not.first) then
|
||||||
|
print*,'Lost packets?',nblock-nblock0,nblock,nblock0
|
||||||
|
endif
|
||||||
|
first=.false.
|
||||||
|
nblock0=nblock
|
||||||
|
|
||||||
|
if(monitoring.eq.1) then
|
||||||
|
|
||||||
|
nsec=msec/1000
|
||||||
|
if(mod(nsec,60).eq.1) nreset=1
|
||||||
|
if(mod(nsec,60).eq.0 .and. nreset.eq.1) then
|
||||||
|
! This is the start of a new minute, switch buffers
|
||||||
|
nreset=0
|
||||||
|
kb=3-kb
|
||||||
|
k=0
|
||||||
|
if(kb.eq.2) k=NSZ
|
||||||
|
endif
|
||||||
|
|
||||||
|
do i=1,174
|
||||||
|
k=k+1
|
||||||
|
d8(k)=buf8(i)
|
||||||
|
enddo
|
||||||
|
|
||||||
|
npkt=npkt+1
|
||||||
|
if(nsec.ne.nsec0) then
|
||||||
|
mutch=nsec/3600
|
||||||
|
mutcm=mod(nsec/60,60)
|
||||||
|
mutc=100*mutch + mutcm
|
||||||
|
ns=mod(nsec,60)
|
||||||
|
! write(*,1010) mutc,ns,0.001*msec,k
|
||||||
|
!1010 format('UTC:',i5.4,' ns:',i3,' t:',f10.3,' k:',i8)
|
||||||
|
nsec0=nsec
|
||||||
|
endif
|
||||||
|
|
||||||
|
if(mod(nsec,60).eq.59) then
|
||||||
|
kbuf=kb
|
||||||
|
nutc=mutc
|
||||||
|
ndecoding=1
|
||||||
|
endif
|
||||||
|
endif
|
||||||
|
go to 10
|
||||||
|
|
||||||
|
end subroutine recvpkt
|
Loading…
x
Reference in New Issue
Block a user