/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/transport/http/ |
H A D | HttpAdapter.java | 306 Packet packet = new Packet(); 307 packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction")); 308 packet.wasTransportSecure = con.isSecure(); 309 packet.acceptableMimeTypes = con.getRequestHeader("Accept"); 310 packet.addSatellite(con); 311 packet.transportBackChannel = new Oneway(con); 312 packet.webServiceContextDelegate = con.getWebServiceContextDelegate(); 321 codec.decode(in, ct, packet); 322 return packet; 346 private void encodePacket(@NotNull Packet packet, argument 431 addReplicaCookie(WSHTTPConnection con, Packet packet) argument 521 encodePacket(WSHTTPConnection con, @NotNull Packet packet, @NotNull Codec codec) argument [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/encoding/fastinfoset/ |
H A D | FastInfosetCodec.java | 84 public ContentType getStaticContentType(Packet packet) { argument 88 public ContentType encode(Packet packet, OutputStream out) { argument 89 Message message = packet.getMessage(); 94 packet.getMessage().writePayloadTo(writer); 105 public ContentType encode(Packet packet, WritableByteChannel buffer) { argument 110 public void decode(InputStream in, String contentType, Packet packet) throws IOException { argument 122 packet.setMessage(message);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/provider/ |
H A D | SOAPProviderArgumentBuilder.java | 80 protected Source getParameter(Packet packet) { argument 81 return packet.getMessage().readPayloadAsSource(); 99 protected Source getParameter(Packet packet) { argument 100 return packet.getMessage().readEnvelopeAsSource(); 117 protected SOAPMessage getParameter(Packet packet) { argument 119 return packet.getMessage().readAsSOAPMessage(packet, true);
|
H A D | XMLProviderArgumentBuilder.java | 73 public Source getParameter(Packet packet) { argument 74 return packet.getMessage().readPayloadAsSource(); 92 public DataSource getParameter(Packet packet) { argument 93 Message msg = packet.getMessage();
|
/openjdk7/jdk/src/share/transport/shmem/ |
H A D | shmemBack.c | 268 shmemWritePacket(jdwpTransportEnv* env, const jdwpPacket *packet) argument 270 if (packet == NULL) { 271 RETURN_ERROR(JDWPTRANSPORT_ERROR_ILLEGAL_ARGUMENT, "packet is null"); 273 if (packet->type.cmd.len < 11) { 279 if (shmemBase_sendPacket(connection, packet) == SYS_OK) { 282 RETURN_IO_ERROR("write packet failed"); 287 shmemReadPacket(jdwpTransportEnv* env, jdwpPacket *packet) argument 289 if (packet == NULL) { 290 RETURN_ERROR(JDWPTRANSPORT_ERROR_ILLEGAL_ARGUMENT, "packet is null"); 295 if (shmemBase_receivePacket(connection, packet) [all...] |
H A D | shmemBase.c | 1029 * Send packet header followed by data. 1032 shmemBase_sendPacket(SharedMemoryConnection *connection, const jdwpPacket *packet) argument 1038 CHECK_ERROR(sendBytes(connection, &packet->type.cmd.id, sizeof(jint))); 1039 CHECK_ERROR(sendBytes(connection, &packet->type.cmd.flags, sizeof(jbyte))); 1041 if (packet->type.cmd.flags & JDWPTRANSPORT_FLAGS_REPLY) { 1042 CHECK_ERROR(sendBytes(connection, &packet->type.reply.errorCode, sizeof(jshort))); 1044 CHECK_ERROR(sendBytes(connection, &packet->type.cmd.cmdSet, sizeof(jbyte))); 1045 CHECK_ERROR(sendBytes(connection, &packet->type.cmd.cmd, sizeof(jbyte))); 1048 data_length = packet->type.cmd.len - 11; 1053 CHECK_ERROR(sendBytes(connection, packet 1102 shmemBase_receivePacket(SharedMemoryConnection *connection, jdwpPacket *packet) argument [all...] |
/openjdk7/jdk/src/share/back/ |
H A D | inStream.c | 41 inStream_init(PacketInputStream *stream, jdwpPacket packet) argument 43 stream->packet = packet; 45 stream->left = packet.type.cmd.len; 46 stream->current = packet.type.cmd.data; 56 return stream->packet.type.cmd.id; 62 return stream->packet.type.cmd.cmd; 483 if (stream->packet.type.cmd.data != NULL) { 484 jvmtiDeallocate(stream->packet.type.cmd.data);
|
H A D | inStream.h | 38 jdwpPacket packet; member in struct:PacketInputStream 42 void inStream_init(PacketInputStream *stream, jdwpPacket packet);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/dispatch/ |
H A D | SOAPMessageDispatch.java | 76 Packet packet = new Packet(new SAAJMessage(arg)); 77 packet.invocationProperties.put(MessageContext.HTTP_REQUEST_HEADERS, ch); 78 return packet;
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/encoding/ |
H A D | StreamSOAP12Codec.java | 80 public void decode(InputStream in, String contentType, Packet packet, AttachmentSet att ) throws IOException { argument 82 packet.soapAction = fixQuotesAroundSoapAction(ct.getParameter("action")); 83 super.decode(in,contentType,packet,att);
|
H A D | MtomCodec.java | 120 public ContentType getStaticContentType(Packet packet) { argument 121 return getContentType(packet); 124 private ContentType getContentType(Packet packet){ argument 127 return new ContentTypeImpl(messageContentType, (packet.soapAction == null)?"":packet.soapAction, null); 129 if(packet.soapAction != null){ 130 messageContentType += ";action=\""+packet.soapAction+"\""; 138 public ContentType encode(Packet packet, OutputStream out) throws IOException { argument 140 ContentType contentType = getContentType(packet); 142 if(packet 216 encode(Packet packet, WritableByteChannel buffer) argument 231 decode(MimeMultipartParser mpp, Packet packet) argument [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/util/pipe/ |
H A D | DumpTube.java | 97 protected void dump(String header, Packet packet) { argument 99 if(packet.getMessage()==null) 110 packet.getMessage().copy().writeTo(writer);
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/ |
H A D | W3CWsaServerTube.java | 70 Packet packet, boolean foundAction, boolean foundTo, boolean foundReplyTo, 72 super.checkMandatoryHeaders(packet, foundAction, foundTo, foundReplyTo, 76 WSDLBoundOperation wbo = getWSDLBoundOperation(packet); 81 throw new MissingAddressingHeaderException(addressingVersion.messageIDTag,packet); 69 checkMandatoryHeaders( Packet packet, boolean foundAction, boolean foundTo, boolean foundReplyTo, boolean foundFaultTo, boolean foundMessageId, boolean foundRelatesTo) argument
|
/openjdk7/jdk/src/share/classes/sun/management/jdp/ |
H A D | JdpBroadcaster.java | 40 * JdpBroadcaster is responsible for sending pre-built JDP packet across a Net 62 * @param ttl - packet ttl 96 * @param ttl - packet ttl 105 * Broadcast pre-built packet 107 * @param packet - instance of JdpPacket 110 public void sendPacket(JdpPacket packet) argument 112 byte[] data = packet.getPacketData();
|
H A D | JdpPacketReader.java | 37 * JdpPacketReader responsible for reading a packet <p>This class gets a byte 46 * Create packet reader, extract and check magic and version 48 * @param packet - packet received from a Net 51 public JdpPacketReader(byte[] packet) argument 53 ByteArrayInputStream bais = new ByteArrayInputStream(packet); 60 throw new JdpException("Invalid JDP packet received, bad magic"); 67 throw new JdpException("Invalid JDP packet received, bad protocol version"); 72 * Get next entry from packet 86 throw new JdpException("Broken JDP packet [all...] |
/openjdk7/jdk/test/java/net/MulticastSocket/ |
H A D | SetOutgoingIf.java | 133 // try to receive on each group, then check if the packet comes 142 DatagramPacket packet = new DatagramPacket(buf, 0, buf.length); 149 mcastsock.receive(packet); 150 debug("received packet on " + packet.getAddress()); 156 // now check which network interface this packet comes from 157 NetworkInterface from = NetworkInterface.getByInetAddress(packet.getAddress()); 205 for (DatagramPacket packet : packets) 206 mcastsock.send(packet);
|
/openjdk7/jdk/src/macosx/native/com/sun/media/sound/ |
H A D | PLATFORM_API_MacOSX_MidiUtils.c | 263 // This function processes the packet and adds the messages to the specified message queue. 265 static void processMessagesForPacket(const MIDIPacket* packet, MacMidiDeviceHandle* handle) { argument 273 MIDITimeStamp ts = packet->timeStamp; 278 data = packet->data; 279 length = packet->length; 416 const MIDIPacket* packet; local 419 packet = packetList->packet; 421 processMessagesForPacket(packet, handle); 422 packet [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/handler/ |
H A D | LogicalMessageImpl.java | 70 private Packet packet; field in class:LogicalMessageImpl 76 packet) { 78 this.packet = packet; 84 Source payload = packet.getMessage().copy().readPayloadAsSource(); 119 o = packet.getMessage().copy().readPayloadAsJAXB(context.createUnmarshaller()); 158 return packet.getMessage(); 75 LogicalMessageImpl(JAXBContext defaultJaxbContext, Packet packet) argument
|
H A D | ClientSOAPHandlerTube.java | 107 MessageUpdatableContext getContext(Packet packet) { argument 108 SOAPMessageContextImpl context = new SOAPMessageContextImpl(binding, packet,roles); 117 AttachmentSet attSet = packet.getMessage().getAttachments();
|
H A D | ServerLogicalHandlerTube.java | 126 MessageUpdatableContext getContext(Packet packet) { argument 127 return new LogicalMessageContextImpl(binding, (seiModel!= null?seiModel.getJAXBContext():null), packet); 150 AttachmentSet attSet = packet.getMessage().getAttachments();
|
H A D | ServerMessageHandlerTube.java | 87 AttachmentSet attSet = packet.getMessage().getAttachments(); 135 MessageUpdatableContext getContext(Packet packet) { argument 136 MessageHandlerContextImpl context = new MessageHandlerContextImpl(seiModel, binding, port, packet, roles);
|
H A D | ServerSOAPHandlerTube.java | 113 MessageUpdatableContext getContext(Packet packet) { argument 114 SOAPMessageContextImpl context = new SOAPMessageContextImpl(binding, packet,roles); 140 AttachmentSet attSet = packet.getMessage().getAttachments();
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/server/ |
H A D | InvokerTube.java | 80 // this allows WebServiceContext to find this packet 109 * Remembers which thread is serving which packet. 115 * synchronously, to obtain the current request packet. 121 Packet packet = packets.get(); 122 if(packet==null) 124 return packet; 128 * {@link Invoker} filter that sets and restores the current packet.
|
/openjdk7/jdk/src/solaris/native/java/net/ |
H A D | PlainDatagramSocketImpl.c | 407 jobject packet) { 434 if (IS_NULL(packet)) { 435 JNU_ThrowNullPointerException(env, "packet"); 441 packetBuffer = (*env)->GetObjectField(env, packet, dp_bufID); 442 packetAddress = (*env)->GetObjectField(env, packet, dp_addressID); 448 packetBufferOffset = (*env)->GetIntField(env, packet, dp_offsetID); 449 packetBufferLen = (*env)->GetIntField(env, packet, dp_lengthID); 460 packetPort = (*env)->GetIntField(env, packet, dp_portID); 476 * than 65,536 (0xFFFF) the max size of an IP packet. 632 jobject packet) { 406 Java_java_net_PlainDatagramSocketImpl_send(JNIEnv *env, jobject this, jobject packet) argument 631 Java_java_net_PlainDatagramSocketImpl_peekData(JNIEnv *env, jobject this, jobject packet) argument 808 Java_java_net_PlainDatagramSocketImpl_receive0(JNIEnv *env, jobject this, jobject packet) argument [all...] |
/openjdk7/jdk/src/windows/native/java/net/ |
H A D | TwoStacksPlainDatagramSocketImpl.c | 637 jobject packet) { 657 if (IS_NULL(packet)) { 658 JNU_ThrowNullPointerException(env, "null packet"); 662 iaObj = (*env)->GetObjectField(env, packet, dp_addressID); 664 packetPort = (*env)->GetIntField(env, packet, dp_portID); 665 packetBufferOffset = (*env)->GetIntField(env, packet, dp_offsetID); 666 packetBuffer = (jbyteArray)(*env)->GetObjectField(env, packet, dp_bufID); 693 packetBufferLen = (*env)->GetIntField(env, packet, dp_lengthID); 739 * than 65,536 (0xFFFF) the max size of an IP packet. 918 jobject packet) { 636 Java_java_net_TwoStacksPlainDatagramSocketImpl_send(JNIEnv *env, jobject this, jobject packet) argument 917 Java_java_net_TwoStacksPlainDatagramSocketImpl_peekData(JNIEnv *env, jobject this, jobject packet) argument 1188 Java_java_net_TwoStacksPlainDatagramSocketImpl_receive0(JNIEnv *env, jobject this, jobject packet) argument [all...] |