Searched refs:packet (Results 26 - 50 of 95) sorted by relevance

1234

/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/provider/
H A DAsyncProviderInvokerTube.java95 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 DMessageProviderArgumentBuilder.java44 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 DMemberSubmissionWsaServerTube.java62 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 DAbstractServerAsyncTransport.java70 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 DSOAPMessageContextImpl.java60 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 DMessageHandlerContextImpl.java47 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 DNoLoopbackPackets.java93 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 DMimeCodec.java112 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 DStreamSOAPCodec.java90 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 DRootOnlyCodec.java57 * @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 DAbstractFilterPipeImpl.java51 * you pass the packet to the next pipe:
113 public Packet process(Packet packet) { argument
114 return next.process(packet);
H A DAbstractTubeImpl.java60 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 DshmemBase.h47 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 DNextAction.java42 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 DCodec.java101 * 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 DFiber.java112 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 DSharedMemoryConnection.c100 * 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 DFastInfosetStreamSOAPCodec.java88 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 DoutStream.c64 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 DsocketTransport.c519 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 DRequestContext.java290 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 DStub.java287 * @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 DWsaTubeHelper.java166 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 DWsaClientTube.java83 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 DHeaderList.java675 * @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...]

Completed in 85 milliseconds

1234