/dports/www/mattermost-server/mattermost-server-6.0.2/app/ |
H A D | web_hub_test.go | 244 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 D | web_hub.go | 449 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 D | multiplexer.go | 60 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 D | multiplexer.go | 60 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | multiplexer.go | 68 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 D | ReadCGNS.cpp | 322 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 D | NCManagerConnectClient.as | 31 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 D | NCManagerConnectClient.as | 31 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 D | we_clients.cpp | 127 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 D | we_clients.h | 89 … 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 D | we_clients.cpp | 127 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 D | we_clients.h | 89 … 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 D | multi_client_executor.c | 55 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 D | benchmark_client.go | 161 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 D | main.go | 273 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 D | benchmark_client.go | 152 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 D | benchmark_client.go | 152 for connIndex := 0; connIndex < connCount; connIndex++ { 153 …conns[connIndex] = benchmark.NewClientConn(config.ServerTargets[connIndex%len(config.ServerTargets…
|