/dports/security/putty-nogtk/putty-0.76/ |
H A D | sshserver.c | 161 if (!srv->frozen && srv->bpp) in server_receive() 302 srv->ic_out_raw.ctx = srv; in ssh_server_start() 305 srv->conf, srv->logctx, srv->ssc->bare_connection, in ssh_server_start() 350 srv->bpp->ssh = &srv->ssh; in server_connect_bpp() 351 srv->bpp->in_raw = &srv->in_raw; in server_connect_bpp() 352 srv->bpp->out_raw = &srv->out_raw; in server_connect_bpp() 354 srv->bpp->pls = &srv->pls; in server_connect_bpp() 355 srv->bpp->logctx = srv->logctx; in server_connect_bpp() 518 srv->bpp = ssh2_bpp_new(srv->logctx, &srv->stats, true); in server_got_ssh_version() 549 srv->base_layer, srv->hostkeys, srv->nhostkeys); in server_got_ssh_version() [all …]
|
/dports/security/putty/putty-0.76/ |
H A D | sshserver.c | 161 if (!srv->frozen && srv->bpp) in server_receive() 302 srv->ic_out_raw.ctx = srv; in ssh_server_start() 305 srv->conf, srv->logctx, srv->ssc->bare_connection, in ssh_server_start() 350 srv->bpp->ssh = &srv->ssh; in server_connect_bpp() 351 srv->bpp->in_raw = &srv->in_raw; in server_connect_bpp() 352 srv->bpp->out_raw = &srv->out_raw; in server_connect_bpp() 354 srv->bpp->pls = &srv->pls; in server_connect_bpp() 355 srv->bpp->logctx = srv->logctx; in server_connect_bpp() 518 srv->bpp = ssh2_bpp_new(srv->logctx, &srv->stats, true); in server_got_ssh_version() 549 srv->base_layer, srv->hostkeys, srv->nhostkeys); in server_got_ssh_version() [all …]
|
/dports/www/minio-client/etcd-3.5.0/tests/functional/agent/ |
H A D | handler.go | 108 srv.lg.Info( 121 srv.etcdCmd.Stdout = srv.etcdLogFile 122 srv.etcdCmd.Stderr = srv.etcdLogFile 137 srv.lg.Info( 143 srv.lg.Info( 169 srv.lg.Info( 196 srv.lg.Info( 574 srv.lg.Info( 595 err := srv.Member.SaveSnapshot(srv.lg) 607 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/functional/agent/ |
H A D | handler.go | 108 srv.lg.Info( 117 srv.etcdCmd.Stdout = srv.etcdLogFile 118 srv.etcdCmd.Stderr = srv.etcdLogFile 133 srv.lg.Info( 139 srv.lg.Info( 165 srv.lg.Info( 192 srv.lg.Info( 570 srv.lg.Info( 591 err := srv.Member.SaveSnapshot(srv.lg) 603 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/functional/agent/ |
H A D | handler.go | 108 srv.lg.Info( 117 srv.etcdCmd.Stdout = srv.etcdLogFile 118 srv.etcdCmd.Stderr = srv.etcdLogFile 133 srv.lg.Info( 139 srv.lg.Info( 165 srv.lg.Info( 192 srv.lg.Info( 570 srv.lg.Info( 591 err := srv.Member.SaveSnapshot(srv.lg) 603 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/devel/etcd34/etcd-3.4.18/functional/agent/ |
H A D | handler.go | 108 srv.lg.Info( 117 srv.etcdCmd.Stdout = srv.etcdLogFile 118 srv.etcdCmd.Stderr = srv.etcdLogFile 133 srv.lg.Info( 139 srv.lg.Info( 165 srv.lg.Info( 192 srv.lg.Info( 570 srv.lg.Info( 591 err := srv.Member.SaveSnapshot(srv.lg) 603 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/functional/agent/ |
H A D | handler.go | 108 srv.lg.Info( 117 srv.etcdCmd.Stdout = srv.etcdLogFile 118 srv.etcdCmd.Stderr = srv.etcdLogFile 133 srv.lg.Info( 139 srv.lg.Info( 165 srv.lg.Info( 192 srv.lg.Info( 570 srv.lg.Info( 591 err := srv.Member.SaveSnapshot(srv.lg) 603 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/functional/agent/ |
H A D | handler.go | 227 srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath) 249 srv.etcdCmd.Stdout = srv.etcdLogFile 250 srv.etcdCmd.Stderr = srv.etcdLogFile 283 srv.lg.Info( 318 srv.lg.Info( 336 srv.lg.Info( 362 srv.lg.Info( 492 srv.lg.Info( 516 err := srv.Member.SaveSnapshot(srv.lg) 528 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/functional/agent/ |
H A D | handler.go | 227 srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath) 249 srv.etcdCmd.Stdout = srv.etcdLogFile 250 srv.etcdCmd.Stderr = srv.etcdLogFile 283 srv.lg.Info( 318 srv.lg.Info( 336 srv.lg.Info( 362 srv.lg.Info( 492 srv.lg.Info( 516 err := srv.Member.SaveSnapshot(srv.lg) 528 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/devel/etcd32/etcd-3.2.32/functional/agent/ |
H A D | handler.go | 227 srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath) 249 srv.etcdCmd.Stdout = srv.etcdLogFile 250 srv.etcdCmd.Stderr = srv.etcdLogFile 283 srv.lg.Info( 318 srv.lg.Info( 336 srv.lg.Info( 362 srv.lg.Info( 492 srv.lg.Info( 516 err := srv.Member.SaveSnapshot(srv.lg) 528 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/functional/agent/ |
H A D | handler.go | 227 srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath) 249 srv.etcdCmd.Stdout = srv.etcdLogFile 250 srv.etcdCmd.Stderr = srv.etcdLogFile 283 srv.lg.Info( 318 srv.lg.Info( 336 srv.lg.Info( 362 srv.lg.Info( 492 srv.lg.Info( 516 err := srv.Member.SaveSnapshot(srv.lg) 528 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/devel/etcd33/etcd-3.3.23/functional/agent/ |
H A D | handler.go | 227 srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath) 249 srv.etcdCmd.Stdout = srv.etcdLogFile 250 srv.etcdCmd.Stderr = srv.etcdLogFile 283 srv.lg.Info( 318 srv.lg.Info( 336 srv.lg.Info( 362 srv.lg.Info( 492 srv.lg.Info( 516 err := srv.Member.SaveSnapshot(srv.lg) 528 err = srv.Member.RestoreSnapshot(srv.lg) [all …]
|
/dports/devel/libvirt/libvirt-7.10.0/src/rpc/ |
H A D | virnetserver.c | 267 srv->nclients, srv->nclients_max, in virNetServerCheckLimits() 277 if (srv->nclients >= srv->nclients_max || in virNetServerCheckLimits() 279 srv->nclients_unauth >= srv->nclients_unauth_max)) { in virNetServerCheckLimits() 283 } else if (srv->nclients < srv->nclients_max && in virNetServerCheckLimits() 300 VIR_EXPAND_N(srv->clients, srv->nclients, 1); in virNetServerAddClient() 301 srv->clients[srv->nclients-1] = virObjectRef(client); in virNetServerAddClient() 630 VIR_EXPAND_N(srv->services, srv->nservices, 1); in virNetServerAddService() 631 srv->services[srv->nservices-1] = virObjectRef(svc); in virNetServerAddService() 791 VIR_EXPAND_N(srv->programs, srv->nprograms, 1); in virNetServerAddProgram() 792 srv->programs[srv->nprograms-1] = virObjectRef(prog); in virNetServerAddProgram() [all …]
|
/dports/games/wmqstat/wmqstat-0.0.4/appcore/ |
H A D | srv_proc.c | 66 struct server *srv; in add_server() local 71 srv->players = NULL; in add_server() 117 obtain_stats(srv); in add_server() 119 return (srv); in add_server() 131 free(srv->players); in kill_server() 132 free(srv); in kill_server() 152 *srv->map = '\0'; in obtain_stats() 156 srv->map); in obtain_stats() 158 if (!srv->map) { in obtain_stats() 189 (*srv->query)(p, &srv->players[i]); in obtain_stats() [all …]
|
/dports/www/gitea/gitea-1.16.5/vendor/github.com/gliderlabs/ssh/ |
H A D | server.go | 79 srv.mu.Lock() 87 srv.HostSigners = append(srv.HostSigners, signer) 93 srv.mu.Lock() 117 srv.mu.RLock() 129 …if srv.PasswordHandler == nil && srv.PublicKeyHandler == nil && srv.KeyboardInteractiveHandler == … 168 srv.mu.Lock() 180 srv.mu.Lock() 198 srv.mu.Lock() 345 srv.mu.Lock() 362 srv.HostSigners = append(srv.HostSigners, key) [all …]
|
/dports/mail/mailfromd/mailfromd-8.10/gacopyz/ |
H A D | server.c | 101 if (srv->ndefs == srv->maxdefs) { in add_def() 109 def = srv->def + srv->ndefs++; in add_def() 129 sizeof(srv->def[0]) *(srv->ndefs - (def - srv->def))); in del_def() 137 GACOPYZ_ALLOC(srv, p = realloc(srv->buf, size)); in srv_ensure_space() 270 srv->def[j++] = srv->def[i]; in gacopyz_srv_clear_macros_pred() 377 gacopyz_srv_t srv = calloc(1, sizeof(*srv)); in gacopyz_srv_create() local 1144 &srv->buf, &srv->bufsize)) { in gacopyz_srv_negotiate() 1313 &srv->buf, &srv->bufsize)) { in gacopyz_srv_send_command() 1326 srv->resp_ptr = srv->buf; in gacopyz_srv_send_command() 1376 srv->resp_ptr = srv->buf; in gacopyz_srv_send_command() [all …]
|
/dports/irc/srain/srain-1.1.0/src/core/ |
H A D | server.c | 41 SrnServer *srv; in srn_server_new() local 49 srv->cfg = cfg; in srn_server_new() 58 srv->cap->srv = srv; in srn_server_new() 71 srv->_user = srn_server_add_and_get_user(srv, ""); in srn_server_new() 72 srv->user = srn_server_add_and_get_user(srv, srv->cfg->user->nick); in srn_server_new() 81 sirc_set_ctx(srv->irc, srv); in srn_server_new() 83 return srv; in srn_server_new() 108 g_free(srv); in srn_server_free() 256 if (!srv->chat && g_strcmp0(name, srv->name) == 0) { in srn_server_add_chat() 264 srv->chat_list = g_list_append(srv->chat_list, chat); in srn_server_add_chat() [all …]
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | clonesrv6.go | 61 srv.port = 5556 88 srv.publisher.Bind(fmt.Sprint("tcp://*:", srv.port+1)) 89 srv.collector.Bind(fmt.Sprint("tcp://*:", srv.port+2)) 102 srv.bstar.NewActive(func() error { return new_active(srv) }) 106 srv.bstar.Reactor.AddSocket(srv.collector, zmq.POLLIN, 167 srv.pending = append(srv.pending[:i], srv.pending[i+1:]...) 199 srv.pending = append(srv.pending, kvmsg) 261 srv.bstar.Reactor.RemoveSocket(srv.subscriber) 271 srv.pending = srv.pending[0:0] 283 srv.bstar.Reactor.AddSocket(srv.subscriber, zmq.POLLIN, [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | clonesrv6.go | 61 srv.port = 5556 88 srv.publisher.Bind(fmt.Sprint("tcp://*:", srv.port+1)) 89 srv.collector.Bind(fmt.Sprint("tcp://*:", srv.port+2)) 102 srv.bstar.NewActive(func() error { return new_active(srv) }) 106 srv.bstar.Reactor.AddSocket(srv.collector, zmq.POLLIN, 167 srv.pending = append(srv.pending[:i], srv.pending[i+1:]...) 199 srv.pending = append(srv.pending, kvmsg) 261 srv.bstar.Reactor.RemoveSocket(srv.subscriber) 271 srv.pending = srv.pending[0:0] 283 srv.bstar.Reactor.AddSocket(srv.subscriber, zmq.POLLIN, [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | clonesrv6.go | 61 srv.port = 5556 88 srv.publisher.Bind(fmt.Sprint("tcp://*:", srv.port+1)) 89 srv.collector.Bind(fmt.Sprint("tcp://*:", srv.port+2)) 102 srv.bstar.NewActive(func() error { return new_active(srv) }) 106 srv.bstar.Reactor.AddSocket(srv.collector, zmq.POLLIN, 167 srv.pending = append(srv.pending[:i], srv.pending[i+1:]...) 199 srv.pending = append(srv.pending, kvmsg) 261 srv.bstar.Reactor.RemoveSocket(srv.subscriber) 271 srv.pending = srv.pending[0:0] 283 srv.bstar.Reactor.AddSocket(srv.subscriber, zmq.POLLIN, [all …]
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/ |
H A D | clonesrv6.go | 61 srv.port = 5556 88 srv.publisher.Bind(fmt.Sprint("tcp://*:", srv.port+1)) 89 srv.collector.Bind(fmt.Sprint("tcp://*:", srv.port+2)) 102 srv.bstar.NewActive(func() error { return new_active(srv) }) 106 srv.bstar.Reactor.AddSocket(srv.collector, zmq.POLLIN, 167 srv.pending = append(srv.pending[:i], srv.pending[i+1:]...) 199 srv.pending = append(srv.pending, kvmsg) 261 srv.bstar.Reactor.RemoveSocket(srv.subscriber) 271 srv.pending = srv.pending[0:0] 283 srv.bstar.Reactor.AddSocket(srv.subscriber, zmq.POLLIN, [all …]
|
/dports/finance/cointop/cointop-1.5.4/vendor/github.com/gliderlabs/ssh/ |
H A D | server.go | 69 srv.mu.Lock() 77 srv.HostSigners = append(srv.HostSigners, signer) 83 srv.mu.Lock() 101 srv.mu.RLock() 152 srv.mu.Lock() 164 srv.mu.Lock() 182 srv.mu.Lock() 327 srv.mu.Lock() 344 srv.HostSigners = append(srv.HostSigners, key) 360 srv.mu.Lock() [all …]
|
/dports/mail/mailutils/mailutils-3.13/libmailutils/server/ |
H A D | ipsrv.c | 86 srv = calloc (1, sizeof *srv); in mu_ip_server_create() 116 srv->f_free (srv->data); in mu_ip_server_destroy() 139 if (!srv || srv->type != MU_IP_TCP) in mu_tcp_server_set_backlog() 148 if (!srv || srv->type != MU_IP_UDP) in mu_udp_server_get_bufsize() 157 if (!srv || srv->type != MU_IP_UDP) in mu_udp_server_set_bufsize() 253 if (!srv || srv->fd != -1) in mu_ip_server_open() 340 if (!srv || srv->fd != -1) in mu_ip_server_shutdown() 366 if (!srv || srv->fd == -1 || srv->type == MU_IP_UDP) in mu_ip_tcp_accept() 376 if (srv->f_intr && srv->f_intr (srv->data, call_data)) in mu_ip_tcp_accept() 445 if (srv->f_intr && srv->f_intr (srv->data, call_data)) in mu_ip_udp_accept() [all …]
|
/dports/net-mgmt/collectd5/collectd-5.12.0/src/libcollectdclient/ |
H A D | network.c | 94 srv->fd = -1; in server_close_socket() 95 free(srv->sa); in server_close_socket() 117 free(srv); in int_server_destroy() 144 srv->fd = in server_open_socket() 159 setsockopt(srv->fd, IPPROTO_IP, optname, &srv->ttl, sizeof(srv->ttl)); in server_open_socket() 297 srv = calloc(1, sizeof(*srv)); in lcc_server_create() 309 free(srv); in lcc_server_create() 316 free(srv); in lcc_server_create() 324 free(srv); in lcc_server_create() 339 return srv; in lcc_server_create() [all …]
|
/dports/www/lighttpd/lighttpd-1.4.63/src/ |
H A D | server.c | 275 server *srv = calloc(1, sizeof(*srv)); in server_init() local 786 srv->srv_sockets.ptr[i]->srv = srv; /* update ptr */ in server_sockets_restore() 788 srv->srv_sockets_inherited.ptr[i]->srv = srv; /* update ptr */ in server_sockets_restore() 1052 if (srv->cur_fds < srv->max_fds_lowat && 0 != srv->lim_conns) in server_overload_check() 1058 if (srv->cur_fds > srv->max_fds_hiwat || 0 == srv->lim_conns) in server_load_check() 1718 srv->max_fds = (int)srv->srvconf.max_fds; in server_main_setup() 1721 srv->ev = fdevent_init(srv->srvconf.event_handler, &srv->max_fds, &srv->cur_fds, srv->errh); in server_main_setup() 1735 srv->srvconf.max_conns, srv->max_fds); in server_main_setup() 1736 srv->lim_conns = srv->srvconf.max_conns = srv->max_fds/2; in server_main_setup() 1739 srv->lim_conns = srv->srvconf.max_conns; in server_main_setup() [all …]
|