headers/private/media/experimental/SimpleMediaClient.h

100

BMediaConnection* connection,

headers/private/media/experimental/SimpleMediaClient.h

106

BMediaConnection* connection,

src/add-ons/kernel/file_systems/netfs/client/SendReceiveRequest.h

19

SendRequest(RequestConnection* connection, Request* request,

src/add-ons/kernel/file_systems/netfs/client/SendReceiveRequest.h

23

status_t error = connection->SendRequest(request, &reply);

src/add-ons/kernel/file_systems/netfs/client/ServerConnection.cpp

83

Connection* connection;

src/add-ons/kernel/file_systems/netfs/client/ServerConnection.cpp

86

&connection);

src/add-ons/kernel/file_systems/netfs/client/ServerConnection.cpp

91

fConnection = new(std::nothrow) RequestConnection(connection, this);

src/add-ons/kernel/file_systems/netfs/client/ServerConnection.cpp

93

delete connection;

src/add-ons/kernel/file_systems/netfs/client/ServerVolume.cpp

229

RequestConnection* connection = serverConnection->GetRequestConnection();

src/add-ons/kernel/file_systems/netfs/client/ServerVolume.cpp

252

error = SendRequest(connection, &request, &reply);

src/add-ons/kernel/file_systems/netfs/client/ServerVolume.cpp

305

RequestConnection* connection = serverConnection->GetRequestConnection();

src/add-ons/kernel/file_systems/netfs/client/ServerVolume.cpp

323

status_t error = SendRequest(connection, &request, &reply);

src/add-ons/kernel/file_systems/netfs/headers/shared/ConnectionFactory.h

18

Connection** connection);

src/add-ons/kernel/file_systems/netfs/headers/shared/RequestConnection.h

14

RequestConnection(Connection* connection,

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

152

QueryHandleUnlocker(ClientConnection* connection, NodeHandle* nodeHandle)

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

153

: fConnection(connection),

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

176

virtual bool FilterVolume(ClientConnection* connection,

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

183

virtual bool FilterVolume(ClientConnection* connection,

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

194

ClientConnection::ClientConnection(Connection* connection,

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

215

fConnection = new(std::nothrow) RequestConnection(connection, this);

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

217

delete connection;

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

68

ConnectionReference(ClientConnection* connection)

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

69

: fConnection(connection)

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

98

ClientVolumePutter(ClientConnection* connection, ClientVolume* volume)

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.cpp

99

: fConnection(connection),

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.h

209

ClientConnection* connection,

src/add-ons/kernel/file_systems/netfs/server/ClientConnection.h

37

ClientConnection(Connection* connection,

src/add-ons/kernel/file_systems/netfs/server/ConnectionListener.h

21

virtual status_t Listen(Connection** connection) = 0;

src/add-ons/kernel/file_systems/netfs/server/ConnectionListener.h

24

virtual status_t FinishInitialization(Connection* connection,

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

106

InsecureConnection* connection

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

108

if (!connection)

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

111

return connection->FinishInitialization();

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

80

InsecureConnection* connection = new(std::nothrow) InsecureConnection;

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

81

if (!connection) {

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

85

status_t error = connection->Init(fd);

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

87

delete connection;

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.cpp

90

*_connection = connection;

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.h

22

virtual status_t Listen(Connection** connection);

src/add-ons/kernel/file_systems/netfs/server/InsecureConnectionListener.h

25

virtual status_t FinishInitialization(Connection* connection,

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1111

Connection* connection = NULL;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1114

error = fConnectionListener->Listen(&connection);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1118

connection);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1126

delete connection;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1148

ClientConnection* connection = NULL;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1151

connection = (ClientConnection*)fClosedConnections.RemoveItem((int32)0);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1153

if (connection)

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

1154

delete connection;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

255

ClientConnection* connection

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

258

connection->Close();

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

259

delete connection;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

264

ClientConnection* connection

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

267

delete connection;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

406

ClientConnection* connection

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

409

connection->UserRemoved(user);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

507

ClientConnection* connection

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

510

connection->ShareRemoved(share);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

60

ConnectionListener* connectionListener, Connection* connection)

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

63

fConnection(connection),

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

677

ClientConnection* connection

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

680

connection->UserPermissionsChanged(share, user,

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

766

NetFSServer::ClientConnectionClosed(ClientConnection* connection, bool broken)

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

769

if (!connection)

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

772

if (!fClientConnections.RemoveItem(connection))

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

774

if (!fClosedConnections.AddItem(connection)) {

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.cpp

779

delete connection;

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.h

39

ClientConnection* connection);

src/add-ons/kernel/file_systems/netfs/server/NetFSServer.h

42

ClientConnection* connection,

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

109

PortConnection* connection = dynamic_cast<PortConnection*>(_connection);

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

110

if (!connection)

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

113

return connection->FinishInitialization();

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

81

PortConnection* connection = new(std::nothrow) PortConnection;

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

82

if (!connection) {

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

86

status_t error = connection->Init(channel, upStreamChannels,

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

89

delete connection;

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.cpp

92

*_connection = connection;

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.h

17

virtual status_t Listen(Connection** connection);

src/add-ons/kernel/file_systems/netfs/server/PortConnectionListener.h

20

virtual status_t FinishInitialization(Connection* connection,

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

27

Connection* connection = NULL;

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

29

connection = new(std::nothrow) InsecureConnection;

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

31

connection = new(std::nothrow) PortConnection;

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

34

if (!connection)

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

37

status_t error = connection->Init(parameters);

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

39

delete connection;

src/add-ons/kernel/file_systems/netfs/shared/ConnectionFactory.cpp

42

*_connection = connection;

src/add-ons/kernel/file_systems/netfs/shared/RequestConnection.cpp

100

RequestConnection::RequestConnection(Connection* connection,

src/add-ons/kernel/file_systems/netfs/shared/RequestConnection.cpp

102

: fConnection(connection),

src/add-ons/kernel/file_systems/netfs/shared/RequestConnection.cpp

31

status_t Init(RequestConnection* connection, Channel* channel,

src/add-ons/kernel/file_systems/netfs/shared/RequestConnection.cpp

34

if (!connection || !channel || !handler)

src/add-ons/kernel/file_systems/netfs/shared/RequestConnection.cpp

36

fConnection = connection;

src/add-ons/kernel/file_systems/nfs4/Connection.cpp

762

ConnectionListener::AcceptConnection(Connection** connection)

src/add-ons/kernel/file_systems/nfs4/Connection.cpp

764

ASSERT(connection != NULL);

src/add-ons/kernel/file_systems/nfs4/Connection.cpp

798

status_t result = Connection::SetTo(connection, sock, address);

src/add-ons/kernel/file_systems/nfs4/Connection.h

100

static status_t Connect(Connection **connection,

src/add-ons/kernel/file_systems/nfs4/Connection.h

102

static status_t SetTo(Connection **connection, int socket,

src/add-ons/kernel/file_systems/nfs4/Connection.h

139

status_t AcceptConnection(Connection** connection);

src/add-ons/kernel/file_systems/nfs4/NFS4Server.cpp

281

Connection* connection)

src/add-ons/kernel/file_systems/nfs4/NFS4Server.cpp

284

ASSERT(connection != NULL);

src/add-ons/kernel/file_systems/nfs4/NFS4Server.cpp

309

connection->Send(stream.Buffer(), stream.Size());

src/add-ons/kernel/file_systems/nfs4/NFS4Server.h

41

Connection* connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallback.cpp

27

Callback::EnqueueRequest(CallbackRequest* request, Connection* connection)

src/add-ons/kernel/file_systems/nfs4/RPCCallback.cpp

30

ASSERT(connection != NULL);

src/add-ons/kernel/file_systems/nfs4/RPCCallback.cpp

31

return fServer->PrivateData()->ProcessCallback(request, connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallback.h

32

Connection* connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

213

CallbackServer::NewConnection(Connection* connection)

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

215

ASSERT(connection != NULL);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

218

entry->fConnection = connection;

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

296

Connection* connection = entry->fConnection;

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

302

status_t result = connection->Receive(&buffer, &size);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

317

connection->Send(reply->Stream().Buffer(),

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

327

GetCallback(request->ID())->EnqueueRequest(request, connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

333

connection->Send(reply->Stream().Buffer(),

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

361

Connection* connection;

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

363

status_t result = fListener->AcceptConnection(&connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

368

result = NewConnection(connection);

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.cpp

370

delete connection;

src/add-ons/kernel/file_systems/nfs4/RPCCallbackServer.h

53

status_t NewConnection(Connection* connection);

src/add-ons/kernel/file_systems/nfs4/RPCServer.cpp

102

ASSERT(connection != NULL);

src/add-ons/kernel/file_systems/nfs4/RPCServer.cpp

93

Server::Server(Connection* connection, PeerAddress* address)

src/add-ons/kernel/file_systems/nfs4/RPCServer.cpp

95

fConnection(connection),

src/add-ons/kernel/file_systems/nfs4/RPCServer.h

59

Connection* connection) = 0;

src/add-ons/kernel/file_systems/nfs4/RPCServer.h

66

Server(Connection* connection,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

550

L2capEndpoint::_HandleConnectionReq(HciConnection* connection,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

555

send_l2cap_connection_rsp(connection, ident, 0, scid,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

565

send_l2cap_connection_rsp(connection, ident, 0, scid,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

576

send_l2cap_connection_rsp(connection, ident, 0, scid,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

583

endpoint->fConnection = connection;

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.cpp

588

send_l2cap_connection_rsp(connection, ident, endpoint->fChannelID, scid,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpoint.h

52

void _HandleConnectionReq(HciConnection* connection,

src/add-ons/kernel/network/protocols/l2cap/L2capEndpointManager.cpp

124

L2capEndpointManager::Disconnected(HciConnection* connection)

src/add-ons/kernel/network/protocols/l2cap/L2capEndpointManager.cpp

130

if (endpoint->fConnection != connection)

src/add-ons/kernel/network/protocols/l2cap/L2capEndpointManager.h

25

void Disconnected(HciConnection* connection);

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

216

struct HciConnection* connection = btCoreData->ConnectionByDestination(

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

221

return connection;

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

257

struct HciConnection* connection = connection_for(buffer);

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

258

if (connection == NULL) {

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

263

status = l2cap_handle_signaling_command(connection, buffer);

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

304

struct HciConnection* connection = connection_for(data);

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

305

if (connection == NULL)

src/add-ons/kernel/network/protocols/l2cap/l2cap.cpp

309

gL2capEndpointManager.Disconnected(connection);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

449

l2cap_handle_signaling_command(HciConnection* connection, net_buffer* buffer)

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

469

btCoreData->lookup_command_ident(connection, ident));

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

488

l2cap_handle_connection_req(connection, ident, buffer);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

496

l2cap_handle_configuration_req(connection, ident,

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

501

l2cap_handle_configuration_rsp(connection, endpoint, ident,

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

506

l2cap_handle_disconnection_req(connection, ident, buffer);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

514

l2cap_handle_echo_req(connection, ident, buffer, length);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

522

l2cap_handle_info_req(connection, ident, buffer);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

532

send_l2cap_command_reject(connection, ident,

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.cpp

539

btCoreData->free_command_ident(connection, ident);

src/add-ons/kernel/network/protocols/l2cap/l2cap_signal.h

11

status_t l2cap_handle_signaling_command(struct HciConnection* connection, net_buffer* buffer);

src/apps/cortex/InfoView/ConnectionInfoView.cpp

101

MediaString::getStringFor(connection.format().type));

src/apps/cortex/InfoView/ConnectionInfoView.cpp

104

_addFormatFields(connection.format());

src/apps/cortex/InfoView/ConnectionInfoView.cpp

66

const Connection &connection)

src/apps/cortex/InfoView/ConnectionInfoView.cpp

68

m_source(connection.source()),

src/apps/cortex/InfoView/ConnectionInfoView.cpp

69

m_destination(connection.destination())

src/apps/cortex/InfoView/ConnectionInfoView.cpp

77

if (connection.getOutput(&output) == B_OK) {

src/apps/cortex/InfoView/ConnectionInfoView.cpp

86

if (connection.getInput(&input) == B_OK) {

src/apps/cortex/InfoView/ConnectionInfoView.h

61

const Connection &connection);

src/apps/cortex/InfoView/InfoWindowManager.cpp

422

const Connection &connection) {

src/apps/cortex/InfoView/InfoWindowManager.cpp

431

if (_findWindowFor(connection.source(), connection.destination(), &window)) {

src/apps/cortex/InfoView/InfoWindowManager.cpp

443

if (_addWindowFor(connection, window)) {

src/apps/cortex/InfoView/InfoWindowManager.cpp

444

window->AddChild(new ConnectionInfoView(connection));

src/apps/cortex/InfoView/InfoWindowManager.cpp

760

const Connection &connection,

src/apps/cortex/InfoView/InfoWindowManager.cpp

768

connection_window *entry = new connection_window(connection.source(),

src/apps/cortex/InfoView/InfoWindowManager.cpp

769

connection.destination(),

src/apps/cortex/InfoView/InfoWindowManager.h

121

const Connection &connection);

src/apps/cortex/InfoView/InfoWindowManager.h

158

const Connection &connection,

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1333

Connection& connection)

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1338

if ((_findPanelFor(connection.sourceNode(), &source) == B_OK)

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1339

&& (_findPanelFor(connection.destinationNode(), &destination) == B_OK))

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1344

error = connection.getOutput(&output);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1353

error = connection.getInput(&input);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1361

MediaWire *wire = new MediaWire(connection, outputJack, inputJack);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1392

if (wire && wire->connection.id() == connectionID)

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1410

_findPanelFor(wire->connection.sourceNode(), &source);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1411

_findPanelFor(wire->connection.destinationNode(), &destination);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1541

Connection connection;

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1542

while (manager->getNextConnection(&connection, &cookie) == B_OK)

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1544

_addWireFor(connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1632

manager->openWindowFor(wire->connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1704

if (wire && !(wire->connection.flags() & Connection::LOCKED))

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

1706

status_t error = manager->disconnect(wire->connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

210

Connection connection;

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

211

error = manager->connect(output, input, &connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

487

Connection connection;

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

488

if (manager->findConnection(output.node.node, output.source, &connection) == B_OK)

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

490

_addWireFor(connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.cpp

535

manager->findConnection(nodeID, *source, &wire->connection);

src/apps/cortex/MediaRoutingView/MediaRoutingView.h

305

Connection &connection);

src/apps/cortex/MediaRoutingView/MediaWire.cpp

222

BString tipText = MediaString::getStringFor(connection.format(), false);

src/apps/cortex/MediaRoutingView/MediaWire.cpp

330

connection.getOutput(&output);

src/apps/cortex/MediaRoutingView/MediaWire.cpp

339

if (connection.flags() & Connection::LOCKED)

src/apps/cortex/MediaRoutingView/MediaWire.cpp

82

Connection connection,

src/apps/cortex/MediaRoutingView/MediaWire.cpp

86

connection(connection)

src/apps/cortex/MediaRoutingView/MediaWire.h

65

Connection connection,

src/apps/cortex/MediaRoutingView/MediaWire.h

81

Connection connection;

src/apps/cortex/NodeManager/NodeManager.cpp

102

Connection* connection) {}

src/apps/cortex/NodeManager/NodeManager.cpp

105

const Connection* connection) {}

src/apps/cortex/NodeManager/NodeManager.cpp

1290

const Connection& connection) {

src/apps/cortex/NodeManager/NodeManager.cpp

1298

if(!connection.isValid())

src/apps/cortex/NodeManager/NodeManager.cpp

1302

if(connection.flags() & Connection::LOCKED) {

src/apps/cortex/NodeManager/NodeManager.cpp

1306

connection.sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1307

connection.outputName(),

src/apps/cortex/NodeManager/NodeManager.cpp

1308

connection.destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1309

connection.inputName()));

src/apps/cortex/NodeManager/NodeManager.cpp

1321

connection.sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1322

connection.source().id, connection.source().port,

src/apps/cortex/NodeManager/NodeManager.cpp

1323

connection.destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1324

connection.destination().id, connection.destination().port));

src/apps/cortex/NodeManager/NodeManager.cpp

1329

connection.sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1330

connection.source(),

src/apps/cortex/NodeManager/NodeManager.cpp

1331

connection.destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1332

connection.destination());

src/apps/cortex/NodeManager/NodeManager.cpp

1336

con_map::iterator it = m_conSourceMap.lower_bound(connection.sourceNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1337

con_map::iterator itEnd = m_conSourceMap.upper_bound(connection.sourceNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1339

if((*it).second->id() == connection.id()) {

src/apps/cortex/NodeManager/NodeManager.cpp

1352

if(getNodeRef(connection.sourceNode(), &ref) == B_OK)

src/apps/cortex/NodeManager/NodeManager.cpp

1354

if(getNodeRef(connection.destinationNode(), &ref) == B_OK)

src/apps/cortex/NodeManager/NodeManager.cpp

1432

Connection* connection,

src/apps/cortex/NodeManager/NodeManager.cpp

1450

*connection = *((*(*pit)).second);

src/apps/cortex/NodeManager/NodeManager.cpp

1753

Connection* connection) {

src/apps/cortex/NodeManager/NodeManager.cpp

1755

ASSERT(connection);

src/apps/cortex/NodeManager/NodeManager.cpp

1764

for(con_map::iterator it = m_conSourceMap.lower_bound(connection->sourceNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1765

it != m_conSourceMap.upper_bound(connection->sourceNode()); ++it) {

src/apps/cortex/NodeManager/NodeManager.cpp

1766

ASSERT((*it).second->id() != connection->id());

src/apps/cortex/NodeManager/NodeManager.cpp

1768

for(con_map::iterator it = m_conDestinationMap.lower_bound(connection->destinationNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1769

it != m_conDestinationMap.upper_bound(connection->destinationNode()); ++it) {

src/apps/cortex/NodeManager/NodeManager.cpp

1770

ASSERT((*it).second->id() != connection->id());

src/apps/cortex/NodeManager/NodeManager.cpp

1778

connection->sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1779

connection));

src/apps/cortex/NodeManager/NodeManager.cpp

1782

connection->destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

1783

connection));

src/apps/cortex/NodeManager/NodeManager.cpp

1786

connectionMade(connection);

src/apps/cortex/NodeManager/NodeManager.cpp

1790

const Connection& connection) {

src/apps/cortex/NodeManager/NodeManager.cpp

1799

connectionBroken(&connection);

src/apps/cortex/NodeManager/NodeManager.cpp

1805

itSource = m_conSourceMap.lower_bound(connection.sourceNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1806

itSource != m_conSourceMap.upper_bound(connection.sourceNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1808

if((*itSource).second->id() == connection.id())

src/apps/cortex/NodeManager/NodeManager.cpp

1814

itDestination = m_conDestinationMap.lower_bound(connection.destinationNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1815

itDestination != m_conDestinationMap.upper_bound(connection.destinationNode());

src/apps/cortex/NodeManager/NodeManager.cpp

1817

if((*itDestination).second->id() == connection.id())

src/apps/cortex/NodeManager/NodeManager.cpp

268

Connection* connection) {

src/apps/cortex/NodeManager/NodeManager.cpp

269

ASSERT(connection);

src/apps/cortex/NodeManager/NodeManager.cpp

272

"NodeManager::_freeConnection(%ld)\n", connection->id()));

src/apps/cortex/NodeManager/NodeManager.cpp

277

connection->isValid() &&

src/apps/cortex/NodeManager/NodeManager.cpp

278

connection->flags() & Connection::INTERNAL &&

src/apps/cortex/NodeManager/NodeManager.cpp

279

!(connection->flags() & Connection::LOCKED)) {

src/apps/cortex/NodeManager/NodeManager.cpp

289

connection->sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

290

connection->source().id, connection->source().port,

src/apps/cortex/NodeManager/NodeManager.cpp

291

connection->destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

292

connection->destination().id, connection->destination().port));

src/apps/cortex/NodeManager/NodeManager.cpp

297

connection->sourceNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

298

connection->source(),

src/apps/cortex/NodeManager/NodeManager.cpp

299

connection->destinationNode(),

src/apps/cortex/NodeManager/NodeManager.cpp

300

connection->destination());

src/apps/cortex/NodeManager/NodeManager.cpp

306

connection->outputName(), connection->inputName(),

src/apps/cortex/NodeManager/NodeManager.cpp

312

delete connection;

src/apps/cortex/NodeManager/NodeManager.h

173

Connection* connection);

src/apps/cortex/NodeManager/NodeManager.h

176

const Connection* connection);

src/apps/cortex/NodeManager/NodeManager.h

406

const Connection& connection);

src/apps/cortex/NodeManager/NodeManager.h

477

Connection* connection);

src/apps/cortex/NodeManager/NodeManager.h

479

const Connection& connection);

src/apps/cortex/NodeManager/NodeManager.h

491

Connection* connection);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

236

Connection* connection) {

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

246

if (strcmp(connection->outputName(), connection->inputName()) == 0) {

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

248

title.ReplaceFirst("%name%", connection->outputName());

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

252

if(!(connection->flags() & Connection::INTERNAL))

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

258

err = getNodeRef(connection->sourceNode(), &producer);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

263

connection->sourceNode()));

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

266

err = getNodeRef(connection->destinationNode(), &consumer);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

271

connection->destinationNode()));

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

288

line << MediaString::getStringFor(connection->format(), false);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

341

const Connection* connection) {

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

349

if (strcmp(connection->outputName(), connection->inputName()) == 0) {

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

351

title.ReplaceFirst("%name%", connection->outputName());

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

355

if(!(connection->flags() & Connection::INTERNAL))

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

366

err = getNodeRef(connection->sourceNode(), &producer);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

371

connection->sourceNode()));

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

374

err = getNodeRef(connection->destinationNode(), &consumer);

src/apps/cortex/RouteApp/RouteAppNodeManager.cpp

379

connection->destinationNode()));

src/apps/cortex/RouteApp/RouteAppNodeManager.h

148

Connection* connection);

src/apps/cortex/RouteApp/RouteAppNodeManager.h

151

const Connection* connection);

src/kits/media/experimental/MediaClient.cpp

223

BMediaClient::Connect(BMediaConnection* connection,

src/preferences/time/ntp.cpp

144

int connection = socket(AF_INET, SOCK_DGRAM, 0);

src/preferences/time/ntp.cpp

145

if (connection < 0) {

src/preferences/time/ntp.cpp

152

if (sendto(connection, reinterpret_cast<char*>(&message),

src/preferences/time/ntp.cpp

162

close(connection);

src/preferences/time/ntp.cpp

168

FD_SET(connection, &waitForReceived);

src/preferences/time/ntp.cpp

177

status = select(connection + 1, &waitForReceived, NULL, NULL,

src/preferences/time/ntp.cpp

183

close(connection);

src/preferences/time/ntp.cpp

190

if (recvfrom(connection, reinterpret_cast<char*>(&message), sizeof(ntp_data), 0,

src/preferences/time/ntp.cpp

194

close(connection);

src/preferences/time/ntp.cpp

198

close(connection);

src/servers/net/Services.cpp

120

const service_connection& connection = *iterator;

src/servers/net/Services.cpp

127

if (connection == *otherIterator)

src/servers/net/Services.cpp

257

service_connection& connection = *iterator;

src/servers/net/Services.cpp

259

connection.socket = socket(connection.Family(),

src/servers/net/Services.cpp

260

connection.Type(), connection.Protocol());

src/servers/net/Services.cpp

261

if (connection.socket < 0

src/servers/net/Services.cpp

262

|| bind(connection.socket, connection.Address(),

src/servers/net/Services.cpp

263

connection.Address().Length()) < 0

src/servers/net/Services.cpp

264

|| fcntl(connection.socket, F_SETFD, FD_CLOEXEC) < 0) {

src/servers/net/Services.cpp

269

if (connection.Type() == SOCK_STREAM

src/servers/net/Services.cpp

270

&& listen(connection.socket, 50) < 0) {

src/servers/net/Services.cpp

288

service_connection& connection = *iterator;

src/servers/net/Services.cpp

290

fSocketMap[connection.socket] = &connection;

src/servers/net/Services.cpp

291

_UpdateMinMaxSocket(connection.socket);

src/servers/net/Services.cpp

292

FD_SET(connection.socket, &fSet);

src/servers/net/Services.cpp

316

const service_connection& connection = *iterator;

src/servers/net/Services.cpp

319

= fSocketMap.find(connection.socket);

src/servers/net/Services.cpp

323

close(connection.socket);

src/servers/net/Services.cpp

324

FD_CLR(connection.socket, &fSet);

src/servers/net/Services.cpp

364

service_connection connection;

src/servers/net/Services.cpp

365

connection.owner = service;

src/servers/net/Services.cpp

366

connection.socket = -1;

src/servers/net/Services.cpp

367

connection.address = address;

src/servers/net/Services.cpp

369

service->connections.push_back(connection);

src/servers/net/Services.cpp

516

struct service_connection& connection = *iterator->second;

src/servers/net/Services.cpp

519

if (connection.Type() == SOCK_STREAM) {

src/servers/net/Services.cpp

525

socket = accept(connection.socket, NULL, NULL);

src/servers/net/Services.cpp

533

socket = connection.socket;

src/servers/net/Services.cpp

537

_LaunchService(*connection.owner, socket);

src/servers/net/Services.cpp

86

const service_connection& connection = *iterator;

src/servers/net/Services.cpp

88

close(connection.socket);

src/servers/print/PrintServerApp.R5.cpp

131

BString connection;

src/servers/print/PrintServerApp.R5.cpp

132

if (msg->FindString("connection", &connection) != B_OK)

src/servers/print/PrintServerApp.R5.cpp

133

connection = "Local";

src/servers/print/PrintServerApp.R5.cpp

137

driverName.String(), connection.String(),

src/servers/print/PrintServerApp.cpp

184

BString transport, address, connection, state;

src/servers/print/PrintServerApp.cpp

189

&& printer->ReadAttrString(PSRV_PRINTER_ATTR_CNX, &connection) == B_OK

src/servers/print/PrintServerApp.cpp

204

address.String(), connection.String());

src/servers/print/PrintServerApp.cpp

358

const char* connection, const char* transportName,

src/servers/print/PrintServerApp.cpp

425

printer.WriteAttr(PSRV_PRINTER_ATTR_CNX, B_STRING_TYPE, 0, connection,

src/servers/print/PrintServerApp.cpp

426

::strlen(connection) + 1);

src/servers/print/PrintServerApp.h

70

const char* connection,

src/servers/print/ResourceManager.cpp

13

Resource::Resource(const char* transport, const char* address, const char* connection)

src/servers/print/ResourceManager.cpp

16

, fConnection(connection)

src/servers/print/ResourceManager.cpp

46

Resource::Equals(const char* transport, const char* address, const char* connection) {

src/servers/print/ResourceManager.cpp

49

fConnection == connection;

src/servers/print/ResourceManager.cpp

76

ResourceManager::Find(const char* transport, const char* address, const char* connection) {

src/servers/print/ResourceManager.cpp

79

if (r->Equals(transport, address, connection)) return r;

src/servers/print/ResourceManager.cpp

86

ResourceManager::Allocate(const char* transport, const char* address, const char* connection) {

src/servers/print/ResourceManager.cpp

87

Resource* r = Find(transport, address, connection);

src/servers/print/ResourceManager.cpp

89

r = new Resource(transport, address, connection);

src/servers/print/ResourceManager.h

26

Resource(const char* transport, const char* address, const char* connection);

src/servers/print/ResourceManager.h

31

bool Equals(const char* transport, const char* address, const char* connection);

src/servers/print/ResourceManager.h

43

Resource* Find(const char* transport, const char* address, const char* connection);

src/servers/print/ResourceManager.h

48

Resource* Allocate(const char* transport, const char* address, const char* connection);

src/tests/add-ons/kernel/network/userland_ipc.c

103

static status_t init_connection(net_connection *connection, connection_cookie **_cookie);

src/tests/add-ons/kernel/network/userland_ipc.c

447

init_connection(net_connection *connection, connection_cookie **_cookie)

src/tests/add-ons/kernel/network/userland_ipc.c

458

connection->area = create_area("net connection", (void *) &commands, B_ANY_ADDRESS,

src/tests/add-ons/kernel/network/userland_ipc.c

461

if (connection->area < B_OK) {

src/tests/add-ons/kernel/network/userland_ipc.c

462

fprintf(stderr, "couldn't create area: %s.\n", strerror(connection->area));

src/tests/add-ons/kernel/network/userland_ipc.c

464

return connection->area;

src/tests/add-ons/kernel/network/userland_ipc.c

468

connection->port = create_port(CONNECTION_QUEUE_LENGTH, "net stack connection");

src/tests/add-ons/kernel/network/userland_ipc.c

469

if (connection->port < B_OK) {

src/tests/add-ons/kernel/network/userland_ipc.c

470

fprintf(stderr, "couldn't create port: %s.\n", strerror(connection->port));

src/tests/add-ons/kernel/network/userland_ipc.c

471

delete_area(connection->area);

src/tests/add-ons/kernel/network/userland_ipc.c

473

return connection->port;

src/tests/add-ons/kernel/network/userland_ipc.c

476

connection->commandSemaphore = create_sem(0, "net command queue");

src/tests/add-ons/kernel/network/userland_ipc.c

477

if (connection->commandSemaphore < B_OK) {

src/tests/add-ons/kernel/network/userland_ipc.c

478

fprintf(stderr, "couldn't create semaphore: %s.\n", strerror(connection->commandSemaphore));

src/tests/add-ons/kernel/network/userland_ipc.c

479

delete_area(connection->area);

src/tests/add-ons/kernel/network/userland_ipc.c

480

delete_port(connection->port);

src/tests/add-ons/kernel/network/userland_ipc.c

482

return connection->commandSemaphore;

src/tests/add-ons/kernel/network/userland_ipc.c

488

delete_sem(connection->commandSemaphore);

src/tests/add-ons/kernel/network/userland_ipc.c

489

delete_area(connection->area);

src/tests/add-ons/kernel/network/userland_ipc.c

490

delete_port(connection->port);

src/tests/add-ons/kernel/network/userland_ipc.c

495

connection->socket_thread = cookie->runner;

src/tests/add-ons/kernel/network/userland_ipc.c

497

connection->numCommands = NUM_COMMANDS;

src/tests/add-ons/kernel/network/userland_ipc.c

498

connection->bufferSize = CONNECTION_BUFFER_SIZE;

src/tests/add-ons/kernel/network/userland_ipc.c

501

cookie->area = connection->area;

src/tests/add-ons/kernel/network/userland_ipc.c

504

cookie->commandSemaphore = connection->commandSemaphore;

src/tests/add-ons/kernel/network/userland_ipc.c

505

cookie->localPort = connection->port;

src/tests/add-ons/kernel/network/userland_ipc.c

543

net_connection connection;

src/tests/add-ons/kernel/network/userland_ipc.c

547

if (init_connection(&connection, &cookie) == B_OK)

src/tests/add-ons/kernel/network/userland_ipc.c

548

write_port(port, NET_STACK_NEW_CONNECTION, &connection, sizeof(net_connection));