MCPcopy Create free account
hub / github.com/PHZ76/RtspServer / UpdateChannel

Method UpdateChannel

src/net/SelectTaskScheduler.cpp:31–57  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

29}
30
31void SelectTaskScheduler::UpdateChannel(ChannelPtr channel)
32{
33 std::lock_guard<std::mutex> lock(mutex_);
34
35 SOCKET socket = channel->GetSocket();
36
37 if(channels_.find(socket) != channels_.end()) {
38 if(channel->IsNoneEvent()) {
39 is_fd_read_reset_ = true;
40 is_fd_write_reset_ = true;
41 is_fd_exp_reset_ = true;
42 channels_.erase(socket);
43 }
44 else {
45 //is_fd_read_reset_ = true;
46 is_fd_write_reset_ = true;
47 }
48 }
49 else {
50 if(!channel->IsNoneEvent()) {
51 channels_.emplace(socket, channel);
52 is_fd_read_reset_ = true;
53 is_fd_write_reset_ = true;
54 is_fd_exp_reset_ = true;
55 }
56 }
57}
58
59void SelectTaskScheduler::RemoveChannel(ChannelPtr& channel)
60{

Callers 1

SelectTaskSchedulerMethod · 0.95

Calls 2

IsNoneEventMethod · 0.80
GetSocketMethod · 0.45

Tested by

no test coverage detected