/haiku/src/add-ons/kernel/file_systems/netfs/shared/ |
H A D | ConnectionFactory.cpp | 26 // 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 D | RequestConnection.cpp | 31 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 D | RPCCallback.cpp | 27 Callback::EnqueueRequest(CallbackRequest* request, Connection* connection) argument 30 ASSERT(connection != NULL); 31 return fServer->PrivateData()->ProcessCallback(request, connection);
|
H A D | RPCCallbackServer.cpp | 213 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 D | Connection.h | 100 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 D | ResourceManager.h | 26 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);
|
H A D | ResourceManager.cpp | 13 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);
|
/haiku/src/add-ons/kernel/file_systems/netfs/headers/shared/ |
H A D | ConnectionFactory.h | 18 Connection** connection);
|
/haiku/src/add-ons/kernel/file_systems/netfs/server/ |
H A D | ConnectionListener.h | 21 virtual status_t Listen(Connection** connection) = 0; 24 virtual status_t FinishInitialization(Connection* connection,
|
H A D | InsecureConnectionListener.cpp | 69 // 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 D | PortConnectionListener.cpp | 80 // 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 D | PortConnectionListener.h | 17 virtual status_t Listen(Connection** connection); 20 virtual status_t FinishInitialization(Connection* connection,
|
H A D | InsecureConnectionListener.h | 22 virtual status_t Listen(Connection** connection); 25 virtual status_t FinishInitialization(Connection* connection,
|
H A D | NetFSServer.cpp | 60 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 D | Services.cpp | 84 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 D | ConnectionInfoView.h | 35 // Display connection-specific info in the InfoWindow. 61 const Connection &connection);
|
H A D | ConnectionInfoView.cpp | 66 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 D | ntp.cpp | 144 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 D | SendReceiveRequest.h | 19 SendRequest(RequestConnection* connection, Request* request, argument 23 status_t error = connection->SendRequest(request, &reply);
|
/haiku/src/tests/add-ons/kernel/network/ |
H A D | userland_ipc.c | 103 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 D | NodeManager.cpp | 102 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/add-ons/kernel/bluetooth/btCoreData/ |
H A D | FrameInterface.cpp | 116 HciConnection* connection = frame->conn; local 119 mutex_lock(&connection->fLockExpected); 120 connection->ExpectedResponses.Remove(frame); 121 mutex_unlock(&connection->fLockExpected);
|
/haiku/src/apps/cortex/MediaRoutingView/ |
H A D | MediaWire.h | 65 Connection connection, 70 // temporary visual indication of the connection process 81 Connection connection; member in class:MediaWire
|
/haiku/build/scripts/ |
H A D | bootstrap_daemon.py | 12 def receiveExactly(connection, size): 15 dataReceived = connection.recv(size)
|
/haiku/src/apps/cortex/RouteApp/ |
H A D | RouteAppNodeManager.cpp | 236 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...] |