// Then
            assertTrue(fileFsSizeInfo.getCapacity() > 0);
            assertEquals(0L, fileFsSizeInfo.getFree());
        }

        @Test
        @DisplayName("Should handle empty disk scenario")
        void shouldHandleEmptyDiskScenario() throws SMBProtocolDecodingException {
            // Given - disk with all space free
            long totalUnits = 1000000L;

                sink.write(postBytes) // push bytes into the stream's buffer
                sink.flush() // Http2Connection.writeData subject to write window
                sink.close() // Http2Connection.writeData empty frame
              }
            },
        ),
      )
    val response = call.execute()
    assertThat(response.body.string()).isEqualTo("ABCDE")
    val request = server.takeRequest()

  @Throws(IOException::class)
  fun peekTrailers(): Headers? {
    withLock {
      if (source.finished && source.receiveBuffer.exhausted() && source.readBuffer.exhausted()) {
        return source.trailers ?: Headers.EMPTY
      }
      if (errorCode != null) {
        throw errorException ?: StreamResetException(errorCode!!)
      }
      return null
    }
  }

  /**
   * Sends a reply to an incoming stream.

        }
    }

    private static String checkName(final String name) throws MalformedURLException {
        if (name == null || name.length() == 0) {
            throw new MalformedURLException("Name must not be empty");
        }
        return name;
    }

    /**
     * Sets whether this file should use an exclusive (non-pooled) connection
     *
     * @param nonPooled

		}

		if requestUser != svcAccount.ParentUser {
			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAccessDenied), r.URL)
			return
		}
	}

	// if session policy is nil or empty, then it is implied policy
	impliedPolicy := sessionPolicy == nil || (sessionPolicy.Version == "" && len(sessionPolicy.Statements) == 0)

	var svcAccountPolicy policy.Policy

	if !impliedPolicy {

	return 0
}

// operand parses a general operand and stores the result in *a.
func (p *Parser) operand(a *obj.Addr) {
	//fmt.Printf("Operand: %v\n", p.input)
	if len(p.input) == 0 {
		p.errorf("empty operand: cannot happen")
		return
	}
	// General address (with a few exceptions) looks like
	//	$sym±offset(SB)(reg)(index*scale)
	// Exceptions are:
	//
	//	R1
	//	offset
	//	$offset

* Patch CVE-2016-8859 in alpine based images: ([#42937](https://github.com/kubernetes/kubernetes/pull/42937), [@timstclair](https://github.com/timstclair))
    * - gcr.io/google-containers/etcd-empty-dir-cleanup
    * - gcr.io/google-containers/kube-dnsmasq-amd64
* Check if pathExists before performing Unmount ([#39311](https://github.com/kubernetes/kubernetes/pull/39311), [@rkouj](https://github.com/rkouj))

              "${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)",
          ),
        isWriter = true,
      )
      return
    }

    try {
      writer.writePing(ByteString.EMPTY)
    } catch (e: IOException) {
      failWebSocket(e = e, isWriter = true)
    }
  }

  fun failWebSocket(
    e: Exception,
    response: Response? = null,
    isWriter: Boolean = false,
  ) {

    list.set(2, 2.0);
    assertThat(iia.asList()).containsExactly(0.0, 1.0, 3.0).inOrder();
  }

  public void testCopyOf_stream() {
    assertThat(ImmutableDoubleArray.copyOf(DoubleStream.empty()))
        .isSameInstanceAs(ImmutableDoubleArray.of());
    assertThat(ImmutableDoubleArray.copyOf(DoubleStream.of(0, 1, 3)).asList())
        .containsExactly(0.0, 1.0, 3.0)
        .inOrder();
  }

        bb.putShort((short) 0);
        bb.putShort((short) 5);
        bb.putShort((short) 300);
        bb.putShort((short) 22);
        bb.putShort((short) 24);
        bb.putShort((short) 26);

        // Empty strings (just null terminators)
        bb.position(22);
        bb.putShort((short) 0);
        bb.position(24);
        bb.putShort((short) 0);
        bb.position(26);
        bb.putShort((short) 0);