Replace pthreads by std::thread #23

dstndstn · 2018-11-18T15:02:27Z

Reviving this ancient branch -- threads and mutexes and condition variables, oh my!

…gbuf

…ate_lock

…tory_lock

… sent in binary form

…pga_count is retrieved before first packet is received.

…eam not found

…stn-injection

… accesses it asynchronously

…he buffering earlier?)

RFI mask monitoring + data injection

Beam duplication

dstndstn and others added 30 commits January 31, 2018 18:14

use std::mutex, locks, and condition variables in assembled_chunk_rin…

1f5eeab

…gbuf

use std::mutex, locks, and condition variables in udp_packet_ringbuf

8c3840d

use std::mutex and condition_variable for intensity_network_stream st…

b03b4bf

…ate_lock

use std::mutex for intensity_network_stream event_lock and packet_his…

305a11d

…tory_lock

use std::mutex for intensity_network_ostream state and statistics locks

c7617b7

switch to std::thread for intensity_network_ostream network thread

52da5fd

FIXME fixed

d5ff573

add msgpack_binary_vector.hpp, defining a 'wire protocol' for vectors…

b9b168f

… sent in binary form

Merge branch 'stdthread' into dstn-stdthread

1a8db72

more pthreads->std::thread

dbfa325

Merge branch 'relcand_latency' into dstn-injection

f6899b0

make first_packet_received an atomic bool; raise error if get_first_f…

01f1f5c

…pga_count is retrieved before first packet is received.

add frame0_nano to get_statistics()

f94914d

intensity_network_stream : get_first_fpga_count: throw exception if b…

ff5cb5c

…eam not found

Merge branch 'dstn-injection' of github.com:CHIMEFRB/ch_frb_io into d…

0fe1b24

…stn-injection

set thread names

fbd63f9

quiet about frame0_ctime fetching

44fd842

change frame0_nano from uint64 to atomic<uint64>, now that RPC thread…

9c37095

… accesses it asynchronously

Merge branch 'dstn-injection' into dstn-maskmon-injection

5fbea08

initial shot at packet forking

11fb70e

revert beam numbers

0a4d29a

implement forking a single beam

eba9f83

allowing stopping all packet forking

7ddfd74

add pause and resume functions for packet forking

826a203

debugging: log number of packets per assembled chunk

00bbd34

also increment packets-received counter in fast_assembled_chunk path

5beb0f4

print packet forking list after updating

b3295de

copy socket init logic from primary packet socket

f18bef4

also set buffer size and timeout for sending forked beam data

55bad3a

collect some stats on forking socket send

1a02c90

dstndstn and others added 18 commits July 2, 2019 10:16

retrieve socket errors too

30bb916

chlog rather than cout

e9431e2

try SIOCOUTQ ioctl

71a8ade

oops, typo in start/end

738eb10

report how long we take to process data

46f0cc0

report time since last batch of sends

feafea1

report if fewer bytes sent than desired

91badfc

allow forking the first 2 or 3 beams

2b2d722

excessive logging of packet rates

268eaf0

log timestamps along with packet rates

9c6ca9a

log packet rates at each flush of the buffer

03dc486

retrieve the SNDBUF size

e88f2c3

set send buffer size to 1MB -- seems to improve packet losses (puts t…

15e9614

…he buffering earlier?)

packet forking: try to fix malformed packets

eadeb06

quiet down some excessive logging

f86621c

Merge pull request #26 from CHIMEFRB/dstn-maskmon-injection

6f69516

RFI mask monitoring + data injection

Merge pull request #27 from CHIMEFRB/dstn-maskmon-injection-dup

6b725c5

Beam duplication

Merge branch 'dstn-master' into dstn-stdthread

78255e1

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Replace pthreads by std::thread #23

Replace pthreads by std::thread #23

dstndstn commented Nov 18, 2018

Replace pthreads by std::thread #23

Are you sure you want to change the base?

Replace pthreads by std::thread #23

Conversation

dstndstn commented Nov 18, 2018