def _recv_tag_raw(sock):
 s = sock.recv((4 * 4))
 if (len(s) != 16):
  raise RuntimeError('Not enough bytes received, something is wrong. Make sure the mne_rt_server is running.')
 tag = Tag(*np.fromstring(s, '>i4'))
 n_received = 0
 rec_buff = [s]
 while (n_received < tag.size):
  n_buffer = min(4096, (tag.size - n_received))
  this_buffer = sock.recv(n_buffer)
  rec_buff.append(this_buffer)
  n_received += len(this_buffer)
 if (n_received != tag.size):
  raise RuntimeError('Not enough bytes received, something is wrong. Make sure the mne_rt_server is running.')
 buff = ''.join(rec_buff)
 return (tag, buff)

def _recv_tag_raw ( sock ) : s = sock . recv ( ( 4 * 4 ) ) if ( len ( s ) != 16 ) : raise RuntimeError ( 'Not enough bytes received, something is wrong. Make sure the mne_rt_server is running.' ) tag = Tag ( * np . fromstring ( s , '>i4' ) ) n_received = 0 rec_buff = [ s ] while ( n_received < tag . size ) : n_buffer = min ( 4096 , ( tag . size - n_received ) ) this_buffer = sock . recv ( n_buffer ) rec_buff . append ( this_buffer ) n_received += len ( this_buffer ) if ( n_received != tag . size ) : raise RuntimeError ( 'Not enough bytes received, something is wrong. Make sure the mne_rt_server is running.' ) buff = '' . join ( rec_buff ) return ( tag , buff )
read a tag and the associated data from a socket .