| /dports/databases/pecl-mongodb/mongodb-1.9.1/src/libmongoc/src/libmongoc/src/mongoc/ |
| H A D | mongoc-async-cmd.c | 126 acmd->cb (acmd, result, &acmd->reply, duration_usec); in mongoc_async_cmd_run()
129 acmd->cb (acmd, result, NULL, duration_usec); in mongoc_async_cmd_run()
146 acmd->rpc.query.collection = acmd->ns; in _mongoc_async_cmd_init_send()
153 _mongoc_rpc_gather (&acmd->rpc, &acmd->array); in _mongoc_async_cmd_init_send()
155 acmd->niovec = acmd->array.len; in _mongoc_async_cmd_init_send()
227 DL_DELETE (acmd->async->cmds, acmd); in mongoc_async_cmd_destroy()
246 acmd->stream = acmd->initiator (acmd); in _mongoc_async_cmd_phase_initiate()
266 retval = acmd->setup (acmd->stream, in _mongoc_async_cmd_phase_setup()
365 &acmd->buffer, acmd->stream, acmd->bytes_to_read, 0); in _mongoc_async_cmd_phase_recv_len()
416 &acmd->buffer, acmd->stream, acmd->bytes_to_read, 0); in _mongoc_async_cmd_phase_recv_rpc()
[all …]
|
| H A D | mongoc-async.c | 42 mongoc_async_cmd_t *acmd, *tmp; in mongoc_async_destroy() local
46 mongoc_async_cmd_destroy (acmd); in mongoc_async_destroy()
55 mongoc_async_cmd_t *acmd, *tmp; in mongoc_async_run() local
69 DL_FOREACH (async->cmds, acmd) in mongoc_async_run()
71 acmd->connect_started = now; in mongoc_async_run()
92 if (now >= acmd->initiate_delay_ms * 1000 + acmd->connect_started) { in mongoc_async_run()
103 expire_at, acmd->connect_started + acmd->initiate_delay_ms); in mongoc_async_run()
107 if (acmd->stream) { in mongoc_async_run()
113 expire_at, acmd->connect_started + acmd->timeout_msec * 1000); in mongoc_async_run()
177 now > acmd->connect_started + acmd->timeout_msec * 1000) { in mongoc_async_run()
[all …]
|
| H A D | mongoc-topology-scanner.c | 53 _async_success (mongoc_async_cmd_t *acmd,
63 _async_handler (mongoc_async_cmd_t *acmd,
581 void *data = acmd->data; in _async_success()
620 &acmd->error); in _async_success()
628 void *data = acmd->data; in _async_error_or_timeout()
633 bson_error_t *error = &acmd->error; in _async_error_or_timeout()
699 BSON_ASSERT (acmd->data); in _async_handler()
703 _async_connected (acmd); in _async_handler()
756 BSON_ASSERT (acmd->dns_result); in _mongoc_topology_scanner_tcp_initiate()
1293 iter != acmd) { in _cancel_commands_excluding()
[all …]
|
| /dports/devel/mongo-c-driver/mongo-c-driver-1.8.1/src/mongoc/ |
| H A D | mongoc-async-cmd.c | 109 acmd->cb (result, &acmd->reply, rtt_msec, acmd->data, &acmd->error); in mongoc_async_cmd_run()
112 acmd->cb (result, NULL, rtt_msec, acmd->data, &acmd->error); in mongoc_async_cmd_run()
129 acmd->rpc.query.collection = acmd->ns; in _mongoc_async_cmd_init_send()
136 _mongoc_rpc_gather (&acmd->rpc, &acmd->array); in _mongoc_async_cmd_init_send()
138 acmd->niovec = acmd->array.len; in _mongoc_async_cmd_init_send()
201 DL_DELETE (acmd->async->cmds, acmd); in mongoc_async_cmd_destroy()
222 retval = acmd->setup (acmd->stream, in _mongoc_async_cmd_phase_setup()
248 bytes = mongoc_stream_writev (acmd->stream, acmd->iovec, acmd->niovec, 0); in _mongoc_async_cmd_phase_send()
283 &acmd->buffer, acmd->stream, acmd->bytes_to_read, 0); in _mongoc_async_cmd_phase_recv_len()
329 &acmd->buffer, acmd->stream, acmd->bytes_to_read, 0); in _mongoc_async_cmd_phase_recv_rpc()
[all …]
|
| H A D | mongoc-async.c | 40 mongoc_async_cmd_t *acmd, *tmp; in mongoc_async_destroy() local
44 mongoc_async_cmd_destroy (acmd); in mongoc_async_destroy()
53 mongoc_async_cmd_t *acmd, *tmp; in mongoc_async_run() local
66 DL_FOREACH (async->cmds, acmd) in mongoc_async_run()
68 acmd->connect_started = now; in mongoc_async_run()
82 DL_FOREACH (async->cmds, acmd) in mongoc_async_run()
84 poller[i].stream = acmd->stream; in mongoc_async_run()
89 expire_at, acmd->connect_started + acmd->timeout_msec * 1000); in mongoc_async_run()
137 if (now > acmd->connect_started + acmd->timeout_msec * 1000) { in mongoc_async_run()
148 acmd->data, in mongoc_async_run()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/ |
| H A D | admin_command.go | 323 acmd.dataBuffer[acmd.dataOffset+2] = command
324 acmd.dataBuffer[acmd.dataOffset+3] = byte(fieldCount)
345 acmd.dataBuffer[acmd.dataOffset] = id
473 id := acmd.dataBuffer[acmd.dataOffset]
478 userRoles.User = string(acmd.dataBuffer[acmd.dataOffset : acmd.dataOffset+len])
508 role := string(acmd.dataBuffer[acmd.dataOffset : acmd.dataOffset+len])
610 id := acmd.dataBuffer[acmd.dataOffset]
615 role.Name = string(acmd.dataBuffer[acmd.dataOffset : acmd.dataOffset+len])
651 priv.Namespace = string(acmd.dataBuffer[acmd.dataOffset : acmd.dataOffset+len])
656 priv.SetName = string(acmd.dataBuffer[acmd.dataOffset : acmd.dataOffset+len])
[all …]
|
| H A D | node_validator.go | 159 acmd := newLoginCommand(conn.dataBuffer)
160 err = acmd.login(&clientPolicy, conn, cluster.Password())
165 ndv.sessionToken = acmd.SessionToken
166 ndv.SessionExpiration = acmd.SessionExpiration
264 acmd := newLoginCommand(hconn.dataBuffer)
265 err = acmd.login(&clientPolicy, hconn, cluster.Password())
270 ndv.sessionToken = acmd.SessionToken
271 ndv.SessionExpiration = acmd.SessionExpiration
|
| /dports/graphics/aseprite/aseprite-1.2.9/third_party/libarchive/libarchive/ |
| H A D | filter_fork_windows.c | 43 struct archive_cmdline *acmd; in __archive_create_child() local
54 acmd = __archive_cmdline_allocate(); in __archive_create_child()
55 if (acmd == NULL) in __archive_create_child()
66 ext = strrchr(acmd->path, '.'); in __archive_create_child()
91 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
95 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
100 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
103 p = acmd->argv[i]; in __archive_create_child()
111 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
162 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/innobase/xtrabackup/src/libarchive/libarchive/ |
| H A D | filter_fork_windows.c | 43 struct archive_cmdline *acmd; in __archive_create_child() local
54 acmd = __archive_cmdline_allocate(); in __archive_create_child()
55 if (acmd == NULL) in __archive_create_child()
66 ext = strrchr(acmd->path, '.'); in __archive_create_child()
91 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
95 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
100 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
103 p = acmd->argv[i]; in __archive_create_child()
111 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
162 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/archivers/libarchive/libarchive-3.5.2/libarchive/ |
| H A D | filter_fork_windows.c | 44 struct archive_cmdline *acmd; in __archive_create_child() local
56 acmd = __archive_cmdline_allocate(); in __archive_create_child()
57 if (acmd == NULL) in __archive_create_child()
68 ext = strrchr(acmd->path, '.'); in __archive_create_child()
93 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
97 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
102 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
105 p = acmd->argv[i]; in __archive_create_child()
113 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
171 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/devel/cmake-doc/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
| H A D | filter_fork_windows.c | 44 struct archive_cmdline *acmd; in __archive_create_child() local
56 acmd = __archive_cmdline_allocate(); in __archive_create_child()
57 if (acmd == NULL) in __archive_create_child()
68 ext = strrchr(acmd->path, '.'); in __archive_create_child()
93 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
97 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
102 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
105 p = acmd->argv[i]; in __archive_create_child()
113 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
171 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/devel/cmake-gui/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
| H A D | filter_fork_windows.c | 44 struct archive_cmdline *acmd; in __archive_create_child() local
56 acmd = __archive_cmdline_allocate(); in __archive_create_child()
57 if (acmd == NULL) in __archive_create_child()
68 ext = strrchr(acmd->path, '.'); in __archive_create_child()
93 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
97 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
102 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
105 p = acmd->argv[i]; in __archive_create_child()
113 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
171 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/devel/cmake/cmake-3.22.1/Utilities/cmlibarchive/libarchive/ |
| H A D | filter_fork_windows.c | 44 struct archive_cmdline *acmd; in __archive_create_child() local
56 acmd = __archive_cmdline_allocate(); in __archive_create_child()
57 if (acmd == NULL) in __archive_create_child()
68 ext = strrchr(acmd->path, '.'); in __archive_create_child()
93 l += (int)strlen(acmd->argv[i]) + 1; in __archive_create_child()
97 for (i = 0; acmd->argv[i] != NULL; i++) { in __archive_create_child()
102 (p = strchr(acmd->argv[i], '\\')) != NULL) in __archive_create_child()
105 p = acmd->argv[i]; in __archive_create_child()
113 archive_strcat(&cmdline, acmd->argv[i]); in __archive_create_child()
171 __archive_cmdline_free(acmd); in __archive_create_child()
[all …]
|
| /dports/games/libretro-uae/libretro-uae-8333daa/sources/src/od-linux/ |
| H A D | blkdev-linux.c | 217 uaecptr acmd = VALUE_TO_PTR(ascsi); in execscsicmd_direct_ioctl() local
288 put_byte (acmd + 8, 0); in execscsicmd_direct_ioctl()
290 put_byte (acmd + 21, cmd.stat); in execscsicmd_direct_ioctl()
302 put_byte (acmd + 28, senselen); in execscsicmd_direct_ioctl()
304 put_byte (acmd + 28, 0); in execscsicmd_direct_ioctl()
314 put_long (acmd + 8, scsi_len); in execscsicmd_direct_ioctl()
315 put_word (acmd + 18, scsi_cmd_len); in execscsicmd_direct_ioctl()
316 put_byte (acmd + 21, cmd.stat); in execscsicmd_direct_ioctl()
320 put_long (acmd + 8, 0); in execscsicmd_direct_ioctl()
321 put_word (acmd + 18, 0); in execscsicmd_direct_ioctl()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/samples/mei/ |
| H A D | mei-amt-version.c | 298 acmd->initialized = mei_init(&acmd->mei_cl, &MEI_IAMTHIF, 0, verbose); in amt_host_if_init()
299 return acmd->initialized; in amt_host_if_init()
304 mei_deinit(&acmd->mei_cl); in amt_host_if_deinit()
305 acmd->initialized = false; in amt_host_if_deinit()
378 in_buf_sz = acmd->mei_cl.buf_size; in amt_host_if_call()
385 written = mei_send_msg(&acmd->mei_cl, in amt_host_if_call()
386 command, command_sz, acmd->send_timeout); in amt_host_if_call()
441 struct amt_host_if acmd; in main() local
449 if (!amt_host_if_init(&acmd, 5000, verbose)) { in main()
454 status = amt_get_code_versions(&acmd, &ver); in main()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/samples/mei/ |
| H A D | mei-amt-version.c | 298 acmd->initialized = mei_init(&acmd->mei_cl, &MEI_IAMTHIF, 0, verbose); in amt_host_if_init()
299 return acmd->initialized; in amt_host_if_init()
304 mei_deinit(&acmd->mei_cl); in amt_host_if_deinit()
305 acmd->initialized = false; in amt_host_if_deinit()
378 in_buf_sz = acmd->mei_cl.buf_size; in amt_host_if_call()
385 written = mei_send_msg(&acmd->mei_cl, in amt_host_if_call()
386 command, command_sz, acmd->send_timeout); in amt_host_if_call()
441 struct amt_host_if acmd; in main() local
449 if (!amt_host_if_init(&acmd, 5000, verbose)) { in main()
454 status = amt_get_code_versions(&acmd, &ver); in main()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/samples/mei/ |
| H A D | mei-amt-version.c | 298 acmd->initialized = mei_init(&acmd->mei_cl, &MEI_IAMTHIF, 0, verbose); in amt_host_if_init()
299 return acmd->initialized; in amt_host_if_init()
304 mei_deinit(&acmd->mei_cl); in amt_host_if_deinit()
305 acmd->initialized = false; in amt_host_if_deinit()
378 in_buf_sz = acmd->mei_cl.buf_size; in amt_host_if_call()
385 written = mei_send_msg(&acmd->mei_cl, in amt_host_if_call()
386 command, command_sz, acmd->send_timeout); in amt_host_if_call()
441 struct amt_host_if acmd; in main() local
449 if (!amt_host_if_init(&acmd, 5000, verbose)) { in main()
454 status = amt_get_code_versions(&acmd, &ver); in main()
[all …]
|
| /dports/databases/libcouchbase/libcouchbase-2.10.7/src/operations/ |
| H A D | counter.cc | 31 protocol_binary_request_incr acmd; in lcb_counter3() local
32 protocol_binary_request_header *hdr = &acmd.message.header; in lcb_counter3()
58 acmd.message.body.delta = lcb_htonll((lcb_uint64_t)cmd->delta); in lcb_counter3()
59 acmd.message.body.initial = lcb_htonll(cmd->initial); in lcb_counter3()
61 memset(&acmd.message.body.expiration, 0xff, in lcb_counter3()
62 sizeof(acmd.message.body.expiration)); in lcb_counter3()
64 acmd.message.body.expiration = htonl(cmd->exptime); in lcb_counter3()
69 acmd.message.body.delta = lcb_htonll((lcb_uint64_t)(cmd->delta * -1)); in lcb_counter3()
74 memcpy(SPAN_BUFFER(&packet->kh_span), acmd.bytes, sizeof(acmd.bytes)); in lcb_counter3()
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/labbsr0x/goh/gohcmd/ |
| H A D | gohcmd.go | 36 acmd := cmd.NewCmd("sh", "-c", command)
37 statusChan := acmd.Start() // non-blocking
40 ctx.CmdRef = acmd
51 acmd.Stop()
63 out := GetCmdOutput(acmd)
64 status := acmd.Status()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/languages/mod_managed/managed/examples/winFailToBan/ |
| H A D | BanTracker.cs | 109 var acmd = String.Format(BanApi, bi.FirewallRuleName, ipAddress); in Ban()
110 Log.WriteLine(LogLevel.Critical, "FTB: api command: {0}", acmd); in Ban()
112 a.ExecuteString(acmd); in Ban()
123 var acmd = String.Format(UnBanApi, bi.FirewallRuleName); in Unban()
124 Log.WriteLine(LogLevel.Critical, "FTB: api command: {0}", acmd); in Unban()
126 a.ExecuteString(acmd); in Unban()
|
| /dports/games/libretro-uae/libretro-uae-8333daa/sources/src/ |
| H A D | blkdev-libscg.c | 297 uaecptr scsi_data = get_long (acmd + 0); in execscsicmd_direct()
298 uae_u32 scsi_len = get_long (acmd + 4); in execscsicmd_direct()
299 uaecptr scsi_cmd = get_long (acmd + 12); in execscsicmd_direct()
300 int scsi_cmd_len = get_word (acmd + 16); in execscsicmd_direct()
302 uae_u8 scsi_flags = get_byte (acmd + 20); in execscsicmd_direct()
303 uaecptr scsi_sense = get_long (acmd + 22); in execscsicmd_direct()
304 uae_u16 scsi_sense_len = get_word (acmd + 26); in execscsicmd_direct()
354 put_word (acmd + 18, scmd->error == SCG_FATAL in execscsicmd_direct()
366 put_long (acmd + 8, 0); /* scsi_Actual */ in execscsicmd_direct()
379 put_long (acmd + 8, 0); /* scsi_Actual */ in execscsicmd_direct()
[all …]
|
| H A D | scsidev.c | 310 uaecptr acmd = get_long (request + 40); in scsidev_do_scsi() local
311 uaecptr scsi_data = get_long (acmd + 0); in scsidev_do_scsi()
312 uae_u32 scsi_len = get_long (acmd + 4); in scsidev_do_scsi()
313 uaecptr scsi_cmd = get_long (acmd + 12); in scsidev_do_scsi()
314 uae_u16 scsi_cmd_len = get_word (acmd + 16); in scsidev_do_scsi()
315 uae_u8 scsi_flags = get_byte (acmd + 20); in scsidev_do_scsi()
316 uaecptr scsi_sense = get_long (acmd + 22); in scsidev_do_scsi()
317 uae_u16 scsi_sense_len = get_word (acmd + 26); in scsidev_do_scsi()
489 put_long (acmd + 8, 0); /* scsi_Actual */ in scsidev_do_scsi()
507 put_long (acmd + 8, 0); /* scsi_Actual */ in scsidev_do_scsi()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/testing/mozbase/mozdevice/mozdevice/ |
| H A D | droid.py | 47 acmd = ["am", "start"] + self._getExtraAmStartArgs() + \
51 acmd.extend(["-a", intent])
61 acmd.extend([extraTypeParam, str(key), str(val)])
64 acmd.extend(["-d", url])
70 if self.shell(acmd, shellOutput) == 0:
|
| /dports/games/libretro-uae/libretro-uae-8333daa/sources/src/od-amiga/ |
| H A D | blkdev-amiga.c | 241 uaecptr scsi_data = get_long (acmd + 0); in execscsicmd_direct()
242 uae_u32 scsi_len = get_long (acmd + 4); in execscsicmd_direct()
243 uaecptr scsi_cmd = get_long (acmd + 12); in execscsicmd_direct()
244 int scsi_cmd_len = get_word (acmd + 16); in execscsicmd_direct()
246 uae_u8 scsi_flags = get_byte (acmd + 20); in execscsicmd_direct()
247 uaecptr scsi_sense = get_long (acmd + 22); in execscsicmd_direct()
248 uae_u16 scsi_sense_len = get_word (acmd + 26); in execscsicmd_direct()
289 put_long (acmd + 8, cmd->scsi_Actual); in execscsicmd_direct()
290 put_word (acmd + 18, cmd->scsi_CmdActual); in execscsicmd_direct()
291 put_byte (acmd + 21, cmd->scsi_Status); in execscsicmd_direct()
[all …]
|
| /dports/emulators/uae/uae-0.8.29/src/ |
| H A D | scsidev.c | 310 uaecptr acmd = get_long (request + 40); in scsidev_do_scsi() local
311 uaecptr scsi_data = get_long (acmd + 0); in scsidev_do_scsi()
312 uae_u32 scsi_len = get_long (acmd + 4); in scsidev_do_scsi()
313 uaecptr scsi_cmd = get_long (acmd + 12); in scsidev_do_scsi()
314 uae_u16 scsi_cmd_len = get_word (acmd + 16); in scsidev_do_scsi()
315 uae_u8 scsi_flags = get_byte (acmd + 20); in scsidev_do_scsi()
316 uaecptr scsi_sense = get_long (acmd + 22); in scsidev_do_scsi()
317 uae_u16 scsi_sense_len = get_word (acmd + 26); in scsidev_do_scsi()
489 put_long (acmd + 8, 0); /* scsi_Actual */ in scsidev_do_scsi()
507 put_long (acmd + 8, 0); /* scsi_Actual */ in scsidev_do_scsi()
[all …]
|