Home
last modified time | relevance | path

Searched refs:msgCtx (Results 1 – 25 of 427) sorted by relevance

12345678910>>...18

/dports/misc/concourse/concourse-6.7.2/vendor/gopkg.in/ldap.v2/
H A Dconn_test.go42 msgCtx, err := conn.sendMessage(packet)
46 defer conn.finishMessage(msgCtx)
48 packetResponse, ok := <-msgCtx.responses
76 msgCtx := testSendRequest(t, ptc, conn)
77 testReceiveResponse(t, ptc, msgCtx)
92 msgCtx := testSendRequest(t, ptc, conn)
93 testReceiveResponse(t, ptc, msgCtx)
119 msgCtx, err = conn.sendMessage(requestPacket)
133 return msgCtx
149 if _, ok := <-msgCtx.responses; !ok {
[all …]
H A Dconn.go61 case msgCtx.responses <- packet:
63 case <-msgCtx.done:
223 defer l.finishMessage(msgCtx)
225 l.Debug.Printf("%d: waiting for response", msgCtx.id)
227 packetResponse, ok := <-msgCtx.responses
305 close(msgCtx.done)
320 MessageID: msgCtx.id,
340 for messageID, msgCtx := range l.messageContexts {
347 close(msgCtx.responses)
413 close(msgCtx.responses)
[all …]
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/gopkg.in/ldap.v2/
H A Dconn_test.go42 msgCtx, err := conn.sendMessage(packet)
46 defer conn.finishMessage(msgCtx)
48 packetResponse, ok := <-msgCtx.responses
76 msgCtx := testSendRequest(t, ptc, conn)
77 testReceiveResponse(t, ptc, msgCtx)
92 msgCtx := testSendRequest(t, ptc, conn)
93 testReceiveResponse(t, ptc, msgCtx)
119 msgCtx, err = conn.sendMessage(requestPacket)
133 return msgCtx
149 if _, ok := <-msgCtx.responses; !ok {
[all …]
H A Dconn.go61 case msgCtx.responses <- packet:
63 case <-msgCtx.done:
223 defer l.finishMessage(msgCtx)
225 l.Debug.Printf("%d: waiting for response", msgCtx.id)
227 packetResponse, ok := <-msgCtx.responses
305 close(msgCtx.done)
320 MessageID: msgCtx.id,
340 for messageID, msgCtx := range l.messageContexts {
347 close(msgCtx.responses)
413 close(msgCtx.responses)
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/go-ldap/ldap/v3/
H A Dconn_test.go42 msgCtx, err := conn.sendMessage(packet)
46 defer conn.finishMessage(msgCtx)
48 packetResponse, ok := <-msgCtx.responses
76 msgCtx := testSendRequest(t, ptc, conn)
77 testReceiveResponse(t, ptc, msgCtx)
92 msgCtx := testSendRequest(t, ptc, conn)
93 testReceiveResponse(t, ptc, msgCtx)
119 msgCtx, err = conn.sendMessage(requestPacket)
133 return msgCtx
149 if _, ok := <-msgCtx.responses; !ok {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/go-ldap/ldap/
H A Dconn_test.go42 msgCtx, err := conn.sendMessage(packet)
46 defer conn.finishMessage(msgCtx)
48 packetResponse, ok := <-msgCtx.responses
76 msgCtx := testSendRequest(t, ptc, conn)
77 testReceiveResponse(t, ptc, msgCtx)
92 msgCtx := testSendRequest(t, ptc, conn)
93 testReceiveResponse(t, ptc, msgCtx)
119 msgCtx, err = conn.sendMessage(requestPacket)
133 return msgCtx
149 if _, ok := <-msgCtx.responses; !ok {
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/gopkg.in/ldap.v3/
H A Dconn_test.go42 msgCtx, err := conn.sendMessage(packet)
46 defer conn.finishMessage(msgCtx)
48 packetResponse, ok := <-msgCtx.responses
76 msgCtx := testSendRequest(t, ptc, conn)
77 testReceiveResponse(t, ptc, msgCtx)
92 msgCtx := testSendRequest(t, ptc, conn)
93 testReceiveResponse(t, ptc, msgCtx)
119 msgCtx, err = conn.sendMessage(requestPacket)
133 return msgCtx
149 if _, ok := <-msgCtx.responses; !ok {
[all …]
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
/dports/net/concourse-fly/concourse-6.7.1/vendor/gopkg.in/ldap.v2/
H A Dconn.go61 case msgCtx.responses <- packet:
63 case <-msgCtx.done:
223 defer l.finishMessage(msgCtx)
225 l.Debug.Printf("%d: waiting for response", msgCtx.id)
227 packetResponse, ok := <-msgCtx.responses
305 close(msgCtx.done)
320 MessageID: msgCtx.id,
340 for messageID, msgCtx := range l.messageContexts {
347 close(msgCtx.responses)
413 close(msgCtx.responses)
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/gopkg.in/ldap.v2/
H A Dconn.go61 case msgCtx.responses <- packet:
63 case <-msgCtx.done:
223 defer l.finishMessage(msgCtx)
225 l.Debug.Printf("%d: waiting for response", msgCtx.id)
227 packetResponse, ok := <-msgCtx.responses
305 close(msgCtx.done)
320 MessageID: msgCtx.id,
340 for messageID, msgCtx := range l.messageContexts {
347 close(msgCtx.responses)
413 close(msgCtx.responses)
[all …]
/dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/mattermost/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/go-ldap/ldap/v3/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
H A Drequest.go35 msgCtx, err := l.sendMessage(packet)
39 l.Debug.Printf("%d: returning", msgCtx.id)
40 return msgCtx, nil
43 func (l *Conn) readPacket(msgCtx *messageContext) (*ber.Packet, error) {
44 l.Debug.Printf("%d: waiting for response", msgCtx.id)
45 packetResponse, ok := <-msgCtx.responses
50 l.Debug.Printf("%d: got response %p", msgCtx.id, packet)
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-secrets-ad/vendor/github.com/go-ldap/ldap/v3/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
/dports/misc/concourse/vault-bdd38fca2cff/vendor/github.com/go-ldap/ldap/v3/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/github.com/go-ldap/ldap/v3/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
262 defer l.finishMessage(msgCtx)
264 l.Debug.Printf("%d: waiting for response", msgCtx.id)
266 packetResponse, ok := <-msgCtx.responses
355 close(msgCtx.done)
370 MessageID: msgCtx.id,
390 for messageID, msgCtx := range l.messageContexts {
397 close(msgCtx.responses)
463 close(msgCtx.responses)
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/net-im/matterircd/matterircd-0.25.0/vendor/github.com/mattermost/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
260 defer l.finishMessage(msgCtx)
262 l.Debug.Printf("%d: waiting for response", msgCtx.id)
264 packetResponse, ok := <-msgCtx.responses
353 close(msgCtx.done)
368 MessageID: msgCtx.id,
388 for messageID, msgCtx := range l.messageContexts {
395 close(msgCtx.responses)
461 close(msgCtx.responses)
[all …]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/mattermost/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
260 defer l.finishMessage(msgCtx)
262 l.Debug.Printf("%d: waiting for response", msgCtx.id)
264 packetResponse, ok := <-msgCtx.responses
353 close(msgCtx.done)
368 MessageID: msgCtx.id,
388 for messageID, msgCtx := range l.messageContexts {
395 close(msgCtx.responses)
461 close(msgCtx.responses)
[all …]
/dports/sysutils/gomplate/vault-sdk-v0.1.13/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/hashicorp/vault/vault-api-v1.0.4/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/devel/gitlab-runner/vault-sdk-v0.1.13/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/sysutils/istio/vault-sdk-v0.1.12/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/hashicorp/vault/vendor/github.com/go-ldap/ldap/
H A Dconn.go65 case msgCtx.responses <- packet:
67 case <-msgCtx.done:
258 defer l.finishMessage(msgCtx)
260 l.Debug.Printf("%d: waiting for response", msgCtx.id)
262 packetResponse, ok := <-msgCtx.responses
351 close(msgCtx.done)
366 MessageID: msgCtx.id,
386 for messageID, msgCtx := range l.messageContexts {
393 close(msgCtx.responses)
459 close(msgCtx.responses)
[all …]

12345678910>>...18