#include <online-feat-input.h>

Inheritance diagram for OnlineUdpInput:

Collaboration diagram for OnlineUdpInput:

Public Member Functions
	OnlineUdpInput (int32 port, int32 feature_dim)

virtual bool	Compute (Matrix< BaseFloat > *output)

virtual int32	Dim () const

const sockaddr_in &	client_addr () const

const int32	descriptor () const

Public Member Functions inherited from OnlineFeatInputItf
virtual	~OnlineFeatInputItf ()

Private Attributes
int32	feature_dim_

int32	sock_desc_

sockaddr_in	server_addr_

sockaddr_in	client_addr_

Detailed Description

Definition at line 160 of file online-feat-input.h.

Constructor & Destructor Documentation

◆ OnlineUdpInput()

OnlineUdpInput	(	int32	port,
		int32	feature_dim
	)

Definition at line 152 of file online-feat-input.cc.

References KALDI_ERR, OnlineUdpInput::server_addr_, and OnlineUdpInput::sock_desc_.

                                                            :
     feature_dim_(feature_dim) {
   server_addr_.sin_family = AF_INET; // IPv4
   server_addr_.sin_addr.s_addr = INADDR_ANY; // listen on all interfaces
   server_addr_.sin_port = htons(port);
   sock_desc_ = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
   if (sock_desc_ == -1)
     KALDI_ERR << "socket() call failed!";
   int32 rcvbuf_size = 30000;
   if (setsockopt(sock_desc_, SOL_SOCKET, SO_RCVBUF,
                  &rcvbuf_size, sizeof(rcvbuf_size)) == -1)
       KALDI_ERR << "setsockopt() failed to set receive buffer size!";
   if (bind(sock_desc_,
            reinterpret_cast<sockaddr*>(&server_addr_),
            sizeof(server_addr_)) == -1)
     KALDI_ERR << "bind() call failed!";
 }

Member Function Documentation

◆ client_addr()

const sockaddr_in& client_addr ( ) const

inline

Definition at line 168 of file online-feat-input.h.

Referenced by main().

168 { return client_addr_; }

kaldi::OnlineUdpInput::client_addr_

sockaddr_in client_addr_

Definition: online-feat-input.h:177

◆ Compute()

bool Compute ( Matrix< BaseFloat > * output )

virtual

Implements OnlineFeatInputItf.

Definition at line 171 of file online-feat-input.cc.

References OnlineUdpInput::client_addr_, KALDI_WARN, Matrix< Real >::Read(), Matrix< Real >::Resize(), and OnlineUdpInput::sock_desc_.

                                                       {
   char buf[65535];
   socklen_t caddr_len = sizeof(client_addr_);
   ssize_t nrecv = recvfrom(sock_desc_, buf, sizeof(buf), 0,
                            reinterpret_cast<sockaddr*>(&client_addr_),
                            &caddr_len);
   if (nrecv == -1) {
     KALDI_WARN << "recvfrom() call error!";
     output->Resize(0, 0);
     return false;
   }
   std::stringstream ss(std::stringstream::in | std::stringstream::out);
   ss.write(buf, nrecv);
   output->Read(ss, true);
   return true;
 }