Home
last modified time | relevance | path

Searched refs:store_fd (Results 1 – 25 of 64) sorted by relevance

123

/dports/net-p2p/c-lightning/lightning-0.10.2/common/test/
H A Drun-route-specific.c72 static void update_connection(int store_fd, in update_connection() argument
105 write_to_store(store_fd, msg); in update_connection()
108 static void add_connection(int store_fd, in add_connection() argument
146 write_to_store(store_fd, msg); in add_connection()
191 int store_fd; in main() local
216 store_fd = mkstemp(gossipfilename); in main()
223 add_connection(store_fd, &c, &b, "6990x2x1", in main()
228 add_connection(store_fd, &b, &a, "6989x2x1", in main()
233 add_connection(store_fd, &b, &c, "6990x2x1", in main()
238 update_connection(store_fd, &a, &b, "6989x2x1", in main()
[all …]
H A Drun-route.c65 static void update_connection(int store_fd, in update_connection() argument
96 write_to_store(store_fd, msg); in update_connection()
99 static void add_connection(int store_fd, in add_connection() argument
135 write_to_store(store_fd, msg); in add_connection()
186 int store_fd; in main() local
197 store_fd = mkstemp(gossipfilename); in main()
210 add_connection(store_fd, &a, &b, 1, 1, 1); in main()
228 add_connection(store_fd, &b, &c, 1, 1, 1); in main()
251 add_connection(store_fd, &a, &d, 0, 2, 1); in main()
252 add_connection(store_fd, &d, &c, 0, 2, 1); in main()
[all …]
/dports/net-p2p/c-lightning/lightning-0.10.2/plugins/test/
H A Drun-route-overlong.c230 static void write_to_store(int store_fd, const u8 *msg) in write_to_store() argument
238 assert(write(store_fd, &hdr, sizeof(hdr)) == sizeof(hdr)); in write_to_store()
242 static void update_connection(int store_fd, in update_connection() argument
271 write_to_store(store_fd, msg); in update_connection()
274 static void add_connection(int store_fd, in add_connection() argument
308 write_to_store(store_fd, msg); in add_connection()
310 update_connection(store_fd, from, to, scid, min, max, in add_connection()
332 int store_fd; in main() local
342 store_fd = mkstemp(gossipfilename); in main()
362 add_connection(store_fd, &ids[i-1], &ids[i], &scid, in main()
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/plasma/
H A Dplasma.h101 int store_fd; member
118 (store_fd == other.store_fd) && (data_offset == other.data_offset) &&
H A Dstore.cc292 result->store_fd = fd; in CreateObject()
316 object->store_fd = entry->fd; in PlasmaObject_init()
375 int fd = object.store_fd; in ReturnFromGet()
391 for (int store_fd : store_fds) { in ReturnFromGet() local
394 if (get_req->client->used_fds.find(store_fd) == get_req->client->used_fds.end()) { in ReturnFromGet()
395 WarnIfSigpipe(send_fd(get_req->client->fd, store_fd), get_req->client->fd); in ReturnFromGet()
396 get_req->client->used_fds.insert(store_fd); in ReturnFromGet()
955 mmap_size = GetMmapSize(object.store_fd); in ProcessMessage()
963 client->used_fds.find(object.store_fd) == client->used_fds.end()) { in ProcessMessage()
964 WarnIfSigpipe(send_fd(client->fd, object.store_fd), client->fd); in ProcessMessage()
[all …]
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/plasma/
H A Dplasma.h101 int store_fd; member
118 (store_fd == other.store_fd) && (data_offset == other.data_offset) &&
H A Dstore.cc292 result->store_fd = fd; in CreateObject()
316 object->store_fd = entry->fd; in PlasmaObject_init()
375 int fd = object.store_fd; in ReturnFromGet()
391 for (int store_fd : store_fds) { in ReturnFromGet() local
394 if (get_req->client->used_fds.find(store_fd) == get_req->client->used_fds.end()) { in ReturnFromGet()
395 WarnIfSigpipe(send_fd(get_req->client->fd, store_fd), get_req->client->fd); in ReturnFromGet()
396 get_req->client->used_fds.insert(store_fd); in ReturnFromGet()
955 mmap_size = GetMmapSize(object.store_fd); in ProcessMessage()
963 client->used_fds.find(object.store_fd) == client->used_fds.end()) { in ProcessMessage()
964 WarnIfSigpipe(send_fd(client->fd, object.store_fd), client->fd); in ProcessMessage()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/plasma/
H A Dplasma.h101 int store_fd; member
118 (store_fd == other.store_fd) && (data_offset == other.data_offset) &&
H A Dstore.cc292 result->store_fd = fd; in CreateObject()
316 object->store_fd = entry->fd; in PlasmaObject_init()
375 int fd = object.store_fd; in ReturnFromGet()
391 for (int store_fd : store_fds) { in ReturnFromGet() local
394 if (get_req->client->used_fds.find(store_fd) == get_req->client->used_fds.end()) { in ReturnFromGet()
395 WarnIfSigpipe(send_fd(get_req->client->fd, store_fd), get_req->client->fd); in ReturnFromGet()
396 get_req->client->used_fds.insert(store_fd); in ReturnFromGet()
955 mmap_size = GetMmapSize(object.store_fd); in ProcessMessage()
963 client->used_fds.find(object.store_fd) == client->used_fds.end()) { in ProcessMessage()
964 WarnIfSigpipe(send_fd(client->fd, object.store_fd), client->fd); in ProcessMessage()
[all …]
/dports/lang/perl5.34/perl-5.34.0/dist/Storable/t/
H A Dhugeids.t12 use Storable qw(store_fd retrieve_fd nstore_fd);
183 store_fd(\@x, $fh);
207 store_fd(\@x, $fh);
233 store_fd(\@x, $fh);
276 store_fd($x, $fh);
294 store_fd($x, $fh);
H A Dstore.t21 use Storable qw(store retrieve store_fd nstore_fd fd_retrieve);
64 isnt(store_fd(\@a, ::OUT), undef);
/dports/lang/perl5.30/perl-5.30.3/dist/Storable/t/
H A Dhugeids.t12 use Storable qw(store_fd retrieve_fd nstore_fd);
183 store_fd(\@x, $fh);
207 store_fd(\@x, $fh);
233 store_fd(\@x, $fh);
276 store_fd($x, $fh);
294 store_fd($x, $fh);
H A Dstore.t21 use Storable qw(store retrieve store_fd nstore_fd fd_retrieve);
64 isnt(store_fd(\@a, ::OUT), undef);
/dports/lang/perl5.32/perl-5.32.1/dist/Storable/t/
H A Dhugeids.t12 use Storable qw(store_fd retrieve_fd nstore_fd);
183 store_fd(\@x, $fh);
207 store_fd(\@x, $fh);
233 store_fd(\@x, $fh);
276 store_fd($x, $fh);
294 store_fd($x, $fh);
H A Dstore.t21 use Storable qw(store retrieve store_fd nstore_fd fd_retrieve);
64 isnt(store_fd(\@a, ::OUT), undef);
/dports/devel/p5-Storable/Storable-3.25/t/
H A Dhugeids.t12 use Storable qw(store_fd retrieve_fd nstore_fd);
183 store_fd(\@x, $fh);
207 store_fd(\@x, $fh);
233 store_fd(\@x, $fh);
276 store_fd($x, $fh);
294 store_fd($x, $fh);
H A Dstore.t21 use Storable qw(store retrieve store_fd nstore_fd fd_retrieve);
64 isnt(store_fd(\@a, ::OUT), undef);
/dports/lang/perl5-devel/perl5-5.35.4-102-ge43d289c7c/dist/Storable/t/
H A Dhugeids.t12 use Storable qw(store_fd retrieve_fd nstore_fd);
183 store_fd(\@x, $fh);
207 store_fd(\@x, $fh);
233 store_fd(\@x, $fh);
276 store_fd($x, $fh);
294 store_fd($x, $fh);
H A Dstore.t21 use Storable qw(store retrieve store_fd nstore_fd fd_retrieve);
64 isnt(store_fd(\@a, ::OUT), undef);
/dports/devel/p5-Coro/Coro-6.57/Coro/
H A DStorable.pm117 Storable::store_fd $_[0], $fh;
141 Storable::store_fd $_[0], $fh;
H A DUtil.pm202 Storable::store_fd $@ ? \"$@" : \@res, $fh;
218 eval { Storable::store_fd undef, undef };
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/cpp/src/plasma/test/
H A Dserialization_tests.cc64 object.store_fd = random + 7; in random_plasma_object()
128 int store_fd; in TEST_F() local
130 ASSERT_OK(ReadCreateReply(data.data(), data.size(), &object_id2, &object2, &store_fd, in TEST_F()
133 ASSERT_EQ(object1.store_fd, store_fd); in TEST_F()
/dports/databases/arrow/apache-arrow-6.0.1/cpp/src/plasma/test/
H A Dserialization_tests.cc64 object.store_fd = random + 7; in random_plasma_object()
128 int store_fd; in TEST_F() local
130 ASSERT_OK(ReadCreateReply(data.data(), data.size(), &object_id2, &object2, &store_fd, in TEST_F()
133 ASSERT_EQ(object1.store_fd, store_fd); in TEST_F()
/dports/security/vault/vault-1.8.2/vendor/github.com/apache/arrow/cpp/src/plasma/test/
H A Dserialization_tests.cc64 object.store_fd = random + 7; in random_plasma_object()
128 int store_fd; in TEST_F() local
130 ASSERT_OK(ReadCreateReply(data.data(), data.size(), &object_id2, &object2, &store_fd, in TEST_F()
133 ASSERT_EQ(object1.store_fd, store_fd); in TEST_F()
/dports/devel/p5-MooseX-POE/MooseX-POE-0.215/ex/tbray/
H A Dwf_mmap.pl45 store_fd \%h, \*STDOUT or die "$i can't store!\n";

123