/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/transport/ |
H A D | DeferredTransportPipe.java | 92 public NextAction processRequest(@NotNull Packet request) { argument 93 if(request.endpointAddress==address) 95 return transport.processRequest(request); 109 request.endpointAddress, 118 address = request.endpointAddress; 123 return transport.processRequest(request);
|
/openjdk7/jdk/src/share/sample/nio/server/ |
H A D | RequestHandler.java | 58 private Request request = null; field in class:RequestHandler 78 // Returns true when request is complete 99 // When parse is successfull, saves request and returns true 103 request = Request.parse(rbb); 115 Request.Action action = request.action(); 119 new StringContent(request.toString())); 122 new FileContent(request.uri()), action); 128 if (request == null) {
|
/openjdk7/jdk/test/java/nio/channels/ |
H A D | TestServers.java | 642 * Represents an UDP request received by the server. 646 protected final DatagramPacket request; field in class:TestServers.AbstractUdpServer.UdpRequestThread 649 protected UdpRequestThread(DatagramSocket socket, DatagramPacket request) { argument 651 this.request = request; 660 * @param socket the socket through which the request was received. 661 * @param request the datagram packet received through the socket. 662 * @return a new UdpRequestThread to handle the request received through 666 DatagramPacket request); 672 * @param socket the socket through which the request wa 665 createConnection(DatagramSocket socket, DatagramPacket request) argument 675 handle(DatagramSocket socket, DatagramPacket request) argument 718 createConnection(DatagramSocket socket, DatagramPacket request) argument 753 createConnection(DatagramSocket socket, DatagramPacket request) argument 760 UdpEchoRequest(DatagramSocket socket, DatagramPacket request) argument 809 createConnection(DatagramSocket socket, DatagramPacket request) argument 816 UdpDayTimeRequestThread(DatagramSocket socket, DatagramPacket request) argument [all...] |
/openjdk7/jdk/src/share/classes/sun/security/provider/certpath/ldap/ |
H A D | LDAPCertStore.java | 89 * We always request CA certificates, cross certificate pairs, and ARLs in 90 * a single LDAP request when any one of them is needed. The reason is that 94 * overhead. In addition, when the prefetchCRLs flag is true, we also request 96 * request for an ARL to the server returns an null value. The reason is 266 * LDAPRequest request = new LDAPRequest(dn); 267 * request.addRequestedAttribute(CROSS_CERT); 268 * request.addRequestedAttribute(CA_CERT); 269 * byte[][] crossValues = request.getValues(CROSS_CERT); 270 * byte[][] caValues = request.getValues(CA_CERT); 272 * At most one LDAP request i 419 getCertificates(LDAPRequest request, String id, X509CertSelector sel) argument 467 getCertPairs( LDAPRequest request, String id) argument 522 getMatchingCrossCerts( LDAPRequest request, X509CertSelector forward, X509CertSelector reverse) argument 696 getCRLs(LDAPRequest request, String id, X509CRLSelector sel) argument [all...] |
/openjdk7/jdk/src/share/classes/com/sun/tools/example/debug/tty/ |
H A D | ModificationWatchpointSpec.java | 38 import com.sun.jdi.request.EventRequestManager; 39 import com.sun.jdi.request.EventRequest;
|
/openjdk7/jdk/test/com/sun/jdi/ |
H A D | DeleteAllBkptsTest.java | 38 import com.sun.jdi.request.*; 86 BreakpointRequest request = erm.createBreakpointRequest( 90 //request.enable();
|
H A D | AfterThreadDeathTest.java | 37 import com.sun.jdi.request.*; 137 ThreadStartRequest request = erm.createThreadStartRequest(); 138 request.setSuspendPolicy(EventRequest.SUSPEND_ALL); 139 request.enable();
|
H A D | VMDeathRequestTest.java | 43 import com.sun.jdi.request.*; 73 if (event.request() == deathRequest) { 80 } else if (event.request() == null) {
|
H A D | ExceptionEvents.java | 65 import com.sun.jdi.request.*; 115 ExceptionRequest request; field in class:ExceptionEvents 369 if (event.request() == request) { 417 request = eventRequestManager().createExceptionRequest(exceptionClass, 419 request.addClassExclusionFilter("java.*"); 420 request.addClassExclusionFilter("sun.*"); 421 request.addClassExclusionFilter("com.sun.*"); 422 request.setSuspendPolicy(suspendPolicy); 423 request [all...] |
H A D | ExpiredRequestDeletionTest.java | 38 import com.sun.jdi.request.*; 77 EventRequest req = event.request(); 82 println("Got BreakpointEvent with null request"); 92 EventRequest req = event.request(); 97 println("Got StepEvent with null request");
|
H A D | FieldWatchpoints.java | 92 com.sun.jdi.request.EventRequest req = 94 req.setSuspendPolicy(com.sun.jdi.request.EventRequest.SUSPEND_ALL); 102 req.setSuspendPolicy(com.sun.jdi.request.EventRequest.SUSPEND_ALL);
|
H A D | InterruptHangTest.java | 14 import com.sun.jdi.request.*; 122 StepRequest request = erm.createStepRequest(mainThread, 125 request.enable();
|
H A D | TemplateTest.java | 40 import com.sun.jdi.request.*; 154 StepRequest request = erm.createStepRequest(mainThread, 157 request.enable();
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/protocol/ |
H A D | INSServerRequestDispatcher.java | 47 * INSServerRequestDispatcher handles all INS related discovery request. The INS Service 77 CorbaMessageMediator request = (CorbaMessageMediator) mediator; 80 String insKey = new String( request.getObjectKey().getBytes(orb) ); 81 request.getProtocolHandler() 82 .createLocationForward(request, getINSReference( insKey ), null);
|
/openjdk7/jdk/src/share/classes/com/sun/jmx/snmp/agent/ |
H A D | SnmpTableEntryFactory.java | 76 * @param request The SNMP subrequest containing the sublist of varbinds 88 public void createNewEntry(SnmpMibSubRequest request, SnmpOid rowOid, argument
|
/openjdk7/jdk/src/share/classes/com/sun/tools/example/debug/bdi/ |
H A D | SpecEvent.java | 39 import com.sun.jdi.request.EventRequest;
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/server/ |
H A D | AsyncProvider.java | 48 * of this request, and exit from this method immediately (the point of AWS is not 49 * to use this calling thread for request processing.) 65 * public void invoke( final Source request, final AsyncProviderCallback<Source> callback, final WebServiceContext context) { 69 * callback.send(request); // just echo back 84 * the calling {@link Thread} to determine which request it should return information about. 101 * Schedules an execution of a request. 103 * @param request 104 * Represents the request message or payload. 107 * of a request is complete. 110 * context information about the given request 112 invoke( @otNull T request, @NotNull AsyncProviderCallback<T> callback, @NotNull WebServiceContext context) argument [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/protocol/soap/ |
H A D | ServerMUTube.java | 67 * Do MU Header Processing on incoming message (request) 75 public NextAction processRequest(Packet request) { argument 76 Set<QName> misUnderstoodHeaders = getMisUnderstoodHeaders(request.getMessage().getHeaders(),roles, handlerKnownHeaders); 78 return doInvoke(super.next, request); 80 return doReturnWith(request.createServerResponse(createMUSOAPFaultMessage(misUnderstoodHeaders),
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/provider/ |
H A D | ProviderArgumentsBuilder.java | 50 protected Packet getResponse(Packet request, Exception e, WSDLPort port, WSBinding binding) { argument 52 Packet response = request.createServerResponse(message,port,null,binding); 67 protected Packet getResponse(Packet request, @Nullable T returnValue, WSDLPort port, WSBinding binding) { argument 72 Packet response = request.createServerResponse(message,port,null,binding);
|
/openjdk7/jdk/test/sun/net/www/protocol/http/ |
H A D | SetIfModifiedSince.java | 43 // assume we read the entire http request 48 String request = new String(b, 0, nread); 49 int pos = request.indexOf("If-Modified-Since:"); 54 if (request.charAt(pos) == (char)',') {
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/ |
H A D | WsaServerTube.java | 94 public @NotNull NextAction processRequest(Packet request) { argument 95 Message msg = request.getMessage(); 96 if(msg==null) return doInvoke(next,request); // hmm? 99 request.addSatellite(new WsaPropertyBag(addressingVersion,soapVersion,request)); 101 // Store request ReplyTo and FaultTo in requestPacket.invocationProperties 105 HeaderList hl = request.getMessage().getHeaders(); 114 if ((wsdlPort!=null) && request.getMessage().isOneWay(wsdlPort)) { 115 Packet response = request.createServerResponse(null, wsdlPort, null, binding); 125 Packet response = request [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/wsdl/ |
H A D | OperationDispatcher.java | 44 * This class abstracts the process of identifying the wsdl operation from a SOAP Message request. 45 * This is primarily for dispatching the request messages to an endpoint method. 69 * @param request Packet 73 public @NotNull QName getWSDLOperationQName(Packet request) throws DispatchException { argument 76 opName = finder.getWSDLOperationQName(request); 80 //No way to dispatch this request 82 request.soapAction, request.getMessage().getPayloadNamespaceURI(), 83 request.getMessage().getPayloadLocalPart());
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/ |
H A D | ServerSchemaValidationTube.java | 105 public NextAction processRequest(Packet request) { argument 106 if (isNoValidation() || !feature.isInbound() || !request.getMessage().hasPayload() || request.getMessage().isFault()) { 107 return super.processRequest(request); 110 doProcess(request); 113 // Client request is invalid. So sending specific fault code 119 return doReturnWith(request.createServerResponse(faultMsg, 122 return super.processRequest(request);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/client/ |
H A D | HttpTransportPipe.java | 62 * {@link Tube} that sends a request to a remote HTTP server. 121 public NextAction processRequest(@NotNull Packet request) { argument 122 return doReturnWith(process(request)); 130 public Packet process(Packet request) { argument 136 Map<String, List<String>> userHeaders = (Map<String, List<String>>) request.invocationProperties.get(MessageContext.HTTP_REQUEST_HEADERS); 150 addBasicAuth(request, reqHeaders); 151 addCookies(request, reqHeaders); 153 con = new HttpClientTransport(request,reqHeaders); 154 request.addSatellite(new HttpResponseProperties(con)); 156 ContentType ct = codec.getStaticContentType(request); 211 createResponsePacket(Packet request, HttpClientTransport con) argument [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/ |
H A D | ClientSchemaValidationTube.java | 112 public NextAction processRequest(Packet request) { argument 113 if (isNoValidation() || !feature.isOutbound() || !request.getMessage().hasPayload() || request.getMessage().isFault()) { 114 return super.processRequest(request); 117 doProcess(request); 121 return super.processRequest(request);
|