Searched refs:connection (Results 1 - 25 of 56) sorted by relevance

123

/haiku/src/add-ons/kernel/file_systems/netfs/shared/
H A DConnectionFactory.cpp26 // create the connection
27 Connection* connection = NULL;
29 connection = new(std::nothrow) InsecureConnection;
31 connection = new(std::nothrow) PortConnection;
34 if (!connection)
37 status_t error = connection->Init(parameters);
39 delete connection;
42 *_connection = connection;
H A DRequestConnection.cpp31 status_t Init(RequestConnection* connection, Channel* channel, argument
34 if (!connection || !channel || !handler)
36 fConnection = connection;
100 RequestConnection::RequestConnection(Connection* connection, argument
102 : fConnection(connection),
/haiku/src/add-ons/kernel/file_systems/nfs4/
H A DRPCCallback.cpp27 Callback::EnqueueRequest(CallbackRequest* request, Connection* connection) argument
30 ASSERT(connection != NULL);
31 return fServer->PrivateData()->ProcessCallback(request, connection);
H A DRPCCallbackServer.cpp213 CallbackServer::NewConnection(Connection* connection) argument
215 ASSERT(connection != NULL);
218 entry->fConnection = connection;
296 Connection* connection = entry->fConnection; local
302 status_t result = connection->Receive(&buffer, &size);
317 connection->Send(reply->Stream().Buffer(),
327 GetCallback(request->ID())->EnqueueRequest(request, connection);
333 connection->Send(reply->Stream().Buffer(),
361 Connection* connection; local
363 status_t result = fListener->AcceptConnection(&connection);
[all...]
H A DConnection.h100 static status_t Connect(Connection **connection,
102 static status_t SetTo(Connection **connection, int socket,
139 status_t AcceptConnection(Connection** connection);
/haiku/src/servers/print/
H A DResourceManager.cpp13 Resource::Resource(const char* transport, const char* address, const char* connection) argument
16 , fConnection(connection)
46 Resource::Equals(const char* transport, const char* address, const char* connection) { argument
49 fConnection == connection;
76 ResourceManager::Find(const char* transport, const char* address, const char* connection) { argument
79 if (r->Equals(transport, address, connection)) return r;
86 ResourceManager::Allocate(const char* transport, const char* address, const char* connection) { argument
87 Resource* r = Find(transport, address, connection);
89 r = new Resource(transport, address, connection);
H A DResourceManager.h26 Resource(const char* transport, const char* address, const char* connection);
31 bool Equals(const char* transport, const char* address, const char* connection);
43 Resource* Find(const char* transport, const char* address, const char* connection);
48 Resource* Allocate(const char* transport, const char* address, const char* connection);
/haiku/src/add-ons/kernel/file_systems/netfs/headers/shared/
H A DConnectionFactory.h18 Connection** connection);
/haiku/src/add-ons/kernel/file_systems/netfs/server/
H A DConnectionListener.h21 virtual status_t Listen(Connection** connection) = 0;
24 virtual status_t FinishInitialization(Connection* connection,
H A DInsecureConnectionListener.cpp69 // accept a connection
79 // create a connection
80 InsecureConnection* connection = new(std::nothrow) InsecureConnection; local
81 if (!connection) {
85 status_t error = connection->Init(fd);
87 delete connection;
90 *_connection = connection;
106 InsecureConnection* connection local
108 if (!connection)
111 return connection
[all...]
H A DPortConnectionListener.cpp80 // create the connection
81 PortConnection* connection = new(std::nothrow) PortConnection; local
82 if (!connection) {
86 status_t error = connection->Init(channel, upStreamChannels,
89 delete connection;
92 *_connection = connection;
109 PortConnection* connection = dynamic_cast<PortConnection*>(_connection); local
110 if (!connection)
113 return connection->FinishInitialization();
H A DPortConnectionListener.h17 virtual status_t Listen(Connection** connection);
20 virtual status_t FinishInitialization(Connection* connection,
H A DInsecureConnectionListener.h22 virtual status_t Listen(Connection** connection);
25 virtual status_t FinishInitialization(Connection* connection,
H A DNetFSServer.cpp60 ConnectionListener* connectionListener, Connection* connection)
63 fConnection(connection),
75 fThread = spawn_thread(&_ThreadEntry, "connection initializer",
91 // finish connection initialization
95 // create a client connection
104 fConnection = NULL; // connection belongs to client connection now
107 // add the client connection to the server
217 // stop the connection listener
240 // terminate the server info connection listene
59 ConnectionInitializer(NetFSServer* server, ConnectionListener* connectionListener, Connection* connection) argument
766 ClientConnectionClosed(ClientConnection* connection, bool broken) argument
1111 Connection* connection = NULL; local
1148 ClientConnection* connection = NULL; local
[all...]
/haiku/src/servers/net/
H A DServices.cpp84 const service_connection& connection = *iterator; local
86 close(connection.socket);
118 const service_connection& connection = *iterator; local
125 if (connection == *otherIterator)
255 service_connection& connection = *iterator; local
257 connection.socket = socket(connection.Family(),
258 connection.Type(), connection.Protocol());
259 if (connection
286 service_connection& connection = *iterator; local
314 const service_connection& connection = *iterator; local
362 service_connection connection; local
509 struct service_connection& connection = *iterator->second; local
[all...]
/haiku/src/apps/cortex/InfoView/
H A DConnectionInfoView.h35 // Display connection-specific info in the InfoWindow.
61 const Connection &connection);
H A DConnectionInfoView.cpp66 const Connection &connection)
68 m_source(connection.source()),
69 m_destination(connection.destination())
77 if (connection.getOutput(&output) == B_OK) {
86 if (connection.getInput(&input) == B_OK) {
101 MediaString::getStringFor(connection.format().type));
104 _addFormatFields(connection.format());
65 ConnectionInfoView( const Connection &connection) argument
/haiku/src/preferences/time/
H A Dntp.cpp144 int connection = socket(AF_INET, SOCK_DGRAM, 0); local
145 if (connection < 0) {
152 if (sendto(connection, reinterpret_cast<char*>(&message),
162 close(connection);
168 FD_SET(connection, &waitForReceived);
177 status = select(connection + 1, &waitForReceived, NULL, NULL,
183 close(connection);
190 if (recvfrom(connection, reinterpret_cast<char*>(&message), sizeof(ntp_data), 0,
194 close(connection);
198 close(connection);
[all...]
/haiku/src/add-ons/kernel/file_systems/netfs/client/
H A DSendReceiveRequest.h19 SendRequest(RequestConnection* connection, Request* request, argument
23 status_t error = connection->SendRequest(request, &reply);
H A DServerConnection.cpp29 fLock("server connection"),
61 // create a connection broken event
82 // establish the connection
83 Connection* connection; local
86 &connection);
90 // create a request connection
91 fConnection = new(std::nothrow) RequestConnection(connection, this);
93 delete connection;
100 // send an `init connection request'
128 // mark the connection close
[all...]
/haiku/src/tests/add-ons/kernel/network/
H A Duserland_ipc.c103 static status_t init_connection(net_connection *connection, connection_cookie **_cookie);
131 localArea[i].id = clone_area("net connection",(void **)&localArea[i].offset,B_ANY_ADDRESS,
242 printf("Opening socket connection, mode = %lx!\n", cookie->openFlags);
246 printf("Closing socket connection...\n");
447 init_connection(net_connection *connection, connection_cookie **_cookie) argument
458 connection->area = create_area("net connection", (void *) &commands, B_ANY_ADDRESS,
461 if (connection->area < B_OK) {
462 fprintf(stderr, "couldn't create area: %s.\n", strerror(connection->area));
464 return connection
543 net_connection connection; local
[all...]
/haiku/src/apps/cortex/NodeManager/
H A DNodeManager.cpp102 Connection* connection) {}
105 const Connection* connection) {}
268 Connection* connection) {
269 ASSERT(connection);
272 "NodeManager::_freeConnection(%ld)\n", connection->id()));
277 connection->isValid() &&
278 connection->flags() & Connection::INTERNAL &&
279 !(connection->flags() & Connection::LOCKED)) {
282 "! breaking connection:\n"
289 connection
101 connectionMade( Connection* connection) argument
104 connectionBroken( const Connection* connection) argument
267 _freeConnection( Connection* connection) argument
1289 disconnect( const Connection& connection) argument
1431 getNextConnection( Connection* connection, void** cookie) argument
1752 _addConnection( Connection* connection) argument
1789 _removeConnection( const Connection& connection) argument
[all...]
/haiku/src/apps/cortex/MediaRoutingView/
H A DMediaWire.h65 Connection connection,
70 // temporary visual indication of the connection process
81 Connection connection; member in class:MediaWire
/haiku/build/scripts/
H A Dbootstrap_daemon.py12 def receiveExactly(connection, size):
15 dataReceived = connection.recv(size)
/haiku/src/apps/cortex/RouteApp/
H A DRouteAppNodeManager.cpp236 Connection* connection) {
246 if (strcmp(connection->outputName(), connection->inputName()) == 0) {
248 title.ReplaceFirst("%name%", connection->outputName());
252 if(!(connection->flags() & Connection::INTERNAL))
253 // don't react to connection Cortex didn't make
258 err = getNodeRef(connection->sourceNode(), &producer);
263 connection->sourceNode()));
266 err = getNodeRef(connection->destinationNode(), &consumer);
271 connection
235 connectionMade( Connection* connection) argument
340 connectionBroken( const Connection* connection) argument
[all...]

Completed in 171 milliseconds

123