Home
last modified time | relevance | path

Searched refs:connIndex (Results 1 – 25 of 131) sorted by relevance

123456

/dports/www/mattermost-server/mattermost-server-6.0.2/app/
H A Dweb_hub_test.go244 connIndex.Add(wc1)
245 connIndex.Add(wc2)
246 connIndex.Add(wc3)
247 connIndex.Add(wc4)
315 connIndex.Add(wc1)
316 connIndex.Add(wc2)
317 connIndex.Add(wc3)
330 connIndex.Add(wc3)
392 connIndex.Add(wc1)
393 connIndex.Add(wc2)
[all …]
H A Dweb_hub.go449 connIndex.RemoveInactiveConnections()
454 oldConn = connIndex.RemoveInactiveByConnectionID(
464 connIndex.Add(webConn)
480 connIndex.Remove(webConn)
489 conns := connIndex.ForUser(webConn.UserId)
525 if !connIndex.Has(directMsg.conn) {
533 connIndex.Remove(directMsg.conn)
541 if !connIndex.Has(webConn) {
550 connIndex.Remove(webConn)
561 candidates := connIndex.All()
[all …]
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dmultiplexer.go60 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
61 p, ok := m.conns[connIndex]
69 m.conns[connIndex] = p
84 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
85 if _, ok := m.conns[connIndex]; !ok {
89 delete(m.conns, connIndex)
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/
H A Dmultiplexer.go60 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
61 p, ok := m.conns[connIndex]
69 m.conns[connIndex] = p
84 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
85 if _, ok := m.conns[connIndex]; !ok {
89 delete(m.conns, connIndex)
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/dns/nextdns/nextdns-1.32.2/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net/storj/storj-1.45.3/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/security/xray-core/Xray-core-1.5.0/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/net/traefik/traefik-2.6.1/vendor/github.com/lucas-clemente/quic-go/
H A Dmultiplexer.go68 connIndex := addr.Network() + " " + addr.String()
69 p, ok := m.conns[connIndex]
81 m.conns[connIndex] = p
100 connIndex := c.LocalAddr().Network() + " " + c.LocalAddr().String()
101 if _, ok := m.conns[connIndex]; !ok {
105 delete(m.conns, connIndex)
/dports/math/moab/fathomteam-moab-7bde9dfb84a8/src/io/
H A DReadCGNS.cpp322 int connIndex = 0; in load_file() local
324 elemsType = ElementType_t(elemNodes[connIndex]); in load_file()
373 connIndex = 0; in load_file()
375 elemsType = ElementType_t(elemNodes[connIndex]); in load_file()
383 elemsConn_EDGE[idx_edge + j] = elemNodes[connIndex + j + 1]; in load_file()
388 elemsConn_TRI[idx_tri + j] = elemNodes[connIndex + j + 1]; in load_file()
393 elemsConn_QUAD[idx_quad + j] = elemNodes[connIndex + j + 1]; in load_file()
398 elemsConn_TET[idx_tet + j] = elemNodes[connIndex + j + 1]; in load_file()
403 elemsConn_PYRA[idx_pyra + j] = elemNodes[connIndex + j + 1]; in load_file()
408 elemsConn_PRISM[idx_prism + j] = elemNodes[connIndex + j + 1]; in load_file()
[all …]
/dports/devel/flex-sdk35/flex-sdk3-3.5.0.12683_1/frameworks/projects/framework/src/mx/controls/videoClasses/
H A DNCManagerConnectClient.as31 public var connIndex:uint; variable in NCManagerConnectClient
34 …public function NCManagerConnectClient(nc:NetConnection, owner:NCManager = null, connIndex:uint = …
40 this.connIndex = connIndex;
/dports/devel/flex-sdk/flex-sdk-4.6.0.23201/frameworks/projects/mx/src/mx/controls/videoClasses/
H A DNCManagerConnectClient.as31 public var connIndex:uint; variable in NCManagerConnectClient
34 …public function NCManagerConnectClient(nc:NetConnection, owner:NCManager = null, connIndex:uint = …
40 this.connIndex = connIndex;
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/client/
H A Dwe_clients.cpp127 connIndex(connectionIndex) {} in WEClientRunner()
130 uint32_t connIndex; member
136 jbl->Listen(client, connIndex); in operator ()()
339 void WEClients::Listen ( boost::shared_ptr<MessageQueueClient> client, uint32_t connIndex) in Listen() argument
353 addDataToOutput(sbs, connIndex); in Listen()
542 void WEClients::StartClientListener(boost::shared_ptr<MessageQueueClient> cl, uint32_t connIndex) in StartClientListener() argument
544 boost::thread* thrd = new boost::thread(WEClientRunner(this, cl, connIndex)); in StartClientListener()
549 void WEClients::addDataToOutput(SBS sbs, uint32_t connIndex) in addDataToOutput() argument
571 atomicops::atomicInc(&mqe->unackedWork[connIndex % pmCount]); in addDataToOutput()
H A Dwe_clients.h89 … EXPORT void Listen(boost::shared_ptr<messageqcpp::MessageQueueClient> client, uint32_t connIndex);
147 …oid StartClientListener(boost::shared_ptr<messageqcpp::MessageQueueClient> cl, uint32_t connIndex);
152 void addDataToOutput(messageqcpp::SBS, uint32_t connIndex);
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/client/
H A Dwe_clients.cpp127 connIndex(connectionIndex) {} in WEClientRunner()
130 uint32_t connIndex; member
136 jbl->Listen(client, connIndex); in operator ()()
339 void WEClients::Listen ( boost::shared_ptr<MessageQueueClient> client, uint32_t connIndex) in Listen() argument
353 addDataToOutput(sbs, connIndex); in Listen()
542 void WEClients::StartClientListener(boost::shared_ptr<MessageQueueClient> cl, uint32_t connIndex) in StartClientListener() argument
544 boost::thread* thrd = new boost::thread(WEClientRunner(this, cl, connIndex)); in StartClientListener()
549 void WEClients::addDataToOutput(SBS sbs, uint32_t connIndex) in addDataToOutput() argument
571 atomicops::atomicInc(&mqe->unackedWork[connIndex % pmCount]); in addDataToOutput()
H A Dwe_clients.h89 … EXPORT void Listen(boost::shared_ptr<messageqcpp::MessageQueueClient> client, uint32_t connIndex);
147 …oid StartClientListener(boost::shared_ptr<messageqcpp::MessageQueueClient> cl, uint32_t connIndex);
152 void addDataToOutput(messageqcpp::SBS, uint32_t connIndex);
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/
H A Dmulti_client_executor.c55 for (int32 connIndex = 0; connIndex < MAX_CONNECTION_COUNT; connIndex++) in AllocateConnectionId() local
57 MultiConnection *connection = ClientConnectionArray[connIndex]; in AllocateConnectionId()
60 connectionId = connIndex; in AllocateConnectionId()
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/google.golang.org/grpc/benchmark/worker/
H A Dbenchmark_client.go161 for connIndex := 0; connIndex < connCount; connIndex++ {
162 …conns[connIndex] = benchmark.NewClientConn(config.ServerTargets[connIndex%len(config.ServerTargets…
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/google.golang.org/grpc/stress/client/
H A Dmain.go273 for connIndex := 0; connIndex < *numChannelsPerServer; connIndex++ {
280 …name := fmt.Sprintf("/stress_test/server_%d/channel_%d/stub_%d/qps", serverIndex+1, connIndex+1, c…
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/benchmark/worker/
H A Dbenchmark_client.go152 for connIndex := 0; connIndex < connCount; connIndex++ {
153 …conns[connIndex] = benchmark.NewClientConn(config.ServerTargets[connIndex%len(config.ServerTargets…
/dports/net/grpcox/grpcox-1.0.0/vendor/google.golang.org/grpc/benchmark/worker/
H A Dbenchmark_client.go152 for connIndex := 0; connIndex < connCount; connIndex++ {
153 …conns[connIndex] = benchmark.NewClientConn(config.ServerTargets[connIndex%len(config.ServerTargets…

123456