/haiku/src/add-ons/kernel/file_systems/userlandfs/server/ |
H A D | RequestThread.cpp | 67 fPort(NULL), in RequestThread() 78 delete fPort; in ~RequestThread() 88 fPort = new(std::nothrow) RequestPort(kRequestPortSize); in Init() 89 if (!fPort) in Init() 91 status_t error = fPort->InitCheck(); in Init() 117 if (fPort) in PrepareTermination() 118 fPort->Close(); in PrepareTermination() 136 return (fPort ? fPort->GetPortInfo() : NULL); in GetPortInfo() 150 return fPort; in GetPort() 188 return fPort->HandleRequests(&handler); in _ThreadLoop()
|
H A D | UserlandRequestHandler.cpp | 275 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 303 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 328 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 354 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 381 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 414 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 441 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 487 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 519 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 547 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() [all …]
|
/haiku/src/add-ons/kernel/file_systems/netfs/server/ |
H A D | PortConnectionListener.cpp | 18 fPort(-1) in PortConnectionListener() 25 if (fPort >= 0) in ~PortConnectionListener() 26 delete_port(fPort); in ~PortConnectionListener() 33 fPort = create_port(5, kPortConnectionPortName); in Init() 34 if (fPort < 0) in Init() 35 return fPort; in Init() 43 if (!_connection || fPort < 0) in Listen() 51 ssize_t bytesRead = read_port(fPort, 0, &request, in Listen() 100 delete_port(fPort); in StopListening() 101 fPort = -1; in StopListening()
|
/haiku/src/build/libbe/app/ |
H A D | Messenger.cpp | 40 fPort(-1), in BMessenger() 54 fPort(from.fPort), in BMessenger() 80 fPort = from.fPort; in operator =() 99 return fPort == other.fPort in operator ==() 114 return fPort >= 0; in IsValid() 144 fPort = port; in _SetTo()
|
/haiku/src/add-ons/kernel/busses/scsi/ahci/ |
H A D | ahci_controller.cpp | 36 memset(fPort, 0, sizeof(fPort)); in AHCIController() 234 fPort[i] = new (std::nothrow)AHCIPort(this, i); in Init() 235 if (!fPort[i]) { in Init() 239 status_t status = fPort[i]->Init1(); in Init() 242 delete fPort[i]; in Init() 243 fPort[i] = NULL; in Init() 259 if (fPort[i]) { in Init() 260 status_t status = fPort[i]->Init2(); in Init() 263 fPort[i]->Uninit(); in Init() 264 delete fPort[i]; in Init() [all …]
|
/haiku/headers/private/bluetooth/ |
H A D | PortListener.h | 22 fInformation.port = &fPort; in PortListener() 38 close_port(fPort); in ~PortListener() 49 return write_port(fPort, code, NULL, 0); in Trigger() 58 return write_port(fPort, code, buffer, size); in Trigger() 65 fPort = find_port(fPortName); in InitCheck() 66 if (fPort == B_NAME_NOT_FOUND) { in InitCheck() 67 fPort = create_port(MAX_MESSAGE_DEEP, fPortName); in InitCheck() 70 if (fPort < B_OK) in InitCheck() 71 return fPort; in InitCheck() 75 set_port_owner(fPort, B_SYSTEM_TEAM); in InitCheck() [all …]
|
/haiku/src/kits/app/ |
H A D | Messenger.cpp | 44 fPort(-1), in BMessenger() 53 fPort(-1), in BMessenger() 64 fPort(-1), in BMessenger() 74 fPort(other.fPort), in BMessenger() 106 *_looper = BPrivate::gLooperList.LooperForPort(fPort); in Target() 120 if (looper->fMsgPort == fPort) in LockTarget() 141 if (result == B_OK && looper->fMsgPort != fPort) { in LockTargetWithTimeout() 186 return BMessage::Private(message).SendMessage(fPort, fTeam, fHandlerToken, in SendMessage() 207 status_t result = BMessage::Private(message).SendMessage(fPort, fTeam, in SendMessage() 245 fPort = other.fPort; in operator =() [all …]
|
H A D | LinkSender.cpp | 39 fPort(port), in LinkSender() 60 fPort = port; in SetPort() 167 status_t result = get_port_info(fPort, &info); in Attach() 306 fCurrentEnd, fPort)); in Flush() 311 err = write_port_etc(fPort, kLinkCode, fBuffer, in Flush() 316 err = write_port(fPort, kLinkCode, fBuffer, fCurrentEnd); in Flush() 322 fCurrentEnd, strerror(err), fPort)); in Flush() 327 fCurrentEnd, fPort)); in Flush()
|
/haiku/src/add-ons/kernel/file_systems/userlandfs/kernel_add_on/ |
H A D | KernelRequestHandler.cpp | 236 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 245 return fPort->SendRequest(&allocator); in _HandleRequest() 270 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 279 return fPort->SendRequest(&allocator); in _HandleRequest() 333 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 342 return fPort->SendRequest(&allocator); in _HandleRequest() 360 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 368 return fPort->SendRequest(&allocator); in _HandleRequest() 382 RequestAllocator allocator(fPort->GetPort()); in _HandleRequest() 389 return fPort->SendRequest(&allocator); in _HandleRequest() [all …]
|
H A D | PortReleaser.h | 14 fPort(port) in PortReleaser() 20 if (fPort && fPortPool) in ~PortReleaser() 21 fPortPool->ReleasePort(fPort); in ~PortReleaser() 26 RequestPort* fPort; variable
|
H A D | KernelDebug.cpp | 76 kprintf(" status : %" B_PRIx32 "\n", port->fPort.fInitStatus); in DebugPort() 77 kprintf(" is owner : %d\n", port->fPort.fOwner); in DebugPort() 78 kprintf(" owner port: %" B_PRId32 "\n", port->fPort.fInfo.owner_port); in DebugPort() 79 kprintf(" client port: %" B_PRId32 "\n", port->fPort.fInfo.client_port); in DebugPort() 80 kprintf(" size: %" B_PRId32 "\n", port->fPort.fInfo.size); in DebugPort() 81 kprintf(" capacity: %" B_PRId32 "\n", port->fPort.fCapacity); in DebugPort() 82 kprintf(" buffer: %p\n", port->fPort.fBuffer); in DebugPort()
|
/haiku/src/add-ons/media/media-add-ons/radeon/ |
H A D | Theater.cpp | 18 : fPort(radeon), in CTheater() 50 return fPort.Register(fDevice, index); in Register() 55 return fPort.Register(fDevice, index) & mask; in Register() 60 fPort.SetRegister(fDevice, index, value); in SetRegister() 68 fPort.SetRegister(fDevice, index, in SetRegister() 69 (fPort.Register(fDevice, index) & ~mask) | (value & mask)); in SetRegister()
|
H A D | Tuner.cpp | 139 : fPort(port), in CTuner() 146 if( fPort.InitCheck() == B_OK ) { in CTuner() 152 fPort.Radeon().GetMMParameters(tuner, video, clock, dummy, dummy, dummy); in CTuner() 190 if (fPort.Probe(fAddress)) { in CTuner() 287 fPort.Read(fAddress, buffer, sizeof(buffer)); in Status() 322 fPort.Write(fAddress, buffer, sizeof(buffer)); in SetParameters()
|
/haiku/src/servers/app/ |
H A D | EventStream.cpp | 54 fPort(-1), in InputServerStream() 70 if (reply.FindInt32("event port", &fPort) != B_OK) in InputServerStream() 71 fPort = -1; in InputServerStream() 84 fPort = find_port(SERVER_INPUT_PORT); in InputServerStream() 99 if (fPort < B_OK || get_port_info(fPort, &portInfo) != B_OK) in IsValid() 110 write_port(fPort, 'quit', NULL, 0); in SendQuit() 139 fPort = -1; in GetNextEvent() 143 int32 count = port_count(fPort); in GetNextEvent() 208 status_t status = write_port_etc(fPort, 'insm', NULL, 0, B_RELATIVE_TIMEOUT, in InsertEvent() 235 bufferSize = port_buffer_size_etc(fPort, B_RELATIVE_TIMEOUT, timeout); in _MessageFromPort() [all …]
|
/haiku/src/kits/network/libnetapi/ |
H A D | NetAddress.cpp | 91 fPort = int16value; in BNetAddress() 110 fPort = other.fPort; in operator =() 155 *port = ntohs(fPort); in GetAddr() 192 sa.sin_port = fPort; in GetAddr() 231 *port = ntohs(fPort); in GetAddr() 280 if (into->AddInt16("bnaddr_port", fPort) != B_OK) in Archive() 359 fPort = htons(port); in SetTo() 375 fPort = addr.sin_port; in SetTo() 403 fPort = htons((short)port); in SetTo() 422 fPort = htons((short)port); in SetTo()
|
/haiku/src/tests/kits/net/service/ |
H A D | TestServer.cpp | 238 if (fPort.InitCheck() != B_OK) { in Start() 239 return fPort.InitCheck(); in Start() 247 child_process_args.push_back(to_string(fPort.Port())); in Start() 249 child_process_args.push_back(to_string(fPort.FileDescriptor())); in Start() 279 std::string port_string = to_string(fPort.Port()); in BaseUrl() 289 if (fPort.InitCheck() != B_OK) { in Start() 290 return fPort.InitCheck(); in Start() 297 child_process_args.push_back(to_string(fPort.Port())); in Start() 299 child_process_args.push_back(to_string(fPort.FileDescriptor())); in Start() 314 return fPort.Port(); in Port()
|
H A D | TestServer.h | 62 RandomTCPServerPort fPort; variable 73 RandomTCPServerPort fPort; variable
|
/haiku/headers/private/userlandfs/private/ |
H A D | RequestPort.h | 47 Port fPort; variable 55 : fPort(port), fRequest(request) {} in RequestReleaser() 59 if (fPort && fRequest) in ~RequestReleaser() 60 fPort->ReleaseRequest(fRequest); in ~RequestReleaser() 64 RequestPort* fPort;
|
/haiku/src/add-ons/kernel/file_systems/userlandfs/private/ |
H A D | RequestPort.cpp | 26 : fPort(size), in RequestPort() 33 : fPort(info), in RequestPort() 49 fPort.Close(); in Close() 56 return fPort.InitCheck(); in InitCheck() 63 return &fPort; in GetPort() 70 return fPort.GetInfo(); in GetPortInfo() 99 RETURN_ERROR(fPort.Send(allocator->GetRequest(), in SendRequest() 127 AllocatorNode* node = new(nothrow) AllocatorNode(&fPort); in ReceiveRequest()
|
H A D | RequestAllocator.cpp | 22 fPort(NULL), in RequestAllocator() 45 fPort = port; in Init() 46 fError = fPort->InitCheck(); in Init() 47 fPortReservedOffset = fPort->ReservedSize(); in Init() 57 fPort->Unreserve(fPortReservedOffset); in Uninit() 72 fPort = NULL; in Uninit() 116 || fRequestOffset + size > fPort->GetCapacity()) { in AllocateRequest() 120 fRequest = (Request*)((uint8*)fPort->GetBuffer() + fRequestOffset); in AllocateRequest() 123 fPort->Reserve(fRequestOffset + fRequestSize); in AllocateRequest() 137 status_t error = fPort->Receive(&message, &messageSize, timeout); in ReadRequest() [all …]
|
H A D | RequestHandler.cpp | 7 : fPort(NULL), in RequestHandler() 21 fPort = port; in SetPort()
|
/haiku/src/tests/kits/net/netservices2/ |
H A D | TestServer.cpp | 223 if (fPort.InitCheck() != B_OK) { in Start() 224 return fPort.InitCheck(); in Start() 238 child_process_args.push_back(to_string(fPort.Port())); in Start() 240 child_process_args.push_back(to_string(fPort.FileDescriptor())); in Start() 271 std::string port_string = to_string(fPort.Port()); in BaseUrl() 282 if (fPort.InitCheck() != B_OK) { in Start() 283 return fPort.InitCheck(); in Start() 296 child_process_args.push_back(to_string(fPort.Port())); in Start() 298 child_process_args.push_back(to_string(fPort.FileDescriptor())); in Start() 314 return fPort.Port(); in Port()
|
/haiku/src/add-ons/print/transports/hp_jetdirect/ |
H A D | HPJetDirectTransport.cpp | 26 fPort(9100), in HPJetDirectPort() 46 fPort = atoi(address.String() + index + 1); in HPJetDirectPort() 52 printf("fPort = %d\n", fPort); in HPJetDirectPort() 65 if (fEndpoint->Connect(fHost, fPort) == B_OK) { in HPJetDirectPort() 67 fHost.String(), fPort); in HPJetDirectPort()
|
/haiku/src/servers/syslog_daemon/ |
H A D | SyslogDaemon.cpp | 45 fPort = BLaunchRoster().GetPort("logger"); in ReadyToRun() 48 if (fPort >= 0 && fDaemon >= 0) { in ReadyToRun() 49 _kern_register_syslog_daemon(fPort); in ReadyToRun() 94 write_port(fPort, kQuitDaemon, NULL, 0); in QuitRequested() 141 ssize_t bytesRead = read_port(fPort, &code, &message, sizeof(buffer)); in _Daemon()
|
/haiku/src/tests/kits/app/bmessenger/ |
H A D | MessengerComparissonTester.cpp | 34 port_id fPort; member 54 return (a.fPort < b.fPort in operator <() 55 || a.fPort == b.fPort in operator <() 270 fake1.fPort = port1; in LessTest1() 285 fake2.fPort = port2; in LessTest1()
|