/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/provider/ |
H A D | AsyncProviderInvokerTube.java | 95 Packet packet = argsBuilder.getResponse(request, param, getEndpoint().getPort(), getEndpoint().getBinding()); 96 fiber.resume(packet); 106 Packet packet = argsBuilder.getResponse(request, e, getEndpoint().getPort(), getEndpoint().getBinding()); 107 fiber.resume(packet); 115 final Packet packet; field in class:AsyncProviderInvokerTube.AsyncWebServiceContext 117 AsyncWebServiceContext(WSEndpoint endpoint, Packet packet) { argument 119 this.packet = packet; 123 return packet;
|
H A D | MessageProviderArgumentBuilder.java | 44 protected Message getParameter(Packet packet) { argument 45 return packet.getMessage();
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/v200408/ |
H A D | MemberSubmissionWsaServerTube.java | 62 protected void checkMandatoryHeaders(Packet packet, boolean foundAction, boolean foundTo, boolean foundReplyTo, argument 65 super.checkMandatoryHeaders(packet, foundAction, foundTo, foundReplyTo, 70 throw new MissingAddressingHeaderException(addressingVersion.toTag,packet); 74 WSDLBoundOperation wbo = getWSDLBoundOperation(packet); 79 throw new MissingAddressingHeaderException(addressingVersion.replyToTag,packet); 85 throw new MissingAddressingHeaderException(addressingVersion.messageIDTag,packet);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/server/ |
H A D | AbstractServerAsyncTransport.java | 70 Packet packet = new Packet(); 71 packet.acceptableMimeTypes = getAcceptableMimeTypes(connection); 72 packet.addSatellite(getPropertySet(connection)); 73 packet.transportBackChannel = getTransportBackChannel(connection); 74 return packet; 81 * @param packet that needs to encoded to infoset 85 protected abstract void encodePacket(T connection, @NotNull Packet packet, @NotNull Codec codec) throws IOException; argument
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/handler/ |
H A D | SOAPMessageContextImpl.java | 60 public SOAPMessageContextImpl(WSBinding binding, Packet packet,Set<String> roles) { argument 61 super(packet); 69 soapMsg = packet.getMessage().readAsSOAPMessage(); 87 packet.setMessage(newMessage); 96 packet.setMessage(new SAAJMessage(soapMsg)); 106 Iterator<Header> itr = packet.getMessage().getHeaders().getHeaders(header,false);
|
H A D | MessageHandlerContextImpl.java | 47 public MessageHandlerContextImpl(@Nullable SEIModel seiModel, WSBinding binding, @Nullable WSDLPort wsdlModel, Packet packet, Set<String> roles) { argument 48 super(packet); 55 return packet.getMessage(); 59 packet.setMessage(message);
|
/openjdk7/jdk/test/java/net/MulticastSocket/ |
H A D | NoLoopbackPackets.java | 93 DatagramPacket packet = new DatagramPacket(buf, 0, buf.length); 98 msock.receive(packet); 133 DatagramPacket packet = new DatagramPacket(buf, buf.length, group); 134 packets.add(packet); 140 for (DatagramPacket packet : packets) { 141 msock.send(packet);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/encoding/ |
H A D | MimeCodec.java | 112 public ContentType encode(Packet packet, OutputStream out) throws IOException { argument 113 Message msg = packet.getMessage(); 120 ContentType ct = rootCodec.getStaticContentType(packet); 125 ContentType primaryCt = rootCodec.encode(packet, out); 148 return hasAttachments ? new ContentTypeImpl(messageContentType, packet.soapAction, null) : primaryCt; 151 public ContentType getStaticContentType(Packet packet) { argument 152 Message msg = packet.getMessage(); 162 return new ContentTypeImpl(messageContentType, packet.soapAction, null); 164 return rootCodec.getStaticContentType(packet); 176 public void decode(InputStream in, String contentType, Packet packet) throw argument 181 decode(ReadableByteChannel in, String contentType, Packet packet) argument 188 decode(MimeMultipartParser mpp, Packet packet) argument [all...] |
H A D | StreamSOAPCodec.java | 90 public ContentType getStaticContentType(Packet packet) { argument 91 return getContentType(packet.soapAction); 94 public ContentType encode(Packet packet, OutputStream out) { argument 95 if (packet.getMessage() != null) { 98 packet.getMessage().writeTo(writer); 105 return getContentType(packet.soapAction); 110 public ContentType encode(Packet packet, WritableByteChannel buffer) { argument 117 public void decode(InputStream in, String contentType, Packet packet) throws IOException { argument 118 decode(in, contentType, packet, new AttachmentSetImpl()); 226 public void decode(ReadableByteChannel in, String contentType, Packet packet ) { 281 decode(InputStream in, String contentType, Packet packet, AttachmentSet att ) argument [all...] |
H A D | RootOnlyCodec.java | 57 * @param packet the new created {@link Message} is set in this packet 64 void decode(@NotNull InputStream in, @NotNull String contentType, @NotNull Packet packet, @NotNull AttachmentSet att) argument 71 void decode(@NotNull ReadableByteChannel in, @NotNull String contentType, @NotNull Packet packet, @NotNull AttachmentSet att); argument
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/helper/ |
H A D | AbstractFilterPipeImpl.java | 51 * you pass the packet to the next pipe: 113 public Packet process(Packet packet) { argument 114 return next.process(packet);
|
H A D | AbstractTubeImpl.java | 60 protected final NextAction doInvoke(Tube next, Packet packet) { argument 62 na.invoke(next,packet); 66 protected final NextAction doInvokeAndForget(Tube next, Packet packet) { argument 68 na.invokeAndForget(next,packet);
|
/openjdk7/jdk/src/share/transport/shmem/ |
H A D | shmemBase.h | 47 jint shmemBase_sendPacket(SharedMemoryConnection *, const jdwpPacket *packet); 48 jint shmemBase_receivePacket(SharedMemoryConnection *, jdwpPacket *packet);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/pipe/ |
H A D | NextAction.java | 42 Packet packet; field in class:NextAction 59 this.packet = p; 67 * with the response packet. 76 * but the current tube doesn't want to receive the response packet to 127 return packet; 143 buf.append("packet=").append(packet).append(',');
|
H A D | Codec.java | 101 * encodin the packet. Otherwise content type for this {@link Packet}, 104 ContentType getStaticContentType(Packet packet); argument 114 * @param packet 126 ContentType encode( Packet packet, OutputStream out ) throws IOException; argument 136 ContentType encode( Packet packet, WritableByteChannel buffer ); argument
|
H A D | Fiber.java | 112 private Packet packet; field in class:Fiber 231 * The first tube of the tubeline that will act on the packet. 233 * The request packet to be passed to <tt>startPoint.processRequest()</tt>. 236 * final response packet is available. 242 this.packet = request; 250 this.packet = request; 264 * packet as the parameter. 270 * specified resume packet as the parameter. 277 * @param resumePacket packet used in the resumed processing 282 packet [all...] |
/openjdk7/jdk/src/share/native/com/sun/tools/jdi/ |
H A D | SharedMemoryConnection.c | 100 * Create a byte[] from a packet struct. All data in the byte array 101 * is JDWP packet suitable for wire transmission. That is, all fields, 116 /* total packet length is header + data */ 122 /* First 4 bytes of packet are the length (in big endian format) */ 156 * Fill a packet struct from a byte array. The byte array is a 157 * JDWP packet suitable for wire transmission. That is, all fields, 164 * the JDWP packet that is contains. 174 * Get the packet header 192 /* command packet */ 198 * The length of the JDWP packet i 224 freePacketData(jdwpPacket *packet) argument 272 jdwpPacket packet; local 314 jdwpPacket packet; local [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/encoding/fastinfoset/ |
H A D | FastInfosetStreamSOAPCodec.java | 88 public ContentType getStaticContentType(Packet packet) { argument 89 return getContentType(packet.soapAction); 92 public ContentType encode(Packet packet, OutputStream out) { argument 93 if (packet.getMessage() != null) { 96 packet.getMessage().writeTo(writer); 102 return getContentType(packet.soapAction); 105 public ContentType encode(Packet packet, WritableByteChannel buffer) { argument
|
/openjdk7/jdk/src/share/back/ |
H A D | outStream.c | 64 stream->packet.type.cmd.id = id; 65 stream->packet.type.cmd.cmdSet = commandSet; 66 stream->packet.type.cmd.cmd = command; 68 stream->packet.type.cmd.flags = flags; 79 stream->packet.type.reply.id = id; 80 stream->packet.type.reply.errorCode = 0x0; 81 stream->packet.type.cmd.flags = (jbyte)JDWPTRANSPORT_FLAGS_REPLY; 87 return stream->packet.type.cmd.id; 94 JDI_ASSERT(!(stream->packet.type.cmd.flags & JDWPTRANSPORT_FLAGS_REPLY)); 95 return stream->packet [all...] |
/openjdk7/jdk/src/share/transport/socket/ |
H A D | socketTransport.c | 519 socketTransport_writePacket(jdwpTransportEnv* env, const jdwpPacket *packet) argument 528 /* packet can't be null */ 529 if (packet == NULL) { 530 RETURN_ERROR(JDWPTRANSPORT_ERROR_ILLEGAL_ARGUMENT, "packet is NULL"); 533 len = packet->type.cmd.len; /* includes header */ 536 /* bad packet */ 543 id = (jint)dbgsysHostToNetworkLong(packet->type.cmd.id); 547 header[8] = packet->type.cmd.flags; 548 if (packet->type.cmd.flags & JDWPTRANSPORT_FLAGS_REPLY) { 550 dbgsysHostToNetworkShort(packet 614 socketTransport_readPacket(jdwpTransportEnv* env, jdwpPacket* packet) argument [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/ |
H A D | RequestContext.java | 290 public void fill(Packet packet, boolean isAddressingEnabled) { argument 293 packet.endpointAddress = endpointAddress; 294 packet.contentNegotiation = contentNegotiation; 303 packet.soapAction = soapAction; 311 packet.invocationProperties.putAll(others); 313 packet.getHandlerScopePropertyNames(false).addAll(others.keySet()); 320 if(packet.supports(key)) 321 packet.put(key,entry.getValue()); 323 packet.invocationProperties.put(key,entry.getValue()); 332 packet [all...] |
H A D | Stub.java | 287 * @param packet The message to be sent to the server 297 protected final Packet process(Packet packet, RequestContext requestContext, ResponseContextReceiver receiver) { argument 298 configureRequestPacket(packet, requestContext); 308 return fiber.runSync(tube, packet); 310 // this allows us to capture the packet even when the call failed with an exception. 316 Packet reply = (fiber.getPacket() == null) ? packet : fiber.getPacket(); 323 private void configureRequestPacket(Packet packet, RequestContext requestContext) { argument 325 packet.proxy = this; 326 packet.handlerConfig = binding.getHandlerConfig(); 327 requestContext.fill(packet,(bindin [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/ |
H A D | WsaTubeHelper.java | 166 public String getInputAction(Packet packet) { argument 170 QName wsdlOp = packet.getWSDLOperation(); 185 * @param packet 188 public String getEffectiveInputAction(Packet packet) { argument 190 if(packet.soapAction != null && !packet.soapAction.equals("")) 191 return packet.soapAction; 195 QName wsdlOp = packet.getWSDLOperation(); 201 action = packet.soapAction; 203 action = packet 208 isInputActionDefault(Packet packet) argument 220 getSOAPAction(Packet packet) argument 238 getOutputAction(Packet packet) argument [all...] |
H A D | WsaClientTube.java | 83 protected void validateAction(Packet packet) { argument 86 WSDLBoundOperation wbo = getWSDLBoundOperation(packet); 90 String gotA = packet.getMessage().getHeaders().getAction(addressingVersion, soapVersion); 94 String expected = helper.getOutputAction(packet);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/message/ |
H A D | HeaderList.java | 675 * @param packet request packet 682 public void fillRequestAddressingHeaders(Packet packet, AddressingVersion av, SOAPVersion sv, boolean oneway, String action, boolean mustUnderstand) { argument 683 fillCommonAddressingHeaders(packet, av, sv, action, mustUnderstand); 692 Header h = new StringHeader(av.messageIDTag, packet.getMessage().getID(av, sv)); 697 public void fillRequestAddressingHeaders(Packet packet, AddressingVersion av, SOAPVersion sv, boolean oneway, String action) { argument 698 fillRequestAddressingHeaders(packet,av,sv,oneway,action,false); 718 * @param packet request packet 720 public void fillRequestAddressingHeaders(WSDLPort wsdlPort, @NotNull WSBinding binding, Packet packet) { argument 763 fillRequestAddressingHeaders(@otNull Packet packet, @NotNull AddressingVersion av, @NotNull SOAPVersion sv, @NotNull OneWayFeature of, @NotNull String action) argument 795 fillCommonAddressingHeaders(Packet packet, @NotNull AddressingVersion av, @NotNull SOAPVersion sv, @NotNull String action, boolean mustUnderstand) argument [all...] |