/dports/mail/dovecot/dovecot-2.3.17/src/lib-program-client/ |
H A D | program-client.c | 72 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 D | program-client-local.c | 149 (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 D | program-client-remote.c | 279 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 D | program-client-private.h | 15 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 D | program-client.h | 68 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 D | fake_test.go | 32 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 D | main.cpp | 214 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 D | fake_test.go | 37 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 D | fake_test.go | 38 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 D | fake_test.go | 37 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 D | fake_test.go | 37 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 D | fake_test.go | 38 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 D | fake_test.go | 38 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 D | fake_test.go | 35 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 D | fake_test.go | 35 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 D | fake_test.go | 38 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 D | fake_test.go | 37 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 D | fake_test.go | 38 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 D | fake_test.go | 37 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 D | fake_test.go | 34 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 D | fake_test.go | 34 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 D | fake_test.go | 34 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 D | fake_test.go | 34 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 D | fake_test.go | 34 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 D | fake_test.go | 34 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 …]
|