Home
last modified time | relevance | path

Searched refs:pclient (Results 1 – 25 of 145) sorted by relevance

123456

/dports/mail/dovecot/dovecot-2.3.17/src/lib-program-client/
H A Dprogram-client.c72 return pclient->connect(pclient); in program_client_connect()
82 if ((ret = pclient->close_output(pclient)) < 0) in program_client_close_output()
121 if (pclient->fd_out == pclient->fd_in) in program_client_do_disconnect()
156 pclient->disconnect(pclient, force); in program_client_disconnect()
382 struct program_client *pclient = efd->pclient; in program_client_extra_fd_input() local
550 efd->pclient = pclient; in program_client_set_extra_fd()
564 p_array_init(&pclient->envs, pclient->pool, 16); in program_client_set_env()
637 pclient->destroy(pclient); in program_client_destroy()
655 pclient->to = io_loop_move_timeout(&pclient->to); in program_client_switch_ioloop()
661 pclient->io = io_loop_move_io(&pclient->io); in program_client_switch_ioloop()
[all …]
H A Dprogram-client-local.c149 (pclient->fd_in < 0 && pclient->fd_out < 0)) in program_client_local_waitchild()
207 e_error(pclient->event, in program_client_local_connect()
260 pclient->set.home); in program_client_local_connect()
262 exec_child(plclient->bin_path, pclient->args, &pclient->envs, in program_client_local_connect()
314 pclient->fd_out = -1; in program_client_local_close_output()
318 e_error(pclient->event, in program_client_local_close_output()
344 e_info(pclient->event, in program_client_local_exited()
347 pclient->exit_status = in program_client_local_exited()
350 pclient->exit_status = in program_client_local_exited()
428 e_debug(pclient->event, in program_client_local_kill()
[all …]
H A Dprogram-client-remote.c279 io_remove(&pclient->io); in program_client_remote_connected()
314 e_error(pclient->event, in program_client_remote_connected()
362 pclient->fd_in = (prclient->noreply && pclient->output == NULL ? in program_client_unix_connect()
364 pclient->fd_out = fd; in program_client_unix_connect()
385 pclient->fd_in = pclient->fd_out = -1; in program_client_net_connect_timeout()
405 pclient->fd_in = pclient->fd_out = -1; in program_client_net_connected()
408 pclient->io = io_add(pclient->fd_out, IO_WRITE, in program_client_net_connected()
443 pclient->fd_in = (prclient->noreply && pclient->output == NULL ? in program_client_net_connect_real()
445 pclient->fd_out = fd; in program_client_net_connect_real()
575 int fd_out = pclient->fd_out, fd_in = pclient->fd_in; in program_client_remote_close_output()
[all …]
H A Dprogram-client-private.h15 struct program_client *pclient; member
53 int (*connect) (struct program_client * pclient);
54 int (*close_output) (struct program_client * pclient);
55 void (*switch_ioloop) (struct program_client * pclient);
56 void (*disconnect) (struct program_client * pclient, bool force);
57 void (*destroy) (struct program_client * pclient);
65 void program_client_set_label(struct program_client *pclient,
74 void program_client_init_streams(struct program_client *pclient);
76 void program_client_connected(struct program_client *pclient);
78 void program_client_fail(struct program_client *pclient,
[all …]
H A Dprogram-client.h68 void program_client_set_input(struct program_client *pclient,
70 void program_client_set_output(struct program_client *pclient,
73 void program_client_set_output_seekable(struct program_client *pclient,
76 program_client_get_output_seekable(struct program_client *pclient);
78 void program_client_switch_ioloop(struct program_client *pclient);
83 #define program_client_set_extra_fd(pclient, fd, callback, context) \ argument
84 program_client_set_extra_fd(pclient, fd - \
89 void program_client_set_env(struct program_client *pclient,
93 program_client_run(struct program_client *pclient);
94 void program_client_run_async(struct program_client *pclient,
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go32 pclient, _, server := newFake(t)
73 pclient, sclient, server := newFake(t)
184 pclient, sclient, _ := newFake(t)
206 pclient, sclient, _ := newFake(t)
252 pclient, sclient, srv := newFake(t)
289 pclient, sclient, _ := newFake(t)
323 pclient, sclient, _ := newFake(t)
368 pclient, sclient, _ := newFake(t)
398 pclient, sclient, _ := newFake(t)
432 pclient, sclient, srv := newFake(t)
[all …]
/dports/x11-wm/chamfer/chamferwm-d0916ee/src/
H A Dmain.cpp214 if(pdst->pclient){ in MoveContainer()
276 if(pcont->pclient) in ReleaseContainersRecursive()
518 if(!pclient || pclient->pcontainer == pclient->pcontainer->GetRoot()) in SetFullscreen()
527 if(!pclient || pclient->pcontainer == pclient->pcontainer->GetRoot()) in SetFocus()
535 if(!pclient || pclient->pcontainer == pclient->pcontainer->GetRoot()) in Enter()
542 if(!pclient){ in PropertyChange()
550 if(pclient->pcontainer == pclient->pcontainer->GetRoot()) in PropertyChange()
594 delete pclient; in DestroyClient()
620 if(premoved->pclient) in DestroyClient()
711 return pclient; in SetupClient()
[all …]
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsub/pstest/
H A Dfake_test.go37 pclient, _, server, cleanup := newFake(context.TODO(), t)
308 want := publish(t, pclient, top, []*pb.PubsubMessage{
363 _ = publish(t, pclient, top, []*pb.PubsubMessage{
414 publish(t, pclient, top, []*pb.PubsubMessage{
453 publish(t, pclient, top, []*pb.PubsubMessage{
490 _ = publish(t, pclient, top, []*pb.PubsubMessage{
563 pclient, sclient, _, cleanup := newFake(ctx, t)
594 publish(t, pclient, top, []*pb.PubsubMessage{
722 publish(t, pclient, top, []*pb.PubsubMessage{
791 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go38 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/cloud.google.com/go/google-cloud-go-0.72.0/pubsub/pstest/
H A Dfake_test.go37 pclient, _, server, cleanup := newFake(context.TODO(), t)
308 want := publish(t, pclient, top, []*pb.PubsubMessage{
363 _ = publish(t, pclient, top, []*pb.PubsubMessage{
414 publish(t, pclient, top, []*pb.PubsubMessage{
453 publish(t, pclient, top, []*pb.PubsubMessage{
490 _ = publish(t, pclient, top, []*pb.PubsubMessage{
563 pclient, sclient, _, cleanup := newFake(ctx, t)
594 publish(t, pclient, top, []*pb.PubsubMessage{
722 publish(t, pclient, top, []*pb.PubsubMessage{
791 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go37 pclient, _, server, cleanup := newFake(context.TODO(), t)
308 want := publish(t, pclient, top, []*pb.PubsubMessage{
363 _ = publish(t, pclient, top, []*pb.PubsubMessage{
414 publish(t, pclient, top, []*pb.PubsubMessage{
453 publish(t, pclient, top, []*pb.PubsubMessage{
490 _ = publish(t, pclient, top, []*pb.PubsubMessage{
563 pclient, sclient, _, cleanup := newFake(ctx, t)
594 publish(t, pclient, top, []*pb.PubsubMessage{
722 publish(t, pclient, top, []*pb.PubsubMessage{
791 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go38 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go38 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/gomplate/google-cloud-go-storage-v1.12.0/pubsub/pstest/
H A Dfake_test.go35 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/devel/gitlab-runner/google-cloud-go-storage-v1.12.0/pubsub/pstest/
H A Dfake_test.go35 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go38 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go37 pclient, _, server, cleanup := newFake(context.TODO(), t)
308 want := publish(t, pclient, top, []*pb.PubsubMessage{
363 _ = publish(t, pclient, top, []*pb.PubsubMessage{
414 publish(t, pclient, top, []*pb.PubsubMessage{
453 publish(t, pclient, top, []*pb.PubsubMessage{
490 _ = publish(t, pclient, top, []*pb.PubsubMessage{
563 pclient, sclient, _, cleanup := newFake(ctx, t)
594 publish(t, pclient, top, []*pb.PubsubMessage{
722 publish(t, pclient, top, []*pb.PubsubMessage{
791 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsub/pstest/
H A Dfake_test.go38 pclient, _, server, cleanup := newFake(context.TODO(), t)
306 want := publish(t, pclient, top, []*pb.PubsubMessage{
361 _ = publish(t, pclient, top, []*pb.PubsubMessage{
412 publish(t, pclient, top, []*pb.PubsubMessage{
451 publish(t, pclient, top, []*pb.PubsubMessage{
488 _ = publish(t, pclient, top, []*pb.PubsubMessage{
561 pclient, sclient, _, cleanup := newFake(ctx, t)
592 publish(t, pclient, top, []*pb.PubsubMessage{
720 publish(t, pclient, top, []*pb.PubsubMessage{
789 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go37 pclient, _, server, cleanup := newFake(context.TODO(), t)
308 want := publish(t, pclient, top, []*pb.PubsubMessage{
363 _ = publish(t, pclient, top, []*pb.PubsubMessage{
414 publish(t, pclient, top, []*pb.PubsubMessage{
453 publish(t, pclient, top, []*pb.PubsubMessage{
490 _ = publish(t, pclient, top, []*pb.PubsubMessage{
563 pclient, sclient, _, cleanup := newFake(ctx, t)
594 publish(t, pclient, top, []*pb.PubsubMessage{
722 publish(t, pclient, top, []*pb.PubsubMessage{
791 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
258 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
268 want := publish(t, pclient, top, []*pb.PubsubMessage{
299 want := publish(t, pclient, top, []*pb.PubsubMessage{
323 _ = publish(t, pclient, top, []*pb.PubsubMessage{
374 publish(t, pclient, top, []*pb.PubsubMessage{
413 publish(t, pclient, top, []*pb.PubsubMessage{
450 _ = publish(t, pclient, top, []*pb.PubsubMessage{
501 want := publish(t, pclient, top, []*pb.PubsubMessage{
523 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/net/storj/storj-1.45.3/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
258 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
268 want := publish(t, pclient, top, []*pb.PubsubMessage{
299 want := publish(t, pclient, top, []*pb.PubsubMessage{
323 _ = publish(t, pclient, top, []*pb.PubsubMessage{
374 publish(t, pclient, top, []*pb.PubsubMessage{
413 publish(t, pclient, top, []*pb.PubsubMessage{
450 _ = publish(t, pclient, top, []*pb.PubsubMessage{
501 want := publish(t, pclient, top, []*pb.PubsubMessage{
523 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/istio/google-cloud-go-logging-v1.0.0/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
239 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
249 want := publish(t, pclient, top, []*pb.PubsubMessage{
280 want := publish(t, pclient, top, []*pb.PubsubMessage{
304 _ = publish(t, pclient, top, []*pb.PubsubMessage{
355 publish(t, pclient, top, []*pb.PubsubMessage{
394 publish(t, pclient, top, []*pb.PubsubMessage{
431 _ = publish(t, pclient, top, []*pb.PubsubMessage{
482 want := publish(t, pclient, top, []*pb.PubsubMessage{
504 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
258 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
268 want := publish(t, pclient, top, []*pb.PubsubMessage{
299 want := publish(t, pclient, top, []*pb.PubsubMessage{
323 _ = publish(t, pclient, top, []*pb.PubsubMessage{
374 publish(t, pclient, top, []*pb.PubsubMessage{
413 publish(t, pclient, top, []*pb.PubsubMessage{
450 _ = publish(t, pclient, top, []*pb.PubsubMessage{
501 want := publish(t, pclient, top, []*pb.PubsubMessage{
523 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
258 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
268 want := publish(t, pclient, top, []*pb.PubsubMessage{
299 want := publish(t, pclient, top, []*pb.PubsubMessage{
323 _ = publish(t, pclient, top, []*pb.PubsubMessage{
374 publish(t, pclient, top, []*pb.PubsubMessage{
413 publish(t, pclient, top, []*pb.PubsubMessage{
450 _ = publish(t, pclient, top, []*pb.PubsubMessage{
501 want := publish(t, pclient, top, []*pb.PubsubMessage{
523 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/cloud.google.com/go/pubsub/pstest/
H A Dfake_test.go34 pclient, _, server, cleanup := newFake(context.TODO(), t)
239 pclient, sclient, _, cleanup := newFake(context.TODO(), t)
249 want := publish(t, pclient, top, []*pb.PubsubMessage{
280 want := publish(t, pclient, top, []*pb.PubsubMessage{
304 _ = publish(t, pclient, top, []*pb.PubsubMessage{
355 publish(t, pclient, top, []*pb.PubsubMessage{
394 publish(t, pclient, top, []*pb.PubsubMessage{
431 _ = publish(t, pclient, top, []*pb.PubsubMessage{
482 want := publish(t, pclient, top, []*pb.PubsubMessage{
504 pclient, sclient, _, cleanup := newFake(ctx, t)
[all …]

123456